diff options
author | Yann Leboulanger <asterix@lagaule.org> | 2007-11-03 01:15:23 +0300 |
---|---|---|
committer | Yann Leboulanger <asterix@lagaule.org> | 2007-11-03 01:15:23 +0300 |
commit | 4b4ababe7ec2b5866225b9499c988771e8d8797d (patch) | |
tree | ead35fbdb6ce29a8f221c93a674ad1c787bf1790 | |
parent | abf85ddcb4c98f7ea517ff5e7bb1186e9a387c8e (diff) |
process all incoming and outgoing queues even if we receive big things (a file). Fixes #3380
-rw-r--r-- | src/common/xmpp/idlequeue.py | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/common/xmpp/idlequeue.py b/src/common/xmpp/idlequeue.py index db0c575bd..efbf8929e 100644 --- a/src/common/xmpp/idlequeue.py +++ b/src/common/xmpp/idlequeue.py @@ -206,13 +206,13 @@ class SelectIdleQueue(IdleQueue): if e[0] != 4: # interrupt raise for fd in waiting_descriptors[0]: - self.queue.get(fd).pollin() - self.check_time_events() - return True + q = self.queue.get(fd) + if q: + q.pollin() for fd in waiting_descriptors[1]: - self.queue.get(fd).pollout() - self.check_time_events() - return True + q = self.queue.get(fd) + if q: + q.pollout() for fd in waiting_descriptors[2]: self.queue.get(fd).pollend() self.check_time_events() |