fn transport_send(
        &self,
        message: GossipMessage,
        peer_id: NodeId,
        flow_tag: FlowTag,
    ) -> Result<(), TransportErrorCode> {
        let _timer = self
            .metrics
            .op_duration
            .with_label_values(&["transport_send"])
            .start_timer();
        let message = TransportPayload(pb::GossipMessage::proxy_encode(message).unwrap());
        self.transport
            .send(self.transport_client_type, &peer_id, flow_tag, message)
            .map_err(|e| {
                trace!(
                    self.log,
                    "Failed to send gossip message to peer {:?}: {:?}",
                    peer_id,
                    e
                );
                e
            })
    }
/// The method sends the given message over transport to the given peer.
The method sends the given message over transport to the given peer.
The method sends the given message over transport to the given peer .
fn transport_send(
        &self,
        message: GossipMessage,
        peer_id: NodeId,
        flow_tag: FlowTag,
    ) -> Result<(), TransportErrorCode> {
        let _timer = self
            .metrics
            .op_duration
            .with_label_values(&["transport_send"])
            .start_timer();
        let message = TransportPayload(pb::GossipMessage::proxy_encode(message).unwrap());
        self.transport
            .send(self.transport_client_type, &peer_id, flow_tag, message)
            .map_err(|e| {
                trace!(
                    self.log,
                    "Failed to send gossip message to peer {:?}: {:?}",
                    peer_id,
                    e
                );
                e
            })
    }
fn transport_send ( & self , message : GossipMessage , peer_id : NodeId , flow_tag : FlowTag , ) -> Result < ( ) , TransportErrorCode > { let _timer = self . metrics . op_duration . with_label_values ( & [ " " ] ) . start_timer ( ) ; let message = TransportPayload ( pb :: GossipMessage :: proxy_encode ( message ) . unwrap ( ) ) ; self . transport . send ( self . transport_client_type , & peer_id , flow_tag , message ) . map_err ( | e | { trace ! ( self log " " peer_id e ) ; e } ) }
The method sends the given message over transport to the given peer.
The method sends the given message over transport to the given peer .
&self
message
GossipMessage
peer_id
NodeId
flow_tag
FlowTag
&self
message
GossipMessage
peer_id
NodeId
flow_tag
FlowTag