Method: Aerospike::PartitionTracker#init_timeout

Defined in:
lib/aerospike/query/partition_tracker.rb

#init_timeout(policy) ⇒ Object

[View source]

137
138
139
140
141
142
143
144
145
146
147
 
# File 'lib/aerospike/query/partition_tracker.rb', line 137

def init_timeout(policy)
  @sleep_between_retries = policy.sleep_between_retries
  @socket_timeout = policy.socket_timeout
  @total_timeout = policy.timeout
  if @total_timeout.positive?
    @deadline = Time.now + @total_timeout
    if !@socket_timeout || @socket_timeout > @total_timeout
      @socket_timeout = @total_timeout
    end
  end
end