Skip to content
Snippets Groups Projects

Add a sync map for rounds received

1 file
+ 1
0
Compare changes
  • Side-by-side
  • Inline
+ 1
0
@@ -341,6 +341,7 @@ func (nb *Impl) ReceiveNotificationBatch(notifBatch *pb.NotificationBatch, auth
_, loaded := nb.roundStore.LoadOrStore(rid, time.Now())
if loaded {
jww.DEBUG.Printf("Dropping duplicate notification batch for round %+v", notifBatch.RoundID)
return nil
}
Loading