| Index: mojo/public/tests/simple_bindings_support.cc
|
| diff --git a/mojo/public/tests/simple_bindings_support.cc b/mojo/public/tests/simple_bindings_support.cc
|
| deleted file mode 100644
|
| index eba5cccf09a742e5a2e5e7ffe0b84250ef6e8ab2..0000000000000000000000000000000000000000
|
| --- a/mojo/public/tests/simple_bindings_support.cc
|
| +++ /dev/null
|
| @@ -1,101 +0,0 @@
|
| -// 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/tests/simple_bindings_support.h"
|
| -
|
| -#include <stdlib.h>
|
| -
|
| -#include <algorithm>
|
| -
|
| -namespace mojo {
|
| -namespace test {
|
| -
|
| -SimpleBindingsSupport::SimpleBindingsSupport()
|
| - : buf_(NULL) {
|
| - BindingsSupport::Set(this);
|
| -}
|
| -
|
| -SimpleBindingsSupport::~SimpleBindingsSupport() {
|
| - BindingsSupport::Set(NULL);
|
| -
|
| - for (WaiterList::iterator it = waiters_.begin(); it != waiters_.end(); ++it)
|
| - delete *it;
|
| -}
|
| -
|
| -Buffer* SimpleBindingsSupport::SetCurrentBuffer(Buffer* buf) {
|
| - // This is a simplistic implementation that assumes it is only ever used from
|
| - // a single thread, which is common in tests.
|
| - std::swap(buf_, buf);
|
| - return buf;
|
| -}
|
| -
|
| -Buffer* SimpleBindingsSupport::GetCurrentBuffer() {
|
| - return buf_;
|
| -}
|
| -
|
| -BindingsSupport::AsyncWaitID SimpleBindingsSupport::AsyncWait(
|
| - const Handle& handle,
|
| - MojoWaitFlags flags,
|
| - AsyncWaitCallback* callback) {
|
| - Waiter* waiter = new Waiter();
|
| - waiter->handle = handle;
|
| - waiter->flags = flags;
|
| - waiter->callback = callback;
|
| - waiters_.push_back(waiter);
|
| - return waiter;
|
| -}
|
| -
|
| -void SimpleBindingsSupport::CancelWait(AsyncWaitID async_wait_id) {
|
| - Waiter* waiter = static_cast<Waiter*>(async_wait_id);
|
| -
|
| - WaiterList::iterator it = waiters_.begin();
|
| - while (it != waiters_.end()) {
|
| - if (*it == waiter) {
|
| - WaiterList::iterator doomed = it++;
|
| - waiters_.erase(doomed);
|
| - } else {
|
| - ++it;
|
| - }
|
| - }
|
| -
|
| - delete waiter;
|
| -}
|
| -
|
| -void SimpleBindingsSupport::Process() {
|
| - for (;;) {
|
| - typedef std::pair<AsyncWaitCallback*, MojoResult> Result;
|
| - std::list<Result> results;
|
| -
|
| - WaiterList::iterator it = waiters_.begin();
|
| - while (it != waiters_.end()) {
|
| - Waiter* waiter = *it;
|
| - MojoResult result;
|
| - if (IsReady(waiter->handle, waiter->flags, &result)) {
|
| - results.push_back(std::make_pair(waiter->callback, result));
|
| - WaiterList::iterator doomed = it++;
|
| - waiters_.erase(doomed);
|
| - delete waiter;
|
| - } else {
|
| - ++it;
|
| - }
|
| - }
|
| -
|
| - for (std::list<Result>::const_iterator it = results.begin();
|
| - it != results.end();
|
| - ++it) {
|
| - it->first->OnHandleReady(it->second);
|
| - }
|
| - if (results.empty())
|
| - break;
|
| - }
|
| -}
|
| -
|
| -bool SimpleBindingsSupport::IsReady(const Handle& handle, MojoWaitFlags flags,
|
| - MojoResult* result) {
|
| - *result = Wait(handle, flags, 0);
|
| - return *result != MOJO_RESULT_DEADLINE_EXCEEDED;
|
| -}
|
| -
|
| -} // namespace test
|
| -} // namespace mojo
|
|
|