Mailman 3 December 2003 - Twisted

[Twisted-Python] reactor.callLater ponderings
by jjanecek＠telusplanet.net Dec. 15, 2003

Dec. 15, 2003

I created this little program to test the callLater feacture in twisted. from twisted.internet import pollreactor pollreactor.install() ##try : ## from twisted.internet import win32eventreactor ## win32eventreactor.install() ##except : ## print "can not install win32 reactor" from twisted.internet import reactor from twisted.python import threadable from twisted.internet import threads threadable.init(1) reactor.suggestThreadPoolSize(10) print reactor import time #conclusions would be … [View More]possible to correct so reactor #fires more accuratly not required since it is pretty close #for what ever reason reactor can not go finer then 10ms #on freebsd the min timer frequency is 20.0 ms frequency=20.0 #time that callback will pulse in ms clock_count=0 start_time=None last_tick=0 def clock_pulse() : global start_time,clock_count,last_tick if start_time==None : start_time=time.time() next_time=frequency/1000.0 #i noticed that the clock needs to be corrected #to keep proper time over a long period cur_time=(time.time()-start_time)*1000 if (cur_time-clock_count)>frequency : print "too slow correction" next_time=0 elif(clock_count-cur_time)>frequency : print "too fast correction" next_time=(frequency/1000.0)*2 #if clock_count>0 : #last_tick=time.time reactor.callLater(next_time,clock_pulse) reactor.callInThread(clock_pulse_thread) clock_count+=frequency #clock_pulse_thread() def clock_pulse_thread() : global start_time,clock_count,last_tick cur_time=time.time() if last_tick>0 : print "diff ",(cur_time-last_tick)*1000 pass last_tick=cur_time if clock_count>=1000 : stop_time=time.time() real_time=(stop_time-start_time)*1000 print "Total Time= ",clock_count," ",real_time print "Difference= ",clock_count-real_time," percent ",((clock_count-real_time)/real_time)*100.0 reactor.stop() time.sleep(0.01) reactor.callLater(frequency/1000.0,clock_pulse) reactor.run() Now the instresting thing is that is windows the smallest increment i can call the callback with is like 10 ms. While on freebsd even using kqueue it is like 20 ms. I guess you could call that smallest increment like a tick. ticks in freebsd and on windows are accurate while on linux they seem to be all over the place, why is this ? Also is there a place that I can use to set how frequent i want the reactor to check to see if a callLater function should be run ? While on Linux (I tested using redhat 9.0 and mandrake 9.2) it does not seem to be accurate on anything under 1 second. I peeked inside the basereactor code and it does not seem to shed anylight. I am running the clock pulse in a thread to simulate that it has to wait for something. [View Less]

3 2

[Twisted-Python] PATCH: psycopg support in test_enterprise.py
by Federico Di Gregorio Dec. 14, 2003

Dec. 14, 2003

Hi *, lately some people asked me why twisted does not support psycopg. Mm.. actually I write all my twisted-based code using psycopg so I was a little bit disappointed. :) They told me that twisted is using pypgsql as default and I finally realized what they meant: psycopg is missing from the test_enterprise.py unit test and pypgsql is listed as "the" postgresql adapter. So here's the patch that adds psycopg to test_enterprise.py (I don't care about the "the" part :) federico -- Federico … [View More]

2 2

[Twisted-Python] Small Problem -twisted web
by Mike Owens Dec. 14, 2003

Dec. 14, 2003

I have written a script that runs as a Win32 service. The service runs but when I try to connect I get a connection refused error in the browser. I am including the source at the end. Also the call to unlistenTCP doesn't seem to return. Anyone have any ideas? import win32serviceutil as wsu import win32service as ws import win32event as we from twisted.internet import app from twisted.web import static, server, vhost, script DefaultSite = r"sites\Default\documents" my = r"sites\my\documents"… [View More]

2 1

[Twisted-Python] mktap not working with Twisted_NoDocs-1.1.1.win32-py2.3.exe
by Kevin Howe Dec. 13, 2003

Dec. 13, 2003

I just installed "Twisted_NoDocs-1.1.1.win32-py2.3.exe" but am not able to use mktap. When I run "mktap.py --path=c:\my\path --port 8080" the script runs with no errors (I tried using --debug), it just just ends with no TAP file being created?

3 2

[Twisted-Python] patch for finger14.py
by Martin Waite Dec. 13, 2003

Dec. 13, 2003

Hi, Below is a patched up version of finger14.py for the tutorial page. The key difference here is that the FingerService is registered as a service of the application, and so the startService() and stopService() methods are called appropriately. I have also removed the statement f.startService = self.startService from within getFingerFactory(), because it didn't do anything. Also, self.file has become self.filename in _read(). It does work now, but is this the right way to do it ?… [View More]

2 1

[Twisted-Python] template in wchild
by vicky lupien Dec. 12, 2003

