OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "chrome/browser/chromeos/file_system_provider/fileapi/file_stream_reade
r.h" | 5 #include "chrome/browser/chromeos/file_system_provider/fileapi/file_stream_reade
r.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 #include <vector> | 8 #include <vector> |
9 | 9 |
10 #include "base/files/file.h" | 10 #include "base/files/file.h" |
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
74 // TearDown(). | 74 // TearDown(). |
75 KeyedService* CreateService(content::BrowserContext* context) { | 75 KeyedService* CreateService(content::BrowserContext* context) { |
76 return new Service(Profile::FromBrowserContext(context), | 76 return new Service(Profile::FromBrowserContext(context), |
77 extensions::ExtensionRegistry::Get(context)); | 77 extensions::ExtensionRegistry::Get(context)); |
78 } | 78 } |
79 | 79 |
80 } // namespace | 80 } // namespace |
81 | 81 |
82 class FileSystemProviderFileStreamReader : public testing::Test { | 82 class FileSystemProviderFileStreamReader : public testing::Test { |
83 protected: | 83 protected: |
84 FileSystemProviderFileStreamReader() {} | 84 FileSystemProviderFileStreamReader() : profile_(NULL), fake_file_(NULL) {} |
85 virtual ~FileSystemProviderFileStreamReader() {} | 85 virtual ~FileSystemProviderFileStreamReader() {} |
86 | 86 |
87 virtual void SetUp() OVERRIDE { | 87 virtual void SetUp() OVERRIDE { |
88 ASSERT_TRUE(data_dir_.CreateUniqueTempDir()); | 88 ASSERT_TRUE(data_dir_.CreateUniqueTempDir()); |
89 profile_manager_.reset( | 89 profile_manager_.reset( |
90 new TestingProfileManager(TestingBrowserProcess::GetGlobal())); | 90 new TestingProfileManager(TestingBrowserProcess::GetGlobal())); |
91 ASSERT_TRUE(profile_manager_->SetUp()); | 91 ASSERT_TRUE(profile_manager_->SetUp()); |
92 profile_ = profile_manager_->CreateTestingProfile("testing-profile"); | 92 profile_ = profile_manager_->CreateTestingProfile("testing-profile"); |
93 | 93 |
94 ServiceFactory::GetInstance()->SetTestingFactory(profile_, &CreateService); | 94 ServiceFactory::GetInstance()->SetTestingFactory(profile_, &CreateService); |
95 Service* service = Service::Get(profile_); // Owned by its factory. | 95 Service* service = Service::Get(profile_); // Owned by its factory. |
96 service->SetFileSystemFactoryForTesting( | 96 service->SetFileSystemFactoryForTesting( |
97 base::Bind(&FakeProvidedFileSystem::Create)); | 97 base::Bind(&FakeProvidedFileSystem::Create)); |
98 | 98 |
99 const bool result = service->MountFileSystem(kExtensionId, | 99 const bool result = service->MountFileSystem(kExtensionId, |
100 kFileSystemId, | 100 kFileSystemId, |
101 "Testing File System", | 101 "Testing File System", |
102 false /* writable */); | 102 false /* writable */); |
103 ASSERT_TRUE(result); | 103 ASSERT_TRUE(result); |
104 FakeProvidedFileSystem* provided_file_system = | 104 FakeProvidedFileSystem* provided_file_system = |
105 static_cast<FakeProvidedFileSystem*>( | 105 static_cast<FakeProvidedFileSystem*>( |
106 service->GetProvidedFileSystem(kExtensionId, kFileSystemId)); | 106 service->GetProvidedFileSystem(kExtensionId, kFileSystemId)); |
107 ASSERT_TRUE(provided_file_system); | 107 ASSERT_TRUE(provided_file_system); |
108 ASSERT_TRUE(provided_file_system->GetEntry( | 108 fake_file_ = provided_file_system->GetEntry( |
109 base::FilePath::FromUTF8Unsafe(kFakeFilePath), &fake_file_)); | 109 base::FilePath::FromUTF8Unsafe(kFakeFilePath)); |
| 110 ASSERT_TRUE(fake_file_); |
110 const ProvidedFileSystemInfo& file_system_info = | 111 const ProvidedFileSystemInfo& file_system_info = |
111 service->GetProvidedFileSystem(kExtensionId, kFileSystemId) | 112 service->GetProvidedFileSystem(kExtensionId, kFileSystemId) |
112 ->GetFileSystemInfo(); | 113 ->GetFileSystemInfo(); |
113 const std::string mount_point_name = | 114 const std::string mount_point_name = |
114 file_system_info.mount_path().BaseName().AsUTF8Unsafe(); | 115 file_system_info.mount_path().BaseName().AsUTF8Unsafe(); |
115 | 116 |
116 file_url_ = CreateFileSystemURL( | 117 file_url_ = CreateFileSystemURL( |
117 mount_point_name, base::FilePath::FromUTF8Unsafe(kFakeFilePath + 1)); | 118 mount_point_name, base::FilePath::FromUTF8Unsafe(kFakeFilePath + 1)); |
118 ASSERT_TRUE(file_url_.is_valid()); | 119 ASSERT_TRUE(file_url_.is_valid()); |
119 wrong_file_url_ = CreateFileSystemURL( | 120 wrong_file_url_ = CreateFileSystemURL( |
120 mount_point_name, base::FilePath::FromUTF8Unsafe("im-not-here.txt")); | 121 mount_point_name, base::FilePath::FromUTF8Unsafe("im-not-here.txt")); |
121 ASSERT_TRUE(wrong_file_url_.is_valid()); | 122 ASSERT_TRUE(wrong_file_url_.is_valid()); |
122 } | 123 } |
123 | 124 |
124 virtual void TearDown() OVERRIDE { | 125 virtual void TearDown() OVERRIDE { |
125 // Setting the testing factory to NULL will destroy the created service | 126 // Setting the testing factory to NULL will destroy the created service |
126 // associated with the testing profile. | 127 // associated with the testing profile. |
127 ServiceFactory::GetInstance()->SetTestingFactory(profile_, NULL); | 128 ServiceFactory::GetInstance()->SetTestingFactory(profile_, NULL); |
128 } | 129 } |
129 | 130 |
130 content::TestBrowserThreadBundle thread_bundle_; | 131 content::TestBrowserThreadBundle thread_bundle_; |
131 base::ScopedTempDir data_dir_; | 132 base::ScopedTempDir data_dir_; |
132 scoped_ptr<TestingProfileManager> profile_manager_; | 133 scoped_ptr<TestingProfileManager> profile_manager_; |
133 TestingProfile* profile_; // Owned by TestingProfileManager. | 134 TestingProfile* profile_; // Owned by TestingProfileManager. |
134 FakeEntry fake_file_; | 135 const FakeEntry* fake_file_; // Owned by FakePRovidedFileSystem. |
135 storage::FileSystemURL file_url_; | 136 storage::FileSystemURL file_url_; |
136 storage::FileSystemURL wrong_file_url_; | 137 storage::FileSystemURL wrong_file_url_; |
137 }; | 138 }; |
138 | 139 |
139 TEST_F(FileSystemProviderFileStreamReader, Read_AllAtOnce) { | 140 TEST_F(FileSystemProviderFileStreamReader, Read_AllAtOnce) { |
140 EventLogger logger; | 141 EventLogger logger; |
141 | 142 |
142 const int64 initial_offset = 0; | 143 const int64 initial_offset = 0; |
143 FileStreamReader reader( | 144 FileStreamReader reader( |
144 NULL, file_url_, initial_offset, fake_file_.metadata.modification_time); | 145 NULL, file_url_, initial_offset, fake_file_->metadata->modification_time); |
145 scoped_refptr<net::IOBuffer> io_buffer( | 146 scoped_refptr<net::IOBuffer> io_buffer( |
146 new net::IOBuffer(fake_file_.metadata.size)); | 147 new net::IOBuffer(fake_file_->metadata->size)); |
147 | 148 |
148 const int result = | 149 const int result = |
149 reader.Read(io_buffer.get(), | 150 reader.Read(io_buffer.get(), |
150 fake_file_.metadata.size, | 151 fake_file_->metadata->size, |
151 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); | 152 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); |
152 EXPECT_EQ(net::ERR_IO_PENDING, result); | 153 EXPECT_EQ(net::ERR_IO_PENDING, result); |
153 base::RunLoop().RunUntilIdle(); | 154 base::RunLoop().RunUntilIdle(); |
154 | 155 |
155 ASSERT_EQ(1u, logger.results().size()); | 156 ASSERT_EQ(1u, logger.results().size()); |
156 EXPECT_LT(0, logger.results()[0]); | 157 EXPECT_LT(0, logger.results()[0]); |
157 EXPECT_EQ(fake_file_.metadata.size, logger.results()[0]); | 158 EXPECT_EQ(fake_file_->metadata->size, logger.results()[0]); |
158 | 159 |
159 std::string buffer_as_string(io_buffer->data(), fake_file_.metadata.size); | 160 std::string buffer_as_string(io_buffer->data(), fake_file_->metadata->size); |
160 EXPECT_EQ(fake_file_.contents, buffer_as_string); | 161 EXPECT_EQ(fake_file_->contents, buffer_as_string); |
161 } | 162 } |
162 | 163 |
163 TEST_F(FileSystemProviderFileStreamReader, Read_WrongFile) { | 164 TEST_F(FileSystemProviderFileStreamReader, Read_WrongFile) { |
164 EventLogger logger; | 165 EventLogger logger; |
165 | 166 |
166 const int64 initial_offset = 0; | 167 const int64 initial_offset = 0; |
167 FileStreamReader reader(NULL, | 168 FileStreamReader reader(NULL, |
168 wrong_file_url_, | 169 wrong_file_url_, |
169 initial_offset, | 170 initial_offset, |
170 fake_file_.metadata.modification_time); | 171 fake_file_->metadata->modification_time); |
171 scoped_refptr<net::IOBuffer> io_buffer( | 172 scoped_refptr<net::IOBuffer> io_buffer( |
172 new net::IOBuffer(fake_file_.metadata.size)); | 173 new net::IOBuffer(fake_file_->metadata->size)); |
173 | 174 |
174 const int result = | 175 const int result = |
175 reader.Read(io_buffer.get(), | 176 reader.Read(io_buffer.get(), |
176 fake_file_.metadata.size, | 177 fake_file_->metadata->size, |
177 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); | 178 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); |
178 EXPECT_EQ(net::ERR_IO_PENDING, result); | 179 EXPECT_EQ(net::ERR_IO_PENDING, result); |
179 base::RunLoop().RunUntilIdle(); | 180 base::RunLoop().RunUntilIdle(); |
180 | 181 |
181 ASSERT_EQ(1u, logger.results().size()); | 182 ASSERT_EQ(1u, logger.results().size()); |
182 EXPECT_EQ(net::ERR_FILE_NOT_FOUND, logger.results()[0]); | 183 EXPECT_EQ(net::ERR_FILE_NOT_FOUND, logger.results()[0]); |
183 } | 184 } |
184 | 185 |
185 TEST_F(FileSystemProviderFileStreamReader, Read_InChunks) { | 186 TEST_F(FileSystemProviderFileStreamReader, Read_InChunks) { |
186 EventLogger logger; | 187 EventLogger logger; |
187 | 188 |
188 const int64 initial_offset = 0; | 189 const int64 initial_offset = 0; |
189 FileStreamReader reader( | 190 FileStreamReader reader( |
190 NULL, file_url_, initial_offset, fake_file_.metadata.modification_time); | 191 NULL, file_url_, initial_offset, fake_file_->metadata->modification_time); |
191 | 192 |
192 for (int64 offset = 0; offset < fake_file_.metadata.size; ++offset) { | 193 for (int64 offset = 0; offset < fake_file_->metadata->size; ++offset) { |
193 scoped_refptr<net::IOBuffer> io_buffer(new net::IOBuffer(1)); | 194 scoped_refptr<net::IOBuffer> io_buffer(new net::IOBuffer(1)); |
194 const int result = | 195 const int result = |
195 reader.Read(io_buffer.get(), | 196 reader.Read(io_buffer.get(), |
196 1, | 197 1, |
197 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); | 198 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); |
198 EXPECT_EQ(net::ERR_IO_PENDING, result); | 199 EXPECT_EQ(net::ERR_IO_PENDING, result); |
199 base::RunLoop().RunUntilIdle(); | 200 base::RunLoop().RunUntilIdle(); |
200 ASSERT_EQ(offset + 1, static_cast<int64>(logger.results().size())); | 201 ASSERT_EQ(offset + 1, static_cast<int64>(logger.results().size())); |
201 EXPECT_EQ(1, logger.results()[offset]); | 202 EXPECT_EQ(1, logger.results()[offset]); |
202 EXPECT_EQ(fake_file_.contents[offset], io_buffer->data()[0]); | 203 EXPECT_EQ(fake_file_->contents[offset], io_buffer->data()[0]); |
203 } | 204 } |
204 } | 205 } |
205 | 206 |
206 TEST_F(FileSystemProviderFileStreamReader, Read_Slice) { | 207 TEST_F(FileSystemProviderFileStreamReader, Read_Slice) { |
207 EventLogger logger; | 208 EventLogger logger; |
208 | 209 |
209 // Trim first 3 and last 3 characters. | 210 // Trim first 3 and last 3 characters. |
210 const int64 initial_offset = 3; | 211 const int64 initial_offset = 3; |
211 const int length = fake_file_.metadata.size - initial_offset - 3; | 212 const int length = fake_file_->metadata->size - initial_offset - 3; |
212 ASSERT_GT(fake_file_.metadata.size, initial_offset); | 213 ASSERT_GT(fake_file_->metadata->size, initial_offset); |
213 ASSERT_LT(0, length); | 214 ASSERT_LT(0, length); |
214 | 215 |
215 FileStreamReader reader( | 216 FileStreamReader reader( |
216 NULL, file_url_, initial_offset, fake_file_.metadata.modification_time); | 217 NULL, file_url_, initial_offset, fake_file_->metadata->modification_time); |
217 scoped_refptr<net::IOBuffer> io_buffer(new net::IOBuffer(length)); | 218 scoped_refptr<net::IOBuffer> io_buffer(new net::IOBuffer(length)); |
218 | 219 |
219 const int result = | 220 const int result = |
220 reader.Read(io_buffer.get(), | 221 reader.Read(io_buffer.get(), |
221 length, | 222 length, |
222 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); | 223 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); |
223 EXPECT_EQ(net::ERR_IO_PENDING, result); | 224 EXPECT_EQ(net::ERR_IO_PENDING, result); |
224 base::RunLoop().RunUntilIdle(); | 225 base::RunLoop().RunUntilIdle(); |
225 | 226 |
226 ASSERT_EQ(1u, logger.results().size()); | 227 ASSERT_EQ(1u, logger.results().size()); |
227 EXPECT_EQ(length, logger.results()[0]); | 228 EXPECT_EQ(length, logger.results()[0]); |
228 | 229 |
229 std::string buffer_as_string(io_buffer->data(), length); | 230 std::string buffer_as_string(io_buffer->data(), length); |
230 std::string expected_buffer(fake_file_.contents.data() + initial_offset, | 231 std::string expected_buffer(fake_file_->contents.data() + initial_offset, |
231 length); | 232 length); |
232 EXPECT_EQ(expected_buffer, buffer_as_string); | 233 EXPECT_EQ(expected_buffer, buffer_as_string); |
233 } | 234 } |
234 | 235 |
235 TEST_F(FileSystemProviderFileStreamReader, Read_Beyond) { | 236 TEST_F(FileSystemProviderFileStreamReader, Read_Beyond) { |
236 EventLogger logger; | 237 EventLogger logger; |
237 | 238 |
238 // Request reading 1KB more than available. | 239 // Request reading 1KB more than available. |
239 const int64 initial_offset = 0; | 240 const int64 initial_offset = 0; |
240 const int length = fake_file_.metadata.size + 1024; | 241 const int length = fake_file_->metadata->size + 1024; |
241 | 242 |
242 FileStreamReader reader( | 243 FileStreamReader reader( |
243 NULL, file_url_, initial_offset, fake_file_.metadata.modification_time); | 244 NULL, file_url_, initial_offset, fake_file_->metadata->modification_time); |
244 scoped_refptr<net::IOBuffer> io_buffer(new net::IOBuffer(length)); | 245 scoped_refptr<net::IOBuffer> io_buffer(new net::IOBuffer(length)); |
245 | 246 |
246 const int result = | 247 const int result = |
247 reader.Read(io_buffer.get(), | 248 reader.Read(io_buffer.get(), |
248 length, | 249 length, |
249 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); | 250 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); |
250 EXPECT_EQ(net::ERR_IO_PENDING, result); | 251 EXPECT_EQ(net::ERR_IO_PENDING, result); |
251 base::RunLoop().RunUntilIdle(); | 252 base::RunLoop().RunUntilIdle(); |
252 | 253 |
253 ASSERT_EQ(1u, logger.results().size()); | 254 ASSERT_EQ(1u, logger.results().size()); |
254 EXPECT_LT(0, logger.results()[0]); | 255 EXPECT_LT(0, logger.results()[0]); |
255 EXPECT_EQ(fake_file_.metadata.size, logger.results()[0]); | 256 EXPECT_EQ(fake_file_->metadata->size, logger.results()[0]); |
256 | 257 |
257 std::string buffer_as_string(io_buffer->data(), fake_file_.metadata.size); | 258 std::string buffer_as_string(io_buffer->data(), fake_file_->metadata->size); |
258 EXPECT_EQ(fake_file_.contents, buffer_as_string); | 259 EXPECT_EQ(fake_file_->contents, buffer_as_string); |
259 } | 260 } |
260 | 261 |
261 TEST_F(FileSystemProviderFileStreamReader, Read_ModifiedFile) { | 262 TEST_F(FileSystemProviderFileStreamReader, Read_ModifiedFile) { |
262 EventLogger logger; | 263 EventLogger logger; |
263 | 264 |
264 const int64 initial_offset = 0; | 265 const int64 initial_offset = 0; |
265 FileStreamReader reader(NULL, file_url_, initial_offset, base::Time::Max()); | 266 FileStreamReader reader(NULL, file_url_, initial_offset, base::Time::Max()); |
266 | 267 |
267 scoped_refptr<net::IOBuffer> io_buffer( | 268 scoped_refptr<net::IOBuffer> io_buffer( |
268 new net::IOBuffer(fake_file_.metadata.size)); | 269 new net::IOBuffer(fake_file_->metadata->size)); |
269 const int result = | 270 const int result = |
270 reader.Read(io_buffer.get(), | 271 reader.Read(io_buffer.get(), |
271 fake_file_.metadata.size, | 272 fake_file_->metadata->size, |
272 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); | 273 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); |
273 | 274 |
274 EXPECT_EQ(net::ERR_IO_PENDING, result); | 275 EXPECT_EQ(net::ERR_IO_PENDING, result); |
275 base::RunLoop().RunUntilIdle(); | 276 base::RunLoop().RunUntilIdle(); |
276 | 277 |
277 ASSERT_EQ(1u, logger.results().size()); | 278 ASSERT_EQ(1u, logger.results().size()); |
278 EXPECT_EQ(net::ERR_UPLOAD_FILE_CHANGED, logger.results()[0]); | 279 EXPECT_EQ(net::ERR_UPLOAD_FILE_CHANGED, logger.results()[0]); |
279 } | 280 } |
280 | 281 |
281 TEST_F(FileSystemProviderFileStreamReader, Read_ExpectedModificationTimeNull) { | 282 TEST_F(FileSystemProviderFileStreamReader, Read_ExpectedModificationTimeNull) { |
282 EventLogger logger; | 283 EventLogger logger; |
283 | 284 |
284 const int64 initial_offset = 0; | 285 const int64 initial_offset = 0; |
285 FileStreamReader reader(NULL, file_url_, initial_offset, base::Time()); | 286 FileStreamReader reader(NULL, file_url_, initial_offset, base::Time()); |
286 | 287 |
287 scoped_refptr<net::IOBuffer> io_buffer( | 288 scoped_refptr<net::IOBuffer> io_buffer( |
288 new net::IOBuffer(fake_file_.metadata.size)); | 289 new net::IOBuffer(fake_file_->metadata->size)); |
289 const int result = | 290 const int result = |
290 reader.Read(io_buffer.get(), | 291 reader.Read(io_buffer.get(), |
291 fake_file_.metadata.size, | 292 fake_file_->metadata->size, |
292 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); | 293 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); |
293 | 294 |
294 EXPECT_EQ(net::ERR_IO_PENDING, result); | 295 EXPECT_EQ(net::ERR_IO_PENDING, result); |
295 base::RunLoop().RunUntilIdle(); | 296 base::RunLoop().RunUntilIdle(); |
296 | 297 |
297 ASSERT_EQ(1u, logger.results().size()); | 298 ASSERT_EQ(1u, logger.results().size()); |
298 EXPECT_EQ(fake_file_.metadata.size, logger.results()[0]); | 299 EXPECT_EQ(fake_file_->metadata->size, logger.results()[0]); |
299 | 300 |
300 std::string buffer_as_string(io_buffer->data(), fake_file_.metadata.size); | 301 std::string buffer_as_string(io_buffer->data(), fake_file_->metadata->size); |
301 EXPECT_EQ(fake_file_.contents, buffer_as_string); | 302 EXPECT_EQ(fake_file_->contents, buffer_as_string); |
302 } | 303 } |
303 | 304 |
304 TEST_F(FileSystemProviderFileStreamReader, GetLength) { | 305 TEST_F(FileSystemProviderFileStreamReader, GetLength) { |
305 EventLogger logger; | 306 EventLogger logger; |
306 | 307 |
307 const int64 initial_offset = 0; | 308 const int64 initial_offset = 0; |
308 FileStreamReader reader( | 309 FileStreamReader reader( |
309 NULL, file_url_, initial_offset, fake_file_.metadata.modification_time); | 310 NULL, file_url_, initial_offset, fake_file_->metadata->modification_time); |
310 | 311 |
311 const int result = reader.GetLength( | 312 const int result = reader.GetLength( |
312 base::Bind(&EventLogger::OnGetLength, logger.GetWeakPtr())); | 313 base::Bind(&EventLogger::OnGetLength, logger.GetWeakPtr())); |
313 EXPECT_EQ(net::ERR_IO_PENDING, result); | 314 EXPECT_EQ(net::ERR_IO_PENDING, result); |
314 base::RunLoop().RunUntilIdle(); | 315 base::RunLoop().RunUntilIdle(); |
315 | 316 |
316 ASSERT_EQ(1u, logger.results().size()); | 317 ASSERT_EQ(1u, logger.results().size()); |
317 EXPECT_LT(0, logger.results()[0]); | 318 EXPECT_LT(0, logger.results()[0]); |
318 EXPECT_EQ(fake_file_.metadata.size, logger.results()[0]); | 319 EXPECT_EQ(fake_file_->metadata->size, logger.results()[0]); |
319 } | 320 } |
320 | 321 |
321 TEST_F(FileSystemProviderFileStreamReader, GetLength_WrongFile) { | 322 TEST_F(FileSystemProviderFileStreamReader, GetLength_WrongFile) { |
322 EventLogger logger; | 323 EventLogger logger; |
323 | 324 |
324 const int64 initial_offset = 0; | 325 const int64 initial_offset = 0; |
325 FileStreamReader reader(NULL, | 326 FileStreamReader reader(NULL, |
326 wrong_file_url_, | 327 wrong_file_url_, |
327 initial_offset, | 328 initial_offset, |
328 fake_file_.metadata.modification_time); | 329 fake_file_->metadata->modification_time); |
329 | 330 |
330 const int result = reader.GetLength( | 331 const int result = reader.GetLength( |
331 base::Bind(&EventLogger::OnGetLength, logger.GetWeakPtr())); | 332 base::Bind(&EventLogger::OnGetLength, logger.GetWeakPtr())); |
332 EXPECT_EQ(net::ERR_IO_PENDING, result); | 333 EXPECT_EQ(net::ERR_IO_PENDING, result); |
333 base::RunLoop().RunUntilIdle(); | 334 base::RunLoop().RunUntilIdle(); |
334 | 335 |
335 ASSERT_EQ(1u, logger.results().size()); | 336 ASSERT_EQ(1u, logger.results().size()); |
336 EXPECT_EQ(net::ERR_FILE_NOT_FOUND, logger.results()[0]); | 337 EXPECT_EQ(net::ERR_FILE_NOT_FOUND, logger.results()[0]); |
337 } | 338 } |
338 | 339 |
(...skipping 19 matching lines...) Expand all Loading... |
358 const int64 initial_offset = 0; | 359 const int64 initial_offset = 0; |
359 FileStreamReader reader(NULL, file_url_, initial_offset, base::Time()); | 360 FileStreamReader reader(NULL, file_url_, initial_offset, base::Time()); |
360 | 361 |
361 const int result = reader.GetLength( | 362 const int result = reader.GetLength( |
362 base::Bind(&EventLogger::OnGetLength, logger.GetWeakPtr())); | 363 base::Bind(&EventLogger::OnGetLength, logger.GetWeakPtr())); |
363 EXPECT_EQ(net::ERR_IO_PENDING, result); | 364 EXPECT_EQ(net::ERR_IO_PENDING, result); |
364 base::RunLoop().RunUntilIdle(); | 365 base::RunLoop().RunUntilIdle(); |
365 | 366 |
366 ASSERT_EQ(1u, logger.results().size()); | 367 ASSERT_EQ(1u, logger.results().size()); |
367 EXPECT_LT(0, logger.results()[0]); | 368 EXPECT_LT(0, logger.results()[0]); |
368 EXPECT_EQ(fake_file_.metadata.size, logger.results()[0]); | 369 EXPECT_EQ(fake_file_->metadata->size, logger.results()[0]); |
369 } | 370 } |
370 | 371 |
371 } // namespace file_system_provider | 372 } // namespace file_system_provider |
372 } // namespace chromeos | 373 } // namespace chromeos |
OLD | NEW |