Index: content/renderer/p2p/host_address_request.cc |
diff --git a/content/renderer/p2p/host_address_request.cc b/content/renderer/p2p/host_address_request.cc |
index e21e0aae2278b7e5052a3879556f48b829795945..6c7f26244e20dd50458013fa8e151b815ffd0ac9 100644 |
--- a/content/renderer/p2p/host_address_request.cc |
+++ b/content/renderer/p2p/host_address_request.cc |
@@ -16,7 +16,7 @@ namespace content { |
P2PAsyncAddressResolver::P2PAsyncAddressResolver( |
P2PSocketDispatcher* dispatcher) |
: dispatcher_(dispatcher), |
- ipc_message_loop_(dispatcher->message_loop()), |
+ ipc_task_runner_(dispatcher->task_runner()), |
delegate_message_loop_(base::MessageLoopProxy::current()), |
state_(STATE_CREATED), |
request_id_(0), |
@@ -35,8 +35,9 @@ void P2PAsyncAddressResolver::Start(const rtc::SocketAddress& host_name, |
DCHECK_EQ(STATE_CREATED, state_); |
state_ = STATE_SENT; |
- ipc_message_loop_->PostTask(FROM_HERE, base::Bind( |
- &P2PAsyncAddressResolver::DoSendRequest, this, host_name, done_callback)); |
+ ipc_task_runner_->PostTask( |
+ FROM_HERE, base::Bind(&P2PAsyncAddressResolver::DoSendRequest, this, |
+ host_name, done_callback)); |
} |
void P2PAsyncAddressResolver::Cancel() { |
@@ -44,8 +45,8 @@ void P2PAsyncAddressResolver::Cancel() { |
if (state_ != STATE_FINISHED) { |
state_ = STATE_FINISHED; |
- ipc_message_loop_->PostTask(FROM_HERE, base::Bind( |
- &P2PAsyncAddressResolver::DoUnregister, this)); |
+ ipc_task_runner_->PostTask( |
+ FROM_HERE, base::Bind(&P2PAsyncAddressResolver::DoUnregister, this)); |
} |
done_callback_.Reset(); |
} |
@@ -53,7 +54,7 @@ void P2PAsyncAddressResolver::Cancel() { |
void P2PAsyncAddressResolver::DoSendRequest( |
const rtc::SocketAddress& host_name, |
const DoneCallback& done_callback) { |
- DCHECK(ipc_message_loop_->BelongsToCurrentThread()); |
+ DCHECK(ipc_task_runner_->BelongsToCurrentThread()); |
done_callback_ = done_callback; |
request_id_ = dispatcher_->RegisterHostAddressRequest(this); |
@@ -63,7 +64,7 @@ void P2PAsyncAddressResolver::DoSendRequest( |
} |
void P2PAsyncAddressResolver::DoUnregister() { |
- DCHECK(ipc_message_loop_->BelongsToCurrentThread()); |
+ DCHECK(ipc_task_runner_->BelongsToCurrentThread()); |
if (registered_) { |
dispatcher_->UnregisterHostAddressRequest(request_id_); |
registered_ = false; |
@@ -71,7 +72,7 @@ void P2PAsyncAddressResolver::DoUnregister() { |
} |
void P2PAsyncAddressResolver::OnResponse(const net::IPAddressList& addresses) { |
- DCHECK(ipc_message_loop_->BelongsToCurrentThread()); |
+ DCHECK(ipc_task_runner_->BelongsToCurrentThread()); |
DCHECK(registered_); |
dispatcher_->UnregisterHostAddressRequest(request_id_); |