From 61df1204f88acb9c4397c799d8dadcacfabc905b Mon Sep 17 00:00:00 2001 From: evgeny Date: Sun, 11 Oct 2026 08:34:33 +0200 Subject: [PATCH] Expect expired arrival intervals to leave the load window --- tests/test_stream_core.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/test_stream_core.c b/tests/test_stream_core.c index 3d30ff6f..7ee55e05 100644 --- a/tests/test_stream_core.c +++ b/tests/test_stream_core.c @@ -48,7 +48,7 @@ static void test_load(void) { CHECK(stream_load_poll(&load, 1500, 0, &snapshot) == STREAM_OK && snapshot.arrivals.bytes == snapshot.sent.bytes); CHECK(stream_load_add(&load, 3, 3900) == STREAM_OK); stream_load_changed(&load); CHECK(stream_load_poll(&load, 1700, 300, &snapshot) == STREAM_OK && snapshot.growth_rate == 0 && !snapshot.confirmed); - CHECK(stream_load_poll(&load, 13000, 300, &snapshot) == STREAM_OK && snapshot.input_rate == 390); + CHECK(stream_load_poll(&load, 13000, 300, &snapshot) == STREAM_OK && snapshot.input_rate == 0); struct stream_metric_snapshot input = {.lag_ms = UINT64_C(1) << 42, .blocks = UINT64_MAX, .late_blocks = 2, .stops = 3, .source_rate_bytes_sec = UINT64_C(1) << 40, .receive_rate_bytes_sec = 10000, .source_rate_valid = 1, .receive_rate_valid = 1, .stopped = 1}; uint8_t wire[STREAM_METRIC_WIRE_SIZE]; stream_metric_write(wire, &input, 1);