Thrift + Twisted, run the reactor multiple times

[Alex Parenteau <ap...@adobe.com>]

Hi,

I'm a new user of both twisted and thrift, and I need for my project to be able to call multiple times reactor.run (essentially for running unit tests).

I know this post is more about twisted, but this is probably the first of many posts related to thrift+twisted, which is more my focus :)

I've searched everywhere on how to do that, but not to prevail. See below the example program.

The symptom is that the second reactor.stop never succeeds, and "Success" is never printed.

(notice I tried with and without 'reactor_clean_up'which is a code I found in twisted unit test, which seemed to allow for that)

This is using latest twisted, both on Ubuntu Lucid + 10.0.1 (PPA), and Windows.

Sorry if I'm asking at the wrong location, and don't know yet what is the process to ask those kind of questions.

Many thanks in advance!

Alex

>>>>>>>> CUT >>>>>>>>>>>>
from twisted.internet import reactor

def reactor_clean_up():
    reactor._uninstallHandler()
    if getattr(reactor, '_internalReaders', None) is not None:
        for reader in reactor._internalReaders:
            reactor.removeReader(reader)
            reader.connectionLost(None)
        reactor._internalReaders.clear()

    # Here's an extra thing unrelated to wakers but necessary for
    # cleaning up after the reactors we make.  -exarkun
    reactor.disconnectAll()

    # It would also be bad if any timed calls left over were allowed to
    # run.
    calls = reactor.getDelayedCalls()
    for c in calls:
        c.cancel()


print "1st call to reactor"
reactor.callLater(2, reactor.stop)
reactor.run(installSignalHandlers=False)

reactor_clean_up()

print "2nd call to reactor"
reactor.callLater(2, reactor.stop)
reactor.run(installSignalHandlers=False)

print "Success"

>>>>>>>> CUT >>>>>>>>>>>>