Contents

module NFAgent
  class Server
    def run
      Log.info("Starting up")
      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

9 entries across 9 versions & 1 rubygems

Version	Path
nfagent-0.9.31	lib/nfagent/server.rb
nfagent-0.9.19	lib/nfagent/server.rb
nfagent-0.9.17	lib/nfagent/server.rb
nfagent-0.9.15	lib/nfagent/server.rb
nfagent-0.9.13	lib/nfagent/server.rb
nfagent-0.9.11	lib/nfagent/server.rb
nfagent-0.9.10	lib/nfagent/server.rb
nfagent-0.9.9	lib/nfagent/server.rb
nfagent-0.9.8	lib/nfagent/server.rb