require 'protobuf/rpc/server' require 'protobuf/logging' module Protobuf module Rpc module Socket class Worker include ::Protobuf::Rpc::Server include ::Protobuf::Logging def initialize(sock, &complete_cb) @socket = sock @complete_cb = complete_cb data = read_data return unless data gc_pause do encoded_response = handle_request(data) send_data(encoded_response) end end def read_data size_io = StringIO.new until (size_reader = @socket.getc) == "-" size_io << size_reader end str_size_io = size_io.string @socket.read(str_size_io.to_i) end def send_data(data) fail 'Socket closed unexpectedly' unless socket_writable? response_buffer = Protobuf::Rpc::Buffer.new(:write) response_buffer.set_data(data) @socket.write(response_buffer.write) @socket.flush @complete_cb.call(@socket) end def log_signature @_log_signature ||= "[server-#{self.class}-#{object_id}]" end def socket_writable? ! @socket.nil? && ! @socket.closed? end end end end end