/
githubmirror
/
node
Обзор
Документация
Войти
/
githubmirror
/
node
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
benchmark/dgram/multi-buffer.js
57 строк
1 KB
Bruno Rodrigues
benchmark: calibrate config dgram multi-buffer
14 сен 2025, 03:39
Не верифицирован
14 сен 2025, 03:39
5ed1a47
Код
Авторство
О чём код?
// test UDP send/recv throughput with the multi buffer API 'use strict'; const common = require('../common.js'); const dgram = require('dgram'); const PORT = common.PORT; // `n` is the number of send requests to queue up each time. // Keep it reasonably high (>10) otherwise you're benchmarking the speed of // event loop cycles more than anything else. const bench = common.createBenchmark(main, { len: [64, 512, 1024], n: [100], chunks: [1, 8], type: ['send', 'recv'], dur: [5], }); function main({ dur, len, n, type, chunks }) { const chunk = []; for (let i = 0; i < chunks; i++) { chunk.push(Buffer.allocUnsafe(Math.round(len / chunks))); } let sent = 0; let received = 0; const socket = dgram.createSocket('udp4'); function onsend() { if (sent++ % n === 0) { // The setImmediate() is necessary to have event loop progress on OSes // that only perform synchronous I/O on nonblocking UDP sockets. setImmediate(() => { for (let i = 0; i < n; i++) { socket.send(chunk, PORT, '127.0.0.1', onsend); } }); } } socket.on('listening', () => { bench.start(); onsend(); setTimeout(() => { const bytes = (type === 'send' ? sent : received) * len; const gbits = (bytes * 8) / (1024 * 1024 * 1024); bench.end(gbits); process.exit(0); }, dur * 1000); }); socket.on('message', () => { received++; }); socket.bind(PORT); }