/**
   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>

static int thread_count = 0;

typedef struct {
  void(*func) PROTO_LIST((void *));
  void *arg;
} helper;

static void *r_thread_real_create PROTO_LIST((void *arg));

static void *r_thread_real_create(void *arg) {
  helper *h;

  h = (helper *)arg;

  thread_count++;

  h->func(h->arg);

  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);

  _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 {
    pthread_yield();
    usleep(10000);
    DBG((0, "%d threads left", thread_count));
  } while(thread_count);

  return (0);
}

int r_rwlock_create(r_rwlock **lockp) {
  pthread_rwlock_t *lock;
  int r;

  if(!(lock = (pthread_rwlock_t *)malloc(sizeof(pthread_rwlock_t))))
    ERETURN(R_NO_MEMORY);

  if(r = pthread_rwlock_init(lock, 0))
    ERETURN(R_INTERNAL);

  *lockp = (void *)lock;
  return (0);
}

int r_rwlock_destroy(r_rwlock **lock) {
  pthread_rwlock_t *plock;

  if(!lock || !*lock)
    return (0);

  plock = (pthread_rwlock_t *)(*lock);

  pthread_rwlock_destroy(plock);

  return (0);
}

int r_rwlock_lock(r_rwlock *lock, int action) {
  pthread_rwlock_t *plock;
  int r, _status;

  plock = (pthread_rwlock_t *)lock;

  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);
  }

  _status = 0;
abort:
  return (_status);
}