Contents

module NFAgent
  class Server
    def run
      Log.info("Starting up")
      NFAgent::Plugin.load_plugins

      chunk_handler = ChunkHandler.new
      poller = Poller.new

      EM.run {
        EM.start_server "0.0.0.0", 10000, Event, chunk_handler, poller
        EM::PeriodicTimer.new(5) do
          chunk_handler.check_full_or_expired
        end
        EM::PeriodicTimer.new(120) do
          poller.send_heartbeat
        end
        Submitter.run_every(60)
      }
    end

    def shutdown
      EM::stop_event_loop if EM::reactor_running?
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
nfagent-0.9.20	lib/nfagent/server.rb