Mailman 3 August 2005 - Twisted

[Twisted-Python] Australian Twisted folk at the OSDC: Melbourne Dec 5th - 7th 2005
by Mary Gardiner 14 Aug '05

14 Aug '05

We haven't even gotten to the second sprint yet (this weekend, Sydney, see you there), and there's talk of a third one. The Australian Open Source Developers Conference is being held at Monash University, Caulfield, Melbourne from December 5th to 7th this year. Seems like all of the Tassie Twisted folk are submitting papers and a few others are thinking of submitting or attending. Hence, while it probably won't be even as formally informal (or informally formal?) as the Hobart and Sydney sprints, it seems likely that critical mass will be achieved in Melbourne and Twisted coding might take place... .... Conference details: Monday, December the 5th to Wednesday December the 7th, 2005 Call for papers is currently open: http://osdc2005.cgpublisher.com/cfp.html but deadline is *this Friday* 19th August. Details at http://www.osdc2005.com.au/ .... And after that... anyone going to linux.conf.au 2006 in Dunedin New Zealand...? -Mary

1 1

[Twisted-Python] Re: Twisted-Python Digest, Vol 17, Issue 12
by pooja bector 14 Aug '05

14 Aug '05

Hi Thanks for the quick reply. PLease let me know if the twisted word chat server is available as a software download?? >From where can i download the server and client software? Thanks twisted-python-request(a)twistedmatrix.com wrote: Send Twisted-Python mailing list submissions to twisted-python(a)twistedmatrix.com To subscribe or unsubscribe via the World Wide Web, visit http://twistedmatrix.com/cgi-bin/mailman/listinfo/twisted-python or, via email, send a message with subject or body 'help' to twisted-python-request(a)twistedmatrix.com You can reach the person managing the list at twisted-python-owner(a)twistedmatrix.com When replying, please edit your Subject line so it is more specific than "Re: Contents of Twisted-Python digest..." Today's Topics: 1. Re: twisted-compliant interactive interpreter (Antony Kummel) 2. Query (pooja bector) 3. SSL Example? (markw) 4. Re: Query (Jp Calderone) ---------------------------------------------------------------------- Message: 1 Date: Sun, 14 Aug 2005 05:15:27 -0700 (PDT) From: Antony Kummel Subject: Re: [Twisted-Python] twisted-compliant interactive interpreter To: Twisted general discussion Message-ID: <20050814121527.92362.qmail(a)web33908.mail.mud.yahoo.com> Content-Type: text/plain; charset="iso-8859-1" Hi, Here is a version of PyCrust I hooked up that uses Manhole. I'm trying to figure out if there's a way to easily mix together some free tools to make Twisted development on Windows easier. Comments wanted. Antony Kummel __________________________________________________ Do You Yahoo!? Tired of spam? Yahoo! Mail has the best spam protection around http://mail.yahoo.com

1 0

[Twisted-Python] Query
by pooja bector 14 Aug '05

14 Aug '05

Hi All I am new to Twisted networks.I read its documentation that it is a network over which we can build network applications like chat server. I have queries regarding , Twisted Word chat server , written in python. I just know that it is available under free BSD license. I want to know that is it available as a free download.Can I download the server and a compatible client ? are the APIs of the server available? How many simlutaneuos users does it support. Does it supports group chat and multilanguage chatting. Thanks __________________________________________________ Do You Yahoo!? Tired of spam? Yahoo! Mail has the best spam protection around http://mail.yahoo.com

2 1

[Twisted-Python] twisted-compliant interactive interpreter
by Antony Kummel 14 Aug '05

14 Aug '05

