gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1252 from nats-io/updates_prior_to_release

Browse Source 
Remove debug trace in writeLoop
This commit is contained in:
Ivan Kozlovic
2020-01-17 12:40:16 -07:00
committed by GitHub
parent e758c7be1b e94f1b7afb
commit 1553a784c3
1 changed files with 0 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
server/client.go
View File

@@ -773,10 +773,8 @@ func (c *client) writeLoop() {
if close = c.flags.isSet(closeConnection); !close {
owtf := c.out.fsp > 0 && c.out.pb < maxBufSize && c.out.fsp < maxFlushPending
if waitOk && (c.out.pb == 0 || owtf) {
fspBeforeWait := c.out.fsp
c.mu.Unlock()
var timeout bool
// Reset our timer
t.Reset(maxWait)
@@ -784,14 +782,10 @@ func (c *client) writeLoop() {
select {
case <-ch:
case <-t.C:
timeout = true
}
c.mu.Lock()
close = c.flags.isSet(closeConnection)
if !close && timeout && fspBeforeWait > 0 && c.out.fsp > 0 {
c.Warnf("Entered wait with fsp=%v and was not signaled within timeout", fspBeforeWait)
}
}
}
if close {