X-Git-Url: http://git.onelab.eu/?p=sface.git;a=blobdiff_plain;f=sface%2Fsfiprocess.py;h=cd24f9a9d870c7e3a1844d96ef422f724aff9e61;hp=d39bd756cfe5b06b40937064eaa8a4ef738f054e;hb=7d7fc902c4b3a8df291292da526018dea66d20fd;hpb=152e4e2934173feeffe201602771cdacf6f7c5af;ds=sidebyside diff --git a/sface/sfiprocess.py b/sface/sfiprocess.py index d39bd75..cd24f9a 100644 --- a/sface/sfiprocess.py +++ b/sface/sfiprocess.py @@ -1,7 +1,9 @@ import os +import time + from PyQt4.QtCore import * -from sface.sficonfig import config +from sface.config import config def find_executable(exec_name): """find the given executable in $PATH""" @@ -23,12 +25,16 @@ class SfiProcess(QObject): self.args << QString(arg) self.exe = find_executable("sfi.py") + if not self.exe: + print "FATAL.. Could not locate binary sfi.py - not much we can do without that" + self.process = QProcess() self.connect(self.process, SIGNAL("finished(int, QProcess::ExitStatus)"), self.processFinished) def processFinished(self): + self.trace_end() self.emit(SIGNAL("finished()")) def __getRSpec(self, mgr): @@ -40,7 +46,7 @@ class SfiProcess(QObject): except: pass args = ["-u", config.getUser(), "-a", config.getAuthority(), - "-r", config.registry(), "-s", mgr, "resources", + "-r", config.getRegistry(), "-s", mgr, "resources", "-o", filename, slice] self.__init_command(args) @@ -48,21 +54,32 @@ class SfiProcess(QObject): return filename def getRSpecFromSM(self): - return self.__getRSpec(config.slicemgr()) + return self.__getRSpec(config.getSlicemgr()) def getRSpecFromAM(self): - return self.__getRSpec(config.aggmgr()) + return self.__getRSpec(config.getAggmgr()) def getRecord(self, hrn): args = ["-u", config.getUser(), "-a", config.getAuthority(), - "-r", config.registry(), "-s", config.slicemgr(), "show", hrn] + "-r", config.getRegistry(), "-s", config.getSlicemgr(), "show", hrn] self.__init_command(args) self.start() def start(self): + self.trace_command() self.process.start(self.exe, self.args) def readOutput(self): if self.process.state() == QProcess.NotRunning: return self.process.readAll() + def trace_command (self): + if config.verbose: + self._trace=time.time() + command = "%s %s" % (self.exe, self.args.join(" ")) + print time.strftime('%M:%S'),'Invoking',command + + def trace_end (self): + if config.verbose: + command = "%s %s" % (self.exe, self.args.join(" ")) + print time.strftime('%M:%S'),"[%.3f s]"%(time.time()-self._trace),command,'Done'