[mojo-edk] Add MojoWatch and MojoCancelWatch APIs

mojo/edk/system/data_pipe_producer_dispatcher.cc

Index: mojo/edk/system/data_pipe_producer_dispatcher.cc
diff --git a/mojo/edk/system/data_pipe_producer_dispatcher.cc b/mojo/edk/system/data_pipe_producer_dispatcher.cc
index cbbade8b0249dfc177cf6ccb83eb584791421d6b..ed20067e864d56a16982d25a9ab08b8caa545a6b 100644
--- a/mojo/edk/system/data_pipe_producer_dispatcher.cc
+++ b/mojo/edk/system/data_pipe_producer_dispatcher.cc
@@ -79,7 +79,7 @@ Dispatcher::Type DataPipeProducerDispatcher::GetType() const {
   return Type::DATA_PIPE_PRODUCER;
 }
 
-MojoResult DataPipeProducerDispatcher::Close() {
+MojoResult DataPipeProducerDispatcher::Close(RequestContext* request_context) {
   base::AutoLock lock(lock_);
   DVLOG(1) << "Closing data pipe producer " << pipe_id_;
   return CloseNoLock();
@@ -298,7 +298,7 @@ bool DataPipeProducerDispatcher::EndSerialize(
   return true;
 }
 
-bool DataPipeProducerDispatcher::BeginTransit() {
+bool DataPipeProducerDispatcher::BeginTransit(RequestContext* request_context) {
   base::AutoLock lock(lock_);
   if (in_transit_)
     return false;
@@ -306,7 +306,8 @@ bool DataPipeProducerDispatcher::BeginTransit() {
   return in_transit_;
 }
 
-void DataPipeProducerDispatcher::CompleteTransitAndClose() {
+void DataPipeProducerDispatcher::CompleteTransitAndClose(
+    RequestContext* request_context) {
   node_controller_->SetPortObserver(control_port_, nullptr);
 
   base::AutoLock lock(lock_);
@@ -317,7 +318,8 @@ void DataPipeProducerDispatcher::CompleteTransitAndClose() {
   CloseNoLock();
 }
 
-void DataPipeProducerDispatcher::CancelTransit() {
+void DataPipeProducerDispatcher::CancelTransit(
+    RequestContext* request_context) {
   base::AutoLock lock(lock_);
   DCHECK(in_transit_);
   in_transit_ = false;