X-Git-Url: http://git.onelab.eu/?p=sfa-gui.git;a=blobdiff_plain;f=SfaData.py;h=b6d73317b05f0c8790caef57f67b9483168b17c0;hp=343ad0e45df44823533fb88e1d0dba2e1f873eee;hb=e15ce3036c57ffce83734d8f9912acff5ce2e82a;hpb=9b1e2b7e901d9a7edc707916c52efe808cae6cfc diff --git a/SfaData.py b/SfaData.py index 343ad0e..b6d7331 100644 --- a/SfaData.py +++ b/SfaData.py @@ -1,11 +1,12 @@ import os -from subprocess import call +import re +from subprocess import * from sfa.util.rspecHelper import RSpec class SfaData: authority = "plc.princeton" user = "plc.princeton.acb" - slice = "plc.princeton.iias" + slice = "plc.princeton.sapan" def __init__(self): self.registry = None @@ -30,8 +31,26 @@ class SfaData: def setSlice(self, slice): SfaData.slice = slice - def getRecord(self): - pass + def getRecord(self, hrn): + text = Popen(["sfi.py", "-u", self.getUser(), "-a", + self.getAuthority(), "-r", self.registry, + "-s", self.slicemgr, "show", hrn], + stdout=PIPE).communicate()[0] + return text + + def listChildren(self, hrn): + children = [] + text = Popen(["sfi.py", "-u", self.getUser(), "-a", + self.getAuthority(), "-r", self.registry, + "-s", self.slicemgr, "list", hrn], + stdout=PIPE).communicate()[0] + lines = text.split('\n') + for line in lines: + if line: + (hrn, kind) = line.split() + children.append((hrn, kind)) + + return children def getRSpec(self): slice = self.getSlice() @@ -54,37 +73,61 @@ class SfaData: "-r", self.registry, "-s", self.slicemgr, "create", slice, filename]) -class ViniData(SfaData): +class PlanetLabData(SfaData): def __init__(self): SfaData.__init__(self) self.registry = "http://www.planet-lab.org:12345" - self.slicemgr = "http://www.vini-veritas.net:12346" + self.slicemgr = "http://www.planet-lab.org:12346" + self.rspec = None - def getRSpec(self): + def refreshRSpec(self): xml = SfaData.getRSpec(self) - return RSpec(xml) + self.rspec = RSpec(xml) - def applyRSpec(self, rspec): - xml = rspec.toxml() + def getRSpec(self): + if self.rspec is None: + self.refreshRSpec() + return self.rspec + + def applyRSpec(self): + xml = self.rspec.toxml() SfaData.applyRSpec(self, xml) -class PlanetLabData(SfaData): +class PLEData(PlanetLabData): def __init__(self): - SfaData.__init__(self) - self.registry = "http://www.planet-lab.org:12345" - self.slicemgr = "http://www.planet-lab.org:12346" + PlanetLabData.__init__(self) + self.slicemgr = "http://www.planet-lab.eu:12346" - def getRSpec(self): - xml = SfaData.getRSpec(self) - return RSpec(xml) +class PLJData(PlanetLabData): + def __init__(self): + PlanetLabData.__init__(self) + self.slicemgr = "http://www.planet-lab.jp:12346" - def applyRSpec(self, rspec): - xml = rspec.toxml() - SfaData.applyRSpec(self, xml) +class ViniData(PlanetLabData): + def __init__(self): + PlanetLabData.__init__(self) + self.slicemgr = "http://www.vini-veritas.net:12346" + +class GpENIData(PlanetLabData): + def __init__(self): + PlanetLabData.__init__(self) + self.slicemgr = "http://198.248.241.100:12346" class OpenCirrusData(SfaData): def __init__(self): SfaData.__init__(self) - self.registry = "http://www.planet-lab.org:12345" - self.slicemgr = "http://www.planet-lab.org:12346" + self.registry = "http://198.55.37.29:12345" + self.slicemgr = "http://198.55.37.29:12346" + + def refreshRSpec(self): + xml = SfaData.getRSpec(self) + self.rspec = xml + def getRSpec(self): + if self.rspec is None: + self.refreshRSpec() + return self.rspec + + def applyRSpec(self): + xml = self.rspec + SfaData.applyRSpec(self, xml)