Hi, I felt a need for an interactive interpreter that continued to be interactive when the reactor ran. Here is my adaptation of the console class in codes.py. Please comment. Yours, Antony Kummel ____________________________________________________ Start your day with Yahoo! - make it your home page http://www.yahoo.com/r/hs """ Emulation of Python's interactive interpreter that lives in harmony with Twisted's reactor. """ from twisted.python import threadable threadable.init() from twisted.internet import reactor, defer, threads from code import InteractiveConsole as _InteractiveConsole import sys class TwistedInteractiveConsole(_InteractiveConsole): """Closely emulate the behavior of the interactive Python interpreter, but run from within Twisted's reactor! """ def __init__(self, locals=None, filename="<console>"): """Constructor. The optional locals argument will be passed to the InteractiveInterpreter base class. The optional filename argument should specify the (file)name of the input stream; it will show up in tracebacks. """ _InteractiveConsole.__init__(self, locals, filename) def interact(self, banner=None, stopReactor=False): """Closely emulate the interactive Python console. The optional banner argument specify the banner to print before the first interaction; by default it prints a banner similar to the one printed by the real Python interpreter, followed by the current class name in parentheses (so as not to confuse this with the real interpreter -- since it's so close!). The optional stopReactor argument indicates whether to stop the Twisted reactor when the user exits the interpreter (^Z). """ self.stopReactor = stopReactor try: sys.ps1 except AttributeError: sys.ps1 = ">>> " try: sys.ps2 except AttributeError: sys.ps2 = "... " cprt = 'Type "help", "copyright", "credits" or "license" for more information.' if banner is None: self.write("Python %s on %s\n%s\n(%s)\n" % (sys.version, sys.platform, cprt, self.__class__.__name__)) else: self.write("%s\n" % str(banner)) reactor.callLater(0, self._startInteraction) def _startInteraction(self, more=False): if more: prompt = sys.ps2 else: prompt = sys.ps1 d = defer.maybeDeferred(self.raw_input, prompt) d.addCallbacks(self._processInput, self._processInputError) def _processInput(self, line): more = self.push(line) reactor.callLater(0, self._startInteraction, more) def _processInputError(self, failure): failure.trap(EOFError) self.write("\n") if bool(self.stopReactor): reactor.stop() def raw_input(self, prompt=""): """Write a prompt and read a line. The returned line does not include the trailing newline. When the user enters the EOF key sequence, EOFError is raised. The base implementation uses the built-in function raw_input(); a subclass may replace this with a different implementation. """ return threads.deferToThread(raw_input, prompt) def interact(banner=None, readfunc=None, local=None, stopReactor=False): """Closely emulate the interactive Python interpreter. This is a backwards compatible interface to the InteractiveConsole class. When readfunc is not specified, it attempts to import the readline module to enable GNU readline if it is available. Arguments (all optional, all default to None): banner -- passed to InteractiveConsole.interact() readfunc -- if not None, replaces InteractiveConsole.raw_input() local -- passed to InteractiveInterpreter.__init__() stopReactor -- passed to InteractiveConsole.interact() """ console = TwistedInteractiveConsole(local) if readfunc is not None: console.raw_input = readfunc else: try: import readline except ImportError: pass console.interact(banner, stopReactor) if __name__ == '__main__': reactor.callWhenRunning(interact, stopReactor=True) reactor.run()

4 5

Re: [Twisted-Python] How to run function from protocol class
by Michał Tyde 12 Aug '05

12 Aug '05

Thank You it works just fine.

1 0

[Twisted-Python] How to run function from protocol class
by Michał Tyde 12 Aug '05

12 Aug '05

I got the code: from twisted.internet.protocol import Protocol class MyClientProtocol(Protocol): buffer = '' def connectionMade(self): self.transport.write('hello world') def myFunction(self): self.transport.write('blah') def dataReceived(self, data): self.buffer += data if self.buffer == 'hello world': self.transport.loseConnection() from twisted.internet.protocol import ClientFactory class MyFactory(ClientFactory): protocol = MyClientProtocol def startedConnecting(self, connector): pass # we could connector.stopConnecting() def clientConnectionLost(self, connector, reason): connector.connect() # reconnect def clientConnectionFailed(self, connector, reason): print "connection failed" reactor.stop() from twisted.internet import reactor, task #t=MyClientProtocol() #l = task.LoopingCall(t.myFunction) #l.start(5.0) reactor.connectTCP('localhost', 7771, MyFactory(), timeout=30) reactor.run() I want to run my function myFunction every 5 sec (commented code). I want to use a task.LoopingCall loop. I am run out of new ideas. I don't know how to do this. Help please.

3 2

[Twisted-Python] Searchable mailing list?
by Alwyn Schoeman 12 Aug '05

12 Aug '05

Hi everyone, Any version of this mailing list that one can search? -- Alwyn Schoeman

3 2

