Mailman 3 April 2007 - 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] 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] Reconnecting PB Client
by Don Smith 12 Sep '07

12 Sep '07

Does anyone have some example code for building a reconnecting PB client? This is what I have now: from twisted.spread import pb from twisted.internet import reactor from twisted.python import util events = pb.PBClientFactory() reactor.connectTCP("localhost", 8789, events) queue = events.getRootObject()

3 2

[Twisted-Python] Re: [Twisted-commits] r20094 - Add a spewing decorator which stores all of the function and method calls
by Jean-Paul Calderone 30 Apr '07

30 Apr '07

On Sat, 28 Apr 2007 23:37:57 -0600, Jonathan Lange <jml(a)wolfwood.twistedmatrix.com> wrote: >Author: jml >Date: Sat Apr 28 23:37:56 2007 >New Revision: 20094 > >Modified: > branches/spew-decorator/twisted/python/util.py > branches/spew-decorator/twisted/test/test_util.py > >Log: >Add a spewing decorator which stores all of the function and method calls >within a function in a structured data object. > What ticket is this associated with? Also, there is already an improved spew function in Epsilon which does nice things like track call depth and exception propagation and call arguments. Jean-Paul

4 9

[Twisted-Python] UDP + TCP + Serial
by Roel Schroeven 30 Apr '07

30 Apr '07

I'm looking for a way to combine serial input with UDP (and possibly TCP) communication. Currently I have a very simple quick-and-dirty script using pyserial and the socket module without Twisted that reads line-based data from a serial port and sends it out using UDP. It works very well, but functional and reliability requirements are growing and I'm looking for a better design. New functionality that we'll need is connection to a database, two-way network communication to control the program while it's running, and perhaps the ability to use encrypted connections for the output data. Twisted seems nice, but apart from a few simple hello-world-style test I don't have any experience with it. It doesn't seem too difficult though, except for one thing: I can't find any concrete information on how to combine serial communication and network communication. What reactor do I need? How do I initialize it? How can I make it listen to both a serial port and one or more UDP and/or TCP ports? I need to do this on Linux, but it would be nice to have it working on Windows too. Many thanks, Roel -- If I have been able to see further, it was only because I stood on the shoulders of giants. -- Isaac Newton Roel Schroeven

3 3

[Twisted-Python] Looking for an answer...
by Chaz. 29 Apr '07

29 Apr '07

I have programmed very traditional systems passed on fork and pthreads and have used state machine systems. Last year I started working with Twisted Matrix. Each has their appropriate application. I started thinking about how to implement the following in Twisted, and realized I don't know if it is possible. I thought I would ask the list to find out if someone can come up with an answer. Suppose I have a sequence of instructions, some of which can take a long time. For example in a non-Twisted Matrix system I would do: ....do some computation.... proxy = xmlrpc.Proxy("http://....") proxy.CallRemote(....) ... take the results of the CallRemote and use them... In this example I assume CallRemote() only returns a result when it has completed. In the Twisted Matrix system I would do something like: ...do some computation.... proxy = twisted.web.xmlrpc.Proxy("http://...") defer = proxy.CallRemote(...) defer.addErrback(fcs_storeErr,...) defer.addCallback(fcs_storeDone,...) And I would define fcs_StoreErr() and fcs_storeDone(). In fcs_storeDone() I would take the results from the CallRemote() and process them. My question is easy (the answer might be hard): Can I emulate the non-Twisted example in the Twisted Matrix system. In other words can I create something like CallRemote() which returns only there is a result to process and get away from having to explicitly use a defer? Peace, Chaz

2 1

[Twisted-Python] Weekly Bug Summary
by exarkun＠twistedmatrix.com 29 Apr '07

29 Apr '07

