From 6927a889ab3ee4ec35e93602acdde7fdfcf5ed12 Mon Sep 17 00:00:00 2001
From: PascalCoinFreePool <pascalcoinfreepool@gmail.com>
Date: Tue, 8 Jan 2019 22:29:54 +0000
Subject: [PATCH] fix port user count

---
 lib/pool.js    | 4 ++--
 lib/stratum.js | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/lib/pool.js b/lib/pool.js
index b3c5af8..82a4348 100644
--- 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
index 2ef002b..1c4407b 100644
--- 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)