| Index: mojo/system/data_pipe.cc
|
| diff --git a/mojo/system/data_pipe.cc b/mojo/system/data_pipe.cc
|
| index 80cd44c3ee3820c9402ab9292799d49ad1af01fe..ed0536ae4e3ae71ae9c6cb29690f5abce9238115 100644
|
| --- a/mojo/system/data_pipe.cc
|
| +++ b/mojo/system/data_pipe.cc
|
| @@ -168,7 +168,7 @@ MojoResult DataPipe::ProducerEndWriteData(uint32_t num_bytes_written) {
|
| // If we're now writable, we *became* writable (since we weren't writable
|
| // during the two-phase write), so awake producer waiters.
|
| WaitFlagsState new_producer_state = ProducerGetWaitFlagsStateNoLock();
|
| - if (new_producer_state.satisfies(MOJO_WAIT_FLAG_WRITABLE))
|
| + if (new_producer_state.satisfies(MOJO_HANDLE_SIGNAL_WRITABLE))
|
| AwakeProducerWaitersForStateChangeNoLock(new_producer_state);
|
| WaitFlagsState new_consumer_state = ConsumerGetWaitFlagsStateNoLock();
|
| if (!new_consumer_state.equals(old_consumer_state))
|
| @@ -320,7 +320,7 @@ MojoResult DataPipe::ConsumerEndReadData(uint32_t num_bytes_read) {
|
| // If we're now readable, we *became* readable (since we weren't readable
|
| // during the two-phase read), so awake consumer waiters.
|
| WaitFlagsState new_consumer_state = ConsumerGetWaitFlagsStateNoLock();
|
| - if (new_consumer_state.satisfies(MOJO_WAIT_FLAG_READABLE))
|
| + if (new_consumer_state.satisfies(MOJO_HANDLE_SIGNAL_READABLE))
|
| AwakeConsumerWaitersForStateChangeNoLock(new_consumer_state);
|
| WaitFlagsState new_producer_state = ProducerGetWaitFlagsStateNoLock();
|
| if (!new_producer_state.equals(old_producer_state))
|
|
|