Mailman 3 September 2006 - 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] 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] Reconnecting PB Client
by Don Smith Sept. 12, 2007

Sept. 12, 2007

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] Producers / Consumers and more examples tutorials?
by jarrod roberson March 13, 2007

March 13, 2007

Are there any more concrete examples or tutorials of using Producers and Consumers?

3 5

[Twisted-Python] Support for ICMP ping?
by Nicolas D. Cesar Feb. 8, 2007

Feb. 8, 2007

I've been googling if there is any 'ICMP ping' support in Twisted. I've encounter ancient replies: http://twistedmatrix.com/pipermail/twisted-python/2003-August/005542.html I wonder if today is any ICMP support. I've tried to search the source tree[1], and doesn't seem. My actual needs is creating a DeferredList with "ping-testers" for different IPs, just to check if there up or not. I know I can end up using twisted.internet.utils.getProcessOutput and calling ping, as I would normally … [View More]

5 7

[Twisted-Python] Problem: spawnProcess() never ending when installSignalHandlers=False
by Matt Feifarek Feb. 3, 2007

Feb. 3, 2007

Hello. I'm using Twisted 1.3.0 on python2.4 on an Ubuntu-Hoary x86 Linux box. I'm using twisted and spawnProcess() with a Queue structure to chain processes that need to be called (specifically, imagemagick commands). I use the "processEnded" event/method of t.i.p.ProcessProtocol to go from one task to the next. Twisted shares a python process with a multi-threaded web-app-kit (Webware) so it has to be run in a thread. This worked well on other older versions of twisted and older versions of … [View More]

6 14

[Twisted-Python] Twisted & Qt
by Ed Suominen Oct. 9, 2006

Oct. 9, 2006

I'm using the qtreactor in a GPL-but-unreleased PyQt 4.1 application of my own, and have not found any problems whatsoever with the integration of the Qt Twisted event loops. It's really a pretty slick combination. As an example and a contribution, I offer the following (GPL'd) module: http://deadbeefbabe.org/paste/1996 (syntax-highlighted version), http://foss.eepatents.com/misc/qt-twisted-dialog.py (source). It allows you to construct a non-blocking modal dialog, immediately obtaining a … [View More]

12 19

[Twisted-Python] _dumbwin32proc and PIPE_NOWAIT
by Manlio Perillo Oct. 7, 2006

Oct. 7, 2006

From the msdn: http://msdn.microsoft.com/library/default.asp?url=/library/en-us/ipc/base/s… """PIPE_NOWAIT 0x00000001 Nonblocking mode is enabled. In this mode, ReadFile, WriteFile, and ConnectNamedPipe always return immediately. Note that nonblocking mode is supported for compatibility with Microsoft® LAN Manager version 2.0 and should not be used to achieve asynchronous input and output (I/O) with named pipes. """ P.S. I really can't believe that win32 support for asynchronous I/O works … [View More]

4 11

[Twisted-Python] twistd save state does not work
by Remi Cool Oct. 2, 2006

Oct. 2, 2006

Hello, I've readied my app for use with twistd, the daemonizing works, but a tap file is not saved upon exit (kill 'cat twisted.pid'). How can I enable the save state option? BTW I'm not using the -o option with twistd ;) Second ... is it possible to disable the twisted logging if you use twistd to start the app? Or is it possible to set a log level so that only warnings and errors are shown and my log is not flooded with (TCPServer) connection messages. - Remi -

2 4

[Twisted-Python] Removing _wait from Trial
by Jonathan Lange Oct. 1, 2006

Oct. 1, 2006

