'use strict'; var NUM_WORKERS = 4; var PACKETS_PER_WORKER = 10; var assert = require('assert'); var cluster = require('cluster'); var common = require('../common'); var dgram = require('dgram'); if (common.isWindows) { console.log('1..0 # Skipped: dgram clustering is currently not supported ' + 'on windows.'); return; } if (cluster.isMaster) master(); else worker(); function master() { var listening = 0; // Fork 4 workers. for (var i = 0; i < NUM_WORKERS; i++) cluster.fork(); // Wait until all workers are listening. cluster.on('listening', function() { if (++listening < NUM_WORKERS) return; // Start sending messages. var buf = Buffer.from('hello world'); var socket = dgram.createSocket('udp4'); var sent = 0; doSend(); function doSend() { socket.send(buf, 0, buf.length, common.PORT, '127.0.0.1', afterSend); } function afterSend() { sent++; if (sent < NUM_WORKERS * PACKETS_PER_WORKER) { doSend(); } else { console.log('master sent %d packets', sent); socket.close(); } } }); // Set up event handlers for every worker. Each worker sends a message when // it has received the expected number of packets. After that it disconnects. for (var key in cluster.workers) { if (cluster.workers.hasOwnProperty(key)) setupWorker(cluster.workers[key]); } function setupWorker(worker) { var received = 0; worker.on('message', function(msg) { received = msg.received; console.log('worker %d received %d packets', worker.id, received); }); worker.on('disconnect', function() { assert(received === PACKETS_PER_WORKER); console.log('worker %d disconnected', worker.id); }); } } function worker() { var received = 0; // Create udp socket and start listening. var socket = dgram.createSocket('udp4'); socket.on('message', function(data, info) { received++; // Every 10 messages, notify the master. if (received == PACKETS_PER_WORKER) { process.send({received: received}); process.disconnect(); } }); socket.bind(common.PORT); }