| Index: mojo/edk/system/message_pipe_unittest.cc
|
| diff --git a/mojo/edk/system/message_pipe_unittest.cc b/mojo/edk/system/message_pipe_unittest.cc
|
| index 52ace8046b458aa944384ec2fb19822cc1db6397..6df7bed0197f833efdf0c01c6a791e283d9bf642 100644
|
| --- a/mojo/edk/system/message_pipe_unittest.cc
|
| +++ b/mojo/edk/system/message_pipe_unittest.cc
|
| @@ -4,7 +4,6 @@
|
|
|
| #include "mojo/edk/system/message_pipe.h"
|
|
|
| -#include "base/memory/ref_counted.h"
|
| #include "mojo/edk/system/waiter.h"
|
| #include "mojo/edk/system/waiter_test_utils.h"
|
| #include "testing/gtest/include/gtest/gtest.h"
|
| @@ -30,7 +29,7 @@ const MojoHandleSignals kAllSignals = MOJO_HANDLE_SIGNAL_READABLE |
|
| // - writing a message to a port, closing the other (would be the source) port,
|
| // and reading it
|
| TEST(MessagePipeTest, Basic) {
|
| - scoped_refptr<MessagePipe> mp(MessagePipe::CreateLocalLocal());
|
| + auto mp = MessagePipe::CreateLocalLocal();
|
|
|
| int32_t buffer[2];
|
| const uint32_t kBufferSize = static_cast<uint32_t>(sizeof(buffer));
|
| @@ -192,7 +191,7 @@ TEST(MessagePipeTest, Basic) {
|
| }
|
|
|
| TEST(MessagePipeTest, CloseWithQueuedIncomingMessages) {
|
| - scoped_refptr<MessagePipe> mp(MessagePipe::CreateLocalLocal());
|
| + auto mp = MessagePipe::CreateLocalLocal();
|
|
|
| int32_t buffer[1];
|
| const uint32_t kBufferSize = static_cast<uint32_t>(sizeof(buffer));
|
| @@ -219,7 +218,7 @@ TEST(MessagePipeTest, CloseWithQueuedIncomingMessages) {
|
| }
|
|
|
| TEST(MessagePipeTest, DiscardMode) {
|
| - scoped_refptr<MessagePipe> mp(MessagePipe::CreateLocalLocal());
|
| + auto mp = MessagePipe::CreateLocalLocal();
|
|
|
| int32_t buffer[2];
|
| const uint32_t kBufferSize = static_cast<uint32_t>(sizeof(buffer));
|
| @@ -323,7 +322,7 @@ TEST(MessagePipeTest, DiscardMode) {
|
| }
|
|
|
| TEST(MessagePipeTest, BasicWaiting) {
|
| - scoped_refptr<MessagePipe> mp(MessagePipe::CreateLocalLocal());
|
| + auto mp = MessagePipe::CreateLocalLocal();
|
| Waiter waiter;
|
| HandleSignalsState hss;
|
|
|
| @@ -465,7 +464,7 @@ TEST(MessagePipeTest, ThreadedWaiting) {
|
|
|
| // Write to wake up waiter waiting for read.
|
| {
|
| - scoped_refptr<MessagePipe> mp(MessagePipe::CreateLocalLocal());
|
| + auto mp = MessagePipe::CreateLocalLocal();
|
| test::SimpleWaiterThread thread(&result, &context);
|
|
|
| thread.waiter()->Init();
|
| @@ -495,7 +494,7 @@ TEST(MessagePipeTest, ThreadedWaiting) {
|
|
|
| // Close to cancel waiter.
|
| {
|
| - scoped_refptr<MessagePipe> mp(MessagePipe::CreateLocalLocal());
|
| + auto mp = MessagePipe::CreateLocalLocal();
|
| test::SimpleWaiterThread thread(&result, &context);
|
|
|
| thread.waiter()->Init();
|
| @@ -518,7 +517,7 @@ TEST(MessagePipeTest, ThreadedWaiting) {
|
|
|
| // Close to cancel waiter using peer closed signal.
|
| {
|
| - scoped_refptr<MessagePipe> mp(MessagePipe::CreateLocalLocal());
|
| + auto mp = MessagePipe::CreateLocalLocal();
|
| test::SimpleWaiterThread thread(&result, &context);
|
|
|
| thread.waiter()->Init();
|
| @@ -541,7 +540,7 @@ TEST(MessagePipeTest, ThreadedWaiting) {
|
|
|
| // Close to make waiter un-wake-up-able.
|
| {
|
| - scoped_refptr<MessagePipe> mp(MessagePipe::CreateLocalLocal());
|
| + auto mp = MessagePipe::CreateLocalLocal();
|
| test::SimpleWaiterThread thread(&result, &context);
|
|
|
| thread.waiter()->Init();
|
|
|