loop-uh
97d2d18f71
All checks were successful
Desktop source guards / guards (push) Successful in 6s
Последняя часть файла делилась на 16 кусков, и параллельные куски уходили за конец файла: ответ сервера на такое смещение не гарантированно пустой, а ошибка любого куска переводит весь файл в Failed. При известном размере куски ограничены концом файла, при неизвестном куски одной части идут по одному, пока короткий кусок не покажет конец.
77 lines
2 KiB
C++
77 lines
2 KiB
C++
/*
|
|
This file is part of Telegram Desktop,
|
|
the official desktop application for the Telegram messaging service.
|
|
|
|
For license and copyright information please follow this link:
|
|
https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
|
|
*/
|
|
#pragma once
|
|
|
|
#include "storage/file_download.h"
|
|
#include "storage/download_manager_mtproto.h"
|
|
|
|
class mtpFileLoader final
|
|
: public FileLoader
|
|
, private Storage::DownloadMtprotoTask {
|
|
public:
|
|
mtpFileLoader(
|
|
not_null<Main::Session*> session,
|
|
const StorageFileLocation &location,
|
|
Data::FileOrigin origin,
|
|
LocationType type,
|
|
const QString &toFile,
|
|
int64 loadSize,
|
|
int64 fullSize,
|
|
LoadToCacheSetting toCache,
|
|
LoadFromCloudSetting fromCloud,
|
|
bool autoLoading,
|
|
uint8 cacheTag);
|
|
mtpFileLoader(
|
|
not_null<Main::Session*> session,
|
|
const WebFileLocation &location,
|
|
int64 loadSize,
|
|
int64 fullSize,
|
|
LoadFromCloudSetting fromCloud,
|
|
bool autoLoading,
|
|
uint8 cacheTag);
|
|
mtpFileLoader(
|
|
not_null<Main::Session*> session,
|
|
const GeoPointLocation &location,
|
|
int64 loadSize,
|
|
int64 fullSize,
|
|
LoadFromCloudSetting fromCloud,
|
|
bool autoLoading,
|
|
uint8 cacheTag);
|
|
mtpFileLoader(
|
|
not_null<Main::Session*> session,
|
|
const AudioAlbumThumbLocation &location,
|
|
int64 loadSize,
|
|
int64 fullSize,
|
|
LoadFromCloudSetting fromCloud,
|
|
bool autoLoading,
|
|
uint8 cacheTag);
|
|
~mtpFileLoader();
|
|
|
|
Data::FileOrigin fileOrigin() const override;
|
|
uint64 objId() const override;
|
|
|
|
private:
|
|
Storage::Cache::Key cacheKey() const override;
|
|
std::optional<MediaKey> fileLocationKey() const override;
|
|
void startLoading() override;
|
|
void startLoadingWithPartial(const QByteArray &data) override;
|
|
void cancelHook() override;
|
|
|
|
bool readyToRequest() const override;
|
|
int64 takeNextRequestOffset() override;
|
|
int64 knownFileSize() const override {
|
|
return fullSize();
|
|
}
|
|
bool feedPart(int64 offset, const QByteArray &bytes) override;
|
|
void cancelOnFail() override;
|
|
bool setWebFileSizeHook(int64 size) override;
|
|
|
|
bool _lastComplete = false;
|
|
int64 _nextRequestOffset = 0;
|
|
|
|
};
|