123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360 |
- #ifndef BOOST_INTERPROCESS_NAMED_UPGRADABLE_MUTEX_HPP
- #define BOOST_INTERPROCESS_NAMED_UPGRADABLE_MUTEX_HPP
- #ifndef BOOST_CONFIG_HPP
- # include <boost/config.hpp>
- #endif
- #
- #if defined(BOOST_HAS_PRAGMA_ONCE)
- # pragma once
- #endif
- #include <boost/interprocess/detail/config_begin.hpp>
- #include <boost/interprocess/detail/workaround.hpp>
- #include <boost/interprocess/creation_tags.hpp>
- #include <boost/interprocess/exceptions.hpp>
- #include <boost/interprocess/shared_memory_object.hpp>
- #include <boost/interprocess/detail/managed_open_or_create_impl.hpp>
- #include <boost/interprocess/sync/interprocess_upgradable_mutex.hpp>
- #include <boost/interprocess/sync/shm/named_creation_functor.hpp>
- #include <boost/interprocess/permissions.hpp>
- namespace boost {
- namespace interprocess {
- #if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED)
- namespace ipcdetail{ class interprocess_tester; }
- #endif
- class named_condition;
- class named_upgradable_mutex
- {
- #if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED)
-
- named_upgradable_mutex();
- named_upgradable_mutex(const named_upgradable_mutex &);
- named_upgradable_mutex &operator=(const named_upgradable_mutex &);
- friend class named_condition;
- #endif
- public:
-
-
- named_upgradable_mutex(create_only_t, const char *name, const permissions &perm = permissions());
-
-
-
-
-
- named_upgradable_mutex(open_or_create_t, const char *name, const permissions &perm = permissions());
-
-
-
-
- named_upgradable_mutex(open_only_t, const char *name);
-
-
-
-
-
-
- ~named_upgradable_mutex();
-
-
-
-
-
- void lock();
-
-
-
-
-
-
- bool try_lock();
-
-
-
-
-
- template<class TimePoint>
- bool timed_lock(const TimePoint &abs_time);
-
-
-
- void unlock();
-
-
-
-
-
- void lock_sharable();
-
-
-
-
-
-
- bool try_lock_sharable();
-
-
-
-
-
- template<class TimePoint>
- bool timed_lock_sharable(const TimePoint &abs_time);
-
-
-
- void unlock_sharable();
-
-
-
-
-
- void lock_upgradable();
-
-
-
-
-
-
- bool try_lock_upgradable();
-
-
-
-
-
- template<class TimePoint>
- bool timed_lock_upgradable(const TimePoint &abs_time);
-
-
-
- void unlock_upgradable();
-
-
-
-
-
- void unlock_and_lock_upgradable();
-
-
-
-
- void unlock_and_lock_sharable();
-
-
-
-
- void unlock_upgradable_and_lock_sharable();
-
-
-
-
-
-
- void unlock_upgradable_and_lock();
-
-
-
-
-
-
- bool try_unlock_upgradable_and_lock();
-
-
-
-
-
-
-
- template<class TimePoint>
- bool timed_unlock_upgradable_and_lock(const TimePoint &abs_time);
-
-
-
-
-
-
- bool try_unlock_sharable_and_lock();
- bool try_unlock_sharable_and_lock_upgradable();
-
-
- static bool remove(const char *name);
- #if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED)
- private:
- friend class ipcdetail::interprocess_tester;
- void dont_close_on_destruction();
- interprocess_upgradable_mutex *mutex() const
- { return static_cast<interprocess_upgradable_mutex*>(m_shmem.get_user_address()); }
- typedef ipcdetail::managed_open_or_create_impl<shared_memory_object, 0, true, false> open_create_impl_t;
- open_create_impl_t m_shmem;
- typedef ipcdetail::named_creation_functor<interprocess_upgradable_mutex> construct_func_t;
- #endif
- };
- #if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED)
- inline named_upgradable_mutex::~named_upgradable_mutex()
- {}
- inline named_upgradable_mutex::named_upgradable_mutex
- (create_only_t, const char *name, const permissions &perm)
- : m_shmem (create_only_t()
- ,name
- ,sizeof(interprocess_upgradable_mutex) +
- open_create_impl_t::ManagedOpenOrCreateUserOffset
- ,read_write
- ,0
- ,construct_func_t(ipcdetail::DoCreate)
- ,perm)
- {}
- inline named_upgradable_mutex::named_upgradable_mutex
- (open_or_create_t, const char *name, const permissions &perm)
- : m_shmem (open_or_create_t()
- ,name
- ,sizeof(interprocess_upgradable_mutex) +
- open_create_impl_t::ManagedOpenOrCreateUserOffset
- ,read_write
- ,0
- ,construct_func_t(ipcdetail::DoOpenOrCreate)
- ,perm)
- {}
- inline named_upgradable_mutex::named_upgradable_mutex
- (open_only_t, const char *name)
- : m_shmem (open_only_t()
- ,name
- ,read_write
- ,0
- ,construct_func_t(ipcdetail::DoOpen))
- {}
- inline void named_upgradable_mutex::dont_close_on_destruction()
- { ipcdetail::interprocess_tester::dont_close_on_destruction(m_shmem); }
- inline void named_upgradable_mutex::lock()
- { this->mutex()->lock(); }
- inline void named_upgradable_mutex::unlock()
- { this->mutex()->unlock(); }
- inline bool named_upgradable_mutex::try_lock()
- { return this->mutex()->try_lock(); }
- template<class TimePoint>
- inline bool named_upgradable_mutex::timed_lock(const TimePoint &abs_time)
- { return this->mutex()->timed_lock(abs_time); }
- inline void named_upgradable_mutex::lock_upgradable()
- { this->mutex()->lock_upgradable(); }
- inline void named_upgradable_mutex::unlock_upgradable()
- { this->mutex()->unlock_upgradable(); }
- inline bool named_upgradable_mutex::try_lock_upgradable()
- { return this->mutex()->try_lock_upgradable(); }
- template<class TimePoint>
- inline bool named_upgradable_mutex::timed_lock_upgradable(const TimePoint &abs_time)
- { return this->mutex()->timed_lock_upgradable(abs_time); }
- inline void named_upgradable_mutex::lock_sharable()
- { this->mutex()->lock_sharable(); }
- inline void named_upgradable_mutex::unlock_sharable()
- { this->mutex()->unlock_sharable(); }
- inline bool named_upgradable_mutex::try_lock_sharable()
- { return this->mutex()->try_lock_sharable(); }
- template<class TimePoint>
- inline bool named_upgradable_mutex::timed_lock_sharable(const TimePoint &abs_time)
- { return this->mutex()->timed_lock_sharable(abs_time); }
- inline void named_upgradable_mutex::unlock_and_lock_upgradable()
- { this->mutex()->unlock_and_lock_upgradable(); }
- inline void named_upgradable_mutex::unlock_and_lock_sharable()
- { this->mutex()->unlock_and_lock_sharable(); }
- inline void named_upgradable_mutex::unlock_upgradable_and_lock_sharable()
- { this->mutex()->unlock_upgradable_and_lock_sharable(); }
- inline void named_upgradable_mutex::unlock_upgradable_and_lock()
- { this->mutex()->unlock_upgradable_and_lock(); }
- inline bool named_upgradable_mutex::try_unlock_upgradable_and_lock()
- { return this->mutex()->try_unlock_upgradable_and_lock(); }
- template<class TimePoint>
- inline bool named_upgradable_mutex::timed_unlock_upgradable_and_lock(const TimePoint &abs_time)
- { return this->mutex()->timed_unlock_upgradable_and_lock(abs_time); }
- inline bool named_upgradable_mutex::try_unlock_sharable_and_lock()
- { return this->mutex()->try_unlock_sharable_and_lock(); }
- inline bool named_upgradable_mutex::try_unlock_sharable_and_lock_upgradable()
- { return this->mutex()->try_unlock_sharable_and_lock_upgradable(); }
- inline bool named_upgradable_mutex::remove(const char *name)
- { return shared_memory_object::remove(name); }
- #endif
- }
- }
- #include <boost/interprocess/detail/config_end.hpp>
- #endif
|