[mojo-edk] Expose notification source to MojoWatch callbacks

mojo/public/cpp/bindings/lib/connector.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/cpp/bindings/lib/connector.h"
 
 #include <stdint.h>
 #include <utility>
 
 #include "base/bind.h"
@@ skipping 115 matching lines @@
 void Connector::ResumeIncomingMethodCallProcessing() {
   DCHECK(thread_checker_.CalledOnValidThread());
 
   if (!paused_)
     return;
 
   paused_ = false;
   WaitToReadMore();
 }
 
+void Connector::SetAllowSyncDispatch(bool allowed) {
+  DCHECK(thread_checker_.CalledOnValidThread());
+  handle_watcher_.SetAllowSyncDispatch(allowed);
+}
+
 bool Connector::Accept(Message* message) {
   DCHECK(lock_ || thread_checker_.CalledOnValidThread());
 
   // It shouldn't hurt even if |error_| may be changed by a different thread at
   // the same time. The outcome is that we may write into |message_pipe_| after
   // encountering an error, which should be fine.
   if (error_)
     return false;
 
   MayAutoLock locker(lock_.get());
@@ skipping 249 matching lines @@
     if (!paused_)
       WaitToReadMore();
   } else {
     error_ = true;
     connection_error_handler_.Run();
   }
 }
 
 }  // namespace internal
 }  // namespace mojo