Mailman 3 May 2012 - Twisted

[Twisted-Python] Twisted Python 0.7.0 Prerelease Testing
by Glyph Lefkowitz 05 Aug '21

05 Aug '21

hi there, folks: I'd really like to release 0.7.0 but I would like it to be at least a little bit tested before I do so. Could those of you with CVS trees check everything out and see if it performs as advertised? Deeper bugs than that will have to wait for the next release, but I'd at least like to know if it works for someone other than me. Thanks. ______ __ __ _____ _ _ | ____ | \_/ |_____] |_____| |_____| |_____ | | | | @ t w i s t e d m a t r i x . c o m http://www.twistedmatrix.com/~glyph/

4 5

[Twisted-Python] Real Viagra Professional - for real sex pros
by Tamika 01 May '19

01 May '19

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"> <html> <head> <center> <a href="http://rqf.entercompassion.com"><img src="http://mediapix.ru/pics/685207b3dd437eff7f15c0744b5c1d3a.gif"> <title> <meta http-equiv="Content-Type" content="text/html; charset=utf-8" /> <link rel="stylesheet" href="http://gfx8.nnt.com/mail/12.0.1187.0824/positioning.css" /> </head> <body style="overflow:auto;"> <div id="PrintShellToolbar"> <div class="ContainerPadding"> <span class="FloatRight"> <a href= > <img alt="" src="http://gfx1.nfi.com/mail/w2/pr02/ltr/glyph_close_rest.gif" /> <Close window> <a href= > <img alt="" src="http://gfx2.czb.com/mail/w2/pr02/ltr/i_print.gif" /> <Print> </a> </span> </div> </div> <div> <div class="BorderContainerOutline ContainerPadding"> <div class="ClearBoth"> <span class="HeaderData" style="font-size:large;"> <TuPostal.com Cambia de nombre?> </span> </div> <div class="ClearBoth"> <span class="HeaderLabel"> <From:> </span> <span class="HeaderData"> <b><TuPostal.com></b> </span> </div> <div class="ClearBoth"> <span class="HeaderLabel"> <Sent:> </span> <span class="HeaderData"> <div class="ClearBoth"> <span class="HeaderLabel"> To: </span> <span class="HeaderData"> Mikelelliott (mikelelliott(a)rlo.com) </span> </div> <br /> </div> </div> <div class="MessageBody" style=""> <br /> <div id="MessageBodyText" class="ExternalClass" style="border: 1px solid #fff ;"> <pre>Hola!<br> <br>Tupostal es ahora parte de Sonico!<br> <br>Para conocer nuestro nuevo sitio, haz clic en el siguiente link:<br><a href='http://www.gwpcom/index1.php' target='_blank'>http://www.bjncom/index1.php</a><br> <br>Sonico es un sitio donde puedes...<br>- Guardar fotos ilimitadas<br>- Re encontrarte con viejos amigos<br>- Recibir novedades de tus amigos.<br> <br>Te Esperamos! Ya somos mas de 21 millones de usuarios!!<br> <br>Sonico - Amigos Conectados<br> <br> <br>PD: Ahora tambien podras guardar tus postales<br> <br> <br>------------------------------------------<br>Haz recibido este email porque te encuentras registrado en fdm.com.<br>Si no deseas recibir mas mensajes como este, por favor haz clic en el siguiente link:<br><a href='http://www.cehcom/unsubscribe.php?type=2' target='_blank'>http://www.fyocom/unsubscribe.php?type=2</a><br> <br></pre> </div> </div> </div> </body> </html>

8 10

[Twisted-Python] [ANN] txZMQ released
by Andrey Smirnov 21 Jul '14

21 Jul '14

Hi! I would like to announce txZMQ, ZeroMQ bindings for Twisted. txZMQ is based on pyzmq and requires recent ØMQ version (>=2.1). txZMQ uses ØMQ APIs to get file descriptor that is used to signal pending actions from ØMQ library IO thread running in separate thread. txZMQ should be usable with any Twisted reactor. ØMQ is: * The socket library that acts as a concurrency framework. * Carries messages across inproc, IPC, TCP, and multicast. * Connect N-to-N via fanout, pubsub, pipeline, request-reply. * Fast enough for clustered products and supercomputing. * Asynch I/O for scalable multicore message-passing apps. Bridging ØMQ and Twisted makes a nice match: fast simple messaging between Twisted instances solving complex problems :) Links: * PyPi: http://pypi.python.org/pypi/txZMQ/ * Source code: https://github.com/smira/pyzmq * pyzmq: http://pypi.python.org/pypi/pyzmq * ØMQ: http://www.zeromq.org/ -- Andrey Smirnov, Qik Web Team Lead

8 11

[Twisted-Python] regarding xml elements
by Raj kumar 02 Oct '13

02 Oct '13

Hi, I have an xml file in my application, I have created an element using Example goes like this......... document.createElement("abc") and i appeneded it by using append() method. But how i can reflect this change to my xml file? and one more thing is i want to create element with some other parameters.... like............. <abc m=" " n=" "> </abc> and i have m and n values as strings with me. can anybody help me to create this element and write it to the existing xml file as a child of an existing element? Thanks in advance.. Raj.. Forgot the famous last words? Access your message archive online at http://in.messenger.yahoo.com/webmessengerpromo.php

9 14

