| Index: mojo/edk/system/message_pipe_perftest.cc
|
| diff --git a/mojo/edk/system/message_pipe_perftest.cc b/mojo/edk/system/message_pipe_perftest.cc
|
| index 4964b83f4093e5f208b5de5e93122347ac77f057..362172ac8b2080a29450e0729b0869fc8f9f5751 100644
|
| --- a/mojo/edk/system/message_pipe_perftest.cc
|
| +++ b/mojo/edk/system/message_pipe_perftest.cc
|
| @@ -45,7 +45,7 @@ class MultiprocessMessagePipePerfTest
|
| }
|
|
|
| protected:
|
| - void WriteWaitThenRead(scoped_refptr<MessagePipe> mp) {
|
| + void WriteWaitThenRead(MessagePipe* mp) {
|
| CHECK_EQ(mp->WriteMessage(0, UserPointer<const void>(payload_.data()),
|
| static_cast<uint32_t>(payload_.size()), nullptr,
|
| MOJO_WRITE_MESSAGE_FLAG_NONE),
|
| @@ -61,13 +61,13 @@ class MultiprocessMessagePipePerfTest
|
| CHECK_EQ(read_buffer_size, static_cast<uint32_t>(payload_.size()));
|
| }
|
|
|
| - void SendQuitMessage(scoped_refptr<MessagePipe> mp) {
|
| + void SendQuitMessage(MessagePipe* mp) {
|
| CHECK_EQ(mp->WriteMessage(0, UserPointer<const void>(""), 0, nullptr,
|
| MOJO_WRITE_MESSAGE_FLAG_NONE),
|
| MOJO_RESULT_OK);
|
| }
|
|
|
| - void Measure(scoped_refptr<MessagePipe> mp) {
|
| + void Measure(MessagePipe* mp) {
|
| // Have one ping-pong to ensure channel being established.
|
| WriteWaitThenRead(mp);
|
|
|
| @@ -101,7 +101,7 @@ MOJO_MULTIPROCESS_TEST_CHILD_MAIN(PingPongClient) {
|
| mojo::test::MultiprocessTestHelper::client_platform_handle.Pass();
|
| CHECK(client_platform_handle.is_valid());
|
| RefPtr<ChannelEndpoint> ep;
|
| - scoped_refptr<MessagePipe> mp(MessagePipe::CreateLocalProxy(&ep));
|
| + auto mp = MessagePipe::CreateLocalProxy(&ep);
|
| channel_thread.Start(client_platform_handle.Pass(), std::move(ep));
|
|
|
| std::string buffer(1000000, '\0');
|
| @@ -110,7 +110,7 @@ MOJO_MULTIPROCESS_TEST_CHILD_MAIN(PingPongClient) {
|
| // Wait for our end of the message pipe to be readable.
|
| HandleSignalsState hss;
|
| MojoResult result =
|
| - test::WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE, &hss);
|
| + test::WaitIfNecessary(mp.get(), MOJO_HANDLE_SIGNAL_READABLE, &hss);
|
| if (result != MOJO_RESULT_OK) {
|
| rv = result;
|
| break;
|
| @@ -149,7 +149,7 @@ TEST_F(MultiprocessMessagePipePerfTest, MAYBE_PingPong) {
|
| helper()->StartChild("PingPongClient");
|
|
|
| RefPtr<ChannelEndpoint> ep;
|
| - scoped_refptr<MessagePipe> mp(MessagePipe::CreateLocalProxy(&ep));
|
| + auto mp = MessagePipe::CreateLocalProxy(&ep);
|
| Init(std::move(ep));
|
|
|
| // This values are set to align with one at ipc_pertests.cc for comparison.
|
| @@ -158,10 +158,10 @@ TEST_F(MultiprocessMessagePipePerfTest, MAYBE_PingPong) {
|
|
|
| for (size_t i = 0; i < 5; i++) {
|
| SetUpMeasurement(kMessageCount[i], kMsgSize[i]);
|
| - Measure(mp);
|
| + Measure(mp.get());
|
| }
|
|
|
| - SendQuitMessage(mp);
|
| + SendQuitMessage(mp.get());
|
| mp->Close(0);
|
| EXPECT_EQ(0, helper()->WaitForChildShutdown());
|
| }
|
|
|