Merge pull request #900 from nats-io/fix_budget_flush

Fixed use of flush budget for connections other than ROUTER
nats-io · Feb 7, 2019 · fe3289b · fe3289b
2 parents a733e67 + 235e7f9
commit fe3289b
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/server/client.go b/server/client.go
@@ -721,10 +721,11 @@ func (c *client) readLoop() {
 
 		// Budget to spend in place flushing outbound data.
 		// Client will be checked on several fronts to see
-		// if applicable. Routes will never wait in place.
-		budget := time.Millisecond
-		if c.kind == ROUTER {
-			budget = 0
+		// if applicable. Routes and Gateways will never
+		// wait in place.
+		var budget time.Duration
+		if c.kind == CLIENT {
+			budget = time.Millisecond
 		}
 
 		// Check pending clients for flush.