Searched refs:kMaxQueueCapacity (Results 1 – 3 of 3) 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()
85 std::weak_ptr<ProducerChannel> buffers_[BufferHubRPC::kMaxQueueCapacity];
303 static constexpr size_t kMaxQueueCapacity = member