Commit 3d5f1aa3 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

CI/CD pipeline - OFC'22

parent e942151f

src/common/tools/mutex_queues/MutexQueues.py

+2 −0
Original line number Diff line number Diff line
@@ -55,6 +55,8 @@ class MutexQueues: 
                self.mutex_queues[queue_name_b] = self.mutex_queues[queue_name_a]

            elif queue_name_b in self.mutex_queues and queue_name_a not in self.mutex_queues:

                self.mutex_queues[queue_name_a] = self.mutex_queues[queue_name_b]

            elif queue_name_b not in self.mutex_queues and queue_name_a not in self.mutex_queues:

                self.mutex_queues[queue_name_b] = self.mutex_queues.setdefault(queue_name_a, Queue())



    def wait_my_turn(self, queue_name : str) -> None:

        LOGGER.warning('[wait_my_turn] begin queue_name={:s}'.format(str(queue_name)))