class MCollective::Discovery::Mc

Public Class Methods

discover(filter, timeout, limit, client) click to toggle source
# File lib/mcollective/discovery/mc.rb, line 4
def self.discover(filter, timeout, limit, client)
  begin
    hosts = []
    Timeout.timeout(timeout) do
      reqid = client.sendreq("ping", "discovery", filter)
      Log.debug("Waiting #{timeout} seconds for discovery replies to request #{reqid}")

      loop do
        reply = client.receive(reqid)
        Log.debug("Got discovery reply from #{reply.payload[:senderid]}")
        hosts << reply.payload[:senderid]

        return hosts if limit > 0 && hosts.size == limit
      end
    end
  rescue Timeout::Error => e
  rescue Exception => e
    raise
  ensure
    client.unsubscribe("discovery", :reply)
  end

  hosts
end