[mojo-edk] Add MojoWatch and MojoCancelWatch APIs

mojo/edk/system/handle_table.cc

 // 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/edk/system/handle_table.h"
 
 #include <stdint.h>
 
 #include <limits>
 
@@ skipping 56 matching lines @@
     return MOJO_RESULT_BUSY;
 
   *dispatcher = it->second.dispatcher;
   handles_.erase(it);
   return MOJO_RESULT_OK;
 }
 
 MojoResult HandleTable::BeginTransit(
     const MojoHandle* handles,
     uint32_t num_handles,
-    std::vector<Dispatcher::DispatcherInTransit>* dispatchers) {
+    std::vector<Dispatcher::DispatcherInTransit>* dispatchers,
+    Dispatcher::RequestContext* request_context) {
   dispatchers->clear();
   dispatchers->reserve(num_handles);
   for (size_t i = 0; i < num_handles; ++i) {
     auto it = handles_.find(handles[i]);
     if (it == handles_.end())
       return MOJO_RESULT_INVALID_ARGUMENT;
     if (it->second.busy)
       return MOJO_RESULT_BUSY;
 
     Dispatcher::DispatcherInTransit d;
     d.local_handle = handles[i];
     d.dispatcher = it->second.dispatcher;
-    if (!d.dispatcher->BeginTransit())
+    if (!d.dispatcher->BeginTransit(request_context))
       return MOJO_RESULT_BUSY;
     it->second.busy = true;
     dispatchers->push_back(d);
   }
   return MOJO_RESULT_OK;
 }
 
 void HandleTable::CompleteTransitAndClose(
-    const std::vector<Dispatcher::DispatcherInTransit>& dispatchers) {
+    const std::vector<Dispatcher::DispatcherInTransit>& dispatchers,
+    Dispatcher::RequestContext* request_context) {
   for (const auto& dispatcher : dispatchers) {
     auto it = handles_.find(dispatcher.local_handle);
     DCHECK(it != handles_.end() && it->second.busy);
     handles_.erase(it);
-    dispatcher.dispatcher->CompleteTransitAndClose();
+    dispatcher.dispatcher->CompleteTransitAndClose(request_context);
   }
 }
 
 void HandleTable::CancelTransit(
-    const std::vector<Dispatcher::DispatcherInTransit>& dispatchers) {
+    const std::vector<Dispatcher::DispatcherInTransit>& dispatchers,
+    Dispatcher::RequestContext* request_context) {
   for (const auto& dispatcher : dispatchers) {
     auto it = handles_.find(dispatcher.local_handle);
     DCHECK(it != handles_.end() && it->second.busy);
     it->second.busy = false;
-    dispatcher.dispatcher->CancelTransit();
+    dispatcher.dispatcher->CancelTransit(request_context);
   }
 }
 
 void HandleTable::GetActiveHandlesForTest(std::vector<MojoHandle>* handles) {
   handles->clear();
   for (const auto& entry : handles_)
     handles->push_back(entry.first);
 }
 
 HandleTable::Entry::Entry() {}
 
 HandleTable::Entry::Entry(scoped_refptr<Dispatcher> dispatcher)
     : dispatcher(dispatcher) {}
 
 HandleTable::Entry::~Entry() {}
 
 }  // namespace edk
 }  // namespace mojo