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

Side by Side Diff: chrome/browser/sync_file_system/drive_backend/sync_engine.cc

Issue 322813002: [SyncFS] Drop test only un-thread-safe getters from SyncEngine (4) (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: buildfix Created 6 years, 6 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
« no previous file with comments | « chrome/browser/sync_file_system/drive_backend/sync_engine.h ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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/sync_file_system/drive_backend/sync_engine.h" 5 #include "chrome/browser/sync_file_system/drive_backend/sync_engine.h"
6 6
7 #include <vector> 7 #include <vector>
8 8
9 #include "base/bind.h" 9 #include "base/bind.h"
10 #include "base/metrics/histogram.h" 10 #include "base/metrics/histogram.h"
(...skipping 219 matching lines...) Expand 10 before | Expand all | Expand 10 after
230 DCHECK(factories); 230 DCHECK(factories);
231 factories->insert(drive::DriveNotificationManagerFactory::GetInstance()); 231 factories->insert(drive::DriveNotificationManagerFactory::GetInstance());
232 factories->insert(SigninManagerFactory::GetInstance()); 232 factories->insert(SigninManagerFactory::GetInstance());
233 factories->insert( 233 factories->insert(
234 extensions::ExtensionsBrowserClient::Get()->GetExtensionSystemFactory()); 234 extensions::ExtensionsBrowserClient::Get()->GetExtensionSystemFactory());
235 factories->insert(ProfileOAuth2TokenServiceFactory::GetInstance()); 235 factories->insert(ProfileOAuth2TokenServiceFactory::GetInstance());
236 } 236 }
237 237
238 SyncEngine::~SyncEngine() { 238 SyncEngine::~SyncEngine() {
239 net::NetworkChangeNotifier::RemoveNetworkChangeObserver(this); 239 net::NetworkChangeNotifier::RemoveNetworkChangeObserver(this);
240 GetDriveService()->RemoveObserver(this); 240 drive_service_->RemoveObserver(this);
241 if (notification_manager_) 241 if (notification_manager_)
242 notification_manager_->RemoveObserver(this); 242 notification_manager_->RemoveObserver(this);
243 243
244 DeleteSoon(FROM_HERE, worker_task_runner_, worker_observer_.Pass()); 244 DeleteSoon(FROM_HERE, worker_task_runner_, worker_observer_.Pass());
245 DeleteSoon(FROM_HERE, worker_task_runner_, sync_worker_.Pass()); 245 DeleteSoon(FROM_HERE, worker_task_runner_, sync_worker_.Pass());
246 DeleteSoon(FROM_HERE, worker_task_runner_, 246 DeleteSoon(FROM_HERE, worker_task_runner_,
247 remote_change_processor_on_worker_.Pass()); 247 remote_change_processor_on_worker_.Pass());
248 } 248 }
249 249
250 void SyncEngine::Initialize(const base::FilePath& base_dir, 250 void SyncEngine::Initialize(const base::FilePath& base_dir,
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after
283 sync_engine_context.Pass(), 283 sync_engine_context.Pass(),
284 env_override)); 284 env_override));
285 sync_worker_->AddObserver(worker_observer_.get()); 285 sync_worker_->AddObserver(worker_observer_.get());
286 worker_task_runner_->PostTask( 286 worker_task_runner_->PostTask(
287 FROM_HERE, 287 FROM_HERE,
288 base::Bind(&SyncWorker::Initialize, 288 base::Bind(&SyncWorker::Initialize,
289 base::Unretained(sync_worker_.get()))); 289 base::Unretained(sync_worker_.get())));
290 290
291 if (notification_manager_) 291 if (notification_manager_)
292 notification_manager_->AddObserver(this); 292 notification_manager_->AddObserver(this);
293 GetDriveService()->AddObserver(this); 293 drive_service_->AddObserver(this);
294 net::NetworkChangeNotifier::AddNetworkChangeObserver(this); 294 net::NetworkChangeNotifier::AddNetworkChangeObserver(this);
295 } 295 }
296 296
297 void SyncEngine::AddServiceObserver(SyncServiceObserver* observer) { 297 void SyncEngine::AddServiceObserver(SyncServiceObserver* observer) {
298 service_observers_.AddObserver(observer); 298 service_observers_.AddObserver(observer);
299 } 299 }
300 300
301 void SyncEngine::AddFileStatusObserver(FileStatusObserver* observer) { 301 void SyncEngine::AddFileStatusObserver(FileStatusObserver* observer) {
302 file_status_observers_.AddObserver(observer); 302 file_status_observers_.AddObserver(observer);
303 } 303 }
(...skipping 198 matching lines...) Expand 10 before | Expand all | Expand 10 after
502 502
503 void SyncEngine::OnNetworkChanged( 503 void SyncEngine::OnNetworkChanged(
504 net::NetworkChangeNotifier::ConnectionType type) { 504 net::NetworkChangeNotifier::ConnectionType type) {
505 worker_task_runner_->PostTask( 505 worker_task_runner_->PostTask(
506 FROM_HERE, 506 FROM_HERE,
507 base::Bind(&SyncWorker::OnNetworkChanged, 507 base::Bind(&SyncWorker::OnNetworkChanged,
508 base::Unretained(sync_worker_.get()), 508 base::Unretained(sync_worker_.get()),
509 type)); 509 type));
510 } 510 }
511 511
512 drive::DriveServiceInterface* SyncEngine::GetDriveService() {
513 return drive_service_.get();
514 }
515
516 drive::DriveUploaderInterface* SyncEngine::GetDriveUploader() {
517 return drive_uploader_.get();
518 }
519
520 SyncEngine::SyncEngine( 512 SyncEngine::SyncEngine(
521 scoped_ptr<drive::DriveServiceInterface> drive_service, 513 scoped_ptr<drive::DriveServiceInterface> drive_service,
522 scoped_ptr<drive::DriveUploaderInterface> drive_uploader, 514 scoped_ptr<drive::DriveUploaderInterface> drive_uploader,
523 base::SequencedTaskRunner* worker_task_runner, 515 base::SequencedTaskRunner* worker_task_runner,
524 drive::DriveNotificationManager* notification_manager, 516 drive::DriveNotificationManager* notification_manager,
525 ExtensionServiceInterface* extension_service, 517 ExtensionServiceInterface* extension_service,
526 SigninManagerBase* signin_manager) 518 SigninManagerBase* signin_manager)
527 : drive_service_(drive_service.Pass()), 519 : drive_service_(drive_service.Pass()),
528 drive_service_wrapper_(new DriveServiceWrapper(drive_service_.get())), 520 drive_service_wrapper_(new DriveServiceWrapper(drive_service_.get())),
529 drive_uploader_(drive_uploader.Pass()), 521 drive_uploader_(drive_uploader.Pass()),
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after
563 555
564 SyncStatusCallback SyncEngine::TrackCallback( 556 SyncStatusCallback SyncEngine::TrackCallback(
565 const SyncStatusCallback& callback) { 557 const SyncStatusCallback& callback) {
566 return callback_tracker_.Register( 558 return callback_tracker_.Register(
567 base::Bind(callback, SYNC_STATUS_ABORT), 559 base::Bind(callback, SYNC_STATUS_ABORT),
568 callback); 560 callback);
569 } 561 }
570 562
571 } // namespace drive_backend 563 } // namespace drive_backend
572 } // namespace sync_file_system 564 } // namespace sync_file_system
OLDNEW
« no previous file with comments | « chrome/browser/sync_file_system/drive_backend/sync_engine.h ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698