class Protobuf::Rpc::Evented::Server

def post_init
  initialize_request!
  @request_buffer = Protobuf::Rpc::Buffer.new(:read)
end

def receive_data(data)
  log_debug { sign_message("receive_data: #{data}") }
  @request_buffer << data
  @request_data = @request_buffer.data
  @stats.request_size = @request_buffer.size
  handle_client if @request_buffer.flushed?
end

def send_data
  response_buffer = Protobuf::Rpc::Buffer.new(:write)
  response_buffer.set_data(@response)
  @stats.response_size = response_buffer.size
  log_debug { sign_message("sending data: #{response_buffer.inspect}") }
  super(response_buffer.write)
end

def set_peer
  @stats.client = ::Socket.unpack_sockaddr_in(get_peername)
end