| Index: third_party/mojo/src/mojo/public/cpp/bindings/lib/connector.cc
|
| diff --git a/third_party/mojo/src/mojo/public/cpp/bindings/lib/connector.cc b/third_party/mojo/src/mojo/public/cpp/bindings/lib/connector.cc
|
| index f9ffdd2fdb1b5160e1dfa2028a225c14953f690e..7c92ac3cbd48ad1fed028c8d4912fc1df03ab0bc 100644
|
| --- a/third_party/mojo/src/mojo/public/cpp/bindings/lib/connector.cc
|
| +++ b/third_party/mojo/src/mojo/public/cpp/bindings/lib/connector.cc
|
| @@ -150,11 +150,9 @@ void Connector::OnHandleReady(MojoResult result) {
|
|
|
| void Connector::WaitToReadMore() {
|
| MOJO_CHECK(!async_wait_id_);
|
| - async_wait_id_ = waiter_->AsyncWait(message_pipe_.get().value(),
|
| - MOJO_HANDLE_SIGNAL_READABLE,
|
| - MOJO_DEADLINE_INDEFINITE,
|
| - &Connector::CallOnHandleReady,
|
| - this);
|
| + async_wait_id_ = waiter_->AsyncWait(
|
| + 4, message_pipe_.get().value(), MOJO_HANDLE_SIGNAL_READABLE,
|
| + MOJO_DEADLINE_INDEFINITE, &Connector::CallOnHandleReady, this);
|
| }
|
|
|
| bool Connector::ReadSingleMessage(MojoResult* read_result) {
|
|
|