diff --git a/core/src/banking_stage.rs b/core/src/banking_stage.rs index baf07e0d5bf7a0..12f158a2acc647 100644 --- a/core/src/banking_stage.rs +++ b/core/src/banking_stage.rs @@ -515,7 +515,21 @@ impl BankingStage { // in favor of shipping Quic support, which was considered higher-priority if !packet_vec.is_empty() { inc_new_counter_info!("banking_stage-forwarded_packets", packet_vec.len()); - if let Err(err) = send_wire_transaction_batch(&packet_vec, tpu_forwards) { + + let mut measure = Measure::start("banking_stage-forward-us"); + + let res = send_wire_transaction_batch(&packet_vec, tpu_forwards); + + measure.stop(); + inc_new_counter_info!( + "banking_stage-forward-us", + measure.as_us() as usize, + 1000, + 1000 + ); + + if let Err(err) = res { + inc_new_counter_info!("banking_stage-forward_packets-failed-batches", 1); return (Err(err), 0); } }