You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2009/10/11 18:58:34 UTC
svn commit: r824107 - /qpid/trunk/qpid/python/qpid/selector.py
Author: rhs
Date: Sun Oct 11 16:58:34 2009
New Revision: 824107
URL: http://svn.apache.org/viewvc?rev=824107&view=rev
Log:
only invoke readable and writeable if the selectables are still reading and writing
Modified:
qpid/trunk/qpid/python/qpid/selector.py
Modified: qpid/trunk/qpid/python/qpid/selector.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/python/qpid/selector.py?rev=824107&r1=824106&r2=824107&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/selector.py (original)
+++ qpid/trunk/qpid/python/qpid/selector.py Sun Oct 11 16:58:34 2009
@@ -136,10 +136,12 @@
rd, wr, ex = select(self.reading, self.writing, (), timeout)
for sel in wr:
- sel.writeable()
+ if sel.writing():
+ sel.writeable()
for sel in rd:
- sel.readable()
+ if sel.reading():
+ sel.readable()
now = time.time()
for sel in self.selectables.copy():
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org