| Index: mojo/edk/system/data_pipe_consumer_dispatcher.cc
|
| diff --git a/mojo/edk/system/data_pipe_consumer_dispatcher.cc b/mojo/edk/system/data_pipe_consumer_dispatcher.cc
|
| index 3c14f35c1ac6e1882fc86da52dbf20d60edf084e..f47dfb1b7c72fbaaee93b238960cd73bfab07d7a 100644
|
| --- a/mojo/edk/system/data_pipe_consumer_dispatcher.cc
|
| +++ b/mojo/edk/system/data_pipe_consumer_dispatcher.cc
|
| @@ -28,9 +28,9 @@ DataPipeConsumerDispatcher::~DataPipeConsumerDispatcher() {
|
| DCHECK(!data_pipe_.get());
|
| }
|
|
|
| -void DataPipeConsumerDispatcher::CancelAllWaitersNoLock() {
|
| +void DataPipeConsumerDispatcher::CancelAllAwakablesNoLock() {
|
| lock().AssertAcquired();
|
| - data_pipe_->ConsumerCancelAllWaiters();
|
| + data_pipe_->ConsumerCancelAllAwakables();
|
| }
|
|
|
| void DataPipeConsumerDispatcher::CloseImplNoLock() {
|
| @@ -109,20 +109,21 @@ HandleSignalsState DataPipeConsumerDispatcher::GetHandleSignalsStateImplNoLock()
|
| return data_pipe_->ConsumerGetHandleSignalsState();
|
| }
|
|
|
| -MojoResult DataPipeConsumerDispatcher::AddWaiterImplNoLock(
|
| - Waiter* waiter,
|
| +MojoResult DataPipeConsumerDispatcher::AddAwakableImplNoLock(
|
| + Awakable* awakable,
|
| MojoHandleSignals signals,
|
| uint32_t context,
|
| HandleSignalsState* signals_state) {
|
| lock().AssertAcquired();
|
| - return data_pipe_->ConsumerAddWaiter(waiter, signals, context, signals_state);
|
| + return data_pipe_->ConsumerAddAwakable(awakable, signals, context,
|
| + signals_state);
|
| }
|
|
|
| -void DataPipeConsumerDispatcher::RemoveWaiterImplNoLock(
|
| - Waiter* waiter,
|
| +void DataPipeConsumerDispatcher::RemoveAwakableImplNoLock(
|
| + Awakable* awakable,
|
| HandleSignalsState* signals_state) {
|
| lock().AssertAcquired();
|
| - data_pipe_->ConsumerRemoveWaiter(waiter, signals_state);
|
| + data_pipe_->ConsumerRemoveAwakable(awakable, signals_state);
|
| }
|
|
|
| bool DataPipeConsumerDispatcher::IsBusyNoLock() const {
|
|
|