From 80c301c39693cc6f77c1772a1a13283e53dd9dcd Mon Sep 17 00:00:00 2001 From: David Symonds Date: Mon, 13 Apr 2015 09:24:25 +1000 Subject: [PATCH] Fix mutex error in (*inFlow).connOnRead. --- transport/control.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/transport/control.go b/transport/control.go index 4319ecaf..9d134a36 100644 --- a/transport/control.go +++ b/transport/control.go @@ -193,11 +193,11 @@ func (f *inFlow) onData(n uint32) error { // connOnRead updates the connection level states when the application consumes data. func (f *inFlow) connOnRead(n uint32) uint32 { - if n == 0 || f.conn != nil { - return 0 - } + if n == 0 || f.conn != nil { + return 0 + } f.mu.Lock() - f.mu.Unlock() + defer f.mu.Unlock() f.pendingData -= n f.pendingUpdate += n if f.pendingUpdate >= f.limit/4 {