Searched refs:MultiProducerSingleConsumerQueue (Results 1 – 12 of 12) 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()
32 using grpc_core::MultiProducerSingleConsumerQueue;35 MultiProducerSingleConsumerQueue::Node node;49 MultiProducerSingleConsumerQueue q; in test_serial()63 MultiProducerSingleConsumerQueue* q;83 MultiProducerSingleConsumerQueue q; in test_mt()95 MultiProducerSingleConsumerQueue::Node* n; in test_mt()117 MultiProducerSingleConsumerQueue* q;131 MultiProducerSingleConsumerQueue::Node* n; in pull_thread()151 MultiProducerSingleConsumerQueue q; in test_mt_multipop()
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>
224 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;