| Index: mojo/edk/system/message_pipe_dispatcher_unittest.cc
|
| diff --git a/mojo/edk/system/message_pipe_dispatcher_unittest.cc b/mojo/edk/system/message_pipe_dispatcher_unittest.cc
|
| index 8fd4696068ca9005dc37ef608b7bcbbdb3beb422..b51899b086b76e4cb71dc2e73b3d28a127596793 100644
|
| --- a/mojo/edk/system/message_pipe_dispatcher_unittest.cc
|
| +++ b/mojo/edk/system/message_pipe_dispatcher_unittest.cc
|
| @@ -16,8 +16,8 @@
|
| #include <utility>
|
| #include <vector>
|
|
|
| -#include "base/memory/ref_counted.h"
|
| #include "mojo/edk/system/message_pipe.h"
|
| +#include "mojo/edk/system/ref_ptr.h"
|
| #include "mojo/edk/system/test_utils.h"
|
| #include "mojo/edk/system/waiter.h"
|
| #include "mojo/edk/system/waiter_test_utils.h"
|
| @@ -42,10 +42,10 @@ TEST(MessagePipeDispatcherTest, Basic) {
|
|
|
| // Run this test both with |d0| as port 0, |d1| as port 1 and vice versa.
|
| for (unsigned i = 0; i < 2; i++) {
|
| - scoped_refptr<MessagePipeDispatcher> d0 = MessagePipeDispatcher::Create(
|
| + auto d0 = MessagePipeDispatcher::Create(
|
| MessagePipeDispatcher::kDefaultCreateOptions);
|
| EXPECT_EQ(Dispatcher::Type::MESSAGE_PIPE, d0->GetType());
|
| - scoped_refptr<MessagePipeDispatcher> d1 = MessagePipeDispatcher::Create(
|
| + auto d1 = MessagePipeDispatcher::Create(
|
| MessagePipeDispatcher::kDefaultCreateOptions);
|
| {
|
| auto mp = MessagePipe::CreateLocalLocal();
|
| @@ -154,9 +154,9 @@ TEST(MessagePipeDispatcherTest, Basic) {
|
| TEST(MessagePipeDispatcherTest, InvalidParams) {
|
| char buffer[1];
|
|
|
| - scoped_refptr<MessagePipeDispatcher> d0 = MessagePipeDispatcher::Create(
|
| + auto d0 = MessagePipeDispatcher::Create(
|
| MessagePipeDispatcher::kDefaultCreateOptions);
|
| - scoped_refptr<MessagePipeDispatcher> d1 = MessagePipeDispatcher::Create(
|
| + auto d1 = MessagePipeDispatcher::Create(
|
| MessagePipeDispatcher::kDefaultCreateOptions);
|
| {
|
| auto mp = MessagePipe::CreateLocalLocal();
|
| @@ -184,9 +184,9 @@ TEST(MessagePipeDispatcherTest, InvalidParams) {
|
| TEST(MessagePipeDispatcherTest, InvalidParamsDeath) {
|
| const char kMemoryCheckFailedRegex[] = "Check failed";
|
|
|
| - scoped_refptr<MessagePipeDispatcher> d0 = MessagePipeDispatcher::Create(
|
| + auto d0 = MessagePipeDispatcher::Create(
|
| MessagePipeDispatcher::kDefaultCreateOptions);
|
| - scoped_refptr<MessagePipeDispatcher> d1 = MessagePipeDispatcher::Create(
|
| + auto d1 = MessagePipeDispatcher::Create(
|
| MessagePipeDispatcher::kDefaultCreateOptions);
|
| {
|
| auto mp = MessagePipe::CreateLocalLocal();
|
| @@ -224,9 +224,9 @@ TEST(MessagePipeDispatcherTest, BasicClosed) {
|
|
|
| // Run this test both with |d0| as port 0, |d1| as port 1 and vice versa.
|
| for (unsigned i = 0; i < 2; i++) {
|
| - scoped_refptr<MessagePipeDispatcher> d0 = MessagePipeDispatcher::Create(
|
| + auto d0 = MessagePipeDispatcher::Create(
|
| MessagePipeDispatcher::kDefaultCreateOptions);
|
| - scoped_refptr<MessagePipeDispatcher> d1 = MessagePipeDispatcher::Create(
|
| + auto d1 = MessagePipeDispatcher::Create(
|
| MessagePipeDispatcher::kDefaultCreateOptions);
|
| {
|
| auto mp = MessagePipe::CreateLocalLocal();
|
| @@ -354,9 +354,9 @@ TEST(MessagePipeDispatcherTest, BasicThreaded) {
|
|
|
| // Run this test both with |d0| as port 0, |d1| as port 1 and vice versa.
|
| for (unsigned i = 0; i < 2; i++) {
|
| - scoped_refptr<MessagePipeDispatcher> d0 = MessagePipeDispatcher::Create(
|
| + auto d0 = MessagePipeDispatcher::Create(
|
| MessagePipeDispatcher::kDefaultCreateOptions);
|
| - scoped_refptr<MessagePipeDispatcher> d1 = MessagePipeDispatcher::Create(
|
| + auto d1 = MessagePipeDispatcher::Create(
|
| MessagePipeDispatcher::kDefaultCreateOptions);
|
| {
|
| auto mp = MessagePipe::CreateLocalLocal();
|
| @@ -437,9 +437,9 @@ TEST(MessagePipeDispatcherTest, BasicThreaded) {
|
| }
|
|
|
| for (unsigned i = 0; i < 2; i++) {
|
| - scoped_refptr<MessagePipeDispatcher> d0 = MessagePipeDispatcher::Create(
|
| + auto d0 = MessagePipeDispatcher::Create(
|
| MessagePipeDispatcher::kDefaultCreateOptions);
|
| - scoped_refptr<MessagePipeDispatcher> d1 = MessagePipeDispatcher::Create(
|
| + auto d1 = MessagePipeDispatcher::Create(
|
| MessagePipeDispatcher::kDefaultCreateOptions);
|
| {
|
| auto mp = MessagePipe::CreateLocalLocal();
|
| @@ -479,7 +479,7 @@ class WriterThread : public mojo::test::SimpleTestThread {
|
| public:
|
| // |*messages_written| and |*bytes_written| belong to the thread while it's
|
| // alive.
|
| - WriterThread(scoped_refptr<Dispatcher> write_dispatcher,
|
| + WriterThread(RefPtr<Dispatcher> write_dispatcher,
|
| size_t* messages_written,
|
| size_t* bytes_written)
|
| : write_dispatcher_(write_dispatcher),
|
| @@ -518,7 +518,7 @@ class WriterThread : public mojo::test::SimpleTestThread {
|
| MOJO_WRITE_MESSAGE_FLAG_NONE));
|
| }
|
|
|
| - const scoped_refptr<Dispatcher> write_dispatcher_;
|
| + const RefPtr<Dispatcher> write_dispatcher_;
|
| size_t* const messages_written_;
|
| size_t* const bytes_written_;
|
|
|
| @@ -528,7 +528,7 @@ class WriterThread : public mojo::test::SimpleTestThread {
|
| class ReaderThread : public mojo::test::SimpleTestThread {
|
| public:
|
| // |*messages_read| and |*bytes_read| belong to the thread while it's alive.
|
| - ReaderThread(scoped_refptr<Dispatcher> read_dispatcher,
|
| + ReaderThread(RefPtr<Dispatcher> read_dispatcher,
|
| size_t* messages_read,
|
| size_t* bytes_read)
|
| : read_dispatcher_(read_dispatcher),
|
| @@ -604,7 +604,7 @@ class ReaderThread : public mojo::test::SimpleTestThread {
|
| return true;
|
| }
|
|
|
| - const scoped_refptr<Dispatcher> read_dispatcher_;
|
| + const RefPtr<Dispatcher> read_dispatcher_;
|
| size_t* const messages_read_;
|
| size_t* const bytes_read_;
|
|
|
| @@ -615,9 +615,9 @@ TEST(MessagePipeDispatcherTest, Stress) {
|
| static const size_t kNumWriters = 30;
|
| static const size_t kNumReaders = kNumWriters;
|
|
|
| - scoped_refptr<MessagePipeDispatcher> d_write = MessagePipeDispatcher::Create(
|
| + auto d_write = MessagePipeDispatcher::Create(
|
| MessagePipeDispatcher::kDefaultCreateOptions);
|
| - scoped_refptr<MessagePipeDispatcher> d_read = MessagePipeDispatcher::Create(
|
| + auto d_read = MessagePipeDispatcher::Create(
|
| MessagePipeDispatcher::kDefaultCreateOptions);
|
| {
|
| auto mp = MessagePipe::CreateLocalLocal();
|
|
|