Implement Invalidator::Acknowledge

sync/internal_api/public/util/weak_handle.h

 // 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.
 
 // Weak handles provides a way to refer to weak pointers from another
 // thread.  This is useful because it is not safe to reference a weak
 // pointer from a thread other than the thread on which it was
 // created.
 //
 // Weak handles can be passed across threads, so for example, you can
@@ skipping 96 matching lines @@
   // May be called on any thread.
   bool IsOnOwnerThread() const;
 
  protected:
   // May be destroyed on any thread.
   ~WeakHandleCoreBase();
 
   // May be called on any thread.
   void PostToOwnerThread(const tracked_objects::Location& from_here,
                          const base::Closure& fn) const;
+  void PostWithReplyToOwnerThread(const tracked_objects::Location& from_here,
+                                  const base::Closure& fn,
+                                  const base::Closure& reply) const;
 
  private:
   // May be used on any thread.
   const scoped_refptr<base::MessageLoopProxy> owner_loop_proxy_;
 
   DISALLOW_COPY_AND_ASSIGN(WeakHandleCoreBase);
 };
 
 // WeakHandleCore<T> contains all the logic for WeakHandle<T>.
 template <typename T>
@@ skipping 61 matching lines @@
             typename ParamTraits<A1>::ForwardType a1,
             typename ParamTraits<A2>::ForwardType a2,
             typename ParamTraits<A3>::ForwardType a3,
             typename ParamTraits<A4>::ForwardType a4) const {
     PostToOwnerThread(
         from_here,
         Bind(&WeakHandleCore::template DoCall4<U, A1, A2, A3, A4>,
              this, fn, a1, a2, a3, a4));
   }
 
+  // Variants that allow for a reply callback.
+  template <typename U>
+  void CallWithReply(const tracked_objects::Location& from_here,
+                     void (U::*fn)(void),
+                     const base::Closure& reply) const {
+    PostWithReplyToOwnerThread(
+        from_here,
+        Bind(&WeakHandleCore::template DoCall0<U>, this, fn),
+        reply);
+  }
+
+  template <typename U, typename A1>
+  void CallWithReply(const tracked_objects::Location& from_here,
+                     void (U::*fn)(A1),
+                     typename ParamTraits<A1>::ForwardType a1,
+                     const base::Closure& reply) const {
+    PostWithReplyToOwnerThread(
+        from_here,
+        Bind(&WeakHandleCore::template DoCall1<U, A1>,
+             this, fn, a1),
+        reply);
+  }
+
+  template <typename U, typename A1, typename A2>
+  void CallWithReply(const tracked_objects::Location& from_here,
+                     void (U::*fn)(A1, A2),
+                     typename ParamTraits<A1>::ForwardType a1,
+                     typename ParamTraits<A2>::ForwardType a2,
+                     const base::Closure& reply) const {
+    PostWithReplyToOwnerThread(
+        from_here,
+        Bind(&WeakHandleCore::template DoCall2<U, A1, A2>,
+             this, fn, a1, a2),
+        reply);
+  }
+
+  template <typename U, typename A1, typename A2, typename A3>
+  void CallWithReply(const tracked_objects::Location& from_here,
+                     void (U::*fn)(A1, A2, A3),
+                     typename ParamTraits<A1>::ForwardType a1,
+                     typename ParamTraits<A2>::ForwardType a2,
+                     typename ParamTraits<A3>::ForwardType a3,
+                     const base::Closure& reply) const {
+    PostWithReplyToOwnerThread(
+        from_here,
+        Bind(&WeakHandleCore::template DoCall3<U, A1, A2, A3>,
+             this, fn, a1, a2, a3),
+        reply);
+  }
+
+  template <typename U, typename A1, typename A2, typename A3, typename A4>
+  void CallWithReply(const tracked_objects::Location& from_here,
+                     void (U::*fn)(A1, A2, A3, A4),
+                     typename ParamTraits<A1>::ForwardType a1,
+                     typename ParamTraits<A2>::ForwardType a2,
+                     typename ParamTraits<A3>::ForwardType a3,
+                     typename ParamTraits<A4>::ForwardType a4,
+                     const base::Closure& reply) const {
+    PostWithReplyToOwnerThread(
+        from_here,
+        Bind(&WeakHandleCore::template DoCall4<U, A1, A2, A3, A4>,
+             this, fn, a1, a2, a3, a4),
+        reply);
+  }
+
  private:
   friend class base::RefCountedThreadSafe<WeakHandleCore<T> >;
 
   // May be destroyed on any thread.
   ~WeakHandleCore() {}
 
   // GCC 4.2.1 on OS X gets confused if all the DoCall functions are
   // named the same, so we distinguish them.
 
   template <typename U>
