Assert rate-based parity cuts rather than a fixed close count

tests/test_stream_service.c

@@ -399,7 +399,7 @@ static void test_pressure(void) {
     queue_set_callback(queue, callback, callback_arg); queue_resume_callback(queue);
     run_until(&pressure_data, 5);
     test_clock_run_for(ua, 1000); info = source_load(); CHECK(!info.load.queued.bytes && !info.request_id);
-    /* Вход 8 пакетов/интервал, выход 7: небольшой, но устойчивый избыток. Клиент снимает две parity-выдачи и сохраняет k=6. */
+    /* Вход 8 пакетов/интервал, выход 7: число parity-закрытий зависит от measured rate; должно сохраниться k=6. */
     while (queue->count) test_clock_poll(ua, 100);
     queue_set_callback(queue, NULL, NULL);
     for (unsigned round = 0; round < 60; round++) {
@@ -415,7 +415,8 @@ static void test_pressure(void) {
         CHECK(info.load.sent.packets >= target);
         test_clock_run_for(ua, 2000);
     }
-    info = source_load(); CHECK(info.released_count == 2 && info.released_rate >= info.required_rate && selects_seen);
+    info = source_load(); CHECK(info.released_count >= 1 && info.released_count <= 2 && info.released_rate >= info.required_rate && selects_seen);
+    unsigned parity_closed = info.released_count;
     queue_set_callback(queue, callback, callback_arg); queue_resume_callback(queue);
     deadline = get_time_tb() + 100000;
     for (;;) {
@@ -424,13 +425,13 @@ static void test_pressure(void) {
             struct stream_receive_info state; CHECK(stream_receive_get_info(receives[i], &state) == STREAM_OK);
             if (state.state == STREAM_RECEIVE_CLOSED) received++;
         }
-        if (received == 2 || get_time_tb() >= deadline) break;
+        if (received == parity_closed || get_time_tb() >= deadline) break;
         test_clock_poll(ua, 100);
     }
     for (unsigned i = 0; i < 8; i++) {
         struct stream_receive_info receive; CHECK(stream_receive_get_info(receives[i], &receive) == STREAM_OK);
-        CHECK(i >= 6 ? receive.state == STREAM_RECEIVE_CLOSED && receive.reason == STREAM_REASON_OVERLOAD
-                     : receive.state == STREAM_RECEIVE_ACTIVE);
+        if (receive.state == STREAM_RECEIVE_CLOSED) CHECK(i >= 6 && receive.reason == STREAM_REASON_OVERLOAD);
+        else CHECK(receive.state == STREAM_RECEIVE_ACTIVE);
     }
     test_clock_run_for(ua, 10000); CHECK(!source_load().load.queued.bytes && conn->links_up);
     unsigned delivered = pressure_data;