blob: 3c8cf20e3f402a716d82b87b1b122f8e92246b91 [file] [log] [blame]
Omar Abdelkader1d9c3192017-08-03 14:54:25 -07001from core.models.plcorebase import *
2from models_decl import VMMEService_decl
3from models_decl import VMMETenant_decl
4
Omar Abdelkader2c162842017-08-07 19:41:59 -06005from django.db import models
6from core.models import Service, PlCoreBase, Slice, Instance, Tenant, TenantWithContainer, Node, Image, User, Flavor, NetworkParameter, NetworkParameterType, Port, AddressPool
7from core.models.plcorebase import StrippedCharField
8import os
9from django.db import models, transaction
10from django.forms.models import model_to_dict
11from django.db.models import *
12from operator import itemgetter, attrgetter, methodcaller
13from core.models import Tag
14from core.models.service import LeastLoadedNodeScheduler
15import traceback
16from xos.exceptions import *
17from xos.config import Config
18from django.contrib.contenttypes.models import ContentType
19from django.contrib.contenttypes.fields import GenericForeignKey
20
Omar Abdelkader1d9c3192017-08-03 14:54:25 -070021class VMMEService(VMMEService_decl):
22 class Meta:
23 proxy = True
24
25class VMMETenant(VMMETenant_decl):
26 class Meta:
27 proxy = True
28
29 def __init__(self, *args, **kwargs):
30 vmmeservice = VMMEService.get_service_objects().all()
31 if vmmeservice:
32 self._meta.get_field(
33 "provider_service").default = vmmeservice[0].id
34 super(VMMETenant, self).__init__(*args, **kwargs)
35
36 def save(self, *args, **kwargs):
37 super(VMMETenant, self).save(*args, **kwargs)
38 # This call needs to happen so that an instance is created for this
39 # tenant is created in the slice. One instance is created per tenant.
40 model_policy_vmmetenant(self.pk)
41
42 def delete(self, *args, **kwargs):
43 # Delete the instance that was created for this tenant
44 self.cleanup_container()
45 super(VMMETenant, self).delete(*args, **kwargs)
46
47def model_policy_vmmetenant(pk):
48 # This section of code is atomic to prevent race conditions
49 with transaction.atomic():
50 # We find all of the tenants that are waiting to update
51 tenant = VMMETenant.objects.select_for_update().filter(pk=pk)
52 if not tenant:
53 return
54 # Since this code is atomic it is safe to always use the first tenant
55 tenant = tenant[0]
Omar Abdelkader2c162842017-08-07 19:41:59 -060056 tenant.manage_container()