planetstack/openstack_observer/steps/sync_network_slivers.py

   1 import os
   2 import base64
   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 *
   7
   8 class SyncNetworkSlivers(OpenStackSyncStep):
   9     requested_interval = 3600
  10     provides=[NetworkSliver]
  11
  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
  19
  20         networks = Network.objects.all()
  21         networks_by_id = {}
  22         for network in networks:
  23             networks_by_id[network.network_id] = network
  24
  25         slivers = Sliver.objects.all()
  26         slivers_by_instance_id = {}
  27         for sliver in slivers:
  28             slivers_by_instance_id[sliver.instance_id] = sliver
  29
  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"]
  32         for port in ports:
  33             if port["id"] in networkSlivers_by_port:
  34                 # we already have it
  35                 print "already accounted for port", port["id"]
  36                 continue
  37
  38             if port["device_owner"] != "compute:nova":
  39                 # we only want the ports that connect to instances
  40                 continue
  41
  42             network = networks_by_id.get(port['network_id'], None)
  43             if not network:
  44                 #print "no network for port", port["id"], "network", port["network_id"]
  45                 continue
  46
  47             sliver = slivers_by_instance_id.get(port['device_id'], None)
  48             if not sliver:
  49                 print "no sliver for port", port["id"], "device_id", port['device_id']
  50                 continue
  51
  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()
  57                 network = None
  58                 for candidate_network in networks:
  59                     if (candidate_network.owner == sliver.slice):
  60                         print "found network", candidate_network
  61                         network = candidate_network
  62
  63                 if not network:
  64                     print "failed to find the correct network for a shared template for port", port["id"], "network", port["network_id"]
  65                     continue
  66
  67             if not port["fixed_ips"]:
  68                 print "port", port["id"], "has no fixed_ips"
  69                 continue
  70
  71 #             print "XXX", port
  72
  73             ns = NetworkSliver(network=network,
  74                                sliver=sliver,
  75                                ip=port["fixed_ips"][0]["ip_address"],
  76                                port_id=port["id"])
  77             ns.save()
  78
  79     def delete_record(self, network_sliver):
  80         # Nothing to do, this is an OpenCloud object
  81         pass
  82