Twisted July 2005

twisted@python.org

68 participants
69 discussions

[Twisted-Python] Trouble with example imap client on unread messages

by Andy Gayton

I'm having trouble running Twisted/doc/mail/examples/imap4client.py on imap folders which have unread messages. When the client issues: proto.fetchSpecific('1:*', headerType='HEADER.FIELDS', headerArgs=['SUBJECT'] ) My server is returning: * 243 FETCH (BODY[HEADER.FIELDS ("SUBJECT")] {47} Subject: DELIVERY REPORTS ABOUT YOUR E-MAIL ) * 244 FETCH (BODY[HEADER.FIELDS ("SUBJECT")] {42} Subject: AW: [syslinux] bug(?) in 2.11 ) * 244 FETCH (FLAGS (\Seen)) 243 is a previously read message, 244 is an unread message. The callback for the above fetchSpecific call is receiving: { 243 : [['BODY', ['HEADER.FIELDS', ['SUBJECT']], 'Subject: DELIVERY REPORTS ABOUT YOUR E-MAIL\r\n\r\n']], 244 : [['FLAGS', ['\\Seen']]] } ie, I'm not getting the subject for unread messages. Just wondering if this is a problem at twisted's end (is it incorrectly reducing the server response for 244 to [['FLAGS', ['\\Seen']]]?), my imap server (is it incorrect that my server is including the extra * 244 FETCH (FLAGS (\Seen)) line ? I'm using BincIMAP v1.2.12) or me :) (am I running something wrong here?) cheers, Andy.

16 years, 4 months

[Twisted-Python] [cpushare@cpushare.com: CPUShare Exception]

by Andrea Arcangeli

Hello, I wrote the below code in my server: from twisted.python import log # local from cpushare.mail import send_exception class cpushare_logging_observer_class(object): def __init__(self, factory): self.factory = factory def start(self): if self.factory.production: log.addObserver(self.emit) def stop(self): if self.factory.production: log.removeObserver(self.emit) def emit(self, eventDict): edm = eventDict['message'] if not edm: if eventDict['isError'] and eventDict.has_key('failure'): send_exception(eventDict['failure']) to receive exceptions by email like the below if (send_exception sends me an sms for the very first exception too). I do a very similar thing in nevow, but in nevow I handle it through the nevow layer, not through twisted. Now to me it seems that the below exception isn't really interesting to me, any client could generate it by injecting garbage in the ssl connection. Does anybody has suggestions on the best way to filter out all OpenSSL.SSL.Error exceptions before calling send_exception in the above code? Thanks! (twisted is great ;) ----- Forwarded message from cpushare(a)cpushare.com ----- Date: Thu, 7 Jul 2005 14:14:08 +0200 (CEST) From: cpushare(a)cpushare.com To: andrea.kernel(a)tiscali.it Subject: CPUShare Exception X-Mailbox-Line: From nobody Thu Jul 7 14:14:07 2005 Traceback (most recent call last): File "/home/build/bin/i686/python-20050707/lib/python2.4/site-packages/twisted/python/log.py", line 43, in callWithContext File "/home/build/bin/i686/python-20050707/lib/python2.4/site-packages/twisted/python/context.py", line 59, in callWithContext File "/home/build/bin/i686/python-20050707/lib/python2.4/site-packages/twisted/python/context.py", line 37, in callWithContext File "/home/build/bin/i686/python-20050707/lib/python2.4/site-packages/twisted/internet/pollreactor.py", line 160, in _doReadOrWrite --- <exception caught here> --- File "/home/build/bin/i686/python-20050707/lib/python2.4/site-packages/twisted/internet/tcp.py", line 111, in doRead File "/home/build/bin/i686/python-20050707/lib/python2.4/site-packages/twisted/internet/tcp.py", line 339, in doRead OpenSSL.SSL.Error: [('SSL routines', 'SSL3_READ_BYTES', 'ssl handshake failure')] ----- End forwarded message -----

16 years, 4 months

[Twisted-Python] Twisted communication with embedded C thread

by Tom Cocagne

