Kgio::Socket
internal implementation details here, do not rely on them in your code
# File lib/mogilefs/socket/kgio.rb, line 30 def timed_peek(len, dst, timeout = 5) case rc = kgio_trypeek(len, dst) when :wait_readable kgio_wait_readable(timeout) or unreadable_socket!(timeout) else return rc end while true end
# File lib/mogilefs/socket/kgio.rb, line 21 def timed_read(len, dst = "", timeout = 5) case rc = kgio_tryread(len, dst) when :wait_readable kgio_wait_readable(timeout) or unreadable_socket!(timeout) else return rc end while true end
# File lib/mogilefs/socket/kgio.rb, line 39 def timed_write(buf, timeout = 5) written = 0 expect = buf.bytesize case rc = kgio_trywrite(buf) when :wait_writable kgio_wait_writable(timeout) or request_truncated!(written, expect, timeout) when String written += expect - rc.bytesize buf = rc else return expect end while true end
Generated with the Darkfish Rdoc Generator 2.