X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2Fvim-emu.git;a=blobdiff_plain;f=src%2Femuvim%2Fapi%2Fopenstack%2Fcompute.py;h=49993315717d44aca8c2b30359d9f8039a550798;hp=9d77a441f4d664db396dc4c8001e5d5cf763290f;hb=aa8823c85d94a4fa72de058076195296334cdb91;hpb=3bb8b25b4584b62a56303404a39b085c4298529a diff --git a/src/emuvim/api/openstack/compute.py b/src/emuvim/api/openstack/compute.py index 9d77a44..4999331 100755 --- a/src/emuvim/api/openstack/compute.py +++ b/src/emuvim/api/openstack/compute.py @@ -25,22 +25,22 @@ # partner consortium (www.sonata-nfv.eu). from mininet.link import Link -from resources.instance_flavor import InstanceFlavor -from resources.net import Net -from resources.port import Port -from resources.port_pair import PortPair -from resources.port_pair_group import PortPairGroup -from resources.flow_classifier import FlowClassifier -from resources.port_chain import PortChain -from resources.server import Server -from resources.image import Image +from emuvim.api.openstack.resources.instance_flavor import InstanceFlavor +from emuvim.api.openstack.resources.net import Net +from emuvim.api.openstack.resources.port import Port +from emuvim.api.openstack.resources.port_pair import PortPair +from emuvim.api.openstack.resources.port_pair_group import PortPairGroup +from emuvim.api.openstack.resources.flow_classifier import FlowClassifier +from emuvim.api.openstack.resources.port_chain import PortChain +from emuvim.api.openstack.resources.server import Server +from emuvim.api.openstack.resources.image import Image from docker import DockerClient import logging import threading import uuid import time -import ip_handler as IP +import emuvim.api.openstack.ip_handler as IP import hashlib @@ -232,8 +232,12 @@ class OpenstackCompute(object): for server in self.stacks[stack_id].servers.values(): self.stop_compute(server) self.delete_server(server) - for net in self.stacks[stack_id].nets.values(): - self.delete_network(net.id) + stack = list(self.stacks[stack_id].nets.values()) + while stack: + id = stack.pop().id + self.delete_network(id) + # for net in self.stacks[stack_id].nets.values(): + # self.delete_network(net.id) for port in self.stacks[stack_id].ports.values(): self.delete_port(port.id) @@ -592,7 +596,7 @@ class OpenstackCompute(object): """ if len(name) > char_limit: # construct a short name - h = hashlib.sha224(name).hexdigest() + h = hashlib.sha224(name.encode()).hexdigest() h = h[0:char_limit] LOG.debug("Shortened server name '%s' to '%s'" % (name, h)) return name @@ -630,6 +634,7 @@ class OpenstackCompute(object): """ if name_or_id in self.nets: return self.nets[name_or_id] + print("name_or_id: ", name_or_id) for net in self.nets.values(): if net.name == name_or_id: return net @@ -710,10 +715,10 @@ class OpenstackCompute(object): if name_or_id in self.ports: return self.ports[name_or_id] # find by name - matching_ports = filter( + matching_ports = list(filter( lambda port: port.name == name_or_id or port.template_name == name_or_id, self.ports.values() - ) + )) matching_ports_count = len(matching_ports) if matching_ports_count == 1: return matching_ports[0]