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
|
# @note +download+ and +upload+ require +curl+. If +curl+ is not in your +PATH+
# then set the +CURL+ environment variable to point to it.
# @todo Use an HTTP library instead of executing +curl+.
class RbVmomi::VIM::Datastore
CURLBIN = ENV['CURL'] || "curl" #@private
# Check whether a file exists on this datastore.
# @param path [String] Path on the datastore.
def exists? path
req = Net::HTTP::Head.new mkuripath(path)
req.initialize_http_header 'cookie' => _connection.cookie
resp = _connection.http.request req
case resp
when Net::HTTPSuccess
true
when Net::HTTPNotFound
false
else
fail resp.inspect
end
end
# Download a file from this datastore.
# @param remote_path [String] Source path on the datastore.
# @param local_path [String] Destination path on the local machine.
# @return [void]
def download remote_path, local_path
url = "http#{_connection.http.use_ssl? ? 's' : ''}://#{_connection.http.address}:#{_connection.http.port}#{mkuripath(remote_path)}"
pid = spawn CURLBIN, "-k", '--noproxy', '*', '-f',
"-o", local_path,
"-b", _connection.cookie,
url,
:out => '/dev/null'
Process.waitpid(pid, 0)
fail "download failed" unless $?.success?
end
# Upload a file to this datastore.
# @param remote_path [String] Destination path on the datastore.
# @param local_path [String] Source path on the local machine.
# @return [void]
def upload remote_path, local_path
url = "http#{_connection.http.use_ssl? ? 's' : ''}://#{_connection.http.address}:#{_connection.http.port}#{mkuripath(remote_path)}"
pid = spawn CURLBIN, "-k", '--noproxy', '*', '-f',
"-T", local_path,
"-b", _connection.cookie,
url,
:out => '/dev/null'
Process.waitpid(pid, 0)
fail "upload failed" unless $?.success?
end
private
def datacenter
return @datacenter if @datacenter
x = parent
while not x.is_a? RbVmomi::VIM::Datacenter
x = x.parent
end
fail unless x.is_a? RbVmomi::VIM::Datacenter
@datacenter = x
end
def mkuripath path
"/folder/#{URI.escape path}?dcPath=#{URI.escape datacenter.name}&dsName=#{URI.escape name}"
end
end
|
