checking message not nil before processing

renproject · Sep 10, 2021 · dacda95 · dacda95
1 parent 0c4e34f
commit dacda95
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/mq/mq.go b/mq/mq.go
@@ -36,6 +36,10 @@ func New(opts Options) MessageQueue {
 func (mq *MessageQueue) Consume(h process.Height, propose func(process.Propose), prevote func(process.Prevote), precommit func(process.Precommit), procsAllowed map[id.Signatory]bool) (n int) {
 	for from, q := range mq.queuesByPid {
 		for len(q) > 0 {
+			if q[0] == nil || height(q[0]) > h {
+				break
+			}
+
 			func() {
 				defer func() {
 					n++