server_ingress = None
server_egress = None
for server in compute.computeUnits.values():
- if port_pair.ingress.name in server.port_names:
+ if port_pair.ingress.name in server.port_names or port_pair.ingress.id in server.port_names:
server_ingress = server
- elif port_pair.egress.name in server.port_names:
+ if port_pair.egress.name in server.port_names or port_pair.egress.id in server.port_names:
server_egress = server
- # TODO: Not sure, if this should throw an error
if not server_ingress:
- logging.warn("Neutron SFC: ingress port %s not connected." % str(
- port_pair.ingress.name))
- continue
+ raise RuntimeError("Neutron SFC: ingress port %s not connected to any server." %
+ port_pair.ingress.name)
if not server_egress:
- logging.warn("Neutron SFC: egress port %s not connected." % str(
- port_pair.egress.name))
- continue
+ raise RuntimeError("Neutron SFC: egress port %s not connected to any server." %
+ port_pair.egress.name)
compute.dc.net.setChain(
server_ingress.name, server_egress.name,