[GCM] Add RMQ storage and MCS message passing support

google_apis/gcm/base/mcs_message.cc

Index: google_apis/gcm/base/mcs_message.cc
diff --git a/google_apis/gcm/base/mcs_message.cc b/google_apis/gcm/base/mcs_message.cc
new file mode 100644
index 0000000000000000000000000000000000000000..c4303f1810ddc77a62e82e32be516b70b249e5ec
--- /dev/null
+++ b/google_apis/gcm/base/mcs_message.cc
@@ -0,0 +1,78 @@
+// Copyright (c) 2013 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 "google_apis/gcm/base/mcs_message.h"
+
+#include "base/logging.h"
+#include "google_apis/gcm/base/mcs_util.h"
+
+namespace gcm {
+
+MCSMessage::Core::Core() {}
+
+MCSMessage::Core::Core(uint8 tag,
+                       const google::protobuf::MessageLite& protobuf) {
+  scoped_ptr<google::protobuf::MessageLite> owned_protobuf(protobuf.New());
+  owned_protobuf->CheckTypeAndMergeFrom(protobuf);
+  protobuf_ = owned_protobuf.Pass();
+}
+
+MCSMessage::Core::Core(
+    uint8 tag,
+    scoped_ptr<const google::protobuf::MessageLite> protobuf) {
+  protobuf_ = protobuf.Pass();
+}
+
+MCSMessage::Core::~Core() {}
+
+const google::protobuf::MessageLite& MCSMessage::Core::Get() const {
+  return *protobuf_;
+}
+
+MCSMessage::MCSMessage() : tag_(0), size_(0) {}
+
+MCSMessage::MCSMessage(const google::protobuf::MessageLite& protobuf)
+  : tag_(GetMCSProtoTag(protobuf)),
+    size_(protobuf.ByteSize()),
+    core_(new Core(tag_, protobuf)) {
+}
+
+MCSMessage::MCSMessage(uint8 tag,
+                       const google::protobuf::MessageLite& protobuf)
+  : tag_(tag),
+    size_(protobuf.ByteSize()),
+    core_(new Core(tag_, protobuf)) {
+  DCHECK_EQ(tag, GetMCSProtoTag(protobuf));
+}
+
+MCSMessage::MCSMessage(uint8 tag,
+                       scoped_ptr<const google::protobuf::MessageLite> protobuf)
+  : tag_(tag),
+    size_(protobuf->ByteSize()),
+    core_(new Core(tag_, protobuf.Pass())) {
+  DCHECK_EQ(tag, GetMCSProtoTag(core_->Get()));
+}
+
+MCSMessage::~MCSMessage() {
+}
+
+bool MCSMessage::IsValid() const {
+  return core_.get() != NULL;
+}
+
+std::string MCSMessage::SerializeAsString() const {
+  return core_->Get().SerializeAsString();
+}
+
+const google::protobuf::MessageLite& MCSMessage::GetProtobuf() const {
+  return core_->Get();
+}
+
+scoped_ptr<google::protobuf::MessageLite> MCSMessage::CloneProtobuf() const {
+  scoped_ptr<google::protobuf::MessageLite> clone(GetProtobuf().New());
+  clone->CheckTypeAndMergeFrom(GetProtobuf());
+  return clone.Pass();
+}
+
+}  // namespace gcm