Add lines to ensure existing queues are closed before starting the ti…

…med pipe test
cropsinsilico · Jan 30, 2019 · a3e9392 · a3e9392
1 parent cbbfb59
commit a3e9392
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/cis_interface/examples/tests/test_timed_pipe.py b/cis_interface/examples/tests/test_timed_pipe.py
@@ -18,6 +18,12 @@ def __init__(self, *args, **kwargs):
         self.env = {'PIPE_MSG_COUNT': '10',
                     'PIPE_MSG_SIZE': '1024'}
         # self.debug_flag = True
+        if self._new_default_comm == 'IPCComm':
+            from cis_interface.communication.IPCComm import ipcrm_queues, ipc_queues
+            qlist = ipc_queues()
+            if qlist:  # pragma: debug
+                print('Existing queues:', qlist)
+                ipcrm_queues()
 
     @property
     def description_prefix(self):