Update pool.js
clean up disconnected miners
This commit is contained in:
parent
22ab1981fc
commit
1d9bf4927f
1 changed files with 11 additions and 2 deletions
13
lib/pool.js
13
lib/pool.js
|
|
@ -1332,8 +1332,17 @@ function startPoolServerTcp(callback){
|
|||
socket.destroy()
|
||||
}).on('close', function(){
|
||||
pushMessage = function(){};
|
||||
if (socket.miner_ids) socket.miner_ids.forEach(miner_id => delete connectedMiners[miner_id]);
|
||||
socketMap.delete[socket]
|
||||
if (socket.miner_ids) {
|
||||
socket.miner_ids.forEach(miner_id => {
|
||||
let miner = connectedMiners[miner_id]
|
||||
if (!!miner) {
|
||||
log('warn', logSystem, 'Miner timed out and disconnected %s@%s', [miner.login, miner.ip]);
|
||||
delete miner;
|
||||
removeConnectedWorker(miner, 'timeout');
|
||||
}
|
||||
});
|
||||
}
|
||||
socketMap.delete[socket]
|
||||
});
|
||||
};
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue