Index: device/serial/data_sender.cc |
diff --git a/device/serial/data_sender.cc b/device/serial/data_sender.cc |
index 962b8fdf202b9917ac526c82ec348f60645e1044..6f12750cbc9d79fbd36b0f59a46bdfdc0b4a0671 100644 |
--- a/device/serial/data_sender.cc |
+++ b/device/serial/data_sender.cc |
@@ -8,7 +8,9 @@ |
#include <utility> |
#include "base/bind.h" |
-#include "base/message_loop/message_loop.h" |
+#include "base/location.h" |
+#include "base/single_thread_task_runner.h" |
+#include "base/threading/thread_task_runner_handle.h" |
namespace device { |
@@ -80,7 +82,7 @@ bool DataSender::Cancel(int32_t error, const CancelCallback& callback) { |
if (!pending_cancel_.is_null() || shut_down_) |
return false; |
if (sends_awaiting_ack_.empty()) { |
- base::MessageLoop::current()->PostTask(FROM_HERE, callback); |
+ base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE, callback); |
return true; |
} |
@@ -120,8 +122,8 @@ void DataSender::RunCancelCallback() { |
if (pending_cancel_.is_null()) |
return; |
- base::MessageLoop::current()->PostTask(FROM_HERE, |
- base::Bind(pending_cancel_)); |
+ base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE, |
+ base::Bind(pending_cancel_)); |
pending_cancel_.Reset(); |
} |
@@ -146,19 +148,19 @@ DataSender::PendingSend::PendingSend(const base::StringPiece& data, |
void DataSender::PendingSend::OnDataSent(uint32_t num_bytes, int32_t error) { |
if (error) { |
- base::MessageLoop::current()->PostTask( |
+ base::ThreadTaskRunnerHandle::Get()->PostTask( |
FROM_HERE, base::Bind(error_callback_, num_bytes, error)); |
sender_->SendFailed(error); |
} else { |
DCHECK(num_bytes == data_.size()); |
- base::MessageLoop::current()->PostTask(FROM_HERE, |
- base::Bind(callback_, num_bytes)); |
+ base::ThreadTaskRunnerHandle::Get()->PostTask( |
+ FROM_HERE, base::Bind(callback_, num_bytes)); |
sender_->SendComplete(); |
} |
} |
void DataSender::PendingSend::DispatchFatalError() { |
- base::MessageLoop::current()->PostTask( |
+ base::ThreadTaskRunnerHandle::Get()->PostTask( |
FROM_HERE, base::Bind(error_callback_, 0, sender_->fatal_error_value_)); |
} |