Dec. 12, 2003

I have a web base application with woven. I'm using an html template with a form for my page. In the setUp fonction I've changed my template. So when I click on my submit button in my form, I want to see the template with the modification from the setUp in my wchild_submit. I don't know if it's possible. I tried to use request.d but it's seems that it's not the same request from my page's class. Thx in advance, Vicky

2 1

[Twisted-Python] PyOpenSSL for Python 2.3
by Steve Jibson Dec. 12, 2003

Dec. 12, 2003

Hi. Sorry to bother you, but do you have (or can you point me to) a binary distribution of pyOpenSSL for Python 2.3? Thanks, Steve

2 1

[Twisted-Python] Re: Installing Twisted 1.0.7 on FreeBSD 4.4
by Lee Harr Dec. 12, 2003

Dec. 12, 2003

>I'm wanting to install proxy65 onto a Jabber server - which requires at a >minimum Twisted v1.0.7. The only port of I see of Twisted for FreeBSD is >1.0.6. Has anyone successfully installed v1.0.7 onto a FreeBSD 4.4 system? >Anything to look out for/gotcha's/etc? > 1.1.0 is the current version in ports. That said, FreeBSD 4.4 is pretty outdated, and you may have trouble compiling anything from the ports collection. I have read a few messages recently which hinted that people … [View More]

1 0

[Twisted-Python] IRC & Excess-Flood
by Richard Livsey Dec. 12, 2003

Dec. 12, 2003

I'm in the process of writing an IRC component to an app I've made. All seems to work fine, except when it comes to output a lot of data it gets booted from the IRC server for flooding :o) *** Quits: SearchBot (Excess Flood) However, it doesn't seem to just disconnect as clientConnectionLost doesn't get called. In the logs, it says: 'Stopping factory <__builtin__.IRCClientFactoryFromService instance at 0x00CE06E8>' Any ideas on what I can do to stop it happening? For the moment I'… [View More]

3 5

[Twisted-Python] startService not called in finger14.py ?
by Martin Waite Dec. 12, 2003

Dec. 12, 2003

Hi, It seems that FingerService.stopService() and FingerService.startService() never actually get called in finger14.py in the tutorial. I have added logging into startService() and stopService() to trace when they get called: ========================================================== # Read from file from twisted.application import internet, service from twisted.internet import protocol, reactor, defer from twisted.protocols import basic from twisted.python import log class FingerProtocol(… [View More]basic.LineReceiver): def lineReceived(self, user): self.factory.getUser(user ).addErrback(lambda _: "Internal error in server" ).addCallback(lambda m: (self.transport.write(m+"\r\n"), self.transport.loseConnection())) class FingerService(service.Service): def __init__(self, filename): self.users = {} self.filename = filename def startService(self): def _read(self): for line in file(self.file): user, status = line.split(':', 1) user=user.strip() status=status.strip() self.users[user] = status self.call = reactor.callLater(30, _read) _read() log.msg( "startService" ) service.Service.startService(self) def stopService(self): log.msg( "stopService" ) service.Service.stopService(self) self.call.cancel() def getUser(self, user): return defer.succeed(self.users.get(user, "No such user")) def getFingerFactory(self): log.msg( "getFingerFactory" ) f = protocol.ServerFactory() f.protocol, f.getUser = FingerProtocol, self.getUser, f.startService = self.startService return f application = service.Application('finger', uid=1, gid=1) f = FingerService('/home/martin/users') finger = internet.TCPServer(1079, f.getFingerFactory()) finger.setServiceParent(service.IServiceCollection(application)) ========================================================== Running the example: twistd2.2 -noy finger14.py 2003/12/11 11:20 GMT [-] Log opened. 2003/12/11 11:20 GMT [-] twistd 1.1.1 (/usr/bin/python2.2 2.2.1) starting up 2003/12/11 11:20 GMT [-] reactor class: twisted.internet.default.SelectReactor 2003/12/11 11:20 GMT [-] Loading finger14.py... 2003/12/11 11:20 GMT [-] getFingerFactory 2003/12/11 11:20 GMT [-] Loaded. 2003/12/11 11:20 GMT [-] twisted.internet.protocol.ServerFactory starting on 1079 2003/12/11 11:20 GMT [-] Starting factory <twisted.internet.protocol.ServerFactory instance at 0x828e5e4> <ctrl-C> 2003/12/11 11:20 GMT [-] (Port 1079 Closed) 2003/12/11 11:20 GMT [-] Stopping factory <twisted.internet.protocol.ServerFactory instance at 0x828e5e4> 2003/12/11 11:20 GMT [-] Main loop terminated. 2003/12/11 11:20 GMT [-] Server Shut Down. ========================== This is bad news for me because I'm trying to write a service based on this code. I really want stopService() to be called so I can cleanly close down my app, but I can't figure out how to do it. Can anyone help please ? regards, Martin [View Less]

4 4