search for: libvirtpool

...atic.rb | 18 +++++++++--------- 2 files changed, 27 insertions(+), 20 deletions(-) diff --git a/src/task-omatic/task_storage.rb b/src/task-omatic/task_storage.rb index cdc0043..bfffa36 100644 --- a/src/task-omatic/task_storage.rb +++ b/src/task-omatic/task_storage.rb @@ -92,11 +92,12 @@ class LibvirtPool attr_reader :remote_pool - def initialize(type, name = nil) + def initialize(type, name = nil, logger = nil) @remote_pool = nil @build_on_start = true @remote_pool_defined = false @remote_pool_started = false + @logger = logger if name == nil @name = ty...

...40 +++++++++++++++++++++++++++++++ 2 files changed, 90 insertions(+), 0 deletions(-) diff --git a/src/task-omatic/task_storage.rb b/src/task-omatic/task_storage.rb index 77363ac..97ae4fc 100644 --- a/src/task-omatic/task_storage.rb +++ b/src/task-omatic/task_storage.rb @@ -202,6 +202,8 @@ class LibvirtPool return IscsiLibvirtPool.new(pool.ip_addr, pool[:target], pool[:port], logger) elsif pool[:type] == "NfsStoragePool" return NFSLibvirtPool.new(pool.ip_addr, pool.export_path, logger) + elsif pool[:type] == "GlusterfsStoragePool" + return GLUSTERFSLibvir...

...sk_storage.rb | 16 +++++++++------- 1 files changed, 9 insertions(+), 7 deletions(-) diff --git a/src/task-omatic/task_storage.rb b/src/task-omatic/task_storage.rb index a2188d7..4961b83 100644 --- a/src/task-omatic/task_storage.rb +++ b/src/task-omatic/task_storage.rb @@ -129,7 +129,7 @@ class LibvirtPool end if @remote_pool == nil - result = node.storagePoolDefineXML(@xml.to_s) + result = node.storagePoolDefineXML(@xml.to_s, :timeout => 60 * 2) raise "Error creating pool: #{result.text}" unless result.status == 0 @remote_pool = session.object(:object...

...++++++++++++++++++++++++++++++++++++ 1 files changed, 50 insertions(+), 0 deletions(-) diff --git a/src/task-omatic/task_storage.rb b/src/task-omatic/task_storage.rb index 8165818..77b0166 100644 --- a/src/task-omatic/task_storage.rb +++ b/src/task-omatic/task_storage.rb @@ -202,6 +202,8 @@ class LibvirtPool return IscsiLibvirtPool.new(pool.ip_addr, pool[:target], pool[:port], logger) elsif pool[:type] == "NfsStoragePool" return NFSLibvirtPool.new(pool.ip_addr, pool.export_path, logger) + elsif pool[:type] == "GlusterfsStoragePool" + return GLUSTERFSLibvir...

...age_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 = nil - @build_on_start = true - @remote_pool_defined = false - @remote_pool_started = false - - if name == nil - @name = type + "-" + String.random_alphanume...

...tic/taskomatic.rb | 10 +++++----- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/src/task-omatic/task_storage.rb b/src/task-omatic/task_storage.rb index 77363ac..8165818 100644 --- a/src/task-omatic/task_storage.rb +++ b/src/task-omatic/task_storage.rb @@ -132,7 +132,7 @@ class LibvirtPool if @remote_pool == nil @logger.debug("Defining new storage pool: #{@xml.to_s} on host: #{node.hostname}") - result = node.storagePoolDefineXML(@xml.to_s, :timeout => 60 * 2) + result = node.storagePoolDefineXML(@xml.to_s, :timeout => 60 * 10) raise &qu...

...ume = StorageVolume.factory("NFS", :filename => filename) + image_volume = StorageVolume.factory("NFS", :filename => filename, :key => filename) image_volume.storage_pool image_pool = StoragePool.factory(StoragePool::NFS) @@ -116,13 +116,14 @@ class LibvirtPool @xml.root.elements["target"].add_element("path") end - def connect(session, node) - pools = session.objects(:class => 'pool', 'node' => node.object_id) + def connect(qmfc, node) + pools = qmfc.objects(:class => 'pool', 'node...

...nsure_credentials server, port = nil @@ -197,6 +206,7 @@ class TaskOmatic phys_libvirt_pool.connect(@session, node) 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}" +...