[Ovirt-devel] [PATCH server] Add more logging to taskomatic.
Ian Main
imain at redhat.com
Fri Apr 24 20:51:04 UTC 2009
This patch logs each task as it's started and lets you know what
hosts it chooses for scanning and vm start.
Signed-off-by: Ian Main <imain at redhat.com>
---
src/task-omatic/taskomatic.rb | 19 +++++++++++++++----
1 files changed, 15 insertions(+), 4 deletions(-)
diff --git a/src/task-omatic/taskomatic.rb b/src/task-omatic/taskomatic.rb
index f852c32..b595364 100755
--- a/src/task-omatic/taskomatic.rb
+++ b/src/task-omatic/taskomatic.rb
@@ -216,6 +216,7 @@ class TaskOmatic
end
def task_create_vm(task)
+ @logger.info "starting task_create_vm"
# This is mostly just a place holder.
vm = find_vm(task, false)
if vm.state != Vm::STATE_PENDING
@@ -255,6 +256,7 @@ class TaskOmatic
def task_shutdown_or_destroy_vm(task, action)
+ @logger.info "starting task_shutdown_or_destroy_vm"
db_vm = task.vm
vm = @session.object(:class => 'domain', 'uuid' => db_vm.uuid)
if !vm
@@ -310,6 +312,7 @@ class TaskOmatic
end
def task_start_vm(task)
+ @logger.info "starting task_start_vm"
db_vm = find_vm(task, false)
vm = @session.object(:class => "domain", 'uuid' => db_vm.uuid)
@@ -329,6 +332,7 @@ class TaskOmatic
node = @session.object(:class => "node", 'hostname' => db_host.hostname)
raise "Unable to find host #{db_host.hostname} to create VM on." unless node
+ @logger.info("VM will be started on node #{node.hostname}")
image_volume = task_storage_cobbler_setup(db_vm)
@@ -399,6 +403,7 @@ class TaskOmatic
end
def task_suspend_vm(task)
+ @logger.info "starting task_suspend_vm"
db_vm = task.vm
dom = @session.object(:class => 'domain', 'uuid' => db_vm.uuid)
raise "Unable to locate VM to suspend" unless dom
@@ -416,6 +421,7 @@ class TaskOmatic
end
def task_resume_vm(task)
+ @logger.info "starting task_resume_vm"
db_vm = task.vm
dom = @session.object(:class => 'domain', 'uuid' => db_vm.uuid)
raise "Unable to locate VM to resume" unless dom
@@ -436,6 +442,7 @@ class TaskOmatic
end
def task_save_vm(task)
+ @logger.info "starting task_save_vm"
# FIXME: This task is actually very broken. It saves to a local
# disk on the node which could be volatile memory, and there is no
@@ -457,6 +464,7 @@ class TaskOmatic
end
def task_restore_vm(task)
+ @logger.info "starting task_restore_vm"
# FIXME: This is also broken, see task_save_vm FIXME.
db_vm = task.vm
@@ -535,7 +543,7 @@ class TaskOmatic
end
def task_migrate_vm(task)
- @logger.info "migrate_vm"
+ @logger.info "starting task_migrate_vm"
# here, we are given an id for a VM to migrate; we have to lookup which
# physical host it is running on
@@ -585,7 +593,7 @@ class TaskOmatic
# represented in the database
def task_refresh_pool(task)
- @logger.info "refresh_pool"
+ @logger.info "starting task_refresh_pool"
db_pool_phys = task.storage_pool
raise "Could not find storage pool" unless db_pool_phys
@@ -601,6 +609,8 @@ class TaskOmatic
# little tricky, though; we have to make sure that we don't pull the
# database entry out from underneath a possibly running VM (or do we?)
begin
+ @logger.info("refresh being done on node #{node.hostname}")
+
phys_libvirt_pool = LibvirtPool.factory(db_pool_phys)
phys_libvirt_pool.connect(@session, node)
db_pool_phys.state = StoragePool::STATE_AVAILABLE
@@ -678,7 +688,7 @@ class TaskOmatic
end
def task_create_volume(task)
- @logger.info "create_volume"
+ @logger.info "starting task_create_volume"
db_volume = task.storage_volume
raise "Could not find storage volume to create" unless db_volume
@@ -730,7 +740,7 @@ class TaskOmatic
end
def task_delete_volume(task)
- @logger.info "delete_volume"
+ @logger.info "starting task_delete_volume"
db_volume = task.storage_volume
raise "Could not find storage volume to create" unless db_volume
@@ -792,6 +802,7 @@ class TaskOmatic
end
def task_clear_vms_host(task)
+ @logger.info "starting task_clear_vms_host"
src_host = task.host
src_host.vms.each do |vm|
--
1.6.0.6
More information about the ovirt-devel
mailing list