Contents

module WatchmonkeyCli
  module Checkers
    class UdpPort < Checker
      self.checker_name = "udp_port"

      def enqueue host, port, opts = {}
        opts = { message: "Port #{port} (UDP) is not reachable!", timeout: 2 }.merge(opts)
        host = app.fetch_connection(:loopback, :local) if !host || host == :local
        host = app.fetch_connection(:ssh, host) if host.is_a?(Symbol)
        app.enqueue(self, host, port, opts)
      end

      def check! result, host, port, opts = {}
        result.result = port_open?(host.is_a?(String) ? host : host.is_a?(WatchmonkeyCli::LoopbackConnection) ? "127.0.0.1" : host.opts[:host_name] || host.opts[:host] || host.opts[:ip], port, opts)
        result.error! "#{opts[:message]}" unless result.result
      end

      def port_open?(ip, port, opts = {})
        Timeout::timeout(opts[:timeout] ? opts[:timeout] : 3600) do
          s = UDPSocket.new
          s.connect(ip, port)
          s.send "aaa", 0
          s.recv(1)
          s.close
        end
        true
      rescue Errno::ECONNREFUSED, Errno::EHOSTUNREACH
        return false
      rescue Timeout::Error
        return true
      end
    end
  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version	Path
watchmonkey_cli-1.12.0	lib/watchmonkey_cli/checkers/udp_port.rb
watchmonkey_cli-1.11.0	lib/watchmonkey_cli/checkers/udp_port.rb
watchmonkey_cli-1.10.0	lib/watchmonkey_cli/checkers/udp_port.rb
watchmonkey_cli-1.9.1	lib/watchmonkey_cli/checkers/udp_port.rb
watchmonkey_cli-1.9.0	lib/watchmonkey_cli/checkers/udp_port.rb
watchmonkey_cli-1.8.6	lib/watchmonkey_cli/checkers/udp_port.rb
watchmonkey_cli-1.8.5	lib/watchmonkey_cli/checkers/udp_port.rb
watchmonkey_cli-1.8.4	lib/watchmonkey_cli/checkers/udp_port.rb
watchmonkey_cli-1.8.3	lib/watchmonkey_cli/checkers/udp_port.rb
watchmonkey_cli-1.8.2	lib/watchmonkey_cli/checkers/udp_port.rb
watchmonkey_cli-1.8.1	lib/watchmonkey_cli/checkers/udp_port.rb
watchmonkey_cli-1.8	lib/watchmonkey_cli/checkers/udp_port.rb