Skip to content

Commit 15b91b7

Browse files
committed
Transport small fix
1 parent 1b6d33a commit 15b91b7

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

simulator/src/main/java/byzzbench/simulator/transport/Transport.java

+4-2
Original file line numberDiff line numberDiff line change
@@ -364,7 +364,8 @@ public synchronized void dropEvent(long eventId) {
364364
}
365365

366366
if (e.getStatus() != Event.Status.QUEUED) {
367-
throw new IllegalArgumentException("Event not found or not in QUEUED state");
367+
return;
368+
//throw new IllegalArgumentException("Event not found or not in QUEUED state");
368369
}
369370

370371
e.setStatus(Event.Status.DROPPED);
@@ -403,7 +404,8 @@ public synchronized void applyMutation(long eventId, Fault fault) {
403404

404405
// check if event is not in QUEUED state
405406
if (e.getStatus() != Event.Status.QUEUED) {
406-
throw new IllegalArgumentException("Message not found or not in QUEUED state");
407+
return;
408+
//throw new IllegalArgumentException("Event not found or not in QUEUED state");
407409
}
408410

409411
// check it is a message event!

simulator/src/main/resources/application.yml

+1-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ byzzbench:
2323

2424
scheduler:
2525
id: "byzzfuzz" # The ID of the scheduler to use
26-
executionMode: sync # async (default, any message delivered) or sync (communication-closure hypothesis, FIFO)
26+
executionMode: async # async (default, any message delivered) or sync (communication-closure hypothesis, FIFO)
2727
maxDropMessages: 10 # Maximum number of messages to drop per scenario
2828
maxMutateMessages: 10 # Maximum number of messages to mutate per scenario
2929
deliverTimeoutWeight: 25 # The weight for scheduler to trigger a timeout

0 commit comments

Comments
 (0)