Index: trunk/src/ipc/ipc_sync_channel_unittest.cc |
=================================================================== |
--- trunk/src/ipc/ipc_sync_channel_unittest.cc (revision 274314) |
+++ trunk/src/ipc/ipc_sync_channel_unittest.cc (working copy) |
@@ -151,12 +151,12 @@ |
} |
virtual SyncChannel* CreateChannel() { |
- scoped_ptr<SyncChannel> channel = SyncChannel::Create( |
- this, |
- ipc_thread_.message_loop_proxy().get(), |
- &shutdown_event_); |
- channel->InitByMode(channel_name_, mode_, true); |
- return channel.release(); |
+ return new SyncChannel(channel_name_, |
+ mode_, |
+ this, |
+ ipc_thread_.message_loop_proxy().get(), |
+ true, |
+ &shutdown_event_); |
} |
base::Thread* ListenerThread() { |
@@ -324,10 +324,9 @@ |
} |
virtual SyncChannel* CreateChannel() OVERRIDE { |
- SyncChannel* channel = SyncChannel::Create( |
- this, ipc_thread().message_loop_proxy().get(), |
- shutdown_event()).release(); |
- channel->InitByMode(channel_name(), mode(), create_pipe_now_); |
+ SyncChannel* channel = new SyncChannel( |
+ this, ipc_thread().message_loop_proxy().get(), shutdown_event()); |
+ channel->Init(channel_name(), mode(), create_pipe_now_); |
return channel; |
} |
@@ -346,10 +345,9 @@ |
} |
virtual SyncChannel* CreateChannel() OVERRIDE { |
- SyncChannel* channel = SyncChannel::Create( |
- this, ipc_thread().message_loop_proxy().get(), |
- shutdown_event()).release(); |
- channel->InitByMode(channel_name(), mode(), create_pipe_now_); |
+ SyncChannel* channel = new SyncChannel( |
+ this, ipc_thread().message_loop_proxy().get(), shutdown_event()); |
+ channel->Init(channel_name(), mode(), create_pipe_now_); |
return channel; |
} |
@@ -1137,12 +1135,13 @@ |
else |
LOG(ERROR) << "Send failed to dispatch incoming message on same channel"; |
- non_restricted_channel_ = |
- SyncChannel::CreateClient("non_restricted_channel", |
- this, |
- ipc_thread().message_loop_proxy().get(), |
- true, |
- shutdown_event()); |
+ non_restricted_channel_.reset( |
+ new SyncChannel("non_restricted_channel", |
+ Channel::MODE_CLIENT, |
+ this, |
+ ipc_thread().message_loop_proxy().get(), |
+ true, |
+ shutdown_event())); |
server_->ListenerThread()->message_loop()->PostTask( |
FROM_HERE, base::Bind(&RestrictedDispatchServer::OnDoPing, server_, 2)); |
@@ -1527,12 +1526,13 @@ |
if (is_first()) |
event1_->Signal(); |
event2_->Wait(); |
- other_channel_ = SyncChannel::CreateClient( |
- other_channel_name_, |
- this, |
- ipc_thread().message_loop_proxy().get(), |
- true, |
- shutdown_event()); |
+ other_channel_.reset( |
+ new SyncChannel(other_channel_name_, |
+ Channel::MODE_CLIENT, |
+ this, |
+ ipc_thread().message_loop_proxy().get(), |
+ true, |
+ shutdown_event())); |
other_channel_->SetRestrictDispatchChannelGroup(group_); |
if (!is_first()) { |
event1_->Signal(); |
@@ -1606,12 +1606,13 @@ |
server_ready_(server_ready) { } |
virtual void Run() OVERRIDE { |
- server2_channel_ = SyncChannel::CreateClient( |
- "reentrant_reply2", |
- this, |
- ipc_thread().message_loop_proxy().get(), |
- true, |
- shutdown_event()); |
+ server2_channel_.reset( |
+ new SyncChannel("reentrant_reply2", |
+ Channel::MODE_CLIENT, |
+ this, |
+ ipc_thread().message_loop_proxy().get(), |
+ true, |
+ shutdown_event())); |
server_ready_->Signal(); |
Message* msg = new SyncChannelTestMsg_Reentrant1(); |
server2_channel_->Send(msg); |