gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-16 19:14:41 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #900 from nats-io/fix_budget_flush

Browse Source 
Fixed use of flush budget for connections other than ROUTER
This commit is contained in:
Ivan Kozlovic
2019-02-07 16:07:22 -07:00
committed by GitHub
parent a733e6781a 235e7f99dd
commit fe3289b1d6
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
server/client.go
View File

@@ -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.