[mojo-edk] Expose notification source to MojoWatch callbacks

ipc/mojo/ipc_mojo_bootstrap.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 "ipc/mojo/ipc_mojo_bootstrap.h"
 
 #include <stdint.h>
 #include <utility>
 
 #include "base/logging.h"
@@ skipping 30 matching lines @@
 };
 
 MojoServerBootstrap::MojoServerBootstrap() = default;
 
 void MojoServerBootstrap::Connect() {
   DCHECK_EQ(state(), STATE_INITIALIZED);
 
   bootstrap_.Bind(mojom::BootstrapPtrInfo(TakeHandle(), 0));
   bootstrap_.set_connection_error_handler(
       base::Bind(&MojoServerBootstrap::Fail, base::Unretained(this)));
+  bootstrap_.SetAllowSyncDispatch(true);
 
   IPC::mojom::ChannelAssociatedRequest send_channel_request;
   IPC::mojom::ChannelAssociatedPtrInfo receive_channel;
 
   bootstrap_.associated_group()->CreateAssociatedInterface(
       mojo::AssociatedGroup::WILL_PASS_REQUEST, &send_channel_,
       &send_channel_request);
   bootstrap_.associated_group()->CreateAssociatedInterface(
       mojo::AssociatedGroup::WILL_PASS_PTR, &receive_channel,
       &receive_channel_request_);
@@ skipping 39 matching lines @@
 
   DISALLOW_COPY_AND_ASSIGN(MojoClientBootstrap);
 };
 
 MojoClientBootstrap::MojoClientBootstrap() : binding_(this) {}
 
 void MojoClientBootstrap::Connect() {
   binding_.Bind(TakeHandle());
   binding_.set_connection_error_handler(
       base::Bind(&MojoClientBootstrap::Fail, base::Unretained(this)));
+  binding_.SetAllowSyncDispatch(true);
 }
 
 void MojoClientBootstrap::Init(mojom::ChannelAssociatedRequest receive_channel,
                                mojom::ChannelAssociatedPtrInfo send_channel,
                                int32_t peer_pid,
                                const mojo::Callback<void(int32_t)>& callback) {
   callback.Run(GetSelfPID());
   set_state(STATE_READY);
   binding_.set_connection_error_handler(mojo::Closure());
   delegate()->OnPipesAvailable(std::move(send_channel),
@@ skipping 45 matching lines @@
 
 bool MojoBootstrap::HasFailed() const {
   return state() == STATE_ERROR;
 }
 
 mojo::ScopedMessagePipeHandle MojoBootstrap::TakeHandle() {
   return std::move(handle_);
 }
 
 }  // namespace IPC