blob: 04f996cda3b25e86f2c153c04d9d710afece701f [file] [log] [blame]
#
# Inject streaming failure
#
# Before start streaming files in `StreamSession#prepare()` method,
# interrupt streaming by throwing RuntimeException.
#
RULE inject stream failure
CLASS org.apache.cassandra.streaming.StreamSession
METHOD prepare
AT INVOKE startStreamingFiles
BIND peer = $0.peer
# set flag to only run this rule once.
IF peer.equals(InetAddress.getByName("127.0.0.2")) AND NOT flagged("done")
DO
flag("done");
throw new java.lang.RuntimeException("Triggering network failure")
ENDRULE