executor=self._execute,
lvm_conf=lvm_conf_file)
- self.remove_export(ctxt, volume)
self._create_volume(volume['name'],
self._sizestr(volume['size']),
lvm_type,
self.configuration.volume_dd_blocksize,
execute=self._execute)
self._delete_volume(volume)
- model_update = self.create_export(ctxt, volume, vg=dest_vg)
- return (True, model_update)
+ return (True, None)
else:
message = (_("Refusing to migrate volume ID: %(id)s. Please "
"check your configuration because source and "
updates = {'migration_status': None}
if status_update:
updates.update(status_update)
- try:
- model_update = self.driver.create_export(ctxt,
- volume_ref)
- if model_update:
- updates.update(model_update)
- except Exception:
- LOG.exception(_LE("Failed to create export for "
- "volume: %s"), volume_ref['id'])
- finally:
- self.db.volume_update(ctxt, volume_ref['id'], updates)
+ self.db.volume_update(ctxt, volume_ref['id'], updates)
if not moved:
try:
self._migrate_volume_generic(ctxt, volume_ref, host,
updates = {'migration_status': None}
if status_update:
updates.update(status_update)
- try:
- model_update = self.driver.create_export(ctxt,
- volume_ref)
- if model_update:
- updates.update(model_update)
- except Exception:
- LOG.exception(_LE("Failed to create export for "
- "volume: %s"), volume_ref['id'])
- finally:
- self.db.volume_update(ctxt, volume_ref['id'], updates)
+ self.db.volume_update(ctxt, volume_ref['id'], updates)
@periodic_task.periodic_task
def _report_driver_status(self, context):