search for: export_path

...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 GLUSTERFSLibvirtPool.new(pool.ip_addr, pool.export_path, logger) elsif pool[:type] == "LvmStoragePool" # OK, if this is LVM storage, there are two cases we need to care about: # 1) this is...

...diff --git a/src/app/views/storage/_form.rhtml b/src/app/views/storage/_form.rhtml index ea2b0c4..1e7f22f 100644 --- a/src/app/views/storage/_form.rhtml +++ b/src/app/views/storage/_form.rhtml @@ -12,6 +12,8 @@ <%= text_field_with_label "Export Path:", 'storage_pool', 'export_path' if @storage_pool[:type] == "NfsStoragePool" %> +<%= text_field_with_label "Export Path:", 'storage_pool', 'export_path' if @storage_pool[:type] == "GlusterfsStoragePool" %> + <!--[eoform:storage_pool]--> diff --git a/src/a...

...diff --git a/src/app/views/storage/_form.rhtml b/src/app/views/storage/_form.rhtml index ea2b0c4..1e7f22f 100644 --- a/src/app/views/storage/_form.rhtml +++ b/src/app/views/storage/_form.rhtml @@ -12,6 +12,8 @@ <%= text_field_with_label "Export Path:", 'storage_pool', 'export_path' if @storage_pool[:type] == "NfsStoragePool" %> +<%= text_field_with_label "Export Path:", 'storage_pool', 'export_path' if @storage_pool[:type] == "GlusterfsStoragePool" %> + <!--[eoform:storage_pool]--> diff --git a/src/a...

...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 GLUSTERFSLibvirtPool.new(pool.ip_addr, pool.export_path, logger) elsif pool[:type] == "LvmStoragePool" # OK, if this is LVM storage, there are two cases we need to care about: # 1) this is...

...== "IscsiStoragePool" - return IscsiLibvirtPool.new(pool.ip_addr, pool[:target], pool[:port]) + return IscsiLibvirtPool.new(pool.ip_addr, pool[:target], pool[:port], logger) elsif pool[:type] == "NfsStoragePool" - return NFSLibvirtPool.new(pool.ip_addr, pool.export_path) + return NFSLibvirtPool.new(pool.ip_addr, pool.export_path, logger) elsif pool[:type] == "LvmStoragePool" # OK, if this is LVM storage, there are two cases we need to care about: # 1) this is a LUN with LVM already on it. In this case, all we need to @@ -212,7 +2...

...if pool[:type] == "IscsiStoragePool" - return IscsiLibvirtPool.new(pool.ip_addr, pool[:target]) + return IscsiLibvirtPool.new(pool.ip_addr, pool[:target], pool[:port]") elsif pool[:type] == "NfsStoragePool" return NFSLibvirtPool.new(pool.ip_addr, pool.export_path) elsif pool[:type] == "LvmStoragePool" @@ -220,8 +220,9 @@ class LibvirtPool end class IscsiLibvirtPool < LibvirtPool - def initialize(ip_addr, target) - super('iscsi') + def initialize(ip_addr, target, port) + mount = "#{ip_addr}-#{target}-#{port}" +...

...- def xmlequal?(docroot) - return false - end - - def self.factory(pool) - if pool[:type] == "IscsiStoragePool" - return IscsiLibvirtPool.new(pool.ip_addr, pool[:target]) - elsif pool[:type] == "NfsStoragePool" - return NFSLibvirtPool.new(pool.ip_addr, pool.export_path) - elsif pool[:type] == "LvmStoragePool" - # OK, if this is LVM storage, there are two cases we need to care about: - # 1) this is a LUN with LVM already on it. In this case, all we need to - # do is to create a new LV (== libvirt volume), and be done with it -...

...@logger.level = Logger::DEBUG + ensure_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: #{p...

...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_addr}:#{db_pool.type}:#{db_pool.target}:#{db_pool.export_path}" libvirt_pool = LibvirtPool.factory(db_pool, @logger) - libvirt_pool.connect(@session, node) + libvirt_pool.connect(@qmfc, node) # OK, the pool should be all set. The last thing we need to do is get # the path based on the volume key @@ -220,12 +225,12 @@ cla...