소스 검색

enforce a minimum drain rate

Brian Gough 7 년 전
부모
커밋
b3e5709b64
1개의 변경된 파일과 1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      services/real-time/app/coffee/DrainManager.coffee

+ 1 - 1
services/real-time/app/coffee/DrainManager.coffee

@@ -4,7 +4,7 @@ module.exports = DrainManager =
 
 
 	startDrainTimeWindow: (io, minsToDrain)->
 	startDrainTimeWindow: (io, minsToDrain)->
 		drainPerMin = io.sockets.clients().length / 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) ->
 	startDrain: (io, rate) ->
 		# Clear out any old interval
 		# Clear out any old interval