[mojo-edk] Add MojoWatch and MojoCancelWatch APIs

mojo/edk/system/wait_set_dispatcher.cc

 // Copyright 2015 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/wait_set_dispatcher.h"
 
 #include <stdint.h>
 
 #include <algorithm>
 #include <utility>
@@ skipping 25 matching lines @@
 
 WaitSetDispatcher::WaitState::~WaitState() {}
 
 WaitSetDispatcher::WaitSetDispatcher()
     : waiter_(new WaitSetDispatcher::Waiter(this)) {}
 
 Dispatcher::Type WaitSetDispatcher::GetType() const {
   return Type::WAIT_SET;
 }
 
-MojoResult WaitSetDispatcher::Close() {
+MojoResult WaitSetDispatcher::Close(RequestContext* request_context) {
   base::AutoLock lock(lock_);
 
   if (is_closed_)
     return MOJO_RESULT_INVALID_ARGUMENT;
   is_closed_ = true;
 
   {
     base::AutoLock locker(awakable_lock_);
     awakable_list_.CancelAll();
   }
@@ skipping 214 matching lines @@
 void WaitSetDispatcher::RemoveAwakable(Awakable* awakable,
                                        HandleSignalsState* signals_state) {
   {
     base::AutoLock locker(awakable_lock_);
     awakable_list_.Remove(awakable);
   }
   if (signals_state)
     *signals_state = GetHandleSignalsState();
 }
 
-bool WaitSetDispatcher::BeginTransit() {
+bool WaitSetDispatcher::BeginTransit(RequestContext* request_context) {
   // You can't transfer wait sets!
   return false;
 }
 
 WaitSetDispatcher::~WaitSetDispatcher() {
   DCHECK(waiting_dispatchers_.empty());
   DCHECK(awoken_queue_.empty());
   DCHECK(processed_dispatchers_.empty());
 }
 
 void WaitSetDispatcher::WakeDispatcher(MojoResult result, uintptr_t context) {
   {
     base::AutoLock locker(awoken_lock_);
 
     if (result == MOJO_RESULT_ALREADY_EXISTS)
       result = MOJO_RESULT_OK;
 
     awoken_queue_.push_back(std::make_pair(context, result));
   }
 
   base::AutoLock locker(awakable_lock_);
   HandleSignalsState signals_state;
   signals_state.satisfiable_signals = MOJO_HANDLE_SIGNAL_READABLE;
   signals_state.satisfied_signals = MOJO_HANDLE_SIGNAL_READABLE;
   awakable_list_.AwakeForStateChange(signals_state);
 }
 
 }  // namespace edk
 }  // namespace mojo