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

Force getDifference if receive a lot of qts updates.

Browse Source
This commit is contained in:
levlam 2021-01-05 16:29:45 +03:00
parent 970f65604a
commit 71ac1f67bf
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
td/telegram/UpdatesManager.cpp
View File

@ -246,6 +246,7 @@ void UpdatesManager::run_get_difference(bool is_recursive, const char *source) {
td_->create_handler<GetDifferenceQuery>()->send(); td_->create_handler<GetDifferenceQuery>()->send();
last_get_difference_pts_ = get_pts(); last_get_difference_pts_ = get_pts();
last_get_difference_qts_ = get_qts();
} }
void UpdatesManager::before_get_difference(bool is_initial) { void UpdatesManager::before_get_difference(bool is_initial) {
@ -1080,6 +1081,7 @@ void UpdatesManager::init_state() {
pts_manager_.init(to_integer<int32>(pts_str)); pts_manager_.init(to_integer<int32>(pts_str));
last_get_difference_pts_ = get_pts(); last_get_difference_pts_ = get_pts();
qts_manager_.init(to_integer<int32>(pmc->get("updates.qts"))); qts_manager_.init(to_integer<int32>(pmc->get("updates.qts")));
last_get_difference_qts_ = get_qts();
date_ = to_integer<int32>(pmc->get("updates.date")); date_ = to_integer<int32>(pmc->get("updates.date"));
date_source_ = "database"; date_source_ = "database";
LOG(DEBUG) << "Init: " << get_pts() << " " << get_qts() << " " << date_; LOG(DEBUG) << "Init: " << get_pts() << " " << get_qts() << " " << date_;
@ -1562,6 +1564,7 @@ void UpdatesManager::add_pending_qts_update(tl_object_ptr<telegram_api::Update>
add_qts(qts - 1).set_value(Unit()); add_qts(qts - 1).set_value(Unit());
CHECK(get_qts() == qts - 1); CHECK(get_qts() == qts - 1);
old_qts = qts - 1; old_qts = qts - 1;
last_get_difference_qts_ = get_qts();
} }
if (qts <= old_qts) { if (qts <= old_qts) {
@ -1667,6 +1670,10 @@ void UpdatesManager::process_seq_updates(int32 seq_end, int32 date,
void UpdatesManager::process_qts_update(tl_object_ptr<telegram_api::Update> &&update_ptr, int32 qts, void UpdatesManager::process_qts_update(tl_object_ptr<telegram_api::Update> &&update_ptr, int32 qts,
Promise<Unit> &&promise) { Promise<Unit> &&promise) {
LOG(DEBUG) << "Process " << to_string(update_ptr); LOG(DEBUG) << "Process " << to_string(update_ptr);
if (last_get_difference_qts_ + FORCED_GET_DIFFERENCE_PTS_DIFF < qts) {
last_get_difference_qts_ = qts;
schedule_get_difference("process_qts_update");
}
switch (update_ptr->get_id()) { switch (update_ptr->get_id()) {
case telegram_api::updateNewEncryptedMessage::ID: { case telegram_api::updateNewEncryptedMessage::ID: {
auto update = move_tl_object_as<telegram_api::updateNewEncryptedMessage>(update_ptr); auto update = move_tl_object_as<telegram_api::updateNewEncryptedMessage>(update_ptr);

1
td/telegram/UpdatesManager.h
View File

@ -133,6 +133,7 @@ class UpdatesManager : public Actor {
bool running_get_difference_ = false; bool running_get_difference_ = false;
int32 last_get_difference_pts_ = 0; int32 last_get_difference_pts_ = 0;
int32 last_get_difference_qts_ = 0;
int32 min_postponed_update_pts_ = 0; int32 min_postponed_update_pts_ = 0;
int32 min_postponed_update_qts_ = 0; int32 min_postponed_update_qts_ = 0;