Mailman 3 April 2009 - Twisted

[Twisted-Python] Twisted Python 0.7.0 Prerelease Testing
by Glyph Lefkowitz Aug. 5, 2021

Aug. 5, 2021

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. ______ __ __ _____ _ _ | ____ | \_/ |_____] |_____| |… [View More]

4 5

[Twisted-Python] Real Viagra Professional - for real sex pros
by Tamika May 1, 2019

May 1, 2019

<!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;"… [View More]> <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> [View Less]

8 10

[Twisted-Python] regarding xml elements
by Raj kumar Oct. 2, 2013

Oct. 2, 2013

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 … [View More]

9 14

[Twisted-Python] Get IP of connecting client in XMLRPC server
by Remy C. Cool April 28, 2013

April 28, 2013

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 … [View More]

3 3

[Twisted-Python] An XMPP client with SSL support
by Pedro Sanchez Sept. 18, 2009

Sept. 18, 2009

Hello, I have a sample XMPP client with the following structure: from twisted.words.protocols.jabber import client, jid from twisted.internet import reactor ... factory = client.basicClientFactory(myJid, myPasswd) reactor.connectTCP(host,5222,factory) reactor.run() It works well, I can connect to the XMPP server. But I would appreciate if some one could give me some hints on what's required to get the client to connect using a secure SSL link. Thanks, -- Pedro

3 3

[Twisted-Python] Twisted meetup/discussion at EuroPython?
by Terry Jones June 30, 2009

June 30, 2009

I was thinking it would be nice to have a Twisted interest group meetup at EuroPython (June 30 - July 2) http://www.europython.eu Would people be interested in attending? Does someone more qualified want to organize it? Are any Twisted developers planning to be at EuroPython? The submissions page http://www.europython.eu/submission/ has a category for Interest Group Meeting or Discussion. I'm thinking more along the lines of the former - that it would be nice to be better connected to other … [View More]

6 5

[Twisted-Python] Available for short-term Twisted consulting, e.g. training, design (but not coding)
by Itamar Shtull-Trauring May 22, 2009

May 22, 2009

Need help with Twisted, distributed systems or or just plain old software architecture? Due to a repetitive strain injury I am unable to type much (though I am slowly improving), and so I'm taking time off of work to recover. As a result I am available for short-term consulting until I recover, e.g. training or design work, assuming of course it does not involve any typing. I've worked on Twisted itself, as well as projects ranging from high-performance distributed C++ servers, to an access … [View More]

2 1

[Twisted-Python] Twisted plugins and py2exe
by Gabriel Rossetti May 10, 2009

May 10, 2009

Hello everyone! I used py2exe on a Twisted app of mine and I get this exception : Traceback (most recent call last): File "proj\service.pyc", line 1308, in connectionMade File "proj\service.pyc", line 1640, in _register File "proj\service.pyc", line 504, in loadPlugins File "twisted\plugin.pyc", line 200, in getPlugins --- <exception caught here> --- File "twisted\plugin.pyc", line 179, in getCache exceptions.AttributeError: ZipPath instance has no attribute 'setContent' … [View More]

3 6

Re: [Twisted-Python] cx_Oracle, Twisted - rollback failed
by Steve Lewis May 3, 2009

May 3, 2009

> Is there some way it can determine that the connection has been lost aside > from trying the rollback (and is compatible with other DB-API 2.0 modules)? > > Jean-Paul Oops, I actually did see my message going through now. Sorry for the duplicate. To answer your question, I was under the impression that the cp_reconnect would check to see if the connection existed already. Is there a way to have it check that query before rolling back? I'm guessing other databases/apis don't … [View More]

2 1

[Twisted-Python] subclassing and mixing protocol.ReconnectingClientFactory and pb.PBClientFactory
by Fabrizio Mancini April 30, 2009

April 30, 2009

