Top Level Namespace

Defined Under Namespace

Modules: Console, Puppet

Constant Summary collapse

PTS_PATH = 
'/dev/pts'
LIBVIRT_USER = 
'libvirt-qemu'
LIBVIRT_GROUP = 
'kvm'

Instance Method Summary collapse

Instance Method Details

#execute_when_tcp_available(ip, options = { }, &block) ⇒ Object

see tinyurl.com/3ht46m5



18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/ssh/port.rb', line 18

def execute_when_tcp_available(ip, options = { } , &block)
    defaults={ :port => 22, :timeout => 2 , :pollrate => 5}
    options=defaults.merge(options)
    begin
    Timeout::timeout(options[:timeout]) do
    connected=false
    while !connected do
        begin
        s = TCPSocket.new(ip, options[:port])
        s.close
        block.call(ip)
        return true
        rescue Errno::ECONNREFUSED, Errno::EHOSTUNREACH, SocketError
        sleep options[:pollrate]
        end
    end
    end
    rescue Timeout::Error
    raise 'timeout connecting to port'
    end
    return false
end

#ssh_after_boot(host, options = {}, &block) ⇒ Object 



9
10
11
12
13
14
15
 
# File 'lib/ssh/port.rb', line 9

def ssh_after_boot(host, options = {} , &block)
    execute_when_tcp_available(host,options) do |host|
    ssh_to(host,options)   do |ssh|
      block.call(ssh)  
    end
    end
end

#ssh_to(host, options = {}, &block) ⇒ Object 



3
4
5
6
7
 
# File 'lib/ssh/port.rb', line 3

def ssh_to(host, options = {} , &block)
    Net::SSH.start(host,options[:user], options) do|ssh|
    block.call(ssh)
    end   
end