From 1a849853730556e0bc07b33f2fabb653389e3fa9 Mon Sep 17 00:00:00 2001 From: xtaci Date: Wed, 30 Sep 2020 19:04:24 +0800 Subject: [PATCH] use rlock for error notification --- sess.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sess.go b/sess.go index cd02163..e5ada2b 100644 --- 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() }) }