X-Git-Url: http://git.onelab.eu/?p=sface.git;a=blobdiff_plain;f=sface%2Fsfiprocess.py;h=8bb6627973f6e5bee11c45b16a0a034a7adeb8a1;hp=61018895a1daa8253aeeb65910900ba737d3803d;hb=1dbdb55c8d56e3c82047dc29a6789183f76d07a7;hpb=154bcc2afda6ff1d2889f8d6b120becbedb3b707 diff --git a/sface/sfiprocess.py b/sface/sfiprocess.py index 6101889..8bb6627 100644 --- a/sface/sfiprocess.py +++ b/sface/sfiprocess.py @@ -5,6 +5,7 @@ import time from PyQt4.QtCore import * from sface.config import config +from sface.xmlrpcwindow import XmlrpcTracker def find_executable(exec_name): """find the given executable in $PATH""" @@ -20,12 +21,28 @@ class SfiProcess(QObject): def __init__(self, parent=None): QObject.__init__(self, parent) + env = QProcess.systemEnvironment() + env << "PYTHONPATH=%s" % ":".join(sys.path) self.process = QProcess() + 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 = '' + + self.connect(self.process, SIGNAL("readyReadStandardOutput()"), + self.processStandardOutput) + self.connect(self.process, SIGNAL("readyReadStandardError()"), + self.processStandardError) def __init_command(self, args): self.args = QStringList() + if config.debug: + # this shows xmlrpc conversation, see sfi.py docs. + self.args << QString('-D') for arg in args: self.args << QString(arg) @@ -36,6 +53,14 @@ class SfiProcess(QObject): def isRunning(self): return self.process.state() != QProcess.NotRunning + def processStandardOutput(self): + output = self.process.readAllStandardOutput() + if config.debug: + print output + + def processStandardError(self): + print self.process.readAllStandardError() + def processFinished(self): if self.process.exitStatus() == QProcess.CrashExit: print self.readOutput() @@ -112,3 +137,5 @@ class SfiProcess(QObject): if config.verbose: command = "%s %s" % (self.exe, self.args.join(" ")) print time.strftime('%M:%S'),"[%.3f s]"%(time.time()-self._trace),command,'Done' + self.xmlrpctracker.getAndPrint(self.output) +