Searched refs:reactive_semaphore_ (Results 1 – 1 of 1) sorted by relevance
110 : reactive_semaphore_(initial_value), handler_(nullptr), reactable_(nullptr) {} in QueueEndpoint()111 ReactiveSemaphore reactive_semaphore_; variable194 enqueue_.reactive_semaphore_.GetFd(), in RegisterEnqueue()228 dequeue_.reactive_semaphore_.GetFd(), callback, base::Closure()); in RegisterDequeue()260 dequeue_.reactive_semaphore_.Decrease(); in TryDequeue()265 enqueue_.reactive_semaphore_.Increase(); in TryDequeue()275 enqueue_.reactive_semaphore_.Decrease(); in EnqueueCallbackInternal()277 dequeue_.reactive_semaphore_.Increase(); in EnqueueCallbackInternal()