| Index: mojo/edk/system/dispatcher.cc
|
| diff --git a/mojo/edk/system/dispatcher.cc b/mojo/edk/system/dispatcher.cc
|
| index bed5f9eaeb0a86db774326ff858b3a8cfd2b823a..e2f2b8784f4684c9d1c074e1a7aae65e8c6ccd66 100644
|
| --- a/mojo/edk/system/dispatcher.cc
|
| +++ b/mojo/edk/system/dispatcher.cc
|
| @@ -220,10 +220,10 @@ HandleSignalsState Dispatcher::GetHandleSignalsState() const {
|
| return GetHandleSignalsStateImplNoLock();
|
| }
|
|
|
| -MojoResult Dispatcher::AddWaiter(Waiter* waiter,
|
| - MojoHandleSignals signals,
|
| - uint32_t context,
|
| - HandleSignalsState* signals_state) {
|
| +MojoResult Dispatcher::AddAwakable(Awakable* awakable,
|
| + MojoHandleSignals signals,
|
| + uint32_t context,
|
| + HandleSignalsState* signals_state) {
|
| base::AutoLock locker(lock_);
|
| if (is_closed_) {
|
| if (signals_state)
|
| @@ -231,18 +231,19 @@ MojoResult Dispatcher::AddWaiter(Waiter* waiter,
|
| return MOJO_RESULT_INVALID_ARGUMENT;
|
| }
|
|
|
| - return AddWaiterImplNoLock(waiter, signals, context, signals_state);
|
| + return AddAwakableImplNoLock(awakable, signals, context, signals_state);
|
| }
|
|
|
| -void Dispatcher::RemoveWaiter(Waiter* waiter,
|
| - HandleSignalsState* handle_signals_state) {
|
| +void Dispatcher::RemoveAwakable(Awakable* awakable,
|
| + HandleSignalsState* handle_signals_state) {
|
| base::AutoLock locker(lock_);
|
| if (is_closed_) {
|
| if (handle_signals_state)
|
| *handle_signals_state = HandleSignalsState();
|
| return;
|
| }
|
| - RemoveWaiterImplNoLock(waiter, handle_signals_state);
|
| +
|
| + RemoveAwakableImplNoLock(awakable, handle_signals_state);
|
| }
|
|
|
| Dispatcher::Dispatcher() : is_closed_(false) {
|
| @@ -253,7 +254,7 @@ Dispatcher::~Dispatcher() {
|
| DCHECK(is_closed_);
|
| }
|
|
|
| -void Dispatcher::CancelAllWaitersNoLock() {
|
| +void Dispatcher::CancelAllAwakablesNoLock() {
|
| lock_.AssertAcquired();
|
| DCHECK(is_closed_);
|
| // By default, waiting isn't supported. Only dispatchers that can be waited on
|
| @@ -370,10 +371,11 @@ HandleSignalsState Dispatcher::GetHandleSignalsStateImplNoLock() const {
|
| return HandleSignalsState();
|
| }
|
|
|
| -MojoResult Dispatcher::AddWaiterImplNoLock(Waiter* /*waiter*/,
|
| - MojoHandleSignals /*signals*/,
|
| - uint32_t /*context*/,
|
| - HandleSignalsState* signals_state) {
|
| +MojoResult Dispatcher::AddAwakableImplNoLock(
|
| + Awakable* /*awakable*/,
|
| + MojoHandleSignals /*signals*/,
|
| + uint32_t /*context*/,
|
| + HandleSignalsState* signals_state) {
|
| lock_.AssertAcquired();
|
| DCHECK(!is_closed_);
|
| // By default, waiting isn't supported. Only dispatchers that can be waited on
|
| @@ -383,8 +385,8 @@ MojoResult Dispatcher::AddWaiterImplNoLock(Waiter* /*waiter*/,
|
| return MOJO_RESULT_FAILED_PRECONDITION;
|
| }
|
|
|
| -void Dispatcher::RemoveWaiterImplNoLock(Waiter* /*waiter*/,
|
| - HandleSignalsState* signals_state) {
|
| +void Dispatcher::RemoveAwakableImplNoLock(Awakable* /*awakable*/,
|
| + HandleSignalsState* signals_state) {
|
| lock_.AssertAcquired();
|
| DCHECK(!is_closed_);
|
| // By default, waiting isn't supported. Only dispatchers that can be waited on
|
| @@ -427,7 +429,7 @@ void Dispatcher::CloseNoLock() {
|
| DCHECK(!is_closed_);
|
|
|
| is_closed_ = true;
|
| - CancelAllWaitersNoLock();
|
| + CancelAllAwakablesNoLock();
|
| CloseImplNoLock();
|
| }
|
|
|
| @@ -437,7 +439,7 @@ Dispatcher::CreateEquivalentDispatcherAndCloseNoLock() {
|
| DCHECK(!is_closed_);
|
|
|
| is_closed_ = true;
|
| - CancelAllWaitersNoLock();
|
| + CancelAllAwakablesNoLock();
|
| return CreateEquivalentDispatcherAndCloseImplNoLock();
|
| }
|
|
|
|
|