Greetings all, I was wondering if anyone has suggestions for a good way to go about setting up a message-passing communication channel between one or more C threads and a single thread dedicated to running Python/Twisted. I already have functional Python bindings accessing the contents of the messages (basically C structures) but need some way to exchange the messages between the C threads and the Python thread. All I really need is a means by which to inform Twisted's reactor that a C thread has sent a message. My original plan was to use a pair of pipes (via os.pipe()) to send pointers back and forth but it didn't seem to work on Windows . I'm pretty sure this will work fine for posix systems but it definitely didn't work on my first attempt with Windows (though the problem may have been due to my library configuration). I would imagine that something along these lines has been done before. Does anyone know of an existing approach or have suggestions for a better solution? Extra Details: I'm using Python 2.4.1, Twisted 2.0, and GLib 2.6 Cheers, Tom

16 years, 4 months

[Twisted-Python] Can I get the interface's IP addr from where the datagram is received?

by Eric Hsu

Hi all, I'm writting a udp server which may have multiple instances listening on multiple network interfaces, I need to get the network interface's address when datagrame received: class MyUdpServer(DatagramProtocol): def datagramReceived(self, data, addr): print "The client's addr is", addr print "My addr is", ??? How can I retrieve the IP? Thanks in advance! - Eric

16 years, 4 months

[Twisted-Python] Fast RPC

by William Waites

It looks like this has come up once or twice on the list under the guyse of "how do I make synchronous calls to PB from another application" with no clear answer. It seems to be hard to do because of the design of PB. Use XMLRPC is the usual response. Here's the situation. I have an embedded python interpreter running inside of Yate. Because of the way Yate deals with threads and signals, it seems to be hard to get a twisted reactor to run inside the embedded interpreter. I also have a twisted process that wraps an API around a database and exposes it over XMLRPC and PB. The embedded interpreter needs to get at various bits of data by making RPC calls to this API. Using XMLRPC works. But it is very slow. Especially since xmlrpclib wants to make a new TCP connection for each call. Using a test PB client, PB calls are much faster, since there is a persistant TCP connection and simpler encoding. I have toyed with the idea of using Sun RPC or something similar to have the embedded interpreter talk to a local twisted process that then would talk over the network, and perhaps this is not a bad option. Any suggestions for a way to make RPC calls over the network with the speed of the PB and the synchronicity of XMLRPC? Cheers, -w

16 years, 4 months

[Twisted-Python] SuxElementStream error

by Milan Avramovic

Hi, I've got a problem with Twisted, and I haven't seen it mentioned on the list in the last year (some sort of search would definitely help tho...) Anyway, when trying to run PyMSNt jabber transport, I get following error: File "/usr/inet/jabberd/PyMSNt-0.9.3/src/utils.py", line 97, in parseString es = SuxElementStream() TypeError: 'NoneType' object is not callable Now, on PyMSNt some people started talking about missing libraries, so here's the question: Which libraries does Twisted rely upon? I've got a Solaris box, manually patched up, so concrete library names will be much appreciated. Also, I've manually compiled python 2.4.1, however whole python build process seems to just swallow errors, so I'm a bit miffed here. All help appreciated. -- Kind regards, Milan Avramovic, System Engineer DataGate - http://www.DataGate.co.uk Tel: +44 8700 119090, Fax: +44 8700 119080 ____________________________________________________ This email is confidential and intended solely for the use of the individual to whom it is addressed. Any views or opinions presented are solely those of the author and do not necessarily represent those of DataGate Network Solutions Ltd. If you're not the intended recipient, be advised that you have received this email in error and that any use, dissemination, forwarding, printing, or copying of this email is strictly prohibited. If you have received this email in error please notify the sender by telephone on +44 (0)8700 11 90 90

16 years, 4 months

[Twisted-Python] Weekly Bug Summary

by James Y Knight