[Twisted-Python] how to delay the response in the protocol.Protocol
by Andrzej Leszczynski 11 Aug '05

11 Aug '05

In the protocol derived class and dataReceived function, I need to send response with given delay using self.transport.write(str(msg)). I guess I would use "maybeDeferred" class to do that. How to pass the delay value. Please advice, A.

3 5

[Twisted-Python] Getting twisted tar balls?
by Magnus Lycka 11 Aug '05

11 Aug '05

It seems tmrc.mit.edu is down. (Or is that just some kind of DNS problem in my end?) Is there any other place I can download TwistedSumo-2005-05-25.tar.bz2 or something equivalent from? Due to firewalls and stuff, I have problems using svn at work...

2 1

Re: [Twisted-Python] What is wrong with this instance?
by Michał Tyde 11 Aug '05

11 Aug '05

First I wanted to say is that i attached a file with _working_ code. Please try to change a user nad password in telnet_User, and telnet_Password. > With this longer example I'm not sure what part of it is not behaving > as you expect. Please read the thread: [Twisted - Python] Telnet client & keeping connection alive. I want to send to connected telnet server a "pwd" command every 20 sec. Here I got less (5 sec.) to wait for effects -> see task.LoopingCall(telnet_KeepAlive2). In function telnet_KeepAlive2 I try to execute function from TelnetProtocol class (function telnet_KeepAlive). It doesn't execute, and becouse of that is after # sign. With this line commented program works just fine (executes every 5 sec. a telnet_KeepAlive2() ),but it does nothing important. Run this program with this line commented, You should see that he prints (after connection): keeping alive 1 keeping alive 2 keeping alive 1 keeping alive 2 ... but I must to execute telnet_KeepAlive() method (from TelnetProtocol, _and this is the problem_). This method should send by self.write("pwd\n \r") command to telnet server. Sorry if I repeat myself, but I try to explain the problem the best way I could. If I uncoment line in telnet_KeepAlive2 (line: tel.telnet_KeepAlive()),my telnet client connect to server and now do nothing (doesn't get into telnet_KeepAlive2 loop). > I feel like I'm trying to read minds here, and I'm not very good at > that :) Me neither :). I know that my problem has something common with instance of class TelnetProtocol. How to could I pass on a TelnetProtocol method or instance to interior of telnet_KeepAlive function? Or maybe there is another solution. Thank You in advance for answers.

1 0

[Twisted-Python] Unix platforms?
by Magnus Lycka 11 Aug '05

11 Aug '05

Are people using Twisted on HP-UX, AIX or Solaris? (I saw that Marcus Kimpenhaus asked about HP-UX and AIX two years ago, and I read Moshe's reply, but maybe someone tried since then? Since I can't connect to tmrc now, I haven't even tried to build it yet...but even if I could, it would be nice to know if someone was using it for real...)

1 0

[Twisted-Python] What is wrong with this instance?
by Michał Tyde 11 Aug '05

11 Aug '05

As a topic. I got the code: ^^^ form twisted.protocols.telnet import Telnet def keep(): telnet=Telnet() print type(telnet) print getattr(telnet,'write')#all OK until here telnet.write("msg") print "msg" keep() ^^^ and I got TypeError: unbound method write() must be called with Telnet instance as first argument (got str instance instead) I really don't understand where is the mistake.

3 4

RE: [Twisted-Python] simple spawnProcess
by jmbenski＠micron.com 10 Aug '05

10 Aug '05

Ok, thanks. I got it working. I was just thinking of it in reverse. All the google hits I came up with had someone talking about running the Qt and Twisted threads separately. Apparently that is a good way to run in circles for awhile. Thanks for the help. -----Original Message----- From: twisted-python-bounces(a)twistedmatrix.com [mailto:twisted-python-bounces@twistedmatrix.com] On Behalf Of glyph(a)divmod.com Sent: Wednesday, August 10, 2005 2:38 PM To: Twisted general discussion Subject: RE: [Twisted-Python] simple spawnProcess On Wed, 10 Aug 2005 08:53:48 -0600, jmbenski(a)micron.com wrote: >Ok, obviously I'm missing something in the API. > >When I call reactor.run(), my main thread is stuck in the loop. I tried to set up my code in a thread to get around this. That is rather the point. Using threads to "get around this" will break Twisted. Threads are not supported for most APIs, and as JP said, they are what is breaking your program. > ##At some unknown point in the future I might need to issue commands You are correct that your program will never get there. Code after run() is not a place that your program should really ever *expect* to get. If you need to run some code 'in the future', see reactor.callLater. In general though, you will have to issue commands to your spawned process in response to some event. Was it a button click? Use Twisted's integration with a toolkit (such as GTK or Qt). Was it a network request? Set up a ProtocolFactory with a reference to your spawned process, or set up one that spawns processes itself when network connections are made. There are lots of events which can potentially hpppen while the main loop is running. Think of your program as a series of responses to those things, and the bit before reactor.run() as simply the set-up to make sure appropriate events get caught (your initial callLater to set up a timed loop, or a listenTCP to connect your program to the network) rather than as the program in its entirety. _______________________________________________ Twisted-Python mailing list Twisted-Python(a)twistedmatrix.com http://twistedmatrix.com/cgi-bin/mailman/listinfo/twisted-python

1 0

[Twisted-Python] Twisted on QNX
by Franklin, Lyndsey 10 Aug '05

10 Aug '05

I'm trying to get Twisted to work on a QNX computer (actually, I'm after buildbot but I need Twisted first) but I'm having problems getting it to run correctly. The long and short is that for some reason, threads and forks don't like each other much on QNX. I've been taking stabs at the code for Twisted but I'm not making much progress on my own yet. Is there some way to get rid of the forking in Twisted? (For those who have played with buildbot, the problems crop up when I try to checkout source code, it complains about the os.fork() not being implemented). Thanks in advance, Lyndsey

