Index: third_party/mojo/src/mojo/edk/test/scoped_ipc_support.cc |
diff --git a/third_party/mojo/src/mojo/edk/test/scoped_ipc_support.cc b/third_party/mojo/src/mojo/edk/test/scoped_ipc_support.cc |
index fad9c82c6d296bd88df7fdf81da90a8c961e9588..9f3b97d7579a3b2fa8dd3db435f6bb80bc1a2aca 100644 |
--- a/third_party/mojo/src/mojo/edk/test/scoped_ipc_support.cc |
+++ b/third_party/mojo/src/mojo/edk/test/scoped_ipc_support.cc |
@@ -10,13 +10,17 @@ |
namespace mojo { |
namespace test { |
-namespace internal { |
- |
-ScopedIPCSupportHelper::ScopedIPCSupportHelper() |
- : event_(true, false) { // Manual reset. |
+ScopedIPCSupport::ScopedIPCSupport( |
+ scoped_refptr<base::TaskRunner> io_thread_task_runner) |
+ : io_thread_task_runner_(io_thread_task_runner), |
+ event_(true, false) { // Manual reset. |
+ // Note: Run delegate methods on the I/O thread. |
+ embedder::InitIPCSupport(embedder::ProcessType::NONE, io_thread_task_runner, |
+ this, io_thread_task_runner, |
+ embedder::ScopedPlatformHandle()); |
} |
-ScopedIPCSupportHelper::~ScopedIPCSupportHelper() { |
+ScopedIPCSupport::~ScopedIPCSupport() { |
if (base::MessageLoop::current() && |
base::MessageLoop::current()->task_runner() == io_thread_task_runner_) { |
embedder::ShutdownIPCSupportOnIOThread(); |
@@ -26,89 +30,8 @@ ScopedIPCSupportHelper::~ScopedIPCSupportHelper() { |
} |
} |
-void ScopedIPCSupportHelper::Init( |
- embedder::ProcessType process_type, |
- embedder::ProcessDelegate* process_delegate, |
- scoped_refptr<base::TaskRunner> io_thread_task_runner, |
- embedder::ScopedPlatformHandle platform_handle) { |
- io_thread_task_runner_ = io_thread_task_runner; |
- // Note: Run delegate methods on the I/O thread. |
- embedder::InitIPCSupport(process_type, io_thread_task_runner_, |
- process_delegate, io_thread_task_runner_, |
- platform_handle.Pass()); |
-} |
- |
-void ScopedIPCSupportHelper::OnShutdownCompleteImpl() { |
- event_.Signal(); |
-} |
- |
-} // namespace internal |
- |
-ScopedIPCSupport::ScopedIPCSupport( |
- scoped_refptr<base::TaskRunner> io_thread_task_runner) { |
- helper_.Init(embedder::ProcessType::NONE, this, io_thread_task_runner.Pass(), |
- embedder::ScopedPlatformHandle()); |
-} |
- |
-ScopedIPCSupport::~ScopedIPCSupport() { |
-} |
- |
void ScopedIPCSupport::OnShutdownComplete() { |
- helper_.OnShutdownCompleteImpl(); |
-} |
- |
-ScopedMasterIPCSupport::ScopedMasterIPCSupport( |
- scoped_refptr<base::TaskRunner> io_thread_task_runner) { |
- helper_.Init(embedder::ProcessType::MASTER, this, |
- io_thread_task_runner.Pass(), embedder::ScopedPlatformHandle()); |
-} |
- |
-ScopedMasterIPCSupport::ScopedMasterIPCSupport( |
- scoped_refptr<base::TaskRunner> io_thread_task_runner, |
- base::Callback<void(embedder::SlaveInfo slave_info)> on_slave_disconnect) |
- : on_slave_disconnect_(on_slave_disconnect) { |
- helper_.Init(embedder::ProcessType::MASTER, this, |
- io_thread_task_runner.Pass(), embedder::ScopedPlatformHandle()); |
-} |
- |
-ScopedMasterIPCSupport::~ScopedMasterIPCSupport() { |
-} |
- |
-void ScopedMasterIPCSupport::OnShutdownComplete() { |
- helper_.OnShutdownCompleteImpl(); |
-} |
- |
-void ScopedMasterIPCSupport::OnSlaveDisconnect(embedder::SlaveInfo slave_info) { |
- if (!on_slave_disconnect_.is_null()) |
- on_slave_disconnect_.Run(slave_info); |
-} |
- |
-ScopedSlaveIPCSupport::ScopedSlaveIPCSupport( |
- scoped_refptr<base::TaskRunner> io_thread_task_runner, |
- embedder::ScopedPlatformHandle platform_handle) { |
- helper_.Init(embedder::ProcessType::SLAVE, this, io_thread_task_runner.Pass(), |
- platform_handle.Pass()); |
-} |
- |
-ScopedSlaveIPCSupport::ScopedSlaveIPCSupport( |
- scoped_refptr<base::TaskRunner> io_thread_task_runner, |
- embedder::ScopedPlatformHandle platform_handle, |
- base::Closure on_master_disconnect) |
- : on_master_disconnect_(on_master_disconnect) { |
- helper_.Init(embedder::ProcessType::SLAVE, this, io_thread_task_runner.Pass(), |
- platform_handle.Pass()); |
-} |
- |
-ScopedSlaveIPCSupport::~ScopedSlaveIPCSupport() { |
-} |
- |
-void ScopedSlaveIPCSupport::OnShutdownComplete() { |
- helper_.OnShutdownCompleteImpl(); |
-} |
- |
-void ScopedSlaveIPCSupport::OnMasterDisconnect() { |
- if (!on_master_disconnect_.is_null()) |
- on_master_disconnect_.Run(); |
+ event_.Signal(); |
} |
} // namespace test |