SyncFS: Introduce SyncFileSystemBackend

webkit/browser/fileapi/file_system_context.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 "webkit/browser/fileapi/file_system_context.h"
 
 #include "base/bind.h"
 #include "base/single_thread_task_runner.h"
 #include "base/stl_util.h"
 #include "base/task_runner_util.h"
 #include "url/gurl.h"
 #include "webkit/browser/blob/file_stream_reader.h"
 #include "webkit/browser/fileapi/copy_or_move_file_validator.h"
 #include "webkit/browser/fileapi/external_mount_points.h"
 #include "webkit/browser/fileapi/file_permission_policy.h"
 #include "webkit/browser/fileapi/file_stream_writer.h"
 #include "webkit/browser/fileapi/file_system_file_util.h"
 #include "webkit/browser/fileapi/file_system_operation.h"
 #include "webkit/browser/fileapi/file_system_operation_runner.h"
 #include "webkit/browser/fileapi/file_system_options.h"
 #include "webkit/browser/fileapi/file_system_quota_client.h"
 #include "webkit/browser/fileapi/file_system_task_runners.h"
 #include "webkit/browser/fileapi/file_system_url.h"
 #include "webkit/browser/fileapi/isolated_context.h"
 #include "webkit/browser/fileapi/isolated_file_system_backend.h"
 #include "webkit/browser/fileapi/mount_points.h"
 #include "webkit/browser/fileapi/sandbox_file_system_backend.h"
