From adce6923b9ec0b96f7bec6bd43db942e8ca89c68 Mon Sep 17 00:00:00 2001 From: Christian Giese Date: Wed, 31 Jan 2024 19:59:31 +0000 Subject: [PATCH] fix stream rate calculation if stopped --- code/bngblaster/src/bbl_stream.c | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/code/bngblaster/src/bbl_stream.c b/code/bngblaster/src/bbl_stream.c index d72ff71f..e10852bb 100644 --- a/code/bngblaster/src/bbl_stream.c +++ b/code/bngblaster/src/bbl_stream.c @@ -1236,9 +1236,9 @@ bbl_stream_ctrl(bbl_stream_s *stream) bytes_delta = packets_delta * stream->tx_len; stream->last_sync_packets_tx = packets; bbl_stream_tx_stats(stream, packets_delta, bytes_delta); - if(g_ctx->config.stream_rate_calc) { - bbl_compute_avg_rate(&stream->rate_packets_tx, stream->tx_packets); - } + } + if(g_ctx->config.stream_rate_calc) { + bbl_compute_avg_rate(&stream->rate_packets_tx, stream->tx_packets); } if(unlikely(stream->type == BBL_TYPE_MULTICAST)) { return; @@ -1254,9 +1254,6 @@ bbl_stream_ctrl(bbl_stream_s *stream) loss_delta = packets - stream->last_sync_loss; stream->last_sync_loss = packets; bbl_stream_rx_stats(stream, packets_delta, bytes_delta, loss_delta); - if(g_ctx->config.stream_rate_calc) { - bbl_compute_avg_rate(&stream->rate_packets_rx, stream->rx_packets); - } if(unlikely(stream->rx_wrong_session)) { bbl_stream_rx_wrong_session(stream); } @@ -1288,6 +1285,9 @@ bbl_stream_ctrl(bbl_stream_s *stream) } } } + if(g_ctx->config.stream_rate_calc) { + bbl_compute_avg_rate(&stream->rate_packets_rx, stream->rx_packets); + } } void