So, I would like to remove _wait() from Trial and make it work like a regular Twisted application. I've had all this stuff on my brain, and have decided to dump it here for feedback. Here's how the plan looks at the moment[1]: 1. Deprecate the use of reactor-spinning things within tests. (Twisted 2.5) We've already done a great deal of work on this. spinWhile, spinUntil and util.wait have alll been deprecated and removed. #2090 (ready for review) actually issues deprecation warnings when … [View More]the reactor is iterated, crashed or stopped within a test. Unfortunately, some of Trial's cleanup code spins the reactor (see t.trial.util._Janitor.do_cleanPending). This has to go. 2. Tighten test cleanup errors. (Twisted 2.5) #2091 (ready for review) fulfils a long-standing promise. The "reactor unclean" warnings have been turned into errors. It doesn't help us remove _wait, but To remove _wait, we'll also have to remove the two calls to reactor.iterate() from _Janitor (see #2092). That means that many tests that *thought* they were cleaning up the reactor properly will find out that they weren't. We can reduce the number of errors by simulating reactor.iterate() using callLater. However, experiments show that even with this bandaid, there will still be new errors in the Twisted suite. That means we will have to either: a) surprise our users with new errors in their tests b) find some way to introduce this gradually. Obviously everyone[2] would prefer b). I've filed #2124 explaining how that might work. 3. Introduce asynchronous APIs to Trial (Twisted 2.6) Currently TestCase.run() is a blocking call. I wish it could remain a blocking call, but it can't. The branch for #1781 makes a SyncTestCase and an AsyncTestCase. run() works in SyncTestCase and doesn't work in AsyncTestCase. For AsyncTestCase, one uses runDeferred(). Although the branch for #1781 will need to be abandoned, these new classes should be brought in for Twisted 2.6 (without breaking run()). Naturally, this affects many, many tests in Trial. We might even add runDeferred to TestSuite at this point. 4. Deprecate TestSuite.run and TestCase.run. (Twisted 2.6) Neither of these will work without wait[3] and they are both public APIs. Also remove the calls to iterate() from _Janitor at this point. 5. Actually remove _wait. (Twisted 2.7) Add runDeferred() to TestSuite, make run() raise NotImplementedErrors for TestCase and TestSuite. Alter TrialSuite to start and stop the reactor. I can't find a theory to explain why this change will break unexpected tests in the Twisted suite. However, it will certainly happen. That means that some tests in user code will probably break as well. I don't know how we could make this any smoother. Questions: - What should I do with the ticket #1781? - What should I do with the branch for #1781? - What more can we do to reduce the number of tests that will break when _wait is removed? - Thoughts? thanks for getting this far :), jml [1] Incidentally, all of this would be superfluous if reactors were restartable. [2] Well, almost everyone [3] ... or restartable reactors. [View Less]

2 2

Re: [Twisted-Python] Twisted & Qt
by Ed Suominen Sept. 30, 2006

Sept. 30, 2006

