Skip to content
Permalink
Browse files
Broken test_speculative_data_request
patch by Berenguer Blasi; reviewed by Brandon Williams for CASSANDRA-17119
  • Loading branch information
bereng committed Nov 15, 2021
1 parent 027eb0d commit 01a647f4a1ec42d42198fe4c49fe654a7705d7d7
Show file tree
Hide file tree
Showing 3 changed files with 19 additions and 3 deletions.
@@ -0,0 +1,12 @@
RULE timing of request messages broken down by verb
CLASS org.apache.cassandra.net.MessagingService
METHOD doSend
AT ENTRY
BIND prefix:String = "org.jboss.byteman."; # byteman in strict mode requires the o.j.b prefix
toHost:String = $to.getAddress().toString();
verb:String = $message.header.verb.toString();
prop:String = prefix + "|request_verb_timing|" + toHost + "|" + verb;
IF true
DO
System.setProperty(prop, String.valueOf(System.currentTimeMillis()));
ENDRULE
@@ -3,10 +3,10 @@ CLASS org.apache.cassandra.net.MessagingService
METHOD doSend
AT ENTRY
BIND prefix:String = "org.jboss.byteman."; # byteman in strict mode requires the o.j.b prefix
toHost:String = $to.getAddress().toString();
toHost:String = $to.address.toString();
verb:String = $message.header.verb.toString();
prop:String = prefix + "|request_verb_timing|" + toHost + "|" + verb;
IF true
DO
System.setProperty(prop, String.valueOf(System.currentTimeMillis()));
ENDRULE
ENDRULE
@@ -606,7 +606,11 @@ def test_speculative_data_request(self):
node2.byteman_submit(['-u', './byteman/read_repair/stop_writes.btm'])

node1.byteman_submit(['./byteman/read_repair/sorted_live_endpoints.btm'])
node1.byteman_submit(['./byteman/request_verb_timing.btm'])
version = self.cluster.cassandra_version()
if version < '4.1':
node1.byteman_submit(['./byteman/request_verb_timing.btm'])
else:
node1.byteman_submit(['./byteman/post4.0/request_verb_timing.btm'])

with StorageProxy(node1) as storage_proxy:
assert storage_proxy.blocking_read_repair == 0

0 comments on commit 01a647f

Please sign in to comment.