Sapan Bhatia | 24836f1 | 2013-08-27 10:16:05 -0400 | [diff] [blame] | 1 | import os |
| 2 | import base64 |
Tony Mack | ae7f30c | 2013-09-25 12:46:50 -0400 | [diff] [blame] | 3 | from django.db.models import F, Q |
Sapan Bhatia | 24836f1 | 2013-08-27 10:16:05 -0400 | [diff] [blame] | 4 | from planetstack.config import Config |
Sapan Bhatia | 04c94ad | 2013-09-02 18:00:28 -0400 | [diff] [blame] | 5 | from observer.openstacksyncstep import OpenStackSyncStep |
| 6 | from core.models.sliver import Sliver |
Scott Baker | 72c2e70 | 2014-08-11 18:58:52 -0700 | [diff] [blame^] | 7 | from util.logger import Logger, logging |
Sapan Bhatia | 24836f1 | 2013-08-27 10:16:05 -0400 | [diff] [blame] | 8 | |
| 9 | class SyncSliverIps(OpenStackSyncStep): |
Tony Mack | ce79de0 | 2013-09-24 10:12:33 -0400 | [diff] [blame] | 10 | provides=[Sliver] |
| 11 | requested_interval=0 |
Tony Mack | 66646d5 | 2013-09-24 21:47:12 -0400 | [diff] [blame] | 12 | |
Sapan Bhatia | b83643c | 2014-07-23 09:59:32 -0400 | [diff] [blame] | 13 | def fetch_pending(self, deleted): |
| 14 | # Not supported yet |
| 15 | if (deleted): |
| 16 | return [] |
Tony Mack | ce79de0 | 2013-09-24 10:12:33 -0400 | [diff] [blame] | 17 | slivers = Sliver.objects.filter(ip=None) |
| 18 | return slivers |
Sapan Bhatia | 24836f1 | 2013-08-27 10:16:05 -0400 | [diff] [blame] | 19 | |
Tony Mack | ce79de0 | 2013-09-24 10:12:33 -0400 | [diff] [blame] | 20 | def sync_record(self, sliver): |
Scott Baker | 72c2e70 | 2014-08-11 18:58:52 -0700 | [diff] [blame^] | 21 | driver = self.driver.client_driver(tenant=sliver.slice.name, |
| 22 | deployment=sliver.node.deployment.name) |
Tony Mack | ce79de0 | 2013-09-24 10:12:33 -0400 | [diff] [blame] | 23 | servers = driver.shell.nova.servers.findall(id=sliver.instance_id) |
| 24 | if not servers: |
| 25 | return |
| 26 | server = servers[0] |
Scott Baker | 72c2e70 | 2014-08-11 18:58:52 -0700 | [diff] [blame^] | 27 | |
| 28 | # First try to grab the dedicated public address |
| 29 | # NOTE: "ext-net" is hardcoded here. |
| 30 | ip = None |
| 31 | ext_net_addrs = server.addresses.get("ext-net")
|
| 32 | if ext_net_addrs:
|
| 33 | ip = ext_net_addrs[0]["addr"]
|
| 34 |
|
| 35 | # If there was no public address, then grab the first address in the
|
| 36 | # list.
|
| 37 | if not ip:
|
| 38 | if server.addresses:
|
| 39 | addrs = server.addresses.values()[0]
|
| 40 | if addrs:
|
| 41 | ip = addrs[0]["addr"] |
| 42 | |
| 43 | if ip and ip!=sliver.ip: |
| 44 | sliver.ip = ip |
Tony Mack | 261f858 | 2014-04-21 17:08:31 -0400 | [diff] [blame] | 45 | sliver.save() |
Scott Baker | 72c2e70 | 2014-08-11 18:58:52 -0700 | [diff] [blame^] | 46 | logger.info("saved sliver ip: %s %s" % (sliver, ip)) |