/// The method sends a retransmission request to the peer with the given
/// node ID.
The method sends a retransmission request to the peer with the given
node ID.
The method sends a retransmission request to the peer with the given node ID .
fn send_retransmission_request(&self, peer_id: NodeId) {
        let filter = self.artifact_manager.get_filter();
        let message = GossipMessage::RetransmissionRequest(GossipRetransmissionRequest { filter });
        let flow_tag = self.flow_mapper.map(&message);
        let start_time = Instant::now();
        self.transport_send(message, peer_id, flow_tag)
            .map(|_| self.metrics.retransmission_requests_sent.inc())
            .unwrap_or_else(|e| {
                trace!(
                    self.log,
                    "Send retransmission request failed: peer {:?} {:?} ",
                    peer_id,
                    e
                );
                self.metrics.retransmission_request_send_failed.inc();
            });
        self.metrics
            .retransmission_request_time
            .observe(start_time.elapsed().as_millis() as f64)
    }
fn send_retransmission_request ( & self , peer_id : NodeId ) { let filter = self . artifact_manager . get_filter ( ) ; let message = GossipMessage :: RetransmissionRequest ( GossipRetransmissionRequest { filter } ) ; let flow_tag = self . flow_mapper . map ( & message ) ; let start_time = Instant :: now ( ) ; self . transport_send ( message , peer_id , flow_tag ) . map ( | _ | self . metrics . retransmission_requests_sent . inc ( ) ) . unwrap_or_else ( | e | { trace ! ( self log " " peer_id e ) ; self . metrics . retransmission_request_send_failed . inc ( ) ; } ) ; self . metrics . retransmission_request_time . observe ( start_time . elapsed ( ) . as_millis ( ) as f64 ) }
The method sends a retransmission request to the peer with the given
node ID.
The method sends a retransmission request to the peer with the given node ID .
&self
peer_id
NodeId