class Protobuf::Rpc::EventedServer
def post_init
def post_init log_debug '[server] Post init, new read buffer created' @stats = Protobuf::Rpc::Stat.new(:SERVER, true) @stats.client = Socket.unpack_sockaddr_in(get_peername) @buffer = Protobuf::Rpc::Buffer.new(:read) @did_respond = false end
def receive_data(data)
def receive_data(data) log_debug '[server] receive_data: %s' % data @buffer << data handle_client if @buffer.flushed? end