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_DETAIL_SPIN_MUTEX_HPP
|
Chris@16
|
12 #define BOOST_INTERPROCESS_DETAIL_SPIN_MUTEX_HPP
|
Chris@16
|
13
|
Chris@101
|
14 #ifndef BOOST_CONFIG_HPP
|
Chris@101
|
15 # include <boost/config.hpp>
|
Chris@101
|
16 #endif
|
Chris@101
|
17 #
|
Chris@101
|
18 #if defined(BOOST_HAS_PRAGMA_ONCE)
|
Chris@16
|
19 # pragma once
|
Chris@16
|
20 #endif
|
Chris@16
|
21
|
Chris@16
|
22 #include <boost/interprocess/detail/config_begin.hpp>
|
Chris@16
|
23 #include <boost/interprocess/detail/workaround.hpp>
|
Chris@16
|
24 #include <boost/interprocess/detail/posix_time_types_wrk.hpp>
|
Chris@16
|
25 #include <boost/assert.hpp>
|
Chris@16
|
26 #include <boost/interprocess/detail/atomic.hpp>
|
Chris@16
|
27 #include <boost/cstdint.hpp>
|
Chris@16
|
28 #include <boost/interprocess/detail/os_thread_functions.hpp>
|
Chris@101
|
29 #include <boost/interprocess/sync/detail/common_algorithms.hpp>
|
Chris@16
|
30
|
Chris@16
|
31 namespace boost {
|
Chris@16
|
32 namespace interprocess {
|
Chris@16
|
33 namespace ipcdetail {
|
Chris@16
|
34
|
Chris@16
|
35 class spin_mutex
|
Chris@16
|
36 {
|
Chris@16
|
37 spin_mutex(const spin_mutex &);
|
Chris@16
|
38 spin_mutex &operator=(const spin_mutex &);
|
Chris@16
|
39 public:
|
Chris@16
|
40
|
Chris@16
|
41 spin_mutex();
|
Chris@16
|
42 ~spin_mutex();
|
Chris@16
|
43
|
Chris@16
|
44 void lock();
|
Chris@16
|
45 bool try_lock();
|
Chris@16
|
46 bool timed_lock(const boost::posix_time::ptime &abs_time);
|
Chris@16
|
47 void unlock();
|
Chris@16
|
48 void take_ownership(){};
|
Chris@16
|
49 private:
|
Chris@16
|
50 volatile boost::uint32_t m_s;
|
Chris@16
|
51 };
|
Chris@16
|
52
|
Chris@16
|
53 inline spin_mutex::spin_mutex()
|
Chris@16
|
54 : m_s(0)
|
Chris@16
|
55 {
|
Chris@16
|
56 //Note that this class is initialized to zero.
|
Chris@16
|
57 //So zeroed memory can be interpreted as an
|
Chris@16
|
58 //initialized mutex
|
Chris@16
|
59 }
|
Chris@16
|
60
|
Chris@16
|
61 inline spin_mutex::~spin_mutex()
|
Chris@16
|
62 {
|
Chris@16
|
63 //Trivial destructor
|
Chris@16
|
64 }
|
Chris@16
|
65
|
Chris@16
|
66 inline void spin_mutex::lock(void)
|
Chris@101
|
67 { return ipcdetail::try_based_lock(*this); }
|
Chris@16
|
68
|
Chris@16
|
69 inline bool spin_mutex::try_lock(void)
|
Chris@16
|
70 {
|
Chris@16
|
71 boost::uint32_t prev_s = ipcdetail::atomic_cas32(const_cast<boost::uint32_t*>(&m_s), 1, 0);
|
Chris@16
|
72 return m_s == 1 && prev_s == 0;
|
Chris@16
|
73 }
|
Chris@16
|
74
|
Chris@16
|
75 inline bool spin_mutex::timed_lock(const boost::posix_time::ptime &abs_time)
|
Chris@101
|
76 { return ipcdetail::try_based_timed_lock(*this, abs_time); }
|
Chris@16
|
77
|
Chris@16
|
78 inline void spin_mutex::unlock(void)
|
Chris@16
|
79 { ipcdetail::atomic_cas32(const_cast<boost::uint32_t*>(&m_s), 0, 1); }
|
Chris@16
|
80
|
Chris@16
|
81 } //namespace ipcdetail {
|
Chris@16
|
82 } //namespace interprocess {
|
Chris@16
|
83 } //namespace boost {
|
Chris@16
|
84
|
Chris@16
|
85 #include <boost/interprocess/detail/config_end.hpp>
|
Chris@16
|
86
|
Chris@16
|
87 #endif //BOOST_INTERPROCESS_DETAIL_SPIN_MUTEX_HPP
|