WIP: Towards NonBlockingTypeProcessorCore

sync/engine/non_blocking_type_commit_contribution.h

Index: sync/engine/non_blocking_type_commit_contribution.h
diff --git a/sync/engine/non_blocking_type_commit_contribution.h b/sync/engine/non_blocking_type_commit_contribution.h
new file mode 100644
index 0000000000000000000000000000000000000000..d8af80fbed8f280c993be98034be609c3a06c51c
--- /dev/null
+++ b/sync/engine/non_blocking_type_commit_contribution.h
@@ -0,0 +1,46 @@
+#ifndef SYNC_ENGINE_NON_BLOCKING_TYPE_COMMIT_CONTRIBUTION_H_
+#define SYNC_ENGINE_NON_BLOCKING_TYPE_COMMIT_CONTRIBUTION_H_
+
+#include <vector>
+
+#include "base/basictypes.h"
+#include "sync/engine/commit_contribution.h"
+#include "sync/protocol/sync.pb.h"
+
+namespace syncer {
+
+class NonBlockingTypeProcessorCore;
+
+class NonBlockingTypeCommitContribution : public CommitContribution {
+ public:
+  NonBlockingTypeCommitContribution(
+      NonBlockingTypeProcessorCore* parent,
+      const sync_pb::DataTypeContext& context,
+      const google::protobuf::RepeatedPtrField<sync_pb::SyncEntity>& entities,
+      const std::vector<int64> sequence_numbers);
+  virtual ~NonBlockingTypeCommitContribution();
+
+  virtual void AddToCommitMessage(sync_pb::ClientToServerMessage* msg) OVERRIDE;
+  virtual SyncerError ProcessCommitResponse(
+      const sync_pb::ClientToServerResponse& response,
+      sessions::StatusController* status) OVERRIDE;
+  virtual void CleanUp() OVERRIDE;
+  virtual size_t GetNumEntries() const OVERRIDE;
+
+ private:
+  NonBlockingTypeProcessorCore* parent_;
+
+  sync_pb::DataTypeContext context_;
+  const google::protobuf::RepeatedPtrField<sync_pb::SyncEntity> entities_;
+  const std::vector<int64> sequence_numbers_;
+
+  size_t entries_start_index_;
+
+  bool cleaned_up_;
+
+  DISALLOW_COPY_AND_ASSIGN(NonBlockingTypeCommitContribution);
+};
+
+}  // namespace syncer
+
+#endif  // SYNC_ENGINE_NON_BLOCKING_TYPE_COMMIT_CONTRIBUTION_H_