-#include "webkit/browser/fileapi/syncable/local_file_change_tracker.h"
-#include "webkit/browser/fileapi/syncable/local_file_sync_context.h"
 #include "webkit/browser/fileapi/test_file_system_backend.h"
 #include "webkit/browser/quota/quota_manager.h"
 #include "webkit/browser/quota/special_storage_policy.h"
 #include "webkit/common/fileapi/file_system_util.h"
 
 using quota::QuotaClient;
 
 namespace fileapi {
 
 namespace {
@@ skipping 69 matching lines @@
     const FileSystemOptions& options)
     : task_runners_(task_runners.Pass()),
       quota_manager_proxy_(quota_manager_proxy),
       sandbox_context_(new SandboxContext(
           quota_manager_proxy,
           task_runners_->file_task_runner(),
           partition_path,
           special_storage_policy)),
       sandbox_backend_(new SandboxFileSystemBackend(
           sandbox_context_.get(),
+          task_runners_->file_task_runner(),
           options)),
       isolated_backend_(new IsolatedFileSystemBackend()),
       additional_backends_(additional_backends.Pass()),
       external_mount_points_(external_mount_points),
       partition_path_(partition_path),
       operation_runner_(new FileSystemOperationRunner(this)) {
   DCHECK(task_runners_.get());
 
   if (quota_manager_proxy) {
     quota_manager_proxy->RegisterClient(CreateQuotaClient(
@@ skipping 46 matching lines @@
   if (!backend)
     return NULL;
   return backend->GetQuotaUtil();
 }
 
 AsyncFileUtil* FileSystemContext::GetAsyncFileUtil(
     FileSystemType type) const {
   FileSystemBackend* backend = GetFileSystemBackend(type);
   if (!backend)
     return NULL;
-  return backend->GetAsyncFileUtil(type);
+  return backend->GetAsyncFileUtil(type, this);
 }
 
 FileSystemFileUtil* FileSystemContext::GetFileUtil(
     FileSystemType type) const {
   FileSystemBackend* backend = GetFileSystemBackend(type);
   if (!backend)
     return NULL;
-  return backend->GetFileUtil(type);
+  return backend->GetFileUtil(type, this);
 }
 
 CopyOrMoveFileValidatorFactory*
 FileSystemContext::GetCopyOrMoveFileValidatorFactory(
     FileSystemType type, base::PlatformFileError* error_code) const {
   DCHECK(error_code);
   *error_code = base::PLATFORM_FILE_OK;
   FileSystemBackend* backend = GetFileSystemBackend(type);
   if (!backend)
     return NULL;
   return backend->GetCopyOrMoveFileValidatorFactory(
       type, error_code);
 }
 
 FileSystemBackend* FileSystemContext::GetFileSystemBackend(
     FileSystemType type) const {
   FileSystemBackendMap::const_iterator found = backend_map_.find(type);
   if (found != backend_map_.end())
     return found->second;
   NOTREACHED() << "Unknown filesystem type: " << type;
   return NULL;
 }
 
 bool FileSystemContext::IsSandboxFileSystem(FileSystemType type) const {
   return GetQuotaUtil(type) != NULL;
 }
 
 const UpdateObserverList* FileSystemContext::GetUpdateObservers(
     FileSystemType type) const {
-  // Currently update observer is only available in SandboxFileSystemBackend
-  // and TestFileSystemBackend.
-  // TODO(kinuko): Probably GetUpdateObservers() virtual method should be
-  // added to FileSystemBackend interface and be called like
-  // other GetFoo() methods do.
+  // Currently update observer is only available in SandboxFileSystemBackend,
+  // SyncFileSystemBackend and TestFileSystemBackend.
   if (sandbox_backend_->CanHandleType(type))
     return sandbox_backend_->GetUpdateObservers(type);
-  if (type != kFileSystemTypeTest)
-    return NULL;
   FileSystemBackend* backend = GetFileSystemBackend(type);
-  return static_cast<TestFileSystemBackend*>(
-      backend)->GetUpdateObservers(type);
+  if (type == kFileSystemTypeSyncable ||
+      type == kFileSystemTypeSyncableForInternalSync) {
+    return static_cast<SandboxFileSystemBackend*>(
+        backend)->GetUpdateObservers(type);
+  }
+  if (type == kFileSystemTypeTest) {
+    return static_cast<TestFileSystemBackend*>(
+        backend)->GetUpdateObservers(type);
+  }
+  return NULL;
 }
 
 const AccessObserverList* FileSystemContext::GetAccessObservers(
     FileSystemType type) const {
-  // Currently access observer is only available in SandboxFileSystemBackend.
+  // Currently access observer is only available in SandboxFileSystemBackend and
+  // SyncFileSystemBackend.
   if (sandbox_backend_->CanHandleType(type))
     return sandbox_backend_->GetAccessObservers(type);
+  if (type == kFileSystemTypeSyncable ||
+      type == kFileSystemTypeSyncableForInternalSync) {
+    return static_cast<SandboxFileSystemBackend*>(
+        GetFileSystemBackend(type))->GetAccessObservers(type);
+  }
   return NULL;
 }
 
 void FileSystemContext::GetFileSystemTypes(
     std::vector<FileSystemType>* types) const {
   types->clear();
   for (FileSystemBackendMap::const_iterator iter = backend_map_.begin();
        iter != backend_map_.end(); ++iter)
     types->push_back(iter->first);
 }
@@ skipping 67 matching lines @@
     const FileSystemURL& url,
     int64 offset) {
   if (!url.is_valid())
     return scoped_ptr<FileStreamWriter>();
   FileSystemBackend* backend = GetFileSystemBackend(url.type());
   if (!backend)
     return scoped_ptr<FileStreamWriter>();
   return backend->CreateFileStreamWriter(url, offset, this);
 }
 
-void FileSystemContext::SetLocalFileChangeTracker(
-    scoped_ptr<sync_file_system::LocalFileChangeTracker> tracker) {
-  DCHECK(!change_tracker_.get());
-  DCHECK(tracker.get());
-  change_tracker_ = tracker.Pass();
-  sandbox_backend_->AddFileUpdateObserver(
-      kFileSystemTypeSyncable,
-      change_tracker_.get(),
-      task_runners_->file_task_runner());
-  sandbox_backend_->AddFileChangeObserver(
-      kFileSystemTypeSyncable,
-      change_tracker_.get(),
-      task_runners_->file_task_runner());
-}
-
-void FileSystemContext::set_sync_context(
-    sync_file_system::LocalFileSyncContext* sync_context) {
-  sync_context_ = sync_context;
-}
-
 FileSystemURL FileSystemContext::CrackURL(const GURL& url) const {
   return CrackFileSystemURL(FileSystemURL(url));
 }
 
 FileSystemURL FileSystemContext::CreateCrackedFileSystemURL(
     const GURL& origin,
     FileSystemType type,
     const base::FilePath& path) const {
   return CrackFileSystemURL(FileSystemURL(origin, type, path));
 }
 
 #if defined(OS_CHROMEOS) && defined(GOOGLE_CHROME_BUILD)
 void FileSystemContext::EnableTemporaryFileSystemInIncognito() {
   sandbox_backend_->set_enable_temporary_file_system_in_incognito(true);
 }
 #endif
 
 FileSystemContext::~FileSystemContext() {
-  task_runners_->file_task_runner()->DeleteSoon(
-      FROM_HERE, change_tracker_.release());
 }
 
 void FileSystemContext::DeleteOnCorrectThread() const {
   if (!task_runners_->io_task_runner()->RunsTasksOnCurrentThread() &&
       task_runners_->io_task_runner()->DeleteSoon(FROM_HERE, this)) {
     return;
   }
   delete this;
 }
 
@@ skipping 71 matching lines @@
     FileSystemType type = static_cast<FileSystemType>(t);
     if (backend->CanHandleType(type)) {
       const bool inserted = backend_map_.insert(
           std::make_pair(type, backend)).second;
       DCHECK(inserted);
     }
   }
 }
 
 }  // namespace fileapi