fix data race

sijms · May 2, 2024 · 032d50b · 032d50b
1 parent b676477
commit 032d50b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/v2/network/session.go b/v2/network/session.go
@@ -166,8 +166,10 @@ func (session *Session) LoadState() (oldState *SessionState) {
 }
 
 func (session *Session) resetWrite() {
+	session.mu.Lock()
 	session.sendPcks = nil
 	session.outBuffer.Reset()
+	session.mu.Unlock()
 }
 func (session *Session) resetRead() {
 	session.inBuffer = nil
@@ -679,9 +681,7 @@ func (session *Session) Write() error {
 func (session *Session) processMarker() error {
 	var err error
 	// send reset connection
-	session.mu.Lock()
 	session.resetWrite()
-	session.mu.Unlock()
 	marker := newMarkerPacket(marker_type_reset, session.Context)
 	err = session.writePacket(marker)
 	if err != nil {