diff --git a/peer.go b/peer.go
index 4b5daa02..a7f8d78f 100644
--- 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()