Software: Apache. PHP/8.1.30 

uname -a: Linux server1.tuhinhossain.com 5.15.0-163-generic #173-Ubuntu SMP Tue Oct 14 17:51:00 UTC
2025 x86_64 

uid=1002(picotech) gid=1003(picotech) groups=1003(picotech),0(root)  

Safe-mode: OFF (not secure)

/home/picotech/.nvm/versions/node/v18.17.1/lib/node_modules/pm2/node_modules/pm2-axon/lib/sockets/   drwxr-xr-x
Free 23.59 GB of 117.98 GB (19.99%)
                            Encoder    Tools    Proc.    FTP brute    Sec.    SQL    PHP-code    Update    Self remove    Logout    

Viewing file:     pub.js (1.14 KB)      -rw-r--r--

/**
 * Module dependencies.
 */

var Socket = require('./sock');
var slice = require('../utils').slice;

/**
 * Expose `PubSocket`.
 */

module.exports = PubSocket;

/**
 * Initialize a new `PubSocket`.
 *
 * @api private
 */

function PubSocket() {
  Socket.call(this);
}

/**
 * Inherits from `Socket.prototype`.
 */

PubSocket.prototype.__proto__ = Socket.prototype;

/**
 * Send `msg` to all established peers.
 *
 * @param {Mixed} msg
 * @api public
 */

PubSocket.prototype.send = function(msg){
  var socks = this.socks;
  var len = socks.length;
  var buf = this.pack(arguments);

  for (var sock of socks) {
      if (sock.writable) sock.write(buf);
  }

  return this;
};

PubSocket.prototype.sendv2 = function(data, cb){
  var socks = this.socks;
  var len = socks.length;
  var sock;

  if (len == 0)
    return process.nextTick(cb);

  var buf = this.pack([data]);

  var i = 0;

  socks.forEach(function(sock) {
    if (sock.writable)
      sock.write(buf, function() {
        i++;
        if (i == len)
          process.nextTick(cb);
      });
    else {
      i++;
      if (i == len)
        process.nextTick(cb);
    }
  });

  return this;
};