3 2

RE: [Twisted-Python] simple spawnProcess
by jmbenski＠micron.com 10 Aug '05

10 Aug '05

Ok, obviously I'm missing something in the API. When I call reactor.run(), my main thread is stuck in the loop. I tried to set up my code in a thread to get around this. from twisted.internet import reactor import os import sys import time class procProtocol(protocol.ProcessProtocol): def __init__(self): pass def connectionMade(self): print "Connection Made\n" def outReceived(self, data): file = open("bob.txt","a") file.write("outReceived\n" + data) file.close() executable = "foo" program = "MSsync" args = ["arg1","arg2", "path", str(os.getpid())] #create the handler for the communication processProtocol = procProtocol() reactor.spawnProcess(processProtocol, executable, args, env=os.environ, path=args[2], uid=None, gid=None, usePTY=True) #launch the reactor to grab events. reactor.run() ### I will never get here ### ##At some unknown point in the future I might need to issue commands processProtocol.transport.write( "some command \r\n" ) processProtocol.transport.write( "some command \r\n" ) -----Original Message----- From: twisted-python-bounces(a)twistedmatrix.com [mailto:twisted-python-bounces@twistedmatrix.com] On Behalf Of Jp Calderone Sent: Wednesday, August 10, 2005 12:04 AM To: Twisted general discussion Subject: Re: [Twisted-Python] simple spawnProcess On Tue, 9 Aug 2005 16:34:17 -0600, jmbenski(a)micron.com wrote: >I'm new to twisted, Python, and network programming in general, so this question has probably been answered many times. Although after searching for a few days I haven't seen it. > > > >I'm trying to set up a simple process that accepts data through stdin and prints the response to stdout. It is a continuously running process that will keep waiting for more input on stdin and will continue writing to stdout until a shutdown command is sent to it. I started the reactor in a separate thread so that my main thread doesn't block while waiting for a response and I can send commands to the spawned process. > Why are you using threads at all? Twisted's process support presents an asynchronous API, like most other things Twisted does. You don't need threads here. Their presence is what is breaking your program. You cannot call reactor.run() from one thread and /any/ other Twisted API (unless explicitly marked as an exception) from a different thread. In particular, reactor.spawnProcess() and transport.write() in the code you included are being called from the wrong thread. Jp _______________________________________________ Twisted-Python mailing list Twisted-Python(a)twistedmatrix.com http://twistedmatrix.com/cgi-bin/mailman/listinfo/twisted-python

2 1

[Twisted-Python] [Twisted - Python] Telnet client & keeping connection alive
by Michał Tyde 10 Aug '05

