module Redis::Connection::SocketMixin
Constants
- CRLF
Public Class Methods
new(*args)
click to toggle source
Calls superclass method
# File lib/redis/connection/ruby.rb, line 12 def initialize(*args) super(*args) @timeout = nil @buffer = "" end
Public Instance Methods
_read_from_socket(nbytes)
click to toggle source
# File lib/redis/connection/ruby.rb, line 47 def _read_from_socket(nbytes) begin read_nonblock(nbytes) rescue Errno::EWOULDBLOCK, Errno::EAGAIN if IO.select([self], nil, nil, @timeout) retry else raise Redis::TimeoutError end end rescue EOFError raise Errno::ECONNRESET end
gets()
click to toggle source
# File lib/redis/connection/ruby.rb, line 37 def gets crlf = nil while (crlf = @buffer.index(CRLF)) == nil @buffer << _read_from_socket(1024) end @buffer.slice!(0, crlf + CRLF.bytesize) end
read(nbytes)
click to toggle source
# File lib/redis/connection/ruby.rb, line 27 def read(nbytes) result = @buffer.slice!(0, nbytes) while result.bytesize < nbytes result << _read_from_socket(nbytes - result.bytesize) end result end
timeout=(timeout)
click to toggle source
# File lib/redis/connection/ruby.rb, line 19 def timeout=(timeout) if timeout && timeout > 0 @timeout = timeout else @timeout = nil end end