| 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 7d0d868a044f536728537f701e254b161ace4b0a..a2be32e9985e6370cde235caf369ad14e392ba4e 100644
|
| --- a/mojo/public/cpp/bindings/lib/router.cc
|
| +++ b/mojo/public/cpp/bindings/lib/router.cc
|
| @@ -57,7 +57,8 @@ Router::Router(ScopedMessagePipeHandle message_pipe,
|
| connector_(message_pipe.Pass(), waiter),
|
| weak_self_(this),
|
| incoming_receiver_(NULL),
|
| - next_request_id_(0) {
|
| + next_request_id_(0),
|
| + testing_mode_(false) {
|
| filters_.SetSink(&thunk_);
|
| connector_.set_incoming_receiver(filters_.GetHead());
|
| }
|
| @@ -94,6 +95,11 @@ bool Router::AcceptWithResponder(Message* message,
|
| return true;
|
| }
|
|
|
| +void Router::EnableTestingMode() {
|
| + testing_mode_ = true;
|
| + connector_.set_enforce_errors_from_incoming_receiver(false);
|
| +}
|
| +
|
| bool Router::HandleIncomingMessage(Message* message) {
|
| if (message->has_flag(kMessageExpectsResponse)) {
|
| if (incoming_receiver_) {
|
| @@ -111,7 +117,7 @@ bool Router::HandleIncomingMessage(Message* message) {
|
| uint64_t request_id = message->request_id();
|
| ResponderMap::iterator it = responders_.find(request_id);
|
| if (it == responders_.end()) {
|
| - assert(false);
|
| + assert(testing_mode_);
|
| return false;
|
| }
|
| MessageReceiver* responder = it->second;
|
|
|