fix port user count

pascal-triangle · Jan 8, 2019 · 6927a88 · 6927a88
1 parent 7464762
commit 6927a88
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/lib/pool.js b/lib/pool.js
@@ -193,8 +193,8 @@ var waitForFirstJob = setInterval(() => {
 
     });
 
-    stratumServer.on("log", function(severity, message) {
-	log(severity, logSystem, message);
+    stratumServer.on("log", function(severity, message, data) {
+	log(severity, logSystem, message, data);
     });
 
     stratumServer.on("started", function() {

diff --git a/lib/stratum.js b/lib/stratum.js
@@ -411,10 +411,10 @@ var StratumServer = exports.Server = function StratumServer(authorizeFn) {
         var serversStarted = 0;
 	config.poolServer.ports.forEach(function(portCfg) {
 	    if(portCfg.port && portCfg.diff) {
+		_this.emit("log", "info", "Clear values for port %s in redis database.", [portCfg.port]);
+		redisClient.del(redisPrefix + ':ports:' + portCfg.port);
+		redisClient.hset(redisPrefix + ':ports:' + portCfg.port, 'port', portCfg.port);
 		net.createServer({allowHalfOpen: false}, function(socket) {
-		    _this.emit("log", "info", "Clear values for port %s in redis database.", [portCfg.port]);
-		    redisClient.del(redisPrefix + ':ports:' + portCfg.port);
-		    redisClient.hset(redisPrefix + ':ports:' + portCfg.port, 'port', portCfg.port);
                     _this.handleNewClient(socket);
 		}).listen(parseInt(portCfg.port), function() {
                     if(++serversStarted == Object.keys(config.poolServer.ports).length)