Skip to content

Commit

Permalink
benchmark: fix http2 benchmarks
Browse files Browse the repository at this point in the history
Fixes: #36746

PR-URL: #36871
Reviewed-By: Antoine du Hamel <duhamelantoine1995@gmail.com>
Reviewed-By: Gireesh Punathil <gpunathi@in.ibm.com>
  • Loading branch information
Trott authored and targos committed May 1, 2021
1 parent 5770ae0 commit c22efc5
Show file tree
Hide file tree
Showing 6 changed files with 11 additions and 8 deletions.
2 changes: 1 addition & 1 deletion benchmark/_test-double-benchmarker.js
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ function run() {
}
} else { // HTTP/2
const client = http.connect(url);
client.on('error', (e) => { throw e; });
client.on('error', () => {});
request(client.request(), client);
}
}
Expand Down
3 changes: 2 additions & 1 deletion benchmark/http2/compat.js
Original file line number Diff line number Diff line change
Expand Up @@ -24,9 +24,10 @@ function main({ requests, streams, clients, duration }) {
res.destroy();
});
});
server.listen(common.PORT, () => {
server.listen(0, () => {
bench.http({
path: '/',
port: server.address().port,
requests,
maxConcurrentStreams: streams,
clients,
Expand Down
5 changes: 2 additions & 3 deletions benchmark/http2/headers.js
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
'use strict';

const common = require('../common.js');
const PORT = common.PORT;

const bench = common.createBenchmark(main, {
n: [1e3],
Expand Down Expand Up @@ -32,8 +31,8 @@ function main({ n, nheaders }) {
stream.respond();
stream.end('Hi!');
});
server.listen(PORT, () => {
const client = http2.connect(`http://localhost:${PORT}/`, {
server.listen(0, () => {
const client = http2.connect(`http://localhost:${server.address().port}/`, {
maxHeaderListPairs: 20000
});

Expand Down
3 changes: 2 additions & 1 deletion benchmark/http2/respond-with-fd.js
Original file line number Diff line number Diff line change
Expand Up @@ -25,10 +25,11 @@ function main({ requests, streams, clients, duration }) {
stream.respondWithFD(fd);
stream.on('error', (err) => {});
});
server.listen(common.PORT, () => {
server.listen(0, () => {
bench.http({
path: '/',
requests,
port: server.address().port,
maxConcurrentStreams: streams,
clients,
duration,
Expand Down
3 changes: 2 additions & 1 deletion benchmark/http2/simple.js
Original file line number Diff line number Diff line change
Expand Up @@ -22,9 +22,10 @@ function main({ requests, streams, clients, duration }) {
out.pipe(stream);
stream.on('error', (err) => {});
});
server.listen(common.PORT, () => {
server.listen(0, () => {
bench.http({
path: '/',
port: server.address().port,
requests,
maxConcurrentStreams: streams,
clients,
Expand Down
3 changes: 2 additions & 1 deletion benchmark/http2/write.js
Original file line number Diff line number Diff line change
Expand Up @@ -26,9 +26,10 @@ function main({ streams, length, size, duration }) {
}
write();
});
server.listen(common.PORT, () => {
server.listen(0, () => {
bench.http({
path: '/',
port: server.address().port,
requests: 10000,
duration,
maxConcurrentStreams: streams,
Expand Down

0 comments on commit c22efc5

Please sign in to comment.