pinger

pinger.rb

def self.ping_server
    EM.synchrony do
      @start_time = Time.now
      r = Redis.new
      ips = r.smembers('not_pinged')
      concurrency = 500
      EM::Synchrony::Iterator.new(ips, concurrency).map do |ip, iter|
        ip = ip_to_icmp_object(ip_to_s(ip))
        ip.failures_required = 3
        ip.on_success {|host| ip.stop ; Fiber.new {r.smove 'not_pinged', 'up', ip_to_i(host)}.resume ; iter.return}
        ip.on_failure {|host| ip.stop ; Fiber.new {r.smove 'not_pinged', 'down', ip_to_i(host)}.resume ; iter.return}
        ip.schedule
      end
      p Time.now - @start_time
      EM.stop
    end
  end