Chris@16
|
1 //////////////////////////////////////////////////////////////////////////////
|
Chris@16
|
2 //
|
Chris@16
|
3 // (C) Copyright Ion Gaztanaga 2005-2012. Distributed under the Boost
|
Chris@16
|
4 // Software License, Version 1.0. (See accompanying file
|
Chris@16
|
5 // LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
|
Chris@16
|
6 //
|
Chris@16
|
7 // See http://www.boost.org/libs/interprocess for documentation.
|
Chris@16
|
8 //
|
Chris@16
|
9 //////////////////////////////////////////////////////////////////////////////
|
Chris@16
|
10
|
Chris@16
|
11 #ifndef BOOST_INTERPROCESS_PTHREAD_HELPERS_HPP
|
Chris@16
|
12 #define BOOST_INTERPROCESS_PTHREAD_HELPERS_HPP
|
Chris@16
|
13
|
Chris@16
|
14 #if (defined _MSC_VER) && (_MSC_VER >= 1200)
|
Chris@16
|
15 # pragma once
|
Chris@16
|
16 #endif
|
Chris@16
|
17
|
Chris@16
|
18 #include <boost/interprocess/detail/config_begin.hpp>
|
Chris@16
|
19 #include <boost/interprocess/detail/workaround.hpp>
|
Chris@16
|
20
|
Chris@16
|
21 #include <pthread.h>
|
Chris@16
|
22 #include <errno.h>
|
Chris@16
|
23 #include <boost/interprocess/exceptions.hpp>
|
Chris@16
|
24
|
Chris@16
|
25 namespace boost {
|
Chris@16
|
26 namespace interprocess {
|
Chris@16
|
27 namespace ipcdetail{
|
Chris@16
|
28
|
Chris@16
|
29 #if defined BOOST_INTERPROCESS_POSIX_PROCESS_SHARED
|
Chris@16
|
30
|
Chris@16
|
31 //!Makes pthread_mutexattr_t cleanup easy when using exceptions
|
Chris@16
|
32 struct mutexattr_wrapper
|
Chris@16
|
33 {
|
Chris@16
|
34 //!Constructor
|
Chris@16
|
35 mutexattr_wrapper(bool recursive = false)
|
Chris@16
|
36 {
|
Chris@16
|
37 if(pthread_mutexattr_init(&m_attr)!=0 ||
|
Chris@16
|
38 pthread_mutexattr_setpshared(&m_attr, PTHREAD_PROCESS_SHARED)!= 0 ||
|
Chris@16
|
39 (recursive &&
|
Chris@16
|
40 pthread_mutexattr_settype(&m_attr, PTHREAD_MUTEX_RECURSIVE)!= 0 ))
|
Chris@16
|
41 throw interprocess_exception("pthread_mutexattr_xxxx failed");
|
Chris@16
|
42 }
|
Chris@16
|
43
|
Chris@16
|
44 //!Destructor
|
Chris@16
|
45 ~mutexattr_wrapper() { pthread_mutexattr_destroy(&m_attr); }
|
Chris@16
|
46
|
Chris@16
|
47 //!This allows using mutexattr_wrapper as pthread_mutexattr_t
|
Chris@16
|
48 operator pthread_mutexattr_t&() { return m_attr; }
|
Chris@16
|
49
|
Chris@16
|
50 pthread_mutexattr_t m_attr;
|
Chris@16
|
51 };
|
Chris@16
|
52
|
Chris@16
|
53 //!Makes pthread_condattr_t cleanup easy when using exceptions
|
Chris@16
|
54 struct condattr_wrapper
|
Chris@16
|
55 {
|
Chris@16
|
56 //!Constructor
|
Chris@16
|
57 condattr_wrapper()
|
Chris@16
|
58 {
|
Chris@16
|
59 if(pthread_condattr_init(&m_attr)!=0 ||
|
Chris@16
|
60 pthread_condattr_setpshared(&m_attr, PTHREAD_PROCESS_SHARED)!= 0)
|
Chris@16
|
61 throw interprocess_exception("pthread_condattr_xxxx failed");
|
Chris@16
|
62 }
|
Chris@16
|
63
|
Chris@16
|
64 //!Destructor
|
Chris@16
|
65 ~condattr_wrapper() { pthread_condattr_destroy(&m_attr); }
|
Chris@16
|
66
|
Chris@16
|
67 //!This allows using condattr_wrapper as pthread_condattr_t
|
Chris@16
|
68 operator pthread_condattr_t&(){ return m_attr; }
|
Chris@16
|
69
|
Chris@16
|
70 pthread_condattr_t m_attr;
|
Chris@16
|
71 };
|
Chris@16
|
72
|
Chris@16
|
73 //!Makes initialized pthread_mutex_t cleanup easy when using exceptions
|
Chris@16
|
74 class mutex_initializer
|
Chris@16
|
75 {
|
Chris@16
|
76 public:
|
Chris@16
|
77 //!Constructor. Takes interprocess_mutex attributes to initialize the interprocess_mutex
|
Chris@16
|
78 mutex_initializer(pthread_mutex_t &mut, pthread_mutexattr_t &mut_attr)
|
Chris@16
|
79 : mp_mut(&mut)
|
Chris@16
|
80 {
|
Chris@16
|
81 if(pthread_mutex_init(mp_mut, &mut_attr) != 0)
|
Chris@16
|
82 throw interprocess_exception("pthread_mutex_init failed");
|
Chris@16
|
83 }
|
Chris@16
|
84
|
Chris@16
|
85 ~mutex_initializer() { if(mp_mut) pthread_mutex_destroy(mp_mut); }
|
Chris@16
|
86
|
Chris@16
|
87 void release() {mp_mut = 0; }
|
Chris@16
|
88
|
Chris@16
|
89 private:
|
Chris@16
|
90 pthread_mutex_t *mp_mut;
|
Chris@16
|
91 };
|
Chris@16
|
92
|
Chris@16
|
93 //!Makes initialized pthread_cond_t cleanup easy when using exceptions
|
Chris@16
|
94 class condition_initializer
|
Chris@16
|
95 {
|
Chris@16
|
96 public:
|
Chris@16
|
97 condition_initializer(pthread_cond_t &cond, pthread_condattr_t &cond_attr)
|
Chris@16
|
98 : mp_cond(&cond)
|
Chris@16
|
99 {
|
Chris@16
|
100 if(pthread_cond_init(mp_cond, &cond_attr)!= 0)
|
Chris@16
|
101 throw interprocess_exception("pthread_cond_init failed");
|
Chris@16
|
102 }
|
Chris@16
|
103
|
Chris@16
|
104 ~condition_initializer() { if(mp_cond) pthread_cond_destroy(mp_cond); }
|
Chris@16
|
105
|
Chris@16
|
106 void release() { mp_cond = 0; }
|
Chris@16
|
107
|
Chris@16
|
108 private:
|
Chris@16
|
109 pthread_cond_t *mp_cond;
|
Chris@16
|
110 };
|
Chris@16
|
111
|
Chris@16
|
112 #endif // #if defined BOOST_INTERPROCESS_POSIX_PROCESS_SHARED
|
Chris@16
|
113
|
Chris@16
|
114 #if defined(BOOST_INTERPROCESS_POSIX_BARRIERS) && defined(BOOST_INTERPROCESS_POSIX_PROCESS_SHARED)
|
Chris@16
|
115
|
Chris@16
|
116 //!Makes pthread_barrierattr_t cleanup easy when using exceptions
|
Chris@16
|
117 struct barrierattr_wrapper
|
Chris@16
|
118 {
|
Chris@16
|
119 //!Constructor
|
Chris@16
|
120 barrierattr_wrapper()
|
Chris@16
|
121 {
|
Chris@16
|
122 if(pthread_barrierattr_init(&m_attr)!=0 ||
|
Chris@16
|
123 pthread_barrierattr_setpshared(&m_attr, PTHREAD_PROCESS_SHARED)!= 0)
|
Chris@16
|
124 throw interprocess_exception("pthread_barrierattr_xxx failed");
|
Chris@16
|
125 }
|
Chris@16
|
126
|
Chris@16
|
127 //!Destructor
|
Chris@16
|
128 ~barrierattr_wrapper() { pthread_barrierattr_destroy(&m_attr); }
|
Chris@16
|
129
|
Chris@16
|
130 //!This allows using mutexattr_wrapper as pthread_barrierattr_t
|
Chris@16
|
131 operator pthread_barrierattr_t&() { return m_attr; }
|
Chris@16
|
132
|
Chris@16
|
133 pthread_barrierattr_t m_attr;
|
Chris@16
|
134 };
|
Chris@16
|
135
|
Chris@16
|
136 //!Makes initialized pthread_barrier_t cleanup easy when using exceptions
|
Chris@16
|
137 class barrier_initializer
|
Chris@16
|
138 {
|
Chris@16
|
139 public:
|
Chris@16
|
140 //!Constructor. Takes barrier attributes to initialize the barrier
|
Chris@16
|
141 barrier_initializer(pthread_barrier_t &mut,
|
Chris@16
|
142 pthread_barrierattr_t &mut_attr,
|
Chris@16
|
143 int count)
|
Chris@16
|
144 : mp_barrier(&mut)
|
Chris@16
|
145 {
|
Chris@16
|
146 if(pthread_barrier_init(mp_barrier, &mut_attr, count) != 0)
|
Chris@16
|
147 throw interprocess_exception("pthread_barrier_init failed");
|
Chris@16
|
148 }
|
Chris@16
|
149
|
Chris@16
|
150 ~barrier_initializer() { if(mp_barrier) pthread_barrier_destroy(mp_barrier); }
|
Chris@16
|
151
|
Chris@16
|
152 void release() {mp_barrier = 0; }
|
Chris@16
|
153
|
Chris@16
|
154 private:
|
Chris@16
|
155 pthread_barrier_t *mp_barrier;
|
Chris@16
|
156 };
|
Chris@16
|
157
|
Chris@16
|
158 #endif //#if defined(BOOST_INTERPROCESS_POSIX_BARRIERS) && defined(BOOST_INTERPROCESS_POSIX_PROCESS_SHARED)
|
Chris@16
|
159
|
Chris@16
|
160 }//namespace ipcdetail
|
Chris@16
|
161
|
Chris@16
|
162 }//namespace interprocess
|
Chris@16
|
163
|
Chris@16
|
164 }//namespace boost
|
Chris@16
|
165
|
Chris@16
|
166 #include <boost/interprocess/detail/config_end.hpp>
|
Chris@16
|
167
|
Chris@16
|
168 #endif //ifdef BOOST_INTERPROCESS_PTHREAD_HELPERS_HPP
|