Mojo: bindings connector

mojo/public/bindings/lib/message_queue.cc

Index: mojo/public/bindings/lib/message_queue.cc
diff --git a/mojo/public/bindings/lib/message_queue.cc b/mojo/public/bindings/lib/message_queue.cc
new file mode 100644
index 0000000000000000000000000000000000000000..6e5640ca81ff567249b352ec7aefa4d1e8644a2f
--- /dev/null
+++ b/mojo/public/bindings/lib/message_queue.cc
@@ -0,0 +1,48 @@
+// Copyright 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 "mojo/public/bindings/lib/message_queue.h"
+
+#include <assert.h>
+#include <stddef.h>
+
+#include "mojo/public/bindings/lib/message.h"
+
+namespace mojo {
+
+MessageQueue::MessageQueue() {
+}
+
+MessageQueue::~MessageQueue() {
+  while (!queue_.empty())
+    Pop();
+}
+
+bool MessageQueue::IsEmpty() const {
+  return queue_.empty();
+}
+
+Message* MessageQueue::Peek() const {
+  assert(!queue_.empty());
+  return queue_.front();
+}
+
+void MessageQueue::Push(Message* message) {
+  queue_.push(new Message());
+  queue_.back()->Swap(message);
+}
+
+void MessageQueue::Pop(Message* message) {
+  assert(!queue_.empty());
+  queue_.front()->Swap(message);
+  Pop();
+}
+
+void MessageQueue::Pop() {
+  assert(!queue_.empty());
+  delete queue_.front();
+  queue_.pop();
+}
+
+}  // namespace mojo