upd

xtaci · xtaci · commit 06f03d2cfbb3 · 2016-08-16T15:42:53.000+08:00
diff --git a/sess.go b/sess.go
@@ -561,14 +561,11 @@ func (s *UDPSession) kcpInput(data []byte) {
 	if n := s.kcp.PeekSize(); n > 0 {
 		s.notifyReadEvent()
 	}
-	s.mu.Unlock()
-
 	if s.ackNoDelay {
-		s.mu.Lock()
 		s.kcp.current = currentMs()
 		s.kcp.flush()
-		s.mu.Unlock()
 	}
+	s.mu.Unlock()
 	atomic.AddUint64(&DefaultSnmp.InSegs, 1)
 }
 

Original file line number	Diff line number	Diff line change
`@@ -561,14 +561,11 @@ func (s *UDPSession) kcpInput(data []byte) {`
`561`	`561`	`if n := s.kcp.PeekSize(); n > 0 {`
`562`	`562`	`s.notifyReadEvent()`
`563`	`563`	`}`
`564`		`- s.mu.Unlock()`
`565`		`-`
`566`	`564`	`if s.ackNoDelay {`
`567`		`- s.mu.Lock()`
`568`	`565`	`s.kcp.current = currentMs()`
`569`	`566`	`s.kcp.flush()`
`570`		`- s.mu.Unlock()`
`571`	`567`	`}`
	`568`	`+ s.mu.Unlock()`
`572`	`569`	`atomic.AddUint64(&DefaultSnmp.InSegs, 1)`
`573`	`570`	`}`
`574`	`571`