Mailman 3 April 2005 - Twisted

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

06 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] 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

Re: [Twisted-Python] blocking and threads
by Joachim Boomberschloss 04 May '05

04 May '05

Thanks, how embarassing... I suggest adding it to the "using threads" howto (I'd do it myself if I knew how). Another idea: make an asynchronous file-handling module that wraps Python's file IO with something that has a deferred-oriented interface. Is there already something like that too? Joe --- Jp Calderone <exarkun(a)divmod.com> wrote: > On Wed, 27 Apr 2005 05:49:01 -0700 (PDT), Joachim > Boomberschloss <boomberschloss(a)yahoo.com> wrote: > >Hi all, > > > >I am just wondering: from the Twisted how-tos, it > >appears that doing anything that could possibly > take > >arbitrarily long to execute should not be done in > the > >reactor's main thread; i.e. it should be done using > an > >asynchronous library (such as Twisted's network > >communication facilities), or in a different > thread, > >using the reactor's thread pool. > > > >So it would seem that many things that may be > >considered "primitive" in Python, such as file IO, > >require some kind of patching if they are to be > >immediately usable by a Twisted application. I came > up > >with the following solution, which enables calling > any > >function in a different thread with a deferred > >interface; I just wanted to make sure that I'm not > >completely missing some point: > > > >def deferToThread(func, *args, **kargs): > > """executes the given function in a thread, and > >passes the return value to the deferred we > return""" > > d = defer.Deferred() > > reactor.callInThread(_calledInThread, d, func, > *args, > >**kargs) > > return d > > > >def _calledInThread(d, func, *args, **kargs): > > try: > > retval = func(*args, **kargs) > > except Exception, x: > > reactor.callFromThread(d.errback, x) > > else: > > reactor.callFromThread(d.callback, retval) > > > > Looks like you've got a pretty firm understanding. > The one thing you did miss is the > twisted.internet.threads module, which provides the > deferToThread function. > > Jp > > _______________________________________________ > Twisted-Python mailing list > Twisted-Python(a)twistedmatrix.com > http://twistedmatrix.com/cgi-bin/mailman/listinfo/twisted-python > __________________________________________________ Do You Yahoo!? Tired of spam? Yahoo! Mail has the best spam protection around http://mail.yahoo.com

5 5

[Twisted-Python] Newbie reactor.crash()/reactor.stop() question
by T Barket 02 May '05

02 May '05

Hello, I have set up a server and client with perspective broker and can successfully move data back and forth between them. however, i want to use the client interactively at the python prompt. ie, i want to create a client object, make a request of the server and get the data returned to me. then i want to do some work with the data interactively at the python command prompt, until i need new data. then i want to use the client again to make another request of the server, etc. i have read i cannot stop and restart a reactor (which is what i would like to do on the client side). then i found out about reactor.crash(). that seems to work fine, which i think allow me to put the reactor on hold so i can get back to the command prompt and do some work until i need to make another request to the server. At least I can get it to work as expected. however, i now dont know how to call "reactor.stop()" before I exit python. once the client finishes, it sets a "reactor.crash()". now when I try to call reactor.stop(), i get the following error that the reactor isnt running: raise RuntimeError, "can't stop reactor that isn't running" RuntimeError: can't stop reactor that isn't running so now i cant stop the reactor using reactor.stop(). and furthermore, when i try to exit the python command prompt (having run reactor.crash() but not reactor.stop()), the python command prompt hangs instead of exiting normally and I have to kill its process. is there any way to exit python normally when the reactor has been put into a reactor.crash()? im using twisted 2.0 and python 2.4.1 on windows xp sp2. TIA, Tom

3 2

[Twisted-Python] Pass error (exception) message to XMLRPC client
by Remy C Cool 30 Apr '05

30 Apr '05

Hello, I've searched on the (Twisted) website and mailinglists, but failed to find the answer to my question. Is is possible to pass the original exception code/message to the XMLRPC client? When an exception occurs, the client get's a general 'error occured' message and I would like to be able to let the client know what went wrong. How can I accomplish this with Twisted? BTW I'm working with the latest Twisted 1.x release (Debian) Regards, Remy Cool

5 8

[Twisted-Python] P2P Discovery
by van Aswegen, Marinus (ZA - Johannesburg) 30 Apr '05

30 Apr '05

Hi Guys I've got a basic UDP broadcaster working now to inform other P2P clients. This obviously only works on the local segment. Any suggestions how I could broadcast outside the segment. Multicast in python seems quite clunky and unreliable ? Regs /marinus Important Notice: This email is subject to important restrictions, qualifications and disclaimers ("the Disclaimer") that must be accessed and read by visiting our website and viewing the webpage at the following address: http://www.deloitte.com/za/disclaimer. The Disclaimer is deemed to form part of the content of this email in terms of Section 11 of the Electronic Communications and Transactions Act, 25 of 2002. If you cannot access the Disclaimer, please obtain a copy thereof from us by sending an email to ClientServiceCentre(a)Deloitte.co.za.

