Mailman 3 February 2003 - Twisted

[Twisted-Python] integrating twisted into an existing application
by Anthony Baxter Feb. 18, 2003

Feb. 18, 2003

I have a large complex application that I'd like to start migrating to twisted, and I'd appreciate feedback on how to implement this. It's a large (around 17KLOC) voicemail server that works with a cisco AS5x00 to provide unified messaging. It talks RADIUS, RTSP and RTP to the cisco, IMAP and SMTP to the message stores, and has a telnet interface for administration and debugging. The current implementation has a separate thread for each of the RTSP, RADIUS and telnet listeners, and spawns a … [View More]

3 2

[Twisted-Python] twisted.web.server.Request.notifyFinish
by Moshe Zadka Feb. 18, 2003

Feb. 18, 2003

After asked how to know when the other side has terminated a web connection, and noticing there wasn't a way I've added the above mentioned method. It is documented in using-twistedweb. -- Moshe Zadka -- http://moshez.org/ Buffy: I don't like you hanging out with someone that... short. Riley: Yeah, a lot of young people nowadays are experimenting with shortness.

1 0

[Twisted-Python] newbie: asynchronous client
by Joshua Bloom Feb. 18, 2003

Feb. 18, 2003

I'd like to set up a non-blocking TCP client that loops indefinately, waiting for the user to input something (which gets sent to the server) but also responds to server replies whenever it can. So after I send "factorial 1234" to the server, I'd like to be able to say "1 + 2" before the server returns and get a response from that. Thanks in advance for any pointers. Josh Bloom

7 12

[Twisted-Python] Twisted Sister
by Jp Calderone Feb. 17, 2003

Feb. 17, 2003

Time and API changes seem to have taken their toll on twisted.sister. Currently, "mktap sister" fails with AttributeError: twisted.cred.authorizer.DefaultAuthorizer instance has no accessor for: loadIdentity Obviously because DefaultAuthorizer doesn't provide loadIdentity - TicketAuthorizer does. I don't see any API for changing the authorizer of an application, though. A quick hack, setting app._authorizer = TicketAuthorizer() at the beginning of sistap.py's updateApplication() solves … [View More]

1 0

[Twisted-Python] man page web links broken
by Mario Ruggier Feb. 17, 2003

Feb. 17, 2003

Hi, just to signal that all links on http://twistedmatrix.com/documents/man/index are broken... mario

2 1

[Twisted-Python] twisted rooming scholarships for PyCon
by Steve Waterbury Feb. 17, 2003

Feb. 17, 2003

Hey gang, If anyone out there is coming to PyCon and hasn't yet made a reservation, I can accomodate one (or two, if they tolerate each other well ;^) at the waterbug mansion. (Yes "mansion" *is* a joke; my house is very humble!) Chris Armstrong and Donovan Preston will be here Sunday eve, but they will be going to their hotels for the rest of their stay, so my living room (with convertible couch, and a futon for one more) is available the rest of the week. I'm planning on attending … [View More]

1 0

[Twisted-Python] A useful value for argv[0]
by Jp Calderone Feb. 17, 2003

Feb. 17, 2003

I think it would be neat if twistd re-executed itself(/python), and specified the name of the tap/tas/tax file it was currently processing as the value for argv[0]. This would make administering a system with many twistd processes running much easier. Want to see your webserver? Just run "ps -C web.tap". Of course there could still be name conflicts, but this might encourage the naming of tap files to be more selective. The system wide twisted.web tap could be "system-web" and Bob's … [View More]

13 25

[Twisted-Python] patch: win32serialport.py implementation
by Chris Liechti Feb. 16, 2003

Feb. 16, 2003

