node.js cluster: pipe

cluster.js

// Based on: https://github.com/nodejs/node-v0.x-archive/issues/5727

const cluster = require('cluster')
const net = require('net')

function runMaster () {
  cluster.setupMaster({ stdio: [0, 1, 2, 'ipc', 'pipe'] })
  const worker = cluster.fork()
  const pipe = worker.process.stdio[4]
  pipe.on('data', (buffer) => {
    console.log('master data:', buffer.toString())
  })
  pipe.write(Buffer.from('hello'))
}

function runWorker () {
  const pipe = new net.Socket({ fd: 4 })
  pipe.on('data', (buffer) => {
    console.log('worker data:', buffer.toString())
    pipe.write('world!')
  })
}

;(cluster.isMaster ? runMaster : runWorker)()