Searched refs:kMaxQueueCapacity (Results 1 – 8 of 8) sorted by relevance
124 for (size_t slot = 0; slot < BufferHubRPC::kMaxQueueCapacity; slot++) { in OnCreateConsumerQueue()206 if (capacity_ >= BufferHubRPC::kMaxQueueCapacity) { in AllocateBuffer()259 for (; slot < BufferHubRPC::kMaxQueueCapacity; slot++) { in AllocateBuffer()263 if (slot == BufferHubRPC::kMaxQueueCapacity) { in AllocateBuffer()292 if (capacity_ >= BufferHubRPC::kMaxQueueCapacity) { in OnProducerQueueInsertBuffer()339 for (; slot < BufferHubRPC::kMaxQueueCapacity; slot++) { in OnProducerQueueInsertBuffer()343 if (slot == BufferHubRPC::kMaxQueueCapacity) { in OnProducerQueueInsertBuffer()
54 std::array<std::unique_ptr<DvrWriteBuffer>, BufferHubQueue::kMaxQueueCapacity>91 std::array<std::unique_ptr<DvrReadBuffer>, BufferHubQueue::kMaxQueueCapacity>
86 return available_buffers_.size() >= kMaxQueueCapacity; in is_full()125 static constexpr size_t kMaxQueueCapacity = variable234 index < static_cast<int64_t>(BufferHubQueue::kMaxQueueCapacity); in is_buffer_event_index()262 std::array<std::shared_ptr<BufferHubBase>, kMaxQueueCapacity> buffers_;
182 int32_t max_buffer_count_{dvr::BufferHubQueue::kMaxQueueCapacity};212 BufferHubSlot buffers_[dvr::BufferHubQueue::kMaxQueueCapacity];
89 int(BufferHubQueue::kMaxQueueCapacity - kDefaultUndequeuedBuffers)) { in setMaxDequeuedBufferCount()91 BufferHubQueue::kMaxQueueCapacity); in setMaxDequeuedBufferCount()163 for (size_t retry = 0; retry < BufferHubQueue::kMaxQueueCapacity; retry++) { in dequeueBuffer()822 for (size_t slot = 0; slot < BufferHubQueue::kMaxQueueCapacity; slot++) { in FreeAllBuffers()
85 std::weak_ptr<ProducerChannel> buffers_[BufferHubRPC::kMaxQueueCapacity];
402 for (size_t slot = 0; slot < BufferHubQueue::kMaxQueueCapacity; slot++) { in FreeAllBuffers()450 if (capacity() + buffer_count > kMaxQueueCapacity) { in AllocateBuffers()
303 static constexpr size_t kMaxQueueCapacity = member