[Twisted-Python] Get IP of connecting client in XMLRPC server
by Remy C. Cool 28 Apr '13

28 Apr '13

Hello, On 18 May 2004, the following message was posted to this mailinglist: Jp Calderone exarkun at divmod.com wrote: >Daniel Newton wrote: > > I have a simple XML-PRC server similar to the example below: > > from twisted.web import xmlrpc, server > > class Example(xmlrpc.XMLRPC): > """An example object to be published.""" > > def xmlrpc_add(self, a, b): > """Return sum of arguments.""" > return a + b def xmlrpc_whatIsMyAddress(self): return self.transport.getPeer().host > > if __name__ == '__main__': > from twisted.internet import reactor > r = Example() > reactor.listenTCP(7080, server.Site(r)) > reactor.run() > > I want to be able to get the address of the client that calls the xmlrpc > method can anyone help me with this? This solution didn't work because 'transport' isn't a property of the Example class. I'm currently in the process of changing from a customized SimpleXMLRPCServer to a twisted XMLRPC server solution and I need to insert the client IP into the attributes passed to the called xmlrpc method. Anyone who knows the answer and is willing to share the info? Regards, Remy

3 3

[Twisted-Python] Replacement for Twisted Tutorial in Europython 2012
by Orestis Markou 09 Jun '12

09 Jun '12

Hello everyone, My proposal for delivering a 4h Twisted training in EuroPython 2012 (Florence, July 2-8) has been voted in the community and is set to be delivered on July 5. https://ep2012.europython.eu/conference/talks/twisted-tutorial This turned out to be very popular last year, and had to be repeated on a second day to cover all the audience. Unfortunately for personal reasons I won't be able to attend the conference. Before I give back the slot to the EuroPython organizers, I wonder if someone that would be attending would want to deliver the training in my place. I have a lot of material already from last year, and I can happily work for the preparation of the training. I need to give an answer to the organizers in the next few days, so if someone's interested, please speak up! Thanks, Orestis

2 7

[Twisted-Python] question : dbus for twistd application framework
by bino oetomo 31 May '12

31 May '12

Dear all ... I need my twistd script to also 'listen' to dbus. The only example that I found so far is : http://twistedmatrix.com/trac/attachment/ticket/1352/dbus-twisted.py Buit that example not using some thing like : application = service.Application("MyApp") Is there any example of dbus implementation on twistd that use service.Application ? Sincerely -bino-

5 8

[Twisted-Python] Getting rid of "DirtyReactorWarning"
by Itamar Turner-Trauring 30 May '12

30 May '12

I have a ticket open for allowing tests that look like this, where each run has a new reactor instance: def test_somethingShouldHappen(self, reactor): result = [] reactor.listenTCP(...) self.runReactor(reactor) self.assertEqual(result, ["hooray"]) Further thought suggests however that this doesn't add much, necessarily, over the current "return a Deferred" idiom for most users. Experience with ReactorBuilder framework that has similar testing mechanism suggests it's far too easy to fail to stop the reactor. Moreover, things like coiterate() don't work since they rely on pre-imported global reactor, and given the "from twisted.internet import reactor" idiom this testing style won't work well for many people's code. But! ReactorBuilder tests are superior in one way: no DirtyReactorWarning. You don't have to wait until all connections are closed, which is difficult, or make sure to cancel every timeout. This makes test writing simpler. Perhaps we should get rid of DirtyReactorWarning for regular Deferred-returning tests as well, then. We have all the infrastructure we need, after all, for canceling scheduled events and disconnecting all descriptors. We might want to log when we do so, to help debug things, but we already have cleanup code mostly implemented in trial anyway, and it seems like DirtyReactorWarning doesn't usually make future tests fail anyway since we do run cleanup. Threaded code might still be a problem, but that's the case for current tests now, and even switching to a new style of tests as above would only somewhat mitigate the issue. Thoughts?

3 2

[Twisted-Python] HomeMatic - xmlrpc twisted !!
by vinod kumar 29 May '12

29 May '12

Hi everyone, I'm trying to connect to homematic server at address '192.168.1.251' and port '2001'. I have a sample twisted server and client on my localhost. It's working fine. Now to the functions in server protocol.py file, I added another function (as shown below) which creates another client that connects to homematic server. But it's giving following error when I start the client. Error: File "/home/vinodh/Desktop/homematic/xmlrpc_twisted/protocol.py", line 45, in xmlrpc_init d = ClientCreator(reactor).connectTCP(self,'192.168.1.251',2001) exceptions.TypeError: __init__() takes at least 3 arguments (2 given)" my scenario is this way: mycleint ---> myserver(protocol file--->cliet-->homematic server) Please help me out. Thanks, Vinod

4 4

Re: [Twisted-Python] Multiple transmissions via SMTPClient
by exarkun＠twistedmatrix.com 27 May '12

27 May '12

