Commit c0306b47 authored by Georgios Dagkakis's avatar Georgios Dagkakis Committed by Jérome Perrin

broker not to search for operator if the operator is dedicated and already in the machine

parent 7731e8ec
...@@ -116,7 +116,9 @@ class Broker(ObjectInterruption): ...@@ -116,7 +116,9 @@ class Broker(ObjectInterruption):
self.waitForOperator=False self.waitForOperator=False
self.victim.printTrace(self.victim.id, resourceAvailable='(broker)') self.victim.printTrace(self.victim.id, resourceAvailable='(broker)')
# else if the Router is already invoked for allocating purposes wait until a resource is allocated to the victim's operatorPool # else if the Router is already invoked for allocating purposes wait until a resource is allocated to the victim's operatorPool
elif G.Router.invoked and G.Router.allocation: # wait only if there is no current operator
# XXX discuss this
elif G.Router.invoked and G.Router.allocation and not self.victim.currentOperator:
self.waitForOperator=True self.waitForOperator=True
self.victim.printTrace(self.victim.id, waitEvent='(resourceIsAvailable broker)') self.victim.printTrace(self.victim.id, waitEvent='(resourceIsAvailable broker)')
......
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