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

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

Issue 324343002: [SyncFS] Support late authentication (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: rebase 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
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 #include "chrome/browser/sync_file_system/drive_backend/sync_worker.h" 5 #include "chrome/browser/sync_file_system/drive_backend/sync_worker.h"
6 6
7 #include <vector> 7 #include <vector>
8 8
9 #include "base/bind.h" 9 #include "base/bind.h"
10 #include "chrome/browser/drive/drive_service_interface.h" 10 #include "chrome/browser/drive/drive_service_interface.h"
(...skipping 319 matching lines...) Expand 10 before | Expand all | Expand 10 after
330 void SyncWorker::OnNotificationReceived() { 330 void SyncWorker::OnNotificationReceived() {
331 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 331 DCHECK(sequence_checker_.CalledOnValidSequencedThread());
332 332
333 if (service_state_ == REMOTE_SERVICE_TEMPORARY_UNAVAILABLE) 333 if (service_state_ == REMOTE_SERVICE_TEMPORARY_UNAVAILABLE)
334 UpdateServiceState(REMOTE_SERVICE_OK, "Got push notification for Drive."); 334 UpdateServiceState(REMOTE_SERVICE_OK, "Got push notification for Drive.");
335 335
336 should_check_remote_change_ = true; 336 should_check_remote_change_ = true;
337 MaybeScheduleNextTask(); 337 MaybeScheduleNextTask();
338 } 338 }
339 339
340 void SyncWorker::OnReadyToSendRequests(const std::string& account_id) { 340 void SyncWorker::OnReadyToSendRequests() {
341 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 341 DCHECK(sequence_checker_.CalledOnValidSequencedThread());
342 342
343 has_refresh_token_ = true; 343 has_refresh_token_ = true;
344 344
345 if (service_state_ == REMOTE_SERVICE_OK) 345 if (service_state_ == REMOTE_SERVICE_OK)
346 return; 346 return;
347 UpdateServiceState(REMOTE_SERVICE_OK, "Authenticated"); 347 UpdateServiceState(REMOTE_SERVICE_OK, "Authenticated");
348 348
349 if (!GetMetadataDatabase() && !account_id.empty()) { 349 if (!GetMetadataDatabase()) {
350 GetDriveService()->Initialize(account_id);
351 PostInitializeTask(); 350 PostInitializeTask();
352 return; 351 return;
353 } 352 }
354 353
355 should_check_remote_change_ = true; 354 should_check_remote_change_ = true;
356 MaybeScheduleNextTask(); 355 MaybeScheduleNextTask();
357 } 356 }
358 357
359 void SyncWorker::OnRefreshTokenInvalid() { 358 void SyncWorker::OnRefreshTokenInvalid() {
360 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 359 DCHECK(sequence_checker_.CalledOnValidSequencedThread());
(...skipping 382 matching lines...) Expand 10 before | Expand all | Expand 10 after
743 "Service state changed: %d->%d: %s", 742 "Service state changed: %d->%d: %s",
744 old_state, GetCurrentState(), description.c_str()); 743 old_state, GetCurrentState(), description.c_str());
745 744
746 FOR_EACH_OBSERVER( 745 FOR_EACH_OBSERVER(
747 Observer, observers_, 746 Observer, observers_,
748 UpdateServiceState(GetCurrentState(), description)); 747 UpdateServiceState(GetCurrentState(), description));
749 } 748 }
750 749
751 } // namespace drive_backend 750 } // namespace drive_backend
752 } // namespace sync_file_system 751 } // namespace sync_file_system
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698