|
@@ -56,7 +56,7 @@ class TestMemorySegmentBuilder(unittest.TestCase):
|
|
|
|
|
|
self._builder_thread.start()
|
|
self._builder_thread.start()
|
|
|
|
|
|
-
|
|
+
|
|
|
|
|
|
with self._builder_cv:
|
|
with self._builder_cv:
|
|
with self._builder_lock:
|
|
with self._builder_lock:
|
|
@@ -69,7 +69,7 @@ class TestMemorySegmentBuilder(unittest.TestCase):
|
|
self.assertFalse(self._builder_thread.isAlive())
|
|
self.assertFalse(self._builder_thread.isAlive())
|
|
|
|
|
|
|
|
|
|
-
|
|
+
|
|
with self._builder_lock:
|
|
with self._builder_lock:
|
|
self.assertEqual(len(self._builder_command_queue), 0)
|
|
self.assertEqual(len(self._builder_command_queue), 0)
|
|
self.assertEqual(len(self._builder_response_queue), 1)
|
|
self.assertEqual(len(self._builder_response_queue), 1)
|