diff --git a/test/ganeti.locking_unittest.py b/test/ganeti.locking_unittest.py index 79c48888ec7d059f3c5d555ffcd412ecf397f5e1..3a77bc0f7ac95c17209e110b8f26401676885c36 100755 --- a/test/ganeti.locking_unittest.py +++ b/test/ganeti.locking_unittest.py @@ -52,6 +52,7 @@ class _ThreadedTestCase(unittest.TestCase): """Test class that supports adding/waiting on threads""" def setUp(self): unittest.TestCase.setUp(self) + self.done = Queue.Queue(0) self.threads = [] def _addThread(self, *args, **kwargs): @@ -76,7 +77,6 @@ class TestPipeCondition(_ThreadedTestCase): _ThreadedTestCase.setUp(self) self.lock = threading.Lock() self.cond = locking._PipeCondition(self.lock) - self.done = Queue.Queue(0) def testAcquireRelease(self): self.assert_(not self.cond._is_owned()) @@ -280,8 +280,6 @@ class TestSharedLock(_ThreadedTestCase): def setUp(self): _ThreadedTestCase.setUp(self) self.sl = locking.SharedLock() - # helper threads use the 'done' queue to tell the master they finished. - self.done = Queue.Queue(0) def testSequenceAndOwnership(self): self.assert_(not self.sl._is_owned()) @@ -725,8 +723,6 @@ class TestSSynchronizedDecorator(_ThreadedTestCase): def setUp(self): _ThreadedTestCase.setUp(self) - # helper threads use the 'done' queue to tell the master they finished. - self.done = Queue.Queue(0) @locking.ssynchronized(_decoratorlock) def _doItExclusive(self): @@ -785,8 +781,6 @@ class TestLockSet(_ThreadedTestCase): def setUp(self): _ThreadedTestCase.setUp(self) self._setUpLS() - # helper threads use the 'done' queue to tell the master they finished. - self.done = Queue.Queue(0) def _setUpLS(self): """Helper to (re)initialize the lock set""" @@ -1138,7 +1132,6 @@ class TestGanetiLockManager(_ThreadedTestCase): self.instances=['i1', 'i2', 'i3'] self.GL = locking.GanetiLockManager(nodes=self.nodes, instances=self.instances) - self.done = Queue.Queue(0) def tearDown(self): # Don't try this at home...