Modify module paths
authorAndy Bavier <acb@cs.princeton.edu>
Thu, 28 Jan 2010 16:22:00 +0000 (16:22 +0000)
committerAndy Bavier <acb@cs.princeton.edu>
Thu, 28 Jan 2010 16:22:00 +0000 (16:22 +0000)
sfa/managers/aggregate_manager_vini.py
sfa/managers/vini/rspec.py [deleted file]
sfa/managers/vini/utils.py

index 418f034..6e96804 100644 (file)
@@ -3,7 +3,7 @@ from sfa.util.namespace import *
 from sfa.server.registry import Registries
 from sfa.plc.nodes import *
 from sfa.plc.api import *
-from sfa.rspecs.aggregates.vini.utils import *
+from sfa.managers.vini.utils import *
 import sys
 
 """
diff --git a/sfa/managers/vini/rspec.py b/sfa/managers/vini/rspec.py
deleted file mode 100644 (file)
index d391a71..0000000
+++ /dev/null
@@ -1,57 +0,0 @@
-from sfa.util.rspec import RSpec
-from sfa.rspecs.aggregates.vini.utils import *
-import sys
-
-SFA_VINI_DEFAULT_RSPEC = '/etc/sfa/vini.rspec'
-
-class ViniRSpec(RSpec):
-    def __init__(self, xml = None, xsd = None, NSURL = None):
-        RSpec.__init__(self, xml, xsd, NSURL)
-        if not xml:
-            self.parseFile(SFA_VINI_DEFAULT_RSPEC)
-        
-    def updateCapacity(self, topo):
-        d = self.toDict()
-        sitespecs = []
-        sitelinkspecs = []
-        for site in topo.getSites():
-            if not site.public:
-                continue
-            sdict = {}
-            nodespecs = []
-            for node in site.get_sitenodes(topo.nodes):
-                if not node.tag:
-                    continue
-                ndict = {}
-                ndict['hostname'] = [node.hostname]
-                ndict['name'] = node.tag
-                ndict['kbps'] = [int(node.bps/1000)] 
-                nodespecs.append(ndict)
-            sdict['NodeSpec'] = nodespecs
-            sdict['name'] = site.name
-            sitespecs.append(sdict)
-            
-            for sl in site.links:
-                if sl.end1 == site:
-                    sldict = {}
-                    sldict['endpoint'] = [sl.end1.name, sl.end2.name]
-                    sldict['kbps'] = [int(sl.bps/1000)]
-                    sitelinkspecs.append(sldict)
-                    
-        d['RSpec']['Capacity'][0]['NetSpec'][0]['SiteSpec'] = sitespecs
-        d['RSpec']['Capacity'][0]['NetSpec'][0]['SiteLinkSpec'] = sitelinkspecs
-        self.parseDict(d)
-
-
-    def updateRequest(self, slice, topo):
-        linkspecs = []
-        for link in topo.nodelinks:
-            edict = {}
-            edict['endpoint'] = [link.end1.tag, link.end2.tag]
-            edict['kbps'] = [int(link.bps/1000)]
-            linkspecs.append(edict)
-
-        d = self.toDict()
-        d['RSpec']['Request'][0]['NetSpec'][0]['LinkSpec'] = linkspecs
-        d['RSpec']['Request'][0]['NetSpec'][0]['name'] = slice.hrn
-        self.parseDict(d)
index 6078125..b0d7e51 100644 (file)
@@ -2,7 +2,7 @@ from __future__ import with_statement
 import re
 import socket
 from sfa.util.faults import *
-from sfa.rspecs.aggregates.vini.topology import *
+from sfa.managers.vini.topology import PhysicalLinks
 from xmlbuilder import XMLBuilder
 from lxml import etree
 import sys