We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 13681ac commit 68a9aefCopy full SHA for 68a9aef
1 file changed
proxy/pubsub.go
@@ -41,7 +41,7 @@ const (
41
// enabling the client to execute regular Redis commands without reconnecting.
42
type pubsubSession struct {
43
mu sync.Mutex // protects upstream, closed, and shadow; channelSet/patternSet/txn are goroutine-confined to commandLoop
44
- writeMu sync.Mutex // serializes writes to dconn; never held across state operations
+ writeMu sync.Mutex // serializes writes to dconn; may be held while acquiring mu (lock ordering: writeMu then mu)
45
dconn redcon.DetachedConn
46
upstream *redis.PubSub // nil when not in pub/sub mode
47
proxy *ProxyServer
0 commit comments