Pass highest handled invalidation version between invalidators

chrome/browser/policy/cloud/cloud_policy_invalidator.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.
 
 #ifndef CHROME_BROWSER_POLICY_CLOUD_CLOUD_POLICY_INVALIDATOR_H_
 #define CHROME_BROWSER_POLICY_CLOUD_CLOUD_POLICY_INVALIDATOR_H_
 
 #include <string>
 
 #include "base/basictypes.h"
@@ skipping 46 matching lines @@
   // The max tolerated discrepancy, in seconds, between policy timestamps and
   // invalidation timestamps when determining if an invalidation is expired.
   static const int kMaxInvalidationTimeDelta;
 
   // |type| indicates the policy type that this invalidator is responsible for.
   // |core| is the cloud policy core which connects the various policy objects.
   // It must remain valid until Shutdown is called.
   // |task_runner| is used for scheduling delayed tasks. It must post tasks to
   // the main policy thread.
   // |clock| is used to get the current time.
+  // |highest_handled_invalidation_version| is the highest invalidation version
+  // that was handled already before this invalidator was created.
   CloudPolicyInvalidator(
       enterprise_management::DeviceRegisterRequest::Type type,
       CloudPolicyCore* core,
       const scoped_refptr<base::SequencedTaskRunner>& task_runner,
-      scoped_ptr<base::Clock> clock);
+      scoped_ptr<base::Clock> clock,
+      int64 highest_handled_invalidation_version);
   virtual ~CloudPolicyInvalidator();
 
   // Initializes the invalidator. No invalidations will be generated before this
   // method is called. This method must only be called once.
   // |invalidation_service| is the invalidation service to use and must remain
   // valid until Shutdown is called.
   void Initialize(invalidation::InvalidationService* invalidation_service);
 
   // Shuts down and disables invalidations. It must be called before the object
   // is destroyed.
   void Shutdown();
 
   // Whether the invalidator currently has the ability to receive invalidations.
   bool invalidations_enabled() {
     return invalidations_enabled_;
   }
 
+  // The highest invalidation version that was handled already.
+  int64 highest_handled_invalidation_version() const {
+    return highest_handled_invalidation_version_;
+  }
+
   // syncer::InvalidationHandler:
   virtual void OnInvalidatorStateChange(
       syncer::InvalidatorState state) OVERRIDE;
   virtual void OnIncomingInvalidation(
       const syncer::ObjectIdInvalidationMap& invalidation_map) OVERRIDE;
   virtual std::string GetOwnerName() const OVERRIDE;
 
   // CloudPolicyCore::Observer:
   virtual void OnCoreConnected(CloudPolicyCore* core) OVERRIDE;
   virtual void OnRefreshSchedulerStarted(CloudPolicyCore* core) OVERRIDE;
@@ skipping 101 matching lines @@
   // The version of the latest invalidation received. This is compared to
   // the invalidation version of policy stored to determine when the
   // invalidated policy is up-to-date.
   int64 invalidation_version_;
 
   // The number of invalidations with unknown version received. Since such
   // invalidations do not provide a version number, this count is used to set
   // invalidation_version_ when such invalidations occur.
   int unknown_version_invalidation_count_;
 
+  // The highest invalidation version that was handled already.
+  int64 highest_handled_invalidation_version_;
+
   // The most up to date invalidation.
   scoped_ptr<syncer::Invalidation> invalidation_;
 
   // WeakPtrFactory used to create callbacks to this object.
   base::WeakPtrFactory<CloudPolicyInvalidator> weak_factory_;
 
   // The maximum random delay, in ms, between receiving an invalidation and
   // fetching the new policy.
   int max_fetch_delay_;
 
   // The hash value of the current policy. This is used to determine if a new
   // policy is different from the current one.
   uint32 policy_hash_value_;
 
   // A thread checker to make sure that callbacks are invoked on the correct
   // thread.
   base::ThreadChecker thread_checker_;
 
   DISALLOW_COPY_AND_ASSIGN(CloudPolicyInvalidator);
 };
 
 }  // namespace policy
 
 #endif  // CHROME_BROWSER_POLICY_CLOUD_CLOUD_POLICY_INVALIDATOR_H_