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

Bugfixes

Browse Source
This commit is contained in:
Andrea Cavalli 2021-07-24 23:37:42 +02:00
parent fcc30bf40a
commit ce31e59554
2 changed files with 8 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
td/telegram/MessagesManager.cpp
View File

@ -7473,7 +7473,7 @@ void MessagesManager::add_pending_channel_update(DialogId dialog_id, tl_object_p
} }
auto enable_pull_based_backpressure auto enable_pull_based_backpressure
= G()->shared_config().get_option_boolean("enable_pull_based_backpressure", false); = G()->shared_config().get_option_boolean("enable_pull_based_backpressure", false);
get_channel_difference_delayed(dialog_id, old_pts, true, enable_pull_based_backpressure, "old"); get_channel_difference_delayed(dialog_id, old_pts, true, enable_pull_based_backpressure, "add_pending_channel_update old");
} }
if (update->get_id() == telegram_api::updateNewChannelMessage::ID) { if (update->get_id() == telegram_api::updateNewChannelMessage::ID) {
@ -33761,10 +33761,6 @@ bool MessagesManager::update_message_content(DialogId dialog_id, Message *old_me
} }
MessagesManager::Dialog *MessagesManager::get_dialog_by_message_id(MessageId message_id) { MessagesManager::Dialog *MessagesManager::get_dialog_by_message_id(MessageId message_id) {
if (G()->shared_config().get_option_boolean("ignore_server_deletes_and_reads", false)) {
LOG(INFO) << "Can't find the chat by " << message_id << " because this function is disabled";
return nullptr;
}
CHECK(message_id.is_valid() && message_id.is_server()); CHECK(message_id.is_valid() && message_id.is_server());
auto it = message_id_to_dialog_id_.find(message_id); auto it = message_id_to_dialog_id_.find(message_id);
if (it == message_id_to_dialog_id_.end()) { if (it == message_id_to_dialog_id_.end()) {
@ -35575,7 +35571,11 @@ void MessagesManager::get_channel_difference_delayed(DialogId dialog_id, int32 p
bool force, bool enable_pull_based_backpressure, const char *source) { bool force, bool enable_pull_based_backpressure, const char *source) {
if (!enable_pull_based_backpressure) { if (!enable_pull_based_backpressure) {
// Execute get_channel_difference immediatly // Execute get_channel_difference immediatly
get_channel_difference(dialog_id,pts, force, "on_get_channel_difference"); const char* source_prefix = "on_get_channel_difference, ";
char* joined_source{ new char[strlen(source_prefix) + strlen(source) + 1] };
joined_source = strcpy(joined_source, source_prefix);
joined_source = strcat(joined_source, source);
get_channel_difference(dialog_id,pts, force, joined_source);
} else { } else {
auto channel_difference_id = ++last_pending_channel_difference_; auto channel_difference_id = ++last_pending_channel_difference_;
PendingChannelDifference pending_channel_difference = {dialog_id, pts, force}; PendingChannelDifference pending_channel_difference = {dialog_id, pts, force};

7
td/telegram/TdDb.cpp
View File

@ -149,10 +149,8 @@ Status init_db(SqliteDb &db) {
TRY_STATUS(db.exec("PRAGMA cache_size=4096")); TRY_STATUS(db.exec("PRAGMA cache_size=4096"));
TRY_STATUS(db.exec("PRAGMA page_size=65536")); TRY_STATUS(db.exec("PRAGMA page_size=65536"));
TRY_STATUS(db.exec("PRAGMA synchronous=NORMAL")); TRY_STATUS(db.exec("PRAGMA synchronous=NORMAL"));
TRY_STATUS(db.exec("PRAGMA temp_store=FILE")); TRY_STATUS(db.exec("PRAGMA temp_store=MEMORY"));
TRY_STATUS(db.exec("PRAGMA wal_autocheckpoint=10000")); TRY_STATUS(db.exec("PRAGMA secure_delete=1"));
TRY_STATUS(db.exec("PRAGMA shrink_memory"));
TRY_STATUS(db.exec("PRAGMA secure_delete=0"));
return Status::OK(); return Status::OK();
} }
@ -371,7 +369,6 @@ Status TdDb::init_sqlite(int32 scheduler_id, const TdParameters &parameters, DbK
binlog_pmc.force_sync({}); binlog_pmc.force_sync({});
TRY_STATUS(db.exec("COMMIT TRANSACTION")); TRY_STATUS(db.exec("COMMIT TRANSACTION"));
TRY_STATUS(db.exec("VACUUM"));
file_db_ = create_file_db(sql_connection_, scheduler_id); file_db_ = create_file_db(sql_connection_, scheduler_id);