Bug summary ______________________ Summary for 2007-04-22 through 2007-04-29 Bugs opened: 22 Bugs closed: 12 Total open bugs: 926 (+10) |== Type Changes |== Priority Changes |== Component Changes |Defect: +3 |Highest: -4 |Conch: +7 |Enhancement: +8 |Normal: +15 |Core: +0 |Task: -1 |Low: -1 |Trial: +3 |Vfs: +1 |Web2: +0 |Website: -2 |Words: +1 New / Reopened Bugs ______________________ ===== Highest ===== [#2604] SFTP VFS adapter mishandles renaming directories (opened by jml) defect vfs http://twistedmatrix.com/trac/ticket/2604 [#2606] XMPP SASL DIGEST-MD5 authentication breaks with jabberd 2.1.4 (opened by ralphm) (CLOSED, fixed) enhancement words http://twistedmatrix.com/trac/ticket/2606 [#2609] Namespace issues with prefixes reuse in twisted.words.xish. (opened by ralphm) enhancement words http://twistedmatrix.com/trac/ticket/2609 ===== Normal ===== [#2588] Quick way of telling which release a revision came under (opened by jml) enhancement core http://twistedmatrix.com/trac/ticket/2588 [#2589] trial --help should warn of the dangers of --temp-directory (opened by jml) defect trial http://twistedmatrix.com/trac/ticket/2589 [#2590] [USE CASE] SFTP server (opened by jml) enhancement conch http://twistedmatrix.com/trac/ticket/2590 [#2591] [USE CASE] XML-RPC driven authentication (opened by jml) enhancement conch http://twistedmatrix.com/trac/ticket/2591 [#2592] [USE CASE] Responding to authentication events (opened by jml) enhancement conch http://twistedmatrix.com/trac/ticket/2592 [#2593] [USE CASE] Virtual file system for SFTP service (opened by jml) enhancement conch http://twistedmatrix.com/trac/ticket/2593 [#2594] Very very basic SCP support (opened by philmayers) enhancement conch http://twistedmatrix.com/trac/ticket/2594 [#2596] Questionable priority assigned to _allowedMethods in twisted.web2.resource.RenderMixin (opened by terrycojones) defect web2 http://twistedmatrix.com/trac/ticket/2596 [#2597] trac: TypeError: <lambda>() got multiple values for keyword argument 'asc' (opened by slamb) (CLOSED, wontfix) defect website http://twistedmatrix.com/trac/ticket/2597 [#2598] Monkey-patching support code (opened by jml) enhancement core http://twistedmatrix.com/trac/ticket/2598 [#2599] trial enhancment - rerun failures against specific revision (opened by bigdog) enhancement trial http://twistedmatrix.com/trac/ticket/2599 [#2600] dtrial - specify which machines (platforms) should be used to execute tests (opened by bigdog) (CLOSED, duplicate) enhancement trial http://twistedmatrix.com/trac/ticket/2600 [#2601] Improve plugin documentation (opened by aknuds-1) enhancement core http://twistedmatrix.com/trac/ticket/2601 [#2602] dtrial - add -exarkun option to exeucte all of your tests on exarkuns machine (opened by bigdog) (CLOSED, wontfix) enhancement trial http://twistedmatrix.com/trac/ticket/2602 [#2603] Simple API for using the conch SFTP client (opened by jml) enhancement conch http://twistedmatrix.com/trac/ticket/2603 [#2605] stdlib unittest change breaks a trial test (opened by therve) defect trial http://twistedmatrix.com/trac/ticket/2605 [#2607] conch.checks.SSHPublicKeyDatabase calls os.seteuid/os.setegid even if it's not necessary (opened by therve) enhancement conch http://twistedmatrix.com/trac/ticket/2607 [#2608] twisted.internet.qtreactor tries to import a module which never exists (opened by exarkun) defect core http://twistedmatrix.com/trac/ticket/2608 ===== Low ===== [#2595] sftp and ftp should share (possibly via adapter) same filesystem interface (opened by itamarst) enhancement conch http://twistedmatrix.com/trac/ticket/2595 Closed Bugs ______________________ ===== Highest ===== [#2574] improve twistd logging setup factoring to remove duplicate code and simplify extending it (opened by exarkun, closed by exarkun, fixed) task core http://twistedmatrix.com/trac/ticket/2574 [#1844] StringTransport should behave more like a real transport (opened by washort, closed by therve, fixed) enhancement core http://twistedmatrix.com/trac/ticket/1844 [#2585] words examples index is missing some links (opened by therve, closed by therve, fixed) enhancement website http://twistedmatrix.com/trac/ticket/2585 [#2539] Add epoll reactor to the choosing-reactor doc (opened by therve, closed by therve, fixed) enhancement core http://twistedmatrix.com/trac/ticket/2539 [#2587] twisted.conch.manhole.Manhole.__init__ passes extra arguments to parent initializer (opened by exarkun, closed by exarkun, fixed) defect conch http://twistedmatrix.com/trac/ticket/2587 [#2606] XMPP SASL DIGEST-MD5 authentication breaks with jabberd 2.1.4 (opened by ralphm, closed by ralphm, fixed) enhancement words http://twistedmatrix.com/trac/ticket/2606 [#2575] There should be a way to create a LogFile instance from a full file path (opened by therve, closed by therve, fixed) enhancement core http://twistedmatrix.com/trac/ticket/2575 ===== Normal ===== [#2597] trac: TypeError: <lambda>() got multiple values for keyword argument 'asc' (opened by slamb, closed by exarkun, wontfix) defect website http://twistedmatrix.com/trac/ticket/2597 [#2602] dtrial - add -exarkun option to exeucte all of your tests on exarkuns machine (opened by bigdog, closed by jml, wontfix) enhancement trial http://twistedmatrix.com/trac/ticket/2602 [#2600] dtrial - specify which machines (platforms) should be used to execute tests (opened by bigdog, closed by jml, duplicate) enhancement trial http://twistedmatrix.com/trac/ticket/2600 ===== Low ===== [#2580] twisted.web2.stream infinite loop (opened by gthomas, closed by gthomas, duplicate) defect web2 http://twistedmatrix.com/trac/ticket/2580 [#959 ] Generate documentation from lore automatically after checkins (opened by hypatia, closed by therve, duplicate) enhancement website http://twistedmatrix.com/trac/ticket/959

1 0

[Twisted-Python] Twisted-Goodies: asyncluster Getting Started
by Ram Peters 28 Apr '07

28 Apr '07

Is there a readme file or an example how to setup server and client and add jobs to it. If someone can share a simple example, it would be great. I think this is a good tool. I am a newb. Example would be great so the masses can hop on. Thank you.

1 0

[Twisted-Python] sAsync example.
by Arye 27 Apr '07

27 Apr '07

Hello all, I was able to run the "semi-functional Twisted XML-RPC Server" example, available on http://foss.eepatents.com/sAsync/wiki/Examples successfully. However, I have the error message below on the server side when changing the database from sqlite to postgres. Any info would be greatly appreciated. Arye. ___________________begin C:\AH\WORK\tutorials\SAsync\OrigPG>\Python24\python.exe \Python24\scripts\twistd .py -noy server.py 2007/04/27 16:41 Paris, Madrid [-] Log opened. 2007/04/27 16:41 Paris, Madrid [-] twistd 2.1.0 (C:\Python24\python.exe 2.4.4) starting up 2007/04/27 16:41 Paris, Madrid [-] reactor class: twisted.internet.selectreactor.SelectReactor 2007/04/27 16:41 Paris, Madrid [-] Loading server.py... 2007/04/27 16:41 Paris, Madrid [-] Loaded. 2007/04/27 16:41 Paris, Madrid [-] twisted.web.server.Site starting on 8080 2007/04/27 16:41 Paris, Madrid [-] Starting factory <twisted.web.server.Site instance at 0x011A7C38> 2007/04/27 16:41 Paris, Madrid [-] Traceback (most recent call last): Failure: psycopg2.ProgrammingError: no results to fetch 2007/04/27 16:41 Paris, Madrid [-] 127.0.0.1 - - [27/Apr/2007:14:41:52 +0000] "POST /RPC2 HTTP/1.0" 200 263 "-" "Twisted/XMLRPClib" 2007/04/27 17:00 Paris, Madrid [-] Received SIGINT, shutting down. 2007/04/27 17:00 Paris, Madrid [-] (Port 8080 Closed) 2007/04/27 17:00 Paris, Madrid [-] Stopping factory <twisted.web.server.Site instance at 0x011A7C38> 2007/04/27 17:00 Paris, Madrid [-] Main loop terminated. 2007/04/27 17:00 Paris, Madrid [-] Server Shut Down. ___________________end

1 0

[Twisted-Python] Load testing twistd + twisted.soap
by Matthew Glubb 27 Apr '07

27 Apr '07

-----BEGIN PGP SIGNED MESSAGE----- Hash: SHA1 Hi All, I am attempting to write a simple load test for my soap web services. I am running the application under twistd and using trial for unit tests. I understand that for a real load test, I would use a tool like ab or http_load in a more scientific environment but I want to get a quick feel for how well a twisted application stands up against low levels of load on my dev box and I feel that there is merit in setting a baseline level of performance in a unit test. I am running into problems with the following: class SOAPTestCase(BaseTestCase): url = 'http://localhost:8080/' def setUp(self): self.proxy = Proxy(self.url) def testMutipleAPCs(self): """Assert that multiple APCs succeed""" deferred = defer.Deferred() for i in range(100): d = self.testAPCTimeout() d.chainDeferred(deferred) return deferred def testAPCTimeout(self): deferred = self.proxy.callRemote('processApc', 0, self._getRandomString()) deferred.addBoth(self.APCTimeout) return deferred def APCTimeout(self, result): requestIdForApc, requestDataForApc, errorFlag, result = result self.assertEqual(result, res) self.assertTrue(isinstance(requestIdForApc, str)) self.assertEqual(id, requestIdForApc) self.assertTrue(isinstance(requestDataForApc, str)) self.assertEqual(data, requestDataForApc) self.assertTrue(isinstance(errorFlag, str)) self.assertEqual(cp.cp_base.getErrorFlag(cp.cp_base.APC, err), errorFlag) For a start, I get a lot of 'reactor left in unclean state' warnings. This number of twisted.internet.tcp.Client instances that this reports on is never usually all of them: twisted.trial.util.DirtyReactorError: THIS WILL BECOME AN ERROR SOON! reactor left in unclean state, the following Selectables were left over: <<class 'twisted.internet.tcp.Client'> to ('localhost', 8080) at 1782390> <<class 'twisted.internet.tcp.Client'> to ('localhost', 8080) at 1782150> ... In addition I get pending time calls still pending: twisted.trial.util.PendingTimedCallsError: pendingTimedCalls still pending (consider setting twisted.internet.base.DelayedCall.debug = True): <DelayedCall 24636392 [24.8269200325s] called=0 cancelled=0 Client.failIfNotConnected(TimeoutError('',))> ... Does any twisted genius have any idea what I am doing wrong? Regards, Matt m a t t h e w g l u b b ________________________________________________________________________ Z Group PLC Tel: +44 (0) 8700 111 173 Fax: +44 (0) 8707 051 393 Txt: +44 (0) 7800 140 877 Web: <http://www.zgroupplc.com/> This email and any files transmitted with it are confidential and intended solely for the use of the individual or entity to whom they are addressed. The opinions expressed in this mail are those of the author and do not necessarily represent the views of the company. If you have received this email in error please notify <service(a)zgroupplc.com> -----BEGIN PGP SIGNATURE----- Version: GnuPG v1.4.1 (Darwin) iD8DBQFGMdWcyI6MkdKPngkRAqTgAJ9I9dxz3B3EYPMfY8fY09kVqmVMdACfSqa2 wPgXzPQMX+FgKcC41oWEQA8= =V8JT -----END PGP SIGNATURE-----

1 0