Searched refs:EmitQ (Results 1 – 2 of 2) sorted by relevance
362 void emitQueueNotifyEnd() { EmitQ.notifyEnd(); } in emitQueueNotifyEnd()491 BoundedProducerConsumerQueue<EmitterWorkItem> EmitQ; variable
312 EmitQ(/*Sequential=*/getFlags().isSequential()), in GlobalContext()899 EmitQ.blockingPush(std::move(Item)); in emitQueueBlockingPush()907 return EmitQ.blockingPop(); in emitQueueBlockingPop()