blob: 9bdd4ae6f94f54e6824ef024e3e806413d51e792 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
#pragma once
#include "storage/map_files_downloader.hpp"
#include "coding/file_writer.hpp"
#include "base/thread_checker.hpp"
#include "std/unique_ptr.hpp"
namespace storage
{
class TaskRunner;
// This class can be used in tests to mimic a real downloader. It
// always returns a single URL for map files downloading and when
// asked for a file, creates a file with zero-bytes content on a disk.
// Because all callbacks must be invoked asynchronously, it needs a
// single-thread message loop runner to run callbacks.
//
// *NOTE*, this class is not thread-safe.
class FakeMapFilesDownloader : public MapFilesDownloader
{
public:
static int64_t const kBlockSize = 1024 * 1024;
FakeMapFilesDownloader(TaskRunner & taskRunner);
virtual ~FakeMapFilesDownloader();
// MapFilesDownloader overrides:
void GetServersList(int64_t const mapVersion, string const & mapFileName, TServersListCallback const & callback) override;
void DownloadMapFile(vector<string> const & urls, string const & path, int64_t size,
TFileDownloadedCallback const & onDownloaded,
TDownloadingProgressCallback const & onProgress) override;
TProgress GetDownloadingProgress() override;
bool IsIdle() override;
void Reset() override;
private:
void DownloadNextChunk(uint64_t requestId);
vector<string> m_servers;
TProgress m_progress;
bool m_idle;
unique_ptr<FileWriter> m_writer;
TFileDownloadedCallback m_onDownloaded;
TDownloadingProgressCallback m_onProgress;
uint64_t m_timestamp;
TaskRunner & m_taskRunner;
ThreadChecker m_checker;
};
} // namespace storage
|
