diff options
Diffstat (limited to 'linuxthreads/restart.h')
| -rw-r--r-- | linuxthreads/restart.h | 43 |
1 files changed, 22 insertions, 21 deletions
diff --git a/linuxthreads/restart.h b/linuxthreads/restart.h index 54a6f50..7492013 100644 --- a/linuxthreads/restart.h +++ b/linuxthreads/restart.h @@ -33,25 +33,26 @@ static inline void suspend(pthread_descr self) } while (self->p_signal !=__pthread_sig_restart ); } -static inline void suspend_with_cancellation(pthread_descr self) -{ - sigset_t mask; - sigjmp_buf jmpbuf; - - sigprocmask(SIG_SETMASK, NULL, &mask); /* Get current signal mask */ - sigdelset(&mask, __pthread_sig_restart); /* Unblock the restart signal */ - /* No need to save the signal mask, we'll restore it ourselves */ - if (sigsetjmp(jmpbuf, 0) == 0) { - self->p_cancel_jmp = &jmpbuf; - if (! (self->p_canceled && self->p_cancelstate == PTHREAD_CANCEL_ENABLE)) { - do { - self->p_signal = 0; - sigsuspend(&mask); /* Wait for a signal */ - } while (self->p_signal != __pthread_sig_restart); - } - self->p_cancel_jmp = NULL; - } else { - sigaddset(&mask, __pthread_sig_restart); /* Reblock the restart signal */ - sigprocmask(SIG_SETMASK, &mask, NULL); - } +#define suspend_with_cancellation(self) \ +{ \ + sigset_t mask; \ + sigjmp_buf jmpbuf; \ + \ + sigprocmask(SIG_SETMASK, NULL, &mask); /* Get current signal mask */ \ + sigdelset(&mask, __pthread_sig_restart); /* Unblock the restart signal */ \ + /* No need to save the signal mask, we'll restore it ourselves */ \ + if (sigsetjmp(jmpbuf, 0) == 0) { \ + self->p_cancel_jmp = &jmpbuf; \ + if (! (self->p_canceled \ + && self->p_cancelstate == PTHREAD_CANCEL_ENABLE)) { \ + do { \ + self->p_signal = 0; \ + sigsuspend(&mask); /* Wait for a signal */ \ + } while (self->p_signal != __pthread_sig_restart); \ + } \ + self->p_cancel_jmp = NULL; \ + } else { \ + sigaddset(&mask, __pthread_sig_restart); /* Reblock the restart signal */ \ + sigprocmask(SIG_SETMASK, &mask, NULL); \ + } \ } |