diff options
author | viettrungluu@chromium.org <viettrungluu@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2014-04-01 16:38:46 +0000 |
---|---|---|
committer | viettrungluu@chromium.org <viettrungluu@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2014-04-01 16:38:46 +0000 |
commit | 388ba91f3896021ae25dd902198e24f71a3c6404 (patch) | |
tree | 4d1974b54f241303801fee3908464eae2a3d00ae /mojo/public/cpp/bindings/lib/message_queue.cc | |
parent | d61f1cc72e7676f95418d0e9f20fa88a5d5391ec (diff) | |
download | chromium_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.cc | 50 |
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 |