Index: third_party/mojo/src/mojo/public/cpp/bindings/lib/router.cc |
diff --git a/third_party/mojo/src/mojo/public/cpp/bindings/lib/router.cc b/third_party/mojo/src/mojo/public/cpp/bindings/lib/router.cc |
index fa264b784a8502c51c1d2fa52ff2001ef680bedb..5a7c7e2f97437724ca7f1284b9175ef1fb477ab8 100644 |
--- a/third_party/mojo/src/mojo/public/cpp/bindings/lib/router.cc |
+++ b/third_party/mojo/src/mojo/public/cpp/bindings/lib/router.cc |
@@ -92,13 +92,11 @@ |
} |
bool Router::Accept(Message* message) { |
- MOJO_DCHECK(thread_checker_.CalledOnValidThread()); |
MOJO_DCHECK(!message->has_flag(kMessageExpectsResponse)); |
return connector_.Accept(message); |
} |
bool Router::AcceptWithResponder(Message* message, MessageReceiver* responder) { |
- MOJO_DCHECK(thread_checker_.CalledOnValidThread()); |
MOJO_DCHECK(message->has_flag(kMessageExpectsResponse)); |
// Reserve 0 in case we want it to convey special meaning in the future. |
@@ -116,13 +114,11 @@ |
} |
void Router::EnableTestingMode() { |
- MOJO_DCHECK(thread_checker_.CalledOnValidThread()); |
testing_mode_ = true; |
connector_.set_enforce_errors_from_incoming_receiver(false); |
} |
bool Router::HandleIncomingMessage(Message* message) { |
- MOJO_DCHECK(thread_checker_.CalledOnValidThread()); |
if (message->has_flag(kMessageExpectsResponse)) { |
if (incoming_receiver_) { |
MessageReceiverWithStatus* responder = new ResponderThunk(weak_self_); |