Implement features needed for local ack handling in InvalidationStateTracker.

sync/tools/sync_client.cc

 // Copyright (c) 2012 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 <cstddef>
 #include <cstdio>
 #include <string>
 
 #include "base/at_exit.h"
 #include "base/base64.h"
@@ skipping 58 matching lines @@
     : public base::SupportsWeakPtr<NullInvalidationStateTracker>,
       public InvalidationStateTracker {
  public:
   NullInvalidationStateTracker() {}
   virtual ~NullInvalidationStateTracker() {}
 
   virtual InvalidationStateMap GetAllInvalidationStates() const OVERRIDE {
     return InvalidationStateMap();
   }
 
-  virtual void SetMaxVersion(
+  virtual void SetMaxVersionAndPayload(
       const invalidation::ObjectId& id,
-      int64 max_invalidation_version) OVERRIDE {
+      int64 max_invalidation_version,
+      const std::string& payload) OVERRIDE {
     VLOG(1) << "Setting max invalidation version for "
-            << ObjectIdToString(id) << " to " << max_invalidation_version;
+            << ObjectIdToString(id) << " to " << max_invalidation_version
+            << " with payload " << payload;
   }
 
   virtual void Forget(const ObjectIdSet& ids) OVERRIDE {
     for (ObjectIdSet::const_iterator it = ids.begin(); it != ids.end(); ++it) {
       VLOG(1) << "Forgetting invalidation state for " << ObjectIdToString(*it);
     }
   }
 
   virtual std::string GetBootstrapData() const OVERRIDE {
     return std::string();
   }
 
   virtual void SetBootstrapData(const std::string& data) OVERRIDE {
     std::string base64_data;
     CHECK(base::Base64Encode(data, &base64_data));
     VLOG(1) << "Setting bootstrap data to: " << base64_data;
   }
+
+  virtual void GenerateAckHandles(
+      const ObjectIdSet& ids,
+      const scoped_refptr<base::TaskRunner>& task_runner,
+      base::Callback<void(const AckHandleMap&)> callback) OVERRIDE {
+    AckHandleMap ack_handles;
+    for (ObjectIdSet::const_iterator it = ids.begin(); it != ids.end(); ++it) {
+      ack_handles.insert(std::make_pair(*it, AckHandle::InvalidAckHandle()));
+    }
+    task_runner->PostTask(FROM_HERE, base::Bind(callback, ack_handles));

[akalin, 2012/11/28 00:11:42]

process return value (CHECK?)

[dcheng, 2012/11/30 01:42:54]

Done.

+  }
+
+  virtual void Acknowledge(const invalidation::ObjectId& id,
+                           const AckHandle& ack_handle) OVERRIDE {
+    VLOG(1) << "Received ack for " << ObjectIdToString(id);
+  }
 };
 
 // Needed to use a real host resolver.
 class MyTestURLRequestContext : public net::TestURLRequestContext {
  public:
   MyTestURLRequestContext() : TestURLRequestContext(true) {
     context_storage_.set_host_resolver(
         net::HostResolver::CreateDefaultResolver(NULL));
     context_storage_.set_transport_security_state(
         new net::TransportSecurityState());
@@ skipping 279 matching lines @@
   io_thread.Stop();
   return 0;
 }
 
 }  // namespace
 }  // namespace syncer
 
 int main(int argc, char* argv[]) {
   return syncer::SyncClientMain(argc, argv);
 }