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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
// Copyright 2017 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "components/offline_items_collection/core/utilities/file_existence_checker.h"
#include <vector>
#include "base/bind.h"
#include "base/files/file_path.h"
#include "base/files/file_util.h"
#include "base/files/scoped_temp_dir.h"
#include "base/sequenced_task_runner.h"
#include "base/test/test_simple_task_runner.h"
#include "base/threading/thread_task_runner_handle.h"
#include "testing/gtest/include/gtest/gtest.h"
namespace offline_items_collection {
using FileIdPairVector = FileExistenceChecker::FileWithIdCollection<int64_t>;
using FileIdPairSet = std::set<std::pair<base::FilePath, int64_t>>;
namespace {
FileIdPairSet CheckForMissingFiles(
const scoped_refptr<base::TestSimpleTaskRunner>& task_runner,
FileIdPairVector file_paths) {
FileIdPairSet missing_files;
FileExistenceChecker::CheckForMissingFiles(
task_runner, std::move(file_paths),
base::BindOnce(
[](FileIdPairSet* set_alias, FileIdPairVector result) {
set_alias->insert(result.begin(), result.end());
},
&missing_files));
task_runner->RunUntilIdle();
return missing_files;
}
} // namespace
class FileExistenceCheckerTest : public testing::Test {
public:
FileExistenceCheckerTest();
~FileExistenceCheckerTest() override;
FileIdPairVector CreateTestFiles(int64_t count);
base::TestSimpleTaskRunner* task_runner() { return task_runner_.get(); }
scoped_refptr<base::TestSimpleTaskRunner>& task_runner_ref() {
return task_runner_;
}
private:
base::ScopedTempDir temp_directory_;
scoped_refptr<base::TestSimpleTaskRunner> task_runner_;
base::ThreadTaskRunnerHandle task_runner_handle_;
};
FileExistenceCheckerTest::FileExistenceCheckerTest()
: task_runner_(new base::TestSimpleTaskRunner),
task_runner_handle_(task_runner_) {
EXPECT_TRUE(temp_directory_.CreateUniqueTempDir());
}
FileExistenceCheckerTest::~FileExistenceCheckerTest() {}
FileIdPairVector FileExistenceCheckerTest::CreateTestFiles(int64_t count) {
base::FilePath file_path;
FileIdPairVector created_files;
for (int64_t i = 0; i < count; i++) {
EXPECT_TRUE(
base::CreateTemporaryFileInDir(temp_directory_.GetPath(), &file_path));
created_files.push_back(std::make_pair(file_path, i));
}
return created_files;
}
TEST_F(FileExistenceCheckerTest, NoFilesMissing) {
FileIdPairVector files = CreateTestFiles(2);
FileIdPairSet missing_files = CheckForMissingFiles(task_runner_ref(), files);
EXPECT_TRUE(missing_files.empty());
}
TEST_F(FileExistenceCheckerTest, MissingFileFound) {
FileIdPairVector files = CreateTestFiles(2);
base::DeleteFile(files[0].first, false /* recursive */);
FileIdPairSet missing_files = CheckForMissingFiles(task_runner_ref(), files);
EXPECT_EQ(1UL, missing_files.size());
EXPECT_EQ(1UL, missing_files.count(files[0]));
EXPECT_EQ(0UL, missing_files.count(files[1]));
}
} // namespace offline_items_collection
|
