socket stuff

README.md

To use

node master&
node test&
# wait ~7 seconds
pkill -SIGINT -x test-server

master.js

'use strict';
const adios = require('adios');
const cluster = require('cluster');

if (cluster.isMaster) {
  process.title = 'test-server';
  adios.master.init('/tmp/test.sock')
    .then(() => {
      cluster.fork();
    });
}
else {
  const server = require('./test-server-express');
  adios.child.init(() => new Promise(resolve => {
    server.close(() => {
      console.log('closed');
      resolve();
    });
  }), '/tmp/test.sock');
}

package.json

{
  "name": "socket-stuff",
  "version": "1.0.0",
  "description": "",
  "main": "master.js",
  "dependencies": {
    "adios": "^1.1.2",
    "express": "^4.13.4"
  },
  "devDependencies": {},
  "scripts": {
    "test": "echo \"Error: no test specified\" && exit 1"
  },
  "author": "Elliott Foster <[email protected]> (http://codebrews.com/)",
  "license": "MIT"
}

test-server-express.js

'use strict';
const express = require('express');

const app = express();

app.use((req, res, next) => {
  req.socket.ref();
  res.on('finish', () => req.socket.unref());
  next();
});

app.get('/', (req, res) => {
  res.status(204).end();
});

module.exports = app.listen(3000, () => {
  console.log('listening');
});

test.js

'use strict';

const http = require('http');

const agent = new http.Agent({keepAlive: true});
new Promise(resolve => {
  http.get({
    hostname: '127.0.0.1',
    port: 3000,
    path: '/v3.4/videos',
    agent: agent
  }, res => {
    res.on('end', () => {
      console.log('req done');
      resolve();
    });
    res.resume();
  }).on('error', err => console.log(err));
}).then(() => {
  console.log('time keeps on ticking...');
  agent.freeSockets['127.0.0.1:3000:'][0].on('timeout', () => {
    console.log('socket timed out!');
    process.exit(0);
  });
  setInterval(() => console.log(`${Object.keys(agent.freeSockets).length} sockets`), 1000);
});

setTimeout(() => {
  http.get({
    hostname: '127.0.0.1',
    port: 3000,
    path: '/v3.4/videos',
    agent: agent
  }, res => {
    console.log(res.statusCode);
    res.on('end', () => {
      console.log('req2 done');
    });
    res.resume();
  }).on('error', err => console.log(err));
}, 5000);