search for: db_volume

...@logger.info "volume #{lvm_volume.key} already exists in db.." + @logger.info "volume #{lvm_volume.get_attr('key')} already exists in db.." end end end @@ -756,7 +756,7 @@ class TaskOmatic end db_volume.reload - db_volume.key = volume.key + db_volume.key = volume.get_attr('key') db_volume.path = volume.path db_volume.state = StorageVolume::STATE_AVAILABLE db_volume.save! @@ -966,4 +966,3 @@ end taskomatic = TaskOmatic.new() taskomatic....

This patch teaches taskomatic to use the volume 'key' instead of the path from libvirt to key the volume off of in the database. This fixes the duplicate iscsi volume bug we were seeing. The issue was that libvirt changed the way they name storage volumes and included a local ID that changed each time it was attached. Note that the first run with this new patch will cause duplicate

...ame}." unless volume + if volume == nil + @logger.info "Unable to find volume by key #{volume_key} attached to pool #{pool.name}, trying by filename..." + volume = @session.object(:class => 'volume', + 'name' => db_volume.filename, + 'storagePool' => pool.object_id) + raise "Unable to find volume by key (#{volume_key}) or filename (#{db_volume.filename}), giving up." unless volume + end @logger.debug "Verified volume of pool #{volume.path}"...

...lass => "node", 'hostname' => curr.hostname) next unless node # So now we expect if the node was found it's alive and well, then @@ -205,12 +210,12 @@ class TaskOmatic # activate the underlying physical device, and then do the logical one if db_volume[:type] == "LvmStorageVolume" phys_libvirt_pool = get_libvirt_lvm_pool_from_volume(db_volume, @logger) - phys_libvirt_pool.connect(@session, node) + phys_libvirt_pool.connect(@qmfc, node) end @logger.debug "Verifying mount of pool #{db_pool.ip_ad...

...end + @logger.debug "Verifying mount of pool #{db_pool.ip_addr}:#{db_pool.type}:#{db_pool.target}:#{db_pool.export_path}" libvirt_pool = LibvirtPool.factory(db_pool) libvirt_pool.connect(@session, node) @@ -205,10 +215,15 @@ class TaskOmatic volume_name = db_volume.read_attribute(db_volume.volume_name) pool = libvirt_pool.remote_pool + + @logger.debug "Pool mounted: #{pool.name}; state: #{pool.state}" + volume = @session.object(:class => 'volume', 'name' => volume_name,...

...ze.times { s << (i = Kernel.rand(62); i += ((i < 10) ? 48 : ((i < 36) ? 55 : 61 ))).chr } - s -end - -def all_storage_pools(conn) - all_pools = conn.list_defined_storage_pools - all_pools.concat(conn.list_storage_pools) - return all_pools -end - -def get_libvirt_lvm_pool_from_volume(db_volume) - phys_volume = StorageVolume.find(:first, :conditions => - [ "lvm_pool_id = ?", db_volume.storage_pool_id]) - - return LibvirtPool.factory(phys_volume.storage_pool) -end - -class LibvirtPool - def initialize(type, name = nil) - @remote_pool = n...