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

Support gaps with 0 pts_count in UpdatesManager::on_get_pts_update.

Browse Source
This commit is contained in:
levlam 2024-01-25 22:02:11 +03:00
parent 2acbcdbb60
commit c9a357f80d
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
td/telegram/UpdatesManager.cpp
View File

@ -2042,13 +2042,13 @@ void UpdatesManager::on_get_pts_update(int32 pts,
if (G()->close_flag() || !td_->auth_manager_->is_authorized()) { if (G()->close_flag() || !td_->auth_manager_->is_authorized()) {
return; return;
} }
LOG(DEBUG) << "Receive update with PTS " << pts << ": " << to_string(difference_ptr);
if (get_pts() != pts - 1 || running_get_difference_ || !postponed_pts_updates_.empty() || if (get_pts() != pts - 1 || running_get_difference_ || !postponed_pts_updates_.empty() ||
pending_pts_updates_.empty() || pending_pts_updates_.begin()->first != pts + 1) { pending_pts_updates_.empty() || pending_pts_updates_.begin()->first > pts + 1 ||
pending_pts_updates_.begin()->first != pts + pending_pts_updates_.begin()->second.pts_count) {
return; return;
} }
LOG(DEBUG) << "Receive update with PTS " << pts << ": " << to_string(difference_ptr);
switch (difference_ptr->get_id()) { switch (difference_ptr->get_id()) {
case telegram_api::updates_difference::ID: { case telegram_api::updates_difference::ID: {
auto difference = move_tl_object_as<telegram_api::updates_difference>(difference_ptr); auto difference = move_tl_object_as<telegram_api::updates_difference>(difference_ptr);
@ -2084,6 +2084,13 @@ void UpdatesManager::on_get_pts_update(int32 pts,
update_message_id->random_id_, MessageId(ServerMessageId(update_message_id->id_)), "on_get_pts_update"); update_message_id->random_id_, MessageId(ServerMessageId(update_message_id->id_)), "on_get_pts_update");
continue; continue;
} }
if (constructor_id == telegram_api::updateDeleteMessages::ID) {
auto *update_delete_messages = static_cast<const telegram_api::updateDeleteMessages *>(update.get());
if (update_delete_messages->pts_count_ != 0 || update_delete_messages->messages_.size() != 1) {
LOG(ERROR) << "Receive in getDifference " << to_string(update);
}
}
update_ptr = &update; update_ptr = &update;
update_count++; update_count++;
} }