> On Tue, 26 Sep 2006 14:14:24 -0400, glyph(a)divmod.com wrote: I've got > what I believe is the final word on this. Phil Thompson (again, > Riverbank) says: > > """ The reactor must be licensed under the GPL, but the rest of > Twisted doesn't. A Twisted application that doesn't use the reactor > can be licensed under the Twisted license. A Twisted application that > uses the reactor must be licensed under the GPL. """ > > The best course of action, then, would … [View More]be to distribute qtreactor > separately, since we can no longer say that Twisted is all MIT > licensed if we do not. The practical ramifications of this are not > earth-shattering, so I think that we do not need to, e.g. release a > 2.4.1 which does not include qtreactor, but 2.5+ should definitely > not include it. > > I also asked specifically about not interfering with the PyQt/Qt > commercial license, and Mr. Thompson suggested wording like this: > > """ This code is licensed under either the Twisted license or the GPL > depending on the license of the copy of PyQt being used. > > If the GPL version of PyQt is being used then this code is also > licensed under the GPL. Given the viral nature of the GPL this means > that any application must also be licensed under the GPL. > > If any other version of PyQt is being used (eg. commercial, > evaluation, educational) then this code is licensed under the Twisted > license. """ > > I suggest that we leave that wording mostly unchanged. I agree and think (see disclaimer below) that this is just fine. It does not seem to inhibit the developer's flexibility at all. If you are developing with GPL PyQt, it looks like you can use freely qtreactor, under the condition that distributions of your application (including the copy of qtreactor that it incorporates) are made under the terms of the GPL. Nothing in the licensing of qtreactor could remove that requirement. If you are developing with commercial PyQt, Mr. Thomson's suggested wording indicates that your commercial application can also use qtreactor without any adverse impact on the proprietary nature of your work. This allows people to develop Twisted-based PyQt applications as free software (GPL) or commercially with the purchase of a commercial PyQt license, which is the desirable outcome for both Riverbank Computing and Twisted fans alike. I would think that Mr. Thompson's authorization from TrollTech to dual-license PyQt gives him the ability to authorize this sensible arrangement regarding qtreactor's use of PyQt. It would be nice to have confirmation of that from him as well, however, since anything importing PyQt ultimately has a dependency on Qt itself. If you need someone to host qtreactor, I'd be willing to do so from http://foss.eepatents.com, as long as I had direct assurance from Mr. Thompson that all these questions are settled. I could also contribute a few Twisted-friendly enhancements like the deferred-returning modal dialog box I posted a while back. However, such enhancements will have been developed with the GPL version of PyQt and would not be subject to the special provisions above unless Mr. Thompson chose to offer that as well. Best regards, Ed DISCLAIMER: Nothing in this comment is to be construed as legal advice. Although I probably think about things legal more often than the average person, being a registered patent agent, I am not a lawyer qualified to practice copyright law or anything else outside the representation of patent applicants before the US patent office. Nobody related to this topic is my client in even that capacity. [View Less]

2 1

[Twisted-Python] removing unsupported reactors in twisted 2.6: qt, corefoundation, threadedselect, wx
by glyph＠divmod.com Sept. 30, 2006

Sept. 30, 2006

There are a few reactors in the twisted codebase which currently have no maintainer and do not pass the test suite. I've listed them in the subject of this message. I'm comfortable to leave half-supported or potentially broken reactors in the Twisted distribution, as long as they were clearly marked as such and there was some at least potential path to making them work. IOCP, for example, is good enough for many uses despite not passing the full test suite (and there are rumours of a new … [View More]buildbot for it appearing soon...) However, leaving a pile of known-to-be-broken and unmaintained reactors in Twisted is just going to give the impression that Twisted is buggy, and increase the amount of dead code that people reading the codebase can be confused by. The reactors presented in the subject all seem to have been abandoned. Even our friends at Apple are mainly concerned with the use of Twisted for server work, and while they've been attempting to help us find someone to poke around GUI <-> reactor integration on OS X, it's not their area of expertise. At this point, I believe that setting up a buildslave for any of these reactors should be possible with our existing build infrastructure. Of course, contributions of additional buildslaves are always welcome :), but we can set up slaves for wx and corefoundation ourselves if someone is going to actually start trying to fix them. I know that there are people in the Twisted community integrating it with wxpython and qt. I'd really like it if someone could commit to at least contributing some patches in the future. If I don't hear anything on these fronts before the Twisted 2.6 release, those reactors will be removed from SVN trunk@HEAD and not be included in the 2.6 release. (The next planned release is Twisted 2.5, so you still have some breathing room.) Currently qtreactor is being tested on the "reactors" buildslave and is keeping it red, despite the fact that all the other reactors on that slave work fine (modulo a few elusive race conditions). wxreactor is not being tested at all. I believe we should split qt out so that it can have its own red column and not interfere with the gtk and poll reactors, and if we run a wx slave it should also be separate. Although I know of Qt and WX users, I do not know of anyone currently using the corefoundation reactor in an application. Are you out there? Is it being used? The last word I heard on the corefoundation reactor was from its author, Bob Ippolito, who suggested that it was not the correct way to integrate Twisted with GUI applications. However, his suggested replacement (threadedselectreactor) is buggy, also unmaintained, and IMHO misdesigned, so in the absence of other knowledge I believe that continuing to provide some corefoundation support would be the best way to support the mac. After receiving a shiny new computer from them I feel inclined to do the best job possible to support Apple's platform, but I simply don't have the time, knowledge, or energy to do the development myself. With the aforementioned hardware, I believe it would not be much trouble for us to set up a corefoundation reactor buildslave of our own, but we still need someone who will actually work on fixing the bugs, otherwise, the code should be removed. threadedselectreactor is an interesting concept but hopelessly broken and untested in its current implementation. I believe it should definitely be removed as a reactor of its own, although as a supporting basis for other reactors it might be good to leave around. While not entirely correct, it is certainly _less_ broken than the previous ghastly attempt at a wxreactor. I think it would be a good idea to remove threadedselect from the reactors list in Twisted 2.6, although if someone wants to convince me otherwise with a use-case (and a similar promise of future patches), I'd be happy to hear it. Once all these reactors have dedicated buildslaves and pass the tests, it is far less important that we have dedicated maintainers. We can simply insist that all future commits keep all the buildslaves green. I say this because I want to be clear that I am not asking for a lifetime commitment or we are going to instantly desupport your platform: I'm asking for help getting to the point where we can support multiple platforms without having to be experts in all of them. [View Less]

