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

postponed_pts_update log tag

Browse Source
This commit is contained in:
Andrea Cavalli 2021-01-05 14:40:44 +01:00
parent c7820e2d15
commit 8b7c89db03
4 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
td/telegram/Logging.cpp
View File

@ -56,7 +56,7 @@ static const std::map<Slice, int *> log_tags{
ADD_TAG(file_loader), ADD_TAG(mtproto), ADD_TAG(raw_mtproto), ADD_TAG(fd), ADD_TAG(file_loader), ADD_TAG(mtproto), ADD_TAG(raw_mtproto), ADD_TAG(fd),
ADD_TAG(actor), ADD_TAG(sqlite), ADD_TAG(notifications), ADD_TAG(get_difference), ADD_TAG(actor), ADD_TAG(sqlite), ADD_TAG(notifications), ADD_TAG(get_difference),
ADD_TAG(file_gc), ADD_TAG(config_recoverer), ADD_TAG(dns_resolver), ADD_TAG(file_references), ADD_TAG(file_gc), ADD_TAG(config_recoverer), ADD_TAG(dns_resolver), ADD_TAG(file_references),
ADD_TAG(messages)}; ADD_TAG(messages), ADD_TAG(postponed_pts_update)};
#undef ADD_TAG #undef ADD_TAG
Status Logging::set_current_stream(td_api::object_ptr<td_api::LogStream> stream) { Status Logging::set_current_stream(td_api::object_ptr<td_api::LogStream> stream) {

3
td/telegram/MessagesManager.cpp
View File

@ -52,7 +52,7 @@
#include "td/telegram/UpdatesManager.h" #include "td/telegram/UpdatesManager.h"
#include "td/telegram/Version.h" #include "td/telegram/Version.h"
#include "td/telegram/WebPageId.h" #include "td/telegram/WebPageId.h"
#include "td/telegram/Td.h" // for VERBOSITY_NAME(messages) #include "td/telegram/Td.h" // for VERBOSITY_NAME(messages) and VERBOSITY_NAME(postponed_pts_update)
#include "td/actor/PromiseFuture.h" #include "td/actor/PromiseFuture.h"
#include "td/actor/SleepActor.h" #include "td/actor/SleepActor.h"
@ -7547,6 +7547,7 @@ void MessagesManager::drop_pending_updates() {
void MessagesManager::postpone_pts_update(tl_object_ptr<telegram_api::Update> &&update, int32 pts, int32 pts_count, void MessagesManager::postpone_pts_update(tl_object_ptr<telegram_api::Update> &&update, int32 pts, int32 pts_count,
Promise<Unit> &&promise) { Promise<Unit> &&promise) {
VLOG(postponed_pts_update) << "Postponed pts size: " << postponed_pts_updates_.size();
postponed_pts_updates_.emplace(pts, PendingPtsUpdate(std::move(update), pts, pts_count, std::move(promise))); postponed_pts_updates_.emplace(pts, PendingPtsUpdate(std::move(update), pts, pts_count, std::move(promise)));
} }

1
td/telegram/Td.cpp
View File

@ -145,6 +145,7 @@ namespace td {
int VERBOSITY_NAME(td_init) = VERBOSITY_NAME(DEBUG) + 3; int VERBOSITY_NAME(td_init) = VERBOSITY_NAME(DEBUG) + 3;
int VERBOSITY_NAME(td_requests) = VERBOSITY_NAME(INFO); int VERBOSITY_NAME(td_requests) = VERBOSITY_NAME(INFO);
int VERBOSITY_NAME(messages) = VERBOSITY_NAME(INFO); int VERBOSITY_NAME(messages) = VERBOSITY_NAME(INFO);
int VERBOSITY_NAME(postponed_pts_update) = VERBOSITY_NAME(DEBUG);
void Td::ResultHandler::set_td(Td *new_td) { void Td::ResultHandler::set_td(Td *new_td) {
CHECK(td == nullptr); CHECK(td == nullptr);

1
td/telegram/Td.h
View File

@ -87,6 +87,7 @@ namespace td {
extern int VERBOSITY_NAME(td_init); extern int VERBOSITY_NAME(td_init);
extern int VERBOSITY_NAME(td_requests); extern int VERBOSITY_NAME(td_requests);
extern int VERBOSITY_NAME(messages); extern int VERBOSITY_NAME(messages);
extern int VERBOSITY_NAME(postponed_pts_update);
// Td may start closing after explicit "close" or "destroy" query. // Td may start closing after explicit "close" or "destroy" query.
// Or it may start closing by itself, because authorization is lost. // Or it may start closing by itself, because authorization is lost.