Update.

	* sysdeps/unix/sysv/linux/s390/sem_wait.c (__new_sem_wait): Make
	cancelable.
	* sysdeps/unix/sysv/linux/s390/sem_timedwait.c (__sem_timedwait):
	Likewise.

4 files changed, 47 insertions, 22 deletions

diff --git a/nptl/Banner b/nptl/Banner
index 7ab7cd4..01c3e6b 100644
--- a/nptl/Banner
+++ b/nptl/Banner
@@ -1 +1 @@
-NPTL 0.44 by Ulrich Drepper
+NPTL 0.45 by Ulrich Drepper
diff --git a/nptl/ChangeLog b/nptl/ChangeLog
index 9161f58..5a59e9a 100644
--- a/nptl/ChangeLog
+++ b/nptl/ChangeLog
@@ -1,5 +1,10 @@
 2003-06-08  Ulrich Drepper  <drepper@redhat.com>
 
+	* sysdeps/unix/sysv/linux/s390/sem_wait.c (__new_sem_wait): Make
+	cancelable.
+	* sysdeps/unix/sysv/linux/s390/sem_timedwait.c (__sem_timedwait):
+	Likewise.
+
 	* sysdeps/unix/sysv/linux/x86_64/sysdep-cancel.h: Remove
 	hand-written CFI generation code.  Since ENTRY/END also initiated
 	CFI frames this caused two CFI sets to be generated.
diff --git a/nptl/sysdeps/unix/sysv/linux/s390/sem_timedwait.c b/nptl/sysdeps/unix/sysv/linux/s390/sem_timedwait.c
index 273b541..e43afdf 100644
--- a/nptl/sysdeps/unix/sysv/linux/s390/sem_timedwait.c
+++ b/nptl/sysdeps/unix/sysv/linux/s390/sem_timedwait.c
@@ -23,6 +23,7 @@
 #include <internaltypes.h>
 #include <semaphore.h>
 
+#include <pthreadP.h>
 #include <shlib-compat.h>
 
 
@@ -31,12 +32,18 @@ sem_timedwait (sem, abstime)
      sem_t *sem;
      const struct timespec *abstime;
 {
-  int oldval, newval;
+  /* First check for cancellation.  */
+  CANCELLATION_P (THREAD_SELF);
 
-  while (1)
+  int *futex = (int *) sem;
+  int oldval;
+  int newval;
+  int err;
+
+  do
     {
       /* Atomically decrement semaphore counter if it is > 0.  */
-      lll_compare_and_swap ((int *) sem, oldval, newval,
+      lll_compare_and_swap (futex, oldval, newval,
 			    "ltr %2,%1; jnp 1f; ahi %2,-1");
       /* oldval != newval if the semaphore count has been decremented.	*/
       if (oldval != newval)
@@ -69,8 +76,14 @@ sem_timedwait (sem, abstime)
 	  return -1;
 	}
 
+      /* Enable asynchronous cancellation.  Required by the standard.  */
+      int oldtype = __pthread_enable_asynccancel ();
+
       /* Do wait.  */
-      int err = lll_futex_timed_wait ((int *) sem, 0, &rt);
+      err = lll_futex_timed_wait (futex, 0, &rt);
+
+      /* Disable asynchronous cancellation.  */
+      __pthread_disable_asynccancel (oldtype);
 
       /* Returned after timing out?  */
       if (err == -ETIMEDOUT)
@@ -78,12 +91,9 @@ sem_timedwait (sem, abstime)
 	  __set_errno (ETIMEDOUT);
 	  return -1;
 	}
-
-      /* Handle EINTR.  */
-      if (err != 0 && err != -EWOULDBLOCK)
-	{
-	  __set_errno (-err);
-	  return -1;
-	}
     }
+  while (err == 0 || err == -EWOULDBLOCK)
+
+    __set_errno (-err);
+  return -1;
 }
diff --git a/nptl/sysdeps/unix/sysv/linux/s390/sem_wait.c b/nptl/sysdeps/unix/sysv/linux/s390/sem_wait.c
index a56e1e0..2be1dbb 100644
--- a/nptl/sysdeps/unix/sysv/linux/s390/sem_wait.c
+++ b/nptl/sysdeps/unix/sysv/linux/s390/sem_wait.c
@@ -23,35 +23,45 @@
 #include <internaltypes.h>
 #include <semaphore.h>
 
+#include <pthreadP.h>
 #include <shlib-compat.h>
 
 
 int
 __new_sem_wait (sem_t *sem)
 {
-  while (1)
+  /* First check for cancellation.  */
+  CANCELLATION_P (THREAD_SELF);
+
+  int *futex = (int *) sem;
+  int err;
+
+  do
     {
       int oldval;
       int newval;
 
       /* Atomically decrement semaphore counter if it is > 0.  */
-      lll_compare_and_swap ((int *) sem, oldval, newval,
+      lll_compare_and_swap (futex, oldval, newval,
 			    "ltr %2,%1; jnp 1f; ahi %2,-1");
 
       /* oldval != newval if the semaphore count has been decremented.	*/
       if (oldval != newval)
 	return 0;
 
+      /* Enable asynchronous cancellation.  Required by the standard.  */
+      int oldtype = __pthread_enable_asynccancel ();
+
       /* Do wait.  */
-      int err = lll_futex_wait ((int *) sem, 0);
-
-      /* Handle EINTR.  */
-      if (err != 0 && err != -EWOULDBLOCK)
-	{
-	  __set_errno (-err);
-	  return -1;
-	}
+      err = lll_futex_wait (futex, 0);
+
+      /* Disable asynchronous cancellation.  */
+      __pthread_disable_asynccancel (oldtype);
     }
+  while (err == 0 || err == -EWOULDBLOCK);
+
+  __set_errno (-err);
+  return -1;
 }
 
 versioned_symbol (libpthread, __new_sem_wait, sem_wait, GLIBC_2_1);