Chromium Code Reviews| 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..eee2d1a9ca626c81c3831007353df375d413874f 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(interface_name_); |
|
yzshen1
2016/06/11 00:10:59
For multiplex router, we may get here because of m
Ken Rockot(use gerrit already)
2016/06/11 21:48:30
Ah right. It's a bit more complicated than this to
|
| } |
| if (!weak_self) |