RanchiMall/node-stratum-pool
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

When clients disconnect new emit + memory clean up

Browse Source 
Replaced some console.log with console.error
This commit is contained in:
Andrea Baccega 2014-01-13 11:06:43 +01:00
parent 475dab8aab
commit 263972fcdc
3 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
example/coins/dogecoin.json
View File

@ -10,6 +10,6 @@
"host": "localhost", "host": "localhost",
"port": 19334, "port": 19334,
"user": "testnet", "user": "testnet",
"password": "AHhQYqfSZqzQvkSXAtHtDAbKaZaoPih3wfmJfgCtjRx9" "password": "testnet1"
} }
} }

11
index.js
View File

@ -76,15 +76,14 @@ var pool = module.exports = function pool(coin, authFn){
[coin.options.address], [coin.options.address],
function(error, result){ function(error, result){
if (error){ if (error){
console.log('validateaddress rpc error for ' + coin.options.name); console.error('validateaddress rpc error for ' + coin.options.name);
callback(error); callback(error);
} } else if (!result.isvalid) {
else if (!result.isvalid){ console.error('address is not valid for ' + coin.options.name);
console.log('address is not valid for ' + coin.options.name);
callback(error); callback(error);
} } else {
else
callback(error, result); callback(error, result);
}
} }
); );
}, },

6
libs/stratum.js
View File

@ -248,6 +248,10 @@ var StratumServer = exports.Server = function StratumServer(options){
); );
stratumClients[subscriptionId] = client; stratumClients[subscriptionId] = client;
_this.emit('client', client); _this.emit('client', client);
c.on('disconnect', function() {
delete stratumClients[subscriptionId];
_this.emit('client.disconnected', client);
});
}); });
_socketServer.listen(options.port, function(){ _socketServer.listen(options.port, function(){
_this.emit('started'); _this.emit('started');
@ -258,7 +262,7 @@ var StratumServer = exports.Server = function StratumServer(options){
//public members //public members
this.broadcastMiningJobs = function(jobParams){ this.broadcastMiningJobs = function(jobParams){
for (var clientId in stratumClients){ for (var clientId in stratumClients) {
stratumClients[clientId].sendMiningJob(jobParams) stratumClients[clientId].sendMiningJob(jobParams)
} }
}; };