Module: Redis::Connection::SocketMixin
- Included in:
- SSLSocket, TCPSocket, UNIXSocket
- Defined in:
- lib/redis/connection/ruby.rb
Constant Summary collapse
- CRLF =
"\r\n"
Instance Method Summary collapse
- #_read_from_socket(nbytes) ⇒ Object
- #gets ⇒ Object
- #initialize(*args) ⇒ Object
- #read(nbytes) ⇒ Object
- #timeout=(timeout) ⇒ Object
- #write(buffer) ⇒ Object
- #write_timeout=(timeout) ⇒ Object
Instance Method Details
#_read_from_socket(nbytes) ⇒ Object
51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 |
# File 'lib/redis/connection/ruby.rb', line 51 def _read_from_socket(nbytes) loop do case chunk = read_nonblock(nbytes, exception: false) when :wait_readable unless wait_readable(@timeout) raise Redis::TimeoutError end when :wait_writable unless wait_writable(@timeout) raise Redis::TimeoutError end when nil raise Errno::ECONNRESET when String return chunk end end end |
#gets ⇒ Object
43 44 45 46 47 48 49 |
# File 'lib/redis/connection/ruby.rb', line 43 def gets while (crlf = @buffer.index(CRLF)).nil? @buffer << _read_from_socket(16_384) end @buffer.slice!(0, crlf + CRLF.bytesize) end |
#initialize(*args) ⇒ Object
20 21 22 23 24 25 |
# File 'lib/redis/connection/ruby.rb', line 20 def initialize(*args) super(*args) @timeout = @write_timeout = nil @buffer = "".dup end |
#read(nbytes) ⇒ Object
35 36 37 38 39 40 41 |
# File 'lib/redis/connection/ruby.rb', line 35 def read(nbytes) result = @buffer.slice!(0, nbytes) result << _read_from_socket(nbytes - result.bytesize) while result.bytesize < nbytes result end |
#timeout=(timeout) ⇒ Object
27 28 29 |
# File 'lib/redis/connection/ruby.rb', line 27 def timeout=(timeout) @timeout = (timeout if timeout && timeout > 0) end |
#write(buffer) ⇒ Object
70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 |
# File 'lib/redis/connection/ruby.rb', line 70 def write(buffer) return super(buffer) unless @write_timeout bytes_to_write = buffer.bytesize total_bytes_written = 0 loop do case bytes_written = write_nonblock(buffer, exception: false) when :wait_readable unless wait_readable(@write_timeout) raise Redis::TimeoutError end when :wait_writable unless wait_writable(@write_timeout) raise Redis::TimeoutError end when nil raise Errno::ECONNRESET when Integer total_bytes_written += bytes_written if total_bytes_written >= bytes_to_write return total_bytes_written end buffer = buffer.byteslice(bytes_written..-1) end end end |
#write_timeout=(timeout) ⇒ Object
31 32 33 |
# File 'lib/redis/connection/ruby.rb', line 31 def write_timeout=(timeout) @write_timeout = (timeout if timeout && timeout > 0) end |