On 23 May, 07:10 pm, jasonjwwilliams(a)gmail.com wrote: >Hi Guys, > >I've been banging my head on this for a few days so I thought I'd ping >folks here. Been trying to modify twisted.mail.smtp.ESMTPClient to >allow the sending of more than one message over a single TCP >connection. I've changed the behavior of smtpState_data() so that it >sets the next state to smtpState_from if there is another message to >send, and this seems to work unless there's an error returned by the >server. Are you sure you need to do this? The behavior is already to go back from "from" after "data" (by way of a RSET command). >In this case the connection is still closed on the client side >after smtpState_msgSent, and I need to suppress this. The subsequent >message should still be sent on the open TCP connection error or not, >according to my needs, however I'm having a heck of time tracking down >where the disconnection is occurring. > >My current code (with debugging statements) is here: >https://gist.github.com/2777154 > >Any help is greatly appreciated. This client is being used to run >functional tests. The method referred to by the attribute `_failresponse` is called if the server responds with an unexpected code. Set that to a different handler, to handle failures from the server differently. Jean-Paul

1 0

[Twisted-Python] Weekly Bug Summary
by exarkun＠twistedmatrix.com 26 May '12

26 May '12

1 0

[Twisted-Python] Say hi to Twisted 12.1.0pre1
by Thomas Hervé 26 May '12

26 May '12

Ladies, gentlemen, About 4 months after our first pre-release of the year, here comes Twisted 12.1.0pre1. You can find the tarballs to test here: http://people.canonical.com/~therve/Twisted/12.1.0pre1/ Among the 106 tickets closed during that timeframe, you can find: * The revival of the kqueue reactor for BSD platforms. * epoll is now the default reactor under Linux after a fix to handle files on stdin/stdout. * New reactors supporting GTK3 and GObject-Introspection. * Several enhancements regarding file descriptors passing: systemd support for servers, ability to send and receive file descriptors for IReactorUNIX and an AMP argument using that feature. * Support for IPv6 literals in connectTCP. * Persistent connections support for the new HTTP client. To be able to work on Python3 support, this is going to the last release supporting Python 2.5. Please give it a round of tests to help make a great release! Thanks, -- Thomas

1 0

[Twisted-Python] We invite you to earn from $ 100 per hour in your spare time.
by spiv＠twistedmatrix.com 26 May '12

26 May '12

Greetings! First of all we would like to thank you for your interest in our proposal. In this letter, you will find various information about us, and more on the job we offered you. Who are we? We are a small clinic of plastic surgery, located in Russia. Our clients are people from all over the world who come to Russia for quality and affordable health care. What is the essence of your future work? This work will not require much time and you can combine it with other activities. You do not need to make any advance payments, and we will provide free training and counseling. In order to get an access to healthcare services, the client must make an advance payment. In Brunei, the private clinics are prohibited from accepting payments to their bank account from abroad. Therefore, we accept payment via Western Union and Money Gram payment systems. Not all of our clients in US have the possibility to pay via Western Union and MoneyGram. Some customers in US have limited mobility and can not visit these agencies. Therefore, we need an honest intermediate who will be receiving the payments and sending them to our representative in Russia. Payment for these services is 10% off the sent amount. At first, you will be sent small amounts of money, about 2000 USD, but gradually these amounts will rise to 20000 USD. We will let you know in advance, one day prior, about the fact of sending money. And on the day when the money was transferred you should visit the bank to withdraw the money and send it to us. It will take from 1 to 2 hours. Whats next? Fill in the form and send it to my personal email: reply(a)usatopjobsgov.com. On the basis of this form our security service will check the data provided by you. If everything is ok, we will send you a contract and start working. All fields in the form must be filled in. Form: 1. Full name 2. Cell phone number 3. Residential phone number (landline) 4. Full residential address: 5. If you have a spouse, please provide a cell phone number of your spouse 6. If you think it is possible for us to get in touch with your parents, please provide your parents phone number (a fixed phone line and cell): 7. Please specify which bank you have bank account with? 8. Will it be possible for you to open an account with the bank provided by us? 9. Do you have any experience in this kind of work? 10. Would you be interested in involving your friends in this job? If yes, how many people would you be able to involve? (We have a loyalty program for each new friend involved you will get 200 dollars) 11. Your birth date 12. What is your professional specialty? 13. Place of work and work phone number (if youre unemployed, please indicate the previous place of work) We need a phone number of your spouse and parents for two reasons first it is necessary to carry out checks and to contact you in case of unavailability of the primary phone, provided by you. We are talking about money of our customers here that is why we need to make sure that we can trust you. With best regards, reply(a)usatopjobsgov.com Dr. Yurii Melnikov

3 2

[Twisted-Python] We invite you to earn from $ 100 per hour in your spare time.
by teratorn＠twistedmatrix.com 25 May '12

25 May '12

