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

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

Issue 537883002: [SyncFS] Fix unexpected delay on running sync task (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@peria
Patch Set: fix test expectation Created 6 years, 3 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
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 340 matching lines...) Expand 10 before | Expand all | Expand 10 after
351 FROM_HERE, 351 FROM_HERE,
352 base::Bind(&SyncWorkerInterface::Initialize, 352 base::Bind(&SyncWorkerInterface::Initialize,
353 base::Unretained(sync_worker_.get()), 353 base::Unretained(sync_worker_.get()),
354 base::Passed(&sync_engine_context))); 354 base::Passed(&sync_engine_context)));
355 if (remote_change_processor_) 355 if (remote_change_processor_)
356 SetRemoteChangeProcessor(remote_change_processor_); 356 SetRemoteChangeProcessor(remote_change_processor_);
357 357
358 drive_service_->AddObserver(this); 358 drive_service_->AddObserver(this);
359 359
360 service_state_ = REMOTE_SERVICE_TEMPORARY_UNAVAILABLE; 360 service_state_ = REMOTE_SERVICE_TEMPORARY_UNAVAILABLE;
361 SetSyncEnabled(sync_enabled_);
362 OnNetworkChanged(net::NetworkChangeNotifier::GetConnectionType()); 361 OnNetworkChanged(net::NetworkChangeNotifier::GetConnectionType());
363 if (drive_service_->HasRefreshToken()) 362 if (drive_service_->HasRefreshToken())
364 OnReadyToSendRequests(); 363 OnReadyToSendRequests();
365 else 364 else
366 OnRefreshTokenInvalid(); 365 OnRefreshTokenInvalid();
367 } 366 }
368 367
369 void SyncEngine::AddServiceObserver(SyncServiceObserver* observer) { 368 void SyncEngine::AddServiceObserver(SyncServiceObserver* observer) {
370 service_observers_.AddObserver(observer); 369 service_observers_.AddObserver(observer);
371 } 370 }
(...skipping 286 matching lines...) Expand 10 before | Expand all | Expand 10 after
658 return; 657 return;
659 658
660 worker_task_runner_->PostTask( 659 worker_task_runner_->PostTask(
661 FROM_HERE, 660 FROM_HERE,
662 base::Bind(&SyncWorkerInterface::ActivateService, 661 base::Bind(&SyncWorkerInterface::ActivateService,
663 base::Unretained(sync_worker_.get()), 662 base::Unretained(sync_worker_.get()),
664 REMOTE_SERVICE_OK, 663 REMOTE_SERVICE_OK,
665 "Got push notification for Drive")); 664 "Got push notification for Drive"));
666 } 665 }
667 666
668 void SyncEngine::OnPushNotificationEnabled(bool) {} 667 void SyncEngine::OnPushNotificationEnabled(bool /* enabled */) {}
669 668
670 void SyncEngine::OnReadyToSendRequests() { 669 void SyncEngine::OnReadyToSendRequests() {
671 has_refresh_token_ = true; 670 has_refresh_token_ = true;
672 if (!sync_worker_) 671 if (!sync_worker_)
673 return; 672 return;
674 673
675 worker_task_runner_->PostTask( 674 worker_task_runner_->PostTask(
676 FROM_HERE, 675 FROM_HERE,
677 base::Bind(&SyncWorkerInterface::ActivateService, 676 base::Bind(&SyncWorkerInterface::ActivateService,
678 base::Unretained(sync_worker_.get()), 677 base::Unretained(sync_worker_.get()),
(...skipping 124 matching lines...) Expand 10 before | Expand all | Expand 10 after
803 802
804 SyncStatusCallback SyncEngine::TrackCallback( 803 SyncStatusCallback SyncEngine::TrackCallback(
805 const SyncStatusCallback& callback) { 804 const SyncStatusCallback& callback) {
806 return callback_tracker_.Register( 805 return callback_tracker_.Register(
807 base::Bind(callback, SYNC_STATUS_ABORT), 806 base::Bind(callback, SYNC_STATUS_ABORT),
808 callback); 807 callback);
809 } 808 }
810 809
811 } // namespace drive_backend 810 } // namespace drive_backend
812 } // namespace sync_file_system 811 } // namespace sync_file_system
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698