OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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/drive/drive_file_stream_reader.h" | 5 #include "chrome/browser/chromeos/drive/drive_file_stream_reader.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
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/file_path.h" | 11 #include "base/files/file_path.h" |
12 #include "base/message_loop.h" | 12 #include "base/message_loop.h" |
13 #include "chrome/browser/chromeos/drive/fake_drive_file_system.h" | 13 #include "chrome/browser/chromeos/drive/fake_file_system.h" |
14 #include "chrome/browser/chromeos/drive/file_system_util.h" | 14 #include "chrome/browser/chromeos/drive/file_system_util.h" |
15 #include "chrome/browser/chromeos/drive/test_util.h" | 15 #include "chrome/browser/chromeos/drive/test_util.h" |
16 #include "chrome/browser/google_apis/fake_drive_service.h" | 16 #include "chrome/browser/google_apis/fake_drive_service.h" |
17 #include "chrome/browser/google_apis/task_util.h" | 17 #include "chrome/browser/google_apis/task_util.h" |
18 #include "chrome/browser/google_apis/test_util.h" | 18 #include "chrome/browser/google_apis/test_util.h" |
19 #include "content/public/test/test_browser_thread.h" | 19 #include "content/public/test/test_browser_thread.h" |
20 #include "net/base/file_stream.h" | 20 #include "net/base/file_stream.h" |
21 #include "net/base/io_buffer.h" | 21 #include "net/base/io_buffer.h" |
22 #include "net/base/net_errors.h" | 22 #include "net/base/net_errors.h" |
23 #include "net/base/test_completion_callback.h" | 23 #include "net/base/test_completion_callback.h" |
(...skipping 290 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
314 void SetUpOnUIThread() { | 314 void SetUpOnUIThread() { |
315 // Initialize FakeDriveService. | 315 // Initialize FakeDriveService. |
316 fake_drive_service_.reset(new google_apis::FakeDriveService); | 316 fake_drive_service_.reset(new google_apis::FakeDriveService); |
317 fake_drive_service_->LoadResourceListForWapi( | 317 fake_drive_service_->LoadResourceListForWapi( |
318 "chromeos/gdata/root_feed.json"); | 318 "chromeos/gdata/root_feed.json"); |
319 fake_drive_service_->LoadAccountMetadataForWapi( | 319 fake_drive_service_->LoadAccountMetadataForWapi( |
320 "chromeos/gdata/account_metadata.json"); | 320 "chromeos/gdata/account_metadata.json"); |
321 fake_drive_service_->LoadAppListForDriveApi("chromeos/drive/applist.json"); | 321 fake_drive_service_->LoadAppListForDriveApi("chromeos/drive/applist.json"); |
322 | 322 |
323 // Create a testee instance. | 323 // Create a testee instance. |
324 fake_drive_file_system_.reset( | 324 fake_file_system_.reset( |
325 new test_util::FakeDriveFileSystem(fake_drive_service_.get())); | 325 new test_util::FakeFileSystem(fake_drive_service_.get())); |
326 fake_drive_file_system_->Initialize(); | 326 fake_file_system_->Initialize(); |
327 } | 327 } |
328 | 328 |
329 void TearDownOnUIThread() { | 329 void TearDownOnUIThread() { |
330 fake_drive_file_system_.reset(); | 330 fake_file_system_.reset(); |
331 fake_drive_service_.reset(); | 331 fake_drive_service_.reset(); |
332 } | 332 } |
333 | 333 |
334 DriveFileSystemInterface* GetDriveFileSystem() { | 334 DriveFileSystemInterface* GetFileSystem() { |
335 return fake_drive_file_system_.get(); | 335 return fake_file_system_.get(); |
336 } | 336 } |
337 | 337 |
338 DriveFileStreamReader::DriveFileSystemGetter GetDriveFileSystemGetter() { | 338 DriveFileStreamReader::FileSystemGetter GetFileSystemGetter() { |
339 return base::Bind(&DriveFileStreamReaderTest::GetDriveFileSystem, | 339 return base::Bind(&DriveFileStreamReaderTest::GetFileSystem, |
340 base::Unretained(this)); | 340 base::Unretained(this)); |
341 } | 341 } |
342 | 342 |
343 MessageLoopForIO message_loop_; | 343 MessageLoopForIO message_loop_; |
344 content::TestBrowserThread ui_thread_; | 344 content::TestBrowserThread ui_thread_; |
345 content::TestBrowserThread io_thread_; | 345 content::TestBrowserThread io_thread_; |
346 | 346 |
347 scoped_ptr<google_apis::FakeDriveService> fake_drive_service_; | 347 scoped_ptr<google_apis::FakeDriveService> fake_drive_service_; |
348 scoped_ptr<test_util::FakeDriveFileSystem> fake_drive_file_system_; | 348 scoped_ptr<test_util::FakeFileSystem> fake_file_system_; |
349 }; | 349 }; |
350 | 350 |
351 TEST_F(DriveFileStreamReaderTest, Read) { | 351 TEST_F(DriveFileStreamReaderTest, Read) { |
352 const base::FilePath kDriveFile = | 352 const base::FilePath kDriveFile = |
353 util::GetDriveMyDriveRootPath().AppendASCII("File 1.txt"); | 353 util::GetDriveMyDriveRootPath().AppendASCII("File 1.txt"); |
354 net::TestCompletionCallback callback; | 354 net::TestCompletionCallback callback; |
355 const int kBufferSize = 3; | 355 const int kBufferSize = 3; |
356 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kBufferSize)); | 356 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kBufferSize)); |
357 | 357 |
358 // Create the reader, and initialize it. | 358 // Create the reader, and initialize it. |
359 // In this case, the file is not yet locally cached. | 359 // In this case, the file is not yet locally cached. |
360 scoped_ptr<DriveFileStreamReader> reader( | 360 scoped_ptr<DriveFileStreamReader> reader( |
361 new DriveFileStreamReader(GetDriveFileSystemGetter())); | 361 new DriveFileStreamReader(GetFileSystemGetter())); |
362 | 362 |
363 EXPECT_FALSE(reader->IsInitialized()); | 363 EXPECT_FALSE(reader->IsInitialized()); |
364 | 364 |
365 FileError error = FILE_ERROR_FAILED; | 365 FileError error = FILE_ERROR_FAILED; |
366 scoped_ptr<DriveEntryProto> entry; | 366 scoped_ptr<DriveEntryProto> entry; |
367 reader->Initialize( | 367 reader->Initialize( |
368 kDriveFile, | 368 kDriveFile, |
369 google_apis::CreateComposedCallback( | 369 google_apis::CreateComposedCallback( |
370 base::Bind(&google_apis::test_util::RunAndQuit), | 370 base::Bind(&google_apis::test_util::RunAndQuit), |
371 google_apis::test_util::CreateCopyResultCallback( | 371 google_apis::test_util::CreateCopyResultCallback( |
(...skipping 11 matching lines...) Expand all Loading... |
383 result = callback.GetResult(result); | 383 result = callback.GetResult(result); |
384 ASSERT_GT(result, 0); | 384 ASSERT_GT(result, 0); |
385 first_content.append(buffer->data(), result); | 385 first_content.append(buffer->data(), result); |
386 } | 386 } |
387 | 387 |
388 EXPECT_EQ(content_size, first_content.size()); | 388 EXPECT_EQ(content_size, first_content.size()); |
389 | 389 |
390 // Create second instance and initialize it. | 390 // Create second instance and initialize it. |
391 // In this case, the file should be cached one. | 391 // In this case, the file should be cached one. |
392 reader.reset( | 392 reader.reset( |
393 new DriveFileStreamReader(GetDriveFileSystemGetter())); | 393 new DriveFileStreamReader(GetFileSystemGetter())); |
394 EXPECT_FALSE(reader->IsInitialized()); | 394 EXPECT_FALSE(reader->IsInitialized()); |
395 | 395 |
396 error = FILE_ERROR_FAILED; | 396 error = FILE_ERROR_FAILED; |
397 entry.reset(); | 397 entry.reset(); |
398 reader->Initialize( | 398 reader->Initialize( |
399 kDriveFile, | 399 kDriveFile, |
400 google_apis::CreateComposedCallback( | 400 google_apis::CreateComposedCallback( |
401 base::Bind(&google_apis::test_util::RunAndQuit), | 401 base::Bind(&google_apis::test_util::RunAndQuit), |
402 google_apis::test_util::CreateCopyResultCallback( | 402 google_apis::test_util::CreateCopyResultCallback( |
403 &error, &entry))); | 403 &error, &entry))); |
(...skipping 13 matching lines...) Expand all Loading... |
417 result = callback.GetResult(result); | 417 result = callback.GetResult(result); |
418 ASSERT_GT(result, 0); | 418 ASSERT_GT(result, 0); |
419 second_content.append(buffer->data(), result); | 419 second_content.append(buffer->data(), result); |
420 } | 420 } |
421 | 421 |
422 // The same content is expected. | 422 // The same content is expected. |
423 EXPECT_EQ(first_content, second_content); | 423 EXPECT_EQ(first_content, second_content); |
424 } | 424 } |
425 | 425 |
426 } // namespace drive | 426 } // namespace drive |
OLD | NEW |