Добрый день. Принялся изучать twisted, но к сожалению слаб в техническом английском, поэтому много понять не могу
. Вопрос в следующем, почему при попытке остановить реактор, выдает исключение (смотреть после кода) и как выстроить архитектуру приложения что бы такого не происходило.Цель с помощью callLater выставить timeout после которого Reactor будет остановлен, если данные с сервера не были получены за этот промежуток.
import optparse, sys
from twisted.internet.protocol import Protocol, ClientFactory
def parse_args():
usage = """usage: %prog [options] [hostname]:port ...
This is the Get Poetry Now! client, Twisted version 3.1
Run it like this:
python get-poetry-1.py port1 port2 port3 ...
If you are in the base directory of the twisted-intro package,
you could run it like this:
python twisted-client-3/get-poetry-1.py 10001 10002 10003
to grab poetry from servers on ports 10001, 10002, and 10003.
Of course, there need to be servers listening on those ports
for that to work.
"""
parser = optparse.OptionParser(usage)
_, addresses = parser.parse_args()
if not addresses:
print parser.format_help()
parser.exit()
def parse_address(addr):
if ':' not in addr:
host = '127.0.0.1'
port = addr
else:
host, port = addr.split(':', 1)
if not port.isdigit():
parser.error('Ports must be integers.')
return host, int(port)
return map(parse_address, addresses)
class PoetryProtocol(Protocol):
poem = ''
def dataReceived(self, data):
self.poem += data
def connectionLost(self, reason):
self.poemReceived(self.poem)
def poemReceived(self, poem):
self.factory.poem_finished(poem)
class PoetryClientFactory(ClientFactory):
protocol = PoetryProtocol
def __init__(self, callback, errback):
self.callback = callback
self.errback = errback
def poem_finished(self, poem):
self.callback(poem)
def clientConnectionFailed(self, connector, reason):
print 'Connection Failed'
self.errback(reason)
def get_poetry(host, port, callback, errback):
"""
Download a poem from the given host and port and invoke
callback(poem)
when the poem is complete. If there is a failure, invoke:
errback(err)
instead, where err is a twisted.python.failure.Failure instance.
"""
from twisted.internet import reactor
factory = PoetryClientFactory(callback, errback)
reactor.connectTCP(host, port, factory)
def poetry_main():
addresses = parse_args()
from twisted.internet import reactor
poems = []
errors = []
def got_poem(poem):
poems.append(poem)
poem_done()
def poem_failed(err):
print >>sys.stderr, 'Poem failed:', err
errors.append(err)
poem_done()
def poem_done():
if len(poems) + len(errors) == len(addresses):
reactor.stop()
for address in addresses:
host, port = address
get_poetry(host, port, got_poem, poem_failed)
reactor.run()
for poem in poems:
print poem
def go():
from twisted.internet import reactor
reactor.callLater(0.000001,poetry_main)
reactor.callLater(2,stop)
def stop():
from twisted.internet import reactor
print 'Exceeded the threshold of response'
reactor.stop()
if __name__ == '__main__':
from twisted.internet import reactor
reactor.callWhenRunning(go)
reactor.run()
Unhandled Error
Traceback (most recent call last):
File "D:/Python/book/twistedbook/examples-twisted/twisted-client-3/get-poetry-1.py", line 144, in <module>
reactor.run()
File "C:\Python27\lib\site-packages\twisted\internet\base.py", line 1169, in run
self.mainLoop()
File "C:\Python27\lib\site-packages\twisted\internet\base.py", line 1178, in mainLoop
self.runUntilCurrent()
--- <exception caught here> ---
File "C:\Python27\lib\site-packages\twisted\internet\base.py", line 800, in runUntilCurrent
call.func(*call.args, **call.kw)
File "D:/Python/book/twistedbook/examples-twisted/twisted-client-3/get-poetry-1.py", line 124, in poetry_main
reactor.run()
File "C:\Python27\lib\site-packages\twisted\internet\base.py", line 1168, in run
self.startRunning(installSignalHandlers=installSignalHandlers)
File "C:\Python27\lib\site-packages\twisted\internet\base.py", line 1148, in startRunning
ReactorBase.startRunning(self)
File "C:\Python27\lib\site-packages\twisted\internet\base.py", line 678, in startRunning
raise error.ReactorAlreadyRunning()
twisted.internet.error.ReactorAlreadyRunning:
Exceeded the threshold of response
Unhandled Error
Traceback (most recent call last):
File "C:\Python27\lib\site-packages\twisted\internet\defer.py", line 290, in addCallbacks
self._runCallbacks()
File "C:\Python27\lib\site-packages\twisted\internet\defer.py", line 551, in _runCallbacks
current.result = callback(current.result, *args, **kw)
File "C:\Python27\lib\site-packages\twisted\internet\base.py", line 426, in _continueFiring
callable(*args, **kwargs)
File "C:\Python27\lib\site-packages\twisted\internet\base.py", line 621, in disconnectAll
failure.Failure(main.CONNECTION_LOST))
--- <exception caught here> ---
File "C:\Python27\lib\site-packages\twisted\python\log.py", line 84, in callWithLogger
return callWithContext({"system": lp}, func, *args, **kw)
File "C:\Python27\lib\site-packages\twisted\python\log.py", line 69, in callWithContext
return context.call({ILogContext: newCtx}, func, *args, **kw)
File "C:\Python27\lib\site-packages\twisted\python\context.py", line 118, in callWithContext
return self.currentContext().callWithContext(ctx, func, *args, **kw)
File "C:\Python27\lib\site-packages\twisted\python\context.py", line 81, in callWithContext
return func(*args,**kw)
File "C:\Python27\lib\site-packages\twisted\internet\tcp.py", line 473, in connectionLost
self._commonConnection.connectionLost(self, reason)
File "C:\Python27\lib\site-packages\twisted\internet\tcp.py", line 287, in connectionLost
protocol.connectionLost(reason)
File "D:/Python/book/twistedbook/examples-twisted/twisted-client-3/get-poetry-1.py", line 60, in connectionLost
self.poemReceived(self.poem)
File "D:/Python/book/twistedbook/examples-twisted/twisted-client-3/get-poetry-1.py", line 63, in poemReceived
self.factory.poem_finished(poem)
File "D:/Python/book/twistedbook/examples-twisted/twisted-client-3/get-poetry-1.py", line 75, in poem_finished
self.callback(poem)
File "D:/Python/book/twistedbook/examples-twisted/twisted-client-3/get-poetry-1.py", line 108, in got_poem
poem_done()
File "D:/Python/book/twistedbook/examples-twisted/twisted-client-3/get-poetry-1.py", line 117, in poem_done
reactor.stop()
File "C:\Python27\lib\site-packages\twisted\internet\base.py", line 577, in stop
"Can't stop reactor that isn't running.")
twisted.internet.error.ReactorNotRunning: Can't stop reactor that isn't running.
.
