Commit 9aae101d authored by Georgios Dagkakis's avatar Georgios Dagkakis

correction in BatchReassemblyBlocking

parent b8803b97
...@@ -30,9 +30,7 @@ from BatchReassembly import BatchReassembly ...@@ -30,9 +30,7 @@ from BatchReassembly import BatchReassembly
class BatchReassemblyBlocking(BatchReassembly): class BatchReassemblyBlocking(BatchReassembly):
# ======================================================================= # =======================================================================
# This is only for a BatchScrapMachine that is followed by a BatchDecomposition # extend behaviour to send canDispose signal to the correct predecessor
# We consider that since this is in essence one station, the BatchScrapMachine
# should be blocked if the BatchDecomposition is blocked
# ======================================================================= # =======================================================================
def removeEntity(self, entity=None): def removeEntity(self, entity=None):
activeEntity=BatchReassembly.removeEntity(self, entity) activeEntity=BatchReassembly.removeEntity(self, entity)
...@@ -45,7 +43,8 @@ class BatchReassemblyBlocking(BatchReassembly): ...@@ -45,7 +43,8 @@ class BatchReassemblyBlocking(BatchReassembly):
if issubclass(previous.__class__, Queue): if issubclass(previous.__class__, Queue):
if previous.expectedSignals['canDispose']: if previous.expectedSignals['canDispose']:
self.sendSignal(receiver=previous, signal=previous.canDispose, sender=station) self.sendSignal(receiver=previous, signal=previous.canDispose, sender=station)
break break
# continue with further previous stations
else: else:
station=previous station=previous
return activeEntity return activeEntity
......
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