From b3e5709b649be38aeef72a1f86ccfb537013a4cf Mon Sep 17 00:00:00 2001 From: Brian Gough Date: Tue, 13 Aug 2019 16:15:30 +0100 Subject: [PATCH] enforce a minimum drain rate --- services/real-time/app/coffee/DrainManager.coffee | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/services/real-time/app/coffee/DrainManager.coffee b/services/real-time/app/coffee/DrainManager.coffee index a71ffa8ed9..2219291267 100644 --- a/services/real-time/app/coffee/DrainManager.coffee +++ b/services/real-time/app/coffee/DrainManager.coffee @@ -4,7 +4,7 @@ module.exports = DrainManager = startDrainTimeWindow: (io, minsToDrain)-> drainPerMin = io.sockets.clients().length / minsToDrain - DrainManager.startDrain(io, drainPerMin / 60) + DrainManager.startDrain(io, Math.max(drainPerMin / 60, 4)) # enforce minimum drain rate startDrain: (io, rate) -> # Clear out any old interval