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

Decrease UPDATE_APPLY_WARNING_TIME and improve logging.

Browse Source
This commit is contained in:
levlam 2024-01-17 16:50:08 +03:00
parent 14c93b1772
commit e5f9e4c400
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
td/telegram/UpdatesManager.cpp
View File

@ -2179,6 +2179,7 @@ void UpdatesManager::after_get_difference() {
auto begin_time = Time::now();
auto update_count = postponed_updates.size();
auto old_pts = get_pts();
VLOG(get_difference) << "Begin to apply " << postponed_updates.size()
<< " postponed PTS updates with PTS = " << get_pts();
for (auto &postponed_update : postponed_updates) {
@ -2192,8 +2193,9 @@ void UpdatesManager::after_get_difference() {
<< postponed_pts_updates_.size() << " pending PTS updates";
auto passed_time = Time::now() - begin_time;
if (passed_time >= UPDATE_APPLY_WARNING_TIME) {
LOG(WARNING) << "Applied " << update_count << " PTS updates in " << passed_time
<< " seconds after postponing them for " << (Time::now() - get_difference_start_time_) << " seconds";
LOG(WARNING) << "Updated PTS from " << old_pts << " to " << get_pts() << " and applied " << update_count
<< " PTS updates in " << passed_time << " seconds after postponing them for "
<< (Time::now() - get_difference_start_time_) << " seconds";
}
}
@ -3133,7 +3135,7 @@ void UpdatesManager::process_postponed_pts_updates() {
continue;
}
if (Time::now() - begin_time >= td::min(UPDATE_APPLY_WARNING_TIME / 2, 0.1)) {
if (Time::now() - begin_time >= 0.1) {
// the updates will be applied or skipped later; reget the remaining updates through getDifference
break;
}

2
td/telegram/UpdatesManager.h
View File

@ -147,7 +147,7 @@ class UpdatesManager final : public Actor {
static constexpr double MIN_UNFILLED_GAP_TIME = 0.05;
static constexpr double MAX_UNFILLED_GAP_TIME = 0.7;
static constexpr double MAX_PTS_SAVE_DELAY = 0.05;
static constexpr double UPDATE_APPLY_WARNING_TIME = 0.25;
static constexpr double UPDATE_APPLY_WARNING_TIME = 0.1;
static constexpr bool DROP_PTS_UPDATES = false;
static constexpr const char *AFTER_GET_DIFFERENCE_SOURCE = "after get difference";