20 46

[Twisted-Python] Re: [Twisted-commits] r18320 - Name functions in deprecation warnings
by James Y Knight Sept. 30, 2006

Sept. 30, 2006

On Sep 28, 2006, at 10:30 PM, Jonathan Lange wrote: > def flushErrors(*errorTypes): > - """Support function for testing frameworks. > + """ > + DEPRECATED in Twisted 2.5. > + > + Support function for testing frameworks. > > Return a list of errors that occurred since the last call to > flushErrors(). > (This will return None unless startKeepingErrors has been > called.) > """ > > + warnings.warn("Deprecated in Twisted … [View More]

2 1

[Twisted-Python] Socket - connection lost
by Norman Tindall Sept. 29, 2006

Sept. 29, 2006

Hello, Reciently i wrote a simple client using Reconnecting Factory. That client logins to my socket server.. and that`s it. Interesting thing is that it is seems that twisted client, sends some ping on a TCP level without sending any data to the socket directly. Because when i pull out cord from the ethernet card simulating network falure, client in about 10-15 seconds determines that connection lost!! (pretty cool) While my server still thinks … [View More]

1 0

[Twisted-Python] Sending a long string/buffer without copying it
by Brian Granger Sept. 28, 2006

Sept. 28, 2006

HI, In one of my Twisted based applications, I need to send large string and buffers. They can be 100's of MB's long (they come from large numpy arrays). I would like to be able to send them *without making any copies* in the process. This seems to be dificult with the way that certain parts of Twisted are written: in protocols.basic many of the sendString/sendLine method having things that make a copy of the string or line to be send: def sendLine(self, line): """Sends a line … [View More]

5 6

[Twisted-Python] SIGBREAK on windows
by Jacob Gabrielson Sept. 28, 2006

Sept. 28, 2006

Hi, Has anyone run into a problem where their Twisted application gets a SIGBREAK and shuts down, on Windows? I have a simple application using the ReconnectingClientFactory, running as a service (via srvany.exe), that occasionally dies with a few messages: 2006/09/24 16:46 Pacific Daylight Time [-] Received SIGBREAK, shutting down. 2006/09/24 16:46 Pacific Daylight Time [AgentProtocol,client] <twisted.internet.tcp.Connector instance at 0x00A1B468> will retry in 2 seconds 2006/09/24 … [View More]

4 6

[Twisted-Python] RELEASE: Flumotion 0.2.2 'IT'
by thomas＠apestaart.org Sept. 27, 2006

Sept. 27, 2006

