only 2 epochs stored in nodes

salesforce · Feb 11, 2024 · 0423537 · 0423537
1 parent 2ae9bb8
commit 0423537
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/ethereal/src/main/java/com/salesforce/apollo/ethereal/Adder.java b/ethereal/src/main/java/com/salesforce/apollo/ethereal/Adder.java
@@ -600,8 +600,8 @@ private boolean decodeParents(Waiting wp) {
      * Answer the bloom filter with the commits the receiver has
      */
     private Biff haveCommits() {
-        var bff = new DigestBloomFilter(Entropy.nextBitsStreamLong(),
-                                        conf.epochLength() * conf.numberOfEpochs() * conf.nProc() * 2, conf.fpr());
+        var bff = new DigestBloomFilter(Entropy.nextBitsStreamLong(), conf.epochLength() * 2 * conf.nProc() * 2,
+                                        conf.fpr());
         signedCommits.keySet().forEach(d -> bff.add(d));
         return bff.toBff();
     }
@@ -610,8 +610,8 @@ private Biff haveCommits() {
      * Answer the bloom filter with the prevotes the receiver has
      */
     private Biff havePreVotes() {
-        var bff = new DigestBloomFilter(Entropy.nextBitsStreamLong(),
-                                        conf.epochLength() * conf.numberOfEpochs() * conf.nProc() * 2, conf.fpr());
+        var bff = new DigestBloomFilter(Entropy.nextBitsStreamLong(), conf.epochLength() * 2 * conf.nProc() * 2,
+                                        conf.fpr());
         signedPrevotes.keySet().forEach(d -> bff.add(d));
         return bff.toBff();
     }
@@ -620,8 +620,8 @@ private Biff havePreVotes() {
      * Answer the bloom filter with the units the receiver has
      */
     private Biff haveUnits() {
-        var bff = new DigestBloomFilter(Entropy.nextBitsStreamLong(),
-                                        conf.epochLength() * conf.numberOfEpochs() * conf.nProc() * 2, conf.fpr());
+        var bff = new DigestBloomFilter(Entropy.nextBitsStreamLong(), conf.epochLength() * 2 * conf.nProc() * 2,
+                                        conf.fpr());
         waiting.keySet().forEach(d -> bff.add(d));
         dag.have(bff);
         return bff.toBff();