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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
|
// Copyright 2015 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chrome/browser/ash/file_system_provider/scoped_file_opener.h"
#include <memory>
#include <vector>
#include "base/files/file.h"
#include "base/functional/bind.h"
#include "base/run_loop.h"
#include "base/strings/string_number_conversions.h"
#include "chrome/browser/ash/file_system_provider/fake_provided_file_system.h"
#include "chrome/browser/ash/file_system_provider/provided_file_system_info.h"
#include "content/public/test/browser_task_environment.h"
#include "testing/gtest/include/gtest/gtest.h"
namespace ash::file_system_provider {
namespace {
class TestingProvidedFileSystem : public FakeProvidedFileSystem {
public:
TestingProvidedFileSystem()
: FakeProvidedFileSystem(ProvidedFileSystemInfo()) {}
~TestingProvidedFileSystem() override = default;
AbortCallback OpenFile(const base::FilePath& file_path,
OpenFileMode mode,
OpenFileCallback callback) override {
open_callback_ = std::move(callback);
return base::BindOnce(&TestingProvidedFileSystem::AbortOpen,
base::Unretained(this));
}
AbortCallback CloseFile(
int file_handle,
storage::AsyncFileUtil::StatusCallback callback) override {
close_requests_.push_back(file_handle);
std::move(callback).Run(base::File::FILE_OK);
return AbortCallback();
}
bool has_open_callback() const { return !!open_callback_; }
OpenFileCallback open_callback() {
return base::BindOnce(&TestingProvidedFileSystem::CompleteOpen,
base::Unretained(this));
}
const std::vector<int> close_requests() const { return close_requests_; }
private:
OpenFileCallback open_callback_;
std::vector<int> close_requests_;
void CompleteOpen(int file_handle,
base::File::Error result,
std::unique_ptr<EntryMetadata> metadata) {
std::move(open_callback_).Run(file_handle, result, std::move(metadata));
}
void AbortOpen() {
std::move(open_callback_)
.Run(0, base::File::FILE_ERROR_ABORT, /*metadata=*/nullptr);
}
};
typedef std::vector<std::pair<int, base::File::Error>> OpenLog;
void LogOpen(OpenLog* log,
int file_handle,
base::File::Error result,
std::unique_ptr<EntryMetadata> metadata) {
log->emplace_back(file_handle, result);
}
} // namespace
TEST(ScopedFileOpenerTest, AbortWhileOpening) {
TestingProvidedFileSystem file_system;
content::BrowserTaskEnvironment task_environment;
OpenLog log;
{
ScopedFileOpener file_opener(&file_system, base::FilePath(),
OPEN_FILE_MODE_READ,
base::BindOnce(&LogOpen, &log));
base::RunLoop().RunUntilIdle();
EXPECT_TRUE(file_system.has_open_callback());
}
ASSERT_EQ(1u, log.size());
EXPECT_EQ(0, log[0].first);
EXPECT_EQ(base::File::FILE_ERROR_ABORT, log[0].second);
base::RunLoop().RunUntilIdle();
EXPECT_EQ(0u, file_system.close_requests().size());
}
TEST(ScopedFileOpenerTest, CloseAfterOpening) {
TestingProvidedFileSystem file_system;
content::BrowserTaskEnvironment task_environment;
OpenLog log;
{
ScopedFileOpener file_opener(&file_system, base::FilePath(),
OPEN_FILE_MODE_READ,
base::BindOnce(&LogOpen, &log));
base::RunLoop().RunUntilIdle();
ASSERT_TRUE(file_system.has_open_callback());
file_system.open_callback().Run(123, base::File::FILE_OK,
/*cloud_file_info=*/nullptr);
}
ASSERT_EQ(1u, log.size());
EXPECT_EQ(123, log[0].first);
EXPECT_EQ(base::File::FILE_OK, log[0].second);
ASSERT_EQ(1u, file_system.close_requests().size());
EXPECT_EQ(123, file_system.close_requests()[0]);
}
TEST(ScopedFileOpenerTest, CloseAfterAborting) {
TestingProvidedFileSystem file_system;
content::BrowserTaskEnvironment task_environment;
OpenLog log;
{
ScopedFileOpener file_opener(&file_system, base::FilePath(),
OPEN_FILE_MODE_READ,
base::BindOnce(&LogOpen, &log));
base::RunLoop().RunUntilIdle();
ASSERT_TRUE(file_system.has_open_callback());
file_system.open_callback().Run(0, base::File::FILE_ERROR_ABORT,
/*cloud_file_info=*/nullptr);
}
ASSERT_EQ(1u, log.size());
EXPECT_EQ(0, log[0].first);
EXPECT_EQ(base::File::FILE_ERROR_ABORT, log[0].second);
EXPECT_EQ(0u, file_system.close_requests().size());
}
} // namespace ash::file_system_provider
|