Bug summary ______________________ Since 2005-06-30 00:55:46.390000: Bugs opened: 8 Bugs closed: 6 Total open bugs: 398 (+2) Urgent: 9 (+0) Bug: 170 (+2) Feature: 143 (+0) Wish: 76 (+0) New / Reopened Bugs ______________________ ==== Bug ==== TypeError in Failure.raiseException when using defer.deferredGenerator and perspective broker (8 hours ago) http://twistedmatrix.com/bugs/issue1103 opened by titty [PB] _Dereferences showing up in cyclic data structures with pb, jelly, and Cacheable (5 days ago) http://twistedmatrix.com/bugs/issue1102 opened by phenyx twisted-bugs list is broken (6 days ago) http://twistedmatrix.com/bugs/issue1101 opened by exarkun Bugs Closed ______________________ ==== Bug ==== internet.py: self._port.stopListening() should check that self._port exists (2 weeks ago) http://twistedmatrix.com/bugs/issue1088 opened by loic, closed by exarkun

16 years, 4 months

[Twisted-Python] resolution failure after upgrade to twisted 2.0

by Paul Pelzl

Hello, I maintain a wxPython application that uses Twisted for the networking back-end. After upgrading from Twisted 1.3 to 2.0, the application fails to connect to a given hostname (e.g. "localhost"), although everything works fine if an explicit IP address is provided. My application runs the Twisted loop by polling with a timer, like so: ------------------------------------------------------------------------ class MyApp(wxApp): def OnInit(self): ... EVT_TIMER(self, TIMERID, self.OnTimer) self.timer = wxTimer(self, TIMERID) self.timer.Start(250, False) ... def OnTimer(self, event): reactor.runUntilCurrent() reactor.doIteration(0) def connect(self, event=None): ... reactor.connectTCP(hostname, portNum, MyClientFactory()) reactor.startRunning() app = MyApp(0) app.MainLoop() ------------------------------------------------------------------------ Any idea what's going on here? I suspect this guy is dealing with a related issue: http://groups-beta.google.com/group/comp.lang.python/browse_frm/thread/1f0b… Paul

16 years, 4 months

[Twisted-Python] ANN: Coil v0.1, a configuration library

by Itamar Shtull-Trauring

Coil is a configuration language, inspired by some of SmartFrog's features (http://www.hpl.hp.com/research/smartfrog/papers.htm), aimed at Python programs in general and Twisted in particular. Coil will at some point become twisted.coil and form the basis for a new (but, of course, completely optional) deployment system for Twisted. You can download it at: http://itamarst.org/software/coil-0.1.tar.gz and read the documentation (also in the tarball) at: http://svn.twistedmatrix.com/cvs/sandbox/itamar/coil/DOC.txt?view=auto&rev=… I forgot to add a license file, but it's licensed under same terms as Twisted itself (i.e. MIT license). Coil's development was sponsored by my employer, ITA Software (we're hiring: <http://www.itasoftware.com/careers/>) -- Itamar Shtull-Trauring <itamar(a)itamarst.org> http://itamarst.org

16 years, 4 months

[Twisted-Python] Adbapi, cp_reconnect and MySQL

by Yanick Dufresne

Hi all, quick question: In adbapi's Transaction.reopen: def reopen(self): if self._connection is None: self.reconnect() if self._cursor is not None: self.close() try: self._cursor = self._connection.cursor() return except: if not self._pool.reconnect: raise My understand of the goal of cp_reconnect is to ensure that at the beginning of a query, the connection be re-established if it timed out since the last query (I understand that trying to reconnect in the middle of an interaction could potentially have undesired and unpredictable effects). The code above seems to assume that self._connection.cursor() will raise ConnectionLost if the connection has timed out. My question is two-fold: 1) should it not specifically check for ConnectionLost rather than catch everything? 2) I don't know about other backends, but MySQL will cheerfully give you a cursor object whenever you ask for one, and only raises ConnectionLost when you actually call execute on the cursor, making the code above completely ineffective. Anyone has a clever solution to this, short of inserting " self._cursor.execute(self._pool.good_sql)" in the try block? That works, but isn't exactly performance friendly... Any help appreciated, Yanick Dufresne Iotum Corporation

16 years, 4 months

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

2007

2006

2005

2004

2003

2002

2001

Twisted July 2005