Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(64)

Side by Side Diff: chrome/browser/sync_file_system/drive_backend/sync_worker.h

Issue 288193002: [SyncFS] Construct and destruct sync_worker in worker_task_runner (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Work for a nit, from offline chat Created 6 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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 #ifndef CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_ 5 #ifndef CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_
6 #define CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_ 6 #define CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_
7 7
8 #include <set> 8 #include <set>
9 #include <string> 9 #include <string>
10 10
(...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after
66 SyncFileStatus file_status, 66 SyncFileStatus file_status,
67 SyncAction sync_action, 67 SyncAction sync_action,
68 SyncDirection direction) = 0; 68 SyncDirection direction) = 0;
69 virtual void UpdateServiceState(RemoteServiceState state, 69 virtual void UpdateServiceState(RemoteServiceState state,
70 const std::string& description) = 0; 70 const std::string& description) = 0;
71 71
72 protected: 72 protected:
73 virtual ~Observer() {} 73 virtual ~Observer() {}
74 }; 74 };
75 75
76 static scoped_ptr<SyncWorker> CreateOnWorker( 76 SyncWorker(const base::FilePath& base_dir,
77 const base::FilePath& base_dir, 77 const base::WeakPtr<ExtensionServiceInterface>& extension_service,
78 Observer* observer, 78 scoped_ptr<SyncEngineContext> sync_engine_context,
79 const base::WeakPtr<ExtensionServiceInterface>& extension_service, 79 leveldb::Env* env_override);
80 scoped_ptr<SyncEngineContext> sync_engine_context,
81 leveldb::Env* env_override);
82 80
83 virtual ~SyncWorker(); 81 virtual ~SyncWorker();
84 82
85 void Initialize(); 83 void Initialize();
86 84
87 // SyncTaskManager::Client overrides 85 // SyncTaskManager::Client overrides
88 virtual void MaybeScheduleNextTask() OVERRIDE; 86 virtual void MaybeScheduleNextTask() OVERRIDE;
89 virtual void NotifyLastOperationStatus( 87 virtual void NotifyLastOperationStatus(
90 SyncStatusCode sync_status, bool used_network) OVERRIDE; 88 SyncStatusCode sync_status, bool used_network) OVERRIDE;
91 89
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after
133 drive::DriveUploaderInterface* GetDriveUploader(); 131 drive::DriveUploaderInterface* GetDriveUploader();
134 MetadataDatabase* GetMetadataDatabase(); 132 MetadataDatabase* GetMetadataDatabase();
135 SyncTaskManager* GetSyncTaskManager(); 133 SyncTaskManager* GetSyncTaskManager();
136 134
137 void AddObserver(Observer* observer); 135 void AddObserver(Observer* observer);
138 136
139 private: 137 private:
140 friend class DriveBackendSyncTest; 138 friend class DriveBackendSyncTest;
141 friend class SyncEngineTest; 139 friend class SyncEngineTest;
142 140
143 SyncWorker(const base::FilePath& base_dir,
144 const base::WeakPtr<ExtensionServiceInterface>& extension_service,
145 scoped_ptr<SyncEngineContext> sync_engine_context,
146 leveldb::Env* env_override);
147
148 void DoDisableApp(const std::string& app_id, 141 void DoDisableApp(const std::string& app_id,
149 const SyncStatusCallback& callback); 142 const SyncStatusCallback& callback);
150 void DoEnableApp(const std::string& app_id, 143 void DoEnableApp(const std::string& app_id,
151 const SyncStatusCallback& callback); 144 const SyncStatusCallback& callback);
152 145
153 void PostInitializeTask(); 146 void PostInitializeTask();
154 void DidInitialize(SyncEngineInitializer* initializer, 147 void DidInitialize(SyncEngineInitializer* initializer,
155 SyncStatusCode status); 148 SyncStatusCode status);
156 void UpdateRegisteredApp(); 149 void UpdateRegisteredApp();
157 void DidQueryAppStatus(const AppStatusMap* app_status); 150 void DidQueryAppStatus(const AppStatusMap* app_status);
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after
196 ObserverList<Observer> observers_; 189 ObserverList<Observer> observers_;
197 190
198 base::WeakPtrFactory<SyncWorker> weak_ptr_factory_; 191 base::WeakPtrFactory<SyncWorker> weak_ptr_factory_;
199 DISALLOW_COPY_AND_ASSIGN(SyncWorker); 192 DISALLOW_COPY_AND_ASSIGN(SyncWorker);
200 }; 193 };
201 194
202 } // namespace drive_backend 195 } // namespace drive_backend
203 } // namespace sync_file_system 196 } // namespace sync_file_system
204 197
205 #endif // CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_ 198 #endif // CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698