tdlight-team/tdlight
tdlight-team/tdlight
1
1
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Improve check in MultiTimeout::update_timeout.

Browse Source
This commit is contained in:
levlam 2023-03-21 12:25:01 +03:00
parent cf9866cfe4
commit 52509b20a8
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
tdactor/td/actor/MultiTimeout.cpp
View File

@ -69,8 +69,17 @@ void MultiTimeout::update_timeout(const char *source) {
if (items_.empty()) {
LOG(DEBUG) << "Cancel timeout of " << get_name();
LOG_CHECK(timeout_queue_.empty()) << get_name() << ' ' << source;
LOG_CHECK(Actor::has_timeout()) << get_name() << ' ' << source;
Actor::cancel_timeout();
if (!Actor::has_timeout()) {
bool has_pending_timeout = false;
for (auto &event : get_info()->mailbox_) {
if (event.type == Event::Type::Timeout) {
has_pending_timeout = true;
}
}
LOG_CHECK(has_pending_timeout) << get_name() << ' ' << get_info()->mailbox_.size() << ' ' << source;
} else {
Actor::cancel_timeout();
}
} else {
LOG(DEBUG) << "Set timeout of " << get_name() << " in " << timeout_queue_.top_key() - Time::now_cached();
Actor::set_timeout_at(timeout_queue_.top_key());