[Twisted-Python] ReconnectingClientFactory

[Skinny Puppy]

ReconnectingClientFactory could not be pickled.  This did not seam to make
much sence :), well the cleanest way I could get it to is the
following.  It really is far from clean but works for me at least for me
now.  

Jeremy Rossi 


--- protocol.py	Mon Oct  7 20:29:22 2002
+++ protocol2.py	Mon Dec 23 12:00:10 2002
@@ -192,28 +192,24 @@
     retries = 0
     maxRetries = None
     _callID = None
+    _stop = None
     connector = None
 
     def clientConnectionFailed(self, connector, reason):
-        self.connector = connector
         if not reason.check(error.UserError):
-            self.retry()
+            self.retry(connector)
 
     def clientConnectionLost(self, connector, unused_reason):
-        self.connector = connector
-        self.retry()
+        self.retry(connector)
 
     def retry(self, connector=None):
         """Have this connector connect again, after a suitable delay.
         """
         if connector is None:
-            if self.connector is None:
-                raise ValueError("no connector to retry")
-            else:
-                connector = self.connector
+            raise ValueError("no connector to retry")
 
         self.retries += 1
-        if self.maxRetries is not None and (self.retries > self.maxRetries):
+        if self._stop or (self.maxRetries is not None and (self.retries > self.maxRetries)):
             log.msg("Abandoning %s after %d retries." %
                     (connector, self.retries))
             return
@@ -225,18 +221,13 @@
             
         log.msg("%s will retry in %d seconds" % (connector, self.delay,))
         from twisted.internet import reactor
-        self._callID = reactor.callLater(self.delay, connector.connect)
+        reactor.callLater(self.delay, connector.connect)
 
     def stopTrying(self):
         """I put a stop to any attempt to reconnect in progress.
         """
-        # ??? Is this function really stopFactory?
-        if self._callID:
-            self._callID.cancel()
-        if self.connector and self.connector.state == "connecting":
-            # Hopefully this doesn't just make clientConnectionFailed
-            # retry again.
-            self.connector.stopConnecting()
+        # XXX CHeap work around
+        self._stop = 1
 
     def resetDelay(self):
         """Call me after a successful connection to reset.