From adbb0cf344d180db3d2eb5a90136a526a42a3213 Mon Sep 17 00:00:00 2001
From: Christophe Geuzaine <cgeuzaine@ulg.ac.be>
Date: Wed, 29 Jan 2014 14:45:05 +0000
Subject: [PATCH] runNonBlockingSubClient()
---
contrib/onelab/python/onelab.py | 11 +++++++----
1 file changed, 7 insertions(+), 4 deletions(-)
diff --git a/contrib/onelab/python/onelab.py b/contrib/onelab/python/onelab.py
index d47dafc048..08f7aebf14 100755
--- a/contrib/onelab/python/onelab.py
+++ b/contrib/onelab/python/onelab.py
@@ -320,7 +320,7 @@ class client :
s = addr.split(':')
self.socket.connect((s[0], int(s[1])))
- def _waitOnSubClients(self):
+ def waitOnSubClients(self):
if not self.socket :
return
while self._numSubClients > 0:
@@ -328,7 +328,7 @@ class client :
if t == self._GMSH_STOP :
self._numSubClients -= 1
- def runSubClient(self, name, command, arguments=''):
+ def runNonBlockingSubClient(self, name, command, arguments=''):
# create command line
if self.action == "check":
cmd = command
@@ -339,7 +339,10 @@ class client :
msg = [name, cmd]
self._send(self._GMSH_CONNECT, '\0'.join(msg))
self._numSubClients +=1
- self._waitOnSubClients() # makes the subclient blocking
+
+ def runSubClient(self, name, command, arguments=''):
+ self.runNonBlockingSubClient(name, command, arguments)
+ self.waitOnSubClients() # makes the subclient blocking
def run(self, name, command, arguments=''):
self.runSubClient(name, command, arguments)
@@ -363,7 +366,7 @@ class client :
# code aster python interpreter does not call the destructor at exit, it is
# necessary to call finalize() epxlicitely
if self.socket :
- self._waitOnSubClients()
+ self.waitOnSubClients()
self._send(self._GMSH_STOP, 'Goodbye!')
self.socket.close()
self.socket = None
--
GitLab