fix fifo republish queue lookup

quorumcontrol · Sep 29, 2020 · ae5d9d2 · ae5d9d2
1 parent 6624aff
commit ae5d9d2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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))