Mailman 3 August 2005 - Twisted

[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 11 Aug '05

11 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