From 24664db3cbd17a6ad2fb49cf7f5648e34ca37609 Mon Sep 17 00:00:00 2001 From: levlam Date: Fri, 15 Jan 2021 19:00:17 +0300 Subject: [PATCH] Forcely process qts updates in process_updates. --- td/telegram/UpdatesManager.cpp | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) diff --git a/td/telegram/UpdatesManager.cpp b/td/telegram/UpdatesManager.cpp index da00a5cf1..ff482316c 100644 --- a/td/telegram/UpdatesManager.cpp +++ b/td/telegram/UpdatesManager.cpp @@ -1678,6 +1678,9 @@ void UpdatesManager::process_updates(vector> td_->messages_manager_->process_pts_update(std::move(update)); } + if (update != nullptr && is_qts_update(update.get())) { + process_qts_update(std::move(update), 0, mpas.get_promise()); + } } } for (auto &update : updates) { @@ -2428,10 +2431,6 @@ void UpdatesManager::on_update(tl_object_ptr upd void UpdatesManager::on_update(tl_object_ptr update, bool force_apply, Promise &&promise) { - if (force_apply) { - return process_qts_update(std::move(update), 0, std::move(promise)); - } - auto qts = update->qts_; add_pending_qts_update(std::move(update), qts, std::move(promise)); } @@ -2626,10 +2625,6 @@ void UpdatesManager::on_update(tl_object_ptr upd void UpdatesManager::on_update(tl_object_ptr update, bool force_apply, Promise &&promise) { - if (force_apply) { - return process_qts_update(std::move(update), 0, std::move(promise)); - } - auto qts = update->qts_; add_pending_qts_update(std::move(update), qts, std::move(promise)); }