Mojo: Add BindingsSupportImpl on top of HandleWatcher

mojo/public/tests/simple_bindings_support.cc

 // 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>
 
 namespace mojo {
 namespace test {
 
 SimpleBindingsSupport::SimpleBindingsSupport() {
   BindingsSupport::Set(this);
 }
 
 SimpleBindingsSupport::~SimpleBindingsSupport() {
   BindingsSupport::Set(NULL);
+
+  for (WaiterList::iterator it = waiters_.begin(); it != waiters_.end(); ++it)
+    delete *it;
 }
 
-bool SimpleBindingsSupport::AsyncWait(Handle handle,
-                                      MojoWaitFlags flags,
-                                      MojoDeadline deadline,
-                                      AsyncWaitCallback* callback) {
-  Waiter waiter;
-  waiter.handle = handle;
-  waiter.flags = flags;
-  waiter.deadline = deadline;
-  waiter.callback = callback;
+BindingsSupport::AsyncWaitID SimpleBindingsSupport::AsyncWait(
+    Handle handle,
+    MojoWaitFlags flags,
+    AsyncWaitCallback* callback) {
+  Waiter* waiter = new Waiter();
+  waiter->handle = handle;
+  waiter->flags = flags;
+  waiter->callback = callback;
   waiters_.push_back(waiter);
-  return true;
+  return waiter;
 }
 
-void SimpleBindingsSupport::CancelWait(AsyncWaitCallback* callback) {
-  std::list<Waiter>::iterator it = waiters_.begin();
+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->callback == callback) {
-      std::list<Waiter>::iterator doomed = it++;
+    if (*it == waiter) {
+      WaiterList::iterator doomed = it++;
       waiters_.erase(doomed);
     } else {
       ++it;
     }
   }
+
+  delete waiter;
 }
 
 void SimpleBindingsSupport::Process() {
   typedef std::pair<AsyncWaitCallback*, MojoResult> Result;
   std::list<Result> results;
 
-  // TODO(darin): Honor given deadline.
-
-  std::list<Waiter>::iterator it = waiters_.begin();
+  WaiterList::iterator it = waiters_.begin();
   while (it != waiters_.end()) {
-    const Waiter& waiter = *it;
+    Waiter* waiter = *it;
     MojoResult result;
-    if (IsReady(waiter.handle, waiter.flags, &result)) {
-      results.push_back(std::make_pair(waiter.callback, result));
-      std::list<Waiter>::iterator doomed = it++;
+    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);
   }
 }
 
 bool SimpleBindingsSupport::IsReady(Handle handle, MojoWaitFlags flags,
                                     MojoResult* result) {
   *result = Wait(handle, flags, 0);
   return *result != MOJO_RESULT_DEADLINE_EXCEEDED;
 }
 
 }  // namespace test
 }  // namespace mojo