self._vdiskcopyops_loop = loopingcall.FixedIntervalLoopingCall(
self._check_volume_copy_ops)
self._vdiskcopyops_loop.start(interval=self.VDISKCOPYOPS_INTERVAL)
+ LOG.debug('leave: do_setup')
+ # v2 replication setup
+ self._do_replication_setup()
+
+ def _validate_pools_exist(self):
+ # Validate that the pool exists
+ pools = self.configuration.storwize_svc_volpool_name
+ for pool in pools:
+ try:
+ self._helpers.get_pool_attrs(pool)
+ except exception.VolumeBackendAPIException:
+ msg = _('Failed getting details for pool %s.') % pool
+ raise exception.InvalidInput(reason=msg)
+
def check_for_setup_error(self):
"""Ensure that the flags are set properly."""
LOG.debug('enter: check_for_setup_error')