From 4bbc8dabfd217f70cd085702f15075a92cdb8e42 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Wed, 4 Aug 2010 15:46:20 +0000 Subject: Fix race conditions in brokertest.py and cluster_tests.py. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@982309 13f79535-47bb-0310-9956-ffa450edef68 --- python/qpid/brokertest.py | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 deletions(-) (limited to 'python') diff --git a/python/qpid/brokertest.py b/python/qpid/brokertest.py index a241c8b528..19acfd76ca 100644 --- a/python/qpid/brokertest.py +++ b/python/qpid/brokertest.py @@ -148,6 +148,7 @@ class Popen(popen2.Popen3): drain - if true (default) drain stdout/stderr to files. """ self._clean = False + self._clean_lock = Lock() assert find_exe(cmd[0]), "executable not found: "+cmd[0] if type(cmd) is type(""): cmd = [cmd] # Make it a list. self.cmd = [ str(x) for x in cmd ] @@ -174,12 +175,15 @@ class Popen(popen2.Popen3): def _cleanup(self): """Close pipes to sub-process""" - if self._clean: return - self._clean = True - self.stdin.close() - self.drain() # Drain output pipes. - self.stdout.thread.join() # Drain thread closes pipe. - self.stderr.thread.join() + self._clean_lock.acquire() + try: + if self._clean: return + self._clean = True + self.stdin.close() + self.drain() # Drain output pipes. + self.stdout.thread.join() # Drain thread closes pipe. + self.stderr.thread.join() + finally: self._clean_lock.release() def unexpected(self,msg): self._cleanup() -- cgit v1.2.1