1 #ifndef __PTHREAD_EXTRA_H__
2 #define __PTHREAD_EXTRA_H__
9 #define PTHREAD_XTIME_NOBLOCK (&(struct timespec){ .tv_sec = 0, .tv_nsec = 0 })
10 #define PTHREAD_XTIME_FOREVER NULL
14 #define PTHREAD_XMQ_FRONT true
15 #define PTHREAD_XMQ_BACK false
17 #define PTHREAD_XMQ_RECV false
18 #define PTHREAD_XMQ_PEEK true
20 typedef struct pthread_mq_t
{
22 pthread_cond_t cond_readable
;
23 pthread_cond_t cond_writable
;
32 bool pthread_mq_init(pthread_mq_t
*mq
, size_t msg_size
, size_t msg_count_max
);
33 void pthread_mq_free(pthread_mq_t
*mq
);
34 size_t pthread_mq_waiting(pthread_mq_t
*mq
);
35 bool pthread_mq_reset(pthread_mq_t
*mq
);
36 bool pthread_mq_send_generic(pthread_mq_t
*mq
, void * data
, bool to_front
, const struct timespec
*restrict abs_timeout
);
37 bool pthread_mq_receive_generic(pthread_mq_t
*mq
, void * data
, bool peek
, const struct timespec
*restrict abs_timeout
);
39 // Multi mutex locking
41 #define pthread_mutex_swap(a, b) { pthread_mutex_t *s; s = (a); a = (b); b = s; }
43 #define pthread_mutex_lock_two(a,b) pthread_mutex_timedlock_multi_generic((pthread_mutex_t *[2]){(a), (b)}, 2, true, NULL)
44 #define pthread_mutex_timedlock_two(a,b,tm) pthread_mutex_timedlock_multi_generic((pthread_mutex_t *[2]){(a), (b)}, 2, true, (tm))
45 #define pthread_mutex_trylock_two(a,b) pthread_mutex_timedlock_multi_generic((pthread_mutex_t *[2]){(a), (b)}, 2, false, NULL)
47 #define pthread_mutex_lock_multi(lcks,cnt) pthread_mutex_timedlock_multi_generic((lcks),(cnt),true,NULL)
48 #define pthread_mutex_timedlock_multi(lcks,cnt,tm) pthread_mutex_timedlock_multi_generic((lcks),(cnt),true,(tm))
49 #define pthread_mutex_trylock_multi(lcks,cnt) pthread_mutex_timedlock_multi_generic((lcks),(cnt),false,NULL)
51 int pthread_mutex_timedlock_multi_generic(pthread_mutex_t
**lck
, int cnt
, bool block
, const struct timespec
*restrict abs_timeout
);
54 #endif //__PTHREAD_EXTRA_H__