3 2

[Twisted-Python] Clossing one TCP connection
by Carolina Ardohain 28 Apr '05

28 Apr '05

I launch several connections using an object like this class MyConnection() def __init__(host, port, factory): self.factory = factory self.connector = reactor.connectTCP(host, port, factory) I create several connections m1 = MyConnection('host1', 8000, MyFactory()) m2 = MyConnection('host2', 8000, MyFactory()) reactor.run() Now I want to create a method onClose that close the connection, something like reactor.stop() but that dont close the whole application.

3 3

Re: [Twisted-Python] blocking and threads
by Ed Suominen 27 Apr '05

27 Apr '05

On Wednesday 27 April 2005 08:31 am, Jp Calderone <exarkun(a)divmod.com> wrote: > On Wed, 27 Apr 2005 07:07:15 -0700 (PDT), Joachim Boomberschloss <boomberschloss(a)yahoo.com> wrote: > >Thanks, how embarassing... I suggest adding it to the > >"using threads" howto (I'd do it myself if I knew > >how). Another idea: make an asynchronous file-handling > >module that wraps Python's file IO with something that > >has a deferred-oriented interface. Is there already > >something like that too? > > There's not, yet (although likely the VFS project Chris Armstrong, > Andy Gayton, Tim Stebbing, and Andrew Bennetts recently started on > will probably encompass this at some point). > > For many projects, asynchronous disk file i/o isn't actually that > important. They either only do a little bit of it, or they can > fragment it over multiple reactor iterations manually without too > much effort. This is probably the main reason there isn't something > like adbapi for files in Twisted already. > > For projects that do a lot of disk IO (like an ftp server, say :), > or have latency requirements more stringent than average, an > asynchronous file API would definitely be useful. Also if files are being accessed via NFS or SSH.

1 0

[Twisted-Python] Non-blocking webserver - what am I doing wrong?
by Dave Gray 27 Apr '05

27 Apr '05

I'm trying to get a simple webserver working using twisted. It works, to some extent, serves pages and all, but it blocks until the reactor.callLater(...) is done... what am I doing wrong? Dave # CODE from twisted.web import server from twisted.web.resource import Resource from twisted.internet import reactor, defer import pprint dump = pprint.PrettyPrinter(indent=4).pformat def requestDebug(r): r.write('<pre>'+ dump(r.headers) +'</pre>') reactor.callLater(5, r.finish) class NonBlock(Resource): """ I should be a non-blocking resource that takes 5s to load. Instead, each request waits for any others to finish. """ def getChild(self, path, request): return self isLeaf=False def render_GET(self, request): d = defer.Deferred() d.addCallback(requestDebug) d.callback(request) return server.NOT_DONE_YET from twisted.application import service, internet application = service.Application("nonblock") internet.TCPServer(8080, server.Site(NonBlock()) ).setServiceParent(application)

3 5

[Twisted-Python] XMLRPC server help neede
by Roland Hedberg 27 Apr '05

27 Apr '05

-----BEGIN PGP SIGNED MESSAGE----- Hash: SHA1 Hi ! I have a application, a sort of routing system, where nodes communicate using XML-RPC. It works but to my mind it's too slow. Now, changing to some other protocol then XML-RPC is not an option presently, so I don't want to know what other protocol that would do it much better. I might eventually get there but not at this point in time. One reason for the slowness is that I'm not able to get the server to reply to the client when I would like it to. This is how it should work: 1) server gets a message from the client, checks that it is well formed 2) server determins if it knows what to do with the message 3) server performs the appropriate action on the message Now, if the the message is not well formed or if the server does not know what to do with the packet it should reject it. So far everything works as planned. If the packet is well formed and the server knows what to do with it, it should reply to the client and then perform the action. My problem is how I would go about doing this. Conceptually I could imaging having a workqueue where I would place the message and then from the point of view of the client-sever communication just forget about it. Anyone who has done anything similar or has an idea on how to do this ? - -- Roland -----BEGIN PGP SIGNATURE----- Version: GnuPG v1.4.1 (Darwin) iD8DBQFCb5I6Vxk7TEwZBFwRAmPLAJ0YcIRPRsqSbb7f5cxNBp4y+aXdwQCgmad7 ZFagUsqKhSRgrWr2LDt+iw4= =/uhT -----END PGP SIGNATURE-----

2 1