Lines Matching refs:peer
372 scoped_refptr<NodeChannel> peer = GetPeerChannel(source_node);
373 if (peer)
374 peer->NotifyBadMessage(error);
481 DVLOG(1) << "Ignoring duplicate peer name " << name;
488 DVLOG(2) << "Accepting new peer " << name << " on node " << name_;
518 ports::NodeName peer = it->first;
520 DVLOG(1) << "Dropped peer " << peer;
587 scoped_refptr<NodeChannel> peer = GetPeerChannel(name);
594 if (!peer || !peer->HasRemoteProcessHandle()) {
627 if (peer) {
628 peer->PortsMessage(std::move(channel_message));
632 // If we don't know who the peer is, queue the message for delivery. If this
633 // is the first message queued for the peer, we also ask the broker to
647 DVLOG(1) << "Dropping message for unknown peer: " << name;
708 for (const auto& peer : peers_)
709 all_peers.push_back(peer.second);
710 for (const auto& peer : pending_children_)
711 all_peers.push_back(peer.second);
717 for (const auto& peer : all_peers)
718 peer->ShutDown();
821 // NOTE: The child does not actually add its parent as a peer until
918 << " from peer " << from_node;
1099 DLOG(ERROR) << "Could not be introduced to peer " << name;
1109 DVLOG(1) << "Adding new peer " << name << " via parent introduction.";
1134 // Copy and send the message to each known peer.
1202 scoped_refptr<NodeChannel> peer = GetPeerChannel(destination);
1203 if (peer)
1204 peer->PortsMessageFromRelay(from_node, std::move(message));
