| Index: mojo/system/message_pipe_unittest.cc
|
| diff --git a/mojo/system/message_pipe_unittest.cc b/mojo/system/message_pipe_unittest.cc
|
| index 73c310fab1096b0beb2936c78433be519537f515..5405fd52441ce368c101cb100d113b2bb023856d 100644
|
| --- a/mojo/system/message_pipe_unittest.cc
|
| +++ b/mojo/system/message_pipe_unittest.cc
|
| @@ -366,18 +366,19 @@ TEST(MessagePipeTest, BasicWaiting) {
|
| // Always writable (until the other port is closed).
|
| waiter.Init();
|
| EXPECT_EQ(MOJO_RESULT_ALREADY_EXISTS,
|
| - mp->AddWaiter(0, &waiter, MOJO_WAIT_FLAG_WRITABLE, 0));
|
| + mp->AddWaiter(0, &waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 0));
|
| waiter.Init();
|
| EXPECT_EQ(MOJO_RESULT_ALREADY_EXISTS,
|
| mp->AddWaiter(0,
|
| &waiter,
|
| - MOJO_WAIT_FLAG_READABLE | MOJO_WAIT_FLAG_WRITABLE,
|
| + MOJO_HANDLE_SIGNAL_READABLE |
|
| + MOJO_HANDLE_SIGNAL_WRITABLE,
|
| 0));
|
|
|
| // Not yet readable.
|
| waiter.Init();
|
| EXPECT_EQ(MOJO_RESULT_OK,
|
| - mp->AddWaiter(0, &waiter, MOJO_WAIT_FLAG_READABLE, 1));
|
| + mp->AddWaiter(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 1));
|
| EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, NULL));
|
| mp->RemoveWaiter(0, &waiter);
|
|
|
| @@ -392,17 +393,18 @@ TEST(MessagePipeTest, BasicWaiting) {
|
| // Port 1 should already be readable now.
|
| waiter.Init();
|
| EXPECT_EQ(MOJO_RESULT_ALREADY_EXISTS,
|
| - mp->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_READABLE, 2));
|
| + mp->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 2));
|
| waiter.Init();
|
| EXPECT_EQ(MOJO_RESULT_ALREADY_EXISTS,
|
| mp->AddWaiter(1,
|
| &waiter,
|
| - MOJO_WAIT_FLAG_READABLE | MOJO_WAIT_FLAG_WRITABLE,
|
| + MOJO_HANDLE_SIGNAL_READABLE |
|
| + MOJO_HANDLE_SIGNAL_WRITABLE,
|
| 0));
|
| // ... and still writable.
|
| waiter.Init();
|
| EXPECT_EQ(MOJO_RESULT_ALREADY_EXISTS,
|
| - mp->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_WRITABLE, 3));
|
| + mp->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 3));
|
|
|
| // Close port 0.
|
| mp->Close(0);
|
| @@ -410,12 +412,12 @@ TEST(MessagePipeTest, BasicWaiting) {
|
| // Now port 1 should not be writable.
|
| waiter.Init();
|
| EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION,
|
| - mp->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_WRITABLE, 4));
|
| + mp->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 4));
|
|
|
| // But it should still be readable.
|
| waiter.Init();
|
| EXPECT_EQ(MOJO_RESULT_ALREADY_EXISTS,
|
| - mp->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_READABLE, 5));
|
| + mp->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 5));
|
|
|
| // Read from port 1.
|
| buffer[0] = 0;
|
| @@ -430,7 +432,7 @@ TEST(MessagePipeTest, BasicWaiting) {
|
| // Now port 1 should no longer be readable.
|
| waiter.Init();
|
| EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION,
|
| - mp->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_READABLE, 6));
|
| + mp->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 6));
|
|
|
| mp->Close(1);
|
| }
|
| @@ -449,7 +451,8 @@ TEST(MessagePipeTest, ThreadedWaiting) {
|
|
|
| thread.waiter()->Init();
|
| EXPECT_EQ(MOJO_RESULT_OK,
|
| - mp->AddWaiter(1, thread.waiter(), MOJO_WAIT_FLAG_READABLE, 1));
|
| + mp->AddWaiter(1, thread.waiter(), MOJO_HANDLE_SIGNAL_READABLE,
|
| + 1));
|
| thread.Start();
|
|
|
| buffer[0] = 123456789;
|
| @@ -476,7 +479,8 @@ TEST(MessagePipeTest, ThreadedWaiting) {
|
|
|
| thread.waiter()->Init();
|
| EXPECT_EQ(MOJO_RESULT_OK,
|
| - mp->AddWaiter(1, thread.waiter(), MOJO_WAIT_FLAG_READABLE, 2));
|
| + mp->AddWaiter(1, thread.waiter(), MOJO_HANDLE_SIGNAL_READABLE,
|
| + 2));
|
| thread.Start();
|
|
|
| // Close port 1 first -- this should result in the waiter being cancelled.
|
| @@ -498,7 +502,8 @@ TEST(MessagePipeTest, ThreadedWaiting) {
|
|
|
| thread.waiter()->Init();
|
| EXPECT_EQ(MOJO_RESULT_OK,
|
| - mp->AddWaiter(1, thread.waiter(), MOJO_WAIT_FLAG_READABLE, 3));
|
| + mp->AddWaiter(1, thread.waiter(), MOJO_HANDLE_SIGNAL_READABLE,
|
| + 3));
|
| thread.Start();
|
|
|
| // Close port 0 first -- this should wake the waiter up, since port 1 will
|
|
|