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_NAMED_RECURSIVE_MUTEX_HPP
|
Chris@16
|
12 #define BOOST_INTERPROCESS_NAMED_RECURSIVE_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/creation_tags.hpp>
|
Chris@16
|
25 #include <boost/interprocess/detail/posix_time_types_wrk.hpp>
|
Chris@16
|
26 #include <boost/interprocess/permissions.hpp>
|
Chris@16
|
27 #if !defined(BOOST_INTERPROCESS_FORCE_GENERIC_EMULATION) && defined (BOOST_INTERPROCESS_WINDOWS)
|
Chris@16
|
28 #include <boost/interprocess/sync/windows/named_recursive_mutex.hpp>
|
Chris@16
|
29 #define BOOST_INTERPROCESS_USE_WINDOWS
|
Chris@16
|
30 #else
|
Chris@16
|
31 #include <boost/interprocess/sync/shm/named_recursive_mutex.hpp>
|
Chris@16
|
32 #endif
|
Chris@16
|
33
|
Chris@16
|
34 //!\file
|
Chris@16
|
35 //!Describes a named named_recursive_mutex class for inter-process synchronization
|
Chris@16
|
36
|
Chris@16
|
37 namespace boost {
|
Chris@16
|
38 namespace interprocess {
|
Chris@16
|
39
|
Chris@101
|
40 #if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED)
|
Chris@16
|
41 namespace ipcdetail{ class interprocess_tester; }
|
Chris@101
|
42 #endif //#ifndef BOOST_INTERPROCESS_DOXYGEN_INVOKED
|
Chris@16
|
43
|
Chris@16
|
44 //!A recursive mutex with a global name, so it can be found from different
|
Chris@16
|
45 //!processes. This mutex can't be placed in shared memory, and
|
Chris@16
|
46 //!each process should have it's own named_recursive_mutex.
|
Chris@16
|
47 class named_recursive_mutex
|
Chris@16
|
48 {
|
Chris@101
|
49 #if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED)
|
Chris@16
|
50 //Non-copyable
|
Chris@16
|
51 named_recursive_mutex();
|
Chris@16
|
52 named_recursive_mutex(const named_recursive_mutex &);
|
Chris@16
|
53 named_recursive_mutex &operator=(const named_recursive_mutex &);
|
Chris@101
|
54 #endif //#ifndef BOOST_INTERPROCESS_DOXYGEN_INVOKED
|
Chris@16
|
55 public:
|
Chris@16
|
56
|
Chris@16
|
57 //!Creates a global recursive_mutex with a name.
|
Chris@16
|
58 //!If the recursive_mutex can't be created throws interprocess_exception
|
Chris@16
|
59 named_recursive_mutex(create_only_t create_only, const char *name, const permissions &perm = permissions());
|
Chris@16
|
60
|
Chris@16
|
61 //!Opens or creates a global recursive_mutex with a name.
|
Chris@16
|
62 //!If the recursive_mutex is created, this call is equivalent to
|
Chris@16
|
63 //!named_recursive_mutex(create_only_t, ... )
|
Chris@16
|
64 //!If the recursive_mutex is already created, this call is equivalent
|
Chris@16
|
65 //!named_recursive_mutex(open_only_t, ... )
|
Chris@16
|
66 //!Does not throw
|
Chris@16
|
67 named_recursive_mutex(open_or_create_t open_or_create, const char *name, const permissions &perm = permissions());
|
Chris@16
|
68
|
Chris@16
|
69 //!Opens a global recursive_mutex with a name if that recursive_mutex is previously
|
Chris@16
|
70 //!created. If it is not previously created this function throws
|
Chris@16
|
71 //!interprocess_exception.
|
Chris@16
|
72 named_recursive_mutex(open_only_t open_only, const char *name);
|
Chris@16
|
73
|
Chris@16
|
74 //!Destroys *this and indicates that the calling process is finished using
|
Chris@16
|
75 //!the resource. The destructor function will deallocate
|
Chris@16
|
76 //!any system resources allocated by the system for use by this process for
|
Chris@16
|
77 //!this resource. The resource can still be opened again calling
|
Chris@16
|
78 //!the open constructor overload. To erase the resource from the system
|
Chris@16
|
79 //!use remove().
|
Chris@16
|
80 ~named_recursive_mutex();
|
Chris@16
|
81
|
Chris@16
|
82 //!Unlocks a previously locked
|
Chris@16
|
83 //!named_recursive_mutex.
|
Chris@16
|
84 void unlock();
|
Chris@16
|
85
|
Chris@16
|
86 //!Locks named_recursive_mutex, sleeps when named_recursive_mutex is already locked.
|
Chris@16
|
87 //!Throws interprocess_exception if a severe error is found.
|
Chris@16
|
88 void lock();
|
Chris@16
|
89
|
Chris@16
|
90 //!Tries to lock the named_recursive_mutex, returns false when named_recursive_mutex
|
Chris@16
|
91 //!is already locked, returns true when success.
|
Chris@16
|
92 //!Throws interprocess_exception if a severe error is found.
|
Chris@16
|
93 bool try_lock();
|
Chris@16
|
94
|
Chris@16
|
95 //!Tries to lock the named_recursive_mutex until time abs_time,
|
Chris@16
|
96 //!Returns false when timeout expires, returns true when locks.
|
Chris@16
|
97 //!Throws interprocess_exception if a severe error is found
|
Chris@16
|
98 bool timed_lock(const boost::posix_time::ptime &abs_time);
|
Chris@16
|
99
|
Chris@16
|
100 //!Erases a named recursive mutex
|
Chris@16
|
101 //!from the system
|
Chris@16
|
102 static bool remove(const char *name);
|
Chris@16
|
103
|
Chris@101
|
104 #if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED)
|
Chris@16
|
105 private:
|
Chris@16
|
106 friend class ipcdetail::interprocess_tester;
|
Chris@16
|
107 void dont_close_on_destruction();
|
Chris@16
|
108
|
Chris@16
|
109 #if defined(BOOST_INTERPROCESS_USE_WINDOWS)
|
Chris@16
|
110 typedef ipcdetail::windows_named_recursive_mutex impl_t;
|
Chris@16
|
111 #undef BOOST_INTERPROCESS_USE_WINDOWS
|
Chris@16
|
112 #else
|
Chris@16
|
113 typedef ipcdetail::shm_named_recursive_mutex impl_t;
|
Chris@16
|
114 #endif
|
Chris@16
|
115 impl_t m_mut;
|
Chris@16
|
116
|
Chris@101
|
117 #endif //#ifndef BOOST_INTERPROCESS_DOXYGEN_INVOKED
|
Chris@16
|
118 };
|
Chris@16
|
119
|
Chris@101
|
120 #if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED)
|
Chris@16
|
121
|
Chris@16
|
122 inline named_recursive_mutex::~named_recursive_mutex()
|
Chris@16
|
123 {}
|
Chris@16
|
124
|
Chris@16
|
125 inline void named_recursive_mutex::dont_close_on_destruction()
|
Chris@16
|
126 { ipcdetail::interprocess_tester::dont_close_on_destruction(m_mut); }
|
Chris@16
|
127
|
Chris@16
|
128 inline named_recursive_mutex::named_recursive_mutex(create_only_t, const char *name, const permissions &perm)
|
Chris@16
|
129 : m_mut (create_only, name, perm)
|
Chris@16
|
130 {}
|
Chris@16
|
131
|
Chris@16
|
132 inline named_recursive_mutex::named_recursive_mutex(open_or_create_t, const char *name, const permissions &perm)
|
Chris@16
|
133 : m_mut (open_or_create, name, perm)
|
Chris@16
|
134 {}
|
Chris@16
|
135
|
Chris@16
|
136 inline named_recursive_mutex::named_recursive_mutex(open_only_t, const char *name)
|
Chris@16
|
137 : m_mut (open_only, name)
|
Chris@16
|
138 {}
|
Chris@16
|
139
|
Chris@16
|
140 inline void named_recursive_mutex::lock()
|
Chris@16
|
141 { m_mut.lock(); }
|
Chris@16
|
142
|
Chris@16
|
143 inline void named_recursive_mutex::unlock()
|
Chris@16
|
144 { m_mut.unlock(); }
|
Chris@16
|
145
|
Chris@16
|
146 inline bool named_recursive_mutex::try_lock()
|
Chris@16
|
147 { return m_mut.try_lock(); }
|
Chris@16
|
148
|
Chris@16
|
149 inline bool named_recursive_mutex::timed_lock(const boost::posix_time::ptime &abs_time)
|
Chris@101
|
150 { return m_mut.timed_lock(abs_time); }
|
Chris@16
|
151
|
Chris@16
|
152 inline bool named_recursive_mutex::remove(const char *name)
|
Chris@16
|
153 { return impl_t::remove(name); }
|
Chris@16
|
154
|
Chris@101
|
155 #endif //#ifndef BOOST_INTERPROCESS_DOXYGEN_INVOKED
|
Chris@16
|
156
|
Chris@16
|
157 } //namespace interprocess {
|
Chris@16
|
158 } //namespace boost {
|
Chris@16
|
159
|
Chris@16
|
160 #include <boost/interprocess/detail/config_end.hpp>
|
Chris@16
|
161
|
Chris@16
|
162 #endif //BOOST_INTERPROCESS_NAMED_RECURSIVE_MUTEX_HPP
|