blob: 26d5cfc812a6e2144a8efc6321be6edd2caeeb7c (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
#include <pthread.h>
#include "ddekit/lock.h"
#include "ddekit/memory.h"
#include "ddekit/thread.h"
#define DDEKIT_DEBUG_LOCKS 0
struct ddekit_lock {
pthread_mutex_t lock;
ddekit_thread_t *helder;
};
void _ddekit_lock_init(struct ddekit_lock **mtx) {
struct ddekit_lock *lock;
lock = (struct ddekit_lock *) ddekit_simple_malloc (sizeof *lock);
pthread_mutex_init (&lock->lock, NULL);
lock->helder = NULL;
*mtx = lock;
}
void _ddekit_lock_deinit(struct ddekit_lock **mtx) {
ddekit_simple_free (*mtx);
*mtx = NULL;
}
void _ddekit_lock_lock(struct ddekit_lock **mtx) {
pthread_mutex_lock (&(*mtx)->lock);
(*mtx)->helder = ddekit_thread_myself ();
}
/* returns 0 on success, != 0 if it would block */
int _ddekit_lock_try_lock(struct ddekit_lock **mtx) {
if (!pthread_mutex_trylock (&(*mtx)->lock)) { /* lock succeessfully */
(*mtx)->helder = ddekit_thread_myself ();
return 0;
}
return -1;
}
void _ddekit_lock_unlock(struct ddekit_lock **mtx) {
// TODO I wonder if it can cause any trouble.
(*mtx)->helder = NULL;
pthread_mutex_unlock (&(*mtx)->lock);
}
int _ddekit_lock_owner(struct ddekit_lock **mtx) {
/* The return value is the address of the holder.
* I hope it will be OK. At least, it is OK
* for the current implementation of DDE Linux/BSD */
return (int) (*mtx)->helder;
}
|
