self.wim_account_id, self.plugin_name))
except Exception as e:
self.logger.error("Cannot load sdn connector for wim_account={}, plugin={}: {}".format(
- self.wim_account_id, self.plugin_name, e))
+ self.wim_account_id, self.plugin_name, e), exc_info=True)
self.sdnconnector = None
- self.error_status = "Error loading sdn connector: {}".format(e)
+ self.error_status = self._format_vim_error_msg("Error loading sdn connector: {}".format(e))
def _get_db_task(self):
"""
self.logger.error("Error executing task={}: {}".format(task_id, e), exc_info=True)
task["error_msg"] = str(e)
task["status"] = "FAILED"
- database_update = {"status": "VIM_ERROR", "error_msg": task["error_msg"]}
+ database_update = {"status": "VIM_ERROR" if task["item"] != "instance_wim_nets" else "WIM_ERROR",
+ "error_msg": task["error_msg"]}
# if task["item"] == 'instance_vms':
# database_update["vim_vm_id"] = None
# elif task["item"] == 'instance_nets':
return False
def run(self):
- self.logger.debug("Starting")
+ self.logger.info("Starting")
while True:
self.get_vim_sdn_connector()
- self.logger.debug("Vimconnector loaded")
reload_thread = False
while True:
if '/' not in source_ip:
source_ip += '/32'
definition["source_ip_prefix"] = source_ip
- if source_port:
+ if source_port and ip_proto !='icmp':
definition["source_port_range_min"] = source_port
definition["source_port_range_max"] = source_port
- if destination_port:
+ if destination_port and ip_proto !='icmp':
definition["destination_port_range_min"] = destination_port
definition["destination_port_range_max"] = destination_port
if destination_ip: