sync: Inject sync/'s dependency on invalidations

sync/sessions/data_type_tracker.h

 // Copyright 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.
-//
-// A class to track the per-type scheduling data.
+
 #ifndef SYNC_SESSIONS_DATA_TYPE_TRACKER_H_
 #define SYNC_SESSIONS_DATA_TYPE_TRACKER_H_
 
-#include <deque>
 #include <string>
 
 #include "base/basictypes.h"
+#include "base/memory/scoped_ptr.h"
+#include "base/memory/scoped_vector.h"
 #include "base/time/time.h"
-#include "sync/notifier/dropped_invalidation_tracker.h"
-#include "sync/notifier/single_object_invalidation_set.h"
+#include "sync/internal_api/public/base/invalidation_interface.h"
+#include "sync/internal_api/public/base/model_type.h"
 #include "sync/protocol/sync.pb.h"
 
 namespace syncer {
 
-class Invalidation;
-class SingleObjectInvalidationSet;
+class InvalidationInterface;
 
 namespace sessions {
 
-typedef std::deque<std::string> PayloadList;
-
+// A class to track the per-type scheduling data.
 class DataTypeTracker {
  public:
-  explicit DataTypeTracker(const invalidation::ObjectId& object_id);
+  explicit DataTypeTracker();
   ~DataTypeTracker();
 
   // For STL compatibility, we do not forbid the creation of a default copy
   // constructor and assignment operator.
 
   // Tracks that a local change has been made to this type.
   void RecordLocalChange();
 
   // Tracks that a local refresh request has been made for this type.
   void RecordLocalRefreshRequest();
 
   // Tracks that we received invalidation notifications for this type.
-  void RecordRemoteInvalidations(
-      const SingleObjectInvalidationSet& invalidations);
+  void RecordRemoteInvalidation(scoped_ptr<InvalidationInterface> incoming);
 
   // Records that a sync cycle has been performed successfully.
   // Generally, this means that all local changes have been committed and all
   // remote changes have been downloaded, so we can clear any flags related to
   // pending work.
   void RecordSuccessfulSyncCycle();
 
   // Updates the size of the invalidations payload buffer.
   void UpdatePayloadBufferSize(size_t new_size);
 
@@ skipping 44 matching lines @@
   // successful sync cycle.
   int local_nudge_count_;
 
   // Number of local refresh requests received for this type since the last
   // successful sync cycle.
   int local_refresh_request_count_;
 
   // The list of invalidations received since the last successful sync cycle.
   // This list may be incomplete.  See also:
   // drop_tracker_.IsRecoveringFromDropEvent() and server_payload_overflow_.
-  SingleObjectInvalidationSet pending_invalidations_;
+  //
+  // This list takes ownership of its contents.
+  ScopedVector<InvalidationInterface> pending_invalidations_;
 
   size_t payload_buffer_size_;
 
   // If !unthrottle_time_.is_null(), this type is throttled and may not download
   // or commit data until the specified time.
   base::TimeTicks unthrottle_time_;
 
   // A helper to keep track invalidations we dropped due to overflow.
-  DroppedInvalidationTracker drop_tracker_;
+  scoped_ptr<InvalidationInterface> last_dropped_invalidation_;
+
+  DISALLOW_COPY_AND_ASSIGN(DataTypeTracker);
 };
 
+}  // namespace sessions
 }  // namespace syncer
-}  // namespace sessions
 
 #endif  // SYNC_SESSIONS_DATA_TYPE_TRACKER_H_