[mojo-edk] Add MojoWatch and MojoCancelWatch APIs

mojo/edk/system/data_pipe_consumer_dispatcher.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/edk/system/data_pipe_consumer_dispatcher.h"
 
 #include <stddef.h>
 #include <stdint.h>
 
 #include <algorithm>
@@ skipping 62 matching lines @@
   if (initialized) {
     base::AutoLock lock(lock_);
     InitializeNoLock();
   }
 }
 
 Dispatcher::Type DataPipeConsumerDispatcher::GetType() const {
   return Type::DATA_PIPE_CONSUMER;
 }
 
-MojoResult DataPipeConsumerDispatcher::Close() {
+MojoResult DataPipeConsumerDispatcher::Close(RequestContext* request_context) {
   base::AutoLock lock(lock_);
   DVLOG(1) << "Closing data pipe consumer " << pipe_id_;
   return CloseNoLock();
 }
 
 MojoResult DataPipeConsumerDispatcher::ReadData(void* elements,
                                                 uint32_t* num_bytes,
                                                 MojoReadDataFlags flags) {
   base::AutoLock lock(lock_);
   if (!shared_ring_buffer_ || in_transit_)
@@ skipping 215 matching lines @@
   state->bytes_available = bytes_available_;
 
   ports[0] = control_port_.name();
 
   buffer_handle_for_transit_ = shared_ring_buffer_->DuplicatePlatformHandle();
   platform_handles[0] = buffer_handle_for_transit_.get();
 
   return true;
 }
 
-bool DataPipeConsumerDispatcher::BeginTransit() {
+bool DataPipeConsumerDispatcher::BeginTransit(RequestContext* request_context) {
   base::AutoLock lock(lock_);
   if (in_transit_)
     return false;
   in_transit_ = !in_two_phase_read_;
   return in_transit_;
 }
 
-void DataPipeConsumerDispatcher::CompleteTransitAndClose() {
+void DataPipeConsumerDispatcher::CompleteTransitAndClose(
+    RequestContext* request_context) {
   node_controller_->SetPortObserver(control_port_, nullptr);
 
   base::AutoLock lock(lock_);
   DCHECK(in_transit_);
   in_transit_ = false;
   transferred_ = true;
   ignore_result(buffer_handle_for_transit_.release());
   CloseNoLock();
 }
 
-void DataPipeConsumerDispatcher::CancelTransit() {
+void DataPipeConsumerDispatcher::CancelTransit(
+    RequestContext* request_context) {
   base::AutoLock lock(lock_);
   DCHECK(in_transit_);
   in_transit_ = false;
   buffer_handle_for_transit_.reset();
   UpdateSignalsStateNoLock();
 }
 
 // static
 scoped_refptr<DataPipeConsumerDispatcher>
 DataPipeConsumerDispatcher::Deserialize(const void* data,
@@ skipping 175 matching lines @@
   }
 
   if (peer_closed_ != was_peer_closed ||
       bytes_available_ != previous_bytes_available) {
     awakable_list_.AwakeForStateChange(GetHandleSignalsStateNoLock());
   }
 }
 
 }  // namespace edk
 }  // namespace mojo