From: Andy Bavier Date: Thu, 28 Jan 2010 16:22:00 +0000 (+0000) Subject: Modify module paths X-Git-Tag: sfa-0.9-11~173 X-Git-Url: http://git.onelab.eu/?a=commitdiff_plain;h=6049cf235f117264b115b37c25243d51d0b8b786;p=sfa.git Modify module paths --- diff --git a/sfa/managers/aggregate_manager_vini.py b/sfa/managers/aggregate_manager_vini.py index 418f034f..6e96804a 100644 --- a/sfa/managers/aggregate_manager_vini.py +++ b/sfa/managers/aggregate_manager_vini.py @@ -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 index d391a716..00000000 --- a/sfa/managers/vini/rspec.py +++ /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) diff --git a/sfa/managers/vini/utils.py b/sfa/managers/vini/utils.py index 60781255..b0d7e51e 100644 --- a/sfa/managers/vini/utils.py +++ b/sfa/managers/vini/utils.py @@ -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