summaryrefslogtreecommitdiffstats
path: root/mojo/public/cpp/bindings/lib/message_queue.cc
diff options
context:
space:
mode:
authorviettrungluu@chromium.org <viettrungluu@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2014-04-01 16:38:46 +0000
committerviettrungluu@chromium.org <viettrungluu@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2014-04-01 16:38:46 +0000
commit388ba91f3896021ae25dd902198e24f71a3c6404 (patch)
tree4d1974b54f241303801fee3908464eae2a3d00ae /mojo/public/cpp/bindings/lib/message_queue.cc
parentd61f1cc72e7676f95418d0e9f20fa88a5d5391ec (diff)
downloadchromium_src-388ba91f3896021ae25dd902198e24f71a3c6404.zip
chromium_src-388ba91f3896021ae25dd902198e24f71a3c6404.tar.gz
chromium_src-388ba91f3896021ae25dd902198e24f71a3c6404.tar.bz2
Mojo: Move mojo/public/bindings/lib to mojo/public/cpp/bindings/lib.
R=darin@chromium.org Review URL: https://codereview.chromium.org/220243007 git-svn-id: svn://svn.chromium.org/chrome/trunk/src@260886 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'mojo/public/cpp/bindings/lib/message_queue.cc')
-rw-r--r--mojo/public/cpp/bindings/lib/message_queue.cc50
1 files changed, 50 insertions, 0 deletions
diff --git a/mojo/public/cpp/bindings/lib/message_queue.cc b/mojo/public/cpp/bindings/lib/message_queue.cc
new file mode 100644
index 0000000..1982ccb
--- /dev/null
+++ b/mojo/public/cpp/bindings/lib/message_queue.cc
@@ -0,0 +1,50 @@
+// 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/cpp/bindings/lib/message_queue.h"
+
+#include <assert.h>
+#include <stddef.h>
+
+#include "mojo/public/cpp/bindings/message.h"
+
+namespace mojo {
+namespace internal {
+
+MessageQueue::MessageQueue() {
+}
+
+MessageQueue::~MessageQueue() {
+ while (!queue_.empty())
+ Pop();
+}
+
+bool MessageQueue::IsEmpty() const {
+ return queue_.empty();
+}
+
+Message* MessageQueue::Peek() {
+ 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 internal
+} // namespace mojo