3 from django.db.models import F, Q
4 from planetstack.config import Config
5 from observer.openstacksyncstep import OpenStackSyncStep
6 from core.models.network import *
8 class SyncNetworkSlivers(OpenStackSyncStep):
9 requested_interval = 3600
10 provides=[NetworkSliver]
12 def call(self, failed=[]):
13 networkSlivers = NetworkSliver.objects.all()
14 networkSlivers_by_id = {}
15 networkSlivers_by_port = {}
16 for networkSliver in networkSlivers:
17 networkSlivers_by_id[networkSliver.id] = networkSliver
18 networkSlivers_by_port[networkSliver.port_id] = networkSliver
20 networks = Network.objects.all()
22 for network in networks:
23 networks_by_id[network.network_id] = network
25 slivers = Sliver.objects.all()
26 slivers_by_instance_id = {}
27 for sliver in slivers:
28 slivers_by_instance_id[sliver.instance_id] = sliver
30 driver = self.driver.client_driver(caller=sliver.creator, tenant=sliver.slice.name, deployment=sliver.node.deployment.name)
31 ports = driver.shell.quantum.list_ports()["ports"]
33 if port["id"] in networkSlivers_by_port:
35 print "already accounted for port", port["id"]
38 if port["device_owner"] != "compute:nova":
39 # we only want the ports that connect to instances
42 network = networks_by_id.get(port['network_id'], None)
44 #print "no network for port", port["id"], "network", port["network_id"]
47 sliver = slivers_by_instance_id.get(port['device_id'], None)
49 print "no sliver for port", port["id"], "device_id", port['device_id']
52 if network.template.sharedNetworkId is not None:
53 # If it's a shared network template, then more than one network
54 # object maps to the quantum network. We have to do a whole bunch
55 # of extra work to find the right one.
56 networks = network.template.network_set.all()
58 for candidate_network in networks:
59 if (candidate_network.owner == sliver.slice):
60 print "found network", candidate_network
61 network = candidate_network
64 print "failed to find the correct network for a shared template for port", port["id"], "network", port["network_id"]
67 if not port["fixed_ips"]:
68 print "port", port["id"], "has no fixed_ips"
73 ns = NetworkSliver(network=network,
75 ip=port["fixed_ips"][0]["ip_address"],
79 def delete_record(self, network_sliver):
80 # Nothing to do, this is an OpenCloud object