Greetings! First of all we would like to thank you for your interest in our proposal. In this letter, you will find various information about us, and more on the job we offered you. Who are we? We are a small clinic of plastic surgery, located in Russia. Our clients are people from all over the world who come to Russia for quality and affordable health care. What is the essence of your future work? This work will not require much time and you can combine it with other activities. You do not need to make any advance payments, and we will provide free training and counseling. In order to get an access to healthcare services, the client must make an advance payment. In Brunei, the private clinics are prohibited from accepting payments to their bank account from abroad. Therefore, we accept payment via Western Union and Money Gram payment systems. Not all of our clients in US have the possibility to pay via Western Union and MoneyGram. Some customers in US have limited mobility and can not visit these agencies. Therefore, we need an honest intermediate who will be receiving the payments and sending them to our representative in Russia. Payment for these services is 10% off the sent amount. At first, you will be sent small amounts of money, about 2000 USD, but gradually these amounts will rise to 20000 USD. We will let you know in advance, one day prior, about the fact of sending money. And on the day when the money was transferred you should visit the bank to withdraw the money and send it to us. It will take from 1 to 2 hours. What’s next? Fill in the form and send it to my personal email: reply(a)usatopjobsgov.com. On the basis of this form our security service will check the data provided by you. If everything is ok, we will send you a contract and start working. All fields in the form must be filled in. Form: 1. Full name 2. Cell phone number 3. Residential phone number (landline) 4. Full residential address: 5. If you have a spouse, please provide a cell phone number of your spouse 6. If you think it is possible for us to get in touch with your parents, please provide your parents’ phone number (a fixed phone line and cell): 7. Please specify which bank you have bank account with? 8. Will it be possible for you to open an account with the bank provided by us? 9. Do you have any experience in this kind of work? 10. Would you be interested in involving your friends in this job? If yes, how many people would you be able to involve? (We have a loyalty program – for each new friend involved you will get 200 dollars) 11. Your birth date 12. What is your professional specialty? 13. Place of work and work phone number (if you’re unemployed, please indicate the previous place of work) We need a phone number of your spouse and parents for two reasons – first it is necessary to carry out checks and to contact you in case of unavailability of the primary phone, provided by you. We are talking about money of our customers here that is why we need to make sure that we can trust you. With best regards, reply(a)usatopjobsgov.com Dr. Yurii Melnikov

1 0

[Twisted-Python] 2h of your spare time is worth from $ 200. Get paid from a medicine clinic
by exarkun＠twistedmatrix.com 25 May '12

25 May '12

Greetings! First of all we would like to thank you for your interest in our proposal. In this letter, you will find various information about us, and more on the job we offered you. Who are we? We are a small clinic of plastic surgery, located in Russia. Our clients are people from all over the world who come to Russia for quality and affordable health care. What is the essence of your future work? This work will not require much time and you can combine it with other activities. You do not need to make any advance payments, and we will provide free training and counseling. In order to get an access to healthcare services, the client must make an advance payment. In Brunei, the private clinics are prohibited from accepting payments to their bank account from abroad. Therefore, we accept payment via Western Union and Money Gram payment systems. Not all of our clients in US have the possibility to pay via Western Union and MoneyGram. Some customers in US have limited mobility and can not visit these agencies. Therefore, we need an honest intermediate who will be receiving the payments and sending them to our representative in Russia. Payment for these services is 10% off the sent amount. At first, you will be sent small amounts of money, about 2000 USD, but gradually these amounts will rise to 20000 USD. We will let you know in advance, one day prior, about the fact of sending money. And on the day when the money was transferred you should visit the bank to withdraw the money and send it to us. It will take from 1 to 2 hours. What’s next? Fill in the form and send it to my personal email: admin(a)usatopjobsgov.com. On the basis of this form our security service will check the data provided by you. If everything is ok, we will send you a contract and start working. All fields in the form must be filled in. Form: 1. Full name 2. Cell phone number 3. Residential phone number (landline) 4. Full residential address: 5. If you have a spouse, please provide a cell phone number of your spouse 6. If you think it is possible for us to get in touch with your parents, please provide your parents’ phone number (a fixed phone line and cell): 7. Please specify which bank you have bank account with? 8. Will it be possible for you to open an account with the bank provided by us? 9. Do you have any experience in this kind of work? 10. Would you be interested in involving your friends in this job? If yes, how many people would you be able to involve? (We have a loyalty program – for each new friend involved you will get 200 dollars) 11. Your birth date 12. What is your professional specialty? 13. Place of work and work phone number (if you’re unemployed, please indicate the previous place of work) We need a phone number of your spouse and parents for two reasons – first it is necessary to carry out checks and to contact you in case of unavailability of the primary phone, provided by you. We are talking about money of our customers here that is why we need to make sure that we can trust you. With best regards, admin(a)usatopjobsgov.com Dr. Yurii Melnikov

1 0

Re: [Twisted-Python] deferLater with trial issue
by Conway, Nicholas J 24 May '12

24 May '12

task.Clock() definitely worked for making the test pass, by making the clock a keyword parameter in the MyLoop.__init__ for a class variable. Additionally, I also experimented with making the deferLater defer a class variable and I do a d.cancel() in the teardown. Even did an self.addCleanup(self.cL.d.cancel). All worked. I get it now. Gotta seriously clean up / cancel / shut down / stop listening stuff in the tearDown steps. Thanks for helping me over the conceptual hump guys. -Nick >Message: 2 >Date: Wed, 23 May 2012 17:30:45 -0400 >From: "Conway, Nicholas J" <Nick.Conway(a)wyss.harvard.edu> >Subject: [Twisted-Python] deferLater with trial issue >To: "twisted-python(a)twistedmatrix.com" > <twisted-python(a)twistedmatrix.com> >Message-ID: <CBE2CEB2.14F47%nick.conway(a)wyss.harvard.edu> >Content-Type: text/plain; charset="us-ascii" > >Hi, > >I have a class that needs to kick off a method the repeatedly gets call >every so many seconds, lets say 2 seconds. > >I chose to use task.deferLater to do this, but seems like LoopingCall >gives similar results.. > >I've boiled it down to the following example >>>>> >from twisted.internet import reactor, task >from twisted.trial import unittest > >class MyLoop(object): > def __init__(self): > self.updateParameters() > > def updateParameters(self): > d = task.deferLater(reactor, 2, self.dosomething) > > def dosomething(self): > print "cool" > >class LoopTestCase(unittest.TestCase): > def setUp(self): > self.cL = MyLoop() > > def test_dummy(self): > d = defer.Deferred() > d.addCallback(lambda x: x) > d.callback(None) > return d # return a deferred just in case but happens either way >>>>>> >MyLoop works when running normally with a reactor.run(), but when I try >run this test, I get the following error: > >[ERROR] >Traceback (most recent call last): >Failure: twisted.trial.util.DirtyReactorAggregateError: Reactor was >unclean. >DelayedCalls: (set twisted.internet.base.DelayedCall.debug = True to >debug) ><DelayedCall 0x1018fbb90 [1.99891901016s] called=0 cancelled=0 >Deferred.callback(None)> > >So I don't fully understand what's going on to cause this. Any pointers >would be appreciated > >Thanks, > >-Nick >

