t/io_uring: add support for async-passthru
[fio.git] / pshared.c
1 #include <string.h>
2
3 #include "log.h"
4 #include "pshared.h"
5
6 int cond_init_pshared(pthread_cond_t *cond)
7 {
8         pthread_condattr_t cattr;
9         int ret;
10
11         ret = pthread_condattr_init(&cattr);
12         if (ret) {
13                 log_err("pthread_condattr_init: %s\n", strerror(ret));
14                 return ret;
15         }
16
17 #ifdef CONFIG_PSHARED
18         ret = pthread_condattr_setpshared(&cattr, PTHREAD_PROCESS_SHARED);
19         if (ret) {
20                 log_err("pthread_condattr_setpshared: %s\n", strerror(ret));
21                 return ret;
22         }
23 #endif
24
25 #ifdef CONFIG_PTHREAD_CONDATTR_SETCLOCK
26         ret = pthread_condattr_setclock(&cattr, CLOCK_MONOTONIC);
27         if (ret) {
28                 log_err("pthread_condattr_setclock: %s\n", strerror(ret));
29                 return ret;
30         }
31 #endif
32
33         ret = pthread_cond_init(cond, &cattr);
34         if (ret) {
35                 log_err("pthread_cond_init: %s\n", strerror(ret));
36                 return ret;
37         }
38
39         return 0;
40 }
41
42 /*
43  * 'type' must be a mutex type, e.g. PTHREAD_MUTEX_NORMAL,
44  * PTHREAD_MUTEX_ERRORCHECK, PTHREAD_MUTEX_RECURSIVE or PTHREAD_MUTEX_DEFAULT.
45  */
46 int mutex_init_pshared_with_type(pthread_mutex_t *mutex, int type)
47 {
48         pthread_mutexattr_t mattr;
49         int ret;
50
51         ret = pthread_mutexattr_init(&mattr);
52         if (ret) {
53                 log_err("pthread_mutexattr_init: %s\n", strerror(ret));
54                 return ret;
55         }
56
57         /*
58          * Not all platforms support process shared mutexes (NetBSD/OpenBSD)
59          */
60 #ifdef CONFIG_PSHARED
61         ret = pthread_mutexattr_setpshared(&mattr, PTHREAD_PROCESS_SHARED);
62         if (ret) {
63                 log_err("pthread_mutexattr_setpshared: %s\n", strerror(ret));
64                 return ret;
65         }
66 #endif
67         ret = pthread_mutexattr_settype(&mattr, type);
68         if (ret) {
69                 log_err("pthread_mutexattr_settype: %s\n", strerror(ret));
70                 return ret;
71         }
72         ret = pthread_mutex_init(mutex, &mattr);
73         if (ret) {
74                 log_err("pthread_mutex_init: %s\n", strerror(ret));
75                 return ret;
76         }
77         pthread_mutexattr_destroy(&mattr);
78
79         return 0;
80 }
81
82 int mutex_init_pshared(pthread_mutex_t *mutex)
83 {
84         return mutex_init_pshared_with_type(mutex, PTHREAD_MUTEX_DEFAULT);
85 }
86
87 int mutex_cond_init_pshared(pthread_mutex_t *mutex, pthread_cond_t *cond)
88 {
89         int ret;
90
91         ret = mutex_init_pshared(mutex);
92         if (ret)
93                 return ret;
94
95         ret = cond_init_pshared(cond);
96         if (ret)
97                 return ret;
98
99         return 0;
100 }