Rename fileapi::LocalFileSystemOperation to FileSystemOperationImpl.

webkit/browser/fileapi/file_system_operation_impl_write_unittest.cc

 // Copyright (c) 2012 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 <vector>
 
 #include "base/files/scoped_temp_dir.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/memory/weak_ptr.h"
 #include "base/message_loop/message_loop.h"
@@ skipping 29 matching lines @@
 const GURL kOrigin("http://example.com");
 const FileSystemType kFileSystemType = kFileSystemTypeTest;
 
 void AssertStatusEq(base::PlatformFileError expected,
                     base::PlatformFileError actual) {
   ASSERT_EQ(expected, actual);
 }
 
 }  // namespace
 
-class LocalFileSystemOperationWriteTest
+class FileSystemOperationImplWriteTest
     : public testing::Test,
-      public base::SupportsWeakPtr<LocalFileSystemOperationWriteTest> {
+      public base::SupportsWeakPtr<FileSystemOperationImplWriteTest> {
  public:
-  LocalFileSystemOperationWriteTest()
+  FileSystemOperationImplWriteTest()
       : loop_(base::MessageLoop::TYPE_IO),
         status_(base::PLATFORM_FILE_OK),
         cancel_status_(base::PLATFORM_FILE_ERROR_FAILED),
         bytes_written_(0),
         complete_(false) {
     change_observers_ = MockFileChangeObserver::CreateList(&change_observer_);
   }
 
   virtual void SetUp() {
     ASSERT_TRUE(dir_.CreateUniqueTempDir());
@@ skipping 45 matching lines @@
     return &change_observer_;
   }
 
   FileSystemURL URLForPath(const base::FilePath& path) const {
     return file_system_context_->CreateCrackedFileSystemURL(
         kOrigin, kFileSystemType, path);
   }
 
   // Callback function for recording test results.
   FileSystemOperation::WriteCallback RecordWriteCallback() {
-    return base::Bind(&LocalFileSystemOperationWriteTest::DidWrite,
+    return base::Bind(&FileSystemOperationImplWriteTest::DidWrite,
                       AsWeakPtr());
   }
 
   FileSystemOperation::StatusCallback RecordCancelCallback() {
-    return base::Bind(&LocalFileSystemOperationWriteTest::DidCancel,
+    return base::Bind(&FileSystemOperationImplWriteTest::DidCancel,
                       AsWeakPtr());
   }
 
   void DidWrite(base::PlatformFileError status, int64 bytes, bool complete) {
     if (status == base::PLATFORM_FILE_OK) {
       add_bytes_written(bytes, complete);
       if (complete)
         base::MessageLoop::current()->Quit();
     } else {
       EXPECT_FALSE(complete_);
@@ skipping 25 matching lines @@
   base::PlatformFileError status_;
   base::PlatformFileError cancel_status_;
   int64 bytes_written_;
   bool complete_;
 
   scoped_ptr<MockBlobURLRequestContext> url_request_context_;
 
   MockFileChangeObserver change_observer_;
   ChangeObserverList change_observers_;
 
-  DISALLOW_COPY_AND_ASSIGN(LocalFileSystemOperationWriteTest);
+  DISALLOW_COPY_AND_ASSIGN(FileSystemOperationImplWriteTest);
 };
 
-TEST_F(LocalFileSystemOperationWriteTest, TestWriteSuccess) {
+TEST_F(FileSystemOperationImplWriteTest, TestWriteSuccess) {
   const GURL blob_url("blob:success");
   ScopedTextBlob blob(url_request_context(), blob_url, "Hello, world!\n");
 
   file_system_context_->operation_runner()->Write(
       &url_request_context(), URLForPath(virtual_path_), blob_url,
       0, RecordWriteCallback());
   base::MessageLoop::current()->Run();
 
   EXPECT_EQ(14, bytes_written());
   EXPECT_EQ(base::PLATFORM_FILE_OK, status());
   EXPECT_TRUE(complete());
 
   EXPECT_EQ(1, change_observer()->get_and_reset_modify_file_count());
 }
 
-TEST_F(LocalFileSystemOperationWriteTest, TestWriteZero) {
+TEST_F(FileSystemOperationImplWriteTest, TestWriteZero) {
   GURL blob_url("blob:zero");
   scoped_refptr<webkit_blob::BlobData> blob_data(new webkit_blob::BlobData());
 
   url_request_context().blob_storage_controller()
       ->AddFinishedBlob(blob_url, blob_data.get());
 
   file_system_context_->operation_runner()->Write(
       &url_request_context(), URLForPath(virtual_path_),
       blob_url, 0, RecordWriteCallback());
   base::MessageLoop::current()->Run();
 
   url_request_context().blob_storage_controller()->RemoveBlob(blob_url);
 
   EXPECT_EQ(0, bytes_written());
   EXPECT_EQ(base::PLATFORM_FILE_OK, status());
   EXPECT_TRUE(complete());
 
   EXPECT_EQ(1, change_observer()->get_and_reset_modify_file_count());
 }
 
-TEST_F(LocalFileSystemOperationWriteTest, TestWriteInvalidBlobUrl) {
+TEST_F(FileSystemOperationImplWriteTest, TestWriteInvalidBlobUrl) {
   file_system_context_->operation_runner()->Write(
       &url_request_context(), URLForPath(virtual_path_),
       GURL("blob:invalid"), 0, RecordWriteCallback());
   base::MessageLoop::current()->Run();
 
   EXPECT_EQ(0, bytes_written());
   EXPECT_EQ(base::PLATFORM_FILE_ERROR_FAILED, status());
   EXPECT_TRUE(complete());
 
   EXPECT_EQ(0, change_observer()->get_and_reset_modify_file_count());
 }
 
-TEST_F(LocalFileSystemOperationWriteTest, TestWriteInvalidFile) {
+TEST_F(FileSystemOperationImplWriteTest, TestWriteInvalidFile) {
   GURL blob_url("blob:writeinvalidfile");
   ScopedTextBlob blob(url_request_context(), blob_url,
                       "It\'ll not be written.");
 
   file_system_context_->operation_runner()->Write(
       &url_request_context(),
       URLForPath(base::FilePath(FILE_PATH_LITERAL("nonexist"))),
       blob_url, 0, RecordWriteCallback());
   base::MessageLoop::current()->Run();
 
   EXPECT_EQ(0, bytes_written());
   EXPECT_EQ(base::PLATFORM_FILE_ERROR_NOT_FOUND, status());
   EXPECT_TRUE(complete());
 
   EXPECT_EQ(1, change_observer()->get_and_reset_modify_file_count());
 }
 
-TEST_F(LocalFileSystemOperationWriteTest, TestWriteDir) {
+TEST_F(FileSystemOperationImplWriteTest, TestWriteDir) {
   base::FilePath virtual_dir_path(FILE_PATH_LITERAL("d"));
   file_system_context_->operation_runner()->CreateDirectory(
       URLForPath(virtual_dir_path),
       true /* exclusive */, false /* recursive */,
       base::Bind(&AssertStatusEq, base::PLATFORM_FILE_OK));
 
   GURL blob_url("blob:writedir");
   ScopedTextBlob blob(url_request_context(), blob_url,
                       "It\'ll not be written, too.");
 
   file_system_context_->operation_runner()->Write(
       &url_request_context(), URLForPath(virtual_dir_path),
                         blob_url, 0, RecordWriteCallback());
   base::MessageLoop::current()->Run();
 
   EXPECT_EQ(0, bytes_written());
   // TODO(kinuko): This error code is platform- or fileutil- dependent
   // right now.  Make it return PLATFORM_FILE_ERROR_NOT_A_FILE in every case.
   EXPECT_TRUE(status() == base::PLATFORM_FILE_ERROR_NOT_A_FILE ||
               status() == base::PLATFORM_FILE_ERROR_ACCESS_DENIED ||
               status() == base::PLATFORM_FILE_ERROR_FAILED);
   EXPECT_TRUE(complete());
 
   EXPECT_EQ(1, change_observer()->get_and_reset_modify_file_count());
 }
 
-TEST_F(LocalFileSystemOperationWriteTest, TestWriteFailureByQuota) {
+TEST_F(FileSystemOperationImplWriteTest, TestWriteFailureByQuota) {
   GURL blob_url("blob:success");
   ScopedTextBlob blob(url_request_context(), blob_url, "Hello, world!\n");
 
   quota_manager_->SetQuota(
       kOrigin, FileSystemTypeToQuotaStorageType(kFileSystemType), 10);
   file_system_context_->operation_runner()->Write(
       &url_request_context(), URLForPath(virtual_path_), blob_url,
       0, RecordWriteCallback());
   base::MessageLoop::current()->Run();
 
   EXPECT_EQ(10, bytes_written());
   EXPECT_EQ(base::PLATFORM_FILE_ERROR_NO_SPACE, status());
   EXPECT_TRUE(complete());
 
   EXPECT_EQ(1, change_observer()->get_and_reset_modify_file_count());
 }
 
-TEST_F(LocalFileSystemOperationWriteTest, TestImmediateCancelSuccessfulWrite) {
+TEST_F(FileSystemOperationImplWriteTest, TestImmediateCancelSuccessfulWrite) {
   GURL blob_url("blob:success");
   ScopedTextBlob blob(url_request_context(), blob_url, "Hello, world!\n");
 
   FileSystemOperationRunner::OperationID id =
       file_system_context_->operation_runner()->Write(
           &url_request_context(), URLForPath(virtual_path_),
           blob_url, 0, RecordWriteCallback());
   file_system_context_->operation_runner()->Cancel(id, RecordCancelCallback());
   // We use RunAllPendings() instead of Run() here, because we won't dispatch
   // callbacks after Cancel() is issued (so no chance to Quit) nor do we need
   // to run another write cycle.
   base::MessageLoop::current()->RunUntilIdle();
 
   // Issued Cancel() before receiving any response from Write(),
   // so nothing should have happen.
   EXPECT_EQ(0, bytes_written());
   EXPECT_EQ(base::PLATFORM_FILE_ERROR_ABORT, status());
   EXPECT_EQ(base::PLATFORM_FILE_OK, cancel_status());
   EXPECT_TRUE(complete());
 
   EXPECT_EQ(0, change_observer()->get_and_reset_modify_file_count());
 }
 
-TEST_F(LocalFileSystemOperationWriteTest, TestImmediateCancelFailingWrite) {
+TEST_F(FileSystemOperationImplWriteTest, TestImmediateCancelFailingWrite) {
   GURL blob_url("blob:writeinvalidfile");
   ScopedTextBlob blob(url_request_context(), blob_url,
                       "It\'ll not be written.");
 
   FileSystemOperationRunner::OperationID id =
       file_system_context_->operation_runner()->Write(
           &url_request_context(),
           URLForPath(base::FilePath(FILE_PATH_LITERAL("nonexist"))),
           blob_url, 0, RecordWriteCallback());
   file_system_context_->operation_runner()->Cancel(id, RecordCancelCallback());
   // We use RunAllPendings() instead of Run() here, because we won't dispatch
   // callbacks after Cancel() is issued (so no chance to Quit) nor do we need
   // to run another write cycle.
   base::MessageLoop::current()->RunUntilIdle();
 
   // Issued Cancel() before receiving any response from Write(),
   // so nothing should have happen.
   EXPECT_EQ(0, bytes_written());
   EXPECT_EQ(base::PLATFORM_FILE_ERROR_ABORT, status());
   EXPECT_EQ(base::PLATFORM_FILE_OK, cancel_status());
   EXPECT_TRUE(complete());
 
   EXPECT_EQ(0, change_observer()->get_and_reset_modify_file_count());
 }
 
 // TODO(ericu,dmikurube,kinuko): Add more tests for cancel cases.
 
 }  // namespace fileapi