def send_peers(self, connection_id):
        """Sends a message containing our peers to the
        connection identified by connection_id.

        Args:
            connection_id (str): A unique identifier which identifies an
                connection on the network server socket.
        """
        with self._lock:
            # Needs to actually be the list of advertised endpoints of
            # our peers
            peer_endpoints = list(self._peers.values())
            if self._endpoint:
                peer_endpoints.append(self._endpoint)
            peers_response = GetPeersResponse(peer_endpoints=peer_endpoints)
            try:
                # Send a one_way message because the connection will be closed
                # if this is a temp connection.
                self._network.send(
                    validator_pb2.Message.GOSSIP_GET_PEERS_RESPONSE,
                    peers_response.SerializeToString(),
                    connection_id,
                    one_way=True)
            except ValueError:
                LOGGER.debug("Connection disconnected: %s", connection_id)
def send_peers ( self , connection_id ) : with self . _lock : peer_endpoints = list ( self . _peers . values ( ) ) if self . _endpoint : peer_endpoints . append ( self . _endpoint ) peers_response = GetPeersResponse ( peer_endpoints = peer_endpoints ) try : self . _network . send ( validator_pb2 . Message . GOSSIP_GET_PEERS_RESPONSE , peers_response . SerializeToString ( ) , connection_id , one_way = True ) except ValueError : LOGGER . debug ( "Connection disconnected: %s" , connection_id )
Sends a message containing our peers to the
        connection identified by connection_id.

        Args:
            connection_id (str): A unique identifier which identifies an
                connection on the network server socket.