here is an implementation for the serial port module for win32. it uses a overlapped read of one character and when the event occours, it reads as much as possible from the buffer. writes are overlapped too, meaning that if the send buffer of the os is full, that a python queue is used to save the output for later. i hope that this gives a good performance, low latencies and short function calls. note that i was not sucessful with the WaitCommEvent function that would allow event based … [View More]programming not only for the data but also for the data lines. but this function is broken for overlapped IO in older win32all releases (fixed in newer ones) but i experienced crashes nontheless. (setting up an overlapped wait, then using a WaitForSingleObject worked, but it did crash when using the win32 reactor of twisted. the crash was after the exit of the event handler, but before the control was back in the event loop of twisted. i guess there is some c- stack corruption involved) however, i think that the implementation below is a solid solution. also note that i removed the timeout parameter from the twisted SerialPort class. i think it does not make sense as its event based.. even worse, a wrong timeout could cause malfunction. i sugest that the timeout parameter is removed in posixserial.py and javaserial.py too and inserting the default value in the instantiation of the internal Serial object (like i've done it below). please cc me for comments, im not on the list, tnx. chris ------------------ begin: Twisted/twisted/internet/serialport/win32serialport.py ----------------- # Twisted, the Framework of Your Internet # Copyright (C) 2001-2002 Matthew W. Lefkowitz # this module: cliechti(a)gmx.net # # This library is free software; you can redistribute it and/or # modify it under the terms of version 2.1 of the GNU Lesser General Public # License as published by the Free Software Foundation. # # This library is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU # Lesser General Public License for more details. # # You should have received a copy of the GNU Lesser General Public # License along with this library; if not, write to the Free Software # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA """ Serial Port Protocol """ # system imports import os, Queue # dependent on pyserial ( http://pyserial.sf.net/ ) import serial from serial import PARITY_NONE, PARITY_EVEN, PARITY_ODD from serial import STOPBITS_ONE, STOPBITS_TWO from serial import FIVEBITS, SIXBITS, SEVENBITS, EIGHTBITS from serialport import BaseSerialPort import win32file, win32event # twisted imports from twisted.protocols import basic from twisted.internet import abstract from twisted.python import log class SerialPort(BaseSerialPort, abstract.FileDescriptor): """A select()able serial device, acting as a transport.""" connected = 1 def __init__(self, protocol, deviceNameOrPortNumber, reactor, baudrate = 9600, bytesize = EIGHTBITS, parity = PARITY_NONE, stopbits = STOPBITS_ONE, xonxoff = 0, rtscts = 0): self._serial = serial.Serial(deviceNameOrPortNumber, baudrate = baudrate, bytesize = bytesize, parity = parity, stopbits = stopbits, timeout = None, xonxoff = xonxoff, rtscts = rtscts) self.flushInput() self.flushOutput() self.reactor = reactor self.protocol = protocol self.outQueue = Queue.Queue() self.closed = 0 self.closedNotifies = 0 self.write_in_progress = 0 self.protocol = protocol self.protocol.makeConnection(self) self._overlapped_read = win32file.OVERLAPPED() self._overlapped_read.hEvent = win32event.CreateEvent(None, 0, 0, None) self._overlapped_write = win32file.OVERLAPPED() self._overlapped_write.hEvent = win32event.CreateEvent(None, 0, 0, None) self.reactor.addEvent(self._overlapped_read.hEvent, self, self.serialReadEvent) self.reactor.addEvent(self._overlapped_write.hEvent, self, self.serialWriteEvent) flags, comstat = win32file.ClearCommError(self._serial.hComPort) rc, self.read_buf = win32file.ReadFile(self._serial.hComPort, win32file.AllocateReadBuffer(1), self._overlapped_read) def serialReadEvent(self): #get that character we set up n = win32file.GetOverlappedResult(self._serial.hComPort, self._overlapped_read, 0) if n: first = str(self.read_buf[:n]) #now we should get everything that is already in the buffer flags, comstat = win32file.ClearCommError(self._serial.hComPort) rc, buf = win32file.ReadFile(self._serial.hComPort, win32file.AllocateReadBuffer(comstat.cbInQue), self._overlapped_read) n = win32file.GetOverlappedResult(self._serial.hComPort, self._overlapped_read, 1) #handle all the received data: self.protocol.dataReceived(first + str(buf[:n])) #set up next one rc, self.read_buf = win32file.ReadFile(self._serial.hComPort, win32file.AllocateReadBuffer(1), self._overlapped_read) def write(self, data): #~ self._serial.write(data) if self.write_in_progress: #~ log.msg('adding to write queue') self.outQueue.put(data) else: #~ log.msg('write') self.write_in_progress = 1 win32file.WriteFile(self._serial.hComPort, data, self._overlapped_write) def serialWriteEvent(self): try: dataToWrite = self.outQueue.get_nowait() except: self.write_in_progress = 0 #~ log.msg('outQueue empty') return else: win32file.WriteFile(self._serial.hComPort, dataToWrite, self._overlapped_write) def connectionLost(self, reason): #~ log.msg('connectionLost') self.reactor.removeEvent(self._overlapped_read.hEvent) self.reactor.removeEvent(self._overlapped_write.hEvent) abstract.FileDescriptor.connectionLost(self, reason) self._serial.close() ------------------ end: Twisted/twisted/internet/serialport/win32serialport.py ----------------- [View Less]

1 0

[Twisted-Python] a qtManhole
by cary Feb. 16, 2003

Feb. 16, 2003

hi guys, i needed a qtManhole so i put a simple one together. . meaning it doesnt support snazzy manhole stuff, just basic "remote interp/shell" functionality. . does manhole.explorer work now? perhaps a knowledgable twisted person could give me some pointers. . i thought this could be useful to twisted ppl who are on platforms where pyqt is easier to setup than pygtk. . would this be something that doc/examples could use? ( after i make it right, of course ) i have run this on linux/… [View More]windows/and zaurus5500 :) thanks, cary #!/usr/bin/env python ## by grrrendel(a)comcast.net """ qtManhole - manhole client that uses qt for gui """ from qt import * A=QApplication([]) from twisted.internet import qtreactor qtreactor.install( A ) from twisted.cred.error import * from twisted.internet.error import * from twisted.spread import pb from twisted.python import usage import string,traceback class Options( usage.Options ): synopsis="Usage: qtManhole [options]" optParameters=[["host","h", None, "Host address"], ["port","p", None, "Port number"], ["user","u", None, "Username"], ["pswd","w", None, "Password"]] def postOptions( self ): for i in self.opts.keys(): if not self.opts[i]: raise usage.UsageError, "Wrong, try again." class Interaction( pb.Referenceable ): capabilities={} def __init__( self, gui ): self.gui=gui def remote_console( self, message ): for i in message: if i[0] == 'exception': s=traceback.format_list(i[1]['traceback']) s.extend(i[1]['exception']) s=string.join(s,'') else: s=i[1] self.gui.showoutput( str( s ) ) def remote_recieveExplorer( self, xplorer ): pass def remote_listCapabilities( self ): return self.capabilities class CLI( QWidget ): def __init__( self, parent=None, name=None ): QWidget.__init__( self, parent, name ) self.vlo=QVBoxLayout( self ) self.output=QTextView( self ) self.vlo.addWidget( self.output ) self.input=QLineEdit( self ) self.vlo.addWidget( self.input ) self.input.setFocus() class HoleClient( QMainWindow ): def __init__( self, opts ): QMainWindow.__init__( self, None, None ) self.host=opts['host'] self.port=int(opts['port']) self.user=opts['user'] self.pswd=opts['pswd'] self.service='manhole' self.setCaption( "qtManhole" ) self.resize( 500, 500 ) self.io=CLI(self) self.setCentralWidget( self.io ) self.client=Interaction( self ) self.status=self.statusBar() self.menubar=self.menuBar() self.filemenu=QPopupMenu( self ) self.filemenu.insertItem( '&Close', self.close ) self.menubar.insertItem( '&File', self.filemenu ) self.connect( self.io.input, SIGNAL( "returnPressed()" ), self.do ) self.getPersp() def getPersp( self ): pb.connect( self.host, self.port, self.user, self.pswd, self.service, client=self.client ).addCallbacks( self._setPersp, self._eb_getPersp ) def _setPersp( self, persp ): self.persp=persp def _eb_getPersp( self, fail ): e = fail.trap( ConnectError, Unauthorized, KeyError ) QMessageBox.warning( self, 'Warning', str( e ) ) def do( self ): text=str( self.io.input.text() ) self.persp.callRemote( 'do', text ).addErrback( self._eb_do ) self.showoutput("<font color=red>>> "+ text) self.io.input.clear() _eb_do=_eb_getPersp def showoutput( self, text ): self.io.output.append( text ) if __name__ == '__main__': from twisted.internet import reactor opts=Options() try: opts.parseOptions() except usage.UsageError, e: print str(e) print str(opts) raise SystemExit else: HoleClient(opts).show() reactor.addSystemEventTrigger('after', 'shutdown', A.quit ) A.connect( A, SIGNAL("lastWindowClosed()"), reactor.stop ) reactor.run() [View Less]

3 2

[Twisted-Python] buildbot?
by Cory Dodt Feb. 16, 2003

Feb. 16, 2003

The buildbot at http://twistedmatrix.com/~warner.twistd/ was pointed out to me. I noticed that my new document, extend-lore.html is causing hlint errors in buildbot. hlint runs clean on my local machine, and I think it fails because it can't find the doc/howto/listings/lore directory, which is new. Does buildbot use cvs up -d to check out the code? If not, it should, because that would fix the problem I'm seeing above. Thanks! C __________________________________________________ Do you … [View More]

2 1