From 7f66c853621cdb14a414af04615704e645857f76 Mon Sep 17 00:00:00 2001 From: hellcatz Date: Sat, 29 Apr 2017 13:07:09 -0700 Subject: [PATCH] Update shareProcessor.js --- libs/shareProcessor.js | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/libs/shareProcessor.js b/libs/shareProcessor.js index e6a8daa..7c3ca10 100644 --- a/libs/shareProcessor.js +++ b/libs/shareProcessor.js @@ -86,13 +86,14 @@ module.exports = function(logger, poolConfig){ if (_lastShareTimes[shareData.worker] != null && _lastShareTimes[shareData.worker] > 0) lastShareTime = _lastShareTimes[shareData.worker]; - _lastShareTimes[shareData.worker] = now; - var timeChangeSec = Math.round(Math.max(now - lastShareTime, 0) / 1000); // if its been less than 10 minutes since last share was submitted if (timeChangeSec < 600) { redisCommands.push(['hincrbyfloat', coin + ':shares:timesCurrent', shareData.worker, timeChangeSec]); } + + // track last time share + _lastShareTimes[shareData.worker] = now; } /* Stores share diff, worker, and unique value with a score that is the timestamp. Unique value ensures it