This mail announces the release of Flumotion 0.2.2 'IT'. Flumotion is a GPL streaming media server written in Python. It is distributed and component-based: every step in the streaming process (production, conversion, consumption) can be run inside a separate process on separate machines. Flumotion uses Twisted and GStreamer. Twisted enables the high-level functionality, distributing components over the network. GStreamer, through the Python bindings, enables the high-speed low-level … [View More]functionality: actual media processing. Flumotion uses a central manager process to control the complete network; one or more worker processes distributed over machines to run actual streaming components; and one or more admin clients connecting to the manager to control it. Release notes for Flumotion 0.2.2 "IT" The Flumotion team is happy to announce a new release of the Flumotion Streaming Server. Flumotion is a streaming server for GNU/Linux systems featuring an easy to use configuration and administration GUI. Implemented using GStreamer as the processing backend and using python and Twisted for the high-level operations and GUI, it combines a wide feature set with ease of use. Features of this release * Fully works with GStreamer 0.8 and 0.10 * Fully works with Twisted 1.3.0 through 2.4.0 * bug fixes Bugs fixed in this release * 235 : When selecting the TV card, the device name is not shown * 12 : gstreactor bug * 14 : crash after four days * 17 : Clean up temporary files * 263 : Old component UI remains when new pipeline loaded * 267 : Admin UI doesn't provide a way to find out where http-streamer is listening * 317 : cortado should do typefinding on its input instead of relying on mime type from server * 372 : service scripts can run into permission failures writing to the log file * 374 : running flumotion from service scripts makes it impossible to generate core dumps * 388 : manager could detect registry needing an update before sending bundles * 413 : stopping a component doesn't cause downstream components to go hungry Download You can find source releases of flumotion in the download directory: http://flumotion.net/src/flumotion/ Flumotion Homepage More details can be found on the project's website: http://flumotion.net/ Support and Bugs We use an issue tracker for bug reports and feature requests: https://core.fluendo.com/flumotion/trac/newticket Developers You can browse the repository of SVN code from our tracker. All code is in SVN and can be checked out from there. It is hosted on https://core.fluendo.com/svn/ Contributors to this release * Andy Wingo * Michael Smith * Thomas Vander Stichele * Zaheer Merali [View Less]

1 0

Fwd: [Twisted-Python] Twisted & Qt
by Timothy Fitz Sept. 27, 2006

Sept. 27, 2006

On 9/26/06, glyph(a)divmod.com <glyph(a)divmod.com> wrote: > That ticket doesn't seem to refer to setuptools at all, just distutils. I certainly haven't seen a discussion of removing twisted.plugin and switching to entry points. Bob said "Maybe this is a good time to consider setuptools support?" and I was trying to answer that one question. I agree that it's not about moving entry points, but distutils is a required precursor for setuptools. Gah, sorry for the confusion. To … [View More]

5 4

[Twisted-Python] How to get protocol function do not block server?
by Norman Tindall Sept. 26, 2006

Sept. 26, 2006

