use rlock for error notification

2024-04-21 12:32:15 +00:00 · 2020-09-30 19:04:24 +08:00
parent 608bd97d7b
commit 1a84985373
1 changed files with 2 additions and 2 deletions
@@ -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()
 	})
 }