Repository: cassandra-dtest Updated Branches: refs/heads/master a5f90890f -> 74f578abe
Add clause to test for node-local queries through MessagingService for CASSANDRA-14807 Project: http://git-wip-us.apache.org/repos/asf/cassandra-dtest/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra-dtest/commit/74f578ab Tree: http://git-wip-us.apache.org/repos/asf/cassandra-dtest/tree/74f578ab Diff: http://git-wip-us.apache.org/repos/asf/cassandra-dtest/diff/74f578ab Branch: refs/heads/master Commit: 74f578abe03fd004f9ffe26868e76f63949cedec Parents: a5f9089 Author: Alex Petrov <[email protected]> Authored: Fri Oct 5 16:49:51 2018 +0200 Committer: Alex Petrov <[email protected]> Committed: Fri Oct 12 19:08:29 2018 +0200 ---------------------------------------------------------------------- read_repair_test.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra-dtest/blob/74f578ab/read_repair_test.py ---------------------------------------------------------------------- diff --git a/read_repair_test.py b/read_repair_test.py index ae01763..ed72ada 100644 --- a/read_repair_test.py +++ b/read_repair_test.py @@ -481,12 +481,15 @@ class TestSpeculativeReadRepair(Tester): node2.byteman_submit(['-u', './byteman/read_repair/stop_writes.btm']) node2.byteman_submit(['./byteman/read_repair/sorted_live_endpoints.btm']) - with StorageProxy(node2) as storage_proxy: + coordinator = node2 + # Stop reads on coordinator in order to make sure we do not go through + # the messaging service for the local reads + with StorageProxy(node2) as storage_proxy, stop_reads(coordinator): assert storage_proxy.blocking_read_repair == 0 assert storage_proxy.speculated_rr_read == 0 assert storage_proxy.speculated_rr_write == 0 - session = self.get_cql_connection(node2) + session = self.get_cql_connection(coordinator) expected = [kcv(1, 0, 1), kcv(1, 1, 2)] results = session.execute(quorum("SELECT * FROM ks.tbl WHERE k=1")) assert listify(results) == expected --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
