andreacavalli/tdlib-fork
Archived
1
0
Fork 0
Code Pull Requests Releases Activity

Add more logging.

Browse Source 
GitOrigin-RevId: a6b927c52e37c29fa62029d59fd96375af87b14e
This commit is contained in:
levlam 2020-01-02 03:38:47 +03:00
parent 713608ada1
commit 37d354d3c4
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
td/telegram/files/FileDownloader.cpp
View File

@ -117,6 +117,7 @@ Result<FileLoader::FileInfo> FileDownloader::init() {
res.limit = limit_; res.limit = limit_;
return res; return res;
} }
Status FileDownloader::on_ok(int64 size) { Status FileDownloader::on_ok(int64 size) {
auto dir = get_files_dir(remote_.file_type_); auto dir = get_files_dir(remote_.file_type_);
@ -140,6 +141,7 @@ Status FileDownloader::on_ok(int64 size) {
callback_->on_ok(FullLocalFileLocation(remote_.file_type_, std::move(path), 0), size, !only_check_); callback_->on_ok(FullLocalFileLocation(remote_.file_type_, std::move(path), 0), size, !only_check_);
return Status::OK(); return Status::OK();
} }
void FileDownloader::on_error(Status status) { void FileDownloader::on_error(Status status) {
fd_.close(); fd_.close();
callback_->on_error(std::move(status)); callback_->on_error(std::move(status));
@ -217,6 +219,7 @@ Result<bool> FileDownloader::should_restart_part(Part part, NetQueryPtr &net_que
return false; return false;
} }
Result<std::pair<NetQueryPtr, bool>> FileDownloader::start_part(Part part, int32 part_count) { Result<std::pair<NetQueryPtr, bool>> FileDownloader::start_part(Part part, int32 part_count) {
if (encryption_key_.is_secret()) { if (encryption_key_.is_secret()) {
part.size = (part.size + 15) & ~15; // fix for last part part.size = (part.size + 15) & ~15; // fix for last part
@ -354,12 +357,14 @@ Result<size_t> FileDownloader::process_part(Part part, NetQueryPtr net_query) {
TRY_STATUS(acquire_fd()); TRY_STATUS(acquire_fd());
LOG(INFO) << "Got " << slice.size() << " bytes at offset " << part.offset << " for \"" << path_ << '"'; LOG(INFO) << "Got " << slice.size() << " bytes at offset " << part.offset << " for \"" << path_ << '"';
TRY_RESULT(written, fd_.pwrite(slice, part.offset)); TRY_RESULT(written, fd_.pwrite(slice, part.offset));
LOG(INFO) << "Written " << written << " bytes";
// may write less than part.size, when size of downloadable file is unknown // may write less than part.size, when size of downloadable file is unknown
if (written != slice.size()) { if (written != slice.size()) {
return Status::Error("Failed to save file part to the file"); return Status::Error("Failed to save file part to the file");
} }
return written; return written;
} }
void FileDownloader::on_progress(Progress progress) { void FileDownloader::on_progress(Progress progress) {
if (progress.is_ready) { if (progress.is_ready) {
// do not send partial location. will lead to wrong local_size // do not send partial location. will lead to wrong local_size