class InitiatorConnector(executor.Executor):
def __init__(self, root_helper, driver=None,
execute=putils.execute, *args, **kwargs):
- super(InitiatorConnector, self).__init__(root_helper, execute,
+ super(InitiatorConnector, self).__init__(root_helper, execute=execute,
*args, **kwargs)
if not driver:
driver = host_driver.HostDriver()
LOG.debug("Factory for %s" % protocol)
protocol = protocol.upper()
if protocol == "ISCSI":
- return ISCSIConnector(execute=execute,
+ return ISCSIConnector(root_helper=root_helper,
driver=driver,
- root_helper=root_helper,
+ execute=execute,
use_multipath=use_multipath)
elif protocol == "FIBRE_CHANNEL":
- return FibreChannelConnector(execute=execute,
+ return FibreChannelConnector(root_helper=root_helper,
driver=driver,
- root_helper=root_helper,
+ execute=execute,
use_multipath=use_multipath)
elif protocol == "AOE":
- return AoEConnector(execute=execute,
+ return AoEConnector(root_helper=root_helper,
driver=driver,
- root_helper=root_helper)
+ execute=execute)
elif protocol == "NFS" or protocol == "GLUSTERFS":
return RemoteFsConnector(mount_type=protocol.lower(),
- execute=execute,
+ root_helper=root_helper,
driver=driver,
- root_helper=root_helper)
+ execute=execute)
elif protocol == "LOCAL":
- return LocalConnector(execute=execute,
+ return LocalConnector(root_helper=root_helper,
driver=driver,
- root_helper=root_helper)
+ execute=execute)
else:
msg = (_("Invalid InitiatorConnector protocol "
"specified %(protocol)s") %
execute=putils.execute, use_multipath=False,
*args, **kwargs):
self._linuxscsi = linuxscsi.LinuxSCSI(root_helper, execute)
- super(ISCSIConnector, self).__init__(root_helper, driver, execute,
- *args, **kwargs)
+ super(ISCSIConnector, self).__init__(root_helper, driver=driver,
+ execute=execute, *args, **kwargs)
self.use_multipath = use_multipath
def set_execute(self, execute):
*args, **kwargs):
self._linuxscsi = linuxscsi.LinuxSCSI(root_helper, execute)
self._linuxfc = linuxfc.LinuxFibreChannel(root_helper, execute)
- super(FibreChannelConnector, self).__init__(root_helper, driver,
- execute, *args, **kwargs)
+ super(FibreChannelConnector, self).__init__(root_helper, driver=driver,
+ execute=execute, *args,
+ **kwargs)
self.use_multipath = use_multipath
def set_execute(self, execute):
"""Connector class to attach/detach AoE volumes."""
def __init__(self, root_helper, driver=None,
execute=putils.execute, *args, **kwargs):
- super(AoEConnector, self).__init__(root_helper, driver, execute,
- *args, **kwargs)
+ super(AoEConnector, self).__init__(root_helper, driver=driver,
+ execute=execute, *args, **kwargs)
def _get_aoe_info(self, connection_properties):
shelf = connection_properties['target_shelf']
execute=putils.execute, *args, **kwargs):
self._remotefsclient = remotefs.RemoteFsClient(mount_type,
execute, root_helper)
- super(RemoteFsConnector, self).__init__(driver, execute, root_helper,
- *args, **kwargs)
+ super(RemoteFsConnector, self).__init__(root_helper, driver=driver,
+ execute=execute, *args,
+ **kwargs)
def set_execute(self, execute):
super(RemoteFsConnector, self).set_execute(execute)
def __init__(self, root_helper, driver=None, execute=putils.execute,
*args, **kwargs):
- super(LocalConnector, self).__init__(root_helper,
- driver,
- execute,
- *args,
- **kwargs)
+ super(LocalConnector, self).__init__(root_helper, driver=driver,
+ execute=execute, *args, **kwargs)
def connect_volume(self, connection_properties):
"""Connect to a volume.