kmx git

/* kc3
 * Copyright 2022,2023,2024 kmx.io <contact@kmx.io>
 *
 * Permission is hereby granted to use this software granted the above
 * copyright notice and this permission paragraph are included in all
 * copies and substantial portions of this software.
 *
 * THIS SOFTWARE IS PROVIDED "AS-IS" WITHOUT ANY GUARANTEE OF
 * PURPOSE AND PERFORMANCE. IN NO EVENT WHATSOEVER SHALL THE
 * AUTHOR BE CONSIDERED LIABLE FOR THE USE AND PERFORMANCE OF
 * THIS SOFTWARE.
 */
#include <errno.h>
#include <pthread.h>
#include "assert.h"
#include "io.h"
#include "rwlock.h"

#if HAVE_PTHREAD

void rwlock_clean (s_rwlock *rwlock)
{
  assert(rwlock);
  if (pthread_rwlock_destroy(&rwlock->rwlock)) {
    err_puts("rwlock_clean: pthread_rwlock_destroy");
    assert(! "rwlock_clean: pthread_rwlock_destroy");
    abort();
  }
}

s_rwlock * rwlock_init (s_rwlock *rwlock)
{
  assert(rwlock);
  if (pthread_rwlock_init(&rwlock->rwlock, NULL)) {
    err_puts("rwlock_init: pthread_rwlock_init");
    assert(! "rwlock_init: pthread_rwlock_init");
    return NULL;
  }
  rwlock->count = 0;
  rwlock->thread = 0;
  return rwlock;
}

s_rwlock * rwlock_r (s_rwlock *rwlock)
{
  sw e;
  uw i;
  pthread_t thread;
  assert(rwlock);
  thread = pthread_self();
  if (rwlock->thread != thread) {
    if (false) {
      i = (uw) rwlock;
      err_write_1("rwlock_r: ");
      err_inspect_uw_hexadecimal(&i);
      err_write_1("\n");
    }
    if ((e = pthread_rwlock_rdlock(&rwlock->rwlock))) {
      err_write_1("rwlock_r: pthread_rwlock_rdlock: ");
      switch (e) {
      case EAGAIN:
        err_puts("the maximum number of read locks on this lock has"
                 " been exceeded");
        break;
      case EDEADLK:
        err_puts("the current thread already owns this lock for"
                 " writing");
        break;
      case EINVAL:
        err_puts("invalid lock");
        break;
      case ENOMEM:
        err_puts("not enough memory to initialize the lock");
        break;
      default:
        err_puts("unknown error");
        break;
      }
      assert(! "rwlock_r: pthread_rwlock_rdlock");
      abort();
      return NULL;
    }
  }
  return rwlock;
}

s_rwlock * rwlock_unlock_r (s_rwlock *rwlock)
{
  pthread_t thread;
  assert(rwlock);
  thread = pthread_self();
  if (rwlock->thread != thread &&
      pthread_rwlock_unlock(&rwlock->rwlock)) {
    err_puts("rwlock_unlock_r: pthread_rwlock_unlock");
    assert(! "rwlock_unlock_r: pthread_rwlock_unlock");
    abort();
    return NULL;
  }
  return rwlock;
}

s_rwlock * rwlock_unlock_w (s_rwlock *rwlock)
{
  assert(rwlock);
  assert(rwlock->count);
  rwlock->count--;
  if (! rwlock->count) {
    rwlock->thread = 0;
    if (pthread_rwlock_unlock(&rwlock->rwlock)) {
      err_puts("rwlock_unlock_w: pthread_rwlock_unlock");
      assert(! "rwlock_unlock_w: pthread_rwlock_unlock");
      return NULL;
    }
  }
  return rwlock;
}

s_rwlock * rwlock_w (s_rwlock *rwlock)
{
  pthread_t thread;
  assert(rwlock);
  thread = pthread_self();
  if (rwlock->thread != thread) {
    if (pthread_rwlock_wrlock(&rwlock->rwlock)) {
      err_puts("rwlock_w: pthread_rwlock_wrlock");
      assert(! "rwlock_w: pthread_rwlock_wrlock");
      return NULL;
    }
    rwlock->thread = thread;
    rwlock->count = 0;
  }
  rwlock->count++;
  return rwlock;
}

#endif /* HAVE_PTHREAD */
kc3-lang/kc3/libkc3/rwlock.c

Commit

libkc3/rwlock.c
