Fix ConcurrentScheduler guard usage.

GitOrigin-RevId: 6f4dd470a690cdbe98870c89433634b31136f832
This commit is contained in:
levlam 2020-10-10 22:05:20 +03:00
parent 84ea5b06c9
commit 2850e596d3

View File

@ -129,14 +129,13 @@ class ClientManager::Impl final {
response.object->get_id() == td_api::updateAuthorizationState::ID && response.object->get_id() == td_api::updateAuthorizationState::ID &&
static_cast<const td_api::updateAuthorizationState *>(response.object.get())->authorization_state_->get_id() == static_cast<const td_api::updateAuthorizationState *>(response.object.get())->authorization_state_->get_id() ==
td_api::authorizationStateClosed::ID) { td_api::authorizationStateClosed::ID) {
CHECK(concurrent_scheduler_ != nullptr);
auto guard = concurrent_scheduler_->get_main_guard(); auto guard = concurrent_scheduler_->get_main_guard();
auto it = tds_.find(response.client_id); auto it = tds_.find(response.client_id);
CHECK(it != tds_.end()); CHECK(it != tds_.end());
it->second.reset(); it->second.reset();
} }
if (response.object == nullptr && response.client_id != 0 && response.request_id == 0) { if (response.object == nullptr && response.client_id != 0 && response.request_id == 0) {
CHECK(concurrent_scheduler_ != nullptr);
auto guard = concurrent_scheduler_->get_main_guard();
auto it = tds_.find(response.client_id); auto it = tds_.find(response.client_id);
CHECK(it != tds_.end()); CHECK(it != tds_.end());
CHECK(it->second.empty()); CHECK(it->second.empty());