1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
require 'net/ssh'
module Net; module SSH; module Multi
class Server
attr_reader :host
attr_reader :user
attr_reader :options
attr_reader :gateway
def initialize(host, user, options={})
@host = host
@user = user
@options = options.dup
@gateway = @options.delete(:via)
end
def [](key)
(@options[:properties] || {})[key]
end
def port
options[:port] || 22
end
def eql?(server)
host == server.host &&
user == server.user &&
port == server.port
end
alias :== :eql?
def hash
@hash ||= [host, user, port].hash
end
def to_s
@to_s ||= begin
s = "#{user}@#{host}"
s << ":#{options[:port]}" if options[:port]
s
end
end
def inspect
@inspect ||= "#<%s:0x%x %s>" % [self.class.name, object_id, to_s]
end
def session(ensure_open=false)
return @session if @session || !ensure_open
@session ||= begin
session = if gateway
gateway.ssh(host, user, options)
else
Net::SSH.start(host, user, options)
end
session[:server] = self
session
end
rescue Net::SSH::AuthenticationFailed => error
raise Net::SSH::AuthenticationFailed.new("#{error.message}@#{host}")
end
def close_channels
session.channels.each { |id, channel| channel.close } if session
end
def close
session.transport.close if session
end
def busy?(include_invisible=false)
session && session.busy?(include_invisible)
end
def preprocess(&block)
return true unless session
session.preprocess(&block)
end
def readers
return [] unless session
session.listeners.keys
end
def writers
return [] unless session
session.listeners.keys.select do |io|
io.respond_to?(:pending_write?) && io.pending_write?
end
end
def postprocess(readers, writers)
return true unless session
listeners = session.listeners.keys
session.postprocess(listeners & readers, listeners & writers)
end
end
end; end; end
|
