Keep terminal backpressure test MTU safe
ci / test (push) Canceled after 0s
ci / fuzz-smoke (push) Canceled after 0s
ci / macos-client (macos-aarch64, macos-14) (push) Canceled after 0s
ci / macos-client (macos-x86_64, macos-13) (push) Canceled after 0s
ci / windows-client (push) Canceled after 0s
ci / package-release (linux-x86_64, ubuntu-latest, , , ) (push) Canceled after 0s
ci / package-release (macos-aarch64, macos-14, , , ) (push) Canceled after 0s
ci / package-release (macos-x86_64, macos-13, , , ) (push) Canceled after 0s
ci / package-release (windows-aarch64, windows-latest, aarch64, windows, aarch64-pc-windows-msvc) (push) Canceled after 0s
ci / package-release (windows-x86_64, windows-latest, , , ) (push) Canceled after 0s
ci / remote-bench (push) Canceled after 0s
ci / publish-gitea-release (push) Canceled after 0s
ci / test (push) Canceled after 0s
ci / fuzz-smoke (push) Canceled after 0s
ci / macos-client (macos-aarch64, macos-14) (push) Canceled after 0s
ci / macos-client (macos-x86_64, macos-13) (push) Canceled after 0s
ci / windows-client (push) Canceled after 0s
ci / package-release (linux-x86_64, ubuntu-latest, , , ) (push) Canceled after 0s
ci / package-release (macos-aarch64, macos-14, , , ) (push) Canceled after 0s
ci / package-release (macos-x86_64, macos-13, , , ) (push) Canceled after 0s
ci / package-release (windows-aarch64, windows-latest, aarch64, windows, aarch64-pc-windows-msvc) (push) Canceled after 0s
ci / package-release (windows-x86_64, windows-latest, , , ) (push) Canceled after 0s
ci / remote-bench (push) Canceled after 0s
ci / publish-gitea-release (push) Canceled after 0s
This commit is contained in:
@@ -436,16 +436,28 @@ fn run_backpressure_server(
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
PacketKind::Ack if !bulk_sent => {
|
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(
|
send_frame(
|
||||||
&socket,
|
&socket,
|
||||||
peer.unwrap_or(source),
|
peer.unwrap_or(source),
|
||||||
PacketKind::Frame,
|
PacketKind::Frame,
|
||||||
2,
|
66,
|
||||||
11,
|
75,
|
||||||
&bulk,
|
b"DOSH_BACKPRESSURE_DONE",
|
||||||
false,
|
|
||||||
false,
|
false,
|
||||||
|
true,
|
||||||
);
|
);
|
||||||
bulk_sent = true;
|
bulk_sent = true;
|
||||||
observations.send(ServerObservation::BulkSent).unwrap();
|
observations.send(ServerObservation::BulkSent).unwrap();
|
||||||
@@ -459,16 +471,6 @@ fn run_backpressure_server(
|
|||||||
.send(ServerObservation::Input(input.bytes))
|
.send(ServerObservation::Input(input.bytes))
|
||||||
.unwrap();
|
.unwrap();
|
||||||
if contains(&received_input, expected_input) {
|
if contains(&received_input, expected_input) {
|
||||||
send_frame(
|
|
||||||
&socket,
|
|
||||||
peer.unwrap_or(source),
|
|
||||||
PacketKind::Frame,
|
|
||||||
3,
|
|
||||||
12,
|
|
||||||
b"DOSH_BACKPRESSURE_DONE",
|
|
||||||
false,
|
|
||||||
true,
|
|
||||||
);
|
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user