Hello, I am a newbie in twisted, sorry if this was asked thousands times before. I have wrote a simple protocol (over TCP sockets) with crc32. Suppose one client made a handshake.. and then sends to server 10Mb of data... at the end of that 10Mb there is an crc32.. crc32 is a pretty time consuming task on a slow machine.. while server calculates crc32 of 10Mb sent by client one, other clients can not communicate with server (i tryed by myself to log in while transfer.. and i was wating … [View More]about a 10 seconds) And also i have a UnCryptAFrame time consuming function. How to make those function do not block server, to run in background, and when result is avalable call a chain of other functions (for example it would be nice to add a callback to Factory.handleFrame(data) with the return results of Protocol.UnCryptAFrame())? Is it have to be deferToThread ? And also does dataReceived blocks server by itself? Is twisted.TCPServer scalable, can it serve 1000 - 10000 request in a minute? (in a secound would be great :) ) -------------------------------------------------------------------------------- server.py class MyProtocolServer(protocol.Protocol): # ... connectionMade .. def dataReceived(self, data): self.inp_buf += data if self.initialized != 0: self.handleData() else: self.handShake() # handshake is fast.. but i would gladly # make async if i know how. def handleData(self): if self.w_len is None and len(self.inp_buf) >= 5: self.w_len = struct.unpack("L",self.UncryptLen(self.inp_buf[:5]))[0] if len(self.inp_buf) == self.w_len: uncrypt_frame = self.UnCryptAFrame(self.inp_buf) self.NullInpBufer() def UnCryptAFrame(self): # a very slow function! pass class MyFactory(protocol.ServerFactory): protocol = MyProtocolServer def buildProtocol(self, addr): p = MyProtocolServer() p.factory = self p.addr = addr # ... return p factory = MyFactory() application = service.Application('myservice', uid=1, gid=1) internet.TCPServer(9090, factory).setServiceParent(service.IServiceCollection(application)) -------------------------------------------------------------------------------- end server.py $ twistd -ny ./f_server.py 2006/09/26 14:18 SST [-] Log opened. 2006/09/26 14:18 SST [-] twistd 2.4.0 (/usr/bin/python 2.4.2) starting up 2006/09/26 14:18 SST [-] reactor class: <class 'twisted.internet.selectreactor.SelectReactor'> 2006/09/26 14:18 SST [-] Loading ./f_server.py... 2006/09/26 14:18 SST [-] Loaded. 2006/09/26 14:18 SST [-] __builtin__.UpSTPFactory starting on 9090 2006/09/26 14:18 SST [-] Starting factory <__builtin__.UpSTPFactory instance at 0x407ec54c> 2006/09/26 14:18 SST [-] set uid/gid 1/1 ------------------------------------------------------- In other words if i do something slow in dataReceived (of my Protocol) it seems that it blocks server. how to avoid this? sorry for my english :) -- Best regards, Norman mailto:NormanTindall@zdisk.net [View Less]

3 2

[Twisted-Python] Weekly Bug Summary
by exarkun＠twistedmatrix.com Sept. 24, 2006

Sept. 24, 2006

1 0

[Twisted-Python] New OS X buildbot courtesy of Apple Computer, Inc.
by glyph＠divmod.com Sept. 23, 2006

Sept. 23, 2006

Today a box arrived in the Twisted Matrix Labs global headquarters (AKA the Divmod offices) containing a tricked-out Xserve G5, sent gratis by Apple Computer to help the Twisted team better support the Macintosh platform. Chris Armstrong and JP Calderone have already set up the buildslaves, and you can see them featured on our Buildbot page as "osx-2.4" and "poll-osx-2.4". http://twistedmatrix.com/buildbot/ This new machine is serving its purpose admirably. The new build configuration, … [View More]

5 4

[Twisted-Python] PB over SSH
by Aron Bierbaum Sept. 22, 2006

Sept. 22, 2006

Is there currently any way to us PB over a SSH connection? I noticed that there was a post on this list back in Feb 2004, but I didn't see anyone mention it after that. If anyone has any sample code that does this I would greatly appreciate it. -Aron

3 2

[Twisted-Python] Re: [Twisted-commits] r18220 - Make tests clean up after themselves
by Jean-Paul Calderone Sept. 22, 2006

Sept. 22, 2006

