Searched refs:BufferHubQueue (Results 1 – 6 of 6) sorted by relevance
47 BufferHubQueue::BufferHubQueue(LocalChannelHandle channel_handle) in BufferHubQueue() function in android::dvr::BufferHubQueue53 BufferHubQueue::BufferHubQueue(const std::string& endpoint_path) in BufferHubQueue() function in android::dvr::BufferHubQueue59 void BufferHubQueue::Initialize() { in Initialize()69 .data = {.u64 = Stuff(-1, BufferHubQueue::kEpollQueueEventIndex)}}; in Initialize()77 Status<void> BufferHubQueue::ImportQueue() { in ImportQueue()89 void BufferHubQueue::SetupQueue(const QueueInfo& queue_info) { in SetupQueue()98 std::unique_ptr<ConsumerQueue> BufferHubQueue::CreateConsumerQueue() { in CreateConsumerQueue()105 std::unique_ptr<ConsumerQueue> BufferHubQueue::CreateSilentConsumerQueue() { in CreateSilentConsumerQueue()112 Status<LocalChannelHandle> BufferHubQueue::CreateConsumerQueueHandle( in CreateConsumerQueueHandle()127 BufferHubQueue::CreateConsumerQueueParcelable(bool silent) { in CreateConsumerQueueParcelable()[all …]
37 class BufferHubQueue : public pdx::Client {43 virtual ~BufferHubQueue() {} in ~BufferHubQueue()134 explicit BufferHubQueue(pdx::LocalChannelHandle channel);135 explicit BufferHubQueue(const std::string& endpoint_path);234 index < static_cast<int64_t>(BufferHubQueue::kMaxQueueCapacity); in is_buffer_event_index()239 return index == BufferHubQueue::kEpollQueueEventIndex; in is_queue_event_index()283 BufferHubQueue(const BufferHubQueue&) = delete;284 void operator=(BufferHubQueue&) = delete;287 class ProducerQueue : public pdx::ClientBase<ProducerQueue, BufferHubQueue> {316 BufferHubQueue::GetBuffer(slot)); in GetBuffer()[all …]
24 using BufferHubQueue = android::dvr::BufferHubQueue; member54 std::array<std::unique_ptr<DvrWriteBuffer>, BufferHubQueue::kMaxQueueCapacity>66 using BufferHubQueue = android::dvr::BufferHubQueue; member91 std::array<std::unique_ptr<DvrReadBuffer>, BufferHubQueue::kMaxQueueCapacity>
182 int32_t max_buffer_count_{dvr::BufferHubQueue::kMaxQueueCapacity};190 int dequeue_timeout_ms_{dvr::BufferHubQueue::kNoTimeOut};212 BufferHubSlot buffers_[dvr::BufferHubQueue::kMaxQueueCapacity];
88 int(BufferHubQueue::kMaxQueueCapacity - kDefaultUndequeuedBuffers)) { in setMaxDequeuedBufferCount()90 BufferHubQueue::kMaxQueueCapacity); in setMaxDequeuedBufferCount()162 for (size_t retry = 0; retry < BufferHubQueue::kMaxQueueCapacity; retry++) { in dequeueBuffer()821 for (size_t slot = 0; slot < BufferHubQueue::kMaxQueueCapacity; slot++) { in FreeAllBuffers()
67 bool WaitAndHandleOnce(BufferHubQueue* queue, int timeout_ms) { in WaitAndHandleOnce()