kc3-lang/kc3/libkc3/rwlock.c

Branch - branch -callablecallable-rebaseframemasterconfigurefnfractionsfractions-rebaselinuxratio-rebasev0.1- tag -v0.1.9v0.1.8v0.1.7v0.1.6v0.1.5v0.1.4v0.1.3v0.1.2v0.1.12v0.1.11v0.1.10v0.1.1v0.1.0v0HTTPd-v0.1.0v0.1.13HTTPd-v0.1.1

• Show log

  Commit

• Hash : ff6f677e
  Author : jeremy
  Date : 2024-12-09T12:06:39
  

  rwlock.c

Download

• libkc3/rwlock.c

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

Download