Commits

desmaj committed 7d394c7

hopefully releasing the outgoing protocol will be a bugfix for TRAC-150

Comments (0)

Files changed (2)

daemon/orbited/cometsession.py

         return self.connections[path]
          
     def removeConn(self, conn):
-        self.logger.debug("before removeConn: %s",
-                          len(objgraph.by_type(TCPConnectionResource)))
         if conn.key in self.connections:
             del self.connections[conn.key]
-        self.logger.debug("after removeConn: %s",
-                          len(objgraph.by_type(TCPConnectionResource)))
-
+    
     def connectionMade(self, conn):
         self.listeningPort.connectionMade(conn)
         

daemon/orbited/proxy.py

     def outgoingConnectionLost(self, outgoingConn, reason):
         self.logger.debug("remoteConnectionLost %s" % reason)
         self.transport.loseConnection()
+        # forget about the outgoing protocol so that it can get cleaned up
+        self.outgoingConn = None
 
     def write(self, data):
 #        data = base64.b64encode(data)