Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def cancelPoetryReading(sockets):
- for i, sock in enumerate(sockets):
- print "Timeout!"
- sock.connectionLost("Timeout occurred")
- def poetry_main():
- addresses = parse_args()
- start = datetime.datetime.now()
- try:
- sockets = [PoetrySocket(i + 1, addr) for i, addr in enumerate(addresses)]
- print "SOCKETS: ",sockets
- except socket.error:
- print 'Arr, there be a socket error. Methinks you tried to land on the wrong port.'
- return
- from twisted.internet import reactor
- reactor.callLater(3,cancelPoetryReading,sockets)
- reactor.run()
- elapsed = datetime.datetime.now() - start
- for i, sock in enumerate(sockets):
- print 'Task %d: %d bytes of poetry' % (i + 1, len(sock.poem))
- print 'Got %d poems in %s' % (len(addresses), elapsed)
- if __name__ == '__main__':
- poetry_main()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement