def call(env)
config = env[:machine].provider_config
@@lock.synchronize do
break unless env[:machine].provider.driver.connection.pools.all(
name: config.storage_pool_name
).empty?
@logger.info("No storage pool '#{config.storage_pool_name}' is available.")
raise Errors::NoStoragePool if config.storage_pool_name != 'default'
@logger.info("Creating storage pool 'default'")
begin
@storage_pool_path = storage_pool_path(env)
@storage_pool_uid = storage_uid(env)
@storage_pool_gid = storage_gid(env)
xml = to_xml('default_storage_pool')
@logger.debug {
"Creating Storage Pool with XML:\n#{xml}"
}
libvirt_pool = env[:machine].provider.driver.connection.client.define_storage_pool_xml(
xml
)
libvirt_pool.build
libvirt_pool.create
rescue => e
raise Errors::CreatingStoragePoolError,
error_message: e.message
end
raise Errors::NoStoragePool unless libvirt_pool
end
@app.call(env)
end