test: split test in parallel/sequential

Reviewed-By: Ben Noordhuis <info@bnoordhuis.nl>
PR-URL: https://github.com/iojs/io.js/pull/172
Fix: iojs/io.js#139

1 files changed, 112 insertions, 0 deletions

diff --git a/test/parallel/test-net-binary.js b/test/parallel/test-net-binary.js
new file mode 100644
index 0000000000..3100465846
--- /dev/null
+++ b/test/parallel/test-net-binary.js
@@ -0,0 +1,112 @@
+// Copyright Joyent, Inc. and other Node contributors.
+//
+// Permission is hereby granted, free of charge, to any person obtaining a
+// copy of this software and associated documentation files (the
+// "Software"), to deal in the Software without restriction, including
+// without limitation the rights to use, copy, modify, merge, publish,
+// distribute, sublicense, and/or sell copies of the Software, and to permit
+// persons to whom the Software is furnished to do so, subject to the
+// following conditions:
+//
+// The above copyright notice and this permission notice shall be included
+// in all copies or substantial portions of the Software.
+//
+// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
+// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
+// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
+// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
+// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
+// USE OR OTHER DEALINGS IN THE SOFTWARE.
+
+var common = require('../common');
+var assert = require('assert');
+var net = require('net');
+
+var binaryString = '';
+for (var i = 255; i >= 0; i--) {
+  var s = '\'\\' + i.toString(8) + '\'';
+  var S = eval(s);
+  common.error(s +
+               ' ' +
+               JSON.stringify(S) +
+               ' ' +
+               JSON.stringify(String.fromCharCode(i)) +
+               ' ' +
+               S.charCodeAt(0));
+  assert.ok(S.charCodeAt(0) == i);
+  assert.ok(S == String.fromCharCode(i));
+  binaryString += S;
+}
+
+// safe constructor
+var echoServer = net.Server(function(connection) {
+  console.error('SERVER got connection');
+  connection.setEncoding('binary');
+  connection.on('data', function(chunk) {
+    common.error('SERVER recved: ' + JSON.stringify(chunk));
+    connection.write(chunk, 'binary');
+  });
+  connection.on('end', function() {
+    console.error('SERVER ending');
+    connection.end();
+  });
+});
+echoServer.listen(common.PORT);
+
+var recv = '';
+
+echoServer.on('listening', function() {
+  console.error('SERVER listening');
+  var j = 0;
+  var c = net.createConnection({
+    port: common.PORT
+  });
+
+  c.setEncoding('binary');
+  c.on('data', function(chunk) {
+    console.error('CLIENT data %j', chunk);
+    var n = j + chunk.length;
+    while (j < n && j < 256) {
+      common.error('CLIENT write ' + j);
+      c.write(String.fromCharCode(j), 'binary');
+      j++;
+    }
+    if (j === 256) {
+      console.error('CLIENT ending');
+      c.end();
+    }
+    recv += chunk;
+  });
+
+  c.on('connect', function() {
+    console.error('CLIENT connected, writing');
+    c.write(binaryString, 'binary');
+  });
+
+  c.on('close', function() {
+    console.error('CLIENT closed');
+    console.dir(recv);
+    echoServer.close();
+  });
+
+  c.on('finish', function() {
+    console.error('CLIENT finished');
+  });
+});
+
+process.on('exit', function() {
+  console.log('recv: ' + JSON.stringify(recv));
+
+  assert.equal(2 * 256, recv.length);
+
+  var a = recv.split('');
+
+  var first = a.slice(0, 256).reverse().join('');
+  console.log('first: ' + JSON.stringify(first));
+
+  var second = a.slice(256, 2 * 256).join('');
+  console.log('second: ' + JSON.stringify(second));
+
+  assert.equal(first, second);
+});