| Index: mojo/edk/system/data_pipe_producer_dispatcher.cc
|
| diff --git a/mojo/edk/system/data_pipe_producer_dispatcher.cc b/mojo/edk/system/data_pipe_producer_dispatcher.cc
|
| index 0a82c9a242b7b920d64e4ff6f5848d553bbf1820..513ab73d52325340e19577824edcc0a7b6533728 100644
|
| --- a/mojo/edk/system/data_pipe_producer_dispatcher.cc
|
| +++ b/mojo/edk/system/data_pipe_producer_dispatcher.cc
|
| @@ -28,9 +28,9 @@ DataPipeProducerDispatcher::~DataPipeProducerDispatcher() {
|
| DCHECK(!data_pipe_.get());
|
| }
|
|
|
| -void DataPipeProducerDispatcher::CancelAllWaitersNoLock() {
|
| +void DataPipeProducerDispatcher::CancelAllAwakablesNoLock() {
|
| lock().AssertAcquired();
|
| - data_pipe_->ProducerCancelAllWaiters();
|
| + data_pipe_->ProducerCancelAllAwakables();
|
| }
|
|
|
| void DataPipeProducerDispatcher::CloseImplNoLock() {
|
| @@ -82,20 +82,21 @@ HandleSignalsState DataPipeProducerDispatcher::GetHandleSignalsStateImplNoLock()
|
| return data_pipe_->ProducerGetHandleSignalsState();
|
| }
|
|
|
| -MojoResult DataPipeProducerDispatcher::AddWaiterImplNoLock(
|
| - Waiter* waiter,
|
| +MojoResult DataPipeProducerDispatcher::AddAwakableImplNoLock(
|
| + Awakable* awakable,
|
| MojoHandleSignals signals,
|
| uint32_t context,
|
| HandleSignalsState* signals_state) {
|
| lock().AssertAcquired();
|
| - return data_pipe_->ProducerAddWaiter(waiter, signals, context, signals_state);
|
| + return data_pipe_->ProducerAddAwakable(awakable, signals, context,
|
| + signals_state);
|
| }
|
|
|
| -void DataPipeProducerDispatcher::RemoveWaiterImplNoLock(
|
| - Waiter* waiter,
|
| +void DataPipeProducerDispatcher::RemoveAwakableImplNoLock(
|
| + Awakable* awakable,
|
| HandleSignalsState* signals_state) {
|
| lock().AssertAcquired();
|
| - data_pipe_->ProducerRemoveWaiter(waiter, signals_state);
|
| + data_pipe_->ProducerRemoveAwakable(awakable, signals_state);
|
| }
|
|
|
| bool DataPipeProducerDispatcher::IsBusyNoLock() const {
|
|
|