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 from util.logger import Logger, logging
   8
   9 logger = Logger(level=logging.INFO)
  10
  11 class SyncNetworkSlivers(OpenStackSyncStep):
  12     requested_interval = 0 # 3600
  13     provides=[NetworkSliver]
  14
  15     #     The way it works is to enumerate the all of the ports that quantum
  16     #     has, and then work backward from each port's network-id to determine
  17     #     which Network is associated from the port.
  18
  19     def call(self, **args):
  20         networkSlivers = NetworkSliver.objects.all()
  21         networkSlivers_by_id = {}
  22         networkSlivers_by_port = {}
  23         for networkSliver in networkSlivers:
  24             networkSlivers_by_id[networkSliver.id] = networkSliver
  25             networkSlivers_by_port[networkSliver.port_id] = networkSliver
  26
  27         networks = Network.objects.all()
  28         networks_by_id = {}
  29         for network in networks:
  30             for nd in network.networkdeployments_set.all():
  31                 networks_by_id[nd.net_id] = network
  32
  33         #logger.info("networks_by_id = ")
  34         #for (network_id, network) in networks_by_id.items():
  35         #    logger.info("   %s: %s" % (network_id, network.name))
  36
  37         slivers = Sliver.objects.all()
  38         slivers_by_instance_id = {}
  39         for sliver in slivers:
  40             slivers_by_instance_id[sliver.instance_id] = sliver
  41
  42         driver = self.driver.client_driver(caller=sliver.creator, tenant=sliver.slice.name, deployment=sliver.node.deployment.name)
  43         ports = driver.shell.quantum.list_ports()["ports"]
  44         for port in ports:
  45             #logger.info("port %s" % str(port))
  46             if port["id"] in networkSlivers_by_port:
  47                 # we already have it
  48                 #logger.info("already accounted for port %s" % port["id"])
  49                 continue
  50
  51             if port["device_owner"] != "compute:nova":
  52                 # we only want the ports that connect to instances
  53                 #logger.info("port %s is not a compute port, it is a %s" % (port["id"], port["device_owner"]))
  54                 continue
  55
  56             sliver = slivers_by_instance_id.get(port['device_id'], None)
  57             if not sliver:
  58                 logger.info("no sliver for port %s device_id %s" % (port["id"], port['device_id']))
  59                 continue
  60
  61             network = networks_by_id.get(port['network_id'], None)
  62             if not network:
  63                 logger.info("no network for port %s network %s" % (port["id"], port["network_id"]))
  64
  65                 # we know it's associated with a sliver, but we don't know
  66                 # which network it is part of.
  67
  68                 continue
  69
  70             if network.template.sharedNetworkName:
  71                 # If it's a shared network template, then more than one network
  72                 # object maps to the quantum network. We have to do a whole bunch
  73                 # of extra work to find the right one.
  74                 networks = network.template.network_set.all()
  75                 network = None
  76                 for candidate_network in networks:
  77                     if (candidate_network.owner == sliver.slice):
  78                         print "found network", candidate_network
  79                         network = candidate_network
  80
  81                 if not network:
  82                     logger.info("failed to find the correct network for a shared template for port %s network %s" % (port["id"], port["network_id"]))
  83                     continue
  84
  85             if not port["fixed_ips"]:
  86                 logger.info("port %s has no fixed_ips" % port["id"])
  87                 continue
  88
  89             ip=port["fixed_ips"][0]["ip_address"]
  90             logger.info("creating NetworkSliver (%s, %s, %s, %s)" % (str(network), str(sliver), ip, str(port["id"])))
  91
  92             ns = NetworkSliver(network=network,
  93                                sliver=sliver,
  94                                ip=ip,
  95                                port_id=port["id"])
  96             ns.save()
  97
  98     def delete_record(self, network_sliver):
  99         # Nothing to do, this is an OpenCloud object
 100         pass
 101