From 0fa81262fc887e080c49b9bef469fbc0f0c7dc95 Mon Sep 17 00:00:00 2001 From: Al Cutter Date: Wed, 23 Oct 2024 15:35:18 +0100 Subject: [PATCH] Update aggregated checkpoints even with same size (#243) --- cmd/internal/distributor/distributor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/internal/distributor/distributor.go b/cmd/internal/distributor/distributor.go index 5912282..eddabbf 100644 --- a/cmd/internal/distributor/distributor.go +++ b/cmd/internal/distributor/distributor.go @@ -279,7 +279,7 @@ func (d *Distributor) Distribute(ctx context.Context, logID, witID string, nextR } // If there are no rows then that's fine, we'll allow lastTreeSize to stay at 0 } - if newCP.Size > lastTreeSize { + if newCP.Size >= lastTreeSize { // If the new checkpoint is for a tree larger than the current checkpoint.N for this log, then // we have the option of creating a new checkpoint.N for the larger tree size. mergedCP, err := checkpoints.Combine(allCheckpoints, l.Verifier, note.VerifierList(witnesses...))