@@ skipping 143 matching lines @@
   void Call(const tracked_objects::Location& from_here,
             void (U::*fn)(A1, A2, A3, A4),
             typename internal::ParamTraits<A1>::ForwardType a1,
             typename internal::ParamTraits<A2>::ForwardType a2,
             typename internal::ParamTraits<A3>::ForwardType a3,
             typename internal::ParamTraits<A4>::ForwardType a4) const {
     CHECK(IsInitialized());
     core_->Call(from_here, fn, a1, a2, a3, a4);
   }
 
+  // Variants that allow for a reply callback.
+  template <typename U>
+  void CallWithReply(const tracked_objects::Location& from_here,
+                     void (U::*fn)(void),
+                     const base::Closure& reply) const {
+    CHECK(IsInitialized());
+    core_->CallWithReply(from_here, fn, reply);
+  }
+
+  template <typename U, typename A1>
+  void CallWithReply(const tracked_objects::Location& from_here,
+                     void (U::*fn)(A1),
+                     typename internal::ParamTraits<A1>::ForwardType a1,
+                     const base::Closure& reply) const {
+    CHECK(IsInitialized());
+    core_->CallWithReply(from_here, fn, a1, reply);
+  }
+
+  template <typename U, typename A1, typename A2>
+  void CallWithReply(const tracked_objects::Location& from_here,
+                     void (U::*fn)(A1, A2),
+                     typename internal::ParamTraits<A1>::ForwardType a1,
+                     typename internal::ParamTraits<A2>::ForwardType a2,
+                     const base::Closure& reply) const {
+    CHECK(IsInitialized());
+    core_->CallWithReply(from_here, fn, a1, a2, reply);
+  }
+
+  template <typename U, typename A1, typename A2, typename A3>
+  void CallWithReply(const tracked_objects::Location& from_here,
+                     void (U::*fn)(A1, A2, A3),
+                     typename internal::ParamTraits<A1>::ForwardType a1,
+                     typename internal::ParamTraits<A2>::ForwardType a2,
+                     typename internal::ParamTraits<A3>::ForwardType a3,
+                     const base::Closure& reply) const {
+    CHECK(IsInitialized());
+    core_->CallWithReply(from_here, fn, a1, a2, a3, reply);
+  }
+
+  template <typename U, typename A1, typename A2, typename A3, typename A4>
+  void CallWithReply(const tracked_objects::Location& from_here,
+                     void (U::*fn)(A1, A2, A3, A4),
+                     typename internal::ParamTraits<A1>::ForwardType a1,
+                     typename internal::ParamTraits<A2>::ForwardType a2,
+                     typename internal::ParamTraits<A3>::ForwardType a3,
+                     typename internal::ParamTraits<A4>::ForwardType a4,
+                     const base::Closure& reply) const {
+    CHECK(IsInitialized());
+    core_->CallWithReply(from_here, fn, a1, a2, a3, a4, reply);
+  }
+
+
  private:
   FRIEND_TEST_ALL_PREFIXES(WeakHandleTest,
                            TypeConversionConstructor);
   FRIEND_TEST_ALL_PREFIXES(WeakHandleTest,
                            TypeConversionConstructorAssignment);
 
   scoped_refptr<internal::WeakHandleCore<T> > core_;
 };
 
 // Makes a WeakHandle from a WeakPtr.
 template <typename T>
 WeakHandle<T> MakeWeakHandle(const base::WeakPtr<T>& ptr) {
   return WeakHandle<T>(ptr);
 }
 
 }  // namespace syncer
 
 #endif  // SYNC_UTIL_WEAK_HANDLE_H_