benchmark/throughput.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

var fork = require('child_process').fork;
var net = require('net');
var buffer = new Buffer(1024 * 1024);

function write(socket) {
  if (!socket.writable) return;

  socket.write(buffer, function() {
    write(socket);
  });
}

var server = net.createServer(function(socket) {
  server.close();
  write(socket);
});

server.listen(8000, function() {
  fork(__dirname + '/throughput-child.js');
});