1 ////////////////////////////////////////////////////////////////////////////// 2 // 3 // (C) Copyright Ion Gaztanaga 2005-2012. Distributed under the Boost 4 // Software License, Version 1.0. (See accompanying file 5 // LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) 6 // 7 // See http://www.boost.org/libs/interprocess for documentation. 8 // 9 ////////////////////////////////////////////////////////////////////////////// 10 11 #ifndef BOOST_INTERPROCESS_POSIX_NAMED_CONDITION_HPP 12 #define BOOST_INTERPROCESS_POSIX_NAMED_CONDITION_HPP 13 14 #ifndef BOOST_CONFIG_HPP 15 # include <boost/config.hpp> 16 #endif 17 # 18 #if defined(BOOST_HAS_PRAGMA_ONCE) 19 # pragma once 20 #endif 21 22 #include <boost/interprocess/detail/config_begin.hpp> 23 #include <boost/interprocess/detail/workaround.hpp> 24 25 #include <boost/interprocess/sync/posix/semaphore_wrapper.hpp> 26 27 namespace boost { 28 namespace interprocess { 29 30 #if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED) 31 namespace ipcdetail{ class interprocess_tester; } 32 #endif //#ifndef BOOST_INTERPROCESS_DOXYGEN_INVOKED 33 34 namespace ipcdetail { 35 36 class posix_named_semaphore 37 { 38 posix_named_semaphore(); 39 posix_named_semaphore(const posix_named_semaphore&); 40 posix_named_semaphore &operator= (const posix_named_semaphore &); 41 42 public: posix_named_semaphore(create_only_t,const char * name,unsigned int initialCount,const permissions & perm=permissions ())43 posix_named_semaphore 44 (create_only_t, const char *name, unsigned int initialCount, const permissions &perm = permissions()) 45 { semaphore_open(mp_sem, DoCreate, name, initialCount, perm); } 46 posix_named_semaphore(open_or_create_t,const char * name,unsigned int initialCount,const permissions & perm=permissions ())47 posix_named_semaphore(open_or_create_t, const char *name, unsigned int initialCount, const permissions &perm = permissions()) 48 { semaphore_open(mp_sem, DoOpenOrCreate, name, initialCount, perm); } 49 posix_named_semaphore(open_only_t,const char * name)50 posix_named_semaphore(open_only_t, const char *name) 51 { semaphore_open(mp_sem, DoOpen, name); } 52 ~posix_named_semaphore()53 ~posix_named_semaphore() 54 { 55 if(mp_sem != BOOST_INTERPROCESS_POSIX_SEM_FAILED) 56 semaphore_close(mp_sem); 57 } 58 post()59 void post() 60 { semaphore_post(mp_sem); } 61 wait()62 void wait() 63 { semaphore_wait(mp_sem); } 64 try_wait()65 bool try_wait() 66 { return semaphore_try_wait(mp_sem); } 67 timed_wait(const boost::posix_time::ptime & abs_time)68 bool timed_wait(const boost::posix_time::ptime &abs_time) 69 { return semaphore_timed_wait(mp_sem, abs_time); } 70 remove(const char * name)71 static bool remove(const char *name) 72 { return semaphore_unlink(name); } 73 74 private: 75 friend class ipcdetail::interprocess_tester; dont_close_on_destruction()76 void dont_close_on_destruction() 77 { mp_sem = BOOST_INTERPROCESS_POSIX_SEM_FAILED; } 78 79 sem_t *mp_sem; 80 }; 81 82 } //namespace ipcdetail { 83 } //namespace interprocess { 84 } //namespace boost { 85 86 #include <boost/interprocess/detail/config_end.hpp> 87 88 #endif //#ifndef BOOST_INTERPROCESS_POSIX_NAMED_CONDITION_HPP 89