# File lib/thrift/transport/buffered_transport.rb, line 24 def initialize(transport) @transport = transport @wbuf = '' @rbuf = '' @index = 0 end
# File lib/thrift/transport/buffered_transport.rb, line 39 def close flush @transport.close end
# File lib/thrift/transport/buffered_transport.rb, line 92 def flush if @wbuf != '' @transport.write(@wbuf) @wbuf = '' end @transport.flush end
# File lib/thrift/transport/buffered_transport.rb, line 35 def open @transport.open end
# File lib/thrift/transport/buffered_transport.rb, line 31 def open? return @transport.open? end
# File lib/thrift/transport/buffered_transport.rb, line 44 def read(sz) @index += sz ret = @rbuf.slice(@index - sz, sz) || '' if ret.length == 0 @rbuf = @transport.read([sz, DEFAULT_BUFFER].max) @index = sz ret = @rbuf.slice(0, sz) || '' end ret end
# File lib/thrift/transport/buffered_transport.rb, line 57 def read_byte # If the read buffer is exhausted, try to read up to DEFAULT_BUFFER more bytes into it. if @index >= @rbuf.size @rbuf = @transport.read(DEFAULT_BUFFER) @index = 0 end # The read buffer has some data now, read a single byte. Using get_string_byte() avoids # allocating a temp string of size 1 unnecessarily. @index += 1 return ::Thrift::TransportUtils.get_string_byte(@rbuf, @index - 1) end
# File lib/thrift/transport/buffered_transport.rb, line 70 def read_into_buffer(buffer, size) i = 0 while i < size # If the read buffer is exhausted, try to read up to DEFAULT_BUFFER more bytes into it. if @index >= @rbuf.size @rbuf = @transport.read(DEFAULT_BUFFER) @index = 0 end # The read buffer has some data now, so copy bytes over to the output buffer. byte = ::Thrift::TransportUtils.get_string_byte(@rbuf, @index) ::Thrift::TransportUtils.set_string_byte(buffer, i, byte) @index += 1 i += 1 end i end
# File lib/thrift/transport/buffered_transport.rb, line 88 def write(buf) @wbuf << buf end