| Index: google_apis/gcm/engine/mcs_client.cc
|
| diff --git a/google_apis/gcm/engine/mcs_client.cc b/google_apis/gcm/engine/mcs_client.cc
|
| index 9b4607d7b6768183a8d456d2dcb13aa749ad993e..a63192cac53c814e7c61aedc83ba068b374dc43f 100644
|
| --- a/google_apis/gcm/engine/mcs_client.cc
|
| +++ b/google_apis/gcm/engine/mcs_client.cc
|
| @@ -8,9 +8,10 @@
|
|
|
| #include "base/basictypes.h"
|
| #include "base/bind.h"
|
| -#include "base/message_loop/message_loop.h"
|
| +#include "base/location.h"
|
| #include "base/metrics/histogram.h"
|
| #include "base/strings/string_number_conversions.h"
|
| +#include "base/thread_task_runner_handle.h"
|
| #include "base/time/clock.h"
|
| #include "base/time/time.h"
|
| #include "base/timer/timer.h"
|
| @@ -544,7 +545,7 @@ void MCSClient::MaybeSendMessage() {
|
| packet->persistent_id,
|
| base::Bind(&MCSClient::OnGCMUpdateFinished,
|
| weak_ptr_factory_.GetWeakPtr()));
|
| - base::MessageLoop::current()->PostTask(
|
| + base::ThreadTaskRunnerHandle::Get()->PostTask(
|
| FROM_HERE,
|
| base::Bind(&MCSClient::MaybeSendMessage,
|
| weak_ptr_factory_.GetWeakPtr()));
|
| @@ -717,14 +718,14 @@ void MCSClient::HandlePacketFromWire(
|
| DCHECK_EQ(1U, stream_id_out_);
|
|
|
| // Pass the login response on up.
|
| - base::MessageLoop::current()->PostTask(
|
| + base::ThreadTaskRunnerHandle::Get()->PostTask(
|
| FROM_HERE,
|
| base::Bind(message_received_callback_,
|
| MCSMessage(tag, protobuf.Pass())));
|
|
|
| // If there are pending messages, attempt to send one.
|
| if (!to_send_.empty()) {
|
| - base::MessageLoop::current()->PostTask(
|
| + base::ThreadTaskRunnerHandle::Get()->PostTask(
|
| FROM_HERE,
|
| base::Bind(&MCSClient::MaybeSendMessage,
|
| weak_ptr_factory_.GetWeakPtr()));
|
| @@ -788,7 +789,7 @@ void MCSClient::HandlePacketFromWire(
|
| }
|
|
|
| DCHECK(protobuf.get());
|
| - base::MessageLoop::current()->PostTask(
|
| + base::ThreadTaskRunnerHandle::Get()->PostTask(
|
| FROM_HERE,
|
| base::Bind(message_received_callback_,
|
| MCSMessage(tag, protobuf.Pass())));
|
| @@ -896,7 +897,7 @@ void MCSClient::HandleSelectiveAck(const PersistentIdList& id_list) {
|
| to_send_.push_front(to_resend_.back());
|
| to_resend_.pop_back();
|
| }
|
| - base::MessageLoop::current()->PostTask(
|
| + base::ThreadTaskRunnerHandle::Get()->PostTask(
|
| FROM_HERE,
|
| base::Bind(&MCSClient::MaybeSendMessage,
|
| weak_ptr_factory_.GetWeakPtr()));
|
|
|