Messages may need to stay in the controller for considerable

amount of time. Don't use a timeout waiting for the controller response.
Example where this happens is intercepted flows.
This commit is contained in:
Henrik Nordstrom 2011-02-03 23:28:24 +01:00
parent 7924f07971
commit 2f813fa748
1 changed files with 1 additions and 1 deletions

View File

@ -31,7 +31,7 @@ class Msg:
self.acked = False self.acked = False
try: try:
masterq.put(self, timeout=3) masterq.put(self, timeout=3)
return self.q.get(timeout=3) return self.q.get()
except (Queue.Empty, Queue.Full): except (Queue.Empty, Queue.Full):
return None return None