src/chrome/browser/sync_file_system/local/sync_file_system_backend.h

   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
   3 // found in the LICENSE file.
   4
   5 #ifndef CHROME_BROWSER_SYNC_FILE_SYSTEM_LOCAL_SYNC_FILE_SYSTEM_BACKEND_H_
   6 #define CHROME_BROWSER_SYNC_FILE_SYSTEM_LOCAL_SYNC_FILE_SYSTEM_BACKEND_H_
   7
   8 #include "chrome/browser/profiles/profile.h"
   9 #include "chrome/browser/sync_file_system/sync_callbacks.h"
  10 #include "chrome/browser/sync_file_system/sync_status_code.h"
  11 #include "content/public/browser/notification_observer.h"
  12 #include "content/public/browser/notification_registrar.h"
  13 #include "storage/browser/fileapi/file_system_backend.h"
  14 #include "storage/browser/fileapi/file_system_quota_util.h"
  15 #include "storage/browser/fileapi/sandbox_file_system_backend_delegate.h"
  16 #include "storage/browser/fileapi/task_runner_bound_observer_list.h"
  17
  18 namespace sync_file_system {
  19
  20 class LocalFileChangeTracker;
  21 class LocalFileSyncContext;
  22
  23 class SyncFileSystemBackend : public storage::FileSystemBackend {
  24  public:
  25   explicit SyncFileSystemBackend(Profile* profile);
  26   virtual ~SyncFileSystemBackend();
  27
  28   static SyncFileSystemBackend* CreateForTesting();
  29
  30   // FileSystemBackend overrides.
  31   virtual bool CanHandleType(storage::FileSystemType type) const OVERRIDE;
  32   virtual void Initialize(storage::FileSystemContext* context) OVERRIDE;
  33   virtual void ResolveURL(const storage::FileSystemURL& url,
  34                           storage::OpenFileSystemMode mode,
  35                           const OpenFileSystemCallback& callback) OVERRIDE;
  36   virtual storage::AsyncFileUtil* GetAsyncFileUtil(
  37       storage::FileSystemType type) OVERRIDE;
  38   virtual storage::WatcherManager* GetWatcherManager(
  39       storage::FileSystemType type) OVERRIDE;
  40   virtual storage::CopyOrMoveFileValidatorFactory*
  41       GetCopyOrMoveFileValidatorFactory(storage::FileSystemType type,
  42                                         base::File::Error* error_code) OVERRIDE;
  43   virtual storage::FileSystemOperation* CreateFileSystemOperation(
  44       const storage::FileSystemURL& url,
  45       storage::FileSystemContext* context,
  46       base::File::Error* error_code) const OVERRIDE;
  47   virtual bool SupportsStreaming(
  48       const storage::FileSystemURL& url) const OVERRIDE;
  49   virtual bool HasInplaceCopyImplementation(
  50       storage::FileSystemType type) const OVERRIDE;
  51   virtual scoped_ptr<storage::FileStreamReader> CreateFileStreamReader(
  52       const storage::FileSystemURL& url,
  53       int64 offset,
  54       int64 max_bytes_to_read,
  55       const base::Time& expected_modification_time,
  56       storage::FileSystemContext* context) const OVERRIDE;
  57   virtual scoped_ptr<storage::FileStreamWriter> CreateFileStreamWriter(
  58       const storage::FileSystemURL& url,
  59       int64 offset,
  60       storage::FileSystemContext* context) const OVERRIDE;
  61   virtual storage::FileSystemQuotaUtil* GetQuotaUtil() OVERRIDE;
  62   virtual const storage::UpdateObserverList* GetUpdateObservers(
  63       storage::FileSystemType type) const OVERRIDE;
  64   virtual const storage::ChangeObserverList* GetChangeObservers(
  65       storage::FileSystemType type) const OVERRIDE;
  66   virtual const storage::AccessObserverList* GetAccessObservers(
  67       storage::FileSystemType type) const OVERRIDE;
  68
  69   static SyncFileSystemBackend* GetBackend(
  70       const storage::FileSystemContext* context);
  71
  72   LocalFileChangeTracker* change_tracker() { return change_tracker_.get(); }
  73   void SetLocalFileChangeTracker(scoped_ptr<LocalFileChangeTracker> tracker);
  74
  75   LocalFileSyncContext* sync_context() { return sync_context_.get(); }
  76   void set_sync_context(LocalFileSyncContext* sync_context);
  77
  78  private:
  79   class ProfileHolder : public content::NotificationObserver {
  80    public:
  81     explicit ProfileHolder(Profile* profile);
  82
  83     // NotificationObserver override.
  84     virtual void Observe(int type,
  85                          const content::NotificationSource& source,
  86                          const content::NotificationDetails& details) OVERRIDE;
  87
  88     Profile* GetProfile();
  89
  90    private:
  91     content::NotificationRegistrar registrar_;
  92     Profile* profile_;
  93   };
  94
  95   // Not owned.
  96   storage::FileSystemContext* context_;
  97
  98   scoped_ptr<LocalFileChangeTracker> change_tracker_;
  99   scoped_refptr<LocalFileSyncContext> sync_context_;
 100
 101   // Should be accessed on the UI thread.
 102   scoped_ptr<ProfileHolder> profile_holder_;
 103
 104   // A flag to skip the initialization sequence of SyncFileSystemService for
 105   // testing.
 106   bool skip_initialize_syncfs_service_for_testing_;
 107
 108   storage::SandboxFileSystemBackendDelegate* GetDelegate() const;
 109
 110   void InitializeSyncFileSystemService(
 111       const GURL& origin_url,
 112       const SyncStatusCallback& callback);
 113   void DidInitializeSyncFileSystemService(
 114       storage::FileSystemContext* context,
 115       const GURL& origin_url,
 116       storage::FileSystemType type,
 117       storage::OpenFileSystemMode mode,
 118       const OpenFileSystemCallback& callback,
 119       SyncStatusCode status);
 120
 121   DISALLOW_COPY_AND_ASSIGN(SyncFileSystemBackend);
 122 };
 123
 124 }  // namespace sync_file_system
 125
 126 #endif  // CHROME_BROWSER_SYNC_FILE_SYSTEM_LOCAL_SYNC_FILE_SYSTEM_BACKEND_H_