class Redis::Client

Public Instance Methods

call_loop_with_old_protocol(*args) { |read_with_old_protocol| ... } click to toggle source
# File lib/daikon/redis_hacks.rb, line 16
def call_loop_with_old_protocol(*args)
  without_socket_timeout do
    process(args) do
      loop { yield(read_with_old_protocol) }
    end
  end
end
read_with_old_protocol() click to toggle source
# File lib/daikon/redis_hacks.rb, line 24
def read_with_old_protocol
  begin
    connection.read_with_old_protocol
  rescue Errno::EAGAIN
    disconnect
    raise Errno::EAGAIN, "Timeout reading from the socket"
  rescue Errno::ECONNRESET
    raise Errno::ECONNRESET, "Connection lost"
  end
end