benchmark: chunky http client benchmark variation and server

benchmark/net/chunky_http_client.js

@@ -0,0 +1,104 @@
+"use strict";
+// test HTTP throughput in fragmented header case
+var common = require('../common.js');
+var net = require('net');
+var test = require('../../test/common.js');
+
+var bench = common.createBenchmark(main, {
+//  len: [1, 4, 8, 16, 32, 64, 128],
+  len: [1],
+  num: [5, 50, 500, 2000],
+  type: ['send'],
+}
+)
+
+
+function main(conf) {
+  var len;
+  var num;
+  var type;
+  num = +conf.num;
+  len = +conf.len;
+  type = conf.type;
+  var todo = [];
+  var headers = [];
+  // Chose 7 because 9 showed "Connection error" / "Connection closed"
+  // An odd number could result in a better length dispersion.
+  for (var i = 7; i <= 7*7*7; i *= 7)
+    headers.push(Array(i + 1).join('o'));
+
+  function WriteWithCRLF(line) {
+    todo.push(line + '\r\n');
+  }
+
+  function WriteHTTPHeaders(channel, has_keep_alive, extra_header_count) {
+    todo = []
+    WriteWithCRLF('GET / HTTP/1.1');
+    WriteWithCRLF('Host: localhost');
+    WriteWithCRLF('Connection: keep-alive');
+    WriteWithCRLF('Accept: text/html,application/xhtml+xml,' +
+                           'application/xml;q=0.9,image/webp,*/*;q=0.8');
+    WriteWithCRLF('User-Agent: Mozilla/5.0 (X11; Linux x86_64) ' +
+                           'AppleWebKit/537.36 (KHTML, like Gecko) ' +
+                           'Chrome/39.0.2171.71 Safari/537.36');
+    WriteWithCRLF('Accept-Encoding: gzip, deflate, sdch');
+    WriteWithCRLF('Accept-Language: en-US,en;q=0.8');
+    for (var i = 0; i < extra_header_count; i++) {
+      // Utilize first three powers of a small integer for an odd cycle and
+      // because the fourth power of some integers overloads the server.
+      WriteWithCRLF('X-Header-' + i + ': ' + headers[i%3]);
+    }
+    WriteWithCRLF('');
+    todo = todo.join('');
+    // Using odd numbers in many places may increase length coverage.
+    var chunksize = 37;
+    for (i = 0; i < todo.length; i+=chunksize) {
+      var cur = todo.slice(i,i+chunksize);
+      channel.write(cur);
+    }
+  }
+
+  var success = 0, failure = 0, min = 10, size = 0;
+  var mod = 317, mult = 17, add = 11;
+  var count = 0;
+  var PIPE = test.PIPE;
+  var socket = net.connect(PIPE, function() {
+    bench.start();
+    WriteHTTPHeaders(socket, 1, +conf.len);
+    socket.setEncoding('utf8')
+    socket.on('data', function(d) {
+      var did = false;
+      var pattern = 'HTTP/1.1 200 OK\r\n';
+      if ((d.length === pattern.length && d === pattern) ||
+          (d.length > pattern.length &&
+           d.slice(0, pattern.length) === pattern)) {
+        success += 1;
+        did = true;
+      } else {
+        pattern = 'HTTP/1.1 '
+        if ((d.length === pattern.length && d === pattern) ||
+            (d.length > pattern.length &&
+             d.slice(0, pattern.length) === pattern)) {
+          failure += 1;
+          did = true;
+        }
+      }
+      size = (size * mult + add) % mod;
+      if (did) {
+        count += 1;
+        if (count === num) {
+          bench.end(count);
+        } else {
+          WriteHTTPHeaders(socket, 1, min + size);
+        }
+      }
+    });
+  socket.on('close', function() {
+    console.log('Connection closed');
+    });
+
+  socket.on('error', function() {
+    console.log('Connection error');
+    });
+  });
+}

benchmark/net/http_server_for_chunky_client.js

@@ -0,0 +1,45 @@
+"use strict";
+var path = require('path');
+var http = require('http');
+var fs = require('fs');
+var spawn = require('child_process').spawn;
+var common = require('../common.js')
+var test = require('../../test/common.js')
+var pep = path.dirname(process.argv[1])+'/chunky_http_client.js';
+var PIPE = test.PIPE;
+
+var server;
+
+fs.unlinkSync(PIPE);
+server = http.createServer(function(req, res) {
+  res.writeHead(200, { 'content-type': 'text/plain',
+                       'content-length': '2' });
+  res.end('ok');
+});
+
+server.on('error', function(err) {
+  console.log("Error:");
+  console.log(err);
+});
+
+try {
+  server.listen(PIPE, 'localhost');
+} catch(e) {
+  console.log("oops!");
+  console.log(e);
+}
+
+var child = spawn(process.execPath, [pep], { });
+child.on('error', function(err) {
+  console.log('spawn error.');
+  console.log(err);
+});
+
+child.stdout.on('data', function (data) {
+  process.stdout.write(data);
+});
+
+child.on('exit', function (exitCode) {
+  console.log("Child exited with code: " + exitCode);
+  process.exit(0);
+});