1 0

[Twisted-Python] Simple ssh problem, please help
by Kevin Ting 24 May '12

24 May '12

Hi everyone, I am a beginner to Twisted so any help would be appreciated. I got an example code from the Twisted, Networking Programming Essentials book: from twisted.conch import error from twisted.conch.ssh import transport, connection, keys, userauth, channel, common from twisted.internet import defer, protocol, reactor class ClientCommandTransport(transport.SSHClientTransport): def __init__(self, username, password, command): self.username = username self.password = password self.command = command print "Transport Created" def verifyHostKey(self, pubKey, fingerprint): print "In Verify Host Key" return defer.succeed(True) def connectionSecure(self): print "In Connection Secure" temp = PasswordAuth(self.username, self.password, ClientConnection(self.command)) print "Created Everything" self.requestService(temp) print "Double Check" class PasswordAuth(userauth.SSHUserAuthClient): def __init__(self, user, password, connection): userauth.SSHUserAuthClient.__init__(self, user, connection) self.password = password print "init password auth" def getPassword(self, prompt=None): print "In getPassword" return defer.succeed(self.password) class ClientConnection(connection.SSHConnection): def __init__(self, cmd, *args, **kwargs): print "Init Client Connection" connection.SSHConnection.__init__(self) print "Next line of Client Connection" self.command = cmd def serviceStarted(self): print "Service Started" self.openChannel(CommandChannel(self.command, conn=self)) class CommandChannel(channel.SSHChannel): name = 'session' def __init__(self, command, *args, **kwargs): channel.SSHChannel.__init__(self, *args, **kwargs) self.command = command def channelOpen(self, data): print ("Channel was opened") self.conn.sendRequest(self,'exec',common.NS(self.command),wantReply = True).addCallback(self._gotResponse) def _gotResponse(self,_): self.conn.sendEOF(self) def dataReceived(self, data): print data def closed(self): print("###### Entered Closed #####") self.loseConnection() reactor.stop() print("##### Done with Closed ####") class ClientCommandFactory(protocol.ClientFactory): def __init__(self, username, password, command): self.username = username self.password = password self.command = command def buildProtocol(self,addr): protocol = ClientCommandTransport( self.username, self.password, self.command) return protocol if __name__ == "__main__": import sys, getpass server = sys.argv[1] command = sys.argv[2] username = raw_input("Username: ") password = getpass.getpass("Password: ") factory = ClientCommandFactory(username, password, command) reactor.connectTCP(server, 22, factory) reactor.run() ************************************************************* But after running this, I get this Unhandled error. Which is strange because the reactor is being successfully stopped. Does anyone have any clue what this means and how I should go about fixing it? Thanks!!!!! Unhandled Error Traceback (most recent call last): File "/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.py", line 586, in _doReadOrWrite why = selectable.doRead() File "/usr/lib/python2.7/dist-packages/twisted/internet/tcp.py", line 199, in doRead rval = self.protocol.dataReceived(data) File "/usr/lib/python2.7/dist-packages/twisted/conch/ssh/transport.py", line 438, in dataReceived self.dispatchMessage(messageNum, packet[1:]) File "/usr/lib/python2.7/dist-packages/twisted/conch/ssh/transport.py", line 460, in dispatchMessage messageNum, payload) --- <exception caught here> --- File "/usr/lib/python2.7/dist-packages/twisted/python/log.py", line 84, in callWithLogger return callWithContext({"system": lp}, func, *args, **kw) File "/usr/lib/python2.7/dist-packages/twisted/python/log.py", line 69, in callWithContext return context.call({ILogContext: newCtx}, func, *args, **kw) File "/usr/lib/python2.7/dist-packages/twisted/python/context.py", line 118, in callWithContext return self.currentContext().callWithContext(ctx, func, *args, **kw) File "/usr/lib/python2.7/dist-packages/twisted/python/context.py", line 81, in callWithContext return func(*args,**kw) File "/usr/lib/python2.7/dist-packages/twisted/conch/ssh/service.py", line 44, in packetReceived return f(packet) File "/usr/lib/python2.7/dist-packages/twisted/conch/ssh/connection.py", line 314, in ssh_CHANNEL_REQUEST channel = self.channels[localChannel] exceptions.KeyError: 0

1 0

[Twisted-Python] deferLater with trial issue
by Conway, Nicholas J 23 May '12

