From 83a73c9c2b469b0456fd903e83a686ab8f5175c0 Mon Sep 17 00:00:00 2001 From: GroovieGermanikus Date: Tue, 18 Jul 2023 15:26:48 +0200 Subject: [PATCH] fix timeout --- services/tests/literpc_tpu_quic_server_integrationtest.rs | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/services/tests/literpc_tpu_quic_server_integrationtest.rs b/services/tests/literpc_tpu_quic_server_integrationtest.rs index 5f017e50..73e76cb6 100644 --- a/services/tests/literpc_tpu_quic_server_integrationtest.rs +++ b/services/tests/literpc_tpu_quic_server_integrationtest.rs @@ -105,6 +105,7 @@ pub fn wireup_and_send_txs_via_channel() { info!("start pulling packets..."); let mut packet_count = 0; let time_to_first = Instant::now(); + let mut latest_tx = Instant::now(); let timer = Instant::now(); // second half let mut timer2 = None; @@ -112,8 +113,8 @@ pub fn wireup_and_send_txs_via_channel() { let mut count_map: CountMap = CountMap::with_capacity(SAMPLE_TX_COUNT as usize); const WARMUP_TX_COUNT: u32 = SAMPLE_TX_COUNT / 2; while packet_count < SAMPLE_TX_COUNT { - if timer.elapsed() > Duration::from_secs(5) { - warn!("timeout waiting for packet from quic streamer"); + if latest_tx.elapsed() > Duration::from_secs(5) { + warn!("abort after timeout waiting for packet from quic streamer"); break; } @@ -125,6 +126,9 @@ pub fn wireup_and_send_txs_via_channel() { } }; + // reset timer + latest_tx = Instant::now(); + if packet_count == 0 { info!("time to first packet {}ms", time_to_first.elapsed().as_millis()); }