Lines Matching refs:channel

69   for (const auto& channel : channels) {
70 if (channel->channel_type() == BufferHubChannel::kProducerType) {
71 BufferHubChannel::BufferInfo info = channel->GetBufferInfo();
121 for (const auto& channel : channels) {
122 if (channel->channel_type() == BufferHubChannel::kProducerQueueType) {
123 BufferHubChannel::BufferInfo info = channel->GetBufferInfo();
154 for (const auto& channel : channels) {
155 if (channel->channel_type() == BufferHubChannel::kConsumerQueueType) {
156 BufferHubChannel::BufferInfo info = channel->GetBufferInfo();
174 for (const auto& channel : channels) {
175 BufferHubChannel::BufferInfo info = channel->GetBufferInfo();
178 if (channel->channel_type() == BufferHubChannel::kConsumerType &&
185 stream << (" channel_id=" + std::to_string(channel->channel_id()));
195 if (auto channel = message.GetChannel<BufferHubChannel>())
196 channel->HandleImpulse(message);
201 auto channel = message.GetChannel<BufferHubChannel>();
205 "BufferHubService::HandleMessage: channel=%p channel_id=%d opcode=%d",
206 channel.get(), message.GetChannelId(), message.GetOp());
208 // If the channel is already set up, let it handle the message.
209 if (channel && !channel->HandleMessage(message))
212 // This channel has not been set up yet, the following are valid operations.
240 const std::shared_ptr<Channel>& channel) {
241 if (auto buffer = std::static_pointer_cast<BufferHubChannel>(channel))
249 // Use the producer channel id as the global buffer id.
256 // See if this channel is already attached to a buffer.
257 if (const auto channel = message.GetChannel<BufferHubChannel>()) {
289 // See if this channel is already attached to a buffer.
290 if (const auto channel = message.GetChannel<BufferHubChannel>()) {
294 channel_id, channel->buffer_id());
318 "buffer that is already attached to a channel: name=%s",
350 // See if this channel is already attached to a buffer.
351 if (const auto channel = message.GetChannel<BufferHubChannel>()) {
355 channel_id, channel->buffer_id());
372 "buffer that is already attached to a channel: name=%s",
390 // Use the producer channel id as the global queue id.
395 // See if this channel is already attached to another object.
396 if (const auto channel = message.GetChannel<BufferHubChannel>()) {