apps/mochi-mqtt
1
0
Fork 0
mirror of https://github.com/mochi-mqtt/server.git synced 2025-09-27 04:26:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

Protect close of nil outbound channel

Browse Source
This commit is contained in:
mochi-co
2023-04-21 22:00:27 +01:00
parent ed7fd836e1
commit 17fb7dadbc
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
clients.go
View File

@@ -364,7 +364,9 @@ func (cl *Client) Stop(err error) {
cl.State.stopCause.Store(err) cl.State.stopCause.Store(err)
} }
close(cl.State.outbound) if cl.State.outbound != nil {
close(cl.State.outbound)
}
atomic.StoreUint32(&cl.State.done, 1) atomic.StoreUint32(&cl.State.done, 1)
atomic.StoreInt64(&cl.State.disconnected, time.Now().Unix()) atomic.StoreInt64(&cl.State.disconnected, time.Now().Unix())