t/io_uring: add support for async-passthru
[fio.git] / pshared.c
CommitLineData
ae626d4e
BVA
1#include <string.h>
2
3#include "log.h"
4#include "pshared.h"
5
6int 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
78b66d32
BVA
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
ae626d4e
BVA
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
eac54d73
BVA
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 */
3ed6894b 46int mutex_init_pshared_with_type(pthread_mutex_t *mutex, int type)
ae626d4e
BVA
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 /*
5ced70d4 58 * Not all platforms support process shared mutexes (NetBSD/OpenBSD)
ae626d4e
BVA
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
eac54d73
BVA
67 ret = pthread_mutexattr_settype(&mattr, type);
68 if (ret) {
69 log_err("pthread_mutexattr_settype: %s\n", strerror(ret));
70 return ret;
3ed6894b 71 }
ae626d4e
BVA
72 ret = pthread_mutex_init(mutex, &mattr);
73 if (ret) {
74 log_err("pthread_mutex_init: %s\n", strerror(ret));
75 return ret;
76 }
eac54d73 77 pthread_mutexattr_destroy(&mattr);
ae626d4e
BVA
78
79 return 0;
80}
81
3ed6894b
SK
82int mutex_init_pshared(pthread_mutex_t *mutex)
83{
eac54d73 84 return mutex_init_pshared_with_type(mutex, PTHREAD_MUTEX_DEFAULT);
3ed6894b
SK
85}
86
ae626d4e
BVA
87int 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}