summaryrefslogtreecommitdiffstats
path: root/mojo/public/cpp/environment/lib/default_async_waiter.cc
diff options
context:
space:
mode:
Diffstat (limited to 'mojo/public/cpp/environment/lib/default_async_waiter.cc')
-rw-r--r--mojo/public/cpp/environment/lib/default_async_waiter.cc85
1 files changed, 0 insertions, 85 deletions
diff --git a/mojo/public/cpp/environment/lib/default_async_waiter.cc b/mojo/public/cpp/environment/lib/default_async_waiter.cc
deleted file mode 100644
index 9d9b07e..0000000
--- a/mojo/public/cpp/environment/lib/default_async_waiter.cc
+++ /dev/null
@@ -1,85 +0,0 @@
-// Copyright 2014 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/environment/lib/default_async_waiter.h"
-
-#include <assert.h>
-
-#include "mojo/public/c/environment/async_waiter.h"
-#include "mojo/public/cpp/utility/run_loop.h"
-#include "mojo/public/cpp/utility/run_loop_handler.h"
-
-namespace mojo {
-
-namespace {
-
-// RunLoopHandler implementation used for a request to AsyncWait(). There are
-// two ways RunLoopHandlerImpl is deleted:
-// . when the handle is ready (or errored).
-// . when CancelWait() is invoked.
-class RunLoopHandlerImpl : public RunLoopHandler {
- public:
- RunLoopHandlerImpl(const Handle& handle,
- MojoAsyncWaitCallback callback,
- void* closure)
- : handle_(handle), callback_(callback), closure_(closure) {}
-
- ~RunLoopHandlerImpl() override { RunLoop::current()->RemoveHandler(handle_); }
-
- // RunLoopHandler:
- void OnHandleReady(const Handle& handle) override {
- NotifyCallback(MOJO_RESULT_OK);
- }
-
- void OnHandleError(const Handle& handle, MojoResult result) override {
- NotifyCallback(result);
- }
-
- private:
- void NotifyCallback(MojoResult result) {
- // Delete this to unregister the handle. That way if the callback
- // reregisters everything is ok.
- MojoAsyncWaitCallback callback = callback_;
- void* closure = closure_;
- delete this;
-
- callback(closure, result);
- }
-
- const Handle handle_;
- MojoAsyncWaitCallback callback_;
- void* closure_;
-
- DISALLOW_COPY_AND_ASSIGN(RunLoopHandlerImpl);
-};
-
-MojoAsyncWaitID AsyncWait(MojoHandle handle,
- MojoHandleSignals signals,
- MojoDeadline deadline,
- MojoAsyncWaitCallback callback,
- void* closure) {
- RunLoop* run_loop = RunLoop::current();
- assert(run_loop);
-
- // |run_loop_handler| is destroyed either when the handle is ready or if
- // CancelWait is invoked.
- RunLoopHandlerImpl* run_loop_handler =
- new RunLoopHandlerImpl(Handle(handle), callback, closure);
- run_loop->AddHandler(run_loop_handler, Handle(handle), signals, deadline);
- return reinterpret_cast<MojoAsyncWaitID>(run_loop_handler);
-}
-
-void CancelWait(MojoAsyncWaitID wait_id) {
- delete reinterpret_cast<RunLoopHandlerImpl*>(wait_id);
-}
-
-} // namespace
-
-namespace internal {
-
-const MojoAsyncWaiter kDefaultAsyncWaiter = {AsyncWait, CancelWait};
-
-} // namespace internal
-
-} // namespace mojo