10 Aug '05

First i want to thank all people that responsed for my ealier questions. I have done a progress in my project.I am a green in Twisted/Python, and network programming in general. Now I got a working telnet client. I have got two kind of telnet servers. First one (after succesfuly login) keeps connection even if I don't send a command to him. Second one disconnect me every 30 sec., if I don't send command to him. So I want to create a thread (after connection to the server) that will send to him a "pwd" command. I want this thread to run constantly and sending every 20 sec "pwd" command. Of course in the meantime i want to get responses for my enother commands. Is this the best idea? Where should I do this (in protocol or in factory)? Maybe there is another solution. Where can I find some tutorials with code examples about threads in Python/Twisted? Please send me a link with working pattern of telnet client in Twisted. I have look for this kind of code but i couldn't find anything. I don't know if my code is good (he works, but sometimes I dont know why). Maybe some suggestions. Thank You in advance for answers.

3 2

[Twisted-Python] simple spawnProcess
by jmbenski＠micron.com 10 Aug '05

10 Aug '05

I'm new to twisted, Python, and network programming in general, so this question has probably been answered many times. Although after searching for a few days I haven't seen it. I'm trying to set up a simple process that accepts data through stdin and prints the response to stdout. It is a continuously running process that will keep waiting for more input on stdin and will continue writing to stdout until a shutdown command is sent to it. I started the reactor in a separate thread so that my main thread doesn't block while waiting for a response and I can send commands to the spawned process. If I run this program without the sleep everything works correctly. If I add the sleeps before the write, the write never registers with the process. It is almost as if the pipe never gets flushed with the transport write. I've looked through the API and haven't seen a way to flush the pipes and I have tried using the sys.stdout.flush(). What am I doing wrong? Is there an easier way to setup inter-process communication through Twisted? Thanks, Jon from twisted.internet import reactor, protocol import threading from twisted.python import threadable import os import sys import time threadable.init( with_threads=1) class procProtocol(protocol.ProcessProtocol): def __init__(self): pass def connectionMade(self): print "Connection Made\n" def outReceived(self, data): file = open("bob.txt","a") file.write("outReceived\n" + data) file.close() class ReactorFacade: def __init__( self ): self.reactorThread = threading.Thread( target=reactor.run, name="ReactorThread", kwargs={'installSignalHandlers':0}, ) def start(self): # assume not yet started print "Facade: starting..." self.reactorThread.start() print "Facade: started ok" def stop(self): # assume already running print "Facade: request stop" reactor.callFromThread(reactor.stop) print "Facade: request stopped ok" self.reactorThread.join() executable = "foo" program = "MSsync" args = ["arg1","arg2", "path", str(os.getpid())] #create the handler for the communication processProtocol = procProtocol() reactor.spawnProcess(processProtocol, executable, args, env=os.environ, path=args[2], uid=None, gid=None, usePTY=True) rf = ReactorFacade() rf.start() time.sleep(3) #If I remove this sleep the following write will register with my process. processProtocol.transport.write( "some command \r\n" ) time.sleep(3) processProtocol.transport.write( "some command \r\n" ) rf.stop()

2 1

[Twisted-Python] How to get initialize values of function
by Michał Tyde 09 Aug '05

09 Aug '05

I have code like that: class class1: def funct1(self, some_args): if a==b:#(the condition doesn't matter) self.funct30("value") enother_val=funct30().__init__ #it doesn't work #i want to have in enother_value="value" - argument from function funct30() def funct30(self, value): # do something # i can't return here a value, because the program work inappropriate Maybe this is a very simple solution, but i have got now any idea. Thanks in advance for answers

5 5

[Twisted-Python] Simple Telnet Client - couldn't get answer form server
by Michał Tyde 04 Aug '05

04 Aug '05

I try to get from standard telnet server answer. I connect to this server, and now dataReceived() should give me a full answer from server like: Ret Hat Linux relase: ... login:, but it does not. I would like to know how to connect to this server and grab this data. dataReceived gives me something like that: #' (translation in telnet codes: IAC DO TERMINAL_TYPE IAC DO SPEED IAC DO X_DISPALY_LOCATION IAC DO NEW_ENVI_OPTION ((hex)FF FD 18 FF FD 20 FF FD 23 FF FD 27)). What should I do with this. I try to transport a answers for this questions. Maybe i got a mistake in code, somthing i do in wrong way? Code I working on in attachment.

