new CoreObject method initialSignalReceiver. Invoked as the generator of the...

new CoreObject method initialSignalReceiver. Invoked as the generator of the objects starts and control if there is WIP assigned to them and signals receivers

dream/simulation/BatchDecomposition.py

@@ -75,6 +75,8 @@ class BatchDecomposition(CoreObject):
     #     the run method of the BatchDecomposition
     # =======================================================================
     def run(self):
+        # check if there is WIP and signal receiver
+        self.initialSignalReceiver()
         while 1:
             # wait for an event or an interruption
             while 1:

dream/simulation/BatchReassembly.py

@@ -73,7 +73,8 @@ class BatchReassembly(CoreObject):
     # =======================================================================
     def run(self):
         activeObjectQueue=self.getActiveObjectQueue()
-        
+        # check if there is WIP and signal receiver
+        self.initialSignalReceiver()
         while 1:
             while 1:
                 yield waitevent, self, [self.isRequested, self.interruptionStart]

dream/simulation/CoreObject.py

@@ -140,6 +140,15 @@ class CoreObject(Process):
     def defineRouting(self, predecessorList=[], successorList=[]):
         self.next=successorList
         self.previous=predecessorList
+        
+    # =======================================================================
+    # checks if there is anything set as WIP at the begging of the simulation
+    # and sends an event to initialize the simulation
+    # =======================================================================
+    def initialSignalReceiver(self):
+        activeObject=self.getActiveObject()
+        if self.haveToDispose():
+            self.signalReceiver()
     
     # =======================================================================
     # removes an Entity from the Object the Entity to be removed is passed

dream/simulation/Machine.py

@@ -209,6 +209,8 @@ class Machine(CoreObject):
     # the main process of the machine
     # =======================================================================
     def run(self):
+        # check if there is WIP and signal receiver
+        self.initialSignalReceiver()
         # execute all through simulation time
         while 1:
             # waitEvent isRequested or interruption start 

dream/simulation/Queue.py

@@ -88,7 +88,8 @@ class Queue(CoreObject):
     #===========================================================================
     def run(self):  
         activeObjectQueue=self.getActiveObjectQueue()
-        
+        # check if there is WIP and signal receiver
+        self.initialSignalReceiver()
         while 1:  
             # wait until the Queue can accept an entity and one predecessor requests it
             yield waitevent, self, [self.isRequested,self.canDispose]