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())); |