123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384 |
- #include <errno.h>
- #include <sysdep.h>
- #include <lowlevellock.h>
- #include <internaltypes.h>
- #include <semaphore.h>
- #include <pthreadP.h>
- void
- attribute_hidden
- __sem_wait_cleanup (void *arg)
- {
- struct new_sem *isem = (struct new_sem *) arg;
- atomic_decrement (&isem->nwaiters);
- }
- int
- __new_sem_wait (sem_t *sem)
- {
- struct new_sem *isem = (struct new_sem *) sem;
- int err;
- if (atomic_decrement_if_positive (&isem->value) > 0)
- return 0;
- atomic_increment (&isem->nwaiters);
- pthread_cleanup_push (__sem_wait_cleanup, isem);
- while (1)
- {
-
- int oldtype = __pthread_enable_asynccancel ();
- err = lll_futex_wait (&isem->value, 0,
- isem->private ^ FUTEX_PRIVATE_FLAG);
-
- __pthread_disable_asynccancel (oldtype);
- if (err != 0 && err != -EWOULDBLOCK)
- {
- __set_errno (-err);
- err = -1;
- break;
- }
- if (atomic_decrement_if_positive (&isem->value) > 0)
- {
- err = 0;
- break;
- }
- }
- pthread_cleanup_pop (0);
- atomic_decrement (&isem->nwaiters);
- return err;
- }
- weak_alias(__new_sem_wait, sem_wait)
|