Lines Matching defs:peer
388 scoped_refptr<NodeChannel> peer = GetPeerChannel(source_node);
389 if (peer)
390 peer->NotifyBadMessage(error);
490 auto peer = peers_by_token_.find(peer_token);
492 if (peer == peers_by_token_.end())
495 // |peer| may be removed so make a copy of |name|.
496 ports::NodeName name = peer->second;
544 DVLOG(1) << "Ignoring duplicate peer name " << name;
551 DVLOG(2) << "Accepting new peer " << name << " on node " << name_;
581 ports::NodeName peer = it->first;
583 DVLOG(1) << "Dropped peer " << peer;
632 auto peer = peer_connections_.find(name);
633 if (peer != peer_connections_.end()) {
634 peers_by_token_.erase(peer->second.peer_token);
635 ports_to_close.push_back(peer->second.local_port);
636 peer_connections_.erase(peer);
652 scoped_refptr<NodeChannel> peer = GetPeerChannel(name);
659 if (!peer || !peer->HasRemoteProcessHandle()) {
692 if (peer) {
693 peer->PortsMessage(std::move(channel_message));
697 // If we don't know who the peer is, queue the message for delivery. If this
698 // is the first message queued for the peer, we also ask the broker to
712 DVLOG(1) << "Dropping message for unknown peer: " << name;
803 for (const auto& peer : peers_)
804 all_peers.push_back(peer.second);
805 for (const auto& peer : pending_children_)
806 all_peers.push_back(peer.second);
813 for (const auto& peer : all_peers)
814 peer->ShutDown();
918 // NOTE: The child does not actually add its parent as a peer until
1016 << " from peer " << from_node;
1198 DVLOG(1) << "Could not be introduced to peer " << name;
1208 DVLOG(1) << "Adding new peer " << name << " via parent introduction.";
1233 // Copy and send the message to each known peer.
1301 scoped_refptr<NodeChannel> peer = GetPeerChannel(destination);
1302 if (peer)
1303 peer->PortsMessageFromRelay(from_node, std::move(message));
1340 // If the peer connection is a self connection (which is used in tests),
1348 DVLOG(1) << "Node " << name_ << " accepted peer " << peer_name;
