Parent

Thrift::BufferedTransport

Constants

DEFAULT_BUFFER

Public Class Methods

new(transport) click to toggle source
# File lib/thrift/transport/buffered_transport.rb, line 24
def initialize(transport)
  @transport = transport
  @wbuf = Bytes.empty_byte_buffer
  @rbuf = Bytes.empty_byte_buffer
  @index = 0
end

Public Instance Methods

close() click to toggle source
# File lib/thrift/transport/buffered_transport.rb, line 39
def close
  flush
  @transport.close
end
flush() click to toggle source
# File lib/thrift/transport/buffered_transport.rb, line 98
def flush
  unless @wbuf.empty?
    @transport.write(@wbuf)
    @wbuf = Bytes.empty_byte_buffer
  end
  
  @transport.flush
end
open() click to toggle source
# File lib/thrift/transport/buffered_transport.rb, line 35
def open
  @transport.open
end
open?() click to toggle source
# File lib/thrift/transport/buffered_transport.rb, line 31
def open?
  return @transport.open?
end
read(sz) click to toggle source
# File lib/thrift/transport/buffered_transport.rb, line 44
def read(sz)
  @index += sz
  ret = @rbuf.slice(@index - sz, sz) || Bytes.empty_byte_buffer

  if ret.length == 0
    @rbuf = @transport.read([sz, DEFAULT_BUFFER].max)
    @index = sz
    ret = @rbuf.slice(0, sz) || Bytes.empty_byte_buffer
  end

  ret
end
read_byte() click to toggle source
# 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 Bytes.get_string_byte(@rbuf, @index - 1)
end
read_into_buffer(buffer, size) click to toggle source

Reads a number of bytes from the transport into the buffer passed.

buffer - The String (byte buffer) to write data to; this is assumed to have a BINARY encoding. size - The number of bytes to read from the transport and write to the buffer.

Returns the number of bytes read.

# File lib/thrift/transport/buffered_transport.rb, line 76
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 = Bytes.get_string_byte(@rbuf, @index)
    Bytes.set_string_byte(buffer, i, byte)
    @index += 1
    i += 1
  end
  i
end
write(buf) click to toggle source
# File lib/thrift/transport/buffered_transport.rb, line 94
def write(buf)
  @wbuf << Bytes.force_binary_encoding(buf)
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.