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

Add source to StoryManager::load_dialog_expiring_stories.

Browse Source
This commit is contained in:
levlam 2023-06-30 16:20:09 +03:00
parent a6f2a8f9ae
commit 1e3aa30ed5
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
td/telegram/StoryManager.cpp
View File

@ -1129,13 +1129,14 @@ uint64 StoryManager::save_load_dialog_expiring_stories_log_event(DialogId owner_
get_log_event_storer(log_event)); get_log_event_storer(log_event));
} }
void StoryManager::load_dialog_expiring_stories(DialogId owner_dialog_id, uint64 log_event_id) { void StoryManager::load_dialog_expiring_stories(DialogId owner_dialog_id, uint64 log_event_id, const char *source) {
if (load_expiring_stories_log_event_ids_.count(owner_dialog_id)) { if (load_expiring_stories_log_event_ids_.count(owner_dialog_id)) {
if (log_event_id != 0) { if (log_event_id != 0) {
binlog_erase(G()->td_db()->get_binlog(), log_event_id); binlog_erase(G()->td_db()->get_binlog(), log_event_id);
} }
return; return;
} }
LOG(INFO) << "Load active stories in " << owner_dialog_id << " from " << source;
if (log_event_id == 0 && G()->use_message_database()) { if (log_event_id == 0 && G()->use_message_database()) {
log_event_id = save_load_dialog_expiring_stories_log_event(owner_dialog_id); log_event_id = save_load_dialog_expiring_stories_log_event(owner_dialog_id);
} }
@ -1156,7 +1157,7 @@ void StoryManager::on_load_dialog_expiring_stories(DialogId owner_dialog_id) {
return; return;
} }
auto it = load_expiring_stories_log_event_ids_.find(owner_dialog_id); auto it = load_expiring_stories_log_event_ids_.find(owner_dialog_id);
if (it != load_expiring_stories_log_event_ids_.end()) { if (it == load_expiring_stories_log_event_ids_.end()) {
return; return;
} }
auto log_event_id = it->second; auto log_event_id = it->second;
@ -1164,6 +1165,7 @@ void StoryManager::on_load_dialog_expiring_stories(DialogId owner_dialog_id) {
if (log_event_id != 0) { if (log_event_id != 0) {
binlog_erase(G()->td_db()->get_binlog(), log_event_id); binlog_erase(G()->td_db()->get_binlog(), log_event_id);
} }
LOG(INFO) << "Finished loading of active stories in " << owner_dialog_id;
} }
void StoryManager::on_get_dialog_expiring_stories(DialogId owner_dialog_id, void StoryManager::on_get_dialog_expiring_stories(DialogId owner_dialog_id,
@ -1841,7 +1843,7 @@ StoryId StoryManager::on_get_new_story(DialogId owner_dialog_id,
auto active_stories = get_active_stories(owner_dialog_id); auto active_stories = get_active_stories(owner_dialog_id);
if (active_stories == nullptr) { if (active_stories == nullptr) {
if (is_subscribed_to_dialog_stories(owner_dialog_id)) { if (is_subscribed_to_dialog_stories(owner_dialog_id)) {
load_dialog_expiring_stories(owner_dialog_id, 0); load_dialog_expiring_stories(owner_dialog_id, 0, "on_get_new_story");
} }
} else if (!contains(active_stories->story_ids_, story_id)) { } else if (!contains(active_stories->story_ids_, story_id)) {
auto story_ids = active_stories->story_ids_; auto story_ids = active_stories->story_ids_;
@ -2800,7 +2802,7 @@ void StoryManager::on_binlog_events(vector<BinlogEvent> &&events) {
binlog_erase(G()->td_db()->get_binlog(), event.id_); binlog_erase(G()->td_db()->get_binlog(), event.id_);
break; break;
} }
load_dialog_expiring_stories(dialog_id, event.id_); load_dialog_expiring_stories(dialog_id, event.id_, "LoadDialogExpiringStoriesLogEvent");
break; break;
} }
default: default:

2
td/telegram/StoryManager.h
View File

@ -290,7 +290,7 @@ class StoryManager final : public Actor {
static uint64 save_load_dialog_expiring_stories_log_event(DialogId owner_dialog_id); static uint64 save_load_dialog_expiring_stories_log_event(DialogId owner_dialog_id);
void load_dialog_expiring_stories(DialogId owner_dialog_id, uint64 log_event_id); void load_dialog_expiring_stories(DialogId owner_dialog_id, uint64 log_event_id, const char *source);
void on_load_dialog_expiring_stories(DialogId owner_dialog_id); void on_load_dialog_expiring_stories(DialogId owner_dialog_id);