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()77 Status<void> BufferHubQueue::ImportQueue() { in ImportQueue()146 bool BufferHubQueue::WaitForBuffers(int timeout) { in WaitForBuffers()277 Status<void> BufferHubQueue::AddBuffer( in AddBuffer()386 void BufferHubQueue::SetBufferAvailableCallback( in SetBufferAvailableCallback()576 return BufferHubQueue::RemoveBuffer(slot); in RemoveBuffer()596 BufferHubQueue::Dequeue(timeout, slot); in Dequeue()682 : BufferHubQueue(std::move(handle)) { in ConsumerQueue()[all …]
37 class BufferHubQueue : public pdx::Client {43 virtual ~BufferHubQueue() {} in ~BufferHubQueue()134 explicit BufferHubQueue(pdx::LocalChannelHandle channel);239 return index == BufferHubQueue::kEpollQueueEventIndex; in is_queue_event_index()283 BufferHubQueue(const BufferHubQueue&) = delete;284 void operator=(BufferHubQueue&) = delete;316 BufferHubQueue::GetBuffer(slot)); in GetBuffer()351 return BufferHubQueue::FreeAllBuffers(); in FreeAllBuffers()413 class ConsumerQueue : public BufferHubQueue {421 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()