Searched refs:buffers_ (Results 1 – 2 of 2) sorted by relevance
125 if (auto buffer = buffers_[slot].lock()) in OnCreateConsumerQueue()260 if (buffers_[slot].expired()) in AllocateBuffer()270 buffers_[slot] = producer_channel; in AllocateBuffer()340 if (buffers_[slot].expired()) in OnProducerQueueInsertBuffer()350 buffers_[slot] = producer_channel; in OnProducerQueueInsertBuffer()367 if (buffers_[slot].expired()) { in OnProducerQueueRemoveBuffer()382 buffers_[slot].reset(); in OnProducerQueueRemoveBuffer()
85 std::weak_ptr<ProducerChannel> buffers_[BufferHubRPC::kMaxQueueCapacity]; variable