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

Minor.

Browse Source
This commit is contained in:
levlam 2022-03-03 17:59:24 +03:00
parent 49a23ee28e
commit 2c7a6dd8f4
1 changed files with 10 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
td/telegram/DownloadManager.cpp
View File

@ -73,7 +73,7 @@ class DownloadManagerImpl final : public DownloadManager {
} }
void start_up() final { void start_up() final {
try_start(); init();
} }
Status toggle_is_paused(FileId file_id, bool is_paused) final { Status toggle_is_paused(FileId file_id, bool is_paused) final {
@ -347,7 +347,7 @@ class DownloadManagerImpl final : public DownloadManager {
Counters counters_; Counters counters_;
Counters sent_counters_; Counters sent_counters_;
bool is_started_{false}; bool is_inited_{false};
bool is_search_inited_{false}; bool is_search_inited_{false};
int64 max_download_id_{0}; int64 max_download_id_{0};
uint64 last_link_token_{0}; uint64 last_link_token_{0};
@ -399,8 +399,8 @@ class DownloadManagerImpl final : public DownloadManager {
G()->td_db()->get_binlog_pmc()->erase(pmc_key(file_info)); G()->td_db()->get_binlog_pmc()->erase(pmc_key(file_info));
} }
void try_start() { void init() {
if (is_started_) { if (is_inited_) {
return; return;
} }
@ -431,7 +431,7 @@ class DownloadManagerImpl final : public DownloadManager {
G()->td_db()->get_binlog_pmc()->erase_by_prefix("dlds#"); G()->td_db()->get_binlog_pmc()->erase_by_prefix("dlds#");
} }
is_started_ = true; is_inited_ = true;
update_counters(); update_counters();
check_completed_downloads_size(); check_completed_downloads_size();
} }
@ -523,19 +523,12 @@ class DownloadManagerImpl final : public DownloadManager {
} }
} }
void loop() final {
if (!callback_) {
return;
}
try_start();
}
void timeout_expired() final { void timeout_expired() final {
clear_counters(); clear_counters();
} }
void clear_counters() { void clear_counters() {
if (!is_started_) { if (!is_inited_) {
return; return;
} }
CHECK(counters_ == sent_counters_); CHECK(counters_ == sent_counters_);
@ -575,7 +568,7 @@ class DownloadManagerImpl final : public DownloadManager {
} }
void update_counters() { void update_counters() {
if (!is_started_) { if (!is_inited_) {
return; return;
} }
if (counters_ == sent_counters_) { if (counters_ == sent_counters_) {
@ -690,10 +683,10 @@ class DownloadManagerImpl final : public DownloadManager {
Status check_is_active() const { Status check_is_active() const {
if (!callback_) { if (!callback_) {
LOG(ERROR) << "DownloadManager wasn't initialized"; LOG(ERROR) << "DownloadManager is closed";
return Status::Error(500, "DownloadManager isn't initialized"); return Status::Error(500, "DownloadManager is closed");
} }
CHECK(is_started_); CHECK(is_inited_);
return Status::OK(); return Status::OK();
} }
}; };