Searched refs:consumer_queue (Results 1 – 5 of 5) sorted by relevance
17 ConsumerQueue* consumer_queue; in dvrPoseClientGetDataReader() local20 &consumer_queue); in dvrPoseClientGetDataReader()26 std::shared_ptr<ConsumerQueue> consumer_queue_ptr{consumer_queue}; in dvrPoseClientGetDataReader()
41 std::unique_ptr<ConsumerQueue> consumer_queue = in CreateReadQueue() local43 if (consumer_queue == nullptr) { in CreateReadQueue()50 *out_read_queue = new DvrReadBufferQueue(std::move(consumer_queue)); in CreateReadQueue()324 const std::shared_ptr<ConsumerQueue>& consumer_queue) in DvrReadBufferQueue() argument325 : consumer_queue_(consumer_queue) {} in DvrReadBufferQueue()328 std::unique_ptr<ConsumerQueue> consumer_queue = in CreateReadQueue() local330 if (consumer_queue == nullptr) { in CreateReadQueue()337 *out_read_queue = new DvrReadBufferQueue(std::move(consumer_queue)); in CreateReadQueue()
70 const std::shared_ptr<ConsumerQueue>& consumer_queue);
157 std::unique_ptr<ConsumerQueue> consumer_queue = in GetTangoReaderHandle() local159 *queue_out = consumer_queue.release(); in GetTangoReaderHandle()
133 auto consumer_queue = in CreateConsumerQueueParcelable() local136 consumer_queue->GetChannel()->TakeChannelParcelable()); in CreateConsumerQueueParcelable()