Index: ipc/ipc_channel_win.cc |
diff --git a/ipc/ipc_channel_win.cc b/ipc/ipc_channel_win.cc |
index 66c14c84eef49975bc7f6f03a5be844bad54efcd..f59b22ae4b8c81dd41d99db1aca851e3ab79839e 100644 |
--- a/ipc/ipc_channel_win.cc |
+++ b/ipc/ipc_channel_win.cc |
@@ -20,6 +20,7 @@ |
#include "base/strings/string_number_conversions.h" |
#include "base/strings/utf_string_conversions.h" |
#include "base/threading/thread_checker.h" |
+#include "base/threading/thread_task_runner_handle.h" |
#include "base/win/scoped_handle.h" |
#include "ipc/attachment_broker.h" |
#include "ipc/ipc_listener.h" |
@@ -393,6 +394,8 @@ bool ChannelWin::CreatePipe(const IPC::ChannelHandle &channel_handle, |
} |
bool ChannelWin::Connect() { |
+ DCHECK(base::MessageLoopForIO::IsCurrent()); |
+ |
WillConnect(); |
DLOG_IF(WARNING, thread_check_.get()) << "Connect called more than once"; |
@@ -413,7 +416,7 @@ bool ChannelWin::Connect() { |
// Complete setup asynchronously. By not setting input_state_.is_pending |
// to true, we indicate to OnIOCompleted that this is the special |
// initialization signal. |
- base::MessageLoopForIO::current()->task_runner()->PostTask( |
+ base::ThreadTaskRunnerHandle::Get()->PostTask( |
FROM_HERE, |
base::Bind(&ChannelWin::OnIOCompleted, weak_factory_.GetWeakPtr(), |
&input_state_.context, 0, 0)); |