3 2

[Twisted-Python] Twisted and Qt
by Tom Brown 04 Aug '05

04 Aug '05

Hi, I am trying to write yet another internet based chess game. I am writing the client gui using Qt. When reactor.run() is called in the client, there is communication with the server. However, the main window is never shown. A code snippet is given below. I followed the qtdemo.py example. What am I missing? Thanks, Tom from qt import * from twisted.internet.qtreactor import install from twisted.internet import reactor, protocol from mainwindowimpl import MainWindowImpl ... def main(server, port): a = QApplication(argv) install(a) chessClientFactory = ChessClientFactory() w = MainWindowImpl() w.show() reactor.addSystemEventTrigger('after', 'shutdown', a.quit) a.connect(a, SIGNAL("lastWindowClosed()"), reactor.stop) reactor.connectTCP(server, port, chessClientFactory) reactor.run()

2 1

[Twisted-Python] Ftp client
by Michele Petrazzo 04 Aug '05

04 Aug '05

I want to port my ftp client class from standard library (ftplib) to twisted ftpclient. I start to work with ftpclient example and with a "standard" ftp server, it work well, of course :), but I'm working on a not standard server (hylafax), that not accept the standard commands, so now with the standard library, every time that I want to communicate with it, I send its internal commands. Is it possible to "translate" my very short and simple code to twisted ftpclint? However, I have already tried to modify the simple generic client example "EchoClient", and it work until I make a "LIST status" request, that it would have to return a short string (100-150 characters), because if I use passive mode (command 'PASV') I receive a 425 error, and if I don't use it, I don't receive anything (I wait...). Can someone point me to the right direction ? Thanks, Michele

2 8

[Twisted-Python] [andrea@cpushare.com: Re: error after launching cpushare client]
by Andrea Arcangeli 04 Aug '05

04 Aug '05

