Index: extensions/browser/api/cast_channel/cast_transport.cc |
diff --git a/extensions/browser/api/cast_channel/cast_transport.cc b/extensions/browser/api/cast_channel/cast_transport.cc |
index a11cc6ffbc4c758bd4ec62a3a307acaee168b772..b3fe918505238d83b6a03540de2fb5913f52e414 100644 |
--- a/extensions/browser/api/cast_channel/cast_transport.cc |
+++ b/extensions/browser/api/cast_channel/cast_transport.cc |
@@ -12,9 +12,11 @@ |
#include "base/bind.h" |
#include "base/format_macros.h" |
-#include "base/message_loop/message_loop.h" |
+#include "base/location.h" |
#include "base/numerics/safe_conversions.h" |
+#include "base/single_thread_task_runner.h" |
#include "base/strings/stringprintf.h" |
+#include "base/threading/thread_task_runner_handle.h" |
#include "extensions/browser/api/cast_channel/cast_framer.h" |
#include "extensions/browser/api/cast_channel/cast_message_util.h" |
#include "extensions/browser/api/cast_channel/logger.h" |
@@ -156,7 +158,7 @@ void CastTransportImpl::SetReadDelegate(std::unique_ptr<Delegate> delegate) { |
void CastTransportImpl::FlushWriteQueue() { |
for (; !write_queue_.empty(); write_queue_.pop()) { |
net::CompletionCallback& callback = write_queue_.front().callback; |
- base::MessageLoop::current()->PostTask( |
+ base::ThreadTaskRunnerHandle::Get()->PostTask( |
FROM_HERE, base::Bind(callback, net::ERR_FAILED)); |
callback.Reset(); |
} |
@@ -170,7 +172,7 @@ void CastTransportImpl::SendMessage(const CastMessage& message, |
logger_->LogSocketEventForMessage(channel_id_, proto::SEND_MESSAGE_FAILED, |
message.namespace_(), |
"Error when serializing message."); |
- base::MessageLoop::current()->PostTask( |
+ base::ThreadTaskRunnerHandle::Get()->PostTask( |
FROM_HERE, base::Bind(callback, net::ERR_FAILED)); |
return; |
} |
@@ -325,10 +327,10 @@ int CastTransportImpl::DoWriteCallback() { |
logger_->LogSocketEventForMessage( |
channel_id_, proto::MESSAGE_WRITTEN, request.message_namespace, |
base::StringPrintf("Bytes: %d", bytes_consumed)); |
- base::MessageLoop::current()->PostTask(FROM_HERE, |
- base::Bind(&base::DoNothing)); |
- base::MessageLoop::current()->PostTask(FROM_HERE, |
- base::Bind(request.callback, net::OK)); |
+ base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE, |
+ base::Bind(&base::DoNothing)); |
+ base::ThreadTaskRunnerHandle::Get()->PostTask( |
+ FROM_HERE, base::Bind(request.callback, net::OK)); |
write_queue_.pop(); |
if (write_queue_.empty()) { |