objects have to recreate signal in every replications. TODO check why and which others need it

dream/simulation/CoreObject.py

@@ -132,6 +132,11 @@ class CoreObject(Process):
         # TODO, think what to do in multiple runs
         # TODO, this should be also updated in Globals.setWIP (in case we have initial wip)
         self.wipStatList=[[0,0]]
+        # signalizing an event that activates the generator
+        self.isRequested=SimEvent('isRequested')
+        self.canDispose=SimEvent('canDispose')
+        self.interruptionEnd=SimEvent('interruptionEnd')
+        self.interruptionStart=SimEvent('interruptionStart')
 
     # =======================================================================
     #                the main process of the core object 

dream/simulation/Machine.py

@@ -210,12 +210,18 @@ class Machine(CoreObject):
         self.breakTime=0
         # flag notifying that there is operator assigned to the actievObject
         self.assignedOperator=True
+        
+        self.brokerIsSet=SimEvent('brokerIsSet')
+        # this event is generated every time an operator is requested by machine for Load operation type.
+        #     if the machine has not succeeded in getting an entity due to the resource absence 
+        #     and waits for the next event to get the entity, 
+        #     then it must be signalled that the operator is now available
+        self.loadOperatorAvailable=SimEvent('loadOperatorAvailable')
     
     # =======================================================================
     # 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:

dream/simulation/Queue.py

@@ -84,6 +84,9 @@ class Queue(CoreObject):
         CoreObject.initialize(self)
         # initialise the internal Queue (type Resource) of the Queue object 
         self.Res=Resource(self.capacity)   
+        # event used by router
+        self.loadOperatorAvailable=SimEvent('loadOperatorAvailable')
+
     
     #===========================================================================
     # run method of the queue

dream/simulation/Source.py

@@ -55,7 +55,6 @@ class EntityGenerator(Process):
     # the generator of the EntitiesGenerator
     #===========================================================================
     def run(self): 
-        print '1'
         while 1:
             entity=self.victim.createEntity()                       # create the Entity object and assign its name
             entity.creationTime=now()                               # assign the current simulation time as the Entity's creation time