Commit ff845175 authored by Georgios Dagkakis's avatar Georgios Dagkakis

Queue to signalGiver in a more robust way

parent 0b6d121c
...@@ -96,6 +96,7 @@ class Queue(CoreObject): ...@@ -96,6 +96,7 @@ class Queue(CoreObject):
# run method of the queue # run method of the queue
#=========================================================================== #===========================================================================
def run(self): def run(self):
activeObjectQueue=self.Res.users activeObjectQueue=self.Res.users
# check if there is WIP and signal receiver # check if there is WIP and signal receiver
self.initialSignalReceiver() self.initialSignalReceiver()
...@@ -130,12 +131,12 @@ class Queue(CoreObject): ...@@ -130,12 +131,12 @@ class Queue(CoreObject):
if self.haveToDispose(): if self.haveToDispose():
if self.receiver: if self.receiver:
if not self.receiver.entryIsAssignedTo(): if not self.receiver.entryIsAssignedTo():
# try to signal receiver. In case fo failure signal giver (for synchronization issues) # try to signal receiver. In case of failure signal giver (for synchronization issues)
if not self.signalReceiver(): if not self.signalReceiver():
self.signalGiver() self.signalGiver()
continue continue
if not self.signalReceiver(): self.signalReceiver()
# try to signal receiver. In case fo failure signal giver (for synchronization issues) # signal the giver (for synchronization issues)
self.signalGiver() self.signalGiver()
# ======================================================================= # =======================================================================
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment