From: Andy Bavier <acb@cs.princeton.edu>
Date: Wed, 19 Aug 2009 20:59:13 +0000 (+0000)
Subject: Account for already allocated bandwidth in Capacity
X-Git-Tag: sfa-0.9-1~58
X-Git-Url: http://git.onelab.eu/?a=commitdiff_plain;h=2258863ad35e19db87c64e59cf5c544e1f1fc2b7;p=sfa.git

Account for already allocated bandwidth in Capacity
---

diff --git a/sfa/rspecs/aggregates/vini/rspec.py b/sfa/rspecs/aggregates/vini/rspec.py
index 3076219c..aae96b3f 100644
--- a/sfa/rspecs/aggregates/vini/rspec.py
+++ b/sfa/rspecs/aggregates/vini/rspec.py
@@ -25,7 +25,7 @@ class ViniRspec(Rspec):
                 ndict = {}
                 ndict['hostname'] = [node.hostname]
                 ndict['name'] = node.tag
-                ndict['bw'] = ['999Mbit']
+                ndict['bw'] = [format_tc_rate(node.bps)] 
                 nodespecs.append(ndict)
             sdict['NodeSpec'] = nodespecs
             sdict['name'] = site.name
@@ -35,7 +35,7 @@ class ViniRspec(Rspec):
                 if sl.site1 == site:
                     sldict = {}
                     sldict['endpoint'] = [sl.site1.name, sl.site2.name]
-                    sldict['bw'] = [str(sl.availMbps) + "Mbit"]
+                    sldict['bw'] = [format_tc_rate(sl.bps)]
                     sitelinkspecs.append(sldict)
                     
         d['Rspec']['Capacity'][0]['NetSpec'][0]['SiteSpec'] = sitespecs
diff --git a/sfa/rspecs/aggregates/vini/utils.py b/sfa/rspecs/aggregates/vini/utils.py
index 8250e840..c3a057f4 100644
--- a/sfa/rspecs/aggregates/vini/utils.py
+++ b/sfa/rspecs/aggregates/vini/utils.py
@@ -48,14 +48,29 @@ def get_tc_rate(s):
     else:
         return -1
 
+def format_tc_rate(rate):
+    """
+    Formats a bits/second rate into a tc rate string
+    """
+
+    if rate >= 1000000000 and (rate % 1000000000) == 0:
+        return "%.0fgbit" % (rate / 1000000000.)
+    elif rate >= 1000000 and (rate % 1000000) == 0:
+        return "%.0fmbit" % (rate / 1000000.)
+    elif rate >= 1000:
+        return "%.0fkbit" % (rate / 1000.)
+    else:
+        return "%.0fbit" % rate
+
 
 class Node:
-    def __init__(self, node):
+    def __init__(self, node, mbps = 1000):
         self.id = node['node_id']
         self.hostname = node['hostname']
         self.shortname = self.hostname.replace('.vini-veritas.net', '')
         self.site_id = node['site_id']
         self.ipaddr = socket.gethostbyname(self.hostname)
+        self.bps = mbps * 1000000
         self.links = []
 
     def get_link_id(self, remote):
@@ -106,14 +121,22 @@ class Node:
             self.tag = s.tag + index
         else:
             self.tag = None
-        
+
+    # Assumes there is at most one SiteLink between two sites
+    def get_sitelink(self, node, sites):
+        site1 = sites[self.site_id]
+        site2 = sites[node.site_id]
+        sl = site1.sitelinks.intersection(site2.sitelinks)
+        if len(sl):
+            return sl.pop()
+        return None
+    
 
 class SiteLink:
     def __init__(self, site1, site2, mbps = 1000):
         self.site1 = site1
         self.site2 = site2
-        self.totalMbps = mbps
-        self.availMbps = mbps
+        self.bps = mbps * 1000000
         
         site1.add_sitelink(self)
         site2.add_sitelink(self)
@@ -126,7 +149,7 @@ class Site:
         self.name = site['abbreviated_name']
         self.tag = site['login_base']
         self.public = site['is_public']
-        self.sitelinks = []
+        self.sitelinks = set()
 
     def get_sitenodes(self, nodes):
         n = []
@@ -135,7 +158,7 @@ class Site:
         return n
     
     def add_sitelink(self, link):
-        self.sitelinks.append(link)
+        self.sitelinks.add(link)
     
     
 class Slice:
@@ -362,8 +385,24 @@ def get_topology(api):
     
     for (s1, s2) in PhysicalLinks:
         SiteLink(sites[s1], sites[s2])
-
+        
     for id in nodes:
         nodes[id].add_tag(sites)
         
+    for t in tags:
+        tag = tags[t]
+        if tag.tagname == 'topo_rspec':
+            node1 = nodes[tag.node_id]
+            l = eval(tag.value)
+            for (id, realip, bw, lvip, rvip, vnet) in l:
+                allocbps = get_tc_rate(bw)
+                node1.bps -= allocbps
+                try:
+                    node2 = nodes[id]
+                    if node1.id < node2.id:
+                        sl = node1.get_sitelink(node2, sites)
+                        sl.bps -= allocbps
+                except:
+                    pass
+        
     return (sites, nodes, tags)