Lines Matching refs:channel_message
649 Channel::MessagePtr channel_message = in SendPeerMessage() local
654 if (channel_message->has_handles()) { in SendPeerMessage()
661 broker->RelayPortsMessage(name, std::move(channel_message)); in SendPeerMessage()
664 pending_relay_messages_[name].emplace(std::move(channel_message)); in SendPeerMessage()
670 if (channel_message->has_mach_ports()) { in SendPeerMessage()
682 broker->RelayPortsMessage(name, std::move(channel_message)); in SendPeerMessage()
685 pending_relay_messages_[name].emplace(std::move(channel_message)); in SendPeerMessage()
693 peer->PortsMessage(std::move(channel_message)); in SendPeerMessage()
706 queue.emplace(std::move(channel_message)); in SendPeerMessage()
871 Channel::MessagePtr channel_message = in BroadcastMessage() local
873 CHECK(!channel_message->has_handles()); in BroadcastMessage()
877 broker->Broadcast(std::move(channel_message)); in BroadcastMessage()
879 OnBroadcast(name_, std::move(channel_message)); in BroadcastMessage()
1116 Channel::MessagePtr channel_message) { in OnPortsMessage() argument
1121 if (!ParsePortsMessage(channel_message.get(), &data, &num_data_bytes, in OnPortsMessage()
1128 CHECK(channel_message); in OnPortsMessage()
1133 std::move(channel_message))); in OnPortsMessage()