////////////////////////////////////////////////////////////////////////////// // // (C) Copyright Ion Gaztanaga 2005-2012. Distributed under the Boost // Software License, Version 1.0. (See accompanying file // LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) // // See http://www.boost.org/libs/interprocess for documentation. // ////////////////////////////////////////////////////////////////////////////// #ifndef BOOST_INTERPROCESS_POSIX_NAMED_MUTEX_HPP #define BOOST_INTERPROCESS_POSIX_NAMED_MUTEX_HPP #ifndef BOOST_CONFIG_HPP # include #endif # #if defined(BOOST_HAS_PRAGMA_ONCE) # pragma once #endif #include #include #include #include #include #include #include namespace boost { namespace interprocess { namespace ipcdetail { class named_condition; class posix_named_mutex { #if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED) posix_named_mutex(); posix_named_mutex(const posix_named_mutex &); posix_named_mutex &operator=(const posix_named_mutex &); friend class named_condition; #endif //#ifndef BOOST_INTERPROCESS_DOXYGEN_INVOKED public: posix_named_mutex(create_only_t create_only, const char *name, const permissions &perm = permissions()); posix_named_mutex(open_or_create_t open_or_create, const char *name, const permissions &perm = permissions()); posix_named_mutex(open_only_t open_only, const char *name); ~posix_named_mutex(); void unlock(); void lock(); bool try_lock(); bool timed_lock(const boost::posix_time::ptime &abs_time); static bool remove(const char *name); #if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED) private: friend class interprocess_tester; void dont_close_on_destruction(); posix_named_semaphore m_sem; #endif //#ifndef BOOST_INTERPROCESS_DOXYGEN_INVOKED }; #if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED) inline posix_named_mutex::posix_named_mutex(create_only_t, const char *name, const permissions &perm) : m_sem(create_only, name, 1, perm) {} inline posix_named_mutex::posix_named_mutex(open_or_create_t, const char *name, const permissions &perm) : m_sem(open_or_create, name, 1, perm) {} inline posix_named_mutex::posix_named_mutex(open_only_t, const char *name) : m_sem(open_only, name) {} inline void posix_named_mutex::dont_close_on_destruction() { interprocess_tester::dont_close_on_destruction(m_sem); } inline posix_named_mutex::~posix_named_mutex() {} inline void posix_named_mutex::lock() { m_sem.wait(); } inline void posix_named_mutex::unlock() { m_sem.post(); } inline bool posix_named_mutex::try_lock() { return m_sem.try_wait(); } inline bool posix_named_mutex::timed_lock(const boost::posix_time::ptime &abs_time) { return m_sem.timed_wait(abs_time); } inline bool posix_named_mutex::remove(const char *name) { return posix_named_semaphore::remove(name); } #endif //#ifndef BOOST_INTERPROCESS_DOXYGEN_INVOKED } //namespace ipcdetail { } //namespace interprocess { } //namespace boost { #include #endif //BOOST_INTERPROCESS_POSIX_NAMED_MUTEX_HPP