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

Simpler and faster have_message_force.

Browse Source
This commit is contained in:
levlam 2021-09-16 17:28:33 +03:00
parent 6801eabb8d
commit 48f623f132
3 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
td/telegram/Global.cpp
View File

@ -137,8 +137,8 @@ Status Global::init(const TdParameters &parameters, ActorId<Td> td, unique_ptr<T
int32 Global::to_unix_time(double server_time) const { int32 Global::to_unix_time(double server_time) const {
LOG_CHECK(1.0 <= server_time && server_time <= 2140000000.0) LOG_CHECK(1.0 <= server_time && server_time <= 2140000000.0)
<< server_time << " " << Clocks::system() << " " << is_server_time_reliable() << " " << server_time << ' ' << Clocks::system() << ' ' << is_server_time_reliable() << ' '
<< get_server_time_difference() << " " << Time::now() << saved_diff_ << " " << saved_system_time_; << get_server_time_difference() << ' ' << Time::now() << ' ' << saved_diff_ << ' ' << saved_system_time_;
return static_cast<int32>(server_time); return static_cast<int32>(server_time);
} }

14
td/telegram/MessagesManager.cpp
View File

@ -16690,6 +16690,10 @@ bool MessagesManager::have_message_force(FullMessageId full_message_id, const ch
return get_message_force(full_message_id, source) != nullptr; return get_message_force(full_message_id, source) != nullptr;
} }
bool MessagesManager::have_message_force(Dialog *d, MessageId message_id, const char *source) {
return get_message_force(d, message_id, source) != nullptr;
}
MessagesManager::Message *MessagesManager::get_message(FullMessageId full_message_id) { MessagesManager::Message *MessagesManager::get_message(FullMessageId full_message_id) {
Dialog *d = get_dialog(full_message_id.get_dialog_id()); Dialog *d = get_dialog(full_message_id.get_dialog_id());
if (d == nullptr) { if (d == nullptr) {
@ -27989,7 +27993,7 @@ bool MessagesManager::add_new_message_notification(Dialog *d, Message *m, bool f
if (is_pinned) { if (is_pinned) {
auto message_id = get_message_content_pinned_message_id(m->content.get()); auto message_id = get_message_content_pinned_message_id(m->content.get());
if (message_id.is_valid() && if (message_id.is_valid() &&
!have_message_force({d->dialog_id, message_id}, !have_message_force(d, message_id,
force ? "add_new_message_notification force" : "add_new_message_notification not force")) { force ? "add_new_message_notification force" : "add_new_message_notification not force")) {
missing_pinned_message_id = message_id; missing_pinned_message_id = message_id;
} }
@ -32340,20 +32344,18 @@ MessagesManager::Message *MessagesManager::add_message_to_dialog(Dialog *d, uniq
if (*need_update || (!d->last_new_message_id.is_valid() && !message_id.is_yet_unsent() && from_update)) { if (*need_update || (!d->last_new_message_id.is_valid() && !message_id.is_yet_unsent() && from_update)) {
auto pinned_message_id = get_message_content_pinned_message_id(message->content.get()); auto pinned_message_id = get_message_content_pinned_message_id(message->content.get());
if (pinned_message_id.is_valid() && pinned_message_id < message_id && if (pinned_message_id.is_valid() && pinned_message_id < message_id &&
have_message_force({dialog_id, pinned_message_id}, "preload pinned message")) { have_message_force(d, pinned_message_id, "preload pinned message")) {
LOG(INFO) << "Preloaded pinned " << pinned_message_id << " from database"; LOG(INFO) << "Preloaded pinned " << pinned_message_id << " from database";
} }
if (d->pinned_message_notification_message_id.is_valid() && if (d->pinned_message_notification_message_id.is_valid() &&
d->pinned_message_notification_message_id != message_id && d->pinned_message_notification_message_id != message_id &&
have_message_force({dialog_id, d->pinned_message_notification_message_id}, have_message_force(d, d->pinned_message_notification_message_id, "preload previously pinned message")) {
"preload previously pinned message")) {
LOG(INFO) << "Preloaded previously pinned " << d->pinned_message_notification_message_id << " from database"; LOG(INFO) << "Preloaded previously pinned " << d->pinned_message_notification_message_id << " from database";
} }
} }
if (from_update && message->top_thread_message_id.is_valid() && message->top_thread_message_id != message_id && if (from_update && message->top_thread_message_id.is_valid() && message->top_thread_message_id != message_id &&
message_id.is_server() && message_id.is_server() && have_message_force(d, message->top_thread_message_id, "preload top reply message")) {
have_message_force({dialog_id, message->top_thread_message_id}, "preload top reply message")) {
LOG(INFO) << "Preloaded top thread " << message->top_thread_message_id << " from database"; LOG(INFO) << "Preloaded top thread " << message->top_thread_message_id << " from database";
Message *top_m = get_message(d, message->top_thread_message_id); Message *top_m = get_message(d, message->top_thread_message_id);

2
td/telegram/MessagesManager.h
View File

@ -2639,6 +2639,8 @@ class MessagesManager final : public Actor {
Message *get_message(FullMessageId full_message_id); Message *get_message(FullMessageId full_message_id);
const Message *get_message(FullMessageId full_message_id) const; const Message *get_message(FullMessageId full_message_id) const;
bool have_message_force(Dialog *d, MessageId message_id, const char *source);
Message *get_message_force(Dialog *d, MessageId message_id, const char *source); Message *get_message_force(Dialog *d, MessageId message_id, const char *source);
Message *get_message_force(FullMessageId full_message_id, const char *source); Message *get_message_force(FullMessageId full_message_id, const char *source);