ssldump/common/lib/threads/pthreads/pthread.c

132 lines
2.2 KiB
C
Raw Normal View History

2015-01-31 09:13:33 +00:00
/**
pthread.c
Copyright (C) 1999, RTFM, Inc.
All Rights Reserved.
ekr@rtfm.com Tue Feb 23 15:08:03 1999
*/
#include <r_common.h>
#include <r_thread.h>
#include <pthread.h>
2023-08-14 10:37:08 +00:00
static int thread_count = 0;
2015-01-31 09:13:33 +00:00
typedef struct {
2023-08-14 10:37:08 +00:00
void(*func) PROTO_LIST((void *));
void *arg;
2015-01-31 09:13:33 +00:00
} helper;
static void *r_thread_real_create PROTO_LIST((void *arg));
2023-08-14 10:37:08 +00:00
static void *r_thread_real_create(void *arg) {
helper *h;
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
h = (helper *)arg;
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
thread_count++;
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
h->func(h->arg);
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
thread_count--;
free(h);
return (0);
}
int r_thread_fork(func, arg, id) void(*func) PROTO_LIST((void *));
void *arg;
r_thread *id;
{
pthread_t thread;
helper *h;
int r, _status;
h = (helper *)malloc(sizeof(helper));
h->func = func;
h->arg = arg;
if(r = pthread_create(&thread, 0, r_thread_real_create, (void *)h))
ABORT(R_INTERNAL);
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
_status = 0;
abort:
return (_status);
}
int r_thread_yield(void) {
pthread_yield();
}
int r_thread_exit(void) {
thread_count--;
pthread_exit(0);
return (0);
}
int r_thread_wait_last(void) {
do {
2015-01-31 09:13:33 +00:00
pthread_yield();
2023-08-14 10:37:08 +00:00
usleep(10000);
DBG((0, "%d threads left", thread_count));
} while(thread_count);
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
return (0);
}
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
int r_rwlock_create(r_rwlock **lockp) {
pthread_rwlock_t *lock;
int r;
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
if(!(lock = (pthread_rwlock_t *)malloc(sizeof(pthread_rwlock_t))))
ERETURN(R_NO_MEMORY);
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
if(r = pthread_rwlock_init(lock, 0))
ERETURN(R_INTERNAL);
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
*lockp = (void *)lock;
return (0);
}
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
int r_rwlock_destroy(r_rwlock **lock) {
pthread_rwlock_t *plock;
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
if(!lock || !*lock)
return (0);
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
plock = (pthread_rwlock_t *)(*lock);
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
pthread_rwlock_destroy(plock);
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
return (0);
}
int r_rwlock_lock(r_rwlock *lock, int action) {
pthread_rwlock_t *plock;
int r, _status;
plock = (pthread_rwlock_t *)lock;
2015-01-31 09:13:33 +00:00
2023-08-14 10:37:08 +00:00
switch(action) {
case R_RWLOCK_UNLOCK:
if(r = pthread_rwlock_unlock(plock))
ABORT(R_INTERNAL);
break;
case R_RWLOCK_RLOCK:
if(r = pthread_rwlock_rdlock(plock))
ABORT(R_INTERNAL);
break;
case R_RWLOCK_WLOCK:
if(r = pthread_rwlock_wrlock(plock))
ABORT(R_INTERNAL);
break;
default:
ABORT(R_BAD_ARGS);
2015-01-31 09:13:33 +00:00
}
2023-08-14 10:37:08 +00:00
_status = 0;
abort:
return (_status);
}