OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "base/files/file_util_proxy.h" | 5 #include "base/files/file_util_proxy.h" |
6 | 6 |
7 #include <map> | 7 #include <map> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/file_util.h" | 10 #include "base/file_util.h" |
11 #include "base/files/scoped_temp_dir.h" | 11 #include "base/files/scoped_temp_dir.h" |
12 #include "base/logging.h" | 12 #include "base/logging.h" |
13 #include "base/memory/weak_ptr.h" | 13 #include "base/memory/weak_ptr.h" |
14 #include "base/message_loop/message_loop.h" | 14 #include "base/message_loop/message_loop.h" |
15 #include "base/platform_file.h" | 15 #include "base/platform_file.h" |
16 #include "base/threading/thread.h" | 16 #include "base/threading/thread.h" |
17 #include "testing/gtest/include/gtest/gtest.h" | 17 #include "testing/gtest/include/gtest/gtest.h" |
18 | 18 |
19 namespace base { | 19 namespace base { |
20 | 20 |
21 class FileUtilProxyTest : public testing::Test { | 21 class FileUtilProxyTest : public testing::Test { |
22 public: | 22 public: |
23 FileUtilProxyTest() | 23 FileUtilProxyTest() |
24 : file_thread_("FileUtilProxyTestFileThread"), | 24 : file_thread_("FileUtilProxyTestFileThread"), |
25 error_(PLATFORM_FILE_OK), | 25 error_(File::FILE_OK), |
26 created_(false), | 26 created_(false), |
27 file_(kInvalidPlatformFileValue), | 27 file_(kInvalidPlatformFileValue), |
28 bytes_written_(-1), | 28 bytes_written_(-1), |
29 weak_factory_(this) {} | 29 weak_factory_(this) {} |
30 | 30 |
31 virtual void SetUp() OVERRIDE { | 31 virtual void SetUp() OVERRIDE { |
32 ASSERT_TRUE(dir_.CreateUniqueTempDir()); | 32 ASSERT_TRUE(dir_.CreateUniqueTempDir()); |
33 ASSERT_TRUE(file_thread_.Start()); | 33 ASSERT_TRUE(file_thread_.Start()); |
34 } | 34 } |
35 | 35 |
36 virtual void TearDown() OVERRIDE { | 36 virtual void TearDown() OVERRIDE { |
37 if (file_ != kInvalidPlatformFileValue) | 37 if (file_ != kInvalidPlatformFileValue) |
38 ClosePlatformFile(file_); | 38 ClosePlatformFile(file_); |
39 } | 39 } |
40 | 40 |
41 void DidFinish(PlatformFileError error) { | 41 void DidFinish(File::Error error) { |
42 error_ = error; | 42 error_ = error; |
43 MessageLoop::current()->QuitWhenIdle(); | 43 MessageLoop::current()->QuitWhenIdle(); |
44 } | 44 } |
45 | 45 |
46 void DidCreateOrOpen(PlatformFileError error, | 46 void DidCreateOrOpen(File::Error error, |
47 PassPlatformFile file, | 47 PassPlatformFile file, |
48 bool created) { | 48 bool created) { |
49 error_ = error; | 49 error_ = error; |
50 file_ = file.ReleaseValue(); | 50 file_ = file.ReleaseValue(); |
51 created_ = created; | 51 created_ = created; |
52 MessageLoop::current()->QuitWhenIdle(); | 52 MessageLoop::current()->QuitWhenIdle(); |
53 } | 53 } |
54 | 54 |
55 void DidCreateTemporary(PlatformFileError error, | 55 void DidCreateTemporary(File::Error error, |
56 PassPlatformFile file, | 56 PassPlatformFile file, |
57 const FilePath& path) { | 57 const FilePath& path) { |
58 error_ = error; | 58 error_ = error; |
59 file_ = file.ReleaseValue(); | 59 file_ = file.ReleaseValue(); |
60 path_ = path; | 60 path_ = path; |
61 MessageLoop::current()->QuitWhenIdle(); | 61 MessageLoop::current()->QuitWhenIdle(); |
62 } | 62 } |
63 | 63 |
64 void DidGetFileInfo(PlatformFileError error, | 64 void DidGetFileInfo(File::Error error, |
65 const PlatformFileInfo& file_info) { | 65 const File::Info& file_info) { |
66 error_ = error; | 66 error_ = error; |
67 file_info_ = file_info; | 67 file_info_ = file_info; |
68 MessageLoop::current()->QuitWhenIdle(); | 68 MessageLoop::current()->QuitWhenIdle(); |
69 } | 69 } |
70 | 70 |
71 void DidRead(PlatformFileError error, | 71 void DidRead(File::Error error, |
72 const char* data, | 72 const char* data, |
73 int bytes_read) { | 73 int bytes_read) { |
74 error_ = error; | 74 error_ = error; |
75 buffer_.resize(bytes_read); | 75 buffer_.resize(bytes_read); |
76 memcpy(&buffer_[0], data, bytes_read); | 76 memcpy(&buffer_[0], data, bytes_read); |
77 MessageLoop::current()->QuitWhenIdle(); | 77 MessageLoop::current()->QuitWhenIdle(); |
78 } | 78 } |
79 | 79 |
80 void DidWrite(PlatformFileError error, | 80 void DidWrite(File::Error error, |
81 int bytes_written) { | 81 int bytes_written) { |
82 error_ = error; | 82 error_ = error; |
83 bytes_written_ = bytes_written; | 83 bytes_written_ = bytes_written; |
84 MessageLoop::current()->QuitWhenIdle(); | 84 MessageLoop::current()->QuitWhenIdle(); |
85 } | 85 } |
86 | 86 |
87 protected: | 87 protected: |
88 PlatformFile GetTestPlatformFile(int flags) { | 88 PlatformFile GetTestPlatformFile(int flags) { |
89 if (file_ != kInvalidPlatformFileValue) | 89 if (file_ != kInvalidPlatformFileValue) |
90 return file_; | 90 return file_; |
91 bool created; | 91 bool created; |
92 PlatformFileError error; | 92 PlatformFileError error; |
93 file_ = CreatePlatformFile(test_path(), flags, &created, &error); | 93 file_ = CreatePlatformFile(test_path(), flags, &created, &error); |
94 EXPECT_EQ(PLATFORM_FILE_OK, error); | 94 EXPECT_EQ(PLATFORM_FILE_OK, error); |
95 EXPECT_NE(kInvalidPlatformFileValue, file_); | 95 EXPECT_NE(kInvalidPlatformFileValue, file_); |
96 return file_; | 96 return file_; |
97 } | 97 } |
98 | 98 |
99 TaskRunner* file_task_runner() const { | 99 TaskRunner* file_task_runner() const { |
100 return file_thread_.message_loop_proxy().get(); | 100 return file_thread_.message_loop_proxy().get(); |
101 } | 101 } |
102 const FilePath& test_dir_path() const { return dir_.path(); } | 102 const FilePath& test_dir_path() const { return dir_.path(); } |
103 const FilePath test_path() const { return dir_.path().AppendASCII("test"); } | 103 const FilePath test_path() const { return dir_.path().AppendASCII("test"); } |
104 | 104 |
105 MessageLoopForIO message_loop_; | 105 MessageLoopForIO message_loop_; |
106 Thread file_thread_; | 106 Thread file_thread_; |
107 | 107 |
108 ScopedTempDir dir_; | 108 ScopedTempDir dir_; |
109 PlatformFileError error_; | 109 File::Error error_; |
110 bool created_; | 110 bool created_; |
111 PlatformFile file_; | 111 PlatformFile file_; |
112 FilePath path_; | 112 FilePath path_; |
113 PlatformFileInfo file_info_; | 113 File::Info file_info_; |
114 std::vector<char> buffer_; | 114 std::vector<char> buffer_; |
115 int bytes_written_; | 115 int bytes_written_; |
116 WeakPtrFactory<FileUtilProxyTest> weak_factory_; | 116 WeakPtrFactory<FileUtilProxyTest> weak_factory_; |
117 }; | 117 }; |
118 | 118 |
119 TEST_F(FileUtilProxyTest, CreateOrOpen_Create) { | 119 TEST_F(FileUtilProxyTest, CreateOrOpen_Create) { |
120 FileUtilProxy::CreateOrOpen( | 120 FileUtilProxy::CreateOrOpen( |
121 file_task_runner(), | 121 file_task_runner(), |
122 test_path(), | 122 test_path(), |
123 PLATFORM_FILE_CREATE | PLATFORM_FILE_READ, | 123 PLATFORM_FILE_CREATE | PLATFORM_FILE_READ, |
124 Bind(&FileUtilProxyTest::DidCreateOrOpen, weak_factory_.GetWeakPtr())); | 124 Bind(&FileUtilProxyTest::DidCreateOrOpen, weak_factory_.GetWeakPtr())); |
125 MessageLoop::current()->Run(); | 125 MessageLoop::current()->Run(); |
126 | 126 |
127 EXPECT_EQ(PLATFORM_FILE_OK, error_); | 127 EXPECT_EQ(File::FILE_OK, error_); |
128 EXPECT_TRUE(created_); | 128 EXPECT_TRUE(created_); |
129 EXPECT_NE(kInvalidPlatformFileValue, file_); | 129 EXPECT_NE(kInvalidPlatformFileValue, file_); |
130 EXPECT_TRUE(PathExists(test_path())); | 130 EXPECT_TRUE(PathExists(test_path())); |
131 } | 131 } |
132 | 132 |
133 TEST_F(FileUtilProxyTest, CreateOrOpen_Open) { | 133 TEST_F(FileUtilProxyTest, CreateOrOpen_Open) { |
134 // Creates a file. | 134 // Creates a file. |
135 file_util::WriteFile(test_path(), NULL, 0); | 135 file_util::WriteFile(test_path(), NULL, 0); |
136 ASSERT_TRUE(PathExists(test_path())); | 136 ASSERT_TRUE(PathExists(test_path())); |
137 | 137 |
138 // Opens the created file. | 138 // Opens the created file. |
139 FileUtilProxy::CreateOrOpen( | 139 FileUtilProxy::CreateOrOpen( |
140 file_task_runner(), | 140 file_task_runner(), |
141 test_path(), | 141 test_path(), |
142 PLATFORM_FILE_OPEN | PLATFORM_FILE_READ, | 142 PLATFORM_FILE_OPEN | PLATFORM_FILE_READ, |
143 Bind(&FileUtilProxyTest::DidCreateOrOpen, weak_factory_.GetWeakPtr())); | 143 Bind(&FileUtilProxyTest::DidCreateOrOpen, weak_factory_.GetWeakPtr())); |
144 MessageLoop::current()->Run(); | 144 MessageLoop::current()->Run(); |
145 | 145 |
146 EXPECT_EQ(PLATFORM_FILE_OK, error_); | 146 EXPECT_EQ(File::FILE_OK, error_); |
147 EXPECT_FALSE(created_); | 147 EXPECT_FALSE(created_); |
148 EXPECT_NE(kInvalidPlatformFileValue, file_); | 148 EXPECT_NE(kInvalidPlatformFileValue, file_); |
149 } | 149 } |
150 | 150 |
151 TEST_F(FileUtilProxyTest, CreateOrOpen_OpenNonExistent) { | 151 TEST_F(FileUtilProxyTest, CreateOrOpen_OpenNonExistent) { |
152 FileUtilProxy::CreateOrOpen( | 152 FileUtilProxy::CreateOrOpen( |
153 file_task_runner(), | 153 file_task_runner(), |
154 test_path(), | 154 test_path(), |
155 PLATFORM_FILE_OPEN | PLATFORM_FILE_READ, | 155 PLATFORM_FILE_OPEN | PLATFORM_FILE_READ, |
156 Bind(&FileUtilProxyTest::DidCreateOrOpen, weak_factory_.GetWeakPtr())); | 156 Bind(&FileUtilProxyTest::DidCreateOrOpen, weak_factory_.GetWeakPtr())); |
157 MessageLoop::current()->Run(); | 157 MessageLoop::current()->Run(); |
158 EXPECT_EQ(PLATFORM_FILE_ERROR_NOT_FOUND, error_); | 158 EXPECT_EQ(File::FILE_ERROR_NOT_FOUND, error_); |
159 EXPECT_FALSE(created_); | 159 EXPECT_FALSE(created_); |
160 EXPECT_EQ(kInvalidPlatformFileValue, file_); | 160 EXPECT_EQ(kInvalidPlatformFileValue, file_); |
161 EXPECT_FALSE(PathExists(test_path())); | 161 EXPECT_FALSE(PathExists(test_path())); |
162 } | 162 } |
163 | 163 |
164 TEST_F(FileUtilProxyTest, Close) { | 164 TEST_F(FileUtilProxyTest, Close) { |
165 // Creates a file. | 165 // Creates a file. |
166 PlatformFile file = GetTestPlatformFile( | 166 PlatformFile file = GetTestPlatformFile( |
167 PLATFORM_FILE_CREATE | PLATFORM_FILE_WRITE); | 167 PLATFORM_FILE_CREATE | PLATFORM_FILE_WRITE); |
168 | 168 |
169 #if defined(OS_WIN) | 169 #if defined(OS_WIN) |
170 // This fails on Windows if the file is not closed. | 170 // This fails on Windows if the file is not closed. |
171 EXPECT_FALSE(base::Move(test_path(), | 171 EXPECT_FALSE(base::Move(test_path(), |
172 test_dir_path().AppendASCII("new"))); | 172 test_dir_path().AppendASCII("new"))); |
173 #endif | 173 #endif |
174 | 174 |
175 FileUtilProxy::Close( | 175 FileUtilProxy::Close( |
176 file_task_runner(), | 176 file_task_runner(), |
177 file, | 177 file, |
178 Bind(&FileUtilProxyTest::DidFinish, weak_factory_.GetWeakPtr())); | 178 Bind(&FileUtilProxyTest::DidFinish, weak_factory_.GetWeakPtr())); |
179 MessageLoop::current()->Run(); | 179 MessageLoop::current()->Run(); |
180 EXPECT_EQ(PLATFORM_FILE_OK, error_); | 180 EXPECT_EQ(File::FILE_OK, error_); |
181 | 181 |
182 // Now it should pass on all platforms. | 182 // Now it should pass on all platforms. |
183 EXPECT_TRUE(base::Move(test_path(), test_dir_path().AppendASCII("new"))); | 183 EXPECT_TRUE(base::Move(test_path(), test_dir_path().AppendASCII("new"))); |
184 } | 184 } |
185 | 185 |
186 TEST_F(FileUtilProxyTest, CreateTemporary) { | 186 TEST_F(FileUtilProxyTest, CreateTemporary) { |
187 FileUtilProxy::CreateTemporary( | 187 FileUtilProxy::CreateTemporary( |
188 file_task_runner(), 0 /* additional_file_flags */, | 188 file_task_runner(), 0 /* additional_file_flags */, |
189 Bind(&FileUtilProxyTest::DidCreateTemporary, weak_factory_.GetWeakPtr())); | 189 Bind(&FileUtilProxyTest::DidCreateTemporary, weak_factory_.GetWeakPtr())); |
190 MessageLoop::current()->Run(); | 190 MessageLoop::current()->Run(); |
191 EXPECT_EQ(PLATFORM_FILE_OK, error_); | 191 EXPECT_EQ(File::FILE_OK, error_); |
192 EXPECT_TRUE(PathExists(path_)); | 192 EXPECT_TRUE(PathExists(path_)); |
193 EXPECT_NE(kInvalidPlatformFileValue, file_); | 193 EXPECT_NE(kInvalidPlatformFileValue, file_); |
194 | 194 |
195 // The file should be writable. | 195 // The file should be writable. |
196 #if defined(OS_WIN) | 196 #if defined(OS_WIN) |
197 HANDLE hEvent = CreateEvent(NULL, FALSE, FALSE, NULL); | 197 HANDLE hEvent = CreateEvent(NULL, FALSE, FALSE, NULL); |
198 OVERLAPPED overlapped = {0}; | 198 OVERLAPPED overlapped = {0}; |
199 overlapped.hEvent = hEvent; | 199 overlapped.hEvent = hEvent; |
200 DWORD bytes_written; | 200 DWORD bytes_written; |
201 if (!::WriteFile(file_, "test", 4, &bytes_written, &overlapped)) { | 201 if (!::WriteFile(file_, "test", 4, &bytes_written, &overlapped)) { |
(...skipping 26 matching lines...) Expand all Loading... |
228 GetFileInfo(test_path(), &expected_info); | 228 GetFileInfo(test_path(), &expected_info); |
229 | 229 |
230 // Run. | 230 // Run. |
231 FileUtilProxy::GetFileInfo( | 231 FileUtilProxy::GetFileInfo( |
232 file_task_runner(), | 232 file_task_runner(), |
233 test_path(), | 233 test_path(), |
234 Bind(&FileUtilProxyTest::DidGetFileInfo, weak_factory_.GetWeakPtr())); | 234 Bind(&FileUtilProxyTest::DidGetFileInfo, weak_factory_.GetWeakPtr())); |
235 MessageLoop::current()->Run(); | 235 MessageLoop::current()->Run(); |
236 | 236 |
237 // Verify. | 237 // Verify. |
238 EXPECT_EQ(PLATFORM_FILE_OK, error_); | 238 EXPECT_EQ(File::FILE_OK, error_); |
239 EXPECT_EQ(expected_info.size, file_info_.size); | 239 EXPECT_EQ(expected_info.size, file_info_.size); |
240 EXPECT_EQ(expected_info.is_directory, file_info_.is_directory); | 240 EXPECT_EQ(expected_info.is_directory, file_info_.is_directory); |
241 EXPECT_EQ(expected_info.is_symbolic_link, file_info_.is_symbolic_link); | 241 EXPECT_EQ(expected_info.is_symbolic_link, file_info_.is_symbolic_link); |
242 EXPECT_EQ(expected_info.last_modified, file_info_.last_modified); | 242 EXPECT_EQ(expected_info.last_modified, file_info_.last_modified); |
243 EXPECT_EQ(expected_info.last_accessed, file_info_.last_accessed); | 243 EXPECT_EQ(expected_info.last_accessed, file_info_.last_accessed); |
244 EXPECT_EQ(expected_info.creation_time, file_info_.creation_time); | 244 EXPECT_EQ(expected_info.creation_time, file_info_.creation_time); |
245 } | 245 } |
246 | 246 |
247 TEST_F(FileUtilProxyTest, GetFileInfo_Directory) { | 247 TEST_F(FileUtilProxyTest, GetFileInfo_Directory) { |
248 // Setup. | 248 // Setup. |
249 ASSERT_TRUE(base::CreateDirectory(test_path())); | 249 ASSERT_TRUE(base::CreateDirectory(test_path())); |
250 File::Info expected_info; | 250 File::Info expected_info; |
251 GetFileInfo(test_path(), &expected_info); | 251 GetFileInfo(test_path(), &expected_info); |
252 | 252 |
253 // Run. | 253 // Run. |
254 FileUtilProxy::GetFileInfo( | 254 FileUtilProxy::GetFileInfo( |
255 file_task_runner(), | 255 file_task_runner(), |
256 test_path(), | 256 test_path(), |
257 Bind(&FileUtilProxyTest::DidGetFileInfo, weak_factory_.GetWeakPtr())); | 257 Bind(&FileUtilProxyTest::DidGetFileInfo, weak_factory_.GetWeakPtr())); |
258 MessageLoop::current()->Run(); | 258 MessageLoop::current()->Run(); |
259 | 259 |
260 // Verify. | 260 // Verify. |
261 EXPECT_EQ(PLATFORM_FILE_OK, error_); | 261 EXPECT_EQ(File::FILE_OK, error_); |
262 EXPECT_EQ(expected_info.size, file_info_.size); | 262 EXPECT_EQ(expected_info.size, file_info_.size); |
263 EXPECT_EQ(expected_info.is_directory, file_info_.is_directory); | 263 EXPECT_EQ(expected_info.is_directory, file_info_.is_directory); |
264 EXPECT_EQ(expected_info.is_symbolic_link, file_info_.is_symbolic_link); | 264 EXPECT_EQ(expected_info.is_symbolic_link, file_info_.is_symbolic_link); |
265 EXPECT_EQ(expected_info.last_modified, file_info_.last_modified); | 265 EXPECT_EQ(expected_info.last_modified, file_info_.last_modified); |
266 EXPECT_EQ(expected_info.last_accessed, file_info_.last_accessed); | 266 EXPECT_EQ(expected_info.last_accessed, file_info_.last_accessed); |
267 EXPECT_EQ(expected_info.creation_time, file_info_.creation_time); | 267 EXPECT_EQ(expected_info.creation_time, file_info_.creation_time); |
268 } | 268 } |
269 | 269 |
270 TEST_F(FileUtilProxyTest, Read) { | 270 TEST_F(FileUtilProxyTest, Read) { |
271 // Setup. | 271 // Setup. |
272 const char expected_data[] = "bleh"; | 272 const char expected_data[] = "bleh"; |
273 int expected_bytes = arraysize(expected_data); | 273 int expected_bytes = arraysize(expected_data); |
274 ASSERT_EQ(expected_bytes, | 274 ASSERT_EQ(expected_bytes, |
275 file_util::WriteFile(test_path(), expected_data, expected_bytes)); | 275 file_util::WriteFile(test_path(), expected_data, expected_bytes)); |
276 | 276 |
277 // Run. | 277 // Run. |
278 FileUtilProxy::Read( | 278 FileUtilProxy::Read( |
279 file_task_runner(), | 279 file_task_runner(), |
280 GetTestPlatformFile(PLATFORM_FILE_OPEN | PLATFORM_FILE_READ), | 280 GetTestPlatformFile(PLATFORM_FILE_OPEN | PLATFORM_FILE_READ), |
281 0, // offset | 281 0, // offset |
282 128, | 282 128, |
283 Bind(&FileUtilProxyTest::DidRead, weak_factory_.GetWeakPtr())); | 283 Bind(&FileUtilProxyTest::DidRead, weak_factory_.GetWeakPtr())); |
284 MessageLoop::current()->Run(); | 284 MessageLoop::current()->Run(); |
285 | 285 |
286 // Verify. | 286 // Verify. |
287 EXPECT_EQ(PLATFORM_FILE_OK, error_); | 287 EXPECT_EQ(File::FILE_OK, error_); |
288 EXPECT_EQ(expected_bytes, static_cast<int>(buffer_.size())); | 288 EXPECT_EQ(expected_bytes, static_cast<int>(buffer_.size())); |
289 for (size_t i = 0; i < buffer_.size(); ++i) { | 289 for (size_t i = 0; i < buffer_.size(); ++i) { |
290 EXPECT_EQ(expected_data[i], buffer_[i]); | 290 EXPECT_EQ(expected_data[i], buffer_[i]); |
291 } | 291 } |
292 } | 292 } |
293 | 293 |
294 TEST_F(FileUtilProxyTest, WriteAndFlush) { | 294 TEST_F(FileUtilProxyTest, WriteAndFlush) { |
295 const char data[] = "foo!"; | 295 const char data[] = "foo!"; |
296 int data_bytes = ARRAYSIZE_UNSAFE(data); | 296 int data_bytes = ARRAYSIZE_UNSAFE(data); |
297 PlatformFile file = GetTestPlatformFile( | 297 PlatformFile file = GetTestPlatformFile( |
298 PLATFORM_FILE_CREATE | PLATFORM_FILE_WRITE); | 298 PLATFORM_FILE_CREATE | PLATFORM_FILE_WRITE); |
299 | 299 |
300 FileUtilProxy::Write( | 300 FileUtilProxy::Write( |
301 file_task_runner(), | 301 file_task_runner(), |
302 file, | 302 file, |
303 0, // offset | 303 0, // offset |
304 data, | 304 data, |
305 data_bytes, | 305 data_bytes, |
306 Bind(&FileUtilProxyTest::DidWrite, weak_factory_.GetWeakPtr())); | 306 Bind(&FileUtilProxyTest::DidWrite, weak_factory_.GetWeakPtr())); |
307 MessageLoop::current()->Run(); | 307 MessageLoop::current()->Run(); |
308 EXPECT_EQ(PLATFORM_FILE_OK, error_); | 308 EXPECT_EQ(File::FILE_OK, error_); |
309 EXPECT_EQ(data_bytes, bytes_written_); | 309 EXPECT_EQ(data_bytes, bytes_written_); |
310 | 310 |
311 // Flush the written data. (So that the following read should always | 311 // Flush the written data. (So that the following read should always |
312 // succeed. On some platforms it may work with or without this flush.) | 312 // succeed. On some platforms it may work with or without this flush.) |
313 FileUtilProxy::Flush( | 313 FileUtilProxy::Flush( |
314 file_task_runner(), | 314 file_task_runner(), |
315 file, | 315 file, |
316 Bind(&FileUtilProxyTest::DidFinish, weak_factory_.GetWeakPtr())); | 316 Bind(&FileUtilProxyTest::DidFinish, weak_factory_.GetWeakPtr())); |
317 MessageLoop::current()->Run(); | 317 MessageLoop::current()->Run(); |
318 EXPECT_EQ(PLATFORM_FILE_OK, error_); | 318 EXPECT_EQ(File::FILE_OK, error_); |
319 | 319 |
320 // Verify the written data. | 320 // Verify the written data. |
321 char buffer[10]; | 321 char buffer[10]; |
322 EXPECT_EQ(data_bytes, base::ReadFile(test_path(), buffer, data_bytes)); | 322 EXPECT_EQ(data_bytes, base::ReadFile(test_path(), buffer, data_bytes)); |
323 for (int i = 0; i < data_bytes; ++i) { | 323 for (int i = 0; i < data_bytes; ++i) { |
324 EXPECT_EQ(data[i], buffer[i]); | 324 EXPECT_EQ(data[i], buffer[i]); |
325 } | 325 } |
326 } | 326 } |
327 | 327 |
328 TEST_F(FileUtilProxyTest, Touch) { | 328 TEST_F(FileUtilProxyTest, Touch) { |
329 Time last_accessed_time = Time::Now() - TimeDelta::FromDays(12345); | 329 Time last_accessed_time = Time::Now() - TimeDelta::FromDays(12345); |
330 Time last_modified_time = Time::Now() - TimeDelta::FromHours(98765); | 330 Time last_modified_time = Time::Now() - TimeDelta::FromHours(98765); |
331 | 331 |
332 FileUtilProxy::Touch( | 332 FileUtilProxy::Touch( |
333 file_task_runner(), | 333 file_task_runner(), |
334 GetTestPlatformFile(PLATFORM_FILE_CREATE | | 334 GetTestPlatformFile(PLATFORM_FILE_CREATE | |
335 PLATFORM_FILE_WRITE | | 335 PLATFORM_FILE_WRITE | |
336 PLATFORM_FILE_WRITE_ATTRIBUTES), | 336 PLATFORM_FILE_WRITE_ATTRIBUTES), |
337 last_accessed_time, | 337 last_accessed_time, |
338 last_modified_time, | 338 last_modified_time, |
339 Bind(&FileUtilProxyTest::DidFinish, weak_factory_.GetWeakPtr())); | 339 Bind(&FileUtilProxyTest::DidFinish, weak_factory_.GetWeakPtr())); |
340 MessageLoop::current()->Run(); | 340 MessageLoop::current()->Run(); |
341 EXPECT_EQ(PLATFORM_FILE_OK, error_); | 341 EXPECT_EQ(File::FILE_OK, error_); |
342 | 342 |
343 File::Info info; | 343 File::Info info; |
344 GetFileInfo(test_path(), &info); | 344 GetFileInfo(test_path(), &info); |
345 | 345 |
346 // The returned values may only have the seconds precision, so we cast | 346 // The returned values may only have the seconds precision, so we cast |
347 // the double values to int here. | 347 // the double values to int here. |
348 EXPECT_EQ(static_cast<int>(last_modified_time.ToDoubleT()), | 348 EXPECT_EQ(static_cast<int>(last_modified_time.ToDoubleT()), |
349 static_cast<int>(info.last_modified.ToDoubleT())); | 349 static_cast<int>(info.last_modified.ToDoubleT())); |
350 EXPECT_EQ(static_cast<int>(last_accessed_time.ToDoubleT()), | 350 EXPECT_EQ(static_cast<int>(last_accessed_time.ToDoubleT()), |
351 static_cast<int>(info.last_accessed.ToDoubleT())); | 351 static_cast<int>(info.last_accessed.ToDoubleT())); |
(...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
401 char buffer[53]; | 401 char buffer[53]; |
402 EXPECT_EQ(53, base::ReadFile(test_path(), buffer, 53)); | 402 EXPECT_EQ(53, base::ReadFile(test_path(), buffer, 53)); |
403 int i = 0; | 403 int i = 0; |
404 for (; i < 10; ++i) | 404 for (; i < 10; ++i) |
405 EXPECT_EQ(kTestData[i], buffer[i]); | 405 EXPECT_EQ(kTestData[i], buffer[i]); |
406 for (; i < 53; ++i) | 406 for (; i < 53; ++i) |
407 EXPECT_EQ(0, buffer[i]); | 407 EXPECT_EQ(0, buffer[i]); |
408 } | 408 } |
409 | 409 |
410 } // namespace base | 410 } // namespace base |
OLD | NEW |