Hi, i've implemented a pb client by writing a class which inherits from object and a class which inherits from ReconnectingClientFactory and PBClientFactory. Till now it's all ok, the client detects the disconnection and try to reconnect with an exponential delay if the connection is not immediatly reestabilished. The calls to the callRemote("get_item") method are repetitive, but for sake of simplicity i've cut off the code that controls if there is already another call running. The problem: i'… [View More]d like to manage something like the clientConnectionMade method when the client reconnect (thanks to the ReconnectingClientFactory) after a disconnection and launch again the MypbClient.connect() method as i do in the "if __name__ " statement, but i can't guess how to do it. This is the code i'm using. Thanks in advanche, any help appreciated, and hope to have been clear enough Fabrizio class MypbClient(object): def __init__(self): self.clientfactory = MypbClientFactory() self._scheduledCall] = task.LoopingCall(self.get_item) self._scheduledCall].start(10, False) def connect(self): reactor.connectTCP(server_ip, server_port, self.clientfactory) self.rootObj = self.clientfactory.getRootObject() self.rootObj.addCallback(self.initiateChain).addErrback(self._eb) def initiateChain(self, broker): self.broker = broker self.d = self.broker.callRemote("get_item") self.d.addCallback(self.got_item).addErrback(self._eb) def get_item(self, result): self.d = self.broker.callRemote("get_item") self.d.addCallback(self.got_item).addErrback(self._eb) def got_item(self, record): self.op = doSomethingWith(record) #returns a deferred class MypbClientFactory(pb.PBClientFactory, protocol.ReconnectingClientFactory): def __init__(self): pb.PBClientFactory.__init__(self) def clientConnectionMade(self, broker): self.resetDelay() pb.PBClientFactory.clientConnectionMade(self, broker) def clientConnectionFailed(self, connector, reason): pb.PBClientFactory.clientConnectionFailed(self, connector, reason) if self.continueTrying: self.connector = connector self.retry() def clientConnectionLost(self, connector, reason, reconnecting=1): pb.PBClientFactory.clientConnectionLost(self, connector, reason, reconnecting=reconnecting) protocol.ReconnectingClientFactory.clientConnectionLost(self, connector, reason) if __name__ == "__main__": dpc = MypbClient() dpc.connect() reactor.run() [View Less]

1 0

[Twisted-Python] cx_Oracle, Twisted - rollback failed
by Steve Lewis April 30, 2009

April 30, 2009

(If anyone gets this twice, apology in advance. I think I jumped the gun in sending the email before I got my acknowledge welcome email for the list.) It looks like the latest version 8.2 tries to rollback without seeing if the connection is even open or not: def rollback(self): if not self._pool.reconnect: self._connection.rollback() return try: self._connection.rollback() curs = self._connection.cursor() curs.… [View More]

1 0

[Twisted-Python] handling CTRL-C
by Fabrizio Mancini April 30, 2009

April 30, 2009

Hi, i know twisted already manage CTRL-C keystroke, but i'd like to add some other action when CTRL-C is pressed. I've implemented a perspective broker server, which have a DeferredQueue and a lot of elements in it. I'd like to write to a file all those elements before the program shuts down. Is there a way to handle this kind of situation? Thanks in advance Fabrizio

3 4

[Twisted-Python] Catching exception on a Serial Connection
by Nestor A. Diaz April 30, 2009

April 30, 2009

Hello, i am newbie to twisted, i am trying to find a way to catch exceptions raised from a protocol over a serial line, like the twisted.protocol.gps.zodiac, i see the demo script, on the twisted website: http://twistedmatrix.com/projects/core/documentation/examples/gpsfix.py but i don't figure yet how to handle exceptions coming from the protocol since i didn't figure how to register a callback for an error, cause i haven't found a way to create a deferred object for a serial connection.… [View More]

2 1

[Twisted-Python] deferToThread help
by Minesh Patel April 29, 2009

April 29, 2009

