| Index: content/renderer/p2p/socket_client.cc
|
| diff --git a/content/renderer/p2p/socket_client.cc b/content/renderer/p2p/socket_client.cc
|
| index 55fcee569b62217698070426b1fa3fbc9b6bfedf..7937d27d0223290289ea008222fb8b20c0a0256b 100644
|
| --- a/content/renderer/p2p/socket_client.cc
|
| +++ b/content/renderer/p2p/socket_client.cc
|
| @@ -11,7 +11,7 @@
|
| P2PSocketClient::P2PSocketClient(P2PSocketDispatcher* dispatcher)
|
| : dispatcher_(dispatcher),
|
| ipc_message_loop_(dispatcher->message_loop()),
|
| - delegate_message_loop_(NULL),
|
| + delegate_message_loop_(base::MessageLoopProxy::CreateForCurrentThread()),
|
| socket_id_(0), delegate_(NULL),
|
| state_(STATE_UNINITIALIZED) {
|
| }
|
| @@ -21,21 +21,21 @@ P2PSocketClient::~P2PSocketClient() {
|
| }
|
|
|
| void P2PSocketClient::Init(
|
| - P2PSocketType type, const net::IPEndPoint& local_address,
|
| - const net::IPEndPoint& remote_address, P2PSocketClient::Delegate* delegate,
|
| - scoped_refptr<base::MessageLoopProxy> delegate_loop) {
|
| + P2PSocketType type,
|
| + const net::IPEndPoint& local_address,
|
| + const net::IPEndPoint& remote_address,
|
| + P2PSocketClient::Delegate* delegate) {
|
| if (!ipc_message_loop_->BelongsToCurrentThread()) {
|
| ipc_message_loop_->PostTask(
|
| FROM_HERE, NewRunnableMethod(
|
| - this, &P2PSocketClient::Init, type, local_address, remote_address,
|
| - delegate, delegate_loop));
|
| + this, &P2PSocketClient::Init, type, local_address,
|
| + remote_address, delegate));
|
| return;
|
| }
|
|
|
| DCHECK_EQ(state_, STATE_UNINITIALIZED);
|
| state_ = STATE_OPENING;
|
| delegate_ = delegate;
|
| - delegate_message_loop_ = delegate_loop;
|
| socket_id_ = dispatcher_->RegisterClient(this);
|
| dispatcher_->SendP2PMessage(new P2PHostMsg_CreateSocket(
|
| 0, type, socket_id_, local_address, remote_address));
|
|
|