| Index: ipc/ipc_sync_channel_unittest.cc
|
| diff --git a/ipc/ipc_sync_channel_unittest.cc b/ipc/ipc_sync_channel_unittest.cc
|
| index ca8d5d789a2a7caf9bf2b6032b5998eeb49213d5..817f17ee8a6ddd12cb68cd48faa885bd313bc13a 100644
|
| --- a/ipc/ipc_sync_channel_unittest.cc
|
| +++ b/ipc/ipc_sync_channel_unittest.cc
|
| @@ -151,12 +151,10 @@ class Worker : public Listener, public Sender {
|
| }
|
|
|
| virtual SyncChannel* CreateChannel() {
|
| - return new SyncChannel(channel_name_,
|
| - mode_,
|
| - this,
|
| - ipc_thread_.message_loop_proxy().get(),
|
| - true,
|
| - &shutdown_event_);
|
| + scoped_ptr<SyncChannel> channel = SyncChannel::Create(
|
| + channel_name_, mode_, this, ipc_thread_.message_loop_proxy().get(),
|
| + true, &shutdown_event_);
|
| + return channel.release();
|
| }
|
|
|
| base::Thread* ListenerThread() {
|
| @@ -324,9 +322,11 @@ class TwoStepServer : public Worker {
|
| }
|
|
|
| virtual SyncChannel* CreateChannel() OVERRIDE {
|
| - SyncChannel* channel = new SyncChannel(
|
| - this, ipc_thread().message_loop_proxy().get(), shutdown_event());
|
| - channel->Init(channel_name(), mode(), create_pipe_now_);
|
| + SyncChannel* channel =
|
| + SyncChannel::Create(channel_name(), mode(), this,
|
| + ipc_thread().message_loop_proxy().get(),
|
| + create_pipe_now_,
|
| + shutdown_event()).release();
|
| return channel;
|
| }
|
|
|
| @@ -345,9 +345,11 @@ class TwoStepClient : public Worker {
|
| }
|
|
|
| virtual SyncChannel* CreateChannel() OVERRIDE {
|
| - SyncChannel* channel = new SyncChannel(
|
| - this, ipc_thread().message_loop_proxy().get(), shutdown_event());
|
| - channel->Init(channel_name(), mode(), create_pipe_now_);
|
| + SyncChannel* channel =
|
| + SyncChannel::Create(channel_name(), mode(), this,
|
| + ipc_thread().message_loop_proxy().get(),
|
| + create_pipe_now_,
|
| + shutdown_event()).release();
|
| return channel;
|
| }
|
|
|
| @@ -1135,13 +1137,13 @@ class RestrictedDispatchClient : public Worker {
|
| else
|
| LOG(ERROR) << "Send failed to dispatch incoming message on same channel";
|
|
|
| - non_restricted_channel_.reset(
|
| - new SyncChannel("non_restricted_channel",
|
| - Channel::MODE_CLIENT,
|
| - this,
|
| - ipc_thread().message_loop_proxy().get(),
|
| - true,
|
| - shutdown_event()));
|
| + non_restricted_channel_ =
|
| + SyncChannel::Create("non_restricted_channel",
|
| + IPC::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));
|
| @@ -1526,13 +1528,13 @@ class RestrictedDispatchPipeWorker : public Worker {
|
| if (is_first())
|
| event1_->Signal();
|
| event2_->Wait();
|
| - other_channel_.reset(
|
| - new SyncChannel(other_channel_name_,
|
| - Channel::MODE_CLIENT,
|
| - this,
|
| - ipc_thread().message_loop_proxy().get(),
|
| - true,
|
| - shutdown_event()));
|
| + other_channel_ =
|
| + SyncChannel::Create(other_channel_name_,
|
| + IPC::Channel::MODE_CLIENT,
|
| + this,
|
| + ipc_thread().message_loop_proxy().get(),
|
| + true,
|
| + shutdown_event());
|
| other_channel_->SetRestrictDispatchChannelGroup(group_);
|
| if (!is_first()) {
|
| event1_->Signal();
|
| @@ -1606,13 +1608,13 @@ class ReentrantReplyServer1 : public Worker {
|
| server_ready_(server_ready) { }
|
|
|
| virtual void Run() OVERRIDE {
|
| - server2_channel_.reset(
|
| - new SyncChannel("reentrant_reply2",
|
| - Channel::MODE_CLIENT,
|
| - this,
|
| - ipc_thread().message_loop_proxy().get(),
|
| - true,
|
| - shutdown_event()));
|
| + server2_channel_ =
|
| + SyncChannel::Create("reentrant_reply2",
|
| + IPC::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);
|
|
|