Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
var client_connect = function(server, stream) {
console.log('Connect peer='+server.peer.host+":"+ server.peer.port+" my="+server.my.host+":"+ server.my.port+":"+server['no_output'])
stream = net.createConnection(server.peer.port, server.peer.host, { bind: server.my });
status.connections.client.connects++;
streamer(stream, {
closed: function() {
setTimeout(function() {
client_connect(server, stream);
}, 1000);
}
}, server)
}
servers.forEach(function(server) {
constructor({ host, port }) {
Log.debug('try connecting to', host, port, 'to download');
this.peer = { host, port };
this.timeOut = this.timeOut.bind(this);
this.client = net.createConnection(port, host, this.didConnect.bind(this));
this.client.on('error', (err) => {
this.errored = true;
if (this.timeoutTimer) clearTimeout(this.timeoutTimer);
this.onResult(false);
Log.debug('client connect error', err, host, port);
});
}
function createSocket() {
socket = net.createConnection(config.loggerPort || 5000, config.loggerHost || 'localhost');
socket.on('connect', function() {
emptyBuffer();
canWrite = true;
});
socket.on('timeout', socket.end.bind(socket));
//don't bother listening for 'error', 'close' gets called after that anyway
socket.on('close', createSocket);
}
function createSocket() {
socket = net.createConnection(config.loggerPort || 5000, config.loggerHost || 'localhost');
socket.on('connect', function() {
emptyBuffer();
canWrite = true;
});
socket.on('timeout', socket.end.bind(socket));
//don't bother listening for 'error', 'close' gets called after that anyway
socket.on('close', createSocket);
}
function createSocket() {
socket = net.createConnection(config.loggerPort || 5000, config.loggerHost || 'localhost');
socket.on('connect', function() {
emptyBuffer();
canWrite = true;
});
socket.on('timeout', socket.end.bind(socket));
//don't bother listening for 'error', 'close' gets called after that anyway
socket.on('close', createSocket);
}