Welcome to mirror list, hosted at ThFree Co, Russian Federation.

dev.gajim.org/gajim/gajim.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorYann Leboulanger <asterix@lagaule.org>2007-11-03 01:15:23 +0300
committerYann Leboulanger <asterix@lagaule.org>2007-11-03 01:15:23 +0300
commit4b4ababe7ec2b5866225b9499c988771e8d8797d (patch)
treeead35fbdb6ce29a8f221c93a674ad1c787bf1790
parentabf85ddcb4c98f7ea517ff5e7bb1186e9a387c8e (diff)
process all incoming and outgoing queues even if we receive big things (a file). Fixes #3380
-rw-r--r--src/common/xmpp/idlequeue.py12
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()