Searched refs:reactive_semaphore_ (Results 1 – 1 of 1) sorted by relevance
92 : reactive_semaphore_(initial_value), handler_(nullptr), reactable_(nullptr) {} in QueueEndpoint()93 ReactiveSemaphore reactive_semaphore_; variable177 enqueue_.reactive_semaphore_.GetFd(), in RegisterEnqueue()210 dequeue_.reactive_semaphore_.GetFd(), callback, base::Closure()); in RegisterDequeue()242 dequeue_.reactive_semaphore_.Decrease(); in TryDequeue()247 enqueue_.reactive_semaphore_.Increase(); in TryDequeue()257 enqueue_.reactive_semaphore_.Decrease(); in EnqueueCallbackInternal()259 dequeue_.reactive_semaphore_.Increase(); in EnqueueCallbackInternal()