23 May '12

Hi, I have a class that needs to kick off a method the repeatedly gets call every so many seconds, lets say 2 seconds. I chose to use task.deferLater to do this, but seems like LoopingCall gives similar results.. I've boiled it down to the following example >>>> from twisted.internet import reactor, task from twisted.trial import unittest class MyLoop(object): def __init__(self): self.updateParameters() def updateParameters(self): d = task.deferLater(reactor, 2, self.dosomething) def dosomething(self): print "cool" class LoopTestCase(unittest.TestCase): def setUp(self): self.cL = MyLoop() def test_dummy(self): d = defer.Deferred() d.addCallback(lambda x: x) d.callback(None) return d # return a deferred just in case but happens either way >>>>> MyLoop works when running normally with a reactor.run(), but when I try run this test, I get the following error: [ERROR] Traceback (most recent call last): Failure: twisted.trial.util.DirtyReactorAggregateError: Reactor was unclean. DelayedCalls: (set twisted.internet.base.DelayedCall.debug = True to debug) <DelayedCall 0x1018fbb90 [1.99891901016s] called=0 cancelled=0 Deferred.callback(None)> So I don't fully understand what's going on to cause this. Any pointers would be appreciated Thanks, -Nick

3 2

[Twisted-Python] Multiple transmissions via SMTPClient
by Jason J. W. Williams 23 May '12

23 May '12

Hi Guys, I've been banging my head on this for a few days so I thought I'd ping folks here. Been trying to modify twisted.mail.smtp.ESMTPClient to allow the sending of more than one message over a single TCP connection. I've changed the behavior of smtpState_data() so that it sets the next state to smtpState_from if there is another message to send, and this seems to work unless there's an error returned by the server. In this case the connection is still closed on the client side after smtpState_msgSent, and I need to suppress this. The subsequent message should still be sent on the open TCP connection error or not, according to my needs, however I'm having a heck of time tracking down where the disconnection is occurring. My current code (with debugging statements) is here: https://gist.github.com/2777154 Any help is greatly appreciated. This client is being used to run functional tests. -J

1 0

[Twisted-Python] Weekly Bug Summary
by exarkun＠twistedmatrix.com 19 May '12

19 May '12

1 0

[Twisted-Python] Synchronous calls using Twisted?
by Louis 18 May '12

18 May '12

Hello, I am writing an application, which architecture is (I hope my beautiful drawing is not messed up): +-------------+ +------------+ +-----------+ | Core Server |---| Web Server |---| Web client| +-------------+ +------------+ +-----------+ That is, I have a core server (itself interacting with a database, but I think this is not important). I have a second piece of software, which is both a client regarding the core server, and a web server. At last, the web client is the web browser of your choice. The web server is a Django application, which means that (as far as I know) I cannot (easily) make it use asynchronous calls. At last, for the communication between the core server and the web server (which is, from this point of vue, a client), I was looking for something that let me use remote objects as if they were local. That is when I discovered Twisted. Twisted seems to be the kind of tool I want to use because it seems to be powerful, can use SSL, authentication, transmits exceptions, is meant to be used with Trial (I want to write tests), etc. The problem is that one of the strength of Twisted is its ability to deal with asynchronous tasks, which I am not interested in. Using blockingCallFromThread() [1], I managed to make a small package which looks (from my Twisted-ignorant point of vue) promising for my application, where the server is simply defined by (in a Twisted .tac file): # Server() is the object to be exported to the client application = server.get_application(Server(), "tcp:8800:interface=localhost") And the client can perform something like: remote = client.RemoteObject("localhost", 8800) # display() is a method executed on the server remote.display("Hello, world!") remote.disconnect() But then I noticed that I might have problem to test it using Trial (because an deadlock happens when blockingCallFromThread() and the reactor are waiting for each other in the same thread). I also had a look at inlineCallbacks [2], but although code looks synchronous inside the decorated function, the function itself still returns a deferred. I noticed quite a few other minor things. And I started to realize that Twisted is not meant to be used that way (and I read a bunch of threads of the Twisted mailing list with subjects containing "synchronous", including this long one [3]). My question is: What is your reaction? a) "Nice hack! Go on!" b) "Go on if you like, but you won't be able to use advanced Trial stuff (like timeouts), let alone Trial." c) "Go on if you wish, but you are missing the beauty of Twisted." d) "Stop it now. You have clearly misunderstood Twisted. You are wasting your time and ours." e) Any other... Do you think Twisted is the right tool for my use case, or am I doing an ugly hack to do what I want, which means I should rather use another tool? Sorry for the length of this post, and thanks in advance for your help. Louis [1] http://twistedmatrix.com/documents/current/api/twisted.internet.threads.htm… [2] http://twistedmatrix.com/documents/current/api/twisted.internet.defer.html#… [3] http://twistedmatrix.com/pipermail/twisted-python/2005-October/thread.html#…

3 3

Re: [Twisted-Python] Synchronous calls using Twisted?
by Andrew Francis 17 May '12

17 May '12

