Skip to content

Commit

Permalink
benchmark: enhance dc publish benchmark
Browse files Browse the repository at this point in the history
PR-URL: nodejs#54745
Reviewed-By: Stephen Belanger <admin@stephenbelanger.com>
Reviewed-By: Rich Trott <rtrott@gmail.com>
  • Loading branch information
RafaelGSS authored and tpoisseau committed Nov 21, 2024
1 parent a3b9413 commit 9e47209
Showing 1 changed file with 37 additions and 8 deletions.
45 changes: 37 additions & 8 deletions benchmark/diagnostics_channel/publish.js
Original file line number Diff line number Diff line change
@@ -1,29 +1,58 @@
'use strict';
const common = require('../common.js');
const dc = require('diagnostics_channel');
const dc = require('node:diagnostics_channel');

const bench = common.createBenchmark(main, {
n: [1e8],
checkSubscribers: [1, 0],
objSize: [10, 1e2, 1e3],
subscribers: [0, 1, 10],
});

function noop() {}

function main({ n, subscribers }) {
function createObj(size) {
return Array.from({ length: size }, (n) => ({
foo: 'yarp',
nope: {
bar: '123',
a: [1, 2, 3],
baz: n,
c: {},
b: [],
},
}));
}

function main({ n, subscribers, checkSubscribers, objSize }) {
const channel = dc.channel('test');
for (let i = 0; i < subscribers; i++) {
channel.subscribe(noop);
}

const data = {
foo: 'bar',
const publishWithCheck = () => {
const data = createObj(objSize);
bench.start();
for (let i = 0; i < n; i++) {
if (channel.hasSubscribers) {
channel.publish(data);
}
}
bench.end(n);
};

bench.start();
for (let i = 0; i < n; i++) {
if (channel.hasSubscribers) {
const publishWithoutCheck = () => {
const data = createObj(objSize);
bench.start();
for (let i = 0; i < n; i++) {
channel.publish(data);
}
bench.end(n);
};

if (checkSubscribers) {
publishWithCheck();
} else {
publishWithoutCheck();
}
bench.end(n);
}

0 comments on commit 9e47209

Please sign in to comment.