diff options
Diffstat (limited to 'benchmark/net')
-rw-r--r-- | benchmark/net/net-c2s-cork.js | 18 | ||||
-rw-r--r-- | benchmark/net/net-c2s.js | 24 | ||||
-rw-r--r-- | benchmark/net/net-pipe.js | 24 | ||||
-rw-r--r-- | benchmark/net/net-s2c.js | 24 | ||||
-rw-r--r-- | benchmark/net/tcp-raw-c2s.js | 24 | ||||
-rw-r--r-- | benchmark/net/tcp-raw-pipe.js | 26 | ||||
-rw-r--r-- | benchmark/net/tcp-raw-s2c.js | 24 |
7 files changed, 82 insertions, 82 deletions
diff --git a/benchmark/net/net-c2s-cork.js b/benchmark/net/net-c2s-cork.js index 51ad09ae9e..a6582caa16 100644 --- a/benchmark/net/net-c2s-cork.js +++ b/benchmark/net/net-c2s-cork.js @@ -1,10 +1,10 @@ // test the speed of .pipe() with sockets 'use strict'; -var common = require('../common.js'); -var PORT = common.PORT; +const common = require('../common.js'); +const PORT = common.PORT; -var bench = common.createBenchmark(main, { +const bench = common.createBenchmark(main, { len: [4, 8, 16, 32, 64, 128, 512, 1024], type: ['buf'], dur: [5], @@ -40,7 +40,7 @@ function main(conf) { server(); } -var net = require('net'); +const net = require('net'); function Writer() { this.received = 0; @@ -65,15 +65,15 @@ Writer.prototype.emit = function() {}; Writer.prototype.prependListener = function() {}; function server() { - var writer = new Writer(); + const writer = new Writer(); // the actual benchmark. - var server = net.createServer(function(socket) { + const server = net.createServer(function(socket) { socket.pipe(writer); }); server.listen(PORT, function() { - var socket = net.connect(PORT); + const socket = net.connect(PORT); socket.on('connect', function() { bench.start(); @@ -81,8 +81,8 @@ function server() { send(); setTimeout(function() { - var bytes = writer.received; - var gbits = (bytes * 8) / (1024 * 1024 * 1024); + const bytes = writer.received; + const gbits = (bytes * 8) / (1024 * 1024 * 1024); bench.end(gbits); process.exit(0); }, dur * 1000); diff --git a/benchmark/net/net-c2s.js b/benchmark/net/net-c2s.js index 4bbea92121..140f9612ab 100644 --- a/benchmark/net/net-c2s.js +++ b/benchmark/net/net-c2s.js @@ -1,10 +1,10 @@ // test the speed of .pipe() with sockets 'use strict'; -var common = require('../common.js'); -var PORT = common.PORT; +const common = require('../common.js'); +const PORT = common.PORT; -var bench = common.createBenchmark(main, { +const bench = common.createBenchmark(main, { len: [102400, 1024 * 1024 * 16], type: ['utf', 'asc', 'buf'], dur: [5], @@ -40,7 +40,7 @@ function main(conf) { server(); } -var net = require('net'); +const net = require('net'); function Writer() { this.received = 0; @@ -66,8 +66,8 @@ Writer.prototype.prependListener = function() {}; function flow() { - var dest = this.dest; - var res = dest.write(chunk, encoding); + const dest = this.dest; + const res = dest.write(chunk, encoding); if (!res) dest.once('drain', this.flow); else @@ -87,24 +87,24 @@ Reader.prototype.pipe = function(dest) { function server() { - var reader = new Reader(); - var writer = new Writer(); + const reader = new Reader(); + const writer = new Writer(); // the actual benchmark. - var server = net.createServer(function(socket) { + const server = net.createServer(function(socket) { socket.pipe(writer); }); server.listen(PORT, function() { - var socket = net.connect(PORT); + const socket = net.connect(PORT); socket.on('connect', function() { bench.start(); reader.pipe(socket); setTimeout(function() { - var bytes = writer.received; - var gbits = (bytes * 8) / (1024 * 1024 * 1024); + const bytes = writer.received; + const gbits = (bytes * 8) / (1024 * 1024 * 1024); bench.end(gbits); process.exit(0); }, dur * 1000); diff --git a/benchmark/net/net-pipe.js b/benchmark/net/net-pipe.js index 507640f8ce..a8ae50edfb 100644 --- a/benchmark/net/net-pipe.js +++ b/benchmark/net/net-pipe.js @@ -1,10 +1,10 @@ // test the speed of .pipe() with sockets 'use strict'; -var common = require('../common.js'); -var PORT = common.PORT; +const common = require('../common.js'); +const PORT = common.PORT; -var bench = common.createBenchmark(main, { +const bench = common.createBenchmark(main, { len: [102400, 1024 * 1024 * 16], type: ['utf', 'asc', 'buf'], dur: [5], @@ -40,7 +40,7 @@ function main(conf) { server(); } -var net = require('net'); +const net = require('net'); function Writer() { this.received = 0; @@ -66,8 +66,8 @@ Writer.prototype.prependListener = function() {}; function flow() { - var dest = this.dest; - var res = dest.write(chunk, encoding); + const dest = this.dest; + const res = dest.write(chunk, encoding); if (!res) dest.once('drain', this.flow); else @@ -87,16 +87,16 @@ Reader.prototype.pipe = function(dest) { function server() { - var reader = new Reader(); - var writer = new Writer(); + const reader = new Reader(); + const writer = new Writer(); // the actual benchmark. - var server = net.createServer(function(socket) { + const server = net.createServer(function(socket) { socket.pipe(socket); }); server.listen(PORT, function() { - var socket = net.connect(PORT); + const socket = net.connect(PORT); socket.on('connect', function() { bench.start(); @@ -106,8 +106,8 @@ function server() { setTimeout(function() { // multiply by 2 since we're sending it first one way // then then back again. - var bytes = writer.received * 2; - var gbits = (bytes * 8) / (1024 * 1024 * 1024); + const bytes = writer.received * 2; + const gbits = (bytes * 8) / (1024 * 1024 * 1024); bench.end(gbits); process.exit(0); }, dur * 1000); diff --git a/benchmark/net/net-s2c.js b/benchmark/net/net-s2c.js index 9148a66f3a..9fec2d8577 100644 --- a/benchmark/net/net-s2c.js +++ b/benchmark/net/net-s2c.js @@ -1,10 +1,10 @@ // test the speed of .pipe() with sockets 'use strict'; -var common = require('../common.js'); -var PORT = common.PORT; +const common = require('../common.js'); +const PORT = common.PORT; -var bench = common.createBenchmark(main, { +const bench = common.createBenchmark(main, { len: [102400, 1024 * 1024 * 16], type: ['utf', 'asc', 'buf'], dur: [5] @@ -40,7 +40,7 @@ function main(conf) { server(); } -var net = require('net'); +const net = require('net'); function Writer() { this.received = 0; @@ -66,8 +66,8 @@ Writer.prototype.prependListener = function() {}; function flow() { - var dest = this.dest; - var res = dest.write(chunk, encoding); + const dest = this.dest; + const res = dest.write(chunk, encoding); if (!res) dest.once('drain', this.flow); else @@ -87,24 +87,24 @@ Reader.prototype.pipe = function(dest) { function server() { - var reader = new Reader(); - var writer = new Writer(); + const reader = new Reader(); + const writer = new Writer(); // the actual benchmark. - var server = net.createServer(function(socket) { + const server = net.createServer(function(socket) { reader.pipe(socket); }); server.listen(PORT, function() { - var socket = net.connect(PORT); + const socket = net.connect(PORT); socket.on('connect', function() { bench.start(); socket.pipe(writer); setTimeout(function() { - var bytes = writer.received; - var gbits = (bytes * 8) / (1024 * 1024 * 1024); + const bytes = writer.received; + const gbits = (bytes * 8) / (1024 * 1024 * 1024); bench.end(gbits); process.exit(0); }, dur * 1000); diff --git a/benchmark/net/tcp-raw-c2s.js b/benchmark/net/tcp-raw-c2s.js index 87c6d5ec7e..9b2e926d69 100644 --- a/benchmark/net/tcp-raw-c2s.js +++ b/benchmark/net/tcp-raw-c2s.js @@ -2,22 +2,22 @@ // as many bytes as we can in the specified time (default = 10s) 'use strict'; -var common = require('../common.js'); -var util = require('util'); +const common = require('../common.js'); +const util = require('util'); // if there are --dur=N and --len=N args, then // run the function with those settings. // if not, then queue up a bunch of child processes. -var bench = common.createBenchmark(main, { +const bench = common.createBenchmark(main, { len: [102400, 1024 * 1024 * 16], type: ['utf', 'asc', 'buf'], dur: [5] }); -var TCP = process.binding('tcp_wrap').TCP; -var TCPConnectWrap = process.binding('tcp_wrap').TCPConnectWrap; -var WriteWrap = process.binding('stream_wrap').WriteWrap; -var PORT = common.PORT; +const TCP = process.binding('tcp_wrap').TCP; +const TCPConnectWrap = process.binding('tcp_wrap').TCPConnectWrap; +const WriteWrap = process.binding('stream_wrap').WriteWrap; +const PORT = common.PORT; var dur; var len; @@ -36,7 +36,7 @@ function fail(err, syscall) { } function server() { - var serverHandle = new TCP(); + const serverHandle = new TCP(); var err = serverHandle.bind('127.0.0.1', PORT); if (err) fail(err, 'bind'); @@ -92,9 +92,9 @@ function client() { throw new Error(`invalid type: ${type}`); } - var clientHandle = new TCP(); - var connectReq = new TCPConnectWrap(); - var err = clientHandle.connect(connectReq, '127.0.0.1', PORT); + const clientHandle = new TCP(); + const connectReq = new TCPConnectWrap(); + const err = clientHandle.connect(connectReq, '127.0.0.1', PORT); if (err) fail(err, 'connect'); @@ -110,7 +110,7 @@ function client() { }; function write() { - var writeReq = new WriteWrap(); + const writeReq = new WriteWrap(); writeReq.oncomplete = afterWrite; var err; switch (type) { diff --git a/benchmark/net/tcp-raw-pipe.js b/benchmark/net/tcp-raw-pipe.js index c6d319c64d..204b27b965 100644 --- a/benchmark/net/tcp-raw-pipe.js +++ b/benchmark/net/tcp-raw-pipe.js @@ -2,22 +2,22 @@ // as many bytes as we can in the specified time (default = 10s) 'use strict'; -var common = require('../common.js'); -var util = require('util'); +const common = require('../common.js'); +const util = require('util'); // if there are --dur=N and --len=N args, then // run the function with those settings. // if not, then queue up a bunch of child processes. -var bench = common.createBenchmark(main, { +const bench = common.createBenchmark(main, { len: [102400, 1024 * 1024 * 16], type: ['utf', 'asc', 'buf'], dur: [5] }); -var TCP = process.binding('tcp_wrap').TCP; -var TCPConnectWrap = process.binding('tcp_wrap').TCPConnectWrap; -var WriteWrap = process.binding('stream_wrap').WriteWrap; -var PORT = common.PORT; +const TCP = process.binding('tcp_wrap').TCP; +const TCPConnectWrap = process.binding('tcp_wrap').TCPConnectWrap; +const WriteWrap = process.binding('stream_wrap').WriteWrap; +const PORT = common.PORT; var dur; var len; @@ -35,7 +35,7 @@ function fail(err, syscall) { } function server() { - var serverHandle = new TCP(); + const serverHandle = new TCP(); var err = serverHandle.bind('127.0.0.1', PORT); if (err) fail(err, 'bind'); @@ -54,7 +54,7 @@ function server() { if (nread < 0) fail(nread, 'read'); - var writeReq = new WriteWrap(); + const writeReq = new WriteWrap(); writeReq.async = false; err = clientHandle.writeBuffer(writeReq, buffer); @@ -89,9 +89,9 @@ function client() { throw new Error(`invalid type: ${type}`); } - var clientHandle = new TCP(); - var connectReq = new TCPConnectWrap(); - var err = clientHandle.connect(connectReq, '127.0.0.1', PORT); + const clientHandle = new TCP(); + const connectReq = new TCPConnectWrap(); + const err = clientHandle.connect(connectReq, '127.0.0.1', PORT); var bytes = 0; if (err) @@ -124,7 +124,7 @@ function client() { }; function write() { - var writeReq = new WriteWrap(); + const writeReq = new WriteWrap(); writeReq.oncomplete = afterWrite; var err; switch (type) { diff --git a/benchmark/net/tcp-raw-s2c.js b/benchmark/net/tcp-raw-s2c.js index 1c518a5c7f..412ded7355 100644 --- a/benchmark/net/tcp-raw-s2c.js +++ b/benchmark/net/tcp-raw-s2c.js @@ -2,22 +2,22 @@ // as many bytes as we can in the specified time (default = 10s) 'use strict'; -var common = require('../common.js'); -var util = require('util'); +const common = require('../common.js'); +const util = require('util'); // if there are dur=N and len=N args, then // run the function with those settings. // if not, then queue up a bunch of child processes. -var bench = common.createBenchmark(main, { +const bench = common.createBenchmark(main, { len: [102400, 1024 * 1024 * 16], type: ['utf', 'asc', 'buf'], dur: [5] }); -var TCP = process.binding('tcp_wrap').TCP; -var TCPConnectWrap = process.binding('tcp_wrap').TCPConnectWrap; -var WriteWrap = process.binding('stream_wrap').WriteWrap; -var PORT = common.PORT; +const TCP = process.binding('tcp_wrap').TCP; +const TCPConnectWrap = process.binding('tcp_wrap').TCPConnectWrap; +const WriteWrap = process.binding('stream_wrap').WriteWrap; +const PORT = common.PORT; var dur; var len; @@ -35,7 +35,7 @@ function fail(err, syscall) { } function server() { - var serverHandle = new TCP(); + const serverHandle = new TCP(); var err = serverHandle.bind('127.0.0.1', PORT); if (err) fail(err, 'bind'); @@ -69,7 +69,7 @@ function server() { write(); function write() { - var writeReq = new WriteWrap(); + const writeReq = new WriteWrap(); writeReq.async = false; writeReq.oncomplete = afterWrite; var err; @@ -107,9 +107,9 @@ function server() { } function client() { - var clientHandle = new TCP(); - var connectReq = new TCPConnectWrap(); - var err = clientHandle.connect(connectReq, '127.0.0.1', PORT); + const clientHandle = new TCP(); + const connectReq = new TCPConnectWrap(); + const err = clientHandle.connect(connectReq, '127.0.0.1', PORT); if (err) fail(err, 'connect'); |