| 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);
|
|
|