Part of twisted.internet View Source
A kqueue()/kevent() based implementation of the Twisted main loop.
To install the event loop (and you should do this before any connections, listeners or connectors are added):| from twisted.internet import kqreactor | kqreactor.install()
This reactor only works on FreeBSD and requires PyKQueue 1.3, which is available at: http://people.freebsd.org/~dwhite/PyKQueue/
You're going to need to patch PyKqueue:
=====================================================
--- PyKQueue-1.3/kqsyscallmodule.c Sun Jan 28 21:59:50 2001
+++ PyKQueue-1.3/kqsyscallmodule.c.new Tue Jul 30 18:06:08 2002
@@ -137,7 +137,7 @@
}
statichere PyTypeObject KQEvent_Type = {
- PyObject_HEAD_INIT(NULL)
+ PyObject_HEAD_INIT(&PyType_Type)
0, // ob_size
"KQEvent", // tp_name
sizeof(KQEventObject), // tp_basicsize
@@ -291,13 +291,14 @@
/* Build timespec for timeout */
totimespec.tv_sec = timeout / 1000;
- totimespec.tv_nsec = (timeout % 1000) * 100000;
+ totimespec.tv_nsec = (timeout % 1000) * 1000000;
// printf("timespec: sec=%d nsec=%d\n", totimespec.tv_sec, totimespec.tv_nsec);
/* Make the call */
-
+ Py_BEGIN_ALLOW_THREADS
gotNumEvents = kevent (self->fd, changelist, haveNumEvents, triggered, wantNumEvents, &totimespec);
+ Py_END_ALLOW_THREADS
/* Don't need the input event list anymore, so get rid of it */
free (changelist);
@@ -361,7 +362,7 @@
statichere PyTypeObject KQueue_Type = {
/* The ob_type field must be initialized in the module init function
* to be portable to Windows without using C++. */
- PyObject_HEAD_INIT(NULL)
+ PyObject_HEAD_INIT(&PyType_Type)
0, /*ob_size*/
"KQueue", /*tp_name*/
sizeof(KQueueObject), /*tp_basicsize*/
| Class | KQueueReactor | A reactor that uses kqueue(2)/kevent(2). |
| Function | install | Undocumented |