| Index: mojo/system/multiprocess_message_pipe_unittest.cc
|
| diff --git a/mojo/system/multiprocess_message_pipe_unittest.cc b/mojo/system/multiprocess_message_pipe_unittest.cc
|
| index a27a40c2b5efc8da97404e421f5fa1dbf26bb553..55527788c134a43b804d225943cffc5722b20711 100644
|
| --- a/mojo/system/multiprocess_message_pipe_unittest.cc
|
| +++ b/mojo/system/multiprocess_message_pipe_unittest.cc
|
| @@ -159,7 +159,7 @@ MOJO_MULTIPROCESS_TEST_CHILD_MAIN(EchoEcho) {
|
| int rv = 0;
|
| for (;; rv = (rv + 1) % 100) {
|
| // Wait for our end of the message pipe to be readable.
|
| - MojoResult result = WaitIfNecessary(mp, MOJO_WAIT_FLAG_READABLE);
|
| + MojoResult result = WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE);
|
| if (result != MOJO_RESULT_OK) {
|
| // It was closed, probably.
|
| CHECK_EQ(result, MOJO_RESULT_FAILED_PRECONDITION);
|
| @@ -210,7 +210,7 @@ TEST_F(MultiprocessMessagePipeTest, Basic) {
|
| NULL,
|
| MOJO_WRITE_MESSAGE_FLAG_NONE));
|
|
|
| - EXPECT_EQ(MOJO_RESULT_OK, WaitIfNecessary(mp, MOJO_WAIT_FLAG_READABLE));
|
| + EXPECT_EQ(MOJO_RESULT_OK, WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE));
|
|
|
| std::string read_buffer(1000, '\0');
|
| uint32_t read_buffer_size = static_cast<uint32_t>(read_buffer.size());
|
| @@ -259,7 +259,7 @@ TEST_F(MultiprocessMessagePipeTest, QueueMessages) {
|
| MOJO_WRITE_MESSAGE_FLAG_NONE));
|
|
|
| for (size_t i = 0; i < kNumMessages; i++) {
|
| - EXPECT_EQ(MOJO_RESULT_OK, WaitIfNecessary(mp, MOJO_WAIT_FLAG_READABLE));
|
| + EXPECT_EQ(MOJO_RESULT_OK, WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE));
|
|
|
| std::string read_buffer(kNumMessages * 2, '\0');
|
| uint32_t read_buffer_size = static_cast<uint32_t>(read_buffer.size());
|
| @@ -276,7 +276,7 @@ TEST_F(MultiprocessMessagePipeTest, QueueMessages) {
|
| // Wait for it to become readable, which should fail (since we sent
|
| // "quitquitquit").
|
| EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION,
|
| - WaitIfNecessary(mp, MOJO_WAIT_FLAG_READABLE));
|
| + WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE));
|
|
|
| mp->Close(0);
|
|
|
| @@ -295,7 +295,7 @@ MOJO_MULTIPROCESS_TEST_CHILD_MAIN(CheckSharedBuffer) {
|
| channel_thread.Start(client_platform_handle.Pass(), mp);
|
|
|
| // Wait for the first message from our parent.
|
| - CHECK_EQ(WaitIfNecessary(mp, MOJO_WAIT_FLAG_READABLE), MOJO_RESULT_OK);
|
| + CHECK_EQ(WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE), MOJO_RESULT_OK);
|
|
|
| // It should have a shared buffer.
|
| std::string read_buffer(100, '\0');
|
| @@ -341,7 +341,7 @@ MOJO_MULTIPROCESS_TEST_CHILD_MAIN(CheckSharedBuffer) {
|
| MOJO_RESULT_OK);
|
|
|
| // Now wait for our parent to send us a message.
|
| - CHECK_EQ(WaitIfNecessary(mp, MOJO_WAIT_FLAG_READABLE), MOJO_RESULT_OK);
|
| + CHECK_EQ(WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE), MOJO_RESULT_OK);
|
|
|
| read_buffer = std::string(100, '\0');
|
| num_bytes = static_cast<uint32_t>(read_buffer.size());
|
| @@ -413,7 +413,7 @@ TEST_F(MultiprocessMessagePipeTest, MAYBE_SharedBufferPassing) {
|
| dispatcher = NULL;
|
|
|
| // Wait for a message from the child.
|
| - EXPECT_EQ(MOJO_RESULT_OK, WaitIfNecessary(mp, MOJO_WAIT_FLAG_READABLE));
|
| + EXPECT_EQ(MOJO_RESULT_OK, WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE));
|
|
|
| std::string read_buffer(100, '\0');
|
| uint32_t num_bytes = static_cast<uint32_t>(read_buffer.size());
|
| @@ -445,7 +445,7 @@ TEST_F(MultiprocessMessagePipeTest, MAYBE_SharedBufferPassing) {
|
|
|
| // Wait for |mp| to become readable, which should fail.
|
| EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION,
|
| - WaitIfNecessary(mp, MOJO_WAIT_FLAG_READABLE));
|
| + WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE));
|
|
|
| mp->Close(0);
|
|
|
| @@ -462,7 +462,7 @@ MOJO_MULTIPROCESS_TEST_CHILD_MAIN(CheckPlatformHandleFile) {
|
| scoped_ptr<MessagePipeEndpoint>(new ProxyMessagePipeEndpoint())));
|
| channel_thread.Start(client_platform_handle.Pass(), mp);
|
|
|
| - CHECK_EQ(WaitIfNecessary(mp, MOJO_WAIT_FLAG_READABLE), MOJO_RESULT_OK);
|
| + CHECK_EQ(WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE), MOJO_RESULT_OK);
|
|
|
| std::string read_buffer(100, '\0');
|
| uint32_t num_bytes = static_cast<uint32_t>(read_buffer.size());
|
| @@ -543,7 +543,7 @@ TEST_F(MultiprocessMessagePipeTest, MAYBE_PlatformHandlePassing) {
|
|
|
| // Wait for it to become readable, which should fail.
|
| EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION,
|
| - WaitIfNecessary(mp, MOJO_WAIT_FLAG_READABLE));
|
| + WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE));
|
|
|
| mp->Close(0);
|
|
|
|
|