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_users = None
12 self._sliceInfo = None
14 self._site_allocation = self._sliceInfo["sitesUsed"]
15 self._initial_site_allocation = self._site_allocation
16 self._network_ports = self._sliceInfo["networkPorts"]
17 self._initial_network_ports = self._network_ports
19 def getSliceInfo(self, user=None):
20 if not self._sliceInfo:
25 for sliver in self.slivers.all():
26 site = sliver.node.site_deployment.site
27 deployment = sliver.node.site_deployment.deployment
28 used_sites[site.name] = used_sites.get(site.name, 0) + 1
29 used_deployments[deployment.name] = used_deployments.get(deployment.name, 0) + 1
30 sliverCount = sliverCount + 1
32 if (sliver.instance_id and sliver.instance_name):
33 sshCommand = 'ssh -o "ProxyCommand ssh -q %s@%s" ubuntu@%s' % (sliver.instance_id, sliver.node.name, sliver.instance_name)
34 sshCommands.append(sshCommand);
37 for priv in SlicePrivilege.objects.filter(slice=self):
38 if not (priv.user.id in users.keys()):
39 users[priv.user.id] = {"name": priv.user.email, "id": priv.user.id, "roles": []}
40 users[priv.user.id]["roles"].append(priv.role.role)
42 # XXX this assumes there is only one network that can have ports bound
43 # to it for a given slice. This is intended for the tenant view, which
44 # will obey this field.
46 for networkSlice in self.networkslices.all():
47 network = networkSlice.network
48 if (network.owner.id != self.id):
51 networkPorts = network.ports
53 self._sliceInfo= {"sitesUsed": used_sites,
54 "deploymentsUsed": used_deployments,
55 "sliverCount": sliverCount,
56 "siteCount": len(used_sites.keys()),
59 "sshCommands": sshCommands,
60 "networkPorts": networkPorts}
63 auser = self._sliceInfo["users"].get(user.id, None)
65 self._sliceInfo["roles"] = auser["roles"]
67 return self._sliceInfo
70 def site_allocation(self):
71 return self._site_allocation
73 @site_allocation.setter
74 def site_allocation(self, value):
75 self._site_allocation = value
79 return [user["name"] for user in self.getSliceInfo()["users"].values()]
82 def user_names(self, value):
87 return [user["id"] for user in self.getSliceInfo()["users"].values()]
90 def users(self, value):
91 self._update_users = value
92 #print "XXX set users to", value
95 def network_ports(self):
96 return self._network_ports
99 def network_ports(self, value):
100 self._network_ports = value
101 #print "XXX set networkPorts to", value
104 def select_by_user(user):
106 qs = SlicePlus.objects.all()
108 slice_ids = [sp.slice.id for sp in SlicePrivilege.objects.filter(user=user)]
109 qs = SlicePlus.objects.filter(id__in=slice_ids)
112 def get_node_allocation(self, siteList):
113 siteIDList = [site.id for site in siteList]
115 for node in Node.objects.all():
116 if (node.site_deployment.site.id in siteIDList):
118 for sliver in node.slivers.all():
119 if sliver.slice.id == self.id:
120 node.sliverCount = node.sliverCount + 1
121 nodeList.append(node)
124 def save(self, *args, **kwargs):
125 updated_image = self.has_field_changed("default_image")
126 updated_flavor = self.has_field_changed("default_flavor")
128 super(SlicePlus, self).save(*args, **kwargs)
130 # try things out first
132 updated_sites = (self._site_allocation != self._initial_site_allocation) or updated_image or updated_flavor
134 self.save_site_allocation(noAct=True, reset=(updated_image or updated_flavor))
136 if self._update_users:
137 self.save_users(noAct=True)
139 if (self._network_ports != self._initial_network_ports):
140 self.save_network_ports(noAct=True)
142 # now actually save them
145 self.save_site_allocation(reset=(updated_image or updated_flavor))
147 if self._update_users:
150 if (self._network_ports != self._initial_network_ports):
151 self.save_network_ports()
153 def save_site_allocation(self, noAct = False, reset=False):
154 print "save_site_allocation, reset=",reset
156 if (not self._site_allocation):
157 # Must be a sliver that was just created, and has not site_allocation
161 all_slice_slivers = self.slivers.all()
162 for site_name in self._site_allocation.keys():
163 desired_allocation = self._site_allocation[site_name]
165 # make a list of the slivers for this site
167 for sliver in all_slice_slivers:
168 if sliver.node.site_deployment.site.name == site_name:
169 slivers.append(sliver)
171 # delete extra slivers
172 while (reset and len(slivers)>0) or (len(slivers) > desired_allocation):
173 sliver = slivers.pop()
175 print "deleting sliver", sliver
178 print "would delete sliver", sliver
181 if (len(slivers) < desired_allocation):
182 site = Site.objects.get(name = site_name)
183 nodes = self.get_node_allocation([site])
186 raise ValueError("no nodes in site %s" % site_name)
188 while (len(slivers) < desired_allocation):
189 # pick the least allocated node
190 nodes = sorted(nodes, key=attrgetter("sliverCount"))
193 sliver = Sliver(name=node.name,
196 image = self.default_image,
197 flavor = self.default_flavor,
198 creator = self.creator,
199 deployment = node.site_deployment.deployment)
200 slivers.append(sliver)
202 print "added sliver", sliver
205 print "would add sliver", sliver
207 node.sliverCount = node.sliverCount + 1
209 def save_users(self, noAct = False):
210 new_users = self._update_users
212 default_role = SliceRole.objects.get(role="default")
214 slice_privs = self.sliceprivileges.all()
215 slice_user_ids = [priv.user.id for priv in slice_privs]
217 for user_id in new_users:
218 if (user_id not in slice_user_ids):
219 priv = SlicePrivilege(slice=self, user=User.objects.get(id=user_id), role=default_role)
223 print "added user id", user_id
225 for priv in slice_privs:
226 if (priv.role.id != default_role.id):
227 # only mess with 'default' users; don't kill an admin
230 if (priv.user.id not in new_users):
234 print "deleted user id", user_id
236 def save_network_ports(self, noAct=False):
237 # First search for any network that already has a filled in 'ports'
238 # field. We'll assume there can only be one, so it must be the right
240 for networkSlice in self.networkslices.all():
241 network = networkSlice.network
242 if (network.owner.id != self.id):
245 network.ports = self._network_ports
250 # Now try a network that is a "NAT", since setting ports on a non-NAT
251 # network doesn't make much sense.
252 for networkSlice in self.networkslices.all():
253 network = networkSlice.network
254 if (network.owner.id != self.id):
256 if network.template.translation=="NAT":
257 network.ports = self._network_ports
262 # uh oh, we didn't find a network
264 raise ValueError("No network was found that ports could be set on")