Lines Matching refs:producer
21 const std::shared_ptr<Channel> producer) in ConsumerChannel() argument
24 producer_(producer) { in ConsumerChannel()
33 if (auto producer = GetProducer()) { in ~ConsumerChannel() local
34 producer->RemoveConsumer(this); in ~ConsumerChannel()
40 if (auto producer = GetProducer()) { in GetBufferInfo() local
42 info = producer->GetBufferInfo(); in GetBufferInfo()
68 auto producer = GetProducer(); in HandleMessage() local
69 if (!producer) in HandleMessage()
80 *producer, &ProducerChannel::OnNewConsumer, message); in HandleMessage()
102 if (auto producer = GetProducer()) { in OnGetBuffer() local
103 return {producer->GetBuffer(client_state_mask_)}; in OnGetBuffer()
111 auto producer = GetProducer(); in OnConsumerAcquire() local
112 if (!producer) in OnConsumerAcquire()
119 acquired_, released_, message.GetChannelId(), producer->buffer_id()); in OnConsumerAcquire()
122 auto status = producer->OnConsumerAcquire(message); in OnConsumerAcquire()
134 auto producer = GetProducer(); in OnConsumerRelease() local
135 if (!producer) in OnConsumerRelease()
142 acquired_, released_, message.GetChannelId(), producer->buffer_id()); in OnConsumerRelease()
146 producer->OnConsumerRelease(message, std::move(release_fence)); in OnConsumerRelease()