From 0fdfc0ee22b417443b57424d891f9656d7c9fee5 Mon Sep 17 00:00:00 2001 From: DuProcess <273172371+DuProcess@users.noreply.github.com> Date: Fri, 17 Jul 2026 20:48:50 -0400 Subject: [PATCH] Keep terminal backpressure test MTU safe --- tests/client_terminal_runtime.rs | 32 +++++++++++++++++--------------- 1 file changed, 17 insertions(+), 15 deletions(-) diff --git a/tests/client_terminal_runtime.rs b/tests/client_terminal_runtime.rs index 144abe2..a5ee7a1 100644 --- a/tests/client_terminal_runtime.rs +++ b/tests/client_terminal_runtime.rs @@ -436,16 +436,28 @@ fn run_backpressure_server( ); } PacketKind::Ack if !bulk_sent => { - let bulk = vec![b'x'; 60 * 1024]; + let bulk = [b'x'; 1024]; + for index in 0..64u64 { + send_frame( + &socket, + peer.unwrap_or(source), + PacketKind::Frame, + 2 + index, + 11 + index, + &bulk, + false, + false, + ); + } send_frame( &socket, peer.unwrap_or(source), PacketKind::Frame, - 2, - 11, - &bulk, - false, + 66, + 75, + b"DOSH_BACKPRESSURE_DONE", false, + true, ); bulk_sent = true; observations.send(ServerObservation::BulkSent).unwrap(); @@ -459,16 +471,6 @@ fn run_backpressure_server( .send(ServerObservation::Input(input.bytes)) .unwrap(); if contains(&received_input, expected_input) { - send_frame( - &socket, - peer.unwrap_or(source), - PacketKind::Frame, - 3, - 12, - b"DOSH_BACKPRESSURE_DONE", - false, - true, - ); break; } }