self.process.setEnvironment(env)
self.connect(self.process, SIGNAL("finished(int, QProcess::ExitStatus)"),
self.processFinished)
-
+
self.xmlrpctracker = XmlrpcTracker()
- # in case self.output is read by the XmlrpcTracker before any
- # readyReadStandardOutput signal
- self.output = ''
+
+ # holds aggregate output from processStandardOutput(); used by xmlrpc
+ # tracker.
+ self.output = ""
self.connect(self.process, SIGNAL("readyReadStandardOutput()"),
self.processStandardOutput)
def processStandardOutput(self):
output = self.process.readAllStandardOutput()
+ self.output = self.output + output
if config.debug:
print output
# def getRSpecFromAM(self):
# return self.__getRSpec(config.getAggmgr())
- def getRecord(self, hrn):
- args = ["-u", config.getUser(), "-a", config.getAuthority(),
+ def getRecord(self, hrn, filename=None):
+ args = ["-u", config.getUser(), "-a", config.getAuthority(),
"-r", config.getRegistry(), "-s", config.getSlicemgr(), "show", hrn]
+ if filename:
+ args.append("-o")
+ args.append(filename)
self.__init_command(args)
self.start()
def applyRSpec(self, rspec):
filename = config.getSliceRSpecFile() + "_new"
rspec.save(filename)
- args = ["-u", config.getUser(), "-a", config.getAuthority(),
- "-r", config.getRegistry(), "-s", config.getSlicemgr(), "create",
+ args = ["-u", config.getUser(), "-a", config.getAuthority(),
+ "-r", config.getRegistry(), "-s", config.getSlicemgr(), "create",
config.getSlice(), filename]
self.__init_command(args)
self.start()
return filename
+ def updateRecord(self, filename):
+ args = ["-u", config.getUser(), "-a", config.getAuthority(),
+ "-r", config.getRegistry(), "-s", config.getSlicemgr(), "update", filename]
+ self.__init_command(args)
+ self.start()
+
+ def renewSlivers(self, expiration):
+ args = ["-u", config.getUser(), "-a", config.getAuthority(),
+ "-r", config.getRegistry(), "-s", config.getSlicemgr(), "renew",
+ config.getSlice(), expiration]
+ self.__init_command(args)
+ self.start()
+
def start(self):
+ self.output = ""
self.trace_command()
self.process.start(self.exe, self.args)