sync: Support non-blocking initial sync in proto

sync/sessions/nudge_tracker.cc

 // Copyright (c) 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "sync/sessions/nudge_tracker.h"
 
 #include "base/basictypes.h"
 #include "sync/protocol/sync.pb.h"
 
 namespace syncer {
@@ skipping 88 matching lines @@
 
 void NudgeTracker::RecordRemoteInvalidation(
     syncer::ModelType type,
     scoped_ptr<InvalidationInterface> invalidation) {
   // Forward the invalidations to the proper recipient.
   TypeTrackerMap::iterator tracker_it = type_trackers_.find(type);
   DCHECK(tracker_it != type_trackers_.end());
   tracker_it->second->RecordRemoteInvalidation(invalidation.Pass());
 }
 
+void NudgeTracker::RecordInitialSyncRequired(syncer::ModelType type) {
+  TypeTrackerMap::iterator tracker_it = type_trackers_.find(type);
+  DCHECK(tracker_it != type_trackers_.end());
+  tracker_it->second->RecordInitialSyncRequired();
+}
+
 void NudgeTracker::OnInvalidationsEnabled() {
   invalidations_enabled_ = true;
 }
 
 void NudgeTracker::OnInvalidationsDisabled() {
   invalidations_enabled_ = false;
   invalidations_out_of_sync_ = true;
 }
 
 void NudgeTracker::SetTypesThrottledUntil(
@@ skipping 102 matching lines @@
   // There's an order to these sources: NOTIFICATION, DATATYPE_REFRESH, LOCAL,
   // RETRY.  The server makes optimization decisions based on this field, so
   // it's important to get this right.  Setting it wrong could lead to missed
   // updates.
   //
   // This complexity is part of the reason why we're deprecating 'source' in
   // favor of 'origin'.
   bool has_invalidation_pending = false;
   bool has_refresh_request_pending = false;
   bool has_commit_pending = false;
+  bool is_initial_sync_required = false;
   bool has_retry = IsRetryRequired();
 
   for (TypeTrackerMap::const_iterator it = type_trackers_.begin();
        it != type_trackers_.end(); ++it) {
     const DataTypeTracker& tracker = *it->second;
     if (!tracker.IsThrottled() && tracker.HasPendingInvalidation()) {
       has_invalidation_pending = true;
     }
     if (!tracker.IsThrottled() && tracker.HasRefreshRequestPending()) {
       has_refresh_request_pending = true;
     }
     if (!tracker.IsThrottled() && tracker.HasLocalChangePending()) {
       has_commit_pending = true;
     }
+    if (!tracker.IsThrottled() && tracker.IsInitialSyncRequired()) {
+      is_initial_sync_required = true;
+    }
   }
 
   if (has_invalidation_pending) {
     return sync_pb::GetUpdatesCallerInfo::NOTIFICATION;
   } else if (has_refresh_request_pending) {
     return sync_pb::GetUpdatesCallerInfo::DATATYPE_REFRESH;
+  } else if (is_initial_sync_required) {
+    // Not quite accurate, but good enough for our purposes.  This setting of
+    // SOURCE is just a backward-compatibility hack anyway.
+    return sync_pb::GetUpdatesCallerInfo::DATATYPE_REFRESH;
   } else if (has_commit_pending) {
     return sync_pb::GetUpdatesCallerInfo::LOCAL;
   } else if (has_retry) {
     return sync_pb::GetUpdatesCallerInfo::RETRY;
   } else {
     return sync_pb::GetUpdatesCallerInfo::UNKNOWN;
   }
 }
 
 void NudgeTracker::FillProtoMessage(
@@ skipping 37 matching lines @@
     it->second->UpdatePayloadBufferSize(size);
   }
 }
 
 void NudgeTracker::SetNextRetryTime(base::TimeTicks retry_time) {
   next_retry_time_ = retry_time;
 }
 
 }  // namespace sessions
 }  // namespace syncer