Since Ruby::Qmf moves, the .key() method does not work anymore. It forces to use
a .get_attr('key') in order to get the good value.
Signed-off-by: Loiseleur Michel <mloiseleur at linagora.com>
---
src/task-omatic/taskomatic.rb | 15 +++++++--------
1 files changed, 7 insertions(+), 8 deletions(-)
diff --git a/src/task-omatic/taskomatic.rb b/src/task-omatic/taskomatic.rb
index c0a56b8..7de725d 100755
--- a/src/task-omatic/taskomatic.rb
+++ b/src/task-omatic/taskomatic.rb
@@ -608,7 +608,7 @@ class TaskOmatic
storage_volume.size = volume.capacity / 1024
storage_volume.storage_pool_id = db_pool.id
storage_volume.write_attribute(storage_volume.volume_name, volume.name)
- storage_volume.key = volume.key
+ storage_volume.key = volume.get_attr('key')
storage_volume.lv_owner_perms = owner
storage_volume.lv_group_perms = group
storage_volume.lv_mode_perms = mode
@@ -661,14 +661,14 @@ class TaskOmatic
existing_vol = StorageVolume.find(:first, :conditions =>
["storage_pool_id = ? AND key = ?",
- db_pool_phys.id, volume.key])
+ db_pool_phys.id, volume.get_attr('key')])
- puts "Existing volume is #{existing_vol}, searched for storage
volume key and #{volume.key}"
+ puts "Existing volume is #{existing_vol}, searched for storage
volume key and #{volume.get_attr('key')}"
# Only add if it's not already there.
if not existing_vol
add_volume_to_db(db_pool_phys, volume);
else
- @logger.debug "Scanned volume #{volume.key} already exists in
db.."
+ @logger.debug "Scanned volume
#{volume.get_attr('key')} already exists in db.."
end
# Now check for an LVM pool carving up this volume.
@@ -710,11 +710,11 @@ class TaskOmatic
lvm_storage_volume =
StorageVolume.factory(lvm_db_pool.get_type_label)
existing_vol = StorageVolume.find(:first, :conditions =>
["storage_pool_id = ? AND key = ?",
- lvm_db_pool.id, lvm_volume.key])
+ lvm_db_pool.id,
lvm_volume.get_attr('key')])
if not existing_vol
add_volume_to_db(lvm_db_pool, lvm_volume, "0744",
"0744", "0744");
else
- @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.mainloop()
-
--
1.7.0
On Thu, Feb 25, 2010 at 09:37:17AM +0100, Loiseleur Michel wrote:> Since Ruby::Qmf moves, the .key() method does not work anymore. It forces to use a .get_attr('key') in order to get the good value. > > Signed-off-by: Loiseleur Michel <mloiseleur at linagora.com> > --- > src/task-omatic/taskomatic.rb | 15 +++++++-------- > 1 files changed, 7 insertions(+), 8 deletions(-) > > diff --git a/src/task-omatic/taskomatic.rb b/src/task-omatic/taskomatic.rb > index c0a56b8..7de725d 100755 > --- a/src/task-omatic/taskomatic.rb > +++ b/src/task-omatic/taskomatic.rb > @@ -608,7 +608,7 @@ class TaskOmatic > storage_volume.size = volume.capacity / 1024 > storage_volume.storage_pool_id = db_pool.id > storage_volume.write_attribute(storage_volume.volume_name, volume.name) > - storage_volume.key = volume.key > + storage_volume.key = volume.get_attr('key') > storage_volume.lv_owner_perms = owner > storage_volume.lv_group_perms = group > storage_volume.lv_mode_perms = mode > @@ -661,14 +661,14 @@ class TaskOmatic > > existing_vol = StorageVolume.find(:first, :conditions => > ["storage_pool_id = ? AND key = ?", > - db_pool_phys.id, volume.key]) > + db_pool_phys.id, volume.get_attr('key')]) > > - puts "Existing volume is #{existing_vol}, searched for storage volume key and #{volume.key}" > + puts "Existing volume is #{existing_vol}, searched for storage volume key and #{volume.get_attr('key')}" > # Only add if it's not already there. > if not existing_vol > add_volume_to_db(db_pool_phys, volume); > else > - @logger.debug "Scanned volume #{volume.key} already exists in db.." > + @logger.debug "Scanned volume #{volume.get_attr('key')} already exists in db.." > end > > # Now check for an LVM pool carving up this volume. > @@ -710,11 +710,11 @@ class TaskOmatic > lvm_storage_volume = StorageVolume.factory(lvm_db_pool.get_type_label) > existing_vol = StorageVolume.find(:first, :conditions => > ["storage_pool_id = ? AND key = ?", > - lvm_db_pool.id, lvm_volume.key]) > + lvm_db_pool.id, lvm_volume.get_attr('key')]) > if not existing_vol > add_volume_to_db(lvm_db_pool, lvm_volume, "0744", "0744", "0744"); > else > - @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.mainloop() > - > -- > 1.7.0 > > _______________________________________________ > Ovirt-devel mailing list > Ovirt-devel at redhat.com > https://www.redhat.com/mailman/listinfo/ovirt-develACK and pushed. Thank you for the contribution. :) -- Darryl L. Pierce, Sr. Software Engineer @ Red Hat, Inc. Delivering value year after year. Red Hat ranks #1 in value among software vendors. http://www.redhat.com/promo/vendor/ -------------- next part -------------- A non-text attachment was scrubbed... Name: not available Type: application/pgp-signature Size: 198 bytes Desc: not available URL: <http://listman.redhat.com/archives/ovirt-devel/attachments/20100225/9b64bfbd/attachment.sig>
Apparently Analagous Threads
- [PATCH] Use volume key instead of path to identify volume.
- [PATCH server] Use qpid for migration and add more debugging to taskomatic.
- [PATCH server] Add more debugging to storage tasks
- [PATCH server] Update daemons to use new QMF.
- re-sending outstanding controller refactoring patches after rebase