Commit 608a7b46 authored by Georgios Dagkakis's avatar Georgios Dagkakis

reset the flag correctly

parent 45ef0893
...@@ -97,6 +97,7 @@ class BatchReassembly(CoreObject): ...@@ -97,6 +97,7 @@ class BatchReassembly(CoreObject):
requestingObject=self.isRequested.value requestingObject=self.isRequested.value
assert requestingObject==self.giver, 'the giver is not the requestingObject' assert requestingObject==self.giver, 'the giver is not the requestingObject'
self.isRequested=self.env.event() self.isRequested=self.env.event()
self.isProcessingInitialWIP=False
break break
if not self.isProcessingInitialWIP: # if we are in the state of having initial wip no need to take an Entity if not self.isProcessingInitialWIP: # if we are in the state of having initial wip no need to take an Entity
...@@ -113,6 +114,7 @@ class BatchReassembly(CoreObject): ...@@ -113,6 +114,7 @@ class BatchReassembly(CoreObject):
if self.currentEntity.type=='SubBatch': if self.currentEntity.type=='SubBatch':
yield self.env.timeout(self.calculateProcessingTime()) yield self.env.timeout(self.calculateProcessingTime())
self.reassemble() self.reassemble()
self.isProcessingInitialWIP=False
if not self.signalReceiver(): if not self.signalReceiver():
while 1: while 1:
receivedEvent=yield self.canDispose | self.interruptionStart receivedEvent=yield self.canDispose | self.interruptionStart
......
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