Hello, a CPUShare user reported a failure in the process protocol processEneded method. The status parameter passed to the processEnded callback is like this: status.value.signal == 11 status.value.status == 139 My server code was validating the sigsegv status returned by the client, and it noticed it wasn't 11. But status.value.signal == 11. See the debugging patch that produced the below output: http://www.cpushare.com/hypermail/cpushare-discuss/05/08/0018.html How can it be that the same status has .value.signal == 11 and .value.status == 139 at the same time? I suspect this is a twisted bug. Thanks for any help! ----- Forwarded message from Andrea Arcangeli <andrea(a)cpushare.com> ----- Date: Wed, 3 Aug 2005 16:35:37 +0200 From: Andrea Arcangeli <andrea(a)cpushare.com> To: cpushare-discuss(a)cpushare.com Subject: Re: error after launching cpushare client On Wed, Aug 03, 2005 at 03:26:39PM +0200, Loïc Le Loarer wrote: > Le Wednesday 03 August 2005 à 13:09:35 +0200, Andrea Arcangeli a écrit: > > Hi, > > > > On Mon, Aug 01, 2005 at 06:36:13PM +0200, lll+cpushare(a)m4x.org wrote: > > > 2005/08/01 17:48 CEST [cpushare_protocol,client] 'sigsegv not killed with signal 11: status 139.' > > > > This is weird, it looks like twisted reports status 139 and signal 11 at > > the same time (while status should be 11 == signal), at first glance it > > looks a twisted bug. > > > > Can you please try to apply this patch and see what it prints? (this way > > it will be printed on the client side, previously the number 139 is > > generated by the server side) > > Hi, > > I have applyed your patch and here is the output : > 2005/08/03 15:23 CEST [-] Log opened. > 2005/08/03 15:23 CEST [-] twistd 2.0.1 (/usr/bin/python 2.4.1) starting up > 2005/08/03 15:23 CEST [-] reactor class: twisted.internet.selectreactor.SelectReactor > 2005/08/03 15:23 CEST [-] Loading cpushare.tap... > 2005/08/03 15:23 CEST [-] Loaded. > 2005/08/03 15:23 CEST [-] Starting factory <cpushare.proto.cpushare_factory instance at 0xb78251ac> > 2005/08/03 15:23 CEST [-] Enabling Multithreading. > 2005/08/03 15:23 CEST [cpushare_protocol,client] Starting seccomp task > 2005/08/03 15:23 CEST [-] Seccomp task gracefully killed by seccomp. > 2005/08/03 15:23 CEST [cpushare_protocol,client] Starting seccomp task > 2005/08/03 15:23 CEST [-] Seccomp task gracefully killed by sigsegv, status 139. > 2005/08/03 15:23 CEST [cpushare_protocol,client] 'sigsegv not killed with signal 11: status 139.' > 2005/08/03 15:23 CEST [cpushare_protocol,client] Lost connection. Reason: [Failure instance: Traceback (failure with no frames): twisted.internet.error.ConnectionLost: Connection to the other side was lost in a non-clean fashion: Connection lost. > 2005/08/03 15:23 CEST [cpushare_protocol,client] ] > 2005/08/03 15:23 CEST [cpushare_protocol,client] <twisted.internet.ssl.Connector instance at 0xb783114c> will retry in 2 seconds > 2005/08/03 15:23 CEST [cpushare_protocol,client] Stopping factory <cpushare.proto.cpushare_factory instance at 0xb78251ac> > 2005/08/03 15:23 CEST [-] Main loop terminated. > 2005/08/03 15:23 CEST [-] Server Shut Down. > > The status is 139, does this help ? Yes it helps since it verified that for some reason twisted reports an exit status of 139, which collides with an exist status of 11. (it wasn't a communication error between client and server) I think it's a twisted bug and not a mistake from my part. I'll ask on the twisted lists to be sure. What distro/twisted are you using? In the meantime this will work around it so you can start earning CPUCoins ;) Index: cpushare/proto.py =================================================================== RCS file: /home/andrea/crypto/cvs/cpushare/client/cpushare/cpushare/proto.py,v retrieving revision 1.49 diff -u -p -r1.49 proto.py --- cpushare/proto.py 6 Jul 2005 23:19:02 -0000 1.49 +++ cpushare/proto.py 3 Aug 2005 14:34:34 -0000 @@ -82,7 +82,7 @@ class state_machine(object): self.protocol.sendString(PROTO_SECCOMP_SUCCESS) def end_failure(failure): end_common() - self.protocol.sendString(PROTO_SECCOMP_FAILURE + struct.pack('!i', failure.value.status)) + self.protocol.sendString(PROTO_SECCOMP_FAILURE + struct.pack('!i', failure.value.signal)) def started(result): self.protocol.sendString(PROTO_SECCOMP_RUN) Thanks! ----- End forwarded message -----

2 4

[Twisted-Python] Manually adding a file descriptor to the reactor
by Jason Fritcher 03 Aug '05

03 Aug '05

Hello, I have a C library I've written an extension wrapper around that manages connections to an external server for me. When I create a connection through this library, I get a file descriptor back that I need to monitor for activity. I've been poking through the twisted code to see how I can add these file descriptors to the reactor, but I'm just not seeing how it can be done. My closest guess right now would be to wrap my file descriptor in a FileDescriptor object, but I'm not seeing how to add that to the reactor, or how to tell it what code to call when there is activity on that descriptor. Can anyone give me some insight into what I need to do, or point me at some documentation that would explain what I need to do? For system details, I'll be doing this with Python 2.3.5, Twisted 2.0.1, on both Mac OS X Tiger, and Red Hat Linux. Thanks. -- Jason Fritcher Software Engineer Core Infrastructure Services & Strategy Earthlink, Inc fritcher(a)corp.earthlink.net (404) 748-7262, x22262

1 0

[Twisted-Python] Twisted api docs
by snacktime 03 Aug '05

03 Aug '05

I remember there being very complete api documentation for twisted 1.3, but I can't find anything similar on the website for twisted 2. Do they no longer exist or am I just blind? Chris

3 3

[Twisted-Python] process status
by Daniel Isenegger 02 Aug '05

02 Aug '05

