Include none votes in completion criteria

nimiq · Nov 25, 2024 · ab72063 · ab72063
1 parent 78a4e13
commit ab72063
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/validator/src/aggregation/tendermint/protocol.rs b/validator/src/aggregation/tendermint/protocol.rs
@@ -42,9 +42,14 @@ impl TendermintAggregationProtocol {
             Arc::clone(&registry),
             Arc::clone(&partitioner),
             |aggregate: &TendermintContribution, _, _| {
-                aggregate.proposals().iter().any(|(_, contributor_count)| {
-                    *contributor_count >= Policy::TWO_F_PLUS_ONE as usize
-                })
+                let t = aggregate.all_contributors().len() == Policy::SLOTS as usize;
+                let t = t || aggregate.contributions.iter().any(|(_hash_option, contributor_count)| {
+                    contributor_count.signers.len() >= Policy::TWO_F_PLUS_ONE as usize
+                });
+                if t {
+                    log::warn!(?aggregate, "Encountered final aggregate");
+                }
+                t
             },
         ));