|
Packit |
b5b901 |
/* Copyright Joyent, Inc. and other Node contributors. All rights reserved.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
Packit |
b5b901 |
* of this software and associated documentation files (the "Software"), to
|
|
Packit |
b5b901 |
* deal in the Software without restriction, including without limitation the
|
|
Packit |
b5b901 |
* rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
|
|
Packit |
b5b901 |
* sell copies of the Software, and to permit persons to whom the Software is
|
|
Packit |
b5b901 |
* furnished to do so, subject to the following conditions:
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* The above copyright notice and this permission notice shall be included in
|
|
Packit |
b5b901 |
* all copies or substantial portions of the Software.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
Packit |
b5b901 |
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
Packit |
b5b901 |
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
Packit |
b5b901 |
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
Packit |
b5b901 |
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
|
|
Packit |
b5b901 |
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
|
|
Packit |
b5b901 |
* IN THE SOFTWARE.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#include "uv.h"
|
|
Packit |
b5b901 |
#include "internal.h"
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#include <pthread.h>
|
|
Packit |
b5b901 |
#include <assert.h>
|
|
Packit |
b5b901 |
#include <errno.h>
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#include <sys/time.h>
|
|
Packit |
b5b901 |
#include <sys/resource.h> /* getrlimit() */
|
|
Packit |
b5b901 |
#include <unistd.h> /* getpagesize() */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#include <limits.h>
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#ifdef __MVS__
|
|
Packit |
b5b901 |
#include <sys/ipc.h>
|
|
Packit |
b5b901 |
#include <sys/sem.h>
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#ifdef __GLIBC__
|
|
Packit |
b5b901 |
#include <gnu/libc-version.h> /* gnu_get_libc_version() */
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#undef NANOSEC
|
|
Packit |
b5b901 |
#define NANOSEC ((uint64_t) 1e9)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if defined(UV__PTHREAD_BARRIER_FALLBACK)
|
|
Packit |
b5b901 |
/* TODO: support barrier_attr */
|
|
Packit |
b5b901 |
int pthread_barrier_init(pthread_barrier_t* barrier,
|
|
Packit |
b5b901 |
const void* barrier_attr,
|
|
Packit |
b5b901 |
unsigned count) {
|
|
Packit |
b5b901 |
int rc;
|
|
Packit |
b5b901 |
_uv_barrier* b;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (barrier == NULL || count == 0)
|
|
Packit |
b5b901 |
return EINVAL;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (barrier_attr != NULL)
|
|
Packit |
b5b901 |
return ENOTSUP;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
b = uv__malloc(sizeof(*b));
|
|
Packit |
b5b901 |
if (b == NULL)
|
|
Packit |
b5b901 |
return ENOMEM;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
b->in = 0;
|
|
Packit |
b5b901 |
b->out = 0;
|
|
Packit |
b5b901 |
b->threshold = count;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if ((rc = pthread_mutex_init(&b->mutex, NULL)) != 0)
|
|
Packit |
b5b901 |
goto error2;
|
|
Packit |
b5b901 |
if ((rc = pthread_cond_init(&b->cond, NULL)) != 0)
|
|
Packit |
b5b901 |
goto error;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
barrier->b = b;
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
error:
|
|
Packit |
b5b901 |
pthread_mutex_destroy(&b->mutex);
|
|
Packit |
b5b901 |
error2:
|
|
Packit |
b5b901 |
uv__free(b);
|
|
Packit |
b5b901 |
return rc;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int pthread_barrier_wait(pthread_barrier_t* barrier) {
|
|
Packit |
b5b901 |
int rc;
|
|
Packit |
b5b901 |
_uv_barrier* b;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (barrier == NULL || barrier->b == NULL)
|
|
Packit |
b5b901 |
return EINVAL;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
b = barrier->b;
|
|
Packit |
b5b901 |
/* Lock the mutex*/
|
|
Packit |
b5b901 |
if ((rc = pthread_mutex_lock(&b->mutex)) != 0)
|
|
Packit |
b5b901 |
return rc;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Increment the count. If this is the first thread to reach the threshold,
|
|
Packit |
b5b901 |
wake up waiters, unlock the mutex, then return
|
|
Packit |
b5b901 |
PTHREAD_BARRIER_SERIAL_THREAD. */
|
|
Packit |
b5b901 |
if (++b->in == b->threshold) {
|
|
Packit |
b5b901 |
b->in = 0;
|
|
Packit |
b5b901 |
b->out = b->threshold - 1;
|
|
Packit |
b5b901 |
rc = pthread_cond_signal(&b->cond);
|
|
Packit |
b5b901 |
assert(rc == 0);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
pthread_mutex_unlock(&b->mutex);
|
|
Packit |
b5b901 |
return PTHREAD_BARRIER_SERIAL_THREAD;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
/* Otherwise, wait for other threads until in is set to 0,
|
|
Packit |
b5b901 |
then return 0 to indicate this is not the first thread. */
|
|
Packit |
b5b901 |
do {
|
|
Packit |
b5b901 |
if ((rc = pthread_cond_wait(&b->cond, &b->mutex)) != 0)
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
} while (b->in != 0);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* mark thread exit */
|
|
Packit |
b5b901 |
b->out--;
|
|
Packit |
b5b901 |
pthread_cond_signal(&b->cond);
|
|
Packit |
b5b901 |
pthread_mutex_unlock(&b->mutex);
|
|
Packit |
b5b901 |
return rc;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int pthread_barrier_destroy(pthread_barrier_t* barrier) {
|
|
Packit |
b5b901 |
int rc;
|
|
Packit |
b5b901 |
_uv_barrier* b;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (barrier == NULL || barrier->b == NULL)
|
|
Packit |
b5b901 |
return EINVAL;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
b = barrier->b;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if ((rc = pthread_mutex_lock(&b->mutex)) != 0)
|
|
Packit |
b5b901 |
return rc;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (b->in > 0 || b->out > 0)
|
|
Packit |
b5b901 |
rc = EBUSY;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
pthread_mutex_unlock(&b->mutex);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (rc)
|
|
Packit |
b5b901 |
return rc;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
pthread_cond_destroy(&b->cond);
|
|
Packit |
b5b901 |
pthread_mutex_destroy(&b->mutex);
|
|
Packit |
b5b901 |
uv__free(barrier->b);
|
|
Packit |
b5b901 |
barrier->b = NULL;
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* On MacOS, threads other than the main thread are created with a reduced
|
|
Packit |
b5b901 |
* stack size by default. Adjust to RLIMIT_STACK aligned to the page size.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* On Linux, threads created by musl have a much smaller stack than threads
|
|
Packit |
b5b901 |
* created by glibc (80 vs. 2048 or 4096 kB.) Follow glibc for consistency.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
static size_t thread_stack_size(void) {
|
|
Packit |
b5b901 |
#if defined(__APPLE__) || defined(__linux__)
|
|
Packit |
b5b901 |
struct rlimit lim;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (getrlimit(RLIMIT_STACK, &lim))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (lim.rlim_cur != RLIM_INFINITY) {
|
|
Packit |
b5b901 |
/* pthread_attr_setstacksize() expects page-aligned values. */
|
|
Packit |
b5b901 |
lim.rlim_cur -= lim.rlim_cur % (rlim_t) getpagesize();
|
|
Packit |
b5b901 |
if (lim.rlim_cur >= PTHREAD_STACK_MIN)
|
|
Packit |
b5b901 |
return lim.rlim_cur;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if !defined(__linux__)
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
#elif defined(__PPC__) || defined(__ppc__) || defined(__powerpc__)
|
|
Packit |
b5b901 |
return 4 << 20; /* glibc default. */
|
|
Packit |
b5b901 |
#else
|
|
Packit |
b5b901 |
return 2 << 20; /* glibc default. */
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_thread_create(uv_thread_t *tid, void (*entry)(void *arg), void *arg) {
|
|
Packit |
b5b901 |
int err;
|
|
Packit |
b5b901 |
size_t stack_size;
|
|
Packit |
b5b901 |
pthread_attr_t* attr;
|
|
Packit |
b5b901 |
pthread_attr_t attr_storage;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
attr = NULL;
|
|
Packit |
b5b901 |
stack_size = thread_stack_size();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (stack_size > 0) {
|
|
Packit |
b5b901 |
attr = &attr_storage;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (pthread_attr_init(attr))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (pthread_attr_setstacksize(attr, stack_size))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = pthread_create(tid, attr, (void*(*)(void*)) entry, arg);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (attr != NULL)
|
|
Packit |
b5b901 |
pthread_attr_destroy(attr);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return UV__ERR(err);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uv_thread_t uv_thread_self(void) {
|
|
Packit |
b5b901 |
return pthread_self();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_thread_join(uv_thread_t *tid) {
|
|
Packit |
b5b901 |
return UV__ERR(pthread_join(*tid, NULL));
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_thread_equal(const uv_thread_t* t1, const uv_thread_t* t2) {
|
|
Packit |
b5b901 |
return pthread_equal(*t1, *t2);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_mutex_init(uv_mutex_t* mutex) {
|
|
Packit |
b5b901 |
#if defined(NDEBUG) || !defined(PTHREAD_MUTEX_ERRORCHECK)
|
|
Packit |
b5b901 |
return UV__ERR(pthread_mutex_init(mutex, NULL));
|
|
Packit |
b5b901 |
#else
|
|
Packit |
b5b901 |
pthread_mutexattr_t attr;
|
|
Packit |
b5b901 |
int err;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (pthread_mutexattr_init(&attr))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_ERRORCHECK))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = pthread_mutex_init(mutex, &attr);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (pthread_mutexattr_destroy(&attr))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return UV__ERR(err);
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_mutex_init_recursive(uv_mutex_t* mutex) {
|
|
Packit |
b5b901 |
pthread_mutexattr_t attr;
|
|
Packit |
b5b901 |
int err;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (pthread_mutexattr_init(&attr))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = pthread_mutex_init(mutex, &attr);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (pthread_mutexattr_destroy(&attr))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return UV__ERR(err);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_mutex_destroy(uv_mutex_t* mutex) {
|
|
Packit |
b5b901 |
if (pthread_mutex_destroy(mutex))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_mutex_lock(uv_mutex_t* mutex) {
|
|
Packit |
b5b901 |
if (pthread_mutex_lock(mutex))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_mutex_trylock(uv_mutex_t* mutex) {
|
|
Packit |
b5b901 |
int err;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = pthread_mutex_trylock(mutex);
|
|
Packit |
b5b901 |
if (err) {
|
|
Packit |
b5b901 |
if (err != EBUSY && err != EAGAIN)
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
return UV_EBUSY;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_mutex_unlock(uv_mutex_t* mutex) {
|
|
Packit |
b5b901 |
if (pthread_mutex_unlock(mutex))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_rwlock_init(uv_rwlock_t* rwlock) {
|
|
Packit |
b5b901 |
return UV__ERR(pthread_rwlock_init(rwlock, NULL));
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_rwlock_destroy(uv_rwlock_t* rwlock) {
|
|
Packit |
b5b901 |
if (pthread_rwlock_destroy(rwlock))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_rwlock_rdlock(uv_rwlock_t* rwlock) {
|
|
Packit |
b5b901 |
if (pthread_rwlock_rdlock(rwlock))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_rwlock_tryrdlock(uv_rwlock_t* rwlock) {
|
|
Packit |
b5b901 |
int err;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = pthread_rwlock_tryrdlock(rwlock);
|
|
Packit |
b5b901 |
if (err) {
|
|
Packit |
b5b901 |
if (err != EBUSY && err != EAGAIN)
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
return UV_EBUSY;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_rwlock_rdunlock(uv_rwlock_t* rwlock) {
|
|
Packit |
b5b901 |
if (pthread_rwlock_unlock(rwlock))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_rwlock_wrlock(uv_rwlock_t* rwlock) {
|
|
Packit |
b5b901 |
if (pthread_rwlock_wrlock(rwlock))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_rwlock_trywrlock(uv_rwlock_t* rwlock) {
|
|
Packit |
b5b901 |
int err;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = pthread_rwlock_trywrlock(rwlock);
|
|
Packit |
b5b901 |
if (err) {
|
|
Packit |
b5b901 |
if (err != EBUSY && err != EAGAIN)
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
return UV_EBUSY;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_rwlock_wrunlock(uv_rwlock_t* rwlock) {
|
|
Packit |
b5b901 |
if (pthread_rwlock_unlock(rwlock))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_once(uv_once_t* guard, void (*callback)(void)) {
|
|
Packit |
b5b901 |
if (pthread_once(guard, callback))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if defined(__APPLE__) && defined(__MACH__)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_sem_init(uv_sem_t* sem, unsigned int value) {
|
|
Packit |
b5b901 |
kern_return_t err;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = semaphore_create(mach_task_self(), sem, SYNC_POLICY_FIFO, value);
|
|
Packit |
b5b901 |
if (err == KERN_SUCCESS)
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
if (err == KERN_INVALID_ARGUMENT)
|
|
Packit |
b5b901 |
return UV_EINVAL;
|
|
Packit |
b5b901 |
if (err == KERN_RESOURCE_SHORTAGE)
|
|
Packit |
b5b901 |
return UV_ENOMEM;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
return UV_EINVAL; /* Satisfy the compiler. */
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_sem_destroy(uv_sem_t* sem) {
|
|
Packit |
b5b901 |
if (semaphore_destroy(mach_task_self(), *sem))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_sem_post(uv_sem_t* sem) {
|
|
Packit |
b5b901 |
if (semaphore_signal(*sem))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_sem_wait(uv_sem_t* sem) {
|
|
Packit |
b5b901 |
int r;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
do
|
|
Packit |
b5b901 |
r = semaphore_wait(*sem);
|
|
Packit |
b5b901 |
while (r == KERN_ABORTED);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (r != KERN_SUCCESS)
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_sem_trywait(uv_sem_t* sem) {
|
|
Packit |
b5b901 |
mach_timespec_t interval;
|
|
Packit |
b5b901 |
kern_return_t err;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
interval.tv_sec = 0;
|
|
Packit |
b5b901 |
interval.tv_nsec = 0;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = semaphore_timedwait(*sem, interval);
|
|
Packit |
b5b901 |
if (err == KERN_SUCCESS)
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
if (err == KERN_OPERATION_TIMED_OUT)
|
|
Packit |
b5b901 |
return UV_EAGAIN;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
return UV_EINVAL; /* Satisfy the compiler. */
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#else /* !(defined(__APPLE__) && defined(__MACH__)) */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#ifdef __GLIBC__
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Hack around https://sourceware.org/bugzilla/show_bug.cgi?id=12674
|
|
Packit |
b5b901 |
* by providing a custom implementation for glibc < 2.21 in terms of other
|
|
Packit |
b5b901 |
* concurrency primitives.
|
|
Packit |
b5b901 |
* Refs: https://github.com/nodejs/node/issues/19903 */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* To preserve ABI compatibility, we treat the uv_sem_t as storage for
|
|
Packit |
b5b901 |
* a pointer to the actual struct we're using underneath. */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static uv_once_t glibc_version_check_once = UV_ONCE_INIT;
|
|
Packit |
b5b901 |
static int platform_needs_custom_semaphore = 0;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void glibc_version_check(void) {
|
|
Packit |
b5b901 |
const char* version = gnu_get_libc_version();
|
|
Packit |
b5b901 |
platform_needs_custom_semaphore =
|
|
Packit |
b5b901 |
version[0] == '2' && version[1] == '.' &&
|
|
Packit |
b5b901 |
atoi(version + 2) < 21;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#elif defined(__MVS__)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#define platform_needs_custom_semaphore 1
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#else /* !defined(__GLIBC__) && !defined(__MVS__) */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#define platform_needs_custom_semaphore 0
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
typedef struct uv_semaphore_s {
|
|
Packit |
b5b901 |
uv_mutex_t mutex;
|
|
Packit |
b5b901 |
uv_cond_t cond;
|
|
Packit |
b5b901 |
unsigned int value;
|
|
Packit |
b5b901 |
} uv_semaphore_t;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if defined(__GLIBC__) || platform_needs_custom_semaphore
|
|
Packit |
b5b901 |
STATIC_ASSERT(sizeof(uv_sem_t) >= sizeof(uv_semaphore_t*));
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static int uv__custom_sem_init(uv_sem_t* sem_, unsigned int value) {
|
|
Packit |
b5b901 |
int err;
|
|
Packit |
b5b901 |
uv_semaphore_t* sem;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
sem = uv__malloc(sizeof(*sem));
|
|
Packit |
b5b901 |
if (sem == NULL)
|
|
Packit |
b5b901 |
return UV_ENOMEM;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if ((err = uv_mutex_init(&sem->mutex)) != 0) {
|
|
Packit |
b5b901 |
uv__free(sem);
|
|
Packit |
b5b901 |
return err;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if ((err = uv_cond_init(&sem->cond)) != 0) {
|
|
Packit |
b5b901 |
uv_mutex_destroy(&sem->mutex);
|
|
Packit |
b5b901 |
uv__free(sem);
|
|
Packit |
b5b901 |
return err;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
sem->value = value;
|
|
Packit |
b5b901 |
*(uv_semaphore_t**)sem_ = sem;
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void uv__custom_sem_destroy(uv_sem_t* sem_) {
|
|
Packit |
b5b901 |
uv_semaphore_t* sem;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
sem = *(uv_semaphore_t**)sem_;
|
|
Packit |
b5b901 |
uv_cond_destroy(&sem->cond);
|
|
Packit |
b5b901 |
uv_mutex_destroy(&sem->mutex);
|
|
Packit |
b5b901 |
uv__free(sem);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void uv__custom_sem_post(uv_sem_t* sem_) {
|
|
Packit |
b5b901 |
uv_semaphore_t* sem;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
sem = *(uv_semaphore_t**)sem_;
|
|
Packit |
b5b901 |
uv_mutex_lock(&sem->mutex);
|
|
Packit |
b5b901 |
sem->value++;
|
|
Packit |
b5b901 |
if (sem->value == 1)
|
|
Packit |
b5b901 |
uv_cond_signal(&sem->cond);
|
|
Packit |
b5b901 |
uv_mutex_unlock(&sem->mutex);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void uv__custom_sem_wait(uv_sem_t* sem_) {
|
|
Packit |
b5b901 |
uv_semaphore_t* sem;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
sem = *(uv_semaphore_t**)sem_;
|
|
Packit |
b5b901 |
uv_mutex_lock(&sem->mutex);
|
|
Packit |
b5b901 |
while (sem->value == 0)
|
|
Packit |
b5b901 |
uv_cond_wait(&sem->cond, &sem->mutex);
|
|
Packit |
b5b901 |
sem->value--;
|
|
Packit |
b5b901 |
uv_mutex_unlock(&sem->mutex);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static int uv__custom_sem_trywait(uv_sem_t* sem_) {
|
|
Packit |
b5b901 |
uv_semaphore_t* sem;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
sem = *(uv_semaphore_t**)sem_;
|
|
Packit |
b5b901 |
if (uv_mutex_trylock(&sem->mutex) != 0)
|
|
Packit |
b5b901 |
return UV_EAGAIN;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (sem->value == 0) {
|
|
Packit |
b5b901 |
uv_mutex_unlock(&sem->mutex);
|
|
Packit |
b5b901 |
return UV_EAGAIN;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
sem->value--;
|
|
Packit |
b5b901 |
uv_mutex_unlock(&sem->mutex);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static int uv__sem_init(uv_sem_t* sem, unsigned int value) {
|
|
Packit |
b5b901 |
if (sem_init(sem, 0, value))
|
|
Packit |
b5b901 |
return UV__ERR(errno);
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void uv__sem_destroy(uv_sem_t* sem) {
|
|
Packit |
b5b901 |
if (sem_destroy(sem))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void uv__sem_post(uv_sem_t* sem) {
|
|
Packit |
b5b901 |
if (sem_post(sem))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void uv__sem_wait(uv_sem_t* sem) {
|
|
Packit |
b5b901 |
int r;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
do
|
|
Packit |
b5b901 |
r = sem_wait(sem);
|
|
Packit |
b5b901 |
while (r == -1 && errno == EINTR);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (r)
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static int uv__sem_trywait(uv_sem_t* sem) {
|
|
Packit |
b5b901 |
int r;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
do
|
|
Packit |
b5b901 |
r = sem_trywait(sem);
|
|
Packit |
b5b901 |
while (r == -1 && errno == EINTR);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (r) {
|
|
Packit |
b5b901 |
if (errno == EAGAIN)
|
|
Packit |
b5b901 |
return UV_EAGAIN;
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_sem_init(uv_sem_t* sem, unsigned int value) {
|
|
Packit |
b5b901 |
#ifdef __GLIBC__
|
|
Packit |
b5b901 |
uv_once(&glibc_version_check_once, glibc_version_check);
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (platform_needs_custom_semaphore)
|
|
Packit |
b5b901 |
return uv__custom_sem_init(sem, value);
|
|
Packit |
b5b901 |
else
|
|
Packit |
b5b901 |
return uv__sem_init(sem, value);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_sem_destroy(uv_sem_t* sem) {
|
|
Packit |
b5b901 |
if (platform_needs_custom_semaphore)
|
|
Packit |
b5b901 |
uv__custom_sem_destroy(sem);
|
|
Packit |
b5b901 |
else
|
|
Packit |
b5b901 |
uv__sem_destroy(sem);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_sem_post(uv_sem_t* sem) {
|
|
Packit |
b5b901 |
if (platform_needs_custom_semaphore)
|
|
Packit |
b5b901 |
uv__custom_sem_post(sem);
|
|
Packit |
b5b901 |
else
|
|
Packit |
b5b901 |
uv__sem_post(sem);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_sem_wait(uv_sem_t* sem) {
|
|
Packit |
b5b901 |
if (platform_needs_custom_semaphore)
|
|
Packit |
b5b901 |
uv__custom_sem_wait(sem);
|
|
Packit |
b5b901 |
else
|
|
Packit |
b5b901 |
uv__sem_wait(sem);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_sem_trywait(uv_sem_t* sem) {
|
|
Packit |
b5b901 |
if (platform_needs_custom_semaphore)
|
|
Packit |
b5b901 |
return uv__custom_sem_trywait(sem);
|
|
Packit |
b5b901 |
else
|
|
Packit |
b5b901 |
return uv__sem_trywait(sem);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#endif /* defined(__APPLE__) && defined(__MACH__) */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if defined(__APPLE__) && defined(__MACH__) || defined(__MVS__)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_cond_init(uv_cond_t* cond) {
|
|
Packit |
b5b901 |
return UV__ERR(pthread_cond_init(cond, NULL));
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#else /* !(defined(__APPLE__) && defined(__MACH__)) */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_cond_init(uv_cond_t* cond) {
|
|
Packit |
b5b901 |
pthread_condattr_t attr;
|
|
Packit |
b5b901 |
int err;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = pthread_condattr_init(&attr);
|
|
Packit |
b5b901 |
if (err)
|
|
Packit |
b5b901 |
return UV__ERR(err);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if !(defined(__ANDROID_API__) && __ANDROID_API__ < 21)
|
|
Packit |
b5b901 |
err = pthread_condattr_setclock(&attr, CLOCK_MONOTONIC);
|
|
Packit |
b5b901 |
if (err)
|
|
Packit |
b5b901 |
goto error2;
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = pthread_cond_init(cond, &attr);
|
|
Packit |
b5b901 |
if (err)
|
|
Packit |
b5b901 |
goto error2;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = pthread_condattr_destroy(&attr);
|
|
Packit |
b5b901 |
if (err)
|
|
Packit |
b5b901 |
goto error;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
error:
|
|
Packit |
b5b901 |
pthread_cond_destroy(cond);
|
|
Packit |
b5b901 |
error2:
|
|
Packit |
b5b901 |
pthread_condattr_destroy(&attr);
|
|
Packit |
b5b901 |
return UV__ERR(err);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#endif /* defined(__APPLE__) && defined(__MACH__) */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_cond_destroy(uv_cond_t* cond) {
|
|
Packit |
b5b901 |
#if defined(__APPLE__) && defined(__MACH__)
|
|
Packit |
b5b901 |
/* It has been reported that destroying condition variables that have been
|
|
Packit |
b5b901 |
* signalled but not waited on can sometimes result in application crashes.
|
|
Packit |
b5b901 |
* See https://codereview.chromium.org/1323293005.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
pthread_mutex_t mutex;
|
|
Packit |
b5b901 |
struct timespec ts;
|
|
Packit |
b5b901 |
int err;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (pthread_mutex_init(&mutex, NULL))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (pthread_mutex_lock(&mutex))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
ts.tv_sec = 0;
|
|
Packit |
b5b901 |
ts.tv_nsec = 1;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = pthread_cond_timedwait_relative_np(cond, &mutex, &ts);
|
|
Packit |
b5b901 |
if (err != 0 && err != ETIMEDOUT)
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (pthread_mutex_unlock(&mutex))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (pthread_mutex_destroy(&mutex))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
#endif /* defined(__APPLE__) && defined(__MACH__) */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (pthread_cond_destroy(cond))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_cond_signal(uv_cond_t* cond) {
|
|
Packit |
b5b901 |
if (pthread_cond_signal(cond))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_cond_broadcast(uv_cond_t* cond) {
|
|
Packit |
b5b901 |
if (pthread_cond_broadcast(cond))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_cond_wait(uv_cond_t* cond, uv_mutex_t* mutex) {
|
|
Packit |
b5b901 |
if (pthread_cond_wait(cond, mutex))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_cond_timedwait(uv_cond_t* cond, uv_mutex_t* mutex, uint64_t timeout) {
|
|
Packit |
b5b901 |
int r;
|
|
Packit |
b5b901 |
struct timespec ts;
|
|
Packit |
b5b901 |
#if defined(__MVS__)
|
|
Packit |
b5b901 |
struct timeval tv;
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if defined(__APPLE__) && defined(__MACH__)
|
|
Packit |
b5b901 |
ts.tv_sec = timeout / NANOSEC;
|
|
Packit |
b5b901 |
ts.tv_nsec = timeout % NANOSEC;
|
|
Packit |
b5b901 |
r = pthread_cond_timedwait_relative_np(cond, mutex, &ts);
|
|
Packit |
b5b901 |
#else
|
|
Packit |
b5b901 |
#if defined(__MVS__)
|
|
Packit |
b5b901 |
if (gettimeofday(&tv, NULL))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
timeout += tv.tv_sec * NANOSEC + tv.tv_usec * 1e3;
|
|
Packit |
b5b901 |
#else
|
|
Packit |
b5b901 |
timeout += uv__hrtime(UV_CLOCK_PRECISE);
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
ts.tv_sec = timeout / NANOSEC;
|
|
Packit |
b5b901 |
ts.tv_nsec = timeout % NANOSEC;
|
|
Packit |
b5b901 |
#if defined(__ANDROID_API__) && __ANDROID_API__ < 21
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/*
|
|
Packit |
b5b901 |
* The bionic pthread implementation doesn't support CLOCK_MONOTONIC,
|
|
Packit |
b5b901 |
* but has this alternative function instead.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
r = pthread_cond_timedwait_monotonic_np(cond, mutex, &ts);
|
|
Packit |
b5b901 |
#else
|
|
Packit |
b5b901 |
r = pthread_cond_timedwait(cond, mutex, &ts);
|
|
Packit |
b5b901 |
#endif /* __ANDROID_API__ */
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (r == 0)
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (r == ETIMEDOUT)
|
|
Packit |
b5b901 |
return UV_ETIMEDOUT;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
return UV_EINVAL; /* Satisfy the compiler. */
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_barrier_init(uv_barrier_t* barrier, unsigned int count) {
|
|
Packit |
b5b901 |
return UV__ERR(pthread_barrier_init(barrier, NULL, count));
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_barrier_destroy(uv_barrier_t* barrier) {
|
|
Packit |
b5b901 |
if (pthread_barrier_destroy(barrier))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_barrier_wait(uv_barrier_t* barrier) {
|
|
Packit |
b5b901 |
int r = pthread_barrier_wait(barrier);
|
|
Packit |
b5b901 |
if (r && r != PTHREAD_BARRIER_SERIAL_THREAD)
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
return r == PTHREAD_BARRIER_SERIAL_THREAD;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_key_create(uv_key_t* key) {
|
|
Packit |
b5b901 |
return UV__ERR(pthread_key_create(key, NULL));
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_key_delete(uv_key_t* key) {
|
|
Packit |
b5b901 |
if (pthread_key_delete(*key))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void* uv_key_get(uv_key_t* key) {
|
|
Packit |
b5b901 |
return pthread_getspecific(*key);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_key_set(uv_key_t* key, void* value) {
|
|
Packit |
b5b901 |
if (pthread_setspecific(*key, value))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|