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

Close asynchronously opened database if instance was closed in the meanwhile.

Browse Source
This commit is contained in:
levlam 2024-02-01 01:46:34 +03:00
parent 034db9599d
commit acec5146ec
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
td/telegram/Td.cpp
View File

@ -3513,6 +3513,18 @@ void Td::init(Parameters parameters, Result<TdDb::OpenedDatabase> r_opened_datab
VLOG(td_init) << "Successfully inited database";
if (state_ == State::Close) {
LOG(INFO) << "Close asynchronously opened database";
auto database_ptr = events.database.get();
auto promise = PromiseCreator::lambda([database = std::move(events.database)](Unit) {
// destroy the database after closing
});
database_ptr->close(
database_ptr->use_file_database() ? G()->get_database_scheduler_id() : G()->get_slow_net_scheduler_id(),
destroy_flag_, std::move(promise));
return finish_set_parameters();
}
G()->init(actor_id(this), std::move(events.database)).ensure();
init_options_and_network();