Searched refs:direct_queue_ (Results 1 – 2 of 2) sorted by relevance
275 if (direct_queue_) in GetQueueIds()276 queue_ids.push_back(direct_queue_->id()); in GetQueueIds()289 if (!direct_queue_) { in OnCreateQueue()301 direct_queue_ = producer->CreateConsumerQueue(); in OnCreateQueue()302 if (direct_queue_->metadata_size() > 0) { in OnCreateQueue()303 metadata_.reset(new uint8_t[direct_queue_->metadata_size()]); in OnCreateQueue()305 auto status = RegisterQueue(direct_queue_); in OnCreateQueue()334 direct_queue_ = nullptr; in OnQueueEvent()339 if (direct_queue_ == nullptr) { in DequeueBuffersLocked()349 auto buffer_status = direct_queue_->Dequeue( in DequeueBuffersLocked()[all …]
179 std::shared_ptr<ConsumerQueue> direct_queue_; variable