use rlock for error notification

haodreams · Sep 30, 2020 · 1a84985 · 1a84985
1 parent 608bd97
commit 1a84985
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sess.go b/sess.go
@@ -858,11 +858,11 @@ func (l *Listener) notifyReadError(err error) {
 		close(l.chSocketReadError)
 
 		// propagate read error to all sessions
-		l.sessionLock.Lock()
+		l.sessionLock.RLock()
 		for _, s := range l.sessions {
 			s.notifyReadError(err)
 		}
-		l.sessionLock.Unlock()
+		l.sessionLock.RUnlock()
 	})
 }