Mailman 3 December 2009 - Twisted

[Twisted-Python] Websites down
by Landreville Dec. 21, 2009

Dec. 21, 2009

I'm getting an error from http://twistedmatrix.com Error 503 Service Unavailable Service Unavailable Guru Meditation: XID: 1274684191 Varnish

1 0

Re: [Twisted-Python] A resizable cooperator class for queuing and dispatching jobs
by Terry Jones Dec. 21, 2009

Dec. 21, 2009

I forgot to mention that I put the code for this class onto Launchpad: https://launchpad.net/txrdq Terry

1 0

[Twisted-Python] Weekly Bug Summary
by exarkun＠twistedmatrix.com Dec. 20, 2009

Dec. 20, 2009

1 0

[Twisted-Python] Memcache client issues
by MārisR Dec. 18, 2009

Dec. 18, 2009

Hello! I'm trying to write small tcp server, which doing some stuff with memcache. Everything was fine until I start it on production, after few minutes I got to rollback to old one. My script got max open files limit :( After liitle inspection, I saw that, new connection to my daemon opens new connection to memcache and after disconnect its not closed and on new connections is not reused. I could not find how to disconnect form memcache after processing is done, or how to reuse open … [View More]

3 4

[Twisted-Python] copy.deepcopy domish.Element works in python 2.5 but not in 2.6
by Gabriel Rossetti Dec. 18, 2009

Dec. 18, 2009

Hello everyone, for some reason copy.deepcopy forks great on a domish.Element on 2.5 but not in 2.6 : Python 2.5.4 (r254:67916, Sep 20 2009, 10:05:43) [GCC 4.4.1] on linux2 Type "help", "copyright", "credits" or "license" for more information. >>> from twisted.words.xish import domish >>> import copy >>> msg = domish.Element(('jabber:client', 'message')) >>> msg2 = copy.deepcopy(msg) >>> Python 2.6.4 (r264:75706, Nov 2 2009, 14:38:03) [GCC … [View More]

3 2

[Twisted-Python] plugin system
by César García Dec. 17, 2009

Dec. 17, 2009

Guys, I'am new to twisted and I've read the documentation about the plugin system and the components but I can't make it, I really do not get it well, do you guys have any examples there to see if I can get it :) Thanks a lot -- http://celord.blogspot.com/

3 2

[Twisted-Python] Downpour - new project using Twisted
by Jeremy Jongsma Dec. 17, 2009

Dec. 17, 2009

I just posted my latest project - Downpour, a web-based BitTorrent client using twisted and twisted-web. Feel free to try it out and send me any comments. It hasn't been tested on Windows yet, so any trip reports for that would also be appreciated. http://home.jongsma.org/software/downpour/ Could someone add this to the "Projects Using Twisted" page? -j --

3 2

[Twisted-Python] UDP crashes python.exe when using IOCPReactor
by Josh Albrecht Dec. 16, 2009

Dec. 16, 2009

I've been struggling to move a large program over to IOCPReactor, but it is causing python.exe to crash on windows. I reduced the error to this program, which crashes almost immediately on all the machines I've tested it on. Am I doing something wrong? ############################################# from twisted.internet.iocpreactor.reactor import IOCPReactor from twisted.internet.main import installReactor from twisted.internet.protocol import DatagramProtocol reactor = IOCPReactor() … [View More]

3 3

[Twisted-Python] zope.interface
by Jared Gisin Dec. 16, 2009

Dec. 16, 2009

Is there a good document that explains why zope.interface is necessary to the twisted project? -Jared

7 9

[Twisted-Python] complete producer/consumer example
by Benjamin Rutt Dec. 15, 2009

Dec. 15, 2009

How does the below example look as a complete producer/consumer example? If it's well received, perhaps we can add it to the online documentation at http://twistedmatrix.com/documents/current/core/howto/producers.html in the "Further Reading" section? I always felt that the producer/consumer (a.k.a. high volume streaming) docs lacked a real example that users could download and run. #!/sw/external/python-2.6.1/bin/python """Serve as a sample implementation of a twisted producer/consumer … [View More]system, with a simple TCP server which asks the user how many random integers they want, and it sends the result set back to the user, one result per line.""" import random from zope.interface import implements from twisted.internet import interfaces, reactor from twisted.internet.protocol import Factory from twisted.protocols.basic import LineReceiver class Producer: """Send back the requested number of random integers to the client.""" implements(interfaces.IPushProducer) def __init__(self, proto, cnt): self._proto = proto self._goal = cnt self._produced = 0 self._paused = False def pauseProducing(self): """When we've produced data too fast, pauseProducing() will be called (reentrantly from within resumeProducing's transport.write method, most likely), so set a flag that causes production to pause temporarily.""" self._paused = True print('pausing connection from %s' % (self._proto.transport.getPeer())) def resumeProducing(self): self._paused = False while not self._paused and self._produced < self._goal: next_int = random.randint(0, 10000) self._proto.transport.write('%d\r\n' % (next_int)) self._produced += 1 if self._produced == self._goal: self._proto.transport.unregisterProducer() self._proto.transport.loseConnection() def stopProducing(self): pass class ServeRandom(LineReceiver): """Serve up random data.""" def connectionMade(self): print('connection made from %s' % (self.transport.getPeer())) self.transport.write('how many random integers do you want?\r\n') def lineReceived(self, line): cnt = int(line.strip()) producer = Producer(self, cnt) self.transport.registerProducer(producer, True) producer.resumeProducing() def connectionLost(self, reason): print('connection lost from %s' % (self.transport.getPeer())) factory = Factory() factory.protocol = ServeRandom reactor.listenTCP(1234, factory) print('listening on 1234...') reactor.run() Use on the client: $ telnet localhost 1234 Trying 127.0.0.1... Connected to localhost. Escape character is '^]'. how many random integers do you want? 5 431 7201 3289 9604 6659 Connection closed by foreign host. $ Use on the server (observe how the server pauses production sometimes - this happens when a large data set is requested by the client): $ ./streaming.py listening on 1234... connection made from IPv4Address(TCP, '127.0.0.1', 54859) connection lost from IPv4Address(TCP, '127.0.0.1', 54859) connection made from IPv4Address(TCP, '127.0.0.1', 54864) pausing connection from IPv4Address(TCP, '127.0.0.1', 54864) pausing connection from IPv4Address(TCP, '127.0.0.1', 54864) pausing connection from IPv4Address(TCP, '127.0.0.1', 54864) pausing connection from IPv4Address(TCP, '127.0.0.1', 54864) connection lost from IPv4Address(TCP, '127.0.0.1', 54864) [...] Thanks. -- Benjamin Rutt [View Less]

2 2