Sorry if this is a newbie question. I have a blocking function that I defer to thread, let's say 'foo' and I would like to add a callback that gets called after say 10 minues after Thread finishes def foo(): # Blocks for a while def bar(): # Do some stuff d = threads.deferToThread(foo) d.addCallback(bar) # How can I add timing to the callback??? Currently I have the following code which works but doesn't account for the threads execution time: reactor.callInThread(self.bootIso, self.… [View More]

2 1

Re: [Twisted-Python] cx_Oracle, Twisted - rollback failed
by Jean-Paul Calderone April 29, 2009

April 29, 2009

On Wed, 29 Apr 2009 10:39:30 -0700 (PDT), Steve Lewis <spiritualmechanic(a)yahoo.com> wrote: >It looks like the latest version 8.2 tries to rollback without seeing if the connection is even open or not: > > def rollback(self): > if not self._pool.reconnect: > self._connection.rollback() > return > > try: > self._connection.rollback() > curs = self._connection.cursor() > curs.execute(… [View More]

1 0

[Twisted-Python] cx_Oracle, Twisted - rollback failed
by Steve Lewis April 29, 2009

April 29, 2009

It looks like the latest version 8.2 tries to rollback without seeing if the connection is even open or not: def rollback(self): if not self._pool.reconnect: self._connection.rollback() return try: self._connection.rollback() curs = self._connection.cursor() curs.execute(self._pool.good_sql) curs.close() self._connection.commit() return except: log.err(None, "… [View More]

1 0

[Twisted-Python] Polling from Twisted
by Juanjo Conti April 28, 2009

April 28, 2009

Hi, this is my first mail to the list. I am writing a server using Twisted, extending LineOnlyReceiver. In it I maintain a list of clients connected. I'd like to poll every client for certain status information every 30 seconds. Which is the correct approach to implement this? Thanks in advance, -- Juanjo Conti

4 6

[Twisted-Python] Upcoming Twisted Sprint in Cambridge, MA
by Jean-Paul Calderone April 27, 2009

April 27, 2009

Hello All, I'd like to organize another Twisted sprint in Cambridge, MA in May. As with previous sprints, this is an all day event, most likely hosted at the Divmod office in Porter Square, for Twisted hacking. Chris Armstrong has raised plugin system improvements as a possible topic. Other topics are welcome as well, of course. It's been a couple months since our last sprint. I think it would be nice to have a sprint early in May and another one late in May. How do people feel about May … [View More]

3 3

[Twisted-Python] xmlrpc - Possable failure to understand async concept
by Tim Hughes April 26, 2009

April 26, 2009

I am trying to understand this concept of async methods and i thought I had it cracked with the code below but it doesn't seem to work as all the calls to the xmlrpc server return one after the other like this: Success:I started at Fri Apr 24 01:12:23 2009 and i slept 5 seconds then woke at Fri Apr 24 01:12:28 2009 Success:I started at Fri Apr 24 01:12:28 2009 and i slept 5 seconds then woke at Fri Apr 24 01:12:33 2009 Success:I started at Fri Apr 24 01:12:33 2009 and i slept 5 seconds then … [View More]woke at Fri Apr 24 01:12:38 2009 Success:I started at Fri Apr 24 01:12:38 2009 and i slept 5 seconds then woke at Fri Apr 24 01:12:43 2009 Success:I started at Fri Apr 24 01:12:43 2009 and i slept 5 seconds then woke at Fri Apr 24 01:12:48 2009 Success:I started at Fri Apr 24 01:12:48 2009 and i slept 5 seconds then woke at Fri Apr 24 01:12:53 2009 Am I completly missing the point here or is there something incorrect with my code. AT first I thought it was because the sleep was shutting the whole thing down (probably is) so I have also tried it with a long running network call instead of the time.sleep() and have the same issue. Can someone please point me in the right direction or give a bit of criticism of the code concepts/thought processes =========== Server ======================== #!/usr/bin/env python from twisted.web import xmlrpc, server from twisted.internet.defer import Deferred from twisted.internet import reactor, threads import time class MyServer(xmlrpc.XMLRPC): def blocking_method(self, duration=5): """block the instance for a specified duration""" started = time.asctime() time.sleep(duration) data = "I started at %s and i slept %d seconds then woke at %s" % (started, duration, time.asctime()) return data # def xmlrpc_block_thread(self, duration=10): # """ pass to blocking method using thread """ # return threads.deferToThread(self.blocking_method, duration) # # def xmlrpc_block(self, duration=10): # """ pass to blocking method using defered """ # d = Deferred() # d.callback(self.blocking_method(duration)) # return d def xmlrpc_block_fixed(self, duration=5): """ pass to blocking method using defered """ d = self.blocking_method_fixed(duration) # return a defered d.addCallback(self.printdata) d.addErrback(self.printerror) return d def blocking_method_fixed(self, duration=5): d = Deferred() d.callback(self.blocking_method(duration)) return d def printdata(self, val): return 'Success:'+val def printerror(self, val): return 'Error:'+val if __name__ == '__main__': r = MyServer() reactor.listenTCP(8080, server.Site(r)) reactor.run() =============================================== ========== Client ================================ #!/usr/bin/env python import xmlrpclib import datetime import sys proxy = xmlrpclib.ServerProxy("http://localhost:8080/", allow_none=True) print "%s" % str(proxy.block_fixed(5)) =============================================== Tim Hughes mailto:thughes@thegoldfish.org [View Less]

4 4

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

April 26, 2009

1 0

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

April 26, 2009

1 0

Re: [Twisted-Python] Transparent pooling of deferreds to be fired upon another deferred firing
by Terry Jones April 23, 2009

April 23, 2009

BTW, below is a version of my code from yesterday that works on class methods. I didn't write the __get__ code, but took it from a decorator tutorial on the web. This version works with standalone functions, and with class methods that also use @inlineCallbacks. So you can do class MyClass(object): @DeferredPooler @defer.inlineCallbacks def xxx(self, ...): d = funcReturningADeferred() d.addCallbacks(...) yield d and it works. … [View More]

1 0

Re: [Twisted-Python] Re: Transparent pooling of deferreds to be fired upon another
by Terry Jones April 23, 2009

April 23, 2009

Hi Andrew >>>>> "Andrew" == Andrew Francis <andrewfr_ice(a)yahoo.com> writes: Andrew> Why can't you have the callbacks attached to the deferred, share a flag? Andrew> global flag Andrew> def callback(....): Andrew> global flag Andrew> if flag == False: Andrew> flag = True Andrew> # do body of function Andrew> else: Andrew> # don't do anything - flag have been previously fired Andrew> If I understand what is happening, this … [View More]

1 0

[Twisted-Python] Re: Transparent pooling of deferreds to be fired upon another
by Andrew Francis April 23, 2009

April 23, 2009

Hi Terry: --- On Thu, 4/23/09, twisted-python-request(a)twistedmatrix.com > Suppose I have a function called alertSupervisor that takes > a string message for the supervisor and which returns a deferred. I > want to be able to call that function from anywhere in my code, and I > always want to get a deferred back, but if there's already a call in >progress to tell the supervisor the same thing then I don't want to bug >him/her by sending another message, but I do want to … [View More]

1 0

[Twisted-Python] Transparent pooling of deferreds to be fired upon another deferred firing
by Terry Jones April 23, 2009

April 23, 2009

I have a need to make sure that a deferred-returning function is not called multiple times, but I want to be able to write code without having to worry about that. To be more concrete: Suppose I have a function called alertSupervisor that takes a string message for the supervisor and which returns a deferred. I want to be able to call that function from anywhere in my code, and I always want to get a deferred back, but if there's already a call in progress to tell the supervisor the same … [View More]thing then I don't want to bug him/her by sending another message, but I do want to know when the original call fires. So code fragment A calls d = alertSupervisor("We have a problem in the boiler room!") and before the deferred has fired, code fragment B notices the same underlying problem, and also calls d = alertSupervisor("We have a problem in the boiler room!") I want A and B's deferreds to both be called back with the result/failure. If I can write it like the above it has the advantage of looking like regular code and no-one has to think about what's going on. Underneath there's a pool of deferreds whose firing is triggered by the firing of the single original deferred. Note that I specifically only want to pool deferreds like this if there is a call already underway (i.e., the original deferred has not fired). That implies you could not pool calls to functions that return via defer.succeed or defer.fail since those deferreds have already fired. If someone calls alertSupervisor("We have a problem in the boiler room!") and their deferred fires, then a subsequent call to alertSupervisor("We have a problem in the boiler room!") should get through to the supervisor, as per normal. This may all seem a bit esoteric, but I have several uses for it. In particular when the service providing alertSupervisor lives on one machine and is being called via RPC by A and B, both on separate machines. As for how to nicely make RPC calls like this, see Thrift [1] which now has built-in support for Twisted. Here's a first cut at a solution: from twisted.internet import defer from twisted.python import failure class DeferredPooler(object): def __init__(self, func): self.pool = {} self.func = func def _callOthers(self, result, key): if isinstance(result, failure.Failure): for d in self.pool[key]: d.errback(result) else: for d in self.pool[key]: d.callback(result) del self.pool[key] return result def __call__(self, *args, **kwargs): key = (args, hash(tuple(sorted(kwargs.items())))) if key in self.pool: d = defer.Deferred() self.pool[key].append(d) return d else: self.pool[key] = [] d = self.func(*args, **kwargs) assert isinstance(d, defer.Deferred) d.addBoth(self._callOthers, key) return d You use the class transparently, via a decorator: from twisted.internet import reactor @DeferredPooler def x(*args, **kwargs): print 'x called: args = %r, kwargs = %r' % (args, kwargs) d = defer.Deferred() reactor.callLater(2, d.callback, args) return d def printer(what): print 'printer received:', what def stop(_): reactor.stop() if __name__ == '__main__': d1 = x('fred') d1.addCallback(printer) d2 = x('fred') d2.addCallback(printer) d = defer.DeferredList([d1, d2]) d.addBoth(stop) reactor.run() If you run this you'll see x is called only once, but d1 and d2 are each fired properly. For more Twisted pleasure/pain, you can also try out funky things like: d1 = x('fred') d1.addCallback(printer) d1.addCallback(x) d1.addCallback(printer) d2 = x('fred') d2.addCallback(printer) d2.addCallback(x) d2.addCallback(printer) Here there are 4 calls to x, but only 2 get through. I could say more, as usual. But I'll wait to see if there's any reaction. One issue to consider further is the simplistic use of hash. Terry [1] Thrift: http://incubator.apache.org/thrift/ [View Less]

1 0