Searched defs:data_queue (Results 1 – 3 of 3) sorted by relevance
66 std::shared_ptr<DataQueue> data_queue = CreateDataQueue( in Create() local291 …eakItemFromDataQueue(const AnfNodePtr &data_kernel, const std::shared_ptr<BlockingQueue> &data_que… in RetryPeakItemFromDataQueue()314 auto data_queue = buf_mgr.GetDataQueue(queue_name); in UpdateGetNextNode() local326 auto data_queue = buf_mgr.GetDataQueue(queue_name); in UpdateGetNextNode() local
70 DataQueueStatus BlockingQueue::Create(const std::shared_ptr<DataQueue> &data_queue) { in Create()
247 std::shared_ptr<DataQueue> data_queue = std::make_shared<WingmanQueue>(channel_name); in AscendTdtQueue() local