Returns a deferred which will fire with the matching IQ response as it's sole argument. """
def checkDeferred():
if(not d.called):
- d.errback()
+ d.errback("Timeout")
del self.deferredIqs[(jid, ID)]
jid = el.getAttribute("to")
sys.stdout = codecs.lookup('utf-8')[-1](sys.stdout)
# Find the best reactor
-selectWarning = "Unable to install any good reactors (kqueue, epoll, poll).\nWe fell back to using select. You may have scalability problems.\nThis reactor will not support more than 1024 connections +at a time."
+selectWarning = "Unable to install any good reactors (kqueue, epoll, poll).\nWe fell back to using select. You may have scalability problems.\nThis reactor will not support more than 1024 connections at a time."
try:
from twisted.internet import epollreactor as bestreactor
except:
def timeout():
self.timeout = None
if not d.called:
- d.errback()
+ d.errback("Timeout")
self.logOut() # Clean up everything
self.timeout = reactor.callLater(30, timeout)
dispatchFactory = msn.DispatchFactory()