| Index: mojo/system/multiprocess_message_pipe_unittest.cc
|
| diff --git a/mojo/system/multiprocess_message_pipe_unittest.cc b/mojo/system/multiprocess_message_pipe_unittest.cc
|
| index 85318266f417cf181970440f0e0304a94f90b695..406596552e99e84cc0e7b76ff9795cd9377164a4 100644
|
| --- a/mojo/system/multiprocess_message_pipe_unittest.cc
|
| +++ b/mojo/system/multiprocess_message_pipe_unittest.cc
|
| @@ -21,8 +21,8 @@
|
| #include "mojo/system/channel.h"
|
| #include "mojo/system/local_message_pipe_endpoint.h"
|
| #include "mojo/system/message_pipe.h"
|
| -#include "mojo/system/platform_channel.h"
|
| #include "mojo/system/proxy_message_pipe_endpoint.h"
|
| +#include "mojo/system/scoped_platform_handle.h"
|
| #include "mojo/system/test_utils.h"
|
| #include "mojo/system/waiter.h"
|
|
|
| @@ -48,13 +48,14 @@ class IOThreadWrapper {
|
| test::PostTaskAndWait(task_runner(), from_here, task);
|
| }
|
|
|
| - void Init(PlatformChannel* platform_channel, scoped_refptr<MessagePipe> mp) {
|
| + void Init(ScopedPlatformHandle platform_handle,
|
| + scoped_refptr<MessagePipe> mp) {
|
| io_thread_.StartWithOptions(
|
| base::Thread::Options(base::MessageLoop::TYPE_IO, 0));
|
| PostTask(FROM_HERE,
|
| base::Bind(&IOThreadWrapper::InitOnIOThread,
|
| base::Unretained(this),
|
| - platform_channel, mp));
|
| + base::Passed(&platform_handle), mp));
|
| }
|
|
|
| void Shutdown() {
|
| @@ -75,15 +76,14 @@ class IOThreadWrapper {
|
| }
|
|
|
| private:
|
| - void InitOnIOThread(PlatformChannel* platform_channel,
|
| + void InitOnIOThread(ScopedPlatformHandle platform_handle,
|
| scoped_refptr<MessagePipe> mp) {
|
| CHECK_EQ(base::MessageLoop::current(), message_loop());
|
| - CHECK(platform_channel);
|
| - CHECK(platform_channel->is_valid());
|
| + CHECK(platform_handle.is_valid());
|
|
|
| // Create and initialize |Channel|.
|
| channel_ = new Channel();
|
| - CHECK(channel_->Init(platform_channel->PassHandle()));
|
| + CHECK(channel_->Init(platform_handle.Pass()));
|
|
|
| // Attach the message pipe endpoint.
|
| // Note: On the "server" (parent process) side, we need not attach the
|
| @@ -122,7 +122,7 @@ class MultiprocessMessagePipeTest : public mojo::test::MultiprocessTestBase {
|
| }
|
|
|
| void Init(scoped_refptr<MessagePipe> mp) {
|
| - io_thread_wrapper_.Init(server_platform_channel.get(), mp);
|
| + io_thread_wrapper_.Init(server_platform_handle.Pass(), mp);
|
| }
|
|
|
| private:
|
| @@ -152,14 +152,13 @@ MojoResult WaitIfNecessary(scoped_refptr<MessagePipe> mp, MojoWaitFlags flags) {
|
| // not including any "quitquitquit" message, modulo 100.
|
| MOJO_MULTIPROCESS_TEST_CHILD_MAIN(EchoEcho) {
|
| IOThreadWrapper io_thread_wrapper;
|
| - PlatformChannel* const client_platform_channel =
|
| - MultiprocessMessagePipeTest::client_platform_channel.get();
|
| - CHECK(client_platform_channel);
|
| - CHECK(client_platform_channel->is_valid());
|
| + ScopedPlatformHandle client_platform_handle =
|
| + MultiprocessMessagePipeTest::client_platform_handle.Pass();
|
| + CHECK(client_platform_handle.is_valid());
|
| scoped_refptr<MessagePipe> mp(new MessagePipe(
|
| scoped_ptr<MessagePipeEndpoint>(new LocalMessagePipeEndpoint()),
|
| scoped_ptr<MessagePipeEndpoint>(new ProxyMessagePipeEndpoint())));
|
| - io_thread_wrapper.Init(client_platform_channel, mp);
|
| + io_thread_wrapper.Init(client_platform_handle.Pass(), mp);
|
|
|
| const std::string quitquitquit("quitquitquit");
|
| int rv = 0;
|
|
|