From 8edafbabddb201c7b74726cefe8d70c727d07555 Mon Sep 17 00:00:00 2001 From: mzn Date: Mon, 14 Nov 2005 15:41:37 +0000 Subject: [PATCH] Improve waitNS function for more stable salome launch. --- bin/orbmodule.py | 30 ++++++++++++++++++++++++++++++ bin/runSalome.py | 17 ++++++++++------- 2 files changed, 40 insertions(+), 7 deletions(-) diff --git a/bin/orbmodule.py b/bin/orbmodule.py index fdc254472..9dfad8a2c 100755 --- a/bin/orbmodule.py +++ b/bin/orbmodule.py @@ -141,6 +141,36 @@ class client: if nobj is None: print "%s exists but is not a %s" % (name,typobj) return nobj + def waitNSPID(self, theName, thePID, theTypObj = None): + aCount = 0 + aDelta = 0.5 + anObj = None + print "Searching %s in Naming Service " % theName, + while(1): + try: + aPid, aStatus = os.waitpid(thePID,os.WNOHANG) + except Exception, exc: + raise "Impossible de trouver %s" % theName + aCount += 1 + anObj = self.Resolve(theName) + if anObj: + print " found in %s seconds " % ((aCount-1)*aDelta) + break + else: + sys.stdout.write('+') + sys.stdout.flush() + time.sleep(aDelta) + pass + pass + + if theTypObj is None: + return anObj + + anObject = anObj._narrow(theTypObj) + if anObject is None: + print "%s exists but is not a %s" % (theName,theTypObj) + return anObject + # -------------------------------------------------------------------------- diff --git a/bin/runSalome.py b/bin/runSalome.py index 6e7b0938e..ead9b8375 100755 --- a/bin/runSalome.py +++ b/bin/runSalome.py @@ -249,6 +249,7 @@ class Server: """Generic class for CORBA server launch""" def initArgs(self): + self.PID=None self.CMD=[] self.ARGS=[] if self.args['xterm']: @@ -271,6 +272,7 @@ class Server: print "command = ", command pid = os.spawnvp(os.P_NOWAIT, command[0], command) process_id[pid]=self.CMD + self.PID = pid class InterpServer(Server): @@ -286,6 +288,7 @@ class InterpServer(Server): #print "command = ", command pid = os.spawnvp(os.P_NOWAIT, command[0], command) process_id[pid]=self.CMD + self.PID = pid # --- @@ -513,7 +516,7 @@ def startSalome(args, modules_list, modules_root_dir): if 'registry' not in args['embedded']: myServer=RegistryServer(args) myServer.run() - clt.waitNS("/Registry") + clt.waitNSPID("/Registry",myServer.PID) # # Lancement Catalog Server, @@ -526,7 +529,7 @@ def startSalome(args, modules_list, modules_root_dir): cataServer.setpath(modules_list,modules_root_dir) cataServer.run() import SALOME_ModuleCatalog - clt.waitNS("/Kernel/ModulCatalog",SALOME_ModuleCatalog.ModuleCatalog) + clt.waitNSPID("/Kernel/ModulCatalog",cataServer.PID,SALOME_ModuleCatalog.ModuleCatalog) # # Lancement SalomeDS Server, @@ -538,7 +541,7 @@ def startSalome(args, modules_list, modules_root_dir): print "RunStudy" myServer=SalomeDSServer(args) myServer.run() - clt.waitNS("/myStudyManager") + clt.waitNSPID("/myStudyManager",myServer.PID) # # Lancement ContainerManagerServer @@ -567,7 +570,7 @@ def startSalome(args, modules_list, modules_root_dir): if 'cppContainer' in args['standalone']: myServer=ContainerCPPServer(args) myServer.run() - clt.waitNS("/Containers/" + theComputer + "/FactoryServer") + clt.waitNSPID("/Containers/" + theComputer + "/FactoryServer",myServer.PID) # # Lancement Container Python local, @@ -578,7 +581,7 @@ def startSalome(args, modules_list, modules_root_dir): if 'pyContainer' in args['standalone']: myServer=ContainerPYServer(args) myServer.run() - clt.waitNS("/Containers/" + theComputer + "/FactoryServerPy") + clt.waitNSPID("/Containers/" + theComputer + "/FactoryServerPy",myServer.PID) # # Lancement Container Supervision local, @@ -589,7 +592,7 @@ def startSalome(args, modules_list, modules_root_dir): if 'supervContainer' in args['standalone']: myServer=ContainerSUPERVServer(args) myServer.run() - clt.waitNS("/Containers/" + theComputer + "/SuperVisionContainer") + clt.waitNSPID("/Containers/" + theComputer + "/SuperVisionContainer",myServer.PID) # # Lancement Session Server @@ -604,7 +607,7 @@ def startSalome(args, modules_list, modules_root_dir): import SALOME import SALOME_Session_idl - session=clt.waitNS("/Kernel/Session",SALOME.Session) + session=clt.waitNSPID("/Kernel/Session",mySessionServ.PID,SALOME.Session) end_time = os.times() print -- 2.39.2