From edc38fb525f99f2531637dad7652dff51a2395cd Mon Sep 17 00:00:00 2001 From: Hellblazer Date: Fri, 3 Nov 2023 08:49:25 -0700 Subject: [PATCH] cleaner testing --- .../apollo/membership/messaging/RbcTest.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/memberships/src/test/java/com/salesforce/apollo/membership/messaging/RbcTest.java b/memberships/src/test/java/com/salesforce/apollo/membership/messaging/RbcTest.java index 84546a829..6c643fdd7 100644 --- a/memberships/src/test/java/com/salesforce/apollo/membership/messaging/RbcTest.java +++ b/memberships/src/test/java/com/salesforce/apollo/membership/messaging/RbcTest.java @@ -55,9 +55,9 @@ public class RbcTest { private static final Parameters.Builder parameters = Parameters.newBuilder() - .setMaxMessages(1000) - .setFalsePositiveRate(0.00125) - .setBufferSize(5000); + .setMaxMessages(100) + .setFalsePositiveRate(0.0125) + .setBufferSize(500); private final List communications = new ArrayList<>(); private final AtomicInteger totalReceived = new AtomicInteger(0); private List messengers; @@ -78,7 +78,7 @@ public void broadcast() throws Exception { entropy.setSeed(new byte[]{6, 6, 6}); var stereotomy = new StereotomyImpl(new MemKeyStore(), new MemKERL(DigestAlgorithm.DEFAULT), entropy); - List members = IntStream.range(0, 100).mapToObj(i -> stereotomy.newIdentifier()).map(cpk -> new ControlledIdentifierMember(cpk)).map(e -> (SigningMember) e).toList(); + List members = IntStream.range(0, 50).mapToObj(i -> stereotomy.newIdentifier()).map(cpk -> new ControlledIdentifierMember(cpk)).map(e -> (SigningMember) e).toList(); Context context = Context.newBuilder().setCardinality(members.size()).build(); RbcMetrics metrics = new RbcMetricsImpl(context.getId(), "test", registry); @@ -106,7 +106,7 @@ public void broadcast() throws Exception { view.registerHandler(receiver); receivers.put(view.getMember(), receiver); } - int rounds = Boolean.getBoolean("large_tests") ? 100 : 10; + int rounds = Boolean.getBoolean("large_tests") ? 100 : 5; for (int r = 0; r < rounds; r++) { CountDownLatch latch = new CountDownLatch(messengers.size()); round.set(latch); @@ -166,7 +166,7 @@ public void message(Digest context, List messages) { if (index == current.get() + 1) { if (counted.add(m.source().get(0))) { int totalCount = totalReceived.incrementAndGet(); - if (totalCount % 1_000 == 0) { + if (totalCount % 100 == 0) { System.out.print("."); } if (counted.size() == messengers.size() - 1) {