1 from core.models import Slice, SlicePrivilege, SliceRole, Sliver, Site, Node, User
2 from plus import PlusObjectMixin
3 from operator import itemgetter, attrgetter
5 class SlicePlus(Slice, PlusObjectMixin):
9 def __init__(self, *args, **kwargs):
10 super(SlicePlus, self).__init__(*args, **kwargs)
11 self._update_site_allocation = None
12 self._update_users = None
13 self._sliceInfo = None
15 def getSliceInfo(self, user=None):
16 if not self._sliceInfo:
20 for sliver in self.slivers.all():
21 site = sliver.node.site_deployment.site
22 deployment = sliver.node.site_deployment.deployment
23 used_sites[site.name] = used_sites.get(site.name, 0) + 1
24 used_deployments[deployment.name] = used_deployments.get(deployment.name, 0) + 1
25 sliverCount = sliverCount + 1
28 for priv in SlicePrivilege.objects.filter(slice=self):
29 if not (priv.user.id in users.keys()):
30 users[priv.user.id] = {"name": priv.user.email, "id": priv.user.id, "roles": []}
31 users[priv.user.id]["roles"].append(priv.role.role)
33 self._sliceInfo= {"sitesUsed": used_sites,
34 "deploymentsUsed": used_deployments,
35 "sliverCount": sliverCount,
36 "siteCount": len(used_sites.keys()),
41 auser = self._sliceInfo["users"].get(user.id, None)
43 self._sliceInfo["roles"] = auser["roles"]
45 return self._sliceInfo
48 def site_allocation(self):
49 return self.getSliceInfo()["sitesUsed"]
51 @site_allocation.setter
52 def site_allocation(self, value):
53 self._update_site_allocation = value
54 #print "XXX set sitesUsed to", value
58 return [user["name"] for user in self.getSliceInfo()["users"].values()]
62 return [user["id"] for user in self.getSliceInfo()["users"].values()]
65 def users(self, value):
66 self._update_users = value
67 #print "XXX set users to", value
70 def network_ports(self):
71 # XXX this assumes there is only one network that can have ports bound
72 # to it for a given slice. This is intended for the tenant view, which
73 # will obey this field.
75 for networkSlice in self.networkslices.all():
76 network = networkSlice.network
78 networkPorts = network.ports
83 def network_ports(self, value):
84 print "XXX set networkPorts to", value
87 def select_by_user(user):
89 qs = SlicePlus.objects.all()
91 slice_ids = [sp.slice.id for sp in SlicePrivilege.objects.filter(user=user)]
92 qs = SlicePlus.objects.filter(id__in=slice_ids)
95 def get_node_allocation(self, siteList):
96 siteIDList = [site.id for site in siteList]
98 for node in Node.objects.all():
99 if (node.site_deployment.site.id in siteIDList):
101 for sliver in node.slivers.all():
102 if sliver.slice.id == self.id:
103 node.sliverCount = node.sliverCount + 1
104 nodeList.append(node)
107 def save(self, *args, **kwargs):
108 super(SlicePlus, self).save(*args, **kwargs)
110 if self._update_site_allocation:
111 self.save_site_allocation(noAct=True)
113 if self._update_users:
114 self.save_users(noAct=True)
116 if self._update_site_allocation:
117 self.save_site_allocation()
119 if self._update_users:
122 def save_site_allocation(self, noAct = False):
123 new_site_allocation = self._update_site_allocation
125 all_slice_slivers = self.slivers.all()
126 for site_name in new_site_allocation.keys():
127 desired_allocation = new_site_allocation[site_name]
129 # make a list of the slivers for this site
131 for sliver in all_slice_slivers:
132 if sliver.node.site_deployment.site.name == site_name:
133 slivers.append(sliver)
135 # delete extra slivers
136 while (len(slivers) > desired_allocation):
137 sliver = slivers.pop()
138 print "deleting sliver", sliver
143 if (len(slivers) < desired_allocation):
144 site = Site.objects.get(name = site_name)
145 nodes = self.get_node_allocation([site])
148 raise ValueError("no nodes in site %s" % site_name)
150 while (len(slivers) < desired_allocation):
151 # pick the least allocated node
152 nodes = sorted(nodes, key=attrgetter("sliverCount"))
155 sliver = Sliver(name=node.name,
158 image = self.default_image,
159 flavor = self.default_flavor,
160 creator = self.creator,
161 deployment = node.site_deployment.deployment)
162 slivers.append(sliver)
166 print "added sliver", sliver
168 node.sliverCount = node.sliverCount + 1
170 def save_users(self, noAct = False):
171 new_users = self._update_users
173 default_role = SliceRole.objects.get(role="default")
175 slice_privs = self.sliceprivileges.all()
176 slice_user_ids = [priv.user.id for priv in slice_privs]
178 for user_id in new_users:
179 if (user_id not in slice_user_ids):
180 priv = SlicePrivilege(slice=self, user=User.objects.get(id=user_id), role=default_role)
184 print "added user id", user_id
186 for priv in slice_privs:
187 if (priv.role.id != default_role.id):
188 # only mess with 'default' users; don't kill an admin
191 if (priv.user.id not in new_users):
195 print "deleted user id", user_id