diff options
Diffstat (limited to 'python/qpid/selector.py')
| -rw-r--r-- | python/qpid/selector.py | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/python/qpid/selector.py b/python/qpid/selector.py index 05b8d3a203..710f8f0689 100644 --- a/python/qpid/selector.py +++ b/python/qpid/selector.py @@ -17,7 +17,7 @@ # under the License. # import atexit, os, time -from select import select +from compat import select, set from threading import Thread, Lock class Acceptor: @@ -84,10 +84,7 @@ class Selector: self.thread = None def wakeup(self): - while True: - select([], [self.wakeup_fd], []) - if os.write(self.wakeup_fd, "\0") > 0: - break + os.write(self.wakeup_fd, "\0") def register(self, selectable): self.selectables.add(selectable) |