OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "build/build_config.h" | 5 #include "build/build_config.h" |
6 | 6 |
7 #include "ipc/ipc_test_base.h" | 7 #include "ipc/ipc_test_base.h" |
8 | 8 |
9 #include "base/command_line.h" | 9 #include "base/command_line.h" |
10 #include "base/process/kill.h" | 10 #include "base/process/kill.h" |
(...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
76 void IPCTestBase::CreateChannelFromChannelHandle( | 76 void IPCTestBase::CreateChannelFromChannelHandle( |
77 const IPC::ChannelHandle& channel_handle, | 77 const IPC::ChannelHandle& channel_handle, |
78 IPC::Listener* listener) { | 78 IPC::Listener* listener) { |
79 CHECK(!channel_.get()); | 79 CHECK(!channel_.get()); |
80 CHECK(!channel_proxy_.get()); | 80 CHECK(!channel_proxy_.get()); |
81 channel_ = IPC::Channel::CreateServer(channel_handle, listener); | 81 channel_ = IPC::Channel::CreateServer(channel_handle, listener); |
82 } | 82 } |
83 | 83 |
84 void IPCTestBase::CreateChannelProxy( | 84 void IPCTestBase::CreateChannelProxy( |
85 IPC::Listener* listener, | 85 IPC::Listener* listener, |
86 base::SingleThreadTaskRunner* ipc_task_runner) { | 86 const scoped_refptr<base::SingleThreadTaskRunner>& ipc_task_runner) { |
87 CHECK(!channel_.get()); | 87 CHECK(!channel_.get()); |
88 CHECK(!channel_proxy_.get()); | 88 CHECK(!channel_proxy_.get()); |
89 channel_proxy_ = IPC::ChannelProxy::Create(GetChannelName(test_client_name_), | 89 channel_proxy_ = IPC::ChannelProxy::Create(GetChannelName(test_client_name_), |
90 IPC::Channel::MODE_SERVER, | 90 IPC::Channel::MODE_SERVER, |
91 listener, | 91 listener, |
92 ipc_task_runner); | 92 ipc_task_runner); |
93 } | 93 } |
94 | 94 |
95 void IPCTestBase::DestroyChannelProxy() { | 95 void IPCTestBase::DestroyChannelProxy() { |
96 CHECK(channel_proxy_.get()); | 96 CHECK(channel_proxy_.get()); |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
130 return rv; | 130 return rv; |
131 } | 131 } |
132 | 132 |
133 scoped_refptr<base::TaskRunner> IPCTestBase::task_runner() { | 133 scoped_refptr<base::TaskRunner> IPCTestBase::task_runner() { |
134 return message_loop_->message_loop_proxy(); | 134 return message_loop_->message_loop_proxy(); |
135 } | 135 } |
136 | 136 |
137 void IPCTestBase::set_message_loop(scoped_ptr<base::MessageLoop> loop) { | 137 void IPCTestBase::set_message_loop(scoped_ptr<base::MessageLoop> loop) { |
138 message_loop_ = loop.Pass(); | 138 message_loop_ = loop.Pass(); |
139 } | 139 } |
OLD | NEW |