Tony Mack | f3bbe47 | 2014-11-30 15:33:35 -0500 | [diff] [blame] | 1 | import os |
| 2 | import base64 |
| 3 | from collections import defaultdict |
| 4 | from netaddr import IPAddress, IPNetwork |
| 5 | from django.db.models import F, Q |
Scott Baker | 76a840e | 2015-02-11 21:38:09 -0800 | [diff] [blame] | 6 | from xos.config import Config |
Sapan Bhatia | 67ea0d7 | 2016-01-14 11:41:38 -0500 | [diff] [blame] | 7 | from synchronizers.base.openstacksyncstep import OpenStackSyncStep |
Sapan Bhatia | 003e84c | 2016-01-15 11:05:52 -0500 | [diff] [blame] | 8 | from synchronizers.base.syncstep import * |
Tony Mack | f3bbe47 | 2014-11-30 15:33:35 -0500 | [diff] [blame] | 9 | from core.models.network import * |
| 10 | from core.models.slice import * |
Tony Mack | 3de59e3 | 2015-08-19 11:58:18 -0400 | [diff] [blame] | 11 | from core.models.instance import Instance |
Scott Baker | 0ae266e | 2016-01-14 15:30:20 -0800 | [diff] [blame] | 12 | from xos.logger import observer_logger as logger |
Sapan Bhatia | 003e84c | 2016-01-15 11:05:52 -0500 | [diff] [blame] | 13 | from synchronizers.base.ansible import * |
S.Çağlar Onur | ad135a9 | 2015-02-18 09:59:55 -0500 | [diff] [blame] | 14 | from openstack.driver import OpenStackDriver |
Scott Baker | 287137c | 2016-01-04 22:50:28 -0800 | [diff] [blame] | 15 | from xos.config import Config |
Sapan Bhatia | 9028c9a | 2015-05-09 18:14:40 +0200 | [diff] [blame] | 16 | import json |
Tony Mack | f3bbe47 | 2014-11-30 15:33:35 -0500 | [diff] [blame] | 17 | |
Sapan Bhatia | 99f4968 | 2015-01-29 20:58:25 +0000 | [diff] [blame] | 18 | import pdb |
| 19 | |
Tony Mack | dd8746b | 2015-01-07 12:48:37 -0500 | [diff] [blame] | 20 | class SyncControllerNetworks(OpenStackSyncStep): |
Tony Mack | f3bbe47 | 2014-11-30 15:33:35 -0500 | [diff] [blame] | 21 | requested_interval = 0 |
Sapan Bhatia | b3048aa | 2015-01-27 03:52:19 +0000 | [diff] [blame] | 22 | provides=[Network] |
Sapan Bhatia | 99f4968 | 2015-01-29 20:58:25 +0000 | [diff] [blame] | 23 | observes=ControllerNetwork |
Sapan Bhatia | 321b70e | 2015-08-19 12:20:47 -0400 | [diff] [blame] | 24 | playbook='sync_controller_networks.yaml' |
Tony Mack | f3bbe47 | 2014-11-30 15:33:35 -0500 | [diff] [blame] | 25 | |
Sapan Bhatia | 189ed67 | 2014-12-19 13:21:30 -0500 | [diff] [blame] | 26 | def alloc_subnet(self, uuid): |
Sapan Bhatia | d99b112 | 2015-01-23 16:22:12 +0000 | [diff] [blame] | 27 | # 16 bits only |
| 28 | uuid_masked = uuid & 0xffff |
Sapan Bhatia | 189ed67 | 2014-12-19 13:21:30 -0500 | [diff] [blame] | 29 | a = 10 |
Sapan Bhatia | d99b112 | 2015-01-23 16:22:12 +0000 | [diff] [blame] | 30 | b = uuid_masked >> 8 |
| 31 | c = uuid_masked & 0xff |
| 32 | d = 0 |
Sapan Bhatia | 189ed67 | 2014-12-19 13:21:30 -0500 | [diff] [blame] | 33 | |
Sapan Bhatia | d99b112 | 2015-01-23 16:22:12 +0000 | [diff] [blame] | 34 | cidr = '%d.%d.%d.%d/24'%(a,b,c,d) |
| 35 | return cidr |
| 36 | |
Scott Baker | b18845e | 2016-01-04 22:39:46 -0800 | [diff] [blame] | 37 | def alloc_gateway(self, uuid): |
| 38 | # 16 bits only |
| 39 | uuid_masked = uuid & 0xffff |
| 40 | a = 10 |
| 41 | b = uuid_masked >> 8 |
| 42 | c = uuid_masked & 0xff |
| 43 | d = 1 |
| 44 | |
| 45 | gateway = '%d.%d.%d.%d'%(a,b,c,d) |
| 46 | return gateway |
| 47 | |
Sapan Bhatia | 189ed67 | 2014-12-19 13:21:30 -0500 | [diff] [blame] | 48 | |
Tony Mack | 336e0f9 | 2014-11-30 15:53:08 -0500 | [diff] [blame] | 49 | def save_controller_network(self, controller_network): |
Sapan Bhatia | b0464ba | 2015-01-23 16:21:57 +0000 | [diff] [blame] | 50 | network_name = controller_network.network.name |
| 51 | subnet_name = '%s-%d'%(network_name,controller_network.pk) |
| 52 | cidr = self.alloc_subnet(controller_network.pk) |
Sapan Bhatia | 70a3e14 | 2015-09-16 19:14:41 +0200 | [diff] [blame] | 53 | self.cidr=cidr |
Scott Baker | 1ebe12d | 2015-08-21 16:12:33 -0700 | [diff] [blame] | 54 | slice = controller_network.network.owner |
Sapan Bhatia | 6c1cb84 | 2014-12-22 01:42:18 -0500 | [diff] [blame] | 55 | |
Sapan Bhatia | b0464ba | 2015-01-23 16:21:57 +0000 | [diff] [blame] | 56 | network_fields = {'endpoint':controller_network.controller.auth_url, |
Tony Mack | 09a2f07 | 2015-09-14 00:53:39 +0000 | [diff] [blame] | 57 | 'endpoint_v3': controller_network.controller.auth_url_v3, |
Scott Baker | 1ebe12d | 2015-08-21 16:12:33 -0700 | [diff] [blame] | 58 | 'admin_user':slice.creator.email, |
| 59 | 'tenant_name':slice.name, |
Sapan Bhatia | b0464ba | 2015-01-23 16:21:57 +0000 | [diff] [blame] | 60 | 'admin_password':slice.creator.remote_password, |
Scott Baker | 4a20ce6 | 2015-09-21 20:24:45 -0700 | [diff] [blame] | 61 | 'domain': controller_network.controller.domain, |
Sapan Bhatia | b0464ba | 2015-01-23 16:21:57 +0000 | [diff] [blame] | 62 | 'name':network_name, |
| 63 | 'subnet_name':subnet_name, |
| 64 | 'ansible_tag':'%s-%s@%s'%(network_name,slice.slicename,controller_network.controller.name), |
Sapan Bhatia | 1b4394a | 2015-05-09 18:18:56 +0200 | [diff] [blame] | 65 | 'cidr':cidr, |
Scott Baker | b18845e | 2016-01-04 22:39:46 -0800 | [diff] [blame] | 66 | 'gateway':self.alloc_gateway(controller_network.pk), |
Scott Baker | 287137c | 2016-01-04 22:50:28 -0800 | [diff] [blame] | 67 | 'use_vtn':getattr(Config(), "networking_use_vtn", False), |
Sapan Bhatia | 1b4394a | 2015-05-09 18:18:56 +0200 | [diff] [blame] | 68 | 'delete':False |
Sapan Bhatia | b0464ba | 2015-01-23 16:21:57 +0000 | [diff] [blame] | 69 | } |
Sapan Bhatia | 321b70e | 2015-08-19 12:20:47 -0400 | [diff] [blame] | 70 | return network_fields |
Tony Mack | f3bbe47 | 2014-11-30 15:33:35 -0500 | [diff] [blame] | 71 | |
Sapan Bhatia | 321b70e | 2015-08-19 12:20:47 -0400 | [diff] [blame] | 72 | def map_sync_outputs(self, controller_network,res): |
Tony Mack | 3944db2 | 2015-09-30 18:40:16 +0000 | [diff] [blame] | 73 | network_id = res[0]['id'] |
| 74 | subnet_id = res[1]['id'] |
Sapan Bhatia | b0464ba | 2015-01-23 16:21:57 +0000 | [diff] [blame] | 75 | controller_network.net_id = network_id |
Sapan Bhatia | 70a3e14 | 2015-09-16 19:14:41 +0200 | [diff] [blame] | 76 | controller_network.subnet = self.cidr |
Sapan Bhatia | b0464ba | 2015-01-23 16:21:57 +0000 | [diff] [blame] | 77 | controller_network.subnet_id = subnet_id |
Sapan Bhatia | 5851db4 | 2015-01-27 03:52:43 +0000 | [diff] [blame] | 78 | controller_network.backend_status = '1 - OK' |
Sapan Bhatia | b0464ba | 2015-01-23 16:21:57 +0000 | [diff] [blame] | 79 | controller_network.save() |
Tony Mack | f3bbe47 | 2014-11-30 15:33:35 -0500 | [diff] [blame] | 80 | |
Tony Mack | f3bbe47 | 2014-11-30 15:33:35 -0500 | [diff] [blame] | 81 | |
Sapan Bhatia | 321b70e | 2015-08-19 12:20:47 -0400 | [diff] [blame] | 82 | def map_sync_inputs(self, controller_network): |
Scott Baker | 3aaa76b | 2015-12-09 22:55:19 -0800 | [diff] [blame] | 83 | # XXX This check should really be made from booleans, rather than using hardcoded network names |
| 84 | if (controller_network.network.template.name not in ['Private', 'Private-Indirect', 'Private-Direct']): |
Scott Baker | 1ebe12d | 2015-08-21 16:12:33 -0700 | [diff] [blame] | 85 | logger.info("skipping network controller %s because it is not private" % controller_network) |
Sapan Bhatia | db631b2 | 2015-05-27 17:23:58 +0200 | [diff] [blame] | 86 | # We only sync private networks |
Scott Baker | 1a36d66 | 2015-10-12 18:28:00 -0700 | [diff] [blame] | 87 | return SyncStep.SYNC_WITHOUT_RUNNING |
Sapan Bhatia | db631b2 | 2015-05-27 17:23:58 +0200 | [diff] [blame] | 88 | |
Tony Mack | 336e0f9 | 2014-11-30 15:53:08 -0500 | [diff] [blame] | 89 | if not controller_network.controller.admin_user: |
| 90 | logger.info("controller %r has no admin_user, skipping" % controller_network.controller) |
Tony Mack | f3bbe47 | 2014-11-30 15:33:35 -0500 | [diff] [blame] | 91 | return |
| 92 | |
Tony Mack | 336e0f9 | 2014-11-30 15:53:08 -0500 | [diff] [blame] | 93 | if controller_network.network.owner and controller_network.network.owner.creator: |
Sapan Bhatia | 321b70e | 2015-08-19 12:20:47 -0400 | [diff] [blame] | 94 | return self.save_controller_network(controller_network) |
| 95 | else: |
| 96 | raise Exception('Could not save network controller %s'%controller_network) |
Tony Mack | f3bbe47 | 2014-11-30 15:33:35 -0500 | [diff] [blame] | 97 | |
Sapan Bhatia | 321b70e | 2015-08-19 12:20:47 -0400 | [diff] [blame] | 98 | def map_delete_inputs(self, controller_network): |
Scott Baker | 3aaa76b | 2015-12-09 22:55:19 -0800 | [diff] [blame] | 99 | # XXX This check should really be made from booleans, rather than using hardcoded network names |
| 100 | if (controller_network.network.template.name not in ['Private', 'Private-Indirect', 'Private-Direct']): |
Sapan Bhatia | db631b2 | 2015-05-27 17:23:58 +0200 | [diff] [blame] | 101 | # We only sync private networks |
| 102 | return |
Sapan Bhatia | 53a0e9b | 2015-05-09 18:16:24 +0200 | [diff] [blame] | 103 | try: |
| 104 | slice = controller_network.network.owner # XXX: FIXME!! |
| 105 | except: |
| 106 | raise Exception('Could not get slice for Network %s'%controller_network.network.name) |
| 107 | |
| 108 | network_name = controller_network.network.name |
| 109 | subnet_name = '%s-%d'%(network_name,controller_network.pk) |
| 110 | cidr = controller_network.subnet |
| 111 | network_fields = {'endpoint':controller_network.controller.auth_url, |
| 112 | 'admin_user':slice.creator.email, # XXX: FIXME |
| 113 | 'tenant_name':slice.name, # XXX: FIXME |
| 114 | 'admin_password':slice.creator.remote_password, |
| 115 | 'name':network_name, |
| 116 | 'subnet_name':subnet_name, |
| 117 | 'ansible_tag':'%s-%s@%s'%(network_name,slice.slicename,controller_network.controller.name), |
| 118 | 'cidr':cidr, |
| 119 | 'delete':True |
| 120 | } |
| 121 | |
Sapan Bhatia | 321b70e | 2015-08-19 12:20:47 -0400 | [diff] [blame] | 122 | return network_fields |
Sapan Bhatia | 53a0e9b | 2015-05-09 18:16:24 +0200 | [diff] [blame] | 123 | |
| 124 | """ |
Tony Mack | 336e0f9 | 2014-11-30 15:53:08 -0500 | [diff] [blame] | 125 | driver = OpenStackDriver().client_driver(caller=controller_network.network.owner.creator, |
| 126 | tenant=controller_network.network.owner.name, |
| 127 | controller=controller_network.controller.name) |
| 128 | if (controller_network.router_id) and (controller_network.subnet_id): |
| 129 | driver.delete_router_interface(controller_network.router_id, controller_network.subnet_id) |
| 130 | if controller_network.subnet_id: |
| 131 | driver.delete_subnet(controller_network.subnet_id) |
| 132 | if controller_network.router_id: |
| 133 | driver.delete_router(controller_network.router_id) |
| 134 | if controller_network.net_id: |
| 135 | driver.delete_network(controller_network.net_id) |
Sapan Bhatia | 53a0e9b | 2015-05-09 18:16:24 +0200 | [diff] [blame] | 136 | """ |