| Index: mojo/public/cpp/bindings/lib/router.cc
|
| diff --git a/mojo/public/cpp/bindings/lib/router.cc b/mojo/public/cpp/bindings/lib/router.cc
|
| index fff72b44b5a9771b67610a7f47344b8fadca4a50..ee599d68e24be77dc4ddb87b60871f18a3678fa2 100644
|
| --- a/mojo/public/cpp/bindings/lib/router.cc
|
| +++ b/mojo/public/cpp/bindings/lib/router.cc
|
| @@ -11,6 +11,8 @@ namespace internal {
|
|
|
| // ----------------------------------------------------------------------------
|
|
|
| +namespace {
|
| +
|
| class ResponderThunk : public MessageReceiverWithStatus {
|
| public:
|
| explicit ResponderThunk(const SharedData<Router*>& router)
|
| @@ -54,6 +56,8 @@ class ResponderThunk : public MessageReceiverWithStatus {
|
| bool accept_was_invoked_;
|
| };
|
|
|
| +} // namespace
|
| +
|
| // ----------------------------------------------------------------------------
|
|
|
| Router::HandleIncomingMessageThunk::HandleIncomingMessageThunk(Router* router)
|
| @@ -74,7 +78,7 @@ Router::Router(ScopedMessagePipeHandle message_pipe,
|
| const MojoAsyncWaiter* waiter)
|
| : thunk_(this),
|
| filters_(filters.Pass()),
|
| - connector_(message_pipe.Pass(), waiter),
|
| + connector_(message_pipe.Pass(), Connector::SINGLE_THREADED_SEND, waiter),
|
| weak_self_(this),
|
| incoming_receiver_(nullptr),
|
| next_request_id_(0),
|
|
|