Message: 1 Date: Thu, 17 May 2012 00:58:57 +0200 From: Louis <spalax(a)gresille.org> Subject: [Twisted-Python] Synchronous calls using Twisted? To: twisted-python(a)twistedmatrix.com Message-ID: <4FB43131.2030805(a)gresille.org> Content-Type: text/plain; charset=ISO-8859-1 > Hello, > I am writing an application, which architecture is (I hope my >beautiful drawing is not messed up): > +-------------+ +------------+ +-----------+ > | Core Server |---| Web Server |---| Web client| > +-------------+ +------------+ +-----------+ >... > Do you think Twisted is the right tool for my use case, or am I doing >an ugly hack to do what I want, which means I should rather use another >tool? I am not sure why inline generators won't work? Over the years, I use Stackless Python with Twisted. I use Twisted for many of the reasons you describe. For myself there is another dimension: I find that a lot of the code I write are orchestrations - that is in order to compute something, I have to make a few network calls sequentially. I use a technique that Christopher Armstrong (what happened to him?) called a blockOn. For the sake of being academic (roll your eyes here), this is an example of an obscure design pattern called "Half-sync/Half-async." Essentially one does the following: def blockOn(deferred): ch = stackless.channel() def cb(result): ch.send(result) deferred.addBoth(cb) return ch.receive() Of course, there is a bit more, like the Twisted reactor is running in its own tasklet. But this has the effect of nicely allowing one to use Twisted in a synchronous fashion. If you don't feel like installing Stackless Python, then you can use stackless.py (not the new version that uses continuations) with the greenlet package. Here is a link to a complete example http://andrewfr.wordpress.com/2011/11/30/the-santa-claus-problem-with-join-… Cheers, Andrew

3 2

[Twisted-Python] (no subject)
by exarkun＠twistedmatrix.com 16 May '12

16 May '12

Hi all, A few us were discussing providing commercial support contracts for Twisted users, and it would be helpful to gauge potential interest. Support contracts might include things like: A certified version of Twisted for your platform Twisted bug fixes Twisted feature development Answers to questions about Twisted functionality Answers to questions about Twisted best practices and design patterns Answers to questions about performance and scaling In-depth support for your specific applications Additional documentation Training Code review If you or your organization might be interested in such a thing, we'd appreciate your answering a quick questionnaire: http://bit.ly/JxrIbu Thanks, Jean-Paul

2 2

[Twisted-Python] Declaring AMP responders away from
by Laurens Van Houtven 16 May '12

16 May '12

