OpenStack Study: cinder
OpenStack IndexPreviousNext
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def ensure_export(self, context, volume):
def create_export(self, context, volume):
def remove_export(self, context, volume):
def check_for_export(self, context, volume_id):
def initialize_connection(self, volume, connector):
def terminate_connection(self, volume, connector, **kwargs):
def _build_initiator_target_map(self, storage_system, connector):
def extend_volume(self, volume, new_size):
def get_volume_stats(self, refresh=False):
def update_volume_stats(self):
\OpenStack\cinder-2014.1\cinder\volume\drivers\emc\emc_smis_iscsi.py
class EMCSMISISCSIDriver(driver.ISCSIDriver):
def __init__(self, *args, **kwargs):
def check_for_setup_error(self):
def create_volume(self, volume):
def create_volume_from_snapshot(self, volume, snapshot):
def create_cloned_volume(self, volume, src_vref):
def delete_volume(self, volume):
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def ensure_export(self, context, volume):
def create_export(self, context, volume):
def remove_export(self, context, volume):
def check_for_export(self, context, volume_id):
def initialize_connection(self, volume, connector):
def _do_iscsi_discovery(self, volume):
def smis_get_iscsi_properties(self, volume, connector):
def terminate_connection(self, volume, connector, **kwargs):
def extend_volume(self, volume, new_size):
def get_volume_stats(self, refresh=False):
def update_volume_stats(self):
\OpenStack\cinder-2014.1\cinder\volume\drivers\emc\emc_vnx_cli.py
class EMCVnxCli(object):
def __init__(self, prtcl, configuration=None):
def _cli_execute(self, *cmd, **kwargv):
def create_volume(self, volume):
def _wait_for_lun_ready(volumename, start_time):
def delete_volume(self, volume):
def extend_volume(self, volume, new_size):
def update_volume_status(self):
def create_export(self, context, volume):
def _find_lun_id(self, volumename):
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def _wait_for_snap_delete(snapshot, start_time):
def create_volume_from_snapshot(self, volume, snapshot):
def _wait_for_sync_status(volumename, start_time):
def create_cloned_volume(self, volume, src_vref):
def get_storage_group(self, hostname):
def find_device_details(self, volume, storage_group):
def _get_host_lun_id(self, host_lun_id_list):
def _add_lun_to_storagegroup(self, volume, storage_group):
def _remove_lun_from_storagegroup(self, device_number, storage_group):
def initialize_connection(self, volume, connector):
def terminate_connection(self, volume, connector):
def _find_iscsi_protocol_endpoints(self, device_sp):
def _get_volumetype_extraspecs(self, volume):
def _get_provisioning_by_volume(self, volume):
\OpenStack\cinder-2014.1\cinder\volume\drivers\emc\__init__.py
\OpenStack\cinder-2014.1\cinder\volume\drivers\eqlx.py
def with_timeout(f):
def __inner(self, *args, **kwargs):
class DellEQLSanISCSIDriver(SanISCSIDriver):
def __init__(self, *args, **kwargs):
def _get_output(self, chan):
def _get_prefixed_value(self, lines, prefix):
def _ssh_execute(self, ssh, command, *arg, **kwargs):
def _run_ssh(self, cmd_list, attempts=1):
def _eql_execute(self, *args, **kwargs):
def _get_volume_data(self, lines):
def _get_space_in_gb(self, val):
def _update_volume_stats(self):
def _check_volume(self, volume):
def do_setup(self, context):
def create_volume(self, volume):
def delete_volume(self, volume):
def create_snapshot(self, snapshot):
def create_volume_from_snapshot(self, volume, snapshot):
def create_cloned_volume(self, volume, src_vref):
def delete_snapshot(self, snapshot):
def initialize_connection(self, volume, connector):
def terminate_connection(self, volume, connector, force=False, **kwargs):
def create_export(self, context, volume):
def ensure_export(self, context, volume):
def remove_export(self, context, volume):
def extend_volume(self, volume, new_size):
def local_path(self, volume):
\OpenStack\cinder-2014.1\cinder\volume\drivers\glusterfs.py
class GlusterfsDriver(nfs.RemoteFsDriver):
def __init__(self, execute=processutils.execute, *args, **kwargs):
def set_execute(self, execute):
def do_setup(self, context):
def check_for_setup_error(self):
def _local_volume_dir(self, volume):
def _local_path_volume(self, volume):
def _local_path_volume_info(self, volume):
def _qemu_img_info(self, path):
def get_active_image_from_info(self, volume):
def create_cloned_volume(self, volume, src_vref):
def create_volume(self, volume):
def create_volume_from_snapshot(self, volume, snapshot):
def _copy_volume_from_snapshot(self, snapshot, volume, volume_size):
def delete_volume(self, volume):
def create_snapshot(self, snapshot):
def _create_snapshot(self, snapshot):
def _create_qcow2_snap_file(self, snapshot, backing_filename, new_snap_path):
def _create_snapshot_offline(self, snapshot, path_to_disk):
def _read_file(self, filename):
def _read_info_file(self, info_path, empty_if_missing=False):
def _write_info_file(self, info_path, snap_info):
def _get_matching_backing_file(self, backing_chain, snapshot_file):
def delete_snapshot(self, snapshot):
def _delete_snapshot(self, snapshot):
def _delete_snapshot_online(self, context, snapshot, info):
def _get_backing_chain_for_path(self, volume, path):
def _qemu_img_commit(self, path):
def ensure_export(self, ctx, volume):
def create_export(self, ctx, volume):
def remove_export(self, ctx, volume):
def validate_connector(self, connector):
def initialize_connection(self, volume, connector):
def terminate_connection(self, volume, connector, **kwargs):
def copy_volume_to_image(self, context, volume, image_service, image_meta):
def extend_volume(self, volume, size_gb):
def _do_create_volume(self, volume):
def _ensure_shares_mounted(self):
def _ensure_share_writable(self, path):
def _ensure_share_mounted(self, glusterfs_share):
def _find_share(self, volume_size_for):
def _get_hash_str(self, base_str):
def _get_mount_point_for_share(self, glusterfs_share):
def _get_available_capacity(self, glusterfs_share):
def _get_capacity_info(self, glusterfs_share):
def _mount_glusterfs(self, glusterfs_share, mount_path, ensure=False):
def _get_mount_point_base(self):
def backup_volume(self, context, backup, backup_service):
\OpenStack\cinder-2014.1\cinder\volume\drivers\hds\hds.py
def factory_bend():
def _loc_info(loc):
def _do_lu_range_check(start, end, maxlun):
def _xml_read(root, element, check=None):
def _read_config(xml_config_file):
class HUSDriver(driver.ISCSIDriver):
def _array_info_get(self):
def _get_iscsi_info(self):
def _get_service(self, volume):
def _get_stats(self):
def _get_hdp_list(self):
def _check_hdp_list(self):
def _id_to_vol(self, idd):
def _update_vol_location(self, id, loc):
def __init__(self, *args, **kwargs):
def check_for_setup_error(self):
def do_setup(self, context):
def ensure_export(self, context, volume):
def create_export(self, context, volume):
def create_volume(self, volume):
def create_cloned_volume(self, dst, src):
def extend_volume(self, volume, new_size):
def delete_volume(self, volume):
def remove_export(self, context, volume):
def initialize_connection(self, volume, connector):
def terminate_connection(self, volume, connector, **kwargs):
def create_volume_from_snapshot(self, volume, snapshot):
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def get_volume_stats(self, refresh=False):
\OpenStack\cinder-2014.1\cinder\volume\drivers\hds\hus_backend.py
class HusBackend:
def get_version(self, cmd, ver, ip0, ip1, user, pw):
def get_iscsi_info(self, cmd, ver, ip0, ip1, user, pw):
def get_hdp_info(self, cmd, ver, ip0, ip1, user, pw):
def create_lu(self, cmd, ver, ip0, ip1, user, pw, id, hdp, start, end, size):
def delete_lu(self, cmd, ver, ip0, ip1, user, pw, id, lun):
def create_dup(self, cmd, ver, ip0, ip1, user, pw, id, src_lun, hdp, start, end, size):
def extend_vol(self, cmd, ver, ip0, ip1, user, pw, id, lun, new_size):
def add_iscsi_conn(self, cmd, ver, ip0, ip1, user, pw, id, lun, ctl, port, iqn, initiator):
def del_iscsi_conn(self, cmd, ver, ip0, ip1, user, pw, id, lun, ctl, port, iqn, initiator):
\OpenStack\cinder-2014.1\cinder\volume\drivers\hds\__init__.py
\OpenStack\cinder-2014.1\cinder\volume\drivers\huawei\huawei_dorado.py
class HuaweiDoradoISCSIDriver(huawei_t.HuaweiTISCSIDriver):
def __init__(self, *args, **kwargs):
def do_setup(self, context):
class HuaweiDoradoFCDriver(huawei_t.HuaweiTFCDriver):
def __init__(self, *args, **kwargs):
def do_setup(self, context):
def _get_host_port_details(self, hostid):
def _get_tgt_fc_port_wwns(self, port_details):
def initialize_connection(self, volume, connector):
\OpenStack\cinder-2014.1\cinder\volume\drivers\huawei\huawei_hvs.py
class HuaweiHVSISCSIDriver(driver.ISCSIDriver):
def __init__(self, *args, **kwargs):
def do_setup(self, context):
def check_for_setup_error(self):
def create_volume(self, volume):
def create_volume_from_snapshot(self, volume, snapshot):
def create_cloned_volume(self, volume, src_vref):
def extend_volume(self, volume, new_size):
def delete_volume(self, volume):
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def get_volume_stats(self, refresh=False):
def initialize_connection(self, volume, connector):
def terminate_connection(self, volume, connector, **kwargs):
def create_export(self, context, volume):
def ensure_export(self, context, volume):
def remove_export(self, context, volume):
class HuaweiHVSFCDriver(driver.FibreChannelDriver):
def __init__(self, *args, **kwargs):
def do_setup(self, context):
def check_for_setup_error(self):
def create_volume(self, volume):
def create_volume_from_snapshot(self, volume, snapshot):
def create_cloned_volume(self, volume, src_vref):
def extend_volume(self, volume, new_size):
def delete_volume(self, volume):
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def get_volume_stats(self, refresh=False):
def initialize_connection(self, volume, connector):
def terminate_connection(self, volume, connector, **kwargs):
def create_export(self, context, volume):
def ensure_export(self, context, volume):
def remove_export(self, context, volume):
\OpenStack\cinder-2014.1\cinder\volume\drivers\huawei\huawei_t.py
class HuaweiTISCSIDriver(driver.ISCSIDriver):
def __init__(self, *args, **kwargs):
def do_setup(self, context):
def check_for_setup_error(self):
def create_volume(self, volume):
def create_volume_from_snapshot(self, volume, snapshot):
def create_cloned_volume(self, volume, src_vref):
def extend_volume(self, volume, new_size):
def delete_volume(self, volume):
def create_export(self, context, volume):
def ensure_export(self, context, volume):
def remove_export(self, context, volume):
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def initialize_connection(self, volume, connector):
def _get_iscsi_params(self, initiator):
def _get_iscsi_conf(self, filename):
def _get_tgt_iqn(self, port_ip):
def _get_iscsi_tgt_port_info(self, port_ip):
def _add_iscsi_port_to_host(self, hostid, connector, multipathtype=0):
def _initiator_added(self, ininame):
def _add_initiator(self, ininame):
def _delete_initiator(self, ininame, attempts=2):
def terminate_connection(self, volume, connector, **kwargs):
def _remove_iscsi_port(self, hostid, connector):
def get_volume_stats(self, refresh=False):
class HuaweiTFCDriver(driver.FibreChannelDriver):
def __init__(self, *args, **kwargs):
def do_setup(self, context):
def check_for_setup_error(self):
def create_volume(self, volume):
def create_volume_from_snapshot(self, volume, snapshot):
def create_cloned_volume(self, volume, src_vref):
def extend_volume(self, volume, new_size):
def delete_volume(self, volume):
def create_export(self, context, volume):
def ensure_export(self, context, volume):
def remove_export(self, context, volume):
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def validate_connector(self, connector):
def initialize_connection(self, volume, connector):
def _get_connected_free_wwns(self):
def _add_fc_port_to_host(self, hostid, wwn, multipathtype=0):
def _get_host_port_details(self, host_id):
def _get_tgt_fc_port_wwns(self, port_details):
def _get_fc_port_ctr(self, port_details):
def terminate_connection(self, volume, connector, **kwargs):
def _remove_fc_ports(self, hostid, connector):
def get_volume_stats(self, refresh=False):
\OpenStack\cinder-2014.1\cinder\volume\drivers\huawei\huawei_utils.py
def parse_xml_file(filepath):
def get_xml_item(xml_root, item):
def is_xml_item_exist(xml_root, item, attrib_key=None):
def is_xml_item_valid(xml_root, item, valid_list, attrib_key=None):
def get_conf_host_os_type(host_ip, config):
\OpenStack\cinder-2014.1\cinder\volume\drivers\huawei\rest_common.py
class HVSCommon():
def __init__(self, configuration):
def call(self, url=False, data=None, method=None):
def login(self):
def _init_tier_parameters(self, parameters, lunparam):
def _init_lun_parameters(self, name, parameters):
def _init_qos_parameters(self, parameters, lun_param):
def _assert_rest_result(self, result, err_str):
def _assert_data_in_result(self, result, msg):
def _create_volume(self, lun_param):
def create_volume(self, volume):
def _get_volume_size(self, poolinfo, volume):
def delete_volume(self, volume):
def _delete_lun_from_qos_policy(self, volume, lun_id):
def _delete_lun(self, lun_id):
def _encode_name(self, name):
def _find_pool_info(self):
def _get_volume_by_name(self, name):
def _active_snapshot(self, snapshot_id):
def _create_snapshot(self, snapshot):
def create_snapshot(self, snapshot):
def _stop_snapshot(self, snapshot):
def _delete_snapshot(self, snapshotid):
def delete_snapshot(self, snapshot):
def _get_snapshotid_by_name(self, name):
def _copy_volume(self, volume, copy_name, src_lun, tgt_lun):
def create_volume_from_snapshot(self, volume, snapshot):
def create_cloned_volume(self, volume, src_vref):
def _create_luncopy(self, luncopyname, srclunid, tgtlunid):
def _add_host_into_hostgroup(self, host_name, host_ip):
def _mapping_hostgroup_and_lungroup(self, volume_name, hostgroup_id, host_id):
def _ensure_initiator_added(self, initiator_name, hostid):
def initialize_connection_iscsi(self, volume, connector):
def initialize_connection_fc(self, volume, connector):
def _get_iscsi_tgt_port(self):
def _find_hostgroup(self, groupname):
def _find_lungroup(self, lungroupname):
def _create_hostgroup(self, hostgroupname):
def _create_lungroup(self, lungroupname):
def _delete_lungroup(self, lungroupid):
def _lungroup_associated(self, viewid, lungroupid):
def _hostgroup_associated(self, viewid, hostgroupid):
def _find_host_lun_id(self, hostid, lunid):
def _find_host(self, hostname):
def _add_host(self, hostname, type):
def _associate_host_to_hostgroup(self, hostgroupid, hostid):
def _associate_lun_to_lungroup(self, lungroupid, lunid):
def _delete_associated_lun_from_lungroup(self, lungroupid, lunid):
def _initiator_is_added_to_array(self, ininame):
def _is_initiator_associated_to_host(self, ininame):
def _add_initiator_to_array(self, ininame):
def _associate_initiator_to_host(self, ininame, hostid):
def _find_mapping_view(self, name):
def _add_mapping_view(self, name, host_id):
def _associate_hostgroup_to_view(self, viewID, hostGroupID):
def _associate_lungroup_to_view(self, viewID, lunGroupID):
def _delete_lungroup_mapping_view(self, view_id, lungroup_id):
def _delete_hostgoup_mapping_view(self, view_id, hostgroup_id):
def _delete_mapping_view(self, view_id):
def terminate_connection(self, volume, connector, **kwargs):
def login_out(self):
def _start_luncopy(self, luncopyid):
def _get_capacity(self):
def _get_lun_conf_params(self):
def _wait_for_luncopy(self, luncopyid):
def _get_luncopy_info(self, luncopyid):
def _delete_luncopy(self, luncopyid):
def _get_connected_free_wwns(self):
def _add_fc_port_to_host(self, hostid, wwn, multipathtype=0):
def _get_iscsi_port_info(self, ip):
def _get_iscsi_conf(self):
def _get_tgt_iqn(self, iscsiip):
def _get_fc_target_wwpns(self, wwn):
def _parse_volume_type(self, volume):
def update_volume_stats(self, refresh=False):
def _find_qos_policy_info(self, policy_name):
def _update_qos_policy_lunlist(self, lunlist, policy_id):
def _get_login_info(self):
def _change_file_mode(self, filepath):
def _check_conf_file(self):
def _get_iscsi_params(self, connector):
def extend_volume(self, volume, new_size):
\OpenStack\cinder-2014.1\cinder\volume\drivers\huawei\ssh_common.py
def ssh_read(user, channel, cmd, timeout):
class TseriesCommon():
def __init__(self, configuration=None):
def do_setup(self, context):
def _check_conf_file(self):
def _get_login_info(self):
def _change_file_mode(self, filepath):
def _get_lun_distribution_info(self, luns):
def check_for_setup_error(self):
def _get_all_luncopy_name(self):
def _get_extended_lun(self, luns):
def create_volume(self, volume):
def _name_translate(self, name):
def _update_login_info(self):
def _parse_volume_type(self, typeid):
def _create_volume(self, name, size, params):
def _calculate_lun_ctr(self):
def _update_lun_distribution(self, ctr):
def _get_lun_params(self):
def _parse_conf_lun_params(self):
def _get_maximum_capacity_pool_id(self, pools_conf, pools_dev, luntype):
def _execute_cli(self, cmd):
def _reset_transport_timeout(self, ssh, time):
def delete_volume(self, volume):
def _check_volume_created(self, volume_id):
def _del_lun_from_extended_lun(self, extended_id, added_ids):
def _delete_volume(self, volumeid):
def create_volume_from_snapshot(self, volume, snapshot):
def _copy_volume(self, src_vol_id, tgt_vol_id):
def _create_luncopy(self, luncopyname, srclunid, tgtlunid):
def _start_luncopy(self, luncopyid):
def _wait_for_luncopy(self, luncopyname):
def _get_luncopy_info(self, luncopyname):
def _delete_luncopy(self, luncopyid):
def create_cloned_volume(self, tgt_volume, src_volume):
def _get_all_luns_info(self):
def _get_lun_id(self, lun_name):
def extend_volume(self, volume, new_size):
def _extend_volume(self, extended_vol_id, added_vol_id):
def create_snapshot(self, snapshot):
def _resource_pool_enough(self):
def _create_snapshot(self, snapshotname, srclunid):
def _get_snapshot_id(self, snapshotname):
def _active_snapshot(self, snapshotid):
def delete_snapshot(self, snapshot):
def _check_snapshot_created(self, snapshot_id):
def _snapshot_in_luncopy(self, snapshot_id):
def _delete_snapshot(self, snapshotid):
def _assert_cli_out(self, condition, func, msg, cmd, cliout):
def _assert_cli_operate_out(self, func, msg, cmd, cliout):
def map_volume(self, host_id, volume_id):
def add_host(self, host_name, host_ip, initiator=None):
def _get_hostgroup_id(self, groupname):
def _create_hostgroup(self, hostgroupname):
def _get_host_id(self, hostname, hostgroupid):
def _create_host(self, hostname, hostgroupid, type):
def _get_host_port_info(self, hostid):
def _get_host_map_info(self, hostid):
def get_lun_details(self, lun_id):
def change_lun_ctr(self, lun_id, ctr):
def remove_map(self, volume_id, host_name, initiator=None):
def _delete_map(self, mapid, attempts=2):
def _delete_hostport(self, portid):
def _delete_host(self, hostid):
def get_volume_stats(self, refresh=False):
def _update_volume_stats(self):
def _get_free_capacity(self):
def _get_dev_pool_info(self, pooltype):
class DoradoCommon(TseriesCommon):
def __init__(self, configuration=None):
def do_setup(self, context):
def _check_conf_file(self):
def _get_device_type(self):
def _get_lun_distribution_info(self, luns):
def _get_extended_lun(self, luns):
def _create_volume(self, name, size, params):
def _get_lun_id(self, name):
def create_volume_from_snapshot(self, volume, snapshot):
def create_cloned_volume(self, volume, src_vref):
def extend_volume(self, volume, new_size):
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def _get_lun_params(self):
def _parse_conf_lun_params(self):
def _get_free_capacity(self):
\OpenStack\cinder-2014.1\cinder\volume\drivers\huawei\__init__.py
class HuaweiVolumeDriver(object):
def __init__(self, *args, **kwargs):
def _instantiate_driver(self, *args, **kwargs):
def _get_conf_info(self, filename):
def __setattr__(self, name, value):
def __getattr__(self, name):
\OpenStack\cinder-2014.1\cinder\volume\drivers\ibm\gpfs.py
def _different(difference_tuple):
def _same_filesystem(path1, path2):
def _sizestr(size_in_g):
class GPFSDriver(driver.VolumeDriver):
def __init__(self, *args, **kwargs):
def _get_gpfs_state(self):
def _check_gpfs_state(self):
def _get_filesystem_from_path(self, path):
def _get_gpfs_cluster_id(self):
def _get_fileset_from_path(self, path):
def _verify_gpfs_pool(self, storage_pool):
def _update_volume_storage_pool(self, local_path, new_pool):
def _get_gpfs_fs_release_level(self, path):
def _get_gpfs_cluster_release_level(self):
def _is_gpfs_path(self, directory):
def _is_same_fileset(self, path1, path2):
def _same_cluster(self, host):
def _set_rw_permission(self, path, modebits='660'):
def _can_migrate_locally(self, host):
def do_setup(self, ctxt):
def check_for_setup_error(self):
def _create_sparse_file(self, path, size):
def _allocate_file_blocks(self, path, size):
def _gpfs_change_attributes(self, options, path):
def _set_volume_attributes(self, path, metadata):
def create_volume(self, volume):
def create_volume_from_snapshot(self, volume, snapshot):
def create_cloned_volume(self, volume, src_vref):
def _delete_gpfs_file(self, fchild):
def delete_volume(self, volume):
def _gpfs_redirect(self, src):
def _create_gpfs_clone(self, src, dest):
def _create_gpfs_copy(self, src, dest):
def _create_gpfs_snap(self, src, dest=None):
def _is_gpfs_parent_file(self, gpfs_file):
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def local_path(self, volume):
def ensure_export(self, context, volume):
def create_export(self, context, volume):
def remove_export(self, context, volume):
def initialize_connection(self, volume, connector):
def terminate_connection(self, volume, connector, **kwargs):
def get_volume_stats(self, refresh=False):
def _update_volume_stats(self):
def clone_image(self, volume, image_location, image_id, image_meta):
def _is_cloneable(self, image_id):
def _clone_image(self, volume, image_location, image_id):
def copy_image_to_volume(self, context, volume, image_service, image_id):
def _resize_volume_file(self, volume, new_size):
def extend_volume(self, volume, new_size):
def copy_volume_to_image(self, context, volume, image_service, image_meta):
def backup_volume(self, context, backup, backup_service):
def restore_backup(self, context, backup, volume, backup_service):
def _migrate_volume(self, volume, host):
def migrate_volume(self, context, volume, host):
def retype(self, context, volume, new_type, diff, host):
def _mkfs(self, volume, filesystem, label=None):
def _get_available_capacity(self, path):
def _verify_gpfs_path_state(self, path):
\OpenStack\cinder-2014.1\cinder\volume\drivers\ibm\ibmnas.py
class IBMNAS_NFSDriver(nfs.NfsDriver, san.SanDriver):
def __init__(self, execute=utils.execute, *args, **kwargs):
def set_execute(self, execute):
def do_setup(self, context):
def check_for_setup_error(self):
def _get_provider_location(self, volume_id):
def _get_export_path(self, volume_id):
def _update_volume_stats(self):
def _create_ibmnas_snap(self, src, dest, mount_path):
def _create_ibmnas_copy(self, src, dest, snap):
def _resize_volume_file(self, path, new_size):
def extend_volume(self, volume, new_size):
def _delete_snapfiles(self, fchild, mount_point):
def delete_volume(self, volume):
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def create_volume_from_snapshot(self, volume, snapshot):
def create_cloned_volume(self, volume, src_vref):
\OpenStack\cinder-2014.1\cinder\volume\drivers\ibm\storwize_svc\helpers.py
class StorwizeHelpers(object):
def __init__(self, run_ssh):
def handle_keyerror(cmd, out):
def compression_enabled(self):
def get_system_info(self):
def get_pool_attrs(self, pool):
def get_available_io_groups(self):
def get_node_info(self):
def add_iscsi_ip_addrs(self, storage_nodes):
def add_fc_wwpns(self, storage_nodes):
def add_chap_secret_to_host(self, host_name):
def get_chap_secret_for_host(self, host_name):
def get_conn_fc_wwpns(self, host):
def get_host_from_connector(self, connector):
def create_host(self, connector):
def delete_host(self, host_name):
def map_vol_to_host(self, volume_name, host_name, multihostmap):
def unmap_vol_from_host(self, volume_name, host_name):
def build_default_opts(config):
def check_vdisk_opts(state, opts):
def get_vdisk_params(self, config, state, type_id, volume_type=None):
def _get_vdisk_create_params(opts):
def create_vdisk(self, name, size, units, pool, opts):
def get_vdisk_attributes(self, vdisk):
def is_vdisk_defined(self, vdisk_name):
def _prepare_fc_map(self, fc_map_id, timeout):
def run_flashcopy(self, source, target, timeout, full_copy=True):
def _get_vdisk_fc_mappings(self, vdisk):
def _get_flashcopy_mapping_attributes(self, fc_map_id):
def _check_vdisk_fc_mappings(self, name, allow_snaps=True):
def ensure_vdisk_no_fc_mappings(self, name, allow_snaps=True):
def delete_vdisk(self, vdisk, force):
def create_copy(self, src, tgt, src_id, config, opts, full_copy):
def extend_vdisk(self, vdisk, amount):
def add_vdisk_copy(self, vdisk, dest_pool, volume_type, state, config):
def is_vdisk_copy_synced(self, vdisk, copy_id):
def rm_vdisk_copy(self, vdisk, copy_id):
def can_migrate_to_host(host, state):
def change_vdisk_options(self, vdisk, changes, opts, state):
def change_vdisk_iogrp(self, vdisk, state, iogrp):
def vdisk_by_uid(self, vdisk_uid):
def is_vdisk_in_use(self, vdisk):
def rename_vdisk(self, vdisk, new_name):
\OpenStack\cinder-2014.1\cinder\volume\drivers\ibm\storwize_svc\ssh.py
class StorwizeSSH(object):
def __init__(self, run_ssh):
def _run_ssh(self, ssh_cmd):
def run_ssh_info(self, ssh_cmd, delim='!', with_header=False):
def run_ssh_assert_no_output(self, ssh_cmd):
def run_ssh_check_created(self, ssh_cmd):
def lsnode(self, node_id=None):
def lslicense(self):
def lssystem(self):
def lsmdiskgrp(self, pool):
def lsiogrp(self):
def lsportip(self):
def _create_port_arg(port_type, port_name):
def mkhost(self, host_name, port_type, port_name):
def addhostport(self, host, port_type, port_name):
def lshost(self, host=None):
def add_chap_secret(self, secret, host):
def lsiscsiauth(self):
def lsfabric(self, wwpn=None, host=None):
def mkvdiskhostmap(self, host, vdisk, lun, multihostmap):
def rmvdiskhostmap(self, host, vdisk):
def lsvdiskhostmap(self, vdisk):
def lshostvdiskmap(self, host):
def rmhost(self, host):
def mkvdisk(self, name, size, units, pool, opts, params):
def rmvdisk(self, vdisk, force=True):
def lsvdisk(self, vdisk):
def lsvdisks_from_filter(self, filter_name, value):
def chvdisk(self, vdisk, params):
def movevdisk(self, vdisk, iogrp):
def expandvdisksize(self, vdisk, amount):
def mkfcmap(self, source, target, full_copy):
def prestartfcmap(self, fc_map_id):
def startfcmap(self, fc_map_id):
def chfcmap(self, fc_map_id, copyrate='50', autodel='on'):
def stopfcmap(self, fc_map_id):
def rmfcmap(self, fc_map_id):
def lsvdiskfcmappings(self, vdisk):
def lsfcmap(self, fc_map_id):
def addvdiskcopy(self, vdisk, dest_pool, params):
def lsvdiskcopy(self, vdisk, copy_id=None):
def rmvdiskcopy(self, vdisk, copy_id):
def addvdiskaccess(self, vdisk, iogrp):
def rmvdiskaccess(self, vdisk, iogrp):
class CLIResponse(object):
def __init__(self, raw, ssh_cmd=None, delim='!', with_header=True):
def select(self, *keys):
def __getitem__(self, key):
def __iter__(self):
def __len__(self):
def _parse(self):
def get_reader(content, delim):
def append_dict(dict_, key, value):
\OpenStack\cinder-2014.1\cinder\volume\drivers\ibm\storwize_svc\__init__.py
class StorwizeSVCDriver(san.SanDriver):
def __init__(self, *args, **kwargs):
def do_setup(self, ctxt):
def check_for_setup_error(self):
def ensure_export(self, ctxt, volume):
def create_export(self, ctxt, volume):
def remove_export(self, ctxt, volume):
def validate_connector(self, connector):
def _get_vdisk_params(self, type_id, volume_type=None):
def initialize_connection(self, volume, connector):
def _make_initiator_target_map(self, initiator_wwpns, target_wwpns):
def terminate_connection(self, volume, connector, **kwargs):
def create_volume(self, volume):
def delete_volume(self, volume):
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def create_volume_from_snapshot(self, volume, snapshot):
def create_cloned_volume(self, tgt_volume, src_volume):
def extend_volume(self, volume, new_size):
def _add_vdisk_copy_op(self, ctxt, volume, new_op):
def _rm_vdisk_copy_op(self, ctxt, volume, orig_copy_id, new_copy_id):
def _check_volume_copy_ops(self):
def migrate_volume(self, ctxt, volume, host):
def retype(self, ctxt, volume, new_type, diff, host):
def manage_existing(self, volume, ref):
def manage_existing_get_size(self, volume, ref):
def get_volume_stats(self, refresh=False):
def _update_volume_stats(self):
\OpenStack\cinder-2014.1\cinder\volume\drivers\ibm\xiv_ds8k.py
class XIVDS8KDriver(san.SanDriver):
def __init__(self, *args, **kwargs):
def do_setup(self, context):
def ensure_export(self, context, volume):
def create_export(self, context, volume):
def create_volume(self, volume):
def delete_volume(self, volume):
def remove_export(self, context, volume):
def initialize_connection(self, volume, connector):
def terminate_connection(self, volume, connector, **kwargs):
def create_volume_from_snapshot(self, volume, snapshot):
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def get_volume_stats(self, refresh=False):
def create_cloned_volume(self, tgt_volume, src_volume):
def extend_volume(self, volume, new_size):
def migrate_volume(self, context, volume, host):
\OpenStack\cinder-2014.1\cinder\volume\drivers\ibm\__init__.py
\OpenStack\cinder-2014.1\cinder\volume\drivers\lvm.py
class LVMVolumeDriver(driver.VolumeDriver):
def __init__(self, vg_obj=None, *args, **kwargs):
def set_execute(self, execute):
def check_for_setup_error(self):
def _sizestr(self, size_in_g):
def _volume_not_present(self, volume_name):
def _delete_volume(self, volume, is_snapshot=False):
def _clear_volume(self, volume, is_snapshot=False):
def _escape_snapshot(self, snapshot_name):
def _create_volume(self, name, size, lvm_type, mirror_count, vg=None):
def create_volume(self, volume):
def create_volume_from_snapshot(self, volume, snapshot):
def delete_volume(self, volume):
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def local_path(self, volume, vg=None):
def copy_image_to_volume(self, context, volume, image_service, image_id):
def copy_volume_to_image(self, context, volume, image_service, image_meta):
def create_cloned_volume(self, volume, src_vref):
def clone_image(self, volume, image_location, image_id, image_meta):
def backup_volume(self, context, backup, backup_service):
def restore_backup(self, context, backup, volume, backup_service):
def get_volume_stats(self, refresh=False):
def _update_volume_stats(self):
def extend_volume(self, volume, new_size):
def manage_existing(self, volume, existing_ref):
def manage_existing_get_size(self, volume, existing_ref):
class LVMISCSIDriver(LVMVolumeDriver, driver.ISCSIDriver):
def __init__(self, *args, **kwargs):
def set_execute(self, execute):
def _create_target(self, iscsi_name, iscsi_target, volume_path, chap_auth, lun=0, check_exit_code=False, old_name=None):
def ensure_export(self, context, volume):
def create_export(self, context, volume):
def _create_export(self, context, volume, vg=None):
def remove_export(self, context, volume):
def migrate_volume(self, ctxt, volume, host, thin=False, mirror_count=0):
def _iscsi_location(self, ip, target, iqn, lun=None):
def _iscsi_authentication(self, chap, name, password):
class LVMISERDriver(LVMISCSIDriver, driver.ISERDriver):
def __init__(self, *args, **kwargs):
\OpenStack\cinder-2014.1\cinder\volume\drivers\netapp\api.py
class NaServer(object):
def __init__(self, host, server_type=SERVER_TYPE_FILER, transport_type=TRANSPORT_TYPE_HTTP, style=STYLE_LOGIN_PASSWORD, username=None, password=None):
def get_transport_type(self):
def set_transport_type(self, transport_type):
def get_style(self):
def set_style(self, style):
def get_server_type(self):
def set_server_type(self, server_type):
def set_api_version(self, major, minor):
def get_api_version(self):
def set_port(self, port):
def get_port(self):
def set_timeout(self, seconds):
def get_timeout(self):
def get_vfiler(self):
def set_vfiler(self, vfiler):
def get_vserver(self):
def set_vserver(self, vserver):
def set_username(self, username):
def set_password(self, password):
def invoke_elem(self, na_element, enable_tunneling=False):
def invoke_successfully(self, na_element, enable_tunneling=False):
def _create_request(self, na_element, enable_tunneling=False):
def _enable_tunnel_request(self, netapp_elem):
def _parse_response(self, response):
def _get_result(self, response):
def _get_url(self):
def _build_opener(self):
def _create_basic_auth_handler(self):
def _create_certificate_auth_handler(self):
def __str__(self):
class NaElement(object):
def __init__(self, name):
def get_name(self):
def set_content(self, text):
def get_content(self):
def add_attr(self, name, value):
def add_attrs(self, **attrs):
def add_child_elem(self, na_element):
def get_child_by_name(self, name):
def get_child_content(self, name):
def get_children(self):
def has_attr(self, name):
def get_attr(self, name):
def get_attr_names(self):
def add_new_child(self, name, content, convert=False):
def _convert_entity_refs(text):
def create_node_with_children(node, **children):
def add_node_with_children(self, node, **children):
def to_string(self, pretty=False, method='xml', encoding='UTF-8'):
def __getitem__(self, key):
def __setitem__(self, key, value):
def translate_struct(self, data_struct):
class NaApiError(Exception):
def __init__(self, code='unknown', message='unknown'):
def __str__(self, *args, **kwargs):
\OpenStack\cinder-2014.1\cinder\volume\drivers\netapp\common.py
class NetAppDriver(object):
def __init__(self, *args, **kwargs):
def __setattr__(self, name, value):
def __getattr__(self, name):
class NetAppDriverFactory(object):
def create_driver( storage_family, storage_protocol, *args, **kwargs):
def check_netapp_driver(location):
class Deprecated(driver.VolumeDriver):
def __init__(self, *args, **kwargs):
def _log_deprecated_warn(self):
def check_for_setup_error(self):
def ensure_export(self, context, volume):
def get_volume_stats(self, refresh=False):
\OpenStack\cinder-2014.1\cinder\volume\drivers\netapp\eseries\client.py
class WebserviceClient(object):
def __init__(self, scheme, host, port, service_path, username, password, **kwargs):
def _validate_params(self, scheme, host, port):
def _create_endpoint(self, scheme, host, port, service_path):
def _init_connection(self):
def invoke_service(self, method='GET', url=None, params=None, data=None, headers=None, timeout=None, verify=False):
def _eval_response(self, response):
class RestClient(WebserviceClient):
def __init__(self, scheme, host, port, service_path, username, password, **kwargs):
def set_system_id(self, system_id):
def get_system_id(self):
def _get_resource_url(self, path, use_system=True, **kwargs):
def _invoke(self, method, path, data=None, use_system=True, timeout=None, verify=False, **kwargs):
def _eval_response(self, response):
def create_volume(self, pool, label, size, unit='gb', seg_size=0):
def delete_volume(self, object_id):
def list_volumes(self):
def list_volume(self, object_id):
def update_volume(self, object_id, label):
def get_volume_mappings(self):
def create_volume_mapping(self, object_id, target_id, lun):
def delete_volume_mapping(self, map_object_id):
def list_hardware_inventory(self):
def list_hosts(self):
def create_host(self, label, host_type, ports=None, group_id=None):
def create_host_with_port(self, label, host_type, port_id, port_label, port_type='iscsi', group_id=None):
def list_host_types(self):
def list_snapshot_groups(self):
def create_snapshot_group(self, label, object_id, storage_pool_id, repo_percent=99, warn_thres=99, auto_del_limit=0, full_policy='failbasewrites'):
def delete_snapshot_group(self, object_id):
def create_snapshot_image(self, group_id):
def delete_snapshot_image(self, object_id):
def list_snapshot_images(self):
def create_snapshot_volume(self, image_id, label, base_object_id, storage_pool_id, repo_percent=99, full_thres=99, view_mode='readOnly'):
def delete_snapshot_volume(self, object_id):
def list_storage_pools(self):
def list_storage_systems(self):
def list_storage_system(self):
def register_storage_system(self, controller_addresses, password=None, wwn=None):
def update_stored_system_password(self, password):
def create_volume_copy_job(self, src_id, tgt_id, priority='priority4', tgt_wrt_protected='true'):
def control_volume_copy_job(self, obj_id, control='start'):
def list_vol_copy_job(self, object_id):
def delete_vol_copy_job(self, object_id):
\OpenStack\cinder-2014.1\cinder\volume\drivers\netapp\eseries\iscsi.py
class Driver(driver.ISCSIDriver):
def __init__(self, *args, **kwargs):
def do_setup(self, context):
def _check_flags(self):
def check_for_setup_error(self):
def _check_mode_get_or_register_storage_system(self):
def _resolve_host(host):
def _check_storage_system(self):
def _populate_system_objects(self):
def _cache_allowed_disk_pool_refs(self):
def _cache_volume(self, obj):
def _cache_snap_grp(self, obj):
def _cache_snap_img(self, image):
def _cache_vol_mapping(self, mapping):
def _del_volume_frm_cache(self, label):
def _del_snapshot_frm_cache(self, obj_name):
def _del_vol_mapping_frm_cache(self, mapping):
def _get_volume(self, uid):
def _get_cached_volume(self, label):
def _get_cached_snapshot_grp(self, uid):
def _get_cached_snap_grp_image(self, uid):
def _is_volume_containing_snaps(self, label):
def create_volume(self, volume):
def _create_volume(self, label, size_gb):
def _get_sorted_avl_storage_pools(self, size_gb):
def create_volume_from_snapshot(self, volume, snapshot):
def _create_snapshot_volume(self, snapshot_id):
def _copy_volume_high_prior_readonly(self, src_vol, dst_vol):
def create_cloned_volume(self, volume, src_vref):
def delete_volume(self, volume):
def _delete_volume(self, label):
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def ensure_export(self, context, volume):
def create_export(self, context, volume):
def remove_export(self, context, volume):
def initialize_connection(self, volume, connector):
def _get_iscsi_service_details(self):
def _map_volume_to_host(self, vol, initiator):
def _get_or_create_host(self, port_id, host_type='linux'):
def _get_host_with_port(self, port_id, host_type='linux'):
def _create_host(self, port_id, host_type='linux'):
def _get_host_type_definition(self, host_type='linux'):
def _get_free_lun(self, host):
def _get_vol_mapping_for_host_frm_array(self, host_ref):
def terminate_connection(self, volume, connector, **kwargs):
def _get_cached_vol_mapping_for_host(self, volume, host):
def get_volume_stats(self, refresh=False):
def _update_volume_stats(self):
def _update_capacity(self):
def extend_volume(self, volume, new_size):
def _garbage_collect_tmp_vols(self):
\OpenStack\cinder-2014.1\cinder\volume\drivers\netapp\eseries\__init__.py
\OpenStack\cinder-2014.1\cinder\volume\drivers\netapp\iscsi.py
class NetAppLun(object):
def __init__(self, handle, name, size, metadata_dict):
def get_metadata_property(self, prop):
def __str__(self, *args, **kwargs):
class NetAppDirectISCSIDriver(driver.ISCSIDriver):
def __init__(self, *args, **kwargs):
def _create_client(self, **kwargs):
def _do_custom_setup(self):
def _check_flags(self):
def do_setup(self, context):
def check_for_setup_error(self):
def create_volume(self, volume):
def delete_volume(self, volume):
def _destroy_lun(self, path, force=True):
def ensure_export(self, context, volume):
def create_export(self, context, volume):
def remove_export(self, context, volume):
def initialize_connection(self, volume, connector):
def create_snapshot(self, snapshot):
def delete_snapshot(self, snapshot):
def create_volume_from_snapshot(self, volume, snapshot):
def terminate_connection(self, volume, connector, **kwargs):
def _get_ontapi_version(self):
def _create_lun_on_eligible_vol(self, name, size, metadata, extra_specs=None):
def create_lun(self, volume, lun, size, metadata, qos_policy_group=None):
def _get_iscsi_service_details(self):
def _get_target_details(self):
def _create_lun_handle(self, metadata):
def _get_lun_list(self):
def _extract_and_populate_luns(self, api_luns):
def _is_naelement(self, elem):
def _map_lun(self, name, initiator, initiator_type='iscsi', lun_id=None):
def _unmap_lun(self, path, initiator):
def _find_mapped_lun_igroup(self, path, initiator, os=None):
def _get_or_create_igroup(self, initiator, initiator_type='iscsi', os='default'):
def _get_igroup_by_initiator(self, initiator):
def _check_allowed_os(self, os):
def _create_igroup(self, igroup, igroup_type='iscsi', os_type='default'):
def _add_igroup_initiator(self, igroup, initiator):
def _add_lun_to_table(self, lun):
def _get_lun_from_table(self, name):
def _clone_lun(self, name, new_name, space_reserved='true', src_block=0, dest_block=0, block_count=0):
def _get_lun_by_args(self, **args):
def _get_lun_attr(self, name, attr):
def _create_lun_meta(self, lun):
def create_cloned_volume(self, volume, src_vref):
def get_volume_stats(self, refresh=False):
def _update_volume_stats(self):
def extend_volume(self, volume, new_size):
def _do_direct_resize(self, path, new_size_bytes, force=True):
OpenStack IndexPreviousNext
|
