+ # Now, handle port forwarding
+ # We get the list of NetworkSlivers again, since we might have just
+ # added a few. Then, for each one of them we find it's quantum port and
+ # make sure quantum's nat:forward_ports argument is the same.
+
+ for networkSliver in NetworkSliver.objects.all():
+ try:
+ nat_list = networkSliver.network.nat_list
+ except (TypeError, ValueError), e:
+ logger.info("Failed to decode nat_list: %s" % str(e))
+ continue
+
+ if not networkSliver.port_id:
+ continue
+
+ neutron_port = ports_by_id.get(networkSliver.port_id, None)
+ if not neutron_port:
+ continue
+
+ neutron_nat_list = neutron_port.get("nat:forward_ports", None)
+ if not neutron_nat_list:
+ # make sure that None and the empty set are treated identically
+ neutron_nat_list = []
+
+ if (neutron_nat_list != nat_list):
+ logger.info("Setting nat:forward_ports for port %s network %s sliver %s to %s" % (str(networkSliver.port_id), str(networkSliver.network.id), str(networkSliver.sliver), str(nat_list)))
+ try:
+ driver = self.driver.admin_driver(deployment=networkSliver.sliver.node.deployment,tenant='admin')
+ driver.shell.quantum.update_port(networkSliver.port_id, {"port": {"nat:forward_ports": nat_list}})
+ except:
+ logger.log_exc("failed to update port with nat_list %s" % str(nat_list))
+ continue
+ else:
+ #logger.info("port %s network %s sliver %s nat %s is already set" % (str(networkSliver.port_id), str(networkSliver.network.id), str(networkSliver.sliver), str(nat_list)))
+ pass
+