| Index: mojo/public/cpp/bindings/lib/interface_endpoint_client.cc
|
| diff --git a/mojo/public/cpp/bindings/lib/interface_endpoint_client.cc b/mojo/public/cpp/bindings/lib/interface_endpoint_client.cc
|
| index 4682e72fadc43f1b905f00037d19a6124a55dfdc..ef3a1fe6800fe052d5f8bc15e04bea7c10a1a4fd 100644
|
| --- a/mojo/public/cpp/bindings/lib/interface_endpoint_client.cc
|
| +++ b/mojo/public/cpp/bindings/lib/interface_endpoint_client.cc
|
| @@ -52,7 +52,7 @@ class ResponderThunk : public MessageReceiverWithStatus {
|
| // We raise an error to signal the calling application that an error
|
| // condition occurred. Without this the calling application would have no
|
| // way of knowing it should stop waiting for a response.
|
| - if (task_runner_->RunsTasksOnCurrentThread()) {
|
| + if (task_runner_->RunsTasksInCurrentSequence()) {
|
| // Please note that even if this code is run from a different task
|
| // runner on the same thread as |task_runner_|, it is okay to directly
|
| // call InterfaceEndpointClient::RaiseError(), because it will raise
|
| @@ -70,7 +70,7 @@ class ResponderThunk : public MessageReceiverWithStatus {
|
|
|
| // MessageReceiver implementation:
|
| bool Accept(Message* message) override {
|
| - DCHECK(task_runner_->RunsTasksOnCurrentThread());
|
| + DCHECK(task_runner_->RunsTasksInCurrentSequence());
|
| accept_was_invoked_ = true;
|
| DCHECK(message->has_flag(Message::kFlagIsResponse));
|
|
|
| @@ -84,12 +84,12 @@ class ResponderThunk : public MessageReceiverWithStatus {
|
|
|
| // MessageReceiverWithStatus implementation:
|
| bool IsValid() override {
|
| - DCHECK(task_runner_->RunsTasksOnCurrentThread());
|
| + DCHECK(task_runner_->RunsTasksInCurrentSequence());
|
| return endpoint_client_ && !endpoint_client_->encountered_error();
|
| }
|
|
|
| void DCheckInvalid(const std::string& message) override {
|
| - if (task_runner_->RunsTasksOnCurrentThread()) {
|
| + if (task_runner_->RunsTasksInCurrentSequence()) {
|
| DCheckIfInvalid(endpoint_client_, message);
|
| } else {
|
| task_runner_->PostTask(
|
|
|