Changeset 1946

Timestamp:

04/21/08 12:05:09

Author:

dan

Message:

checking signals

Files:

• branches/769-unixwait/cherrypy/process/unix_threading/Makefile (added)
• branches/769-unixwait/cherrypy/process/unix_threading/__init__.py (modified) (1 diff)
• branches/769-unixwait/cherrypy/process/unix_threading/_native_event.py (added)
• branches/769-unixwait/cherrypy/process/unix_threading/_pthread_cond.c (modified) (1 diff)
• branches/769-unixwait/cherrypy/process/unix_threading/test.py (added)

branches/769-unixwait/cherrypy/process/unix_threading/__init__.py

@@ -1 @@
-
-
+
-
-class NativeEvent(threading._Event):
-    def __init__(self):
-        threading._Event.__init__(self)
-        self.__cond = _pthread_cond.Condition()
-

branches/769-unixwait/cherrypy/process/unix_threading/_pthread_cond.c

@@ -120 +120 @@
-  int err = 0;
-  while( !self->set && err != EINVAL ) {
+    /*    struct timespec timeout = {0};
+    timeout.tv_sec = time(0) + 4;
+
+    Py_BEGIN_ALLOW_THREADS;
+    err = pthread_cond_timedwait( &self->cond, &self->lock, &timeout );
+    Py_END_ALLOW_THREADS;
+    */
-    Py_BEGIN_ALLOW_THREADS;
-    err = pthread_cond_wait( &self->cond, &self->lock );
-    Py_END_ALLOW_THREADS;
+    if( PyErr_CheckSignals() ) {
+      return NULL;
+    }
-  }
-  if( err != 0 ) {