How to query process state and receive back control? Hi, a newbie question: i struggle with the defer-mechanism. i start from a client program a using defers a protocol.ProcessProtocol-class to invoke a local application (grass) to display a raster. This works fine, the problem is now how to propagate back the final state of the invoked process back to the invoking instance and then to get the control back over the shell the process has been running in. I can see that the state of the invoked process can be accesses in processEnded(), but when this function is invoked the connection to the invoking instance is already closed, so the state cannot be propagated to this invoking instance. Additionaly the shell the process has been invoked does not receive further output of the invoking process., so i assume that the control is not handed back to the invoking process Any hints? Thanks Dani In the following some excerpts of code to illustrate my problem: invoking process: ############################################################# # invokes GIS to display the raster cmd, using IpodlasProcess to # call a process on the machine def displayRaster(self): # init deferred object d d = defer.Deferred() # add the pair of callbacks d.addCallback(self.handleDisplayRaster) d.addErrback(self.handleDisplayRasterFailure) # #invoke the deferred functions: i.e. handleDisplayRaster # and handleDisplayRasterFailure d.callback(rasterfile) print "displayRaster: after d.callback()" # ############################################################ # handles the successfull call of the display of the raster theRaster def handleDisplayRaster(self,theRaster): # # init IpodlasProcess ip = IpodlasProcess() # # # invoke IpodlasProcess to invoke Grass to display the raster theRaster ip.displayRaster(theRaster) # ######################################################### # handles the failed call of the display of the file theFoile # and its return object theFailure def handleDisplayRasterFailure(self,theFailure): # theFailure.trap(RuntimeError) # ############################################################################### # IpodlasClientFactory is derived from ReconnectingClientFactory, which tries # to reconnect if connection is lost class IpodlasClientFactory(ReconnectingClientFactory): # creates protocol and receives events relating to connection state # def startedConnecting(self, connector): print 'Started to connect.' def buildProtocol(self, addr): print 'Connected.' print 'Resetting reconnection delay' self.resetDelay() # associated subsystem is the GUI return IpodlasClient() def clientConnectionLost(self, connector, reason): print 'Lost connection. Reason:', reason # tries to reconnect, if conn fails with exponentially delays ReconnectingClientFactory.clientConnectionLost(self, connector, reason) # # if connection could not be established def clientConnectionFailed(self, connector, reason): print 'Connection failed. Reason:', reason ReconnectingClientFactory.clientConnectionFailed(self, connector, reason) ################################################################### if __name__ == "__main__": # if len(sys.argv) > 1: # set global subsystem assoSubsys = sys.argv[1] #print assoSubsys # from twisted.internet import reactor reactor.connectTCP("localhost",51423,IpodlasClientFactory()) reactor.run() invoked Process: #! /usr/bin/python # File:ipodlasProcess.py """ ipodlasProcess.py usage: python ipodlasProcess.py """ from twisted.internet import protocol from twisted.internet import reactor from twisted.internet import utils #needed to query process termination status import re import os import gc # own classes class IpodlasProcess(protocol.ProcessProtocol): def __init__(self): self.data = "" # # def connectionMade(self): print "IP connectionMade" self.transport.closeStdin() # data from standard output is receieve in outReceived. def outReceived(self, data): print "IP outReceived: " + self.data self.data = self.data + data # def errReceived(self, data): print "IP errReceived():" + data # def inConnectionLost(self): print "IP inConnectionLost! stdin is closed! (we probably did it)" # def outConnectionLost(self): print "IP outConnectionLost data: " + self.data # def errConnectionLost(self): print "IP errConnectionLost! stdin is closed! (we probably did it)" # def processEnded(self, status_object): self.processStatus = status_object.value.exitCode print "IP processEnded, status: " + str(status_object.value.exitCode) \ + "\nquitting " # this is outcommented, since otherwise the reactor of ipodlasClient would # stopped, since this is the one which controls ipodlasProcess (the own in # the main fctn is only started, when invoked from cmd-line) # reactor.stop # def displayRaster(self,theRaster): # cmd = "d.rast" arg1 = theRaster arg2 = "bg=white" # processes are runned trough reactor using spawnProcess # invoke process cmd with the args arg1, arg2 and the parent process # environment env reactor.spawnProcess(self,cmd,[cmd,arg1,arg2],env=os.environ) # print "IP displayRaster" ################################################################### if __name__ == "__main__": # ip = IpodlasProcess() ip.displayRaster("upperEngadine_raster") # reactor.run()

1 0

Twisted August 2005