Simulate transient error and verify exponential backoff.

chrome/browser/sync/sessions/status_controller.h

 // Copyright (c) 2011 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.
 
 // StatusController handles all counter and status related number crunching and
 // state tracking on behalf of a SyncSession.  It 'controls' the model data
 // defined in session_state.h.  The most important feature of StatusController
 // is the ScopedModelSafetyRestriction. When one of these is active, the
 // underlying data set exposed via accessors is swapped out to the appropriate
 // set for the restricted ModelSafeGroup behind the scenes.  For example, if
@@ skipping 19 matching lines @@
 // notifications if no changes occurred.
 
 #ifndef CHROME_BROWSER_SYNC_SESSIONS_STATUS_CONTROLLER_H_
 #define CHROME_BROWSER_SYNC_SESSIONS_STATUS_CONTROLLER_H_
 #pragma once
 
 #include <vector>
 #include <map>
 
 #include "base/stl_util.h"
+#include "base/time.h"
 #include "chrome/browser/sync/sessions/ordered_commit_set.h"
 #include "chrome/browser/sync/sessions/session_state.h"
 
 namespace browser_sync {
 namespace sessions {
 
 class StatusController {
  public:
   explicit StatusController(const ModelSafeRoutingInfo& routes);
   ~StatusController();
@@ skipping 135 matching lines @@
   // the server said there WAS more to download, or it could mean that we
   // were unable to reach the server.  If we didn't request every enabled
   // datatype, then we can't say for sure that there's nothing left to
   // download: in that case, this also returns false.
   bool ServerSaysNothingMoreToDownload() const;
 
   ModelSafeGroup group_restriction() const {
     return group_restriction_;
   }
 
+  base::Time sync_start_time() const {
+    // The time at which we sent the first GetUpdates command for this sync.
+    return sync_start_time_;
+  }
+
   // Check whether a particular model is included by the active group
   // restriction.
   bool ActiveGroupRestrictionIncludesModel(syncable::ModelType model) const {
     if (!group_restriction_in_effect_)
       return true;
     ModelSafeRoutingInfo::const_iterator it = routing_info_.find(model);
     if (it == routing_info_.end())
       return false;
     return group_restriction() == it->second;
   }
 
   // A toolbelt full of methods for updating counters and flags.
   void increment_num_conflicting_commits_by(int value);
   void reset_num_conflicting_commits();
   void set_num_consecutive_transient_error_commits(int value);
   void increment_num_consecutive_transient_error_commits_by(int value);
   void set_num_consecutive_errors(int value);
   void increment_num_consecutive_errors();
   void increment_num_consecutive_errors_by(int value);
   void set_num_server_changes_remaining(int64 changes_remaining);
   void set_invalid_store(bool invalid_store);
   void set_syncer_stuck(bool syncer_stuck);
-  void set_syncing(bool syncing);
   void set_num_successful_bookmark_commits(int value);
   void increment_num_successful_commits();
   void increment_num_successful_bookmark_commits();
   void increment_num_updates_downloaded_by(int value);
   void increment_num_tombstone_updates_downloaded_by(int value);
   void set_types_needing_local_migration(const syncable::ModelTypeSet& types);
   void set_unsynced_handles(const std::vector<int64>& unsynced_handles);
   void increment_num_local_overwrites();
   void increment_num_server_overwrites();
 
   void set_commit_set(const OrderedCommitSet& commit_set);
   void update_conflict_sets_built(bool built);
   void update_conflicts_resolved(bool resolved);
   void reset_conflicts_resolved();
   void set_items_committed();
 
+  void SetSyncInProgressAndUpdateStartTime(bool sync_in_progress);
+
  private:
   friend class ScopedModelSafeGroupRestriction;
 
   // Returns true iff the commit id projection for |group_restriction_|
   // references position |index| into the full set of commit ids in play.
   bool CurrentCommitIdProjectionHasIndex(size_t index);
 
   // Helper to lazily create objects for per-ModelSafeGroup state.
   PerModelSafeGroupState* GetOrCreateModelSafeGroupState(bool restrict,
                                                          ModelSafeGroup group);
 
   AllModelTypeState shared_;
   std::map<ModelSafeGroup, PerModelSafeGroupState*> per_model_group_;
 
   STLValueDeleter<std::map<ModelSafeGroup, PerModelSafeGroupState*> >
       per_model_group_deleter_;
 
   // Set to true if any DirtyOnWrite pieces of state we maintain are changed.
   // Reset to false by TestAndClearIsDirty.
   bool is_dirty_;
 
   // Used to fail read/write operations on state that don't obey the current
   // active ModelSafeWorker contract.
   bool group_restriction_in_effect_;
   ModelSafeGroup group_restriction_;
 
   const ModelSafeRoutingInfo routing_info_;
 
+  base::Time sync_start_time_;
+
   DISALLOW_COPY_AND_ASSIGN(StatusController);
 };
 
 // A utility to restrict access to only those parts of the given
 // StatusController that pertain to the specified ModelSafeGroup.
 class ScopedModelSafeGroupRestriction {
  public:
   ScopedModelSafeGroupRestriction(StatusController* to_restrict,
                                   ModelSafeGroup restriction)
       : status_(to_restrict) {
     DCHECK(!status_->group_restriction_in_effect_);
     status_->group_restriction_ = restriction;
     status_->group_restriction_in_effect_ = true;
   }
   ~ScopedModelSafeGroupRestriction() {
     DCHECK(status_->group_restriction_in_effect_);
     status_->group_restriction_in_effect_ = false;
   }
  private:
   StatusController* status_;
   DISALLOW_COPY_AND_ASSIGN(ScopedModelSafeGroupRestriction);
 };
 
 }
 }
 
 #endif  // CHROME_BROWSER_SYNC_SESSIONS_STATUS_CONTROLLER_H_