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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
#include "testing/testing.hpp"
#include "storage/storage_integration_tests/test_defines.hpp"
#include "storage/storage.hpp"
#include "platform/mwm_version.hpp"
#include "platform/platform.hpp"
#include "platform/platform_tests_support/writable_dir_changer.hpp"
using namespace storage;
void InitStorage(Storage & storage, Storage::UpdateCallback const & didDownload,
Storage::ProgressFunction const & progress)
{
TEST(version::IsSingleMwm(storage.GetCurrentDataVersion()), ());
auto const changeCountryFunction = [&](CountryId const & /* countryId */) {
if (!storage.IsDownloadInProgress())
{
// End wait for downloading complete.
testing::StopEventLoop();
}
};
storage.Init(didDownload, [](CountryId const &, LocalFilePtr const) { return false; });
storage.RegisterAllLocalMaps(false /* enableDiffs */);
storage.Subscribe(changeCountryFunction, progress);
storage.SetDownloadingUrlsForTesting({kTestWebServer});
}
UNIT_TEST(DownloadingTests_CalcOverallProgress)
{
WritableDirChanger writableDirChanger(storage::kMapTestDir);
CountriesVec const kTestCountries = {"Angola", "Tokelau", "New Zealand North_Auckland",
"New Zealand North_Wellington"};
Storage s;
s.SetDownloadingUrlsForTesting({storage::kTestWebServer});
MapFilesDownloader::Progress baseProgress = s.GetOverallProgress(kTestCountries);
TEST_EQUAL(baseProgress.first, 0, ());
TEST_EQUAL(baseProgress.second, 0, ());
for (auto const &country : kTestCountries)
{
baseProgress.second += s.CountrySizeInBytes(country, MapOptions::Map).second;
}
auto progressChanged = [&s, &kTestCountries, &baseProgress](CountryId const & id,
LocalAndRemoteSize const & sz) {
MapFilesDownloader::Progress currentProgress = s.GetOverallProgress(kTestCountries);
LOG_SHORT(LINFO, (id, "downloading progress:", currentProgress));
TEST_GREATER_OR_EQUAL(currentProgress.first, baseProgress.first, ());
baseProgress.first = currentProgress.first;
TEST_LESS_OR_EQUAL(currentProgress.first, baseProgress.second, ());
TEST_EQUAL(currentProgress.second, baseProgress.second, ());
};
InitStorage(s, [](storage::CountryId const &, LocalFilePtr const) {}, progressChanged);
for (auto const & countryId : kTestCountries)
s.DownloadNode(countryId);
testing::RunEventLoop();
}
|