On Thu, 21 Sep 2006 21:32:47 -0600, Jonathan Lange <jml(a)wolfwood.twistedmatrix.com> wrote: >Author: jml >Date: Thu Sep 21 21:32:47 2006 >New Revision: 18220 > >Modified: > trunk/twisted/web/test/test_distrib.py > trunk/twisted/web2/test/test_static.py > trunk/twisted/words/test/test_service.py >Log: >Make tests clean up after themselves > > * Fixes #1883 > * Author: jml > * Reviewer: MFen > >Although not apparent to the naked eye, … [View More]these tests previous did not >correctly clean up after themselves. Instead, they relied on a couple >of spins of the reactor to do their cleaning for them. This has been >corrected. > > > >Modified: trunk/twisted/web/test/test_distrib.py >============================================================================== >--- trunk/twisted/web/test/test_distrib.py (original) >+++ trunk/twisted/web/test/test_distrib.py Thu Sep 21 21:32:47 2006 >@@ -15,16 +15,26 @@ > self.logFile.close() > del self.logFile > >+ >+class PBServerFactory(pb.PBServerFactory): Docstring? >+ def buildProtocol(self, addr): >+ self.proto = pb.PBServerFactory.buildProtocol(self, addr) >+ return self.proto >+ >+ > class DistribTest(unittest.TestCase): > port1 = None > port2 = None > sub = None > > def tearDown(self): Docstring? >+ dl = [defer.Deferred(), defer.Deferred()] >+ self.f1.proto.notifyOnDisconnect(lambda: dl[0].callback(None)) > if self.sub is not None: >+ self.sub.publisher.broker.notifyOnDisconnect( >+ lambda: dl[1].callback(None)) > self.sub.publisher.broker.transport.loseConnection() > http._logDateTimeStop() >- dl = [] > if self.port1 is not None: > dl.append(self.port1.stopListening()) > if self.port2 is not None: >@@ -36,8 +46,8 @@ > r1 = resource.Resource() > r1.putChild("there", static.Data("root", "text/plain")) > site1 = server.Site(r1) >- f1 = pb.PBServerFactory(distrib.ResourcePublisher(site1)) >- self.port1 = reactor.listenTCP(0, f1) >+ self.f1 = PBServerFactory(distrib.ResourcePublisher(site1)) >+ self.port1 = reactor.listenTCP(0, self.f1) > self.sub = distrib.ResourceSubscription("127.0.0.1", > self.port1.getHost().port) > r2 = resource.Resource() > >Modified: trunk/twisted/web2/test/test_static.py >============================================================================== >--- trunk/twisted/web2/test/test_static.py (original) >+++ trunk/twisted/web2/test/test_static.py Thu Sep 21 21:32:47 2006 >@@ -11,7 +11,6 @@ > self.text = "Hello, World\n" > self.data = static.Data(self.text, "text/plain") > >- > def test_dataState(self): > """ > Test the internal state of the Data object >@@ -42,7 +41,6 @@ > http_headers.MimeType("text", "plain")) > def checkStream(data): > self.assertEquals(str(data), self.text) >- > return stream.readStream(iweb.IResponse(self.data.render(None)).stream, > checkStream) > >@@ -58,7 +56,8 @@ > maxBytes=16) > self.root.addSlash = True > >- def uploadFile(self, fieldname, filename, mimetype, content, resrc=None, host='foo', path='/'): >+ def uploadFile(self, fieldname, filename, mimetype, content, resrc=None, >+ host='foo', path='/'): > if not resrc: > resrc = self.root > >@@ -102,32 +101,33 @@ > return d > > def test_enforcesMaxBytes(self): Docstring? >- return self.assertInResponse(self.uploadFile('FileNameOne', 'myfilename', >- 'text/html', 'X'*32), >- (200, {}, 'exceeds maximum length')) >+ return self.assertInResponse( >+ self.uploadFile('FileNameOne', 'myfilename', 'text/html', 'X'*32), >+ (200, {}, 'exceeds maximum length')) > > def test_enforcesMimeType(self): Docstring? >- return self.assertInResponse(self.uploadFile('FileNameOne', 'myfilename', >- 'application/x-python', 'X'), >- (200, {}, 'type not allowed')) >+ return self.assertInResponse( >+ self.uploadFile('FileNameOne', 'myfilename', >+ 'application/x-python', 'X'), >+ (200, {}, 'type not allowed')) > > def test_invalidField(self): Docstring? >- return self.assertInResponse(self.uploadFile('NotARealField', 'myfilename', >- 'text/html', 'X'), >- (200, {}, 'not a valid field')) >+ return self.assertInResponse( Docstring? >+ self.uploadFile('NotARealField', 'myfilename', 'text/html', 'X'), >+ (200, {}, 'not a valid field')) > > def test_reportFileSave(self): Docstring? >- return self.assertInResponse(self.uploadFile('FileNameOne', 'myfilename', >- 'text/plain', >- 'X'), >- (200, {}, 'Saved file')) >+ return self.assertInResponse( >+ self.uploadFile('FileNameOne', 'myfilename', 'text/plain', 'X'), >+ (200, {}, 'Saved file')) > > def test_compareFileContents(self): Docstring? > def gotFname(fname): > contents = file(fname, 'r').read() > self.assertEquals(contents, 'Test contents') >- >- return self.uploadFile('FileNameOne', 'myfilename', 'text/plain', >- 'Test contents').addCallback( >- self.fileNameFromResponse >- ).addCallback(gotFname) >+ >+ d = self.uploadFile('FileNameOne', 'myfilename', 'text/plain', >+ 'Test contents') >+ d.addCallback(self.fileNameFromResponse) >+ d.addCallback(gotFname) >+ return d > >Modified: trunk/twisted/words/test/test_service.py >============================================================================== >--- trunk/twisted/words/test/test_service.py (original) >+++ trunk/twisted/words/test/test_service.py Thu Sep 21 21:32:47 2006 >@@ -875,21 +875,26 @@ > self.portal = portal.Portal( > self.realm, [self.checker]) > self.serverFactory = pb.PBServerFactory(self.portal) >+ self.serverFactory.protocol = self._protocolFactory > self.serverFactory.unsafeTracebacks = True > self.clientFactory = pb.PBClientFactory() > self.clientFactory.unsafeTracebacks = True >- > self.serverPort = reactor.listenTCP(0, self.serverFactory) > self.clientConn = reactor.connectTCP( > '127.0.0.1', > self.serverPort.getHost().port, > self.clientFactory) > >+ def _protocolFactory(self, *args, **kw): Docstring? >+ self._serverProtocol = pb.Broker(0) >+ return self._serverProtocol > > def tearDown(self): Docstring? >+ d3 = Deferred() >+ self._serverProtocol.notifyOnDisconnect(lambda: d3.callback(None)) > return DeferredList([ > maybeDeferred(self.serverPort.stopListening), >- maybeDeferred(self.clientConn.disconnect)]) >+ maybeDeferred(self.clientConn.disconnect), d3]) > > def _loggedInAvatar(self, name, password, mind): > creds = credentials.UsernamePassword(name, password) > >_______________________________________________ >Twisted-commits mailing list >Twisted-commits(a)twistedmatrix.com >http://twistedmatrix.com/cgi-bin/mailman/listinfo/twisted-commits > [View Less]

3 5

[Twisted-Python] Perspective Broker vs XMLRPC for this...
by Yoheeb Sept. 21, 2006

Sept. 21, 2006

Hi all, I have never used twisted, but really would like to. I am in the middle of rough design of an xmlrpc OR OTHER remote method invocation type system. I am debating the use of xmlrpc vs the use of perspective broker. (for a quick prototype I will likely use the python base xmlrpc lib, but just for proof of concept) I need to support both java and python. (and really c/c++ in some fashion would be nice also) from both "local" and remote sources. I really need something that is secure … [View More]

2 1

[Twisted-Python] how to manage multiple services using application
by William Hanwoody Sept. 19, 2006

Sept. 19, 2006

Hi All: I want to manage multiple services in one twisted.application， multiple services contain t.app.internet.TCPClient services and t.app.internet.TCPServer services. After client service(a.app.internet.TCPClient) connected and get results, Do I need to stop client service? if needed, how to do it? another question is how to use Deferred in twisted.application framework? Thanks -- _______________________________________________________________ William Hanwoody … [View More]

1 0