peer: ensure we unlock the msgCond during peer msgConsumer exit

2025-08-03 10:12:28 +02:00 · 2018-09-03 17:03:00 -07:00
parent 2b448be048
commit edf304ad8b
1 changed files with 1 additions and 0 deletions
--- a/peer.go
+++ b/peer.go
@@ -769,6 +769,7 @@ func (ms *msgStream) msgConsumer() {
 			// items.
 			select {
 			case <-ms.peer.quit:
+				ms.msgCond.L.Unlock()
 				return
 			case <-ms.quit:
 				ms.msgCond.L.Unlock()