'use strict';
-var common = require('../common');
-var assert = require('assert');
-var net = require('net');
+const common = require('../common');
+const assert = require('assert');
+const net = require('net');
-var buf = new Buffer(10 * 1024 * 1024);
+const buf = new Buffer(10 * 1024 * 1024);
buf.fill(0x62);
-var errs = [];
+const errs = [];
+var clientSocket;
+var serverSocket;
+
+function ready() {
+ if (clientSocket && serverSocket) {
+ clientSocket.destroy();
+ serverSocket.write(buf);
+ }
+}
var srv = net.createServer(function onConnection(conn) {
- conn.write(buf);
conn.on('error', function(err) {
errs.push(err);
if (errs.length > 1 && errs[0] === errs[1])
conn.on('close', function() {
srv.unref();
});
+ serverSocket = conn;
+ ready();
}).listen(common.PORT, function() {
var client = net.connect({ port: common.PORT });
client.on('connect', function() {
- client.destroy();
+ clientSocket = client;
+ ready();
});
});