From ae5d9d2ea04280715f78bfdb1a0d564c00d76eaf Mon Sep 17 00:00:00 2001 From: Brandon Westcott Date: Mon, 28 Sep 2020 21:28:27 -0400 Subject: [PATCH] fix fifo republish queue lookup --- signer/gossip/node.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/signer/gossip/node.go b/signer/gossip/node.go index 1c4ce86c..b645a78c 100644 --- a/signer/gossip/node.go +++ b/signer/gossip/node.go @@ -465,7 +465,7 @@ func (n *Node) publishCompletedRound(ctx context.Context, round *round) error { } func (n *Node) republishCompletedRound(ctx context.Context, round *round) error { - roundConfPayload, ok := n.roundRepublishCache.Peek(round) // Peek acts as FIFO based on insert above + roundConfPayload, ok := n.roundRepublishCache.Peek(round.height) // Peek acts as FIFO based on insert above if ok { n.logger.Debugf("republishing round confirmed to: %s", n.notaryGroup.ID) return n.pubsub.Publish(n.notaryGroup.ID, roundConfPayload.([]byte))