Add LwwRegister CRDT

blimp/helium/coded_value_serializer.cc

Index: blimp/helium/coded_value_serializer.cc
diff --git a/blimp/helium/coded_value_serializer.cc b/blimp/helium/coded_value_serializer.cc
new file mode 100644
index 0000000000000000000000000000000000000000..164c51694baa3d7d6db37316f2d804b4ffb7227b
--- /dev/null
+++ b/blimp/helium/coded_value_serializer.cc
@@ -0,0 +1,82 @@
+// 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.
+
+#include "blimp/helium/coded_value_serializer.h"
+
+#include <stdint.h>
+
+#include <string>
+
+#include "base/logging.h"
+#include "blimp/helium/version_vector.h"
+#include "third_party/protobuf/src/google/protobuf/io/coded_stream.h"
+
+namespace blimp {
+namespace helium {
+namespace {
+constexpr uint32_t kMaxStringLength = (10 << 20);  // 10MB

[Kevin M, 2016/10/20 17:11:22]

Add a comment saying this constant is arbitrary and is just a sanity check.

[steimel, 2016/10/20 17:20:41]

Done.

+}
+
+// -----------------------------
+// int32_t serialization methods
+
+void CodedValueSerializer::Serialize(
+    const int32_t& value,
+    google::protobuf::io::CodedOutputStream* output_stream) {
+  output_stream->WriteVarint32(static_cast<uint32_t>(value));
+}
+
+bool CodedValueSerializer::Deserialize(
+    google::protobuf::io::CodedInputStream* input_stream,
+    int32_t* value) {
+  return input_stream->ReadVarint32(reinterpret_cast<uint32_t*>(value));
+}
+
+// ---------------------------------
+// std::string serialization methods
+
+void CodedValueSerializer::Serialize(
+    const std::string& value,
+    google::protobuf::io::CodedOutputStream* output_stream) {
+  DCHECK_LT(value.length(), kMaxStringLength);
+  output_stream->WriteVarint32(value.length());
+  output_stream->WriteString(value);
+}
+
+bool CodedValueSerializer::Deserialize(
+    google::protobuf::io::CodedInputStream* input_stream,
+    std::string* value) {
+  uint32_t length;
+  if (input_stream->ReadVarint32(&length) && length < kMaxStringLength) {
+    return input_stream->ReadString(value, length);
+  }
+  return false;
+}
+
+// -----------------------------------
+// VersionVector serialization methods
+
+void CodedValueSerializer::Serialize(
+    const VersionVector& value,
+    google::protobuf::io::CodedOutputStream* output_stream) {
+  output_stream->WriteVarint64(value.local_revision());
+  output_stream->WriteVarint64(value.remote_revision());
+}
+
+bool CodedValueSerializer::Deserialize(
+    google::protobuf::io::CodedInputStream* input_stream,
+    VersionVector* value) {
+  Revision local_revision;
+  Revision remote_revision;
+  if (!input_stream->ReadVarint64(&local_revision) ||
+      !input_stream->ReadVarint64(&remote_revision)) {
+    return false;
+  }
+  value->set_local_revision(local_revision);
+  value->set_remote_revision(remote_revision);
+  return true;
+}
+
+}  // namespace helium
+}  // namespace blimp