Index: blimp/net/helium/helium_sync_manager.h |
diff --git a/blimp/net/helium/helium_sync_manager.h b/blimp/net/helium/helium_sync_manager.h |
new file mode 100644 |
index 0000000000000000000000000000000000000000..17c287ed9cdd3e7e0ee7f6bd78485b0bc68deb4f |
--- /dev/null |
+++ b/blimp/net/helium/helium_sync_manager.h |
@@ -0,0 +1,94 @@ |
+// Copyright 2016 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 BLIMP_NET_HELIUM_HELIUM_SYNC_MANAGER_H_ |
+#define BLIMP_NET_HELIUM_HELIUM_SYNC_MANAGER_H_ |
+ |
+#include <stdint.h> |
+#include <memory> |
+ |
+#include "base/macros.h" |
+ |
+namespace blimp { |
+ |
+class HeliumObject; |
+class HeliumTransport; |
+class Syncable; |
+ |
+using HeliumObjectId = uint32_t; |
scf
2016/10/06 17:37:49
I with proto allowed typedefs so we could define t
|
+ |
+// TODO(kmarshall): Define this type. |
+class HeliumTransport {}; |
+ |
+class HeliumSyncManager { |
+ public: |
+ // RAII object for managing the sync control and registration status of a |
+ // Syncable. When a Syncable is registered, it should hold onto the resulting |
+ // SyncRegistration object. |
+ // |
+ // When the Syncable is destroyed, it will delete the |
+ // SyncRegistration along with it, which will automatically unregister the |
+ // object from the SyncManager. |
scf
2016/10/06 17:37:49
Who owns the SyncRegistration? Should we add to th
Kevin M
2016/10/06 18:41:09
The Object, which is the TwoPhaseSyncable. So yeah
Wez
2016/10/08 00:38:21
It would be preferable to keep a clean separation
|
+ // |
+ // If a Syncable wishes to halt synchronization for any reason (e.g. a tab |
+ // is hidden on the Client), it may call SyncRegistration::Pause(), which will |
+ // tell the SyncManager to exclude or include the Syncable in state sync. |
+ class SyncRegistration { |
+ public: |
+ explicit SyncRegistration(HeliumSyncManager* sync_manager, |
+ HeliumObjectId id); |
+ ~SyncRegistration(); |
+ |
+ // Tells the HeliumSyncManager to pause or unpause synchronization for the |
+ // HeliumObject associated with |this|. |
+ void Pause(bool paused); |
+ |
+ HeliumObjectId id() { return id_; } |
+ |
+ private: |
+ HeliumObjectId id_; |
+ HeliumSyncManager* sync_manager_; |
+ |
+ DISALLOW_COPY_AND_ASSIGN(SyncRegistration); |
+ }; |
+ |
+ virtual ~HeliumSyncManager() {} |
+ |
+ // Returns a concrete implementation of HeliumSyncManager. |
+ static std::unique_ptr<HeliumSyncManager> Create( |
+ std::unique_ptr<HeliumTransport> transport); |
Wez
2016/10/08 00:38:21
Given that the impl in this CL is a no-op, and tha
|
+ |
+ // Registers a new Syncable for synchronization. The Sync layer allocates a |
+ // unique identifier to the Object (including guaranteeing no clashes between |
+ // Client & Engine). |
+ // The identifier may be used by other Objects to refer to |object|. E.g. the |
+ // tab-list Object might include the Id for each tab’s Object. |
+ virtual std::unique_ptr<SyncRegistration> Register(Syncable* syncable) = 0; |
+ |
+ // Registers a Syncable for synchronization with a pre-existing ID. |
+ // This form is used when the remote peer has created a new Syncable, to |
+ // register our local equivalent. |
+ virtual std::unique_ptr<SyncRegistration> RegisterExisting( |
+ HeliumObjectId id, |
+ Syncable* syncable) = 0; |
+ |
+ protected: |
+ friend class HeliumSyncManager::SyncRegistration; |
+ |
+ // Tells the HeliumSyncManager to pause or unpause synchronization for the |
+ // HeliumObject associated with |this|. |
+ virtual void Pause(HeliumObjectId id, bool paused) = 0; |
Wez
2016/10/08 00:38:21
Let's leave out stuff like this until we get to im
|
+ |
+ // Indicates that a Syncable is being destroyed, and should no longer be |
+ // synchronized. |
+ // Because the Syncable is being destroyed, it is assumed that in-flight |
+ // messages |
+ // about it are now irrelevant, and the Sync layer should tear down underlying |
+ // resources, such as the HeliumStream, immediately. |
+ virtual void Unregister(HeliumObjectId id) = 0; |
+}; |
+ |
+} // namespace blimp |
+ |
+#endif // BLIMP_NET_HELIUM_HELIUM_SYNC_MANAGER_H_ |