3
3
import byzzbench .simulator .Scenario ;
4
4
import byzzbench .simulator .config .ByzzBenchConfig ;
5
5
import byzzbench .simulator .faults .faults .MessageMutationFault ;
6
- import byzzbench .simulator .protocols .tendermint .message .GossipMessage ;
7
6
import byzzbench .simulator .service .MessageMutatorService ;
8
7
import byzzbench .simulator .transport .ClientRequestEvent ;
9
8
import byzzbench .simulator .transport .Event ;
@@ -102,10 +101,8 @@ public synchronized Optional<EventDecision> scheduleNext(Scenario scenario) thro
102
101
if (dieRoll < 0 ) {
103
102
Event message = getRandomElement (messageEvents );
104
103
scenario .getTransport ().dropEvent (message .getEventId ());
105
- if (!(message instanceof GossipMessage )) {
106
- EventDecision decision = new EventDecision (EventDecision .DecisionType .DROPPED , message .getEventId ());
107
- return Optional .of (decision );
108
- }
104
+ EventDecision decision = new EventDecision (EventDecision .DecisionType .DROPPED , message .getEventId ());
105
+ return Optional .of (decision );
109
106
}
110
107
111
108
// check if we should mutate-and-deliver a message sent between nodes
@@ -116,10 +113,7 @@ public synchronized Optional<EventDecision> scheduleNext(Scenario scenario) thro
116
113
117
114
if (mutators .isEmpty ()) {
118
115
// no mutators, return nothing
119
- log .warning ("No mutators available for message " + message .getEventId ());
120
- scenario .getTransport ().deliverEvent (message .getEventId ());
121
- EventDecision decision = new EventDecision (EventDecision .DecisionType .DELIVERED , message .getEventId ());
122
- return Optional .of (decision );
116
+ return Optional .empty ();
123
117
}
124
118
scenario .getTransport ().applyMutation (
125
119
message .getEventId (),
0 commit comments