annotate DEPENDENCIES/generic/include/boost/interprocess/sync/posix/pthread_helpers.hpp @ 16:2665513ce2d3

Add boost headers
author Chris Cannam
date Tue, 05 Aug 2014 11:11:38 +0100
parents
children c530137014c0
rev   line source
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