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

Remove separate setFileDownloadOffset.

Browse Source 
GitOrigin-RevId: b9588dbbc3929de9dba01c008bc18d1f36b24571
This commit is contained in:
levlam 2018-12-28 20:38:37 +03:00
parent 385e87d92c
commit dd5b8a87c2
7 changed files with 0 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
td/generate/scheme/td_api.tl
View File

@ -2952,9 +2952,6 @@ setPinnedChats chat_ids:vector<int53> = Ok;
//@offset File will be downloaded starting from that offset in bytes first. Supposed to be used for streaming
downloadFile file_id:int32 priority:int32 offset:int32 = File;
//@description Sets offset for file downloading @file_id Identifier of the file to change download offset @offset New file download offset
setFileDownloadOffset file_id:int32 offset:int32 = File;
//@description Returns file downloaded prefix size from a given offset @file_id Identifier of the file @offset Offset from which downloaded prefix size should be calculated
getFileDownloadedPrefixSize file_id:int32 offset:int32 = Count;

BIN
td/generate/scheme/td_api.tlo
View File

Binary file not shown.

13
td/telegram/Td.cpp
View File

@ -5693,19 +5693,6 @@ void Td::on_request(uint64 id, const td_api::downloadFile &request) {
send_closure(actor_id(this), &Td::send_result, id, std::move(file));
}
void Td::on_request(uint64 id, const td_api::setFileDownloadOffset &request) {
if (request.offset_ < 0) {
return send_error_raw(id, 5, "Download offset must be non-negative");
}
file_manager_->download_set_offset(FileId(request.file_id_, 0), request.offset_);
auto file = file_manager_->get_file_object(FileId(request.file_id_, 0), false);
if (file->id_ == 0) {
return send_error_raw(id, 400, "Invalid file id");
}
send_closure(actor_id(this), &Td::send_result, id, std::move(file));
}
void Td::on_request(uint64 id, const td_api::cancelDownloadFile &request) {
file_manager_->download(FileId(request.file_id_, 0), nullptr, request.only_if_pending_ ? -1 : 0, -1);

2
td/telegram/Td.h
View File

@ -646,8 +646,6 @@ class Td final : public NetQueryCallback {
void on_request(uint64 id, const td_api::downloadFile &request);
void on_request(uint64 id, const td_api::setFileDownloadOffset &request);
void on_request(uint64 id, const td_api::cancelDownloadFile &request);
void on_request(uint64 id, td_api::uploadFile &request);

6
td/telegram/cli.cpp
View File

@ -2276,12 +2276,6 @@ class CliClient final : public Actor {
send_request(make_tl_object<td_api::getMapThumbnailFile>(
as_location(latitude, longitude), to_integer<int32>(zoom), to_integer<int32>(width),
to_integer<int32>(height), to_integer<int32>(scale), as_chat_id(chat_id)));
} else if (op == "sfdo" || op == "SetDownloadFileOffset") {
string file_id;
string offset;
std::tie(file_id, offset) = split(args);
send_request(make_tl_object<td_api::setFileDownloadOffset>(as_file_id(file_id), to_integer<int32>(offset)));
} else if (op == "df" || op == "DownloadFile") {
string file_id;
string priority;

12
td/telegram/files/FileManager.cpp
View File

@ -1619,18 +1619,6 @@ void FileManager::download(FileId file_id, std::shared_ptr<DownloadCallback> cal
try_flush_node(node, "download");
}
void FileManager::download_set_offset(FileId file_id, int64 offset) {
auto file_node = get_sync_file_node(file_id);
if (!file_node) {
LOG(INFO) << "File " << file_id << " not found";
return;
}
file_node->set_download_offset(offset);
run_generate(file_node);
run_download(file_node);
try_flush_node(file_node, "download_set_offset");
}
void FileManager::run_download(FileNodePtr node) {
if (node->need_load_from_pmc_) {
return;

1
td/telegram/files/FileManager.h
View File

@ -344,7 +344,6 @@ class FileManager : public FileLoadManager::Callback {
bool set_content(FileId file_id, BufferSlice bytes);
void download(FileId file_id, std::shared_ptr<DownloadCallback> callback, int32 new_priority, int64 offset);
void download_set_offset(FileId file_id, int64 offset);
void upload(FileId file_id, std::shared_ptr<UploadCallback> callback, int32 new_priority, uint64 upload_order);
void resume_upload(FileId file_id, std::vector<int> bad_parts, std::shared_ptr<UploadCallback> callback,
int32 new_priority, uint64 upload_order);