Method: Cassandra::Retry::Policies::DowngradingConsistency#read_timeout

Defined in:
lib/cassandra/retry/policies/downgrading_consistency.rb

#read_timeout(statement, consistency, required, received, retrieved, retries) ⇒ Object 



25
26
27
28
29
30
 
# File 'lib/cassandra/retry/policies/downgrading_consistency.rb', line 25

def read_timeout(statement, consistency, required, received, retrieved, retries)
  return reraise if retries > 0 || SERIAL_CONSISTENCIES.include?(consistency)
  return max_likely_to_work(consistency, required, received) if received < required

  retrieved ? reraise : try_again(consistency)
end