[Neo-report] r2024 gregory - in /trunk/neo: connection.py storage/app.py

[nobody at svn.erp5.org]

Author: gregory
Date: Mon Apr 26 10:03:50 2010
New Revision: 2024

Log:
Don't execute queued events related to a closed or aborted connection.

Those events are not purged at disconnection, ignore them here.

Modified:
    trunk/neo/connection.py
    trunk/neo/storage/app.py

Modified: trunk/neo/connection.py
==============================================================================
--- trunk/neo/connection.py [iso-8859-1] (original)
+++ trunk/neo/connection.py [iso-8859-1] Mon Apr 26 10:03:50 2010
@@ -280,6 +280,9 @@
     def getUUID(self):
         return None
 
+    def isClosed(self):
+        return self.connector is None
+
     def isAborted(self):
         return False
 

Modified: trunk/neo/storage/app.py
==============================================================================
--- trunk/neo/storage/app.py [iso-8859-1] (original)
+++ trunk/neo/storage/app.py [iso-8859-1] Mon Apr 26 10:03:50 2010
@@ -290,6 +290,8 @@
         p = self.event_queue.popleft
         for _ in xrange(l):
             some_callable, msg_id, conn, args, kwargs = p()
+            if conn.isAborted() or conn.isClosed():
+                continue
             conn.setPeerId(msg_id)
             some_callable(conn, *args, **kwargs)