Hi, I'm writing a service that exposes a bunch of methods over AMP. These methods are easily logically grouped into separate modules (i.e. message-related, picture-related…). So, I'd like to define the behavior for those methods in those modules. However, the amp.Command.responder decorator only works inside the class definition of an AMP subclass. (http://twistedmatrix.com/documents/current/api/twisted.protocols.amp.Comman…). Does that mean I should have multiple AMP subclasses? How do I get all of them to listen on the same port? Is this what the mysterious "routes" feature I've been hearing about does? Right now I'm doing it like this, which works but isn't very pretty or nice: user.py: ----- class Register(amp.Command): arguments = […] response = […] errors = […] def register(self, …): # do actual registering behavior here ----- api.py: ----- from project import auth class API(amp.AMP): register = auth.Register.responder(auth.register) ----- cheers lvh

2 1

[Twisted-Python] Cannot install Twisted version 8 through PIP
by Pascal Briet 14 May '12

14 May '12

Hi, We're having some troubles today, because it seems that old packages of Twisted are not available anymore. We are currently relying on Twisted 8.2.0. pip install twisted==8.2.0 is failing (first version available seems to be 9.0.0) The package was still available last Friday. Is there a critical reason explaining that it has been removed from the servers ? Thanks very much, Best regards, -- Pascal BRIET Software engineer Optimor Labs http://www.billmonitor.com

2 4

[Twisted-Python] question : json.loads failed using LineReceiver data
by bino oetomo 14 May '12

14 May '12

Dear All .. I'm trying to received json formated text using LineReceiver Here is my code ----START---- class ArduinoReceiver(LineReceiver): def __init__(self): print 'INIT : ArduinoReceiver' def lineReceived(self, line): line = line.strip() print 'Received line = '+line if 'Arduino' in line : return self.linedict=json.loads(line) ----STOP----- but I got error msg in the log as : ----START---- 2012-05-14 15:42:00+0700 [-] Received line = '{"a_flw_fwd":12,"a_flw_rtr":5029,"a_rpm":519,"b_flw_fwd":23,"b_flw_rtr":8,"b_rpm":913}' 2012-05-14 15:42:00+0700 [-] Unhandled Error Traceback (most recent call last): File "/usr/local/lib/python2.6/dist-packages/Twisted-11.1.0_r33425-py2.6-linux-i686.egg/twisted/python/log.py", line 84, in callWithLogger return callWithContext({"system": lp}, func, *args, **kw) File "/usr/local/lib/python2.6/dist-packages/Twisted-11.1.0_r33425-py2.6-linux-i686.egg/twisted/python/log.py", line 69, in callWithContext return context.call({ILogContext: newCtx}, func, *args, **kw) File "/usr/local/lib/python2.6/dist-packages/Twisted-11.1.0_r33425-py2.6-linux-i686.egg/twisted/python/context.py", line 118, in callWithContext return self.currentContext().callWithContext(ctx, func, *args, **kw) File "/usr/local/lib/python2.6/dist-packages/Twisted-11.1.0_r33425-py2.6-linux-i686.egg/twisted/python/context.py", line 81, in callWithContext return func(*args,**kw) --- <exception caught here> --- File "/usr/local/lib/python2.6/dist-packages/Twisted-11.1.0_r33425-py2.6-linux-i686.egg/twisted/internet/posixbase.py", line 586, in _doReadOrWrite why = selectable.doRead() File "/usr/local/lib/python2.6/dist-packages/Twisted-11.1.0_r33425-py2.6-linux-i686.egg/twisted/internet/_posixserialport.py", line 62, in doRead return fdesc.readFromFD(self.fileno(), self.protocol.dataReceived) File "/usr/local/lib/python2.6/dist-packages/Twisted-11.1.0_r33425-py2.6-linux-i686.egg/twisted/internet/fdesc.py", line 94, in readFromFD callback(output) File "/usr/local/lib/python2.6/dist-packages/Twisted-11.1.0_r33425-py2.6-linux-i686.egg/twisted/protocols/basic.py", line 564, in dataReceived why = self.lineReceived(line) File "./kapal02.tac", line 48, in lineReceived self.linedict=json.loads(line) File "/usr/lib/python2.6/json/__init__.py", line 307, in loads return _default_decoder.decode(s) File "/usr/lib/python2.6/json/decoder.py", line 319, in decode obj, end = self.raw_decode(s, idx=_w(s, 0).end()) File "/usr/lib/python2.6/json/decoder.py", line 338, in raw_decode raise ValueError("No JSON object could be decoded") exceptions.ValueError: No JSON object could be decoded ----STOP----- I try to do json.loads based on received msg using python console, and it work : ---START--------- bino@bino-desktop:/var/log/rabbitmq$ python Python 2.6.6 (r266:84292, Sep 15 2010, 15:52:39) [GCC 4.4.5] on linux2 Type "help", "copyright", "credits" or "license" for more information. >>> import json >>> aa='{"a_flw_fwd":12,"a_flw_rtr":5029,"a_rpm":519,"b_flw_fwd":23,"b_flw_rtr":8,"b_rpm":913}' >>> mydict=json.loads(aa) >>> print mydict['a_flw_fwd'] 12 ---STOP---------- Kindly please tell me why the 'json.loads' is failed in my tac file while it work in python console. Sincerely -bino-

3 2

[Twisted-Python] Weekly Bug Summary
by exarkun＠twistedmatrix.com 12 May '12

12 May '12

1 0

[Twisted-Python] Weekly Bug Summary
by exarkun＠twistedmatrix.com 05 May '12

05 May '12

1 0

[Twisted-Python] feedback on next version of Fireshark using twisted framework....
by Stephan 03 May '12

03 May '12

Hi I have an open source project that is pretty well-known in the security community. http://www.fireshark.org it's a service wrapper that runs a headless version of firefox to visit malicious sites to store telemetry data. The old service used PERL for threading (very painful), so a while ago I changed everything to python using the twisted framework. the service's job is to launch a choose a firefox profile, launch the process and handle closes and crashes approprietly. the launch of version 2.5 is next week but I sure could use some feedback on the service code before releasing it. Keep in mind I haven't finishing commenting for public release. here are the files for the new service: 1) fireshark.py http://pastebin.mozilla.org/1614427 this is the main service. opens up a port to listen on, and uses the following two classes to manage profiles and launch a firefox process. 2) firesharkprofilemanager.py http://pastebin.mozilla.org/1614428 this is the firefox profile manager, it manages what firefox profiles are available. 3) firefoxprocess.py http://pastebin.mozilla.org/1614431 this is the firefox process class, to check if the launched process has been killed as well, as check if the logging from the internal plugin (another part of the fireshark project) has completed logging. Thanks in advance! Twisted has been a great Framework! Stephan

4 4

[Twisted-Python] (no subject)
by Dmitriy Komarov 03 May '12

03 May '12

Hi All, Our team is setting up Twisted to access Mercurial over SSH. SSH connection, key exchange, and receiving large amount of data from the client work nicely, but sending server data back to the client ends up with a PuTTY Fatal Error "Incoming packet was garbled on decryption" at a random point. If plink compression is disabled, the error happens very rarely, but overall SSH performance becomes unacceptable. If plink uses compression, the error occurs within 1-10 seconds from starting data download. To make things more hectic, on a rare occasion, PuTTY reports "Incorrect MAC received on packet" instead of "garbled on decryption". If anyone had a similar issue before, I'd appreciate any pointers on resolving or avoiding it. Sincerely, - Dmitriy

5 7

[Twisted-Python] Releasing 12.1
by Itamar Turner-Trauring 01 May '12

01 May '12

Once 12.1 is out, we'll be able to drop Python 2.5 support in trunk. This will make life easier for one of our Google Summer of Code students who will be working on the start of Python 3 support, so it'd be good to get it done soon. In order to release 12.1, we need: 1. To finish code reviews of remaining 12.1 tickets and merge: http://twistedmatrix.com/trac/query?status=assigned&status=new&status=reope… These include two gtk3 tickets: gtk3 is new in 12.1, and I'd like to ship it bug free and feature complete. There's also a couple of tickets which will make epoll the default reactor on Linux. While not strictly necessary, they should be easy enough to get merged and it's a great feature to have in; if they become a bottleneck we can drop this and wait until the next release. 2. A volunteer to do the release. Any takers? -Itamar

1 0