

def rfthree_downgradingcl(self, cluster, keyspace, roundrobin):
    session = cluster.connect()
    create_schema(cluster, session, keyspace, replication_factor=2)
    self._insert(session, keyspace, count=12)
    self._query(session, keyspace, count=12)
    if roundrobin:
        self.coordinator_stats.assert_query_count_equals(self, 1, 4)
        self.coordinator_stats.assert_query_count_equals(self, 2, 4)
        self.coordinator_stats.assert_query_count_equals(self, 3, 4)
    else:
        self.coordinator_stats.assert_query_count_equals(self, 1, 0)
        self.coordinator_stats.assert_query_count_equals(self, 2, 12)
        self.coordinator_stats.assert_query_count_equals(self, 3, 0)
    try:
        self.coordinator_stats.reset_counts()
        force_stop(2)
        wait_for_down(cluster, 2)
        self._assert_writes_succeed(session, keyspace, SINGLE_DC_CONSISTENCY_LEVELS)
        for cl in (SINGLE_DC_CONSISTENCY_LEVELS - set([ConsistencyLevel.ANY])):
            self.coordinator_stats.reset_counts()
            self._query(session, keyspace, 12, consistency_level=cl)
            if roundrobin:
                self.coordinator_stats.assert_query_count_equals(self, 1, 6)
                self.coordinator_stats.assert_query_count_equals(self, 2, 0)
                self.coordinator_stats.assert_query_count_equals(self, 3, 6)
            else:
                self.coordinator_stats.assert_query_count_equals(self, 1, 0)
                self.coordinator_stats.assert_query_count_equals(self, 2, 0)
                self.coordinator_stats.assert_query_count_equals(self, 3, 12)
    finally:
        start(2)
        wait_for_up(cluster, 2)
    session.cluster.shutdown()

dataset/ETHPy150Open datastax/python-driver/tests/integration/long/test_consistency.py ConsistencyTests.rfthree_downgradingcl/original