Searched refs:consumer_waiter_list_ (Results 1 – 2 of 2) sorted by relevance
243 consumer_waiter_list_->CancelAllWaiters(); in ConsumerCancelAllWaiters()251 consumer_waiter_list_.reset(); in ConsumerClose()412 consumer_waiter_list_->AddWaiter(waiter, signals, context); in ConsumerAddWaiter()420 consumer_waiter_list_->RemoveWaiter(waiter); in ConsumerRemoveWaiter()440 consumer_waiter_list_(has_local_consumer ? new WaiterList() : nullptr), in DataPipe()453 DCHECK(!consumer_waiter_list_); in ~DataPipe()469 consumer_waiter_list_->AwakeWaitersForStateChange(new_consumer_state); in AwakeConsumerWaitersForStateChangeNoLock()
192 return !!consumer_waiter_list_; in has_local_consumer_no_lock()205 scoped_ptr<WaiterList> consumer_waiter_list_; variable