[SyncFS] Introduce CallbackTracker to handle callback abortion

chrome/browser/sync_file_system/drive_backend/callback_tracker.h

Index: chrome/browser/sync_file_system/drive_backend/callback_tracker.h
diff --git a/chrome/browser/sync_file_system/drive_backend/callback_tracker.h b/chrome/browser/sync_file_system/drive_backend/callback_tracker.h
new file mode 100644
index 0000000000000000000000000000000000000000..5837f0962e6ba98b6d3aac89c567f41ebf73e789
--- /dev/null
+++ b/chrome/browser/sync_file_system/drive_backend/callback_tracker.h
@@ -0,0 +1,96 @@
+// Copyright 2014 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_SYNC_FILE_SYSTEM_DRIVE_BACKEND_CALLBACK_TRACKER_H_
+#define CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_CALLBACK_TRACKER_H_
+
+#include <map>
+
+#include "base/bind.h"
+
+namespace sync_file_system {
+namespace drive_backend {
+
+class CallbackTracker;
+
+namespace internal {
+
+template <typename>
+struct InvokeAndInvalidateHelper;
+
+class AbortHelper {
+ public:
+  explicit AbortHelper(CallbackTracker* tracker);
+  ~AbortHelper();
+  base::WeakPtr<AbortHelper> AsWeakPtr();
+
+  static scoped_ptr<AbortHelper> TakeOwnership(
+      const base::WeakPtr<AbortHelper>& abort_helper);
+
+ private:
+  CallbackTracker* tracker_;  // Not owned.
+  base::WeakPtrFactory<AbortHelper> weak_ptr_factory_;
+
+  DISALLOW_COPY_AND_ASSIGN(AbortHelper);
+};
+
+}  // namespace internal
+
+// A helper class to ensure one-shot callback to be called exactly once.
+//
+// Usage:
+//   class Foo {
+//    private:
+//     CallbackTracker callback_tracker_;
+//   };
+//
+//   void DoSomethingAsync(const SomeCallbackType& callback) {
+//     base::Closure abort_case_handler = base::Bind(callback, ABORT_ERROR);
+//
+//     SomeCallbackType wrapped_callback =
+//         callback_tracker_.Register(
+//             abort_case_handler, callback);
+//
+//     // The body of the operation goes here.
+//   }
+class CallbackTracker {
+ public:
+  typedef std::map<internal::AbortHelper*, base::Closure> AbortClosureByHelper;
+
+  CallbackTracker();
+  ~CallbackTracker();
+
+  // Returns a wrapped callback.
+  // Upon AbortAll() call, CallbackTracker invokes |abort_closure| and voids all
+  // wrapped callbacks returned by Register().
+  // Invocation of the wrapped callback unregisters |callback| from
+  // CallbackTracker.
+  template <typename T>
+  base::Callback<T> Register(const base::Closure& abort_closure,
+                             const base::Callback<T>& callback) {
+    internal::AbortHelper* helper = new internal::AbortHelper(this);
+    helpers_[helper] = abort_closure;
+    return base::Bind(&internal::InvokeAndInvalidateHelper<T>::Run,
+                      helper->AsWeakPtr(), callback);
+  }
+
+  void AbortAll();
+
+ private:
+  friend class internal::AbortHelper;
+
+  scoped_ptr<internal::AbortHelper> PassAbortHelper(
+      internal::AbortHelper* helper);
+
+  AbortClosureByHelper helpers_;  // Owns Wrapper.
+
+  DISALLOW_COPY_AND_ASSIGN(CallbackTracker);
+};
+
+}  // namespace drive_backend
+}  // namespace sync_file_system
+
+#include "chrome/browser/sync_file_system/drive_backend/callback_tracker_internal.h"

[peria, 2014/06/04 07:39:21]

Putting a header file on the bottom line seems storage.

How about moving AbortHelper class into _internal.h(.pump) file?
Then you can put this #include on the head of this file.

[tzik, 2014/06/04 08:15:56]

Done.

+
+#endif  // CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_CALLBACK_TRACKER_H_