diff options
author | Ryo Nakamura <upa@haeena.net> | 2023-03-03 21:29:43 +0900 |
---|---|---|
committer | Ryo Nakamura <upa@haeena.net> | 2023-03-03 21:29:43 +0900 |
commit | 1b9ae5197463eed7d7015e6749bec1372844baea (patch) | |
tree | b188b8d589610fd8671b670ffa2c534796ad359e /src/atomic.h | |
parent | c5aa70d9c919f8a6a406f696cd8d60db692fa560 (diff) |
add message.h and message.c, mscp_set|get_error()
Instead of pr_err(), libmscp uses mscp_set_error() and
applications use mscp_get_errror() to get error message.
Diffstat (limited to 'src/atomic.h')
-rw-r--r-- | src/atomic.h | 26 |
1 files changed, 5 insertions, 21 deletions
diff --git a/src/atomic.h b/src/atomic.h index 0ccae55..87ba20d 100644 --- a/src/atomic.h +++ b/src/atomic.h @@ -2,8 +2,10 @@ #define _ATOMIC_H_ #include <stdlib.h> +#include <assert.h> #include <pthread.h> -#include <util.h> + +#include <message.h> typedef int refcnt; @@ -28,31 +30,13 @@ static inline void lock_init(lock *l) static inline void lock_acquire(lock *l) { int ret = pthread_mutex_lock(l); - if (ret < 0) { - switch (ret) { - case EINVAL: - pr_err("invalid mutex\n"); - exit(1); - case EDEADLK: - pr_err("a deadlock would occur\n"); - exit(1); - } - } + assert(ret == 0); } static inline void lock_release(lock *l) { int ret = pthread_mutex_unlock(l); - if (ret < 0) { - switch (ret) { - case EINVAL: - pr_err("invalid mutex\n"); - exit(1); - case EPERM: - pr_err("this thread does not hold this mutex\n"); - exit(1); - } - } + assert(ret == 0); } static inline void lock_release_via_cleanup(void *l) |