mojo/edk/system/remote_message_pipe_unittest.cc - Issue 782693004: Update mojo sdk to rev f6c8ec07c01deebc13178d516225fd12695c3dc2

Unified Diff: mojo/edk/system/remote_message_pipe_unittest.cc

Issue 782693004: Update mojo sdk to rev f6c8ec07c01deebc13178d516225fd12695c3dc2 (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master

Patch Set: hack mojo_system_impl gypi for android :| Created 6 years ago

Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.

Jump to:

View side-by-side diff with in-line comments

Download patch

Index: mojo/edk/system/remote_message_pipe_unittest.cc

diff --git a/mojo/edk/system/remote_message_pipe_unittest.cc b/mojo/edk/system/remote_message_pipe_unittest.cc

index 926ca0bf7e2aa6b1daee6ff4b4d1c2ce3da6e26d..d34602c9a382ea6dc91bf41e9a86392d24606162 100644

--- a/mojo/edk/system/remote_message_pipe_unittest.cc

+++ b/mojo/edk/system/remote_message_pipe_unittest.cc

@@ -110,11 +110,11 @@ class RemoteMessagePipeTest : public testing::Test {

void TearDownOnIOThread() {

CHECK_EQ(base::MessageLoop::current(), io_thread()->message_loop());

- if (channels_[0].get()) {

+ if (channels_[0]) {

channels_[0]->Shutdown();

channels_[0] = nullptr;

}

- if (channels_[1].get()) {

+ if (channels_[1]) {

channels_[1]->Shutdown();

channels_[1] = nullptr;

}

@@ -123,7 +123,7 @@ class RemoteMessagePipeTest : public testing::Test {

void CreateAndInitChannel(unsigned channel_index) {

CHECK_EQ(base::MessageLoop::current(), io_thread()->message_loop());

CHECK(channel_index == 0 || channel_index == 1);

- CHECK(!channels_[channel_index].get());

+ CHECK(!channels_[channel_index]);

channels_[channel_index] = new Channel(&platform_support_);

CHECK(channels_[channel_index]->Init(

@@ -134,9 +134,9 @@ class RemoteMessagePipeTest : public testing::Test {

scoped_refptr<ChannelEndpoint> ep1) {

CHECK_EQ(base::MessageLoop::current(), io_thread()->message_loop());

- if (!channels_[0].get())

+ if (!channels_[0])

CreateAndInitChannel(0);

- if (!channels_[1].get())

+ if (!channels_[1])

CreateAndInitChannel(1);

channels_[0]->AttachAndRunEndpoint(ep0, true);

@@ -193,7 +193,7 @@ TEST_F(RemoteMessagePipeTest, Basic) {

waiter.Init();

ASSERT_EQ(

MOJO_RESULT_OK,

- mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

+ mp1->AddAwakable(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

// Write to MP 0, port 0.

EXPECT_EQ(

@@ -205,7 +205,7 @@ TEST_F(RemoteMessagePipeTest, Basic) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(123u, context);

hss = HandleSignalsState();

- mp1->RemoveWaiter(1, &waiter, &hss);

+ mp1->RemoveAwakable(1, &waiter, &hss);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,

hss.satisfied_signals);

EXPECT_EQ(kAllSignals, hss.satisfiable_signals);

@@ -223,7 +223,7 @@ TEST_F(RemoteMessagePipeTest, Basic) {

waiter.Init();

ASSERT_EQ(

MOJO_RESULT_OK,

- mp0->AddWaiter(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 456, nullptr));

+ mp0->AddAwakable(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 456, nullptr));

EXPECT_EQ(

MOJO_RESULT_OK,

@@ -233,7 +233,7 @@ TEST_F(RemoteMessagePipeTest, Basic) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(456u, context);

hss = HandleSignalsState();

- mp0->RemoveWaiter(0, &waiter, &hss);

+ mp0->RemoveAwakable(0, &waiter, &hss);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,

hss.satisfied_signals);

EXPECT_EQ(kAllSignals, hss.satisfiable_signals);

@@ -255,13 +255,13 @@ TEST_F(RemoteMessagePipeTest, Basic) {

waiter.Init();

hss = HandleSignalsState();

MojoResult result =

- mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 789, &hss);

+ mp1->AddAwakable(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 789, &hss);

if (result == MOJO_RESULT_OK) {

EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION,

waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(789u, context);

hss = HandleSignalsState();

- mp1->RemoveWaiter(1, &waiter, &hss);

+ mp1->RemoveAwakable(1, &waiter, &hss);

}

EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, hss.satisfied_signals);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, hss.satisfiable_signals);

@@ -292,12 +292,12 @@ TEST_F(RemoteMessagePipeTest, PeerClosed) {

waiter.Init();

hss = HandleSignalsState();

MojoResult result =

- mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_PEER_CLOSED, 101, &hss);

+ mp1->AddAwakable(1, &waiter, MOJO_HANDLE_SIGNAL_PEER_CLOSED, 101, &hss);

if (result == MOJO_RESULT_OK) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(101u, context);

hss = HandleSignalsState();

- mp1->RemoveWaiter(1, &waiter, &hss);

+ mp1->RemoveAwakable(1, &waiter, &hss);

}

EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, hss.satisfied_signals);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, hss.satisfiable_signals);

@@ -339,7 +339,7 @@ TEST_F(RemoteMessagePipeTest, Multiplex) {

waiter.Init();

ASSERT_EQ(

MOJO_RESULT_OK,

- mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

+ mp1->AddAwakable(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

EXPECT_EQ(MOJO_RESULT_OK,

mp0->WriteMessage(0, UserPointer<const void>(&remote_id),

@@ -349,7 +349,7 @@ TEST_F(RemoteMessagePipeTest, Multiplex) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(123u, context);

hss = HandleSignalsState();

- mp1->RemoveWaiter(1, &waiter, &hss);

+ mp1->RemoveAwakable(1, &waiter, &hss);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,

hss.satisfied_signals);

EXPECT_EQ(kAllSignals, hss.satisfiable_signals);

@@ -366,14 +366,14 @@ TEST_F(RemoteMessagePipeTest, Multiplex) {

// Warning: The local side of mp3 is port 0, not port 1.

scoped_refptr<MessagePipe> mp3 =

channels(1)->PassIncomingMessagePipe(received_id);

- ASSERT_TRUE(mp3.get());

+ ASSERT_TRUE(mp3);

// Write: MP 2, port 0 -> MP 3, port 1.

waiter.Init();

ASSERT_EQ(

MOJO_RESULT_OK,

- mp3->AddWaiter(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 789, nullptr));

+ mp3->AddAwakable(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 789, nullptr));

EXPECT_EQ(

MOJO_RESULT_OK,

@@ -383,7 +383,7 @@ TEST_F(RemoteMessagePipeTest, Multiplex) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(789u, context);

hss = HandleSignalsState();

- mp3->RemoveWaiter(0, &waiter, &hss);

+ mp3->RemoveAwakable(0, &waiter, &hss);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,

hss.satisfied_signals);

EXPECT_EQ(kAllSignals, hss.satisfiable_signals);

@@ -419,7 +419,7 @@ TEST_F(RemoteMessagePipeTest, Multiplex) {

waiter.Init();

ASSERT_EQ(

MOJO_RESULT_OK,

- mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

+ mp1->AddAwakable(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

EXPECT_EQ(

MOJO_RESULT_OK,

@@ -429,7 +429,7 @@ TEST_F(RemoteMessagePipeTest, Multiplex) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(123u, context);

hss = HandleSignalsState();

- mp1->RemoveWaiter(1, &waiter, &hss);

+ mp1->RemoveAwakable(1, &waiter, &hss);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,

hss.satisfied_signals);

EXPECT_EQ(kAllSignals | MOJO_HANDLE_SIGNAL_PEER_CLOSED,

@@ -500,7 +500,7 @@ TEST_F(RemoteMessagePipeTest, CloseBeforeAttachAndRun) {

waiter.Init();

ASSERT_EQ(

MOJO_RESULT_OK,

- mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

+ mp1->AddAwakable(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

BootstrapChannelEndpointNoWait(1, ep1);

@@ -512,7 +512,7 @@ TEST_F(RemoteMessagePipeTest, CloseBeforeAttachAndRun) {

// not appear as writable (there's a race, and it may not have noticed that

// the other side was closed yet -- e.g., inserting a sleep here would make it

// much more likely to notice that it's no longer writable).

- mp1->RemoveWaiter(1, &waiter, &hss);

+ mp1->RemoveAwakable(1, &waiter, &hss);

EXPECT_TRUE((hss.satisfied_signals & MOJO_HANDLE_SIGNAL_READABLE));

EXPECT_TRUE((hss.satisfiable_signals & MOJO_HANDLE_SIGNAL_READABLE));

@@ -562,7 +562,7 @@ TEST_F(RemoteMessagePipeTest, CloseBeforeConnect) {

waiter.Init();

ASSERT_EQ(

MOJO_RESULT_OK,

- mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

+ mp1->AddAwakable(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

BootstrapChannelEndpointNoWait(1, ep1);

@@ -574,7 +574,7 @@ TEST_F(RemoteMessagePipeTest, CloseBeforeConnect) {

// not appear as writable (there's a race, and it may not have noticed that

// the other side was closed yet -- e.g., inserting a sleep here would make it

// much more likely to notice that it's no longer writable).

- mp1->RemoveWaiter(1, &waiter, &hss);

+ mp1->RemoveAwakable(1, &waiter, &hss);

EXPECT_TRUE((hss.satisfied_signals & MOJO_HANDLE_SIGNAL_READABLE));

EXPECT_TRUE((hss.satisfiable_signals & MOJO_HANDLE_SIGNAL_READABLE));

@@ -613,7 +613,7 @@ TEST_F(RemoteMessagePipeTest, HandlePassing) {

waiter.Init();

ASSERT_EQ(

MOJO_RESULT_OK,

- mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

+ mp1->AddAwakable(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

// Write to MP 0, port 0.

{

@@ -639,7 +639,7 @@ TEST_F(RemoteMessagePipeTest, HandlePassing) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(123u, context);

hss = HandleSignalsState();

- mp1->RemoveWaiter(1, &waiter, &hss);

+ mp1->RemoveAwakable(1, &waiter, &hss);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,

hss.satisfied_signals);

EXPECT_EQ(kAllSignals, hss.satisfiable_signals);

@@ -658,7 +658,7 @@ TEST_F(RemoteMessagePipeTest, HandlePassing) {

EXPECT_STREQ(kHello, read_buffer);

EXPECT_EQ(1u, read_dispatchers.size());

EXPECT_EQ(1u, read_num_dispatchers);

- ASSERT_TRUE(read_dispatchers[0].get());

+ ASSERT_TRUE(read_dispatchers[0]);

EXPECT_TRUE(read_dispatchers[0]->HasOneRef());

EXPECT_EQ(Dispatcher::kTypeMessagePipe, read_dispatchers[0]->GetType());

@@ -667,8 +667,8 @@ TEST_F(RemoteMessagePipeTest, HandlePassing) {

// Add the waiter now, before it becomes readable to avoid a race.

waiter.Init();

ASSERT_EQ(MOJO_RESULT_OK,

- dispatcher->AddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 456,

- nullptr));

+ dispatcher->AddAwakable(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 456,

+ nullptr));

// Write to "local_mp", port 1.

EXPECT_EQ(

@@ -683,7 +683,7 @@ TEST_F(RemoteMessagePipeTest, HandlePassing) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(456u, context);

hss = HandleSignalsState();

- dispatcher->RemoveWaiter(&waiter, &hss);

+ dispatcher->RemoveAwakable(&waiter, &hss);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,

hss.satisfied_signals);

EXPECT_EQ(kAllSignals, hss.satisfiable_signals);

@@ -701,8 +701,8 @@ TEST_F(RemoteMessagePipeTest, HandlePassing) {

// Prepare to wait on "local_mp", port 1.

waiter.Init();

ASSERT_EQ(MOJO_RESULT_OK,

- local_mp->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 789,

- nullptr));

+ local_mp->AddAwakable(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 789,

+ nullptr));

// Write to the dispatcher.

EXPECT_EQ(MOJO_RESULT_OK, dispatcher->WriteMessage(

@@ -713,7 +713,7 @@ TEST_F(RemoteMessagePipeTest, HandlePassing) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(789u, context);

hss = HandleSignalsState();

- local_mp->RemoveWaiter(1, &waiter, &hss);

+ local_mp->RemoveAwakable(1, &waiter, &hss);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,

hss.satisfied_signals);

EXPECT_EQ(kAllSignals, hss.satisfiable_signals);

@@ -787,7 +787,7 @@ TEST_F(RemoteMessagePipeTest, HandlePassingHalfClosed) {

waiter.Init();

ASSERT_EQ(

MOJO_RESULT_OK,

- mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

+ mp1->AddAwakable(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

// Write to MP 0, port 0.

{

@@ -813,7 +813,7 @@ TEST_F(RemoteMessagePipeTest, HandlePassingHalfClosed) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(123u, context);

hss = HandleSignalsState();

- mp1->RemoveWaiter(1, &waiter, &hss);

+ mp1->RemoveAwakable(1, &waiter, &hss);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,

hss.satisfied_signals);

EXPECT_EQ(kAllSignals, hss.satisfiable_signals);

@@ -832,7 +832,7 @@ TEST_F(RemoteMessagePipeTest, HandlePassingHalfClosed) {

EXPECT_STREQ(kHello, read_buffer);

EXPECT_EQ(1u, read_dispatchers.size());

EXPECT_EQ(1u, read_num_dispatchers);

- ASSERT_TRUE(read_dispatchers[0].get());

+ ASSERT_TRUE(read_dispatchers[0]);

EXPECT_TRUE(read_dispatchers[0]->HasOneRef());

EXPECT_EQ(Dispatcher::kTypeMessagePipe, read_dispatchers[0]->GetType());

@@ -903,7 +903,7 @@ TEST_F(RemoteMessagePipeTest, MAYBE_SharedBufferPassing) {

platform_support(),

SharedBufferDispatcher::kDefaultCreateOptions,

100, &dispatcher));

- ASSERT_TRUE(dispatcher.get());

+ ASSERT_TRUE(dispatcher);

// Make a mapping.

scoped_ptr<embedder::PlatformSharedBufferMapping> mapping0;

@@ -921,7 +921,7 @@ TEST_F(RemoteMessagePipeTest, MAYBE_SharedBufferPassing) {

waiter.Init();

ASSERT_EQ(

MOJO_RESULT_OK,

- mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

+ mp1->AddAwakable(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

// Write to MP 0, port 0.

{

@@ -947,7 +947,7 @@ TEST_F(RemoteMessagePipeTest, MAYBE_SharedBufferPassing) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(123u, context);

hss = HandleSignalsState();

- mp1->RemoveWaiter(1, &waiter, &hss);

+ mp1->RemoveAwakable(1, &waiter, &hss);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,

hss.satisfied_signals);

EXPECT_EQ(kAllSignals, hss.satisfiable_signals);

@@ -966,7 +966,7 @@ TEST_F(RemoteMessagePipeTest, MAYBE_SharedBufferPassing) {

EXPECT_STREQ(kHello, read_buffer);

EXPECT_EQ(1u, read_dispatchers.size());

EXPECT_EQ(1u, read_num_dispatchers);

- ASSERT_TRUE(read_dispatchers[0].get());

+ ASSERT_TRUE(read_dispatchers[0]);

EXPECT_TRUE(read_dispatchers[0]->HasOneRef());

EXPECT_EQ(Dispatcher::kTypeSharedBuffer, read_dispatchers[0]->GetType());

@@ -1040,7 +1040,7 @@ TEST_F(RemoteMessagePipeTest, MAYBE_PlatformHandlePassing) {

waiter.Init();

ASSERT_EQ(

MOJO_RESULT_OK,

- mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

+ mp1->AddAwakable(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

// Write to MP 0, port 0.

{

@@ -1066,7 +1066,7 @@ TEST_F(RemoteMessagePipeTest, MAYBE_PlatformHandlePassing) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(123u, context);

hss = HandleSignalsState();

- mp1->RemoveWaiter(1, &waiter, &hss);

+ mp1->RemoveAwakable(1, &waiter, &hss);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,

hss.satisfied_signals);

EXPECT_EQ(kAllSignals, hss.satisfiable_signals);

@@ -1085,7 +1085,7 @@ TEST_F(RemoteMessagePipeTest, MAYBE_PlatformHandlePassing) {

EXPECT_STREQ(kWorld, read_buffer);

EXPECT_EQ(1u, read_dispatchers.size());

EXPECT_EQ(1u, read_num_dispatchers);

- ASSERT_TRUE(read_dispatchers[0].get());

+ ASSERT_TRUE(read_dispatchers[0]);

EXPECT_TRUE(read_dispatchers[0]->HasOneRef());

EXPECT_EQ(Dispatcher::kTypePlatformHandle, read_dispatchers[0]->GetType());

@@ -1177,7 +1177,7 @@ TEST_F(RemoteMessagePipeTest, PassMessagePipeHandleAcrossAndBack) {

waiter.Init();

ASSERT_EQ(

MOJO_RESULT_OK,

- mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

+ mp1->AddAwakable(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));

// Write to MP 0, port 0.

{

@@ -1203,7 +1203,7 @@ TEST_F(RemoteMessagePipeTest, PassMessagePipeHandleAcrossAndBack) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(123u, context);

hss = HandleSignalsState();

- mp1->RemoveWaiter(1, &waiter, &hss);

+ mp1->RemoveAwakable(1, &waiter, &hss);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,

hss.satisfied_signals);

EXPECT_EQ(kAllSignals, hss.satisfiable_signals);

@@ -1222,7 +1222,7 @@ TEST_F(RemoteMessagePipeTest, PassMessagePipeHandleAcrossAndBack) {

EXPECT_STREQ(kHello, read_buffer);

EXPECT_EQ(1u, read_dispatchers.size());

EXPECT_EQ(1u, read_num_dispatchers);

- ASSERT_TRUE(read_dispatchers[0].get());

+ ASSERT_TRUE(read_dispatchers[0]);

EXPECT_TRUE(read_dispatchers[0]->HasOneRef());

EXPECT_EQ(Dispatcher::kTypeMessagePipe, read_dispatchers[0]->GetType());

@@ -1236,7 +1236,7 @@ TEST_F(RemoteMessagePipeTest, PassMessagePipeHandleAcrossAndBack) {

waiter.Init();

ASSERT_EQ(

MOJO_RESULT_OK,

- mp0->AddWaiter(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 456, nullptr));

+ mp0->AddAwakable(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 456, nullptr));

// Write to MP 1, port 1.

{

@@ -1262,7 +1262,7 @@ TEST_F(RemoteMessagePipeTest, PassMessagePipeHandleAcrossAndBack) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(456u, context);

hss = HandleSignalsState();

- mp0->RemoveWaiter(0, &waiter, &hss);

+ mp0->RemoveAwakable(0, &waiter, &hss);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,

hss.satisfied_signals);

EXPECT_EQ(kAllSignals, hss.satisfiable_signals);

@@ -1279,7 +1279,7 @@ TEST_F(RemoteMessagePipeTest, PassMessagePipeHandleAcrossAndBack) {

EXPECT_STREQ(kWorld, read_buffer);

EXPECT_EQ(1u, read_dispatchers.size());

EXPECT_EQ(1u, read_num_dispatchers);

- ASSERT_TRUE(read_dispatchers[0].get());

+ ASSERT_TRUE(read_dispatchers[0]);

EXPECT_TRUE(read_dispatchers[0]->HasOneRef());

EXPECT_EQ(Dispatcher::kTypeMessagePipe, read_dispatchers[0]->GetType());

@@ -1289,8 +1289,8 @@ TEST_F(RemoteMessagePipeTest, PassMessagePipeHandleAcrossAndBack) {

// Add the waiter now, before it becomes readable to avoid a race.

waiter.Init();

ASSERT_EQ(MOJO_RESULT_OK,

- dispatcher->AddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 789,

- nullptr));

+ dispatcher->AddAwakable(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 789,

+ nullptr));

// Write to "local_mp", port 1.

EXPECT_EQ(

@@ -1302,7 +1302,7 @@ TEST_F(RemoteMessagePipeTest, PassMessagePipeHandleAcrossAndBack) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(789u, context);

hss = HandleSignalsState();

- dispatcher->RemoveWaiter(&waiter, &hss);

+ dispatcher->RemoveAwakable(&waiter, &hss);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,

hss.satisfied_signals);

EXPECT_EQ(kAllSignals, hss.satisfiable_signals);

@@ -1320,8 +1320,8 @@ TEST_F(RemoteMessagePipeTest, PassMessagePipeHandleAcrossAndBack) {

// Prepare to wait on "local_mp", port 1.

waiter.Init();

ASSERT_EQ(MOJO_RESULT_OK,

- local_mp->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 789,

- nullptr));

+ local_mp->AddAwakable(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 789,

+ nullptr));

// Write to the dispatcher.

EXPECT_EQ(MOJO_RESULT_OK, dispatcher->WriteMessage(

@@ -1332,7 +1332,7 @@ TEST_F(RemoteMessagePipeTest, PassMessagePipeHandleAcrossAndBack) {

EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));

EXPECT_EQ(789u, context);

hss = HandleSignalsState();

- local_mp->RemoveWaiter(1, &waiter, &hss);

+ local_mp->RemoveAwakable(1, &waiter, &hss);

EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,

hss.satisfied_signals);

EXPECT_EQ(kAllSignals, hss.satisfiable_signals);

« mojo/edk/mojo_edk_system_impl.gypi ('K') | « mojo/edk/system/proxy_message_pipe_endpoint.cc ('k') | mojo/edk/system/shared_buffer_dispatcher.cc » ('j') | no next file with comments »