Sha256: dafa976d01d20cf4d69f4a07ef094d77cf68e2b89d6bf3d68157be6aa91afed5
Contents?: true
Size: 879 Bytes
Versions: 34
Compression:
Stored size: 879 Bytes
Contents
module PoolParty
module Pinger
module ClassMethods
# Test to see if the host has the available port open
# for response.
def ping_port(host, port=22, retry_times=400)
connected = false
retry_times.times do |i|
begin
break if connected = TCPSocket.new(host, port).is_a?(TCPSocket)
rescue Exception => e
sleep(2)
end
end
connected
end
end
module InstanceMethods
def ping_port(ip, port=22, retry_times=500);self.class.ping_port(ip, port, retry_times);end
def ping_port_and(ip, port=22, retry_times=500, &block)
block.call if ping_port(ip, port, retry_times) && block
end
end
def self.included(receiver)
receiver.extend ClassMethods
receiver.send :include, InstanceMethods
end
end
end
Version data entries
34 entries across 34 versions & 3 rubygems