Skip to content

Commit

Permalink
4 epochs
Browse files Browse the repository at this point in the history
  • Loading branch information
Hellblazer committed Mar 10, 2024
1 parent 645720e commit 9fd550a
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -109,8 +109,8 @@ public void unbounded() throws NoSuchAlgorithmException, InterruptedException, I

final var prefix = UUID.randomUUID().toString();
int maxSize = 1024 * 1024;
var expectedExpochs = NUM_EPOCHS * 2;
var epochCountDown = new CountDownLatch(NPROC * expectedExpochs);
var expectedEpochs = NUM_EPOCHS + 1;
var epochCountDown = new CountDownLatch(NPROC * expectedEpochs);
for (short i = 0; i < (short) NPROC; i++) {
var level = new AtomicInteger();
var ds = new SimpleDataSource();
Expand Down Expand Up @@ -158,7 +158,7 @@ public void unbounded() throws NoSuchAlgorithmException, InterruptedException, I
comms.forEach(e -> e.close(Duration.ofSeconds(1)));
}

final var expected = expectedExpochs * (EPOCH_LENGTH - 1);
final var expected = expectedEpochs * (EPOCH_LENGTH - 1);
final var first = produced.stream().filter(l -> l.size() == expected).findFirst();
assertFalse(first.isEmpty(),
"no process produced " + expected + " blocks: " + produced.stream().map(l -> l.size()).toList());
Expand Down

0 comments on commit 9fd550a

Please sign in to comment.