summaryrefslogtreecommitdiff
path: root/src/atomic.h
diff options
context:
space:
mode:
authorRyo Nakamura <upa@haeena.net>2023-03-03 21:29:43 +0900
committerRyo Nakamura <upa@haeena.net>2023-03-03 21:29:43 +0900
commit1b9ae5197463eed7d7015e6749bec1372844baea (patch)
treeb188b8d589610fd8671b670ffa2c534796ad359e /src/atomic.h
parentc5aa70d9c919f8a6a406f696cd8d60db692fa560 (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.h26
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)