}
"""
+FAKE_ERROR_CONNECT_RESPONSE = """
+{
+ "error":{
+ "code":-403
+ }
+}
+"""
+
FAKE_ERROR_LUN_INFO_RESPONSE = """
{
"error":{
MAP_COMMAND_TO_FAKE_RESPONSE = {}
MAP_COMMAND_TO_FAKE_RESPONSE['/xx/sessions'] = (
FAKE_GET_LOGIN_STORAGE_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['sessions'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/sessions'] = (
FAKE_LOGIN_OUT_STORAGE_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['LUN_MIGRATION/POST'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/LUN_MIGRATION/POST'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['LUN_MIGRATION?range=[0-100]/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/LUN_MIGRATION?range=[0-100]/GET'] = (
FAKE_GET_LUN_MIGRATION_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['LUN_MIGRATION/11/DELETE'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/LUN_MIGRATION/11/DELETE'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
# mock storage info map
-MAP_COMMAND_TO_FAKE_RESPONSE['storagepool'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/storagepool'] = (
FAKE_STORAGE_POOL_RESPONSE)
# mock lun info map
-MAP_COMMAND_TO_FAKE_RESPONSE['lun'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/lun'] = (
FAKE_LUN_INFO_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lun/11/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/lun/11/GET'] = (
FAKE_LUN_DELETE_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lun/1/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/lun/1/GET'] = (
FAKE_LUN_DELETE_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lun/11/DELETE'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/lun/11/DELETE'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lun/1/DELETE'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/lun/1/DELETE'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lun/1/PUT'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/lun/1/PUT'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lun/11/PUT'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/lun/11/PUT'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lun?range=[0-65535]/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/lun?range=[0-65535]/GET'] = (
FAKE_QUERY_ALL_LUN_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lun/associate?TYPE=11&ASSOCIATEOBJTYPE=256'
+MAP_COMMAND_TO_FAKE_RESPONSE['/lun/associate?TYPE=11&ASSOCIATEOBJTYPE=256'
'&ASSOCIATEOBJID=11/GET'] = (
FAKE_LUN_ASSOCIATE_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lun/associate?TYPE=11&ASSOCIATEOBJTYPE=256'
+MAP_COMMAND_TO_FAKE_RESPONSE['/lun/associate?TYPE=11&ASSOCIATEOBJTYPE=256'
'&ASSOCIATEOBJID=12/GET'] = (
FAKE_LUN_ASSOCIATE_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lun/associate?ID=1&TYPE=11&ASSOCIATEOBJTYPE=21'
+MAP_COMMAND_TO_FAKE_RESPONSE['/lun/associate?ID=1&TYPE=11&ASSOCIATEOBJTYPE=21'
'&ASSOCIATEOBJID=0/GET'] = (
FAKE_LUN_ASSOCIATE_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lun/associate?TYPE=11&ASSOCIATEOBJTYPE=21'
+MAP_COMMAND_TO_FAKE_RESPONSE['/lun/associate?TYPE=11&ASSOCIATEOBJTYPE=21'
'&ASSOCIATEOBJID=1/GET'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lun/associate/cachepartition?ID=1'
+MAP_COMMAND_TO_FAKE_RESPONSE['/lun/associate/cachepartition?ID=1'
'&ASSOCIATEOBJTYPE=11&ASSOCIATEOBJID=11'
'/DELETE'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lungroup?range=[0-8191]/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/lungroup?range=[0-8191]/GET'] = (
FAKE_QUERY_LUN_GROUP_INFO_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lungroup'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/lungroup'] = (
FAKE_QUERY_LUN_GROUP_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lungroup/associate'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/lungroup/associate'] = (
FAKE_QUERY_LUN_GROUP_ASSOCIAT_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['LUNGroup/11/DELETE'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/LUNGroup/11/DELETE'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lungroup/associate?ID=11&ASSOCIATEOBJTYPE=11'
+MAP_COMMAND_TO_FAKE_RESPONSE['/lungroup/associate?ID=11&ASSOCIATEOBJTYPE=11'
'&ASSOCIATEOBJID=1/DELETE'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lungroup/associate?TYPE=256&ASSOCIATEOBJTYPE=11'
+MAP_COMMAND_TO_FAKE_RESPONSE['/lungroup/associate?TYPE=256&ASSOCIATEOBJTYPE=11'
'&ASSOCIATEOBJID=11/GET'] = (
FAKE_LUN_ASSOCIATE_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lungroup/associate?TYPE=256&ASSOCIATEOBJTYPE=11'
+MAP_COMMAND_TO_FAKE_RESPONSE['/lungroup/associate?TYPE=256&ASSOCIATEOBJTYPE=11'
'&ASSOCIATEOBJID=1/GET'] = (
FAKE_LUN_ASSOCIATE_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lungroup/associate?ID=11&ASSOCIATEOBJTYPE=11'
+MAP_COMMAND_TO_FAKE_RESPONSE['/lungroup/associate?ID=11&ASSOCIATEOBJTYPE=11'
'&ASSOCIATEOBJID=11/DELETE'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lun/count?TYPE=11&ASSOCIATEOBJTYPE=256'
+MAP_COMMAND_TO_FAKE_RESPONSE['/lun/count?TYPE=11&ASSOCIATEOBJTYPE=256'
'&ASSOCIATEOBJID=11/GET'] = (
FAKE_LUN_COUNT_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lun/expand/PUT'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/lun/expand/PUT'] = (
FAKE_LUN_INFO_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['lungroup/associate?ID=12&ASSOCIATEOBJTYPE=11'
+MAP_COMMAND_TO_FAKE_RESPONSE['/lungroup/associate?ID=12&ASSOCIATEOBJTYPE=11'
'&ASSOCIATEOBJID=12/DELETE'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
# mock snapshot info map
-MAP_COMMAND_TO_FAKE_RESPONSE['snapshot'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/snapshot'] = (
FAKE_CREATE_SNAPSHOT_INFO_RESPONSE)
# mock snapshot info map
-MAP_COMMAND_TO_FAKE_RESPONSE['snapshot/11/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/snapshot/11/GET'] = (
FAKE_GET_SNAPSHOT_INFO_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['snapshot/activate'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/snapshot/activate'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['snapshot/stop/PUT'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/snapshot/stop/PUT'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['snapshot/11/DELETE'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/snapshot/11/DELETE'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['snapshot?range=[0-32767]/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/snapshot?range=[0-32767]/GET'] = (
FAKE_SNAPSHOT_LIST_INFO_RESPONSE)
# mock QoS info map
-MAP_COMMAND_TO_FAKE_RESPONSE['ioclass/11/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/ioclass/11/GET'] = (
FAKE_LUN_DELETE_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['ioclass/11/DELETE'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/ioclass/11/DELETE'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['ioclass/active/11/PUT'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/ioclass/active/11/PUT'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['ioclass/'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/ioclass/'] = (
FAKE_QOS_INFO_RESPONSE)
# mock iscsi info map
-MAP_COMMAND_TO_FAKE_RESPONSE['iscsi_tgt_port/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/iscsi_tgt_port/GET'] = (
FAKE_GET_ISCSI_INFO_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['eth_port/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/eth_port/GET'] = (
FAKE_GET_ETH_INFO_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['eth_port/associate?TYPE=213&ASSOCIATEOBJTYPE'
+MAP_COMMAND_TO_FAKE_RESPONSE['/eth_port/associate?TYPE=213&ASSOCIATEOBJTYPE'
'=257&ASSOCIATEOBJID=11/GET'] = (
FAKE_GET_ETH_ASSOCIATE_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['iscsidevicename'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/iscsidevicename'] = (
FAKE_GET_ISCSI_DEVICE_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['iscsi_initiator?range=[0-256]/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/iscsi_initiator?range=[0-256]/GET'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['iscsi_initiator/'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/iscsi_initiator'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['iscsi_initiator/POST'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/iscsi_initiator/POST'] = (
FAKE_ISCSI_INITIATOR_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['iscsi_initiator/PUT'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/iscsi_initiator/PUT'] = (
FAKE_ISCSI_INITIATOR_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['iscsi_initiator/remove_iscsi_from_host/PUT'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/iscsi_initiator/remove_iscsi_from_host/PUT'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['iscsi_initiator/'
+MAP_COMMAND_TO_FAKE_RESPONSE['/iscsi_initiator/'
'iqn.1993-08.debian:01:ec2bff7ac3a3/PUT'] = (
FAKE_ISCSI_INITIATOR_RESPONSE)
# mock host info map
-MAP_COMMAND_TO_FAKE_RESPONSE['host?range=[0-65535]/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/host?range=[0-65535]/GET'] = (
FAKE_GET_ALL_HOST_INFO_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['host/1/DELETE'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/host/1/DELETE'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['host'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/host'] = (
FAKE_CREATE_HOST_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['hostgroup?range=[0-8191]/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/hostgroup?range=[0-8191]/GET'] = (
FAKE_GET_ALL_HOST_GROUP_INFO_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['hostgroup'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/hostgroup'] = (
FAKE_GET_HOST_GROUP_INFO_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['host/associate?TYPE=14&ID=0'
+MAP_COMMAND_TO_FAKE_RESPONSE['/host/associate?TYPE=14&ID=0'
'&ASSOCIATEOBJTYPE=21&ASSOCIATEOBJID=1'
'/DELETE'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['host/associate?TYPE=14&ID=0'
+MAP_COMMAND_TO_FAKE_RESPONSE['/host/associate?TYPE=14&ID=0'
'&ASSOCIATEOBJID=0/GET'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['host/associate?TYPE=21&'
+MAP_COMMAND_TO_FAKE_RESPONSE['/host/associate?TYPE=21&'
'ASSOCIATEOBJTYPE=14&ASSOCIATEOBJID=0/GET'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['hostgroup/0/DELETE'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/hostgroup/0/DELETE'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['hostgroup/associate'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/host/associate?TYPE=21&'
+ 'ASSOCIATEOBJTYPE=14&ASSOCIATEOBJID=0/GET'] = (
+ FAKE_COMMON_SUCCESS_RESPONSE)
+
+
+MAP_COMMAND_TO_FAKE_RESPONSE['/hostgroup/associate'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
# mock copy info map
-MAP_COMMAND_TO_FAKE_RESPONSE['luncopy'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/luncopy'] = (
FAKE_GET_LUN_COPY_INFO_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['LUNCOPY?range=[0-1023]/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/LUNCOPY?range=[0-1023]/GET'] = (
FAKE_GET_LUN_COPY_LIST_INFO_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['LUNCOPY/start/PUT'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/LUNCOPY/start/PUT'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['LUNCOPY/0/DELETE'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/LUNCOPY/0/DELETE'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
# mock mapping view info map
-MAP_COMMAND_TO_FAKE_RESPONSE['mappingview?range=[0-8191]/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/mappingview?range=[0-8191]/GET'] = (
FAKE_GET_MAPPING_VIEW_INFO_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['mappingview'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/mappingview'] = (
FAKE_GET_MAPPING_VIEW_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['MAPPINGVIEW/1/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/MAPPINGVIEW/1/GET'] = (
FAKE_GET_SPEC_MAPPING_VIEW_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['mappingview/1/DELETE'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/mappingview/1/DELETE'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['mappingview/associate/lungroup?TYPE=256&'
+MAP_COMMAND_TO_FAKE_RESPONSE['/mappingview/associate/lungroup?TYPE=256&'
'ASSOCIATEOBJTYPE=245&ASSOCIATEOBJID=1/GET'] = (
FAKE_GET_MAPPING_VIEW_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['mappingview/associate?TYPE=245&'
+MAP_COMMAND_TO_FAKE_RESPONSE['/mappingview/associate?TYPE=245&'
'ASSOCIATEOBJTYPE=14&ASSOCIATEOBJID=0/GET'] = (
FAKE_GET_MAPPING_VIEW_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['mappingview/associate?TYPE=245&'
+MAP_COMMAND_TO_FAKE_RESPONSE['/mappingview/associate?TYPE=245&'
'ASSOCIATEOBJTYPE=256&ASSOCIATEOBJID=11/GET'] = (
FAKE_GET_MAPPING_VIEW_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['mappingview/associate?TYPE=245&'
+MAP_COMMAND_TO_FAKE_RESPONSE['/mappingview/associate?TYPE=245&'
'ASSOCIATEOBJTYPE=257&ASSOCIATEOBJID=11/GET'] = (
FAKE_GET_MAPPING_VIEW_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['portgroup/associate?ASSOCIATEOBJTYPE=245&'
+MAP_COMMAND_TO_FAKE_RESPONSE['/portgroup/associate?ASSOCIATEOBJTYPE=245&'
'ASSOCIATEOBJID=1&range=[0-8191]/GET'] = (
FAKE_GET_MAPPING_VIEW_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['MAPPINGVIEW/CREATE_ASSOCIATE/PUT'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/MAPPINGVIEW/CREATE_ASSOCIATE/PUT'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
# mock FC info map
-MAP_COMMAND_TO_FAKE_RESPONSE['fc_initiator?ISFREE=true&'
+MAP_COMMAND_TO_FAKE_RESPONSE['/fc_initiator?ISFREE=true&'
'range=[0-8191]/GET'] = (
FAKE_FC_INFO_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['fc_initiator/10000090fa0d6754/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/MAPPINGVIEW/CREATE_ASSOCIATE/PUT'] = (
+ FAKE_COMMON_SUCCESS_RESPONSE)
+
+# mock FC info map
+MAP_COMMAND_TO_FAKE_RESPONSE['/fc_initiator?ISFREE=true&'
+ 'range=[0-8191]/GET'] = (
FAKE_FC_INFO_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['fc_initiator/10000090fa0d6754/PUT'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/fc_initiator/10000090fa0d6754/PUT'] = (
FAKE_COMMON_SUCCESS_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['host_link?INITIATOR_TYPE=223'
+MAP_COMMAND_TO_FAKE_RESPONSE['/host_link?INITIATOR_TYPE=223'
'&INITIATOR_PORT_WWN=10000090fa0d6754/GET'] = (
FAKE_HOST_LINK_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['portgroup?range=[0-8191]&TYPE=257/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/portgroup?range=[0-8191]&TYPE=257/GET'] = (
FAKE_PORT_GROUP_RESPONSE)
# mock system info map
-MAP_COMMAND_TO_FAKE_RESPONSE['system/'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/system/'] = (
FAKE_SYSTEM_VERSION_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['fc_initiator?range=[0-256]/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/fc_initiator?range=[0-256]/GET'] = (
FAKE_GET_FC_INI_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['fc_port/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/fc_port/GET'] = (
FAKE_GET_FC_PORT_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['fc_initiator/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/fc_initiator/GET'] = (
FAKE_GET_FC_PORT_RESPONSE)
-MAP_COMMAND_TO_FAKE_RESPONSE['fc_initiator?range=[0-100]/GET'] = (
+MAP_COMMAND_TO_FAKE_RESPONSE['/fc_initiator?range=[0-100]/GET'] = (
FAKE_GET_FC_PORT_RESPONSE)
self.terminateFlag = False
self.device_id = None
self.test_fail = False
+ self.test_multi_url_flag = False
self.checkFlag = False
self.remove_chap_flag = False
self.cache_not_exist = False
def add_lun_to_cache(self, lunid, cache_id):
pass
- def call(self, url=False, data=None, method=None):
+ def do_call(self, url=False, data=None, method=None, calltimeout=4):
url = url.replace('http://100.115.10.69:8082/deviceManager/rest', '')
command = url.replace('/210235G7J20000000000/', '')
data = None
self.test_fail = False
+ if self.test_multi_url_flag:
+ data = FAKE_ERROR_CONNECT_RESPONSE
+ self.test_multi_url_flag = False
+
return json.loads(data)
expected_filtered_ports = ['1', '3', '2', '5', '6']
self.assertEqual(expected_filtered_ports, filtered_ports)
+ def test_multi_resturls_success(self):
+ self.driver.restclient.login()
+ self.driver.restclient.test_multi_url_flag = True
+ lun_info = self.driver.create_volume(test_volume)
+ self.assertEqual('1', lun_info['provider_location'])
+
def create_fake_conf_file(self):
"""Create a fake Config file
from cinder import exception
from cinder.i18n import _, _LE, _LI, _LW
+from cinder import utils
from cinder.volume.drivers.huawei import constants
from cinder.volume.drivers.huawei import huawei_utils
def __init__(self, configuration):
self.configuration = configuration
self.xml_file_path = configuration.cinder_huawei_conf_file
- self.cookie = http_cookiejar.CookieJar()
- self.url = None
self.productversion = None
- self.headers = {"Connection": "keep-alive",
- "Content-Type": "application/json"}
- def call(self, url=False, data=None, method=None):
+ def init_http_head(self):
+ self.cookie = http_cookiejar.CookieJar()
+ self.url = None
+ self.device_id = None
+ self.headers = {
+ "Connection": "keep-alive",
+ "Content-Type": "application/json",
+ }
+
+ def do_call(self, url=None, data=None, method=None,
+ calltimeout=constants.SOCKET_TIMEOUT):
"""Send requests to 18000 server.
Send HTTPS call, get response in JSON.
Convert response into Python Object and return it.
"""
-
+ if self.url:
+ url = self.url + url
handler = urllib.request.HTTPCookieProcessor(self.cookie)
opener = urllib.request.build_opener(handler)
urllib.request.install_opener(opener)
res_json = None
try:
- socket.setdefaulttimeout(constants.SOCKET_TIME_OUT)
+ socket.setdefaulttimeout(calltimeout)
req = urllib.request.Request(url, data, self.headers)
if method:
req.get_method = lambda: method
login_info = huawei_utils.get_login_info(self.xml_file_path)
urlstr = login_info['RestURL']
url_list = urlstr.split(";")
+ device_id = None
for item_url in url_list:
url = item_url + "xx/sessions"
data = json.dumps({"username": login_info['UserName'],
"password": login_info['UserPassword'],
"scope": "0"})
- result = self.call(url, data)
+ self.init_http_head()
+ result = self.do_call(url, data,
+ calltimeout=constants.LOGIN_SOCKET_TIMEOUT)
- if result['error']['code'] == constants.ERROR_CONNECT_TO_SERVER:
+ if (result['error']['code'] != 0) or ("data" not in result):
+ LOG.error(_LE("Login error, reason is: %s."), result)
continue
- if (result['error']['code'] != 0) or ('data' not in result):
- msg = (_("Login error, reason is: %s.") % result)
- LOG.error(msg)
- raise exception.VolumeBackendAPIException(data=msg)
-
+ LOG.debug('Login success: %(url)s', {'url': item_url})
device_id = result['data']['deviceid']
self.device_id = device_id
self.url = item_url + device_id
self.headers['iBaseToken'] = result['data']['iBaseToken']
- return device_id
+ break
+
+ if device_id is None:
+ msg = _("Failed to login with all rest URLs.")
+ LOG.error(msg)
+ raise exception.VolumeBackendAPIException(data=msg)
+
+ return device_id
+
+ @utils.synchronized('huawei_cinder_call', external=True)
+ def call(self, url, data=None, method=None):
+ """Send requests to server.
- msg = _("Login error: Can't connect to server.")
- LOG.error(msg)
- raise exception.VolumeBackendAPIException(data=msg)
+ If fail, try another RestURL.
+ """
+ device_id = None
+ old_url = self.url
+ result = self.do_call(url, data, method)
+ error_code = result['error']['code']
+ if (error_code == constants.ERROR_CONNECT_TO_SERVER
+ or error_code == constants.ERROR_UNAUTHORIZED_TO_SERVER):
+ LOG.error(_LE("Can't open the recent url, relogin."))
+ device_id = self.login()
+
+ if device_id is not None:
+ LOG.debug('Replace URL: \n'
+ 'Old URL: %(old_url)s\n,'
+ 'New URL: %(new_url)s\n.',
+ {'old_url': old_url,
+ 'new_url': self.url})
+ result = self.do_call(url, data, method)
+ return result
def _assert_rest_result(self, result, err_str):
if result['error']['code'] != 0:
raise exception.VolumeBackendAPIException(data=err_msg)
def create_volume(self, lun_param):
- url = self.url + "/lun"
+ url = "/lun"
data = json.dumps(lun_param)
result = self.call(url, data)
return result['data']
def check_lun_exist(self, lun_id):
- url = self.url + "/lun/" + lun_id
+ url = "/lun/" + lun_id
data = json.dumps({"TYPE": "11",
"ID": lun_id})
result = self.call(url, data, "GET")
if lun_group_ids and len(lun_group_ids) == 1:
self.remove_lun_from_lungroup(lun_group_ids[0], lun_id)
- url = self.url + "/lun/" + lun_id
+ url = "/lun/" + lun_id
data = json.dumps({"TYPE": "11",
"ID": lun_id})
result = self.call(url, data, "DELETE")
self._assert_rest_result(result, _('Delete lun error.'))
def find_all_pools(self):
- url = self.url + "/storagepool"
+ url = "/storagepool"
result = self.call(url, None)
msg = _('Query resource pool error.')
self._assert_rest_result(result, msg)
return item['ID']
def get_volume_by_name(self, name):
- url = self.url + "/lun?range=[0-65535]"
+ url = "/lun?range=[0-65535]"
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Get volume by name error.'))
return self._get_id_from_result(result, name, 'NAME')
def activate_snapshot(self, snapshot_id):
- activate_url = self.url + "/snapshot/activate"
+ activate_url = "/snapshot/activate"
data = json.dumps({"SNAPSHOTLIST": [snapshot_id]})
result = self.call(activate_url, data)
self._assert_rest_result(result, _('Activate snapshot error.'))
LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
- url = self.url + "/snapshot"
+ url = "/snapshot"
data = json.dumps({"TYPE": "27",
"NAME": snapshot_name,
"PARENTTYPE": "11",
return result['data']
def check_snapshot_exist(self, snapshot_id):
- url = self.url + "/snapshot/%s" % snapshot_id
+ url = "/snapshot/%s" % snapshot_id
data = json.dumps({"TYPE": "27",
"ID": snapshot_id})
result = self.call(url, data, "GET")
return True
def stop_snapshot(self, snapshot_id):
- url = self.url + "/snapshot/stop"
+ url = "/snapshot/stop"
stopdata = json.dumps({"ID": snapshot_id})
result = self.call(url, stopdata, "PUT")
self._assert_rest_result(result, _('Stop snapshot error.'))
def delete_snapshot(self, snapshotid):
- url = self.url + "/snapshot/%s" % snapshotid
+ url = "/snapshot/%s" % snapshotid
data = json.dumps({"TYPE": "27", "ID": snapshotid})
result = self.call(url, data, "DELETE")
self._assert_rest_result(result, _('Delete snapshot error.'))
def get_snapshotid_by_name(self, name):
- url = self.url + "/snapshot?range=[0-32767]"
+ url = "/snapshot?range=[0-32767]"
data = json.dumps({"TYPE": "27"})
result = self.call(url, data, "GET")
self._assert_rest_result(result, _('Get snapshot id error.'))
def create_luncopy(self, luncopyname, srclunid, tgtlunid):
"""Create a luncopy."""
- url = self.url + "/luncopy"
+ url = "/luncopy"
data = json.dumps({"TYPE": 219,
"NAME": luncopyname,
"DESCRIPTION": luncopyname,
def find_tgt_port_group(self, tgt_port_group):
"""Find target portgroup id by target port group name."""
- url = self.url + "/portgroup?range=[0-8191]&TYPE=257"
+ url = "/portgroup?range=[0-8191]&TYPE=257"
result = self.call(url, None, "GET")
msg = _('Find portgroup error.')
return self._get_id_from_result(result, tgt_port_group, 'NAME')
def _associate_portgroup_to_view(self, view_id, portgroup_id):
- url = self.url + "/MAPPINGVIEW/CREATE_ASSOCIATE"
+ url = "/MAPPINGVIEW/CREATE_ASSOCIATE"
data = json.dumps({"ASSOCIATEOBJTYPE": "257",
"ASSOCIATEOBJID": portgroup_id,
"TYPE": "245",
def _portgroup_associated(self, view_id, portgroup_id):
url_subfix = ("/mappingview/associate?TYPE=245&"
"ASSOCIATEOBJTYPE=257&ASSOCIATEOBJID=%s" % portgroup_id)
- url = self.url + url_subfix
+ url = url_subfix
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Check portgroup associate error.'))
host_id)
def _get_iscsi_tgt_port(self):
- url = self.url + "/iscsidevicename"
+ url = "/iscsidevicename"
result = self.call(url, None)
msg = _('Get iSCSI target port error.')
def find_hostgroup(self, groupname):
"""Get the given hostgroup id."""
- url = self.url + "/hostgroup?range=[0-8191]"
+ url = "/hostgroup?range=[0-8191]"
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Get hostgroup information error.'))
def _find_lungroup(self, lungroup_name):
"""Get the given hostgroup id."""
- url = self.url + "/lungroup?range=[0-8191]"
+ url = "/lungroup?range=[0-8191]"
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Get lungroup information error.'))
return hostgroup_id
def _create_hostgroup(self, hostgroup_name):
- url = self.url + "/hostgroup"
+ url = "/hostgroup"
data = json.dumps({"TYPE": "14", "NAME": hostgroup_name})
result = self.call(url, data)
return result['data']['ID']
def _create_lungroup(self, lungroup_name):
- url = self.url + "/lungroup"
+ url = "/lungroup"
data = json.dumps({"DESCRIPTION": lungroup_name,
"APPTYPE": '0',
"GROUPTYPE": '0',
return result['data']['ID']
def delete_lungroup(self, lungroup_id):
- url = self.url + "/LUNGroup/" + lungroup_id
+ url = "/LUNGroup/" + lungroup_id
result = self.call(url, None, "DELETE")
self._assert_rest_result(result, _('Delete lungroup error.'))
def lungroup_associated(self, view_id, lungroup_id):
url_subfix = ("/mappingview/associate?TYPE=245&"
"ASSOCIATEOBJTYPE=256&ASSOCIATEOBJID=%s" % lungroup_id)
- url = self.url + url_subfix
+ url = url_subfix
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Check lungroup associate error.'))
def hostgroup_associated(self, view_id, hostgroup_id):
url_subfix = ("/mappingview/associate?TYPE=245&"
"ASSOCIATEOBJTYPE=14&ASSOCIATEOBJID=%s" % hostgroup_id)
- url = self.url + url_subfix
+ url = url_subfix
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Check hostgroup associate error.'))
return False
def find_host_lun_id(self, host_id, lun_id):
- url = self.url + ("/lun/associate?TYPE=11&ASSOCIATEOBJTYPE=21"
- "&ASSOCIATEOBJID=%s" % (host_id))
+ url = ("/lun/associate?TYPE=11&ASSOCIATEOBJTYPE=21"
+ "&ASSOCIATEOBJID=%s" % (host_id))
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Find host lun id error.'))
def find_host(self, host_name):
"""Get the given host ID."""
- url = self.url + "/host?range=[0-65535]"
+ url = "/host?range=[0-65535]"
data = json.dumps({"TYPE": "21"})
result = self.call(url, data, "GET")
self._assert_rest_result(result, _('Find host in hostgroup error.'))
def _add_host(self, hostname, host_name_before_hash):
"""Add a new host."""
- url = self.url + "/host"
+ url = "/host"
data = json.dumps({"TYPE": "21",
"NAME": hostname,
"OPERATIONSYSTEM": "0",
url_subfix = ("/host/associate?TYPE=21&"
"ASSOCIATEOBJTYPE=14&ASSOCIATEOBJID=%s" % hostgroup_id)
- url = self.url + url_subfix
+ url = url_subfix
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Check hostgroup associate error.'))
url_subfix = ("/lun/associate?TYPE=11&"
"ASSOCIATEOBJTYPE=256&ASSOCIATEOBJID=%s" % lungroup_id)
- url = self.url + url_subfix
+ url = url_subfix
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Check lungroup associate error.'))
return False
def _associate_host_to_hostgroup(self, hostgroup_id, host_id):
- url = self.url + "/hostgroup/associate"
+ url = "/hostgroup/associate"
data = json.dumps({"TYPE": "14",
"ID": hostgroup_id,
"ASSOCIATEOBJTYPE": "21",
def associate_lun_to_lungroup(self, lungroup_id, lun_id):
"""Associate lun to lungroup."""
- url = self.url + "/lungroup/associate"
+ url = "/lungroup/associate"
data = json.dumps({"ID": lungroup_id,
"ASSOCIATEOBJTYPE": "11",
"ASSOCIATEOBJID": lun_id})
def remove_lun_from_lungroup(self, lungroup_id, lun_id):
"""Remove lun from lungroup."""
- url = self.url + ("/lungroup/associate?ID=%s"
- "&ASSOCIATEOBJTYPE=11&ASSOCIATEOBJID=%s"
- % (lungroup_id, lun_id))
+ url = ("/lungroup/associate?ID=%s&ASSOCIATEOBJTYPE=11"
+ "&ASSOCIATEOBJID=%s" % (lungroup_id, lun_id))
result = self.call(url, None, 'DELETE')
self._assert_rest_result(
def _initiator_is_added_to_array(self, ininame):
"""Check whether the initiator is already added on the array."""
- url = self.url + "/iscsi_initiator?range=[0-256]"
+ url = "/iscsi_initiator?range=[0-256]"
result = self.call(url, None, "GET")
self._assert_rest_result(result,
_('Check initiator added to array error.'))
def is_initiator_associated_to_host(self, ininame):
"""Check whether the initiator is associated to the host."""
- url = self.url + "/iscsi_initiator?range=[0-256]"
+ url = "/iscsi_initiator?range=[0-256]"
result = self.call(url, None, "GET")
self._assert_rest_result(
result, _('Check initiator associated to host error.'))
def _add_initiator_to_array(self, initiator_name):
"""Add a new initiator to storage device."""
- url = self.url + "/iscsi_initiator/"
+ url = "/iscsi_initiator"
data = json.dumps({"TYPE": "222",
"ID": initiator_name,
"USECHAP": "false"})
_('Add initiator to array error.'))
def _add_initiator_to_host(self, initiator_name, host_id):
- url = self.url + "/iscsi_initiator/" + initiator_name
+ url = "/iscsi_initiator/" + initiator_name
data = json.dumps({"TYPE": "222",
"ID": initiator_name,
"USECHAP": "false",
"""Use CHAP when adding initiator to host."""
(chap_username, chap_password) = chapinfo.split(";")
- url = self.url + "/iscsi_initiator/" + initiator_name
+ url = "/iscsi_initiator/" + initiator_name
data = json.dumps({"TYPE": "222",
"USECHAP": "true",
"CHAPNAME": chap_username,
def _use_alua(self, initiator_name, multipath_type):
"""Use ALUA when adding initiator to host."""
- url = self.url + "/iscsi_initiator"
+ url = "/iscsi_initiator"
data = json.dumps({"ID": initiator_name,
"MULTIPATHTYPE": multipath_type})
result = self.call(url, data, "PUT")
def remove_chap(self, initiator_name):
"""Remove CHAP when terminate connection."""
- url = self.url + "/iscsi_initiator"
+ url = "/iscsi_initiator"
data = json.dumps({"USECHAP": "false",
"MULTIPATHTYPE": "0",
"ID": initiator_name})
def find_mapping_view(self, name):
"""Find mapping view."""
- url = self.url + "/mappingview?range=[0-8191]"
+ url = "/mappingview?range=[0-8191]"
data = json.dumps({"TYPE": "245"})
result = self.call(url, data, "GET")
return self._get_id_from_result(result, name, 'NAME')
def _add_mapping_view(self, name):
- url = self.url + "/mappingview"
+ url = "/mappingview"
data = json.dumps({"NAME": name, "TYPE": "245"})
result = self.call(url, data)
self._assert_rest_result(result, _('Add mapping view error.'))
return result['data']['ID']
def _associate_hostgroup_to_view(self, view_id, hostgroup_id):
- url = self.url + "/MAPPINGVIEW/CREATE_ASSOCIATE"
+ url = "/MAPPINGVIEW/CREATE_ASSOCIATE"
data = json.dumps({"ASSOCIATEOBJTYPE": "14",
"ASSOCIATEOBJID": hostgroup_id,
"TYPE": "245",
'error.'))
def _associate_lungroup_to_view(self, view_id, lungroup_id):
- url = self.url + "/MAPPINGVIEW/CREATE_ASSOCIATE"
+ url = "/MAPPINGVIEW/CREATE_ASSOCIATE"
data = json.dumps({"ASSOCIATEOBJTYPE": "256",
"ASSOCIATEOBJID": lungroup_id,
"TYPE": "245",
def delete_lungroup_mapping_view(self, view_id, lungroup_id):
"""Remove lungroup associate from the mapping view."""
- url = self.url + "/mappingview/REMOVE_ASSOCIATE"
+ url = "/mappingview/REMOVE_ASSOCIATE"
data = json.dumps({"ASSOCIATEOBJTYPE": "256",
"ASSOCIATEOBJID": lungroup_id,
"TYPE": "245",
def delete_hostgoup_mapping_view(self, view_id, hostgroup_id):
"""Remove hostgroup associate from the mapping view."""
- url = self.url + "/mappingview/REMOVE_ASSOCIATE"
+ url = "/mappingview/REMOVE_ASSOCIATE"
data = json.dumps({"ASSOCIATEOBJTYPE": "14",
"ASSOCIATEOBJID": hostgroup_id,
"TYPE": "245",
def delete_portgroup_mapping_view(self, view_id, portgroup_id):
"""Remove portgroup associate from the mapping view."""
- url = self.url + "/mappingview/REMOVE_ASSOCIATE"
+ url = "/mappingview/REMOVE_ASSOCIATE"
data = json.dumps({"ASSOCIATEOBJTYPE": "257",
"ASSOCIATEOBJID": portgroup_id,
"TYPE": "245",
def delete_mapping_view(self, view_id):
"""Remove mapping view from the storage."""
- url = self.url + "/mappingview/" + view_id
+ url = "/mappingview/" + view_id
result = self.call(url, None, "DELETE")
self._assert_rest_result(result, _('Delete mapping view error.'))
"""Check if there are still other luns associated to the lungroup."""
url_subfix = ("/lun/count?TYPE=11&ASSOCIATEOBJTYPE=256&"
"ASSOCIATEOBJID=%s" % lungroup_id)
- url = self.url + url_subfix
+ url = url_subfix
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Find lun number error.'))
lunnum = -1
"""Check whether the port group is associated to the mapping view."""
url_subfix = ("/portgroup/associate?ASSOCIATEOBJTYPE=245&"
"ASSOCIATEOBJID=%s&range=[0-8191]" % view_id)
- url = self.url + url_subfix
+ url = url_subfix
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Find portgroup from mapping view '
'error.'))
"""Get lungroup from the given map"""
url_subfix = ("/mappingview/associate/lungroup?TYPE=256&"
"ASSOCIATEOBJTYPE=245&ASSOCIATEOBJID=%s" % view_id)
- url = self.url + url_subfix
+ url = url_subfix
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Find lun group from mapping view '
'error.'))
def start_luncopy(self, luncopy_id):
"""Start a LUNcopy."""
- url = self.url + "/LUNCOPY/start"
+ url = "/LUNCOPY/start"
data = json.dumps({"TYPE": "219", "ID": luncopy_id})
result = self.call(url, data, "PUT")
self._assert_rest_result(result, _('Start LUNcopy error.'))
def get_luncopy_info(self, luncopy_id):
"""Get LUNcopy information."""
- url = self.url + "/LUNCOPY?range=[0-1023]"
+ url = "/LUNCOPY?range=[0-1023]"
data = json.dumps({"TYPE": "219", })
result = self.call(url, data, "GET")
self._assert_rest_result(result, _('Get LUNcopy information error.'))
def delete_luncopy(self, luncopy_id):
"""Delete a LUNcopy."""
- url = self.url + "/LUNCOPY/%s" % luncopy_id
+ url = "/LUNCOPY/%s" % luncopy_id
result = self.call(url, None, "DELETE")
self._assert_rest_result(result, _('Delete LUNcopy error.'))
If no new ports connected, return an empty list.
"""
- url = self.url + "/fc_initiator?ISFREE=true&range=[0-8191]"
+ url = "/fc_initiator?ISFREE=true&range=[0-8191]"
result = self.call(url, None, "GET")
msg = _('Get connected free FC wwn error.')
def add_fc_port_to_host(self, host_id, wwn):
"""Add a FC port to the host."""
- url = self.url + "/fc_initiator/" + wwn
+ url = "/fc_initiator/" + wwn
data = json.dumps({"TYPE": "223",
"ID": wwn,
"PARENTTYPE": 21,
def _get_iscsi_port_info(self, ip):
"""Get iscsi port info in order to build the iscsi target iqn."""
- url = self.url + "/eth_port"
+ url = "/eth_port"
result = self.call(url, None, "GET")
msg = _('Get iSCSI port information error.')
return iqn
def get_fc_target_wwpns(self, wwn):
- url = (self.url +
- "/host_link?INITIATOR_TYPE=223&INITIATOR_PORT_WWN=" + wwn)
+ url = ("/host_link?INITIATOR_TYPE=223&INITIATOR_PORT_WWN=" + wwn)
result = self.call(url, None, "GET")
msg = _('Get FC target wwpn error.')
return data
def _find_qos_policy_info(self, policy_name):
- url = self.url + "/ioclass"
+ url = "/ioclass"
result = self.call(url, None, "GET")
msg = _('Get QoS policy error.')
return qos_info
def _update_qos_policy_lunlist(self, lun_list, policy_id):
- url = self.url + "/ioclass/" + policy_id
+ url = "/ioclass/" + policy_id
data = json.dumps({"TYPE": "230",
"ID": policy_id,
"LUNLIST": lun_list})
def _get_tgt_ip_from_portgroup(self, portgroup_id):
target_ips = []
- url = self.url + ("/eth_port/associate?TYPE=213&ASSOCIATEOBJTYPE=257"
- "&ASSOCIATEOBJID=%s" % portgroup_id)
+ url = ("/eth_port/associate?TYPE=213&ASSOCIATEOBJTYPE=257"
+ "&ASSOCIATEOBJID=%s" % portgroup_id)
result = self.call(url, None, "GET")
msg = _('Get target IP error.')
return (target_iqns, target_ips, portgroup_id)
def _get_tgt_iqn_from_rest(self, target_ip):
- url = self.url + "/iscsi_tgt_port"
+ url = "/iscsi_tgt_port"
result = self.call(url, None, "GET")
target_iqn = None
}
mergedata.update(qos)
data = json.dumps(mergedata)
- url = self.url + "/ioclass/"
+ url = "/ioclass/"
result = self.call(url, data)
self._assert_rest_result(result, _('Create QoS policy error.'))
def delete_qos_policy(self, qos_id):
"""Delete a QoS policy."""
- url = self.url + "/ioclass/" + qos_id
+ url = "/ioclass/" + qos_id
data = json.dumps({"TYPE": "230",
"ID": qos_id})
enablestatus: true (activate)
enbalestatus: false (deactivate)
"""
- url = self.url + "/ioclass/active/" + qos_id
+ url = "/ioclass/active/" + qos_id
data = json.dumps({"TYPE": 230,
"ID": qos_id,
"ENABLESTATUS": enablestatus})
def get_qos_info(self, qos_id):
"""Get QoS information."""
- url = self.url + "/ioclass/" + qos_id
+ url = "/ioclass/" + qos_id
data = json.dumps({"TYPE": "230",
"ID": qos_id})
result = self.call(url, data, "GET")
def remove_lun_from_qos(self, lun_id, lun_list, qos_id):
"""Remove lun from QoS."""
lun_list = [i for i in lun_list if i != lun_id]
- url = self.url + "/ioclass/" + qos_id
+ url = "/ioclass/" + qos_id
data = json.dumps({"LUNLIST": lun_list,
"TYPE": 230,
"ID": qos_id})
def change_lun_priority(self, lun_id):
"""Change lun priority to high."""
- url = self.url + "/lun/" + lun_id
+ url = "/lun/" + lun_id
data = json.dumps({"TYPE": "11",
"ID": lun_id,
"IOPRIORITY": "3"})
def change_lun_smarttier(self, lunid, smarttier_policy):
"""Change lun smarttier policy."""
- url = self.url + "/lun/" + lunid
+ url = "/lun/" + lunid
data = json.dumps({"TYPE": "11",
"ID": lunid,
"DATATRANSFERPOLICY": smarttier_policy})
def get_qosid_by_lunid(self, lun_id):
"""Get QoS id by lun id."""
- url = self.url + "/lun/" + lun_id
+ url = "/lun/" + lun_id
data = json.dumps({"TYPE": "11",
"ID": lun_id})
return result['data']['IOCLASSID']
def get_lungroupids_by_lunid(self, lun_id):
- """Get lungroup ids by lun id."""
-
- url = self.url + ("/lungroup/associate?TYPE=256"
- "&ASSOCIATEOBJTYPE=11&ASSOCIATEOBJID=%s" % lun_id)
+ """Get lungroup id by lun id."""
+ url = ("/lungroup/associate?TYPE=256"
+ "&ASSOCIATEOBJTYPE=11&ASSOCIATEOBJID=%s" % lun_id)
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Get lungroup id by lun id error.'))
return lungroup_ids
def get_lun_info(self, lun_id):
- url = self.url + "/lun/" + lun_id
+ url = "/lun/" + lun_id
data = json.dumps({"TYPE": "11",
"ID": lun_id})
result = self.call(url, data, "GET")
return result['data']
def extend_volume(self, lun_id, new_volume_size):
- url = self.url + "/lun/expand"
+ url = "/lun/expand"
data = json.dumps({"TYPE": 11, "ID": lun_id,
"CAPACITY": new_volume_size})
result = self.call(url, data, 'PUT')
return result['data']
def create_lun_migration(self, src_id, dst_id, speed=2):
- url = self.url + "/LUN_MIGRATION"
+ url = "/LUN_MIGRATION"
data = json.dumps({"TYPE": '253',
"PARENTID": src_id,
"TARGETLUNID": dst_id,
self._assert_data_in_result(result, msg)
def get_lun_migration_task(self):
- url = self.url + '/LUN_MIGRATION?range=[0-100]'
+ url = '/LUN_MIGRATION?range=[0-100]'
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Get lun migration task error.'))
return result
def delete_lun_migration(self, src_id, dst_id):
- url = self.url + '/LUN_MIGRATION/' + src_id
+ url = '/LUN_MIGRATION/' + src_id
result = self.call(url, None, "DELETE")
msg = _('Delete lun migration error.')
self._assert_rest_result(result, msg)
self._assert_data_in_result(result, msg)
def get_partition_id_by_name(self, name):
- url = self.url + "/cachepartition"
+ url = "/cachepartition"
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Get partition by name error.'))
def get_partition_info_by_id(self, partition_id):
- url = self.url + '/cachepartition/' + partition_id
+ url = '/cachepartition/' + partition_id
data = json.dumps({"TYPE": '268',
"ID": partition_id})
return result['data']
def add_lun_to_partition(self, lun_id, partition_id):
- url = self.url + "/lun/associate/cachepartition"
+ url = "/lun/associate/cachepartition"
data = json.dumps({"ID": partition_id,
"ASSOCIATEOBJTYPE": 11,
"ASSOCIATEOBJID": lun_id, })
self._assert_rest_result(result, _('Add lun to partition error.'))
def remove_lun_from_partition(self, lun_id, partition_id):
- url = (self.url + '/lun/associate/cachepartition?ID=' + partition_id
+ url = ('/lun/associate/cachepartition?ID=' + partition_id
+ '&ASSOCIATEOBJTYPE=11&ASSOCIATEOBJID=' + lun_id)
result = self.call(url, None, "DELETE")
self._assert_rest_result(result, _('Remove lun from partition error.'))
def get_cache_id_by_name(self, name):
- url = self.url + "/SMARTCACHEPARTITION"
+ url = "/SMARTCACHEPARTITION"
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Get cache by name error.'))
return item['ID']
def get_cache_info_by_id(self, cacheid):
- url = self.url + "/SMARTCACHEPARTITION/" + cacheid
+ url = "/SMARTCACHEPARTITION/" + cacheid
data = json.dumps({"TYPE": "273",
"ID": cacheid})
return result['data']
def remove_lun_from_cache(self, lun_id, cache_id):
- url = self.url + "/SMARTCACHEPARTITION/REMOVE_ASSOCIATE"
+ url = "/SMARTCACHEPARTITION/REMOVE_ASSOCIATE"
data = json.dumps({"ID": cache_id,
"ASSOCIATEOBJTYPE": 11,
"ASSOCIATEOBJID": lun_id,
""""Find available QoS on the array."""
qos_id = None
lun_list = []
- url = self.url + "/ioclass?range=[0-100]"
+ url = "/ioclass?range=[0-100]"
result = self.call(url, None, "GET")
self._assert_rest_result(result, _('Get QoS information error.'))
def add_lun_to_qos(self, qos_id, lun_id, lun_list):
"""Add lun to QoS."""
- url = self.url + "/ioclass/" + qos_id
+ url = "/ioclass/" + qos_id
new_lun_list = []
lun_list_string = lun_list[1:-1]
for lun_string in lun_list_string.split(","):
self._assert_data_in_result(result, msg)
def add_lun_to_cache(self, lun_id, cache_id):
- url = self.url + "/SMARTCACHEPARTITION/CREATE_ASSOCIATE"
+ url = "/SMARTCACHEPARTITION/CREATE_ASSOCIATE"
data = json.dumps({"ID": cache_id,
"ASSOCIATEOBJTYPE": 11,
"ASSOCIATEOBJID": lun_id,
self._assert_rest_result(result, _('Add lun to cache error.'))
def find_array_version(self):
- url = self.url + "/system/"
+ url = "/system/"
result = self.call(url, None)
self._assert_rest_result(result, _('Find array version error.'))
return result['data']['PRODUCTVERSION']
def remove_host(self, host_id):
- url = self.url + "/host/%s" % host_id
+ url = "/host/%s" % host_id
result = self.call(url, None, "DELETE")
self._assert_rest_result(result, _('Remove host from array error.'))
def delete_hostgroup(self, hostgroup_id):
- url = self.url + "/hostgroup/%s" % hostgroup_id
+ url = "/hostgroup/%s" % hostgroup_id
result = self.call(url, None, "DELETE")
self._assert_rest_result(result, _('Delete hostgroup error.'))
def remove_host_from_hostgroup(self, hostgroup_id, host_id):
url_subfix001 = "/host/associate?TYPE=14&ID=%s" % hostgroup_id
url_subfix002 = "&ASSOCIATEOBJTYPE=21&ASSOCIATEOBJID=%s" % host_id
- url = self.url + url_subfix001 + url_subfix002
+ url = url_subfix001 + url_subfix002
result = self.call(url, None, "DELETE")
self._assert_rest_result(result,
_('Remove host from hostgroup error.'))
def remove_iscsi_from_host(self, initiator):
- url = self.url + "/iscsi_initiator/remove_iscsi_from_host"
+ url = "/iscsi_initiator/remove_iscsi_from_host"
data = json.dumps({"TYPE": '222',
"ID": initiator})
result = self.call(url, data, "PUT")
self._assert_rest_result(result, _('Remove iscsi from host error.'))
def get_host_online_fc_initiators(self, host_id):
- url = self.url + "/fc_initiator"
+ url = "/fc_initiator"
data = json.dumps({'PARENTTYPE': 21,
'PARENTID': host_id})
result = self.call(url, data, "GET")
return initiators
def get_host_fc_initiators(self, host_id):
- url = self.url + "/fc_initiator"
+ url = "/fc_initiator"
data = json.dumps({'PARENTTYPE': 21,
'PARENTID': host_id})
result = self.call(url, data, "GET")
return initiators
def get_host_iscsi_initiators(self, host_id):
- url = self.url + "/iscsi_initiator"
+ url = "/iscsi_initiator"
data = json.dumps({'PARENTTYPE': 21,
'PARENTID': host_id})
result = self.call(url, data, "GET")
return initiators
def rename_lun(self, lun_id, new_name):
- url = self.url + "/lun/" + lun_id
+ url = "/lun/" + lun_id
data = json.dumps({"NAME": new_name})
result = self.call(url, data, "PUT")
msg = _('Rename lun on array error.')
def is_fc_initiator_associated_to_host(self, ininame):
"""Check whether the initiator is associated to the host."""
- url = self.url + '/fc_initiator?range=[0-256]'
+ url = '/fc_initiator?range=[0-256]'
result = self.call(url, None, "GET")
self._assert_rest_result(result,
'Check initiator associated to host error.')
return False
def remove_fc_from_host(self, initiator):
- url = self.url + '/fc_initiator/remove_fc_from_host'
+ url = '/fc_initiator/remove_fc_from_host'
data = json.dumps({"TYPE": '223',
"ID": initiator})
result = self.call(url, data, "PUT")
self._assert_rest_result(result, _('Remove fc from host error.'))
def check_fc_initiators_exist_in_host(self, host_id):
- url = self.url + '/fc_initiator?range=[0-256]'
+ url = '/fc_initiator?range=[0-256]'
data = json.dumps({"PARENTID": host_id})
result = self.call(url, data, "GET")
self._assert_rest_result(result, _('Get host initiators info failed.'))
def _fc_initiator_is_added_to_array(self, ininame):
"""Check whether the fc initiator is already added on the array."""
- url = self.url + '/fc_initiator/' + ininame
+ url = '/fc_initiator/' + ininame
data = json.dumps({"TYPE": '223',
"ID": ininame})
result = self.call(url, data, "GET")
def _add_fc_initiator_to_array(self, ininame):
"""Add a fc initiator to storage device."""
- url = self.url + '/fc_initiator/'
+ url = '/fc_initiator/'
data = json.dumps({"TYPE": '223',
"ID": ininame})
result = self.call(url, data)
self.add_fc_port_to_host(host_id, initiator_name)
def get_fc_ports_on_array(self):
- url = self.url + '/fc_port'
+ url = '/fc_port'
result = self.call(url, None, "GET")
msg = _('Get FC ports from array error.')
self._assert_rest_result(result, msg)
Code Review / openstack-build / cinder-build.git / commitdiff