3 from planetstack.config import Config
5 class SyncNetworkSlivers(OpenStackSyncStep):
6 requested_interval = 3600
7 provides=[NetworkSliver]
10 networkSlivers = NetworkSliver.objects.all()
11 networkSlivers_by_id = {}
12 networkSlivers_by_port = {}
13 for networkSliver in networkSlivers:
14 networkSlivers_by_id[networkSliver.id] = networkSliver
15 networkSlivers_by_port[networkSliver.port_id] = networkSliver
17 networks = Network.objects.all()
19 for network in networks:
20 networks_by_id[network.network_id] = network
22 slivers = Sliver.objects.all()
23 slivers_by_instance_id = {}
24 for sliver in slivers:
25 slivers_by_instance_id[sliver.instance_id] = sliver
27 ports = self.manager.driver.shell.quantum.list_ports()["ports"]
29 if port["id"] in networkSlivers_by_port:
31 print "already accounted for port", port["id"]
34 if port["device_owner"] != "compute:nova":
35 # we only want the ports that connect to instances
38 network = networks_by_id.get(port['network_id'], None)
40 #print "no network for port", port["id"], "network", port["network_id"]
43 sliver = slivers_by_instance_id.get(port['device_id'], None)
45 print "no sliver for port", port["id"], "device_id", port['device_id']
48 if network.template.sharedNetworkId is not None:
49 # If it's a shared network template, then more than one network
50 # object maps to the quantum network. We have to do a whole bunch
51 # of extra work to find the right one.
52 networks = network.template.network_set.all()
54 for candidate_network in networks:
55 if (candidate_network.owner == sliver.slice):
56 print "found network", candidate_network
57 network = candidate_network
60 print "failed to find the correct network for a shared template for port", port["id"], "network", port["network_id"]
63 if not port["fixed_ips"]:
64 print "port", port["id"], "has no fixed_ips"
69 ns = NetworkSliver(network=network,
71 ip=port["fixed_ips"][0]["ip_address"],