From 1d9bf4927f9dff98d1929ef67fbc1aada632b209 Mon Sep 17 00:00:00 2001 From: muscleman Date: Sat, 29 Jan 2022 15:56:23 -0600 Subject: [PATCH] Update pool.js clean up disconnected miners --- lib/pool.js | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/lib/pool.js b/lib/pool.js index 6d36957..90e02b8 100644 --- a/lib/pool.js +++ b/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] }); };