Index: mojo/public/c/system/tests/core_unittest.cc |
diff --git a/mojo/public/c/system/tests/core_unittest.cc b/mojo/public/c/system/tests/core_unittest.cc |
index ada99d4b73aa329014e99f5cc6cfa3888ad4347b..8a5438079a3589300e6bf05fb4a2113b9fbbd242 100644 |
--- a/mojo/public/c/system/tests/core_unittest.cc |
+++ b/mojo/public/c/system/tests/core_unittest.cc |
@@ -41,9 +41,9 @@ |
EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, MojoClose(MOJO_HANDLE_INVALID)); |
// Wait: |
- EXPECT_EQ( |
- MOJO_RESULT_INVALID_ARGUMENT, |
- MojoWait(MOJO_HANDLE_INVALID, ~MOJO_HANDLE_SIGNAL_NONE, 0, nullptr)); |
+ EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
+ MojoWait(MOJO_HANDLE_INVALID, ~MOJO_HANDLE_SIGNAL_NONE, 1000000, |
+ nullptr)); |
h0 = MOJO_HANDLE_INVALID; |
sig = ~MOJO_HANDLE_SIGNAL_NONE; |
@@ -98,9 +98,16 @@ |
EXPECT_NE(h0, MOJO_HANDLE_INVALID); |
EXPECT_NE(h1, MOJO_HANDLE_INVALID); |
- // Shouldn't be readable, we haven't written anything. Should be writable. |
+ // Shouldn't be readable, we haven't written anything. |
MojoHandleSignalsState state; |
- EXPECT_EQ(MOJO_RESULT_OK, MojoQueryHandleSignalsState(h0, &state)); |
+ EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, |
+ MojoWait(h0, MOJO_HANDLE_SIGNAL_READABLE, 0, &state)); |
+ EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, state.satisfied_signals); |
+ EXPECT_EQ(kSignalAll, state.satisfiable_signals); |
+ |
+ // Should be writable. |
+ EXPECT_EQ(MOJO_RESULT_OK, |
+ MojoWait(h0, MOJO_HANDLE_SIGNAL_WRITABLE, 0, &state)); |
EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, state.satisfied_signals); |
EXPECT_EQ(kSignalAll, state.satisfiable_signals); |
@@ -140,7 +147,9 @@ |
EXPECT_STREQ(kHello, buffer); |
// |h0| should no longer be readable. |
- EXPECT_EQ(MOJO_RESULT_OK, MojoQueryHandleSignalsState(h0, &state)); |
+ EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, |
+ MojoWait(h0, MOJO_HANDLE_SIGNAL_READABLE, 10, &state)); |
+ |
EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, state.satisfied_signals); |
EXPECT_EQ(kSignalAll, state.satisfiable_signals); |
@@ -155,7 +164,7 @@ |
EXPECT_EQ( |
MOJO_RESULT_FAILED_PRECONDITION, |
MojoWait(h1, MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
- MOJO_DEADLINE_INDEFINITE, &state)); |
+ 1000, &state)); |
EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, state.satisfied_signals); |
EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, state.satisfiable_signals); |
@@ -179,14 +188,18 @@ |
// The consumer |hc| shouldn't be readable. |
MojoHandleSignalsState state; |
- EXPECT_EQ(MOJO_RESULT_OK, MojoQueryHandleSignalsState(hc, &state)); |
+ EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, |
+ MojoWait(hc, MOJO_HANDLE_SIGNAL_READABLE, 0, &state)); |
+ |
EXPECT_EQ(MOJO_HANDLE_SIGNAL_NONE, state.satisfied_signals); |
EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_PEER_CLOSED | |
MOJO_HANDLE_SIGNAL_NEW_DATA_READABLE, |
state.satisfiable_signals); |
// The producer |hp| should be writable. |
- EXPECT_EQ(MOJO_RESULT_OK, MojoQueryHandleSignalsState(hp, &state)); |
+ EXPECT_EQ(MOJO_RESULT_OK, |
+ MojoWait(hp, MOJO_HANDLE_SIGNAL_WRITABLE, 0, &state)); |
+ |
EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, state.satisfied_signals); |
EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE | MOJO_HANDLE_SIGNAL_PEER_CLOSED, |
state.satisfiable_signals); |
@@ -263,8 +276,7 @@ |
// |hc| should no longer be readable. |
EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
- MojoWait(hc, MOJO_HANDLE_SIGNAL_READABLE, MOJO_DEADLINE_INDEFINITE, |
- &state)); |
+ MojoWait(hc, MOJO_HANDLE_SIGNAL_READABLE, 1000, &state)); |
EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, state.satisfied_signals); |
EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, state.satisfiable_signals); |