[Twisted-Python] ReconnectingClientFactory.stopTrying

[Eric C. Newton]

RedHat 9.0
Twisted 1.0.4

I have two servers, A and B, connected over a network which may, or
may not be working well.  Server A wants to send a bunch of data over
to Server B.  I'm using ReconnectingClientFactory to get A connected
to B even in the presence of failures.

Once Server A dumps the data on B, it should disconnect and go back to
doing it's (unrelated) work, and close the connection on B.

ReconnectingClientFactory has "stopTrying" which I call to prevent
future connections from being made.  Then I close the current
connection.  Unfortunately that tells the ReconnectingClientFactory
that it should reconnect, even though it should have stopped trying.
Shortly thereafter I get a stack trace.  Reversing the
order... loseConnection, stopTrying, doesn't work either.

Test code below will give a stack trace after a few seconds of
running.

My (present) workaround is to close the connection, and tell the
ReconnectingClientFactory to stopTrying with:

	reactor.callLater(0.1, self.factory.stopTrying)

It works, but the 0.1 is a kludge to allow connection clean-up to
finish, but timed to go off before the Connector starts a new attempt.
Yuck.

-Eric
#
from twisted.internet import reactor
from twisted.internet.protocol import Factory, ReconnectingClientFactory
from twisted.protocols.basic import Int16StringReceiver
import pickle

class In(Int16StringReceiver):

    def __init__(self):
        self.msgs = {}
    
    def stringReceived(self, msg):
        n, msg = pickle.loads(msg)
        self.msgs[n] = msg
        self.sendString(pickle.dumps(n))

    def connectionLost(self, reason):
        print self.msgs.values()

class Out(Int16StringReceiver):

    def __init__(self):
        self.msgs = {}

    def connectionMade(self):
        for i in range(10):
            self.msgs[i] = 'X' * i
        for i in self.msgs.keys():
            self.sendString(pickle.dumps( (i, self.msgs[i])))
    
    def stringReceived(self, msg):
        n = pickle.loads(msg)
        del self.msgs[n]
        if not self.msgs:
            self.transport.loseConnection()
            self.factory.stopTrying()

f = Factory()
f.protocol = In

c = ReconnectingClientFactory()
c.protocol = Out

PORT=9000
reactor.connectTCP('localhost', PORT, c)
reactor.listenTCP(PORT, f)
reactor.run()