/
usr
/
local
/
lib
/
node_modules
/
pm2
/
node_modules
/
pm2-axon
/
lib
/
plugins
/
/usr/local/lib/node_modules/pm2/node_modules/pm2-axon/lib/plugins
mkdir
upload
Name
Size
Mode
Actions
queue.js
1237
0644
edit
dl
rm
round-robin.js
873
0644
edit
dl
rm
Edit:
/usr/local/lib/node_modules/pm2/node_modules/pm2-axon/lib/plugins/round-robin.js
(873B)
/** * Deps. */ var slice = require('../utils').slice; /** * Round-robin plugin. * * Provides a `send` method which will * write the `msg` to all connected peers. * * @param {Object} options * @api private */ module.exports = function(options){ options = options || {}; var fallback = options.fallback || function(){}; return function(sock){ /** * Bind callback to `sock`. */ fallback = fallback.bind(sock); /** * Initialize counter. */ var n = 0; /** * Sends `msg` to all connected peers round-robin. */ sock.send = function(){ var socks = this.socks; var len = socks.length; var sock = socks[n++ % len]; var msg = slice(arguments); if (sock && sock.writable) { sock.write(this.pack(msg)); } else { fallback(msg); } }; }; };
Save
cmd:
run