diff options
author | Ulrich Drepper <drepper@redhat.com> | 2003-06-08 16:30:17 +0000 |
---|---|---|
committer | Ulrich Drepper <drepper@redhat.com> | 2003-06-08 16:30:17 +0000 |
commit | ecf7955d551d9527b2b6bf0a489b236f9da763b9 (patch) | |
tree | c8c3b252cfdf40b0f94cb791066e2407538817cf /nptl/sysdeps/unix/sysv/linux | |
parent | 3e36c37d35827f060ee432712ba7fc0945e95a5b (diff) | |
download | glibc-ecf7955d551d9527b2b6bf0a489b236f9da763b9.tar.gz glibc-ecf7955d551d9527b2b6bf0a489b236f9da763b9.tar.xz glibc-ecf7955d551d9527b2b6bf0a489b236f9da763b9.zip |
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.
Diffstat (limited to 'nptl/sysdeps/unix/sysv/linux')
-rw-r--r-- | nptl/sysdeps/unix/sysv/linux/s390/sem_timedwait.c | 32 | ||||
-rw-r--r-- | nptl/sysdeps/unix/sysv/linux/s390/sem_wait.c | 30 |
2 files changed, 41 insertions, 21 deletions
diff --git a/nptl/sysdeps/unix/sysv/linux/s390/sem_timedwait.c b/nptl/sysdeps/unix/sysv/linux/s390/sem_timedwait.c index 273b54164a..e43afdfc8b 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 a56e1e0a60..2be1dbbac4 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); |