summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJoel Sherrill <joel.sherrill@OARcorp.com>2011-07-31 22:41:06 +0000
committerJoel Sherrill <joel.sherrill@OARcorp.com>2011-07-31 22:41:06 +0000
commit0cc08a21487798f7b196b0a8e0867d6a6772de97 (patch)
treefaffcf72faccfb85be75f8179cc386aebd4d68a1
parente6e75e20f76c6302bcb4fc3572c00873a464283f (diff)
2011-07-31 Joel Sherrill <joel.sherrilL@OARcorp.com>
PR 1855/cpukit * posix/src/psignal.c, posix/src/psignalunblockthread.c, posix/src/pthread.c, posix/src/pthreadjoin.c: Correct signal processing during pthread_join. We are supposed to unblock the thread waiting on a pthread_join(), dispatch the signal handler, account for it potentially overwriting errno, and then have the thread return to blocking within pthread_join().
-rw-r--r--cpukit/ChangeLog10
-rw-r--r--cpukit/posix/src/psignal.c9
-rw-r--r--cpukit/posix/src/psignalunblockthread.c25
-rw-r--r--cpukit/posix/src/pthread.c2
-rw-r--r--cpukit/posix/src/pthreadjoin.c6
5 files changed, 34 insertions, 18 deletions
diff --git a/cpukit/ChangeLog b/cpukit/ChangeLog
index 11eedb4d9c..25d2e9a96d 100644
--- a/cpukit/ChangeLog
+++ b/cpukit/ChangeLog
@@ -1,5 +1,15 @@
2011-07-31 Joel Sherrill <joel.sherrilL@OARcorp.com>
+ PR 1855/cpukit
+ * posix/src/psignal.c, posix/src/psignalunblockthread.c,
+ posix/src/pthread.c, posix/src/pthreadjoin.c: Correct signal
+ processing during pthread_join. We are supposed to unblock the thread
+ waiting on a pthread_join(), dispatch the signal handler, account for
+ it potentially overwriting errno, and then have the thread return to
+ blocking within pthread_join().
+
+2011-07-31 Joel Sherrill <joel.sherrilL@OARcorp.com>
+
PR 1867/cpukit
* posix/src/pthreadexit.c, posix/src/pthreadjoin.c: Correct
implementation of pthread_exit() and pthread_join() to support the
diff --git a/cpukit/posix/src/psignal.c b/cpukit/posix/src/psignal.c
index e9831256a6..426f54aec6 100644
--- a/cpukit/posix/src/psignal.c
+++ b/cpukit/posix/src/psignal.c
@@ -1,5 +1,5 @@
/*
- * COPYRIGHT (c) 1989-2007.
+ * COPYRIGHT (c) 1989-2011.
* On-Line Applications Research Corporation (OAR).
*
* The license and distribution terms for this file may be
@@ -106,6 +106,13 @@ void _POSIX_signals_Post_switch_extension(
POSIX_API_Control *api;
int signo;
ISR_Level level;
+ int hold_errno;
+
+ /*
+ * We need to ensure that if the signal handler executes a call
+ * which overwrites the unblocking status, we restore it.
+ */
+ hold_errno = _Thread_Executing->Wait.return_code;
api = the_thread->API_Extensions[ THREAD_API_POSIX ];
if ( !api )
diff --git a/cpukit/posix/src/psignalunblockthread.c b/cpukit/posix/src/psignalunblockthread.c
index 40cb43a8a9..69b799d1a6 100644
--- a/cpukit/posix/src/psignalunblockthread.c
+++ b/cpukit/posix/src/psignalunblockthread.c
@@ -1,5 +1,5 @@
/*
- * COPYRIGHT (c) 1989-2007.
+ * COPYRIGHT (c) 1989-2011.
* On-Line Applications Research Corporation (OAR).
*
* The license and distribution terms for this file may be
@@ -103,21 +103,16 @@ bool _POSIX_signals_Unblock_thread(
if ( the_thread->current_state & STATES_INTERRUPTIBLE_BY_SIGNAL ) {
the_thread->Wait.return_code = EINTR;
/*
- * At this time, there is no RTEMS API object which lets a task
- * block on a thread queue and be interruptible by a POSIX signal.
- * If an object class with that requirement is ever added, enable
- * this code.
+ * In pthread_cond_wait, a thread will be blocking on a thread
+ * queue, but is also interruptible by a POSIX signal.
*/
- #if 0
- if ( _States_Is_waiting_on_thread_queue(the_thread->current_state) )
- _Thread_queue_Extract_with_proxy( the_thread );
- else
- #endif
- if ( _States_Is_delaying(the_thread->current_state) ){
- if ( _Watchdog_Is_active( &the_thread->Timer ) )
- (void) _Watchdog_Remove( &the_thread->Timer );
- _Thread_Unblock( the_thread );
- }
+ if ( _States_Is_waiting_on_thread_queue(the_thread->current_state) )
+ _Thread_queue_Extract_with_proxy( the_thread );
+ else if ( _States_Is_delaying(the_thread->current_state) ){
+ (void) _Watchdog_Remove( &the_thread->Timer );
+ _Thread_Unblock( the_thread );
+ }
+
} else if ( the_thread->current_state == STATES_READY ) {
if ( _ISR_Is_in_progress() && _Thread_Is_executing( the_thread ) )
_ISR_Signals_to_thread_executing = TRUE;
diff --git a/cpukit/posix/src/pthread.c b/cpukit/posix/src/pthread.c
index 4a53d939be..d3bf71f909 100644
--- a/cpukit/posix/src/pthread.c
+++ b/cpukit/posix/src/pthread.c
@@ -185,7 +185,7 @@ bool _POSIX_Threads_Create_extension(
_Thread_queue_Initialize(
&api->Join_List,
THREAD_QUEUE_DISCIPLINE_FIFO,
- STATES_WAITING_FOR_JOIN_AT_EXIT,
+ STATES_WAITING_FOR_JOIN_AT_EXIT | STATES_INTERRUPTIBLE_BY_SIGNAL,
0
);
diff --git a/cpukit/posix/src/pthreadjoin.c b/cpukit/posix/src/pthreadjoin.c
index 26d53285dc..0b7e103614 100644
--- a/cpukit/posix/src/pthreadjoin.c
+++ b/cpukit/posix/src/pthreadjoin.c
@@ -1,7 +1,7 @@
/*
* 16.1.3 Wait for Thread Termination, P1003.1c/Draft 10, p. 147
*
- * COPYRIGHT (c) 1989-2007.
+ * COPYRIGHT (c) 1989-2011.
* On-Line Applications Research Corporation (OAR).
*
* The license and distribution terms for this file may be
@@ -32,6 +32,7 @@ int pthread_join(
Objects_Locations location;
void *return_pointer;
+on_EINTR:
the_thread = _Thread_Get( thread, &location );
switch ( location ) {
@@ -66,6 +67,9 @@ int pthread_join(
}
_Thread_Enable_dispatch();
+ if ( _Thread_Executing->Wait.return_code == EINTR )
+ goto on_EINTR;
+
if ( value_ptr )
*value_ptr = return_pointer;
return 0;