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

Update accumulated_pts_count_ when a pending pts update is processed.

Browse Source
This commit is contained in:
levlam 2021-08-16 14:02:15 +03:00
parent c19a0751f0
commit 7ac3c2bdb9
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
td/telegram/UpdatesManager.cpp
View File

@ -2155,6 +2155,12 @@ void UpdatesManager::process_pending_pts_updates() {
td_->messages_manager_->process_pts_update(std::move(update.update)); td_->messages_manager_->process_pts_update(std::move(update.update));
set_pts(update.pts, "process_pending_pts_updates") set_pts(update.pts, "process_pending_pts_updates")
.set_value(Unit()); // TODO can't set until data are really stored on persistent storage .set_value(Unit()); // TODO can't set until data are really stored on persistent storage
if (accumulated_pts_ != -1) {
CHECK(update.pts <= accumulated_pts_);
CHECK(accumulated_pts_count_ >= update.pts_count);
accumulated_pts_count_ -= update.pts_count;
}
} }
update.promise.set_value(Unit()); update.promise.set_value(Unit());
pending_pts_updates_.erase(update_it); pending_pts_updates_.erase(update_it);