diff options
author | rockot <rockot@chromium.org> | 2014-12-08 22:41:37 -0800 |
---|---|---|
committer | Commit bot <commit-bot@chromium.org> | 2014-12-09 06:42:04 +0000 |
commit | fa648a32329c36eda94aeadac4aac14f3b8013be (patch) | |
tree | 29386b2d867a4bb482368a57b90ba809b4079c22 /mojo/edk/system/data_pipe.h | |
parent | bf9d1f3cc8c6921e60de38d8c1a51dee74edcd76 (diff) | |
download | chromium_src-fa648a32329c36eda94aeadac4aac14f3b8013be.zip chromium_src-fa648a32329c36eda94aeadac4aac14f3b8013be.tar.gz chromium_src-fa648a32329c36eda94aeadac4aac14f3b8013be.tar.bz2 |
Update mojo sdk to rev f6c8ec07c01deebc13178d516225fd12695c3dc2
BUG=None
TBR=digit@chromium.org for ashmem dep
TBR=darin@chromium.org for toplevel
Review URL: https://codereview.chromium.org/782693004
Cr-Commit-Position: refs/heads/master@{#307427}
Diffstat (limited to 'mojo/edk/system/data_pipe.h')
-rw-r--r-- | mojo/edk/system/data_pipe.h | 42 |
1 files changed, 22 insertions, 20 deletions
diff --git a/mojo/edk/system/data_pipe.h b/mojo/edk/system/data_pipe.h index 767d405..d893465 100644 --- a/mojo/edk/system/data_pipe.h +++ b/mojo/edk/system/data_pipe.h @@ -20,8 +20,8 @@ namespace mojo { namespace system { -class Waiter; -class WaiterList; +class Awakable; +class AwakableList; // |DataPipe| is a base class for secondary objects implementing data pipes, // similar to |MessagePipe| (see the explanatory comment in core.cc). It is @@ -48,7 +48,7 @@ class MOJO_SYSTEM_IMPL_EXPORT DataPipe // These are called by the producer dispatcher to implement its methods of // corresponding names. - void ProducerCancelAllWaiters(); + void ProducerCancelAllAwakables(); void ProducerClose(); MojoResult ProducerWriteData(UserPointer<const void> elements, UserPointer<uint32_t> num_bytes, @@ -58,16 +58,17 @@ class MOJO_SYSTEM_IMPL_EXPORT DataPipe bool all_or_none); MojoResult ProducerEndWriteData(uint32_t num_bytes_written); HandleSignalsState ProducerGetHandleSignalsState(); - MojoResult ProducerAddWaiter(Waiter* waiter, - MojoHandleSignals signals, - uint32_t context, - HandleSignalsState* signals_state); - void ProducerRemoveWaiter(Waiter* waiter, HandleSignalsState* signals_state); + MojoResult ProducerAddAwakable(Awakable* awakable, + MojoHandleSignals signals, + uint32_t context, + HandleSignalsState* signals_state); + void ProducerRemoveAwakable(Awakable* awakable, + HandleSignalsState* signals_state); bool ProducerIsBusy() const; // These are called by the consumer dispatcher to implement its methods of // corresponding names. - void ConsumerCancelAllWaiters(); + void ConsumerCancelAllAwakables(); void ConsumerClose(); // This does not validate its arguments, except to check that |*num_bytes| is // a multiple of |element_num_bytes_|. @@ -83,11 +84,12 @@ class MOJO_SYSTEM_IMPL_EXPORT DataPipe bool all_or_none); MojoResult ConsumerEndReadData(uint32_t num_bytes_read); HandleSignalsState ConsumerGetHandleSignalsState(); - MojoResult ConsumerAddWaiter(Waiter* waiter, - MojoHandleSignals signals, - uint32_t context, - HandleSignalsState* signals_state); - void ConsumerRemoveWaiter(Waiter* waiter, HandleSignalsState* signals_state); + MojoResult ConsumerAddAwakable(Awakable* awakable, + MojoHandleSignals signals, + uint32_t context, + HandleSignalsState* signals_state); + void ConsumerRemoveAwakable(Awakable* awakable, + HandleSignalsState* signals_state); bool ConsumerIsBusy() const; protected: @@ -179,18 +181,18 @@ class MOJO_SYSTEM_IMPL_EXPORT DataPipe } private: - void AwakeProducerWaitersForStateChangeNoLock( + void AwakeProducerAwakablesForStateChangeNoLock( const HandleSignalsState& new_producer_state); - void AwakeConsumerWaitersForStateChangeNoLock( + void AwakeConsumerAwakablesForStateChangeNoLock( const HandleSignalsState& new_consumer_state); bool has_local_producer_no_lock() const { lock_.AssertAcquired(); - return !!producer_waiter_list_; + return !!producer_awakable_list_; } bool has_local_consumer_no_lock() const { lock_.AssertAcquired(); - return !!consumer_waiter_list_; + return !!consumer_awakable_list_; } const bool may_discard_; @@ -202,8 +204,8 @@ class MOJO_SYSTEM_IMPL_EXPORT DataPipe bool producer_open_; bool consumer_open_; // Non-null only if the producer or consumer, respectively, is local. - scoped_ptr<WaiterList> producer_waiter_list_; - scoped_ptr<WaiterList> consumer_waiter_list_; + scoped_ptr<AwakableList> producer_awakable_list_; + scoped_ptr<AwakableList> consumer_awakable_list_; // These are nonzero if and only if a two-phase write/read is in progress. uint32_t producer_two_phase_max_num_bytes_written_; uint32_t consumer_two_phase_max_num_bytes_read_; |