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 0ad52ad8cfcca67413c11d97925d2e3381559df3..071a902ed0fa7854da5f2e4366cdda2e69ca63b0 100644 |
--- a/mojo/public/c/system/tests/core_unittest.cc |
+++ b/mojo/public/c/system/tests/core_unittest.cc |
@@ -230,8 +230,10 @@ TEST(CoreTest, MAYBE_BasicDataPipe) { |
// The producer |hp| should be writable. |
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, |
+ EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE | MOJO_HANDLE_SIGNAL_WRITE_THRESHOLD, |
+ state.satisfied_signals); |
+ EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE | MOJO_HANDLE_SIGNAL_PEER_CLOSED | |
+ MOJO_HANDLE_SIGNAL_WRITE_THRESHOLD, |
state.satisfiable_signals); |
// Try to read from |hc|. |
@@ -315,12 +317,15 @@ TEST(CoreTest, MAYBE_BasicDataPipe) { |
// the producer never-writable? |
} |
+// TODO(vtl): Once thunks are in: TEST(CoreTest, DataPipeWriteThreshold) { ... } |
+ |
TEST(CoreTest, DataPipeReadThreshold) { |
MojoHandle hp = MOJO_HANDLE_INVALID; |
MojoHandle hc = MOJO_HANDLE_INVALID; |
EXPECT_EQ(MOJO_RESULT_OK, MojoCreateDataPipe(nullptr, &hp, &hc)); |
EXPECT_NE(hp, MOJO_HANDLE_INVALID); |
EXPECT_NE(hc, MOJO_HANDLE_INVALID); |
+ EXPECT_NE(hc, hp); |
MojoDataPipeConsumerOptions copts; |
static const uint32_t kCoptsSize = static_cast<uint32_t>(sizeof(copts)); |