| # | |
| # 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 maybeCompleted | |
| BIND peer = $0.peer | |
| # set flag to only run this rule once. | |
| IF NOT flagged("done") | |
| DO | |
| flag("done"); | |
| throw new java.lang.RuntimeException("Triggering network failure") | |
| ENDRULE |