andreacavalli/tdlib-fork
Archived
1
0
Fork 0
Code Pull Requests Releases Activity

Fix updateHavePendingNotifications.

Browse Source 
GitOrigin-RevId: a466b693497a2bd55ae35fc9c1c50c84235bd98e
This commit is contained in:
levlam 2018-12-26 23:56:03 +03:00
parent 36419ed6c6
commit cc1cb263fd
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
td/telegram/NotificationManager.cpp
View File

@ -989,7 +989,7 @@ void NotificationManager::flush_pending_updates(int32 group_id, const char *sour
updates.end());
if (updates.empty()) {
VLOG(notifications) << "There are no updates to send in " << NotificationGroupId(group_id);
return;
break;
}
auto has_common_notifications = [](const vector<td_api::object_ptr<td_api::notification>> &notifications,
@ -1069,7 +1069,7 @@ void NotificationManager::flush_all_pending_updates(bool include_delayed_chats,
std::sort(ready_group_keys.begin(), ready_group_keys.end());
for (auto group_key : reversed(ready_group_keys)) {
flush_pending_updates_timeout_.cancel_timeout(group_key.group_id.get());
flush_pending_updates(group_key.group_id.get(), "after_get_difference");
flush_pending_updates(group_key.group_id.get(), "flush_all_pending_updates");
}
if (include_delayed_chats) {
CHECK(pending_updates_.empty());
@ -1969,6 +1969,9 @@ void NotificationManager::before_get_difference() {
if (is_disabled()) {
return;
}
if (running_get_difference_) {
return;
}
running_get_difference_ = true;
on_pending_notification_update_count_changed(1, 0, "before_get_difference");