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

Add test for decreasing local_size.

Browse Source 
GitOrigin-RevId: 4dbfd8e0ffd105cb2f87a64bc5d6c0d8112ddcc3
This commit is contained in:
levlam 2018-11-21 13:56:14 +03:00
parent 16707b0602
commit c2a873db4b
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
td/telegram/cli.cpp
View File

@ -353,6 +353,7 @@ class CliClient final : public Actor {
int32 part_size = 0; int32 part_size = 0;
int32 local_size = 0; int32 local_size = 0;
int32 size = 0; int32 size = 0;
bool test_local_size_decrease = false;
}; };
vector<FileGeneration> pending_file_generations_; vector<FileGeneration> pending_file_generations_;
@ -370,6 +371,7 @@ class CliClient final : public Actor {
} else { } else {
file_generation.source = update.original_path_; file_generation.source = update.original_path_;
file_generation.part_size = to_integer<int32>(update.conversion_); file_generation.part_size = to_integer<int32>(update.conversion_);
file_generation.test_local_size_decrease = !update.conversion_.empty() && update.conversion_.back() == 't';
} }
auto r_stat = stat(file_generation.source); auto r_stat = stat(file_generation.source);
@ -3497,8 +3499,12 @@ class CliClient final : public Actor {
send_request(make_tl_object<td_api::finishFileGeneration>(it->id, nullptr)); send_request(make_tl_object<td_api::finishFileGeneration>(it->id, nullptr));
it = pending_file_generations_.erase(it); it = pending_file_generations_.erase(it);
} else { } else {
auto local_size = it->local_size;
if (it->test_local_size_decrease && local_size > it->size / 2) {
local_size = local_size * 2 - it->size;
}
send_request( send_request(
make_tl_object<td_api::setFileGenerationProgress>(it->id, (it->size + it->local_size) / 2, it->local_size)); make_tl_object<td_api::setFileGenerationProgress>(it->id, (it->size + it->local_size) / 2, local_size));
++it; ++it;
} }
} }