Commit 6e97a3af authored by Georgios Dagkakis's avatar Georgios Dagkakis

servers do not need to perform initialSignal to receiver since they need to...

servers do not need to perform initialSignal to receiver since they need to process first - even for 0 time
parent 2a6c715a
......@@ -149,8 +149,6 @@ class Assembly(CoreObject):
#===========================================================================
def run(self):
activeObjectQueue=self.getActiveObjectQueue()
# check if there is WIP and signal receiver
self.initialSignalReceiver()
while 1:
self.printTrace(self.id, waitEvent='')
# wait until the Queue can accept an entity and one predecessor requests it
......
......@@ -82,8 +82,6 @@ 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:
......
......@@ -79,8 +79,6 @@ class BatchReassembly(CoreObject):
# =======================================================================
def run(self):
activeObjectQueue=self.getActiveObjectQueue()
# check if there is WIP and signal receiver
self.initialSignalReceiver()
while 1:
while 1:
self.expectedSignals['isRequested']=1
......
......@@ -96,8 +96,6 @@ class Conveyer(CoreObject):
#these are just for the first Entity
# activate(self.conveyerMover,self.conveyerMover.run())
self.env.process(self.conveyerMover.run())
# check if there is WIP and signal receiver
self.initialSignalReceiver()
while 1:
#calculate the time to reach end. If this is greater than 0 (we did not already have an entity at the end)
#set it as the timeToWait of the conveyerMover and raise call=true so that it will be triggered
......
......@@ -121,8 +121,6 @@ class Dismantle(CoreObject):
#===========================================================================
def run(self):
activeObjectQueue=self.getActiveObjectQueue()
# check if there is WIP and signal receiver
self.initialSignalReceiver()
while 1:
# self.printTrace(self.id, waitEvent='(frame)')
# wait until the Queue can accept an entity and one predecessor requests it
......
......@@ -563,8 +563,8 @@ class Machine(CoreObject):
# the main process of the machine
# =======================================================================
def run(self):
# check if there is WIP and signal receiver
self.initialSignalReceiver()
# request for allocation if needed
self.initialAllocationRequest()
# execute all through simulation time
while 1:
# waitEvent isRequested /interruptionEnd/loadOperatorAvailable
......
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