kc3-lang/kc3/libkc3/mutex.c

• Show log

  Commit

• Hash : 5bcd7eef
  Author : Thomas de Grivel
  Date : 2024-12-08T19:11:14
  

  mutex

Download

• libkc3/mutex.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 "alloc.h"
  #include "assert.h"
  #include "mutex.h"
  
  void mutex_clean (s_mutex *mutex)
  {
    assert(mutex);
    if (pthread_mutex_destroy(&mutex->mutex)) {
      err_puts("mutex_clean: pthread_mutex_destroy");
      assert(! "mutex_clean: pthread_mutex_destroy");
      abort();
    }
  }
  
  void mutex_delete (s_mutex *mutex)
  {
    assert(mutex);
    mutex_clean(mutex);
    free(mutex);
  }
  
  s_mutex * mutex_init (s_mutex *mutex)
  {
    s_mutex tmp = {0};
    assert(mutex);
    if (pthread_mutex_init(&tmp.mutex, NULL)) {
      err_puts("mutex_init: pthread_mutex_init");
      assert(! "mutex_init: pthread_mutex_init");
      abort();
    }
    
    *mutex = tmp;
    return mutex;
  }
  
  void mutex_lock (s_mutex *mutex)
  {
    if (pthread_mutex_lock(&mutex->mutex)) {
      err_puts("mutex_unlock: pthread_mutex_unlock");
      assert(! "mutex_unlock: pthread_mutex_unlock");
      abort();
    }
  }
  
  s_mutex * mutex_new (void)
  {
    s_mutex *mutex;
    if (! (mutex = alloc(sizeof(s_mutex))))
      return NULL;
    if (! mutex_init(mutex)) {
      free(mutex);
      return NULL;
    }
    return mutex;
  }
  
  void mutex_unlock (s_mutex *mutex)
  {
    if (pthread_mutex_unlock(&mutex->mutex)) {
      err_puts("mutex_unlock: pthread_mutex_unlock");
      assert(! "mutex_unlock: pthread_mutex_unlock");
      abort();
    }
  }
  

Download