'Trigger and ensure read_timeouts are counted
Write a key, value pair. Pause a node without the coordinator node knowing about the "DOWN" state.
Attempt a read at cl.ALL and receive a ReadTimeout.'

def test_read_timeout(self):

    self.session.execute('INSERT    INTO    test    (k,    v)    VALUES    (1,    1)')
    query = SimpleStatement('SELECT    *    FROM    test    WHERE    k=1', consistency_level=ConsistencyLevel.ALL)
    results = execute_until_pass(self.session, query)
    self.assertTrue(results)
    get_node(1).pause()
    try:
        query = SimpleStatement('SELECT    *    FROM    test', consistency_level=ConsistencyLevel.ALL)
        with self.assertRaises(ReadTimeout):
            self.session.execute(query, timeout=None)
        self.assertEqual(1, self.cluster.metrics.stats.read_timeouts)
    finally:
        get_node(1).resume()
