1 files changed, 57 insertions, 0 deletions
diff --git a/linuxthreads/restart.h b/linuxthreads/restart.h
new file mode 100644
index 0000000000..4b4a1d7937
--- /dev/null
+++ b/linuxthreads/restart.h
@@ -0,0 +1,57 @@
+/* Linuxthreads - a simple clone()-based implementation of Posix        */
+/* threads for Linux.                                                   */
+/* Copyright (C) 1996 Xavier Leroy (Xavier.Leroy@inria.fr)              */
+/*                                                                      */
+/* This program is free software; you can redistribute it and/or        */
+/* modify it under the terms of the GNU Library General Public License  */
+/* as published by the Free Software Foundation; either version 2       */
+/* of the License, or (at your option) any later version.               */
+/*                                                                      */
+/* This program is distributed in the hope that it will be useful,      */
+/* but WITHOUT ANY WARRANTY; without even the implied warranty of       */
+/* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the        */
+/* GNU Library General Public License for more details.                 */
+
+#include <signal.h>
+
+/* Primitives for controlling thread execution */
+
+static inline void restart(pthread_descr th)
+{
+  kill(th->p_pid, PTHREAD_SIG_RESTART);
+}
+
+static inline void suspend(pthread_descr self)
+{
+  sigset_t mask;
+
+  sigprocmask(SIG_SETMASK, NULL, &mask); /* Get current signal mask */
+  sigdelset(&mask, PTHREAD_SIG_RESTART); /* Unblock the restart signal */
+  do {
+    self->p_signal = 0;
+    sigsuspend(&mask);                   /* Wait for signal */
+  } 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);
+  }
+}