Chris@16: //////////////////////////////////////////////////////////////////////////////
Chris@16: //
Chris@16: // (C) Copyright Ion Gaztanaga 2005-2012. Distributed under the Boost
Chris@16: // Software License, Version 1.0. (See accompanying file
Chris@16: // LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
Chris@16: //
Chris@16: // See http://www.boost.org/libs/interprocess for documentation.
Chris@16: //
Chris@16: //////////////////////////////////////////////////////////////////////////////
Chris@16: 
Chris@16: #ifndef BOOST_INTERPROCESS_PTHREAD_HELPERS_HPP
Chris@16: #define BOOST_INTERPROCESS_PTHREAD_HELPERS_HPP
Chris@16: 
Chris@101: #ifndef BOOST_CONFIG_HPP
Chris@101: #  include <boost/config.hpp>
Chris@101: #endif
Chris@101: #
Chris@101: #if defined(BOOST_HAS_PRAGMA_ONCE)
Chris@16: #  pragma once
Chris@16: #endif
Chris@16: 
Chris@16: #include <boost/interprocess/detail/config_begin.hpp>
Chris@16: #include <boost/interprocess/detail/workaround.hpp>
Chris@16: 
Chris@16: #include <pthread.h>
Chris@16: #include <errno.h>
Chris@16: #include <boost/interprocess/exceptions.hpp>
Chris@16: 
Chris@16: namespace boost {
Chris@16: namespace interprocess {
Chris@16: namespace ipcdetail{
Chris@16: 
Chris@16:    #if defined BOOST_INTERPROCESS_POSIX_PROCESS_SHARED
Chris@16: 
Chris@16:    //!Makes pthread_mutexattr_t cleanup easy when using exceptions
Chris@16:    struct mutexattr_wrapper
Chris@16:    {
Chris@16:       //!Constructor
Chris@16:       mutexattr_wrapper(bool recursive = false)
Chris@16:       {
Chris@16:          if(pthread_mutexattr_init(&m_attr)!=0 ||
Chris@16:             pthread_mutexattr_setpshared(&m_attr, PTHREAD_PROCESS_SHARED)!= 0 ||
Chris@16:              (recursive &&
Chris@16:               pthread_mutexattr_settype(&m_attr, PTHREAD_MUTEX_RECURSIVE)!= 0 ))
Chris@16:             throw interprocess_exception("pthread_mutexattr_xxxx failed");
Chris@16:       }
Chris@16: 
Chris@16:       //!Destructor
Chris@16:      ~mutexattr_wrapper()  {  pthread_mutexattr_destroy(&m_attr);  }
Chris@16: 
Chris@16:       //!This allows using mutexattr_wrapper as pthread_mutexattr_t
Chris@16:       operator pthread_mutexattr_t&()  {  return m_attr;  }
Chris@16: 
Chris@16:       pthread_mutexattr_t m_attr;
Chris@16:    };
Chris@16: 
Chris@16:    //!Makes pthread_condattr_t cleanup easy when using exceptions
Chris@16:    struct condattr_wrapper
Chris@16:    {
Chris@16:       //!Constructor
Chris@16:       condattr_wrapper()
Chris@16:       {
Chris@16:          if(pthread_condattr_init(&m_attr)!=0 ||
Chris@16:             pthread_condattr_setpshared(&m_attr, PTHREAD_PROCESS_SHARED)!= 0)
Chris@16:             throw interprocess_exception("pthread_condattr_xxxx failed");
Chris@16:       }
Chris@16: 
Chris@16:       //!Destructor
Chris@16:      ~condattr_wrapper() { pthread_condattr_destroy(&m_attr); }
Chris@16: 
Chris@16:       //!This allows using condattr_wrapper as pthread_condattr_t
Chris@16:       operator pthread_condattr_t&(){  return m_attr;  }
Chris@16: 
Chris@16:       pthread_condattr_t m_attr;
Chris@16:    };
Chris@16: 
Chris@16:    //!Makes initialized pthread_mutex_t cleanup easy when using exceptions
Chris@16:    class mutex_initializer
Chris@16:    {
Chris@16:     public:
Chris@16:       //!Constructor. Takes interprocess_mutex attributes to initialize the interprocess_mutex
Chris@16:       mutex_initializer(pthread_mutex_t &mut, pthread_mutexattr_t &mut_attr)
Chris@16:       : mp_mut(&mut)
Chris@16:       {
Chris@16:          if(pthread_mutex_init(mp_mut, &mut_attr) != 0)
Chris@16:             throw interprocess_exception("pthread_mutex_init failed");
Chris@16:       }
Chris@16: 
Chris@16:      ~mutex_initializer() {  if(mp_mut) pthread_mutex_destroy(mp_mut);  }
Chris@16: 
Chris@16:       void release() {mp_mut = 0; }
Chris@16: 
Chris@16:     private:
Chris@16:       pthread_mutex_t *mp_mut;
Chris@16:    };
Chris@16: 
Chris@16:    //!Makes initialized pthread_cond_t cleanup easy when using exceptions
Chris@16:    class condition_initializer
Chris@16:    {
Chris@16:     public:
Chris@16:       condition_initializer(pthread_cond_t &cond, pthread_condattr_t &cond_attr)
Chris@16:       : mp_cond(&cond)
Chris@16:       {
Chris@16:          if(pthread_cond_init(mp_cond, &cond_attr)!= 0)
Chris@16:             throw interprocess_exception("pthread_cond_init failed");
Chris@16:       }
Chris@16: 
Chris@16:      ~condition_initializer()   {  if(mp_cond) pthread_cond_destroy(mp_cond);  }
Chris@16: 
Chris@16:       void release()       { mp_cond = 0; }
Chris@16: 
Chris@16:     private:
Chris@16:       pthread_cond_t *mp_cond;
Chris@16:    };
Chris@16: 
Chris@16:    #endif   //   #if defined BOOST_INTERPROCESS_POSIX_PROCESS_SHARED
Chris@16: 
Chris@16:    #if defined(BOOST_INTERPROCESS_POSIX_BARRIERS) && defined(BOOST_INTERPROCESS_POSIX_PROCESS_SHARED)
Chris@16: 
Chris@16:    //!Makes pthread_barrierattr_t cleanup easy when using exceptions
Chris@16:    struct barrierattr_wrapper
Chris@16:    {
Chris@16:       //!Constructor
Chris@16:       barrierattr_wrapper()
Chris@16:       {
Chris@16:          if(pthread_barrierattr_init(&m_attr)!=0 ||
Chris@16:             pthread_barrierattr_setpshared(&m_attr, PTHREAD_PROCESS_SHARED)!= 0)
Chris@16:             throw interprocess_exception("pthread_barrierattr_xxx failed");
Chris@16:       }
Chris@16: 
Chris@16:       //!Destructor
Chris@16:      ~barrierattr_wrapper()  {  pthread_barrierattr_destroy(&m_attr);  }
Chris@16: 
Chris@16:       //!This allows using mutexattr_wrapper as pthread_barrierattr_t
Chris@16:       operator pthread_barrierattr_t&()  {  return m_attr;  }
Chris@16: 
Chris@16:       pthread_barrierattr_t m_attr;
Chris@16:    };
Chris@16: 
Chris@16:    //!Makes initialized pthread_barrier_t cleanup easy when using exceptions
Chris@16:    class barrier_initializer
Chris@16:    {
Chris@16:     public:
Chris@16:       //!Constructor. Takes barrier attributes to initialize the barrier
Chris@16:       barrier_initializer(pthread_barrier_t &mut,
Chris@16:                           pthread_barrierattr_t &mut_attr,
Chris@16:                           int count)
Chris@16:       : mp_barrier(&mut)
Chris@16:       {
Chris@16:          if(pthread_barrier_init(mp_barrier, &mut_attr, count) != 0)
Chris@16:             throw interprocess_exception("pthread_barrier_init failed");
Chris@16:       }
Chris@16: 
Chris@16:      ~barrier_initializer() {  if(mp_barrier) pthread_barrier_destroy(mp_barrier);  }
Chris@16: 
Chris@16:       void release() {mp_barrier = 0; }
Chris@16: 
Chris@16:     private:
Chris@16:       pthread_barrier_t *mp_barrier;
Chris@16:    };
Chris@16: 
Chris@16:    #endif   //#if defined(BOOST_INTERPROCESS_POSIX_BARRIERS) && defined(BOOST_INTERPROCESS_POSIX_PROCESS_SHARED)
Chris@16: 
Chris@16: }//namespace ipcdetail
Chris@16: 
Chris@16: }//namespace interprocess
Chris@16: 
Chris@16: }//namespace boost
Chris@16: 
Chris@16: #include <boost/interprocess/detail/config_end.hpp>
Chris@16: 
Chris@16: #endif //ifdef BOOST_INTERPROCESS_PTHREAD_HELPERS_HPP