mojo/environment/default_async_waiter_impl.cc

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "mojo/environment/default_async_waiter_impl.h"
   6
   7 #include "base/bind.h"
   8 #include "mojo/message_pump/handle_watcher.h"
   9
  10 namespace mojo {
  11 namespace internal {
  12 namespace {
  13
  14 void OnHandleReady(common::HandleWatcher* watcher,
  15                    MojoAsyncWaitCallback callback,
  16                    void* closure,
  17                    MojoResult result) {
  18   delete watcher;
  19   callback(closure, result);
  20 }
  21
  22 MojoAsyncWaitID AsyncWait(MojoHandle handle,
  23                           MojoHandleSignals signals,
  24                           MojoDeadline deadline,
  25                           MojoAsyncWaitCallback callback,
  26                           void* closure) {
  27   // This instance will be deleted when done or cancelled.
  28   common::HandleWatcher* watcher = new common::HandleWatcher();
  29   watcher->Start(Handle(handle), signals, deadline,
  30                  base::Bind(&OnHandleReady, watcher, callback, closure));
  31   return reinterpret_cast<MojoAsyncWaitID>(watcher);
  32 }
  33
  34 void CancelWait(MojoAsyncWaitID wait_id) {
  35   delete reinterpret_cast<common::HandleWatcher*>(wait_id);
  36 }
  37
  38 const MojoAsyncWaiter kDefaultAsyncWaiter = {
  39   AsyncWait,
  40   CancelWait
  41 };
  42
  43 }  // namespace
  44
  45 const MojoAsyncWaiter* GetDefaultAsyncWaiterImpl() {
  46   return &kDefaultAsyncWaiter;
  47 }
  48
  49 }  // namespace internal
  50 }  // namespace mojo