Sha256: d1609bec6707b97f38287fc475b66ae49ba5edf455be77177f2857ca4e219c65
Contents?: true
Size: 1.79 KB
Versions: 11
Compression:
Stored size: 1.79 KB
Contents
class RbVmomi::VIM::ServiceInstance # Retrieve a Datacenter. # If no path is given the first datacenter will be returned. # @param path (see Folder#traverse) # @return [Datacenter] def find_datacenter path=nil if path content.rootFolder.traverse path, RbVmomi::VIM::Datacenter else content.rootFolder.childEntity.grep(RbVmomi::VIM::Datacenter).first end end # Wait for several tasks to complete. # @param interested [Array] Property paths to watch for updates. # @param tasks [Array] Tasks to wait on. # @yield [Hash] Called when a property is updated on a task. # The parameter is a hash from tasks to hashes from # property path to value. # @return [void] def wait_for_multiple_tasks interested, tasks version = '' interested = (interested + ['info.state']).uniq task_props = Hash.new { |h,k| h[k] = {} } filter = @soap.propertyCollector.CreateFilter :spec => { :propSet => [{ :type => 'Task', :all => false, :pathSet => interested }], :objectSet => tasks.map { |x| { :obj => x } }, }, :partialUpdates => false begin until task_props.size == tasks.size and task_props.all? { |k,h| %w(success error).member? h['info.state'] } result = @soap.propertyCollector.WaitForUpdates(:version => version) version = result.version os = result.filterSet[0].objectSet os.each do |o| changes = Hash[o.changeSet.map { |x| [x.name, x.val] }] interested.each do |k| task = tasks.find { |x| x._ref == o.obj._ref } task_props[task][k] = changes[k] if changes.member? k end end yield task_props end ensure @soap.propertyCollector.CancelWaitForUpdates filter.DestroyPropertyFilter end end end
Version data entries
11 entries across 11 versions & 1 rubygems