Commit 2a61b6ec authored by Georgios Dagkakis's avatar Georgios Dagkakis

correction in BatchDecomposition run

parent c983514e
...@@ -138,13 +138,11 @@ class BatchDecomposition(CoreObject): ...@@ -138,13 +138,11 @@ class BatchDecomposition(CoreObject):
# TODO: add failure control # TODO: add failure control
# as long as there are sub-Batches in the internal Resource # as long as there are sub-Batches in the internal Resource
numberOfSubBatches=int(len(self.getActiveObjectQueue())) while len(self.getActiveObjectQueue()):
for i in range(numberOfSubBatches): if len(self.getActiveObjectQueue()) == 1 and self.next[0].isRequested.triggered:
# added here temporarily, it is supposed to break when i==numberOfSubBatches
if not self.getActiveObjectQueue():
break break
# if the loop is run for the first time (i=0) # if the entity was just obtained
if i==0: if self.timeLastEntityEntered == self.env.now:
# try to signal the receiver # try to signal the receiver
signaling=self.signalReceiver() signaling=self.signalReceiver()
if not signaling: if not signaling:
......
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