upd

xtaci · Aug 16, 2016 · 06f03d2 · 06f03d2
1 parent d552626
commit 06f03d2
Showing 1 changed file with 1 addition and 4 deletions.
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)
 }