Searched refs:MultiProducerSingleConsumerQueue (Results 1 – 11 of 11) sorted by relevance
34 class MultiProducerSingleConsumerQueue {41 MultiProducerSingleConsumerQueue() : head_{&stub_}, tail_(&stub_) {} in MultiProducerSingleConsumerQueue() function42 ~MultiProducerSingleConsumerQueue() { in ~MultiProducerSingleConsumerQueue()74 typedef MultiProducerSingleConsumerQueue::Node Node;92 MultiProducerSingleConsumerQueue queue_;
29 bool MultiProducerSingleConsumerQueue::Push(Node* node) { in Push()36 MultiProducerSingleConsumerQueue::Node*37 MultiProducerSingleConsumerQueue::Pop() { in Pop()42 MultiProducerSingleConsumerQueue::Node*43 MultiProducerSingleConsumerQueue::PopAndCheckEnd(bool* empty) { in PopAndCheckEnd()
31 MultiProducerSingleConsumerQueue::Node mpscq_node;49 MultiProducerSingleConsumerQueue queue_;
39 MultiProducerSingleConsumerQueue queue;
113 MultiProducerSingleConsumerQueue queue_;
144 reinterpret_cast<MultiProducerSingleConsumerQueue::Node*>(closure)); in Start()
62 grpc_core::MultiProducerSingleConsumerQueue::Node>
221 grpc_core::MultiProducerSingleConsumerQueue::Node* n = lock->queue.Pop(); in grpc_combiner_continue_exec_ctx()
40 grpc_core::ManualConstructor<grpc_core::MultiProducerSingleConsumerQueue>
238 grpc_core::MultiProducerSingleConsumerQueue queue_;486 reinterpret_cast<grpc_core::MultiProducerSingleConsumerQueue::Node*>(c)); in Push()
95 MultiProducerSingleConsumerQueue::Node mpscq_node;