Skip to content

Commit 0588896

Browse files
committed
fix(conn): cap connections to minimum needed
1 parent 8018588 commit 0588896

1 file changed

Lines changed: 7 additions & 1 deletion

File tree

src/lib.rs

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -964,9 +964,15 @@ impl Opts {
964964
wait_ongoing_requests_after_deadline: self.wait_ongoing_requests_after_deadline,
965965
}
966966
} else {
967+
let mut n_connections = self.n_connections;
968+
let max_useful = self.n_requests.div_ceil(self.n_http2_parallel);
969+
if n_connections > max_useful {
970+
n_connections = max_useful;
971+
}
972+
967973
WorkMode::FixedNumber {
968974
n_requests: self.n_requests,
969-
n_connections: self.n_connections,
975+
n_connections,
970976
n_http2_parallel: self.n_http2_parallel,
971977
query_limit: match self.query_per_second {
972978
Some(0f64) | None => self.burst_duration.map(|burst_duration| {

0 commit comments

Comments
 (0)