X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2Fvim-emu.git;a=blobdiff_plain;f=src%2Femuvim%2Fapi%2Fopenstack%2Fcompute.py;h=9f79dd9e398ae8d4da6012e913a33da54c8e390b;hp=6d4d864107962a30f2812c5530888e5b4671fa91;hb=a7161aab3b0cb321c905f69f860000bcdba43aff;hpb=7b38ee1ed94ec3e9124e8e5b9c21cf224d39edc3 diff --git a/src/emuvim/api/openstack/compute.py b/src/emuvim/api/openstack/compute.py index 6d4d864..9f79dd9 100755 --- a/src/emuvim/api/openstack/compute.py +++ b/src/emuvim/api/openstack/compute.py @@ -410,6 +410,7 @@ class OpenstackCompute(object): """ LOG.debug("Starting new compute resources %s" % server.name) network = list() + network_dict = dict() for port_name in server.port_names: network_dict = dict() @@ -419,7 +420,14 @@ class OpenstackCompute(object): network_dict['ip'] = port.ip_address network_dict[network_dict['id']] = self.find_network_by_name_or_id(port.net_name).name network.append(network_dict) + # default network dict + if len(network) < 1: + network_dict['id'] = server.name + "-eth0" + network_dict[network_dict['id']] = network_dict['id'] + network.append(network_dict) + self.compute_nets[server.name] = network + LOG.debug("Network dict: {}".format(network)) c = self.dc.startCompute(server.name, image=server.image, command=server.command, network=network, flavor_name=server.flavor, properties=server.properties) @@ -486,9 +494,16 @@ class OpenstackCompute(object): if name_or_id in self.computeUnits: return self.computeUnits[name_or_id] + if self._shorten_server_name(name_or_id) in self.computeUnits: + return self.computeUnits[name_or_id] + for server in self.computeUnits.values(): if server.name == name_or_id or server.template_name == name_or_id or server.full_name == name_or_id: return server + if (server.name == self._shorten_server_name(name_or_id) + or server.template_name == self._shorten_server_name(name_or_id) + or server.full_name == self._shorten_server_name(name_or_id)): + return server return None def create_server(self, name, stack_operation=False): @@ -505,12 +520,40 @@ class OpenstackCompute(object): """ if self.find_server_by_name_or_id(name) is not None and not stack_operation: raise Exception("Server with name %s already exists." % name) - server = Server(name) + safe_name = self._shorten_server_name(name) + server = Server(safe_name) server.id = str(uuid.uuid4()) if not stack_operation: self.computeUnits[server.id] = server return server + def _shorten_server_name(self, name, char_limit=9): + """ + Docker does not like too long instance names. + This function provides a shorter name if needed + """ + # fix for NetSoft'17 demo + # TODO remove this after the demo + if "http" in name or "apache" in name: + return "http" + elif "l4fw" in name or "socat" in name: + return "l4fw" + elif "proxy" in name or "squid" in name: + return "proxy" + # this is a ugly fix, but we cannot do better for now (interface names are to long) + if len(name) > char_limit: + LOG.info("Long server name: {}".format(name)) + # construct a short name + name = name.strip("-_ .") + name = name.replace("_vnf", "") + p = name.split("_") + if len(p) > 0: + name = p[len(p)-1] + name = name[-char_limit:].strip("-_ .") + LOG.info("Short server name: {}".format(name)) + return name + + def delete_server(self, server): """ Deletes the given server from the stack dictionary and the computeUnits dictionary.