| Index: mojo/public/cpp/bindings/lib/connector.cc
|
| diff --git a/mojo/public/cpp/bindings/lib/connector.cc b/mojo/public/cpp/bindings/lib/connector.cc
|
| index 9f1037ceae81b09ef3948d6532b7f1cec9a524ff..a8104c24fcb82c9ad70d8ff993a777112f72f05c 100644
|
| --- a/mojo/public/cpp/bindings/lib/connector.cc
|
| +++ b/mojo/public/cpp/bindings/lib/connector.cc
|
| @@ -266,9 +266,10 @@ bool Connector::ReadSingleMessage(MojoResult* read_result) {
|
| const MojoResult rv = ReadMessage(message_pipe_.get(), &message);
|
| *read_result = rv;
|
|
|
| - if (rv == MOJO_RESULT_OK) {
|
| - receiver_result =
|
| - incoming_receiver_ && incoming_receiver_->Accept(&message);
|
| + if (rv == MOJO_RESULT_OK && incoming_receiver_) {
|
| + receiver_result = incoming_receiver_->Accept(&message);
|
| + if (!receiver_result)
|
| + message.NotifyBadMessage();
|
| }
|
|
|
| if (!weak_self)
|
|
|