Searched refs:reactive_semaphore_ (Results 1 – 2 of 2) sorted by relevance
33 enqueue_.reactive_semaphore_.GetFd(),65 dequeue_.reactive_semaphore_.GetFd(), callback, base::Closure());96 dequeue_.reactive_semaphore_.Decrease();101 enqueue_.reactive_semaphore_.Increase();111 enqueue_.reactive_semaphore_.Decrease();113 dequeue_.reactive_semaphore_.Increase();
94 : reactive_semaphore_(initial_value), handler_(nullptr), reactable_(nullptr) {} in QueueEndpoint()95 ReactiveSemaphore reactive_semaphore_; variable