'Try to make an overflow on the reactor waker using callFromThread.'

def test_wakerOverflow(self):

    def cb(ign):
        self.failure = None
        waiter = threading.Event()
        def threadedFunction():
            for i in range(100000):
                try:
                    reactor.callFromThread((lambda : None))
                except:
                    self.failure = failure.Failure()
                    break
            waiter.set()
        reactor.callInThread(threadedFunction)
        waiter.wait(120)
        if (not waiter.isSet()):
            self.fail('Timed    out    waiting    for    event')
        if (self.failure is not None):
            return defer.fail(self.failure)
    return self._waitForThread().addCallback(cb)
