Searched refs:producer_channel (Results 1 – 4 of 4) sorted by relevance
85 const std::shared_ptr<ProducerChannel>& producer_channel, size_t slot) { in RegisterNewBuffer() argument89 buffer_id(), producer_channel->buffer_id(), slot, silent_); in RegisterNewBuffer()92 pending_buffer_slots_.emplace(producer_channel, slot); in RegisterNewBuffer()113 auto producer_channel = pending_buffer_slots_.front().first.lock(); in OnConsumerQueueImportBuffers() local119 if (producer_channel == nullptr) { in OnConsumerQueueImportBuffers()126 auto status = producer_channel->CreateConsumer(message); in OnConsumerQueueImportBuffers()
235 auto producer_channel = producer_channel_status.take(); in AllocateBuffer() local243 service()->SetChannel(buffer_id, producer_channel); in AllocateBuffer()266 buffers_[slot] = producer_channel; in AllocateBuffer()275 consumer_channel->RegisterNewBuffer(producer_channel, slot); in AllocateBuffer()
33 const std::shared_ptr<ProducerChannel>& producer_channel, size_t slot);
19 "producer_channel.cpp",