1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
|
// -*- C++ -*-
//=============================================================================
/**
* @file Process_Mutex.h
*
* $Id$
*
* A wrapper for mutexes that can be used across processes on the
* same host machine, as well as within a process, of course.
*
* @author Douglas C. Schmidt <schmidt@uci.edu>
*/
//=============================================================================
#ifndef ACE_PROCESS_MUTEX_H
#define ACE_PROCESS_MUTEX_H
#include /**/ "ace/pre.h"
#include "ace/config-all.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
// To make it easier to carry the setting though this file as well as
// Process_Mutex.{cpp inl}, set a private macro here.
#ifdef _ACE_USE_SV_SEM
# undef _ACE_USE_SV_SEM
#endif /* _ACE_USE_SV_SEM */
#if defined (ACE_HAS_SYSV_IPC) && !defined (ACE_USES_MUTEX_FOR_PROCESS_MUTEX)
# include "ace/SV_Semaphore_Complex.h"
# define _ACE_USE_SV_SEM
#else
# include "ace/Mutex.h"
#endif /* ACE_HAS_SYSV_IPC && !ACE_USES_MUTEX_FOR_PROCESS_MUTEX */
// Forward declarations
class ACE_Time_Value;
/**
* @class ACE_Process_Mutex
*
* @brief A wrapper for mutexes that can be used across processes on
* the same host machine, as well as within a process, of
* course.
*
* @attention The mechanism upon which @c ACE_Process_Mutex is based
* can be configured at build time to be either @c ACE_SV_Semaphore_Complex
* (on platforms that support it) or @c ACE_Mutex. On platforms that
* require interprocess mutexes be allocated from shared memory (Pthreads
* and UI Threads are examples), @c ACE_SV_Semaphore_Complex provides a
* more reliable mechanism for implementing inter-process mutex than
* @c ACE_Mutex. However, at least on some platforms,
* @c ACE_SV_Semaphore_Complex is limited to a small number of
* objects by the underlying System V IPC kernel parameters. If you
* want to force use of @c ACE_Mutex as the underlying mechanism, set
* @c ACE_USES_MUTEX_FOR_PROCESS_MUTEX in your @c config.h file.
* Also, if you require the ability to do a timed @c acquire(), you must
* set @c ACE_USES_MUTEX_FOR_PROCESS_MUTEX, as timed acquire does not
* work with System V semaphores.
* @attention Currently there is also the operational difference between
* pthreads and semaphores based @c. For semaphore base @c the semaphore
* is destroyed after the last instance of @c in OS. In contrary, pthread based
* @c is destroyed when the owner, namely the process which created the
* first instance of @c destroys the mutex. For protable applications it is better
* to always ensure that the owner of the mutex destroys it after the
* other processes.
*/
class ACE_Export ACE_Process_Mutex
{
public:
/**
* Create a Process_Mutex, passing in the optional @c name.
*
* @param name optional, null-terminated string containing the name of
* the object. Multiple users of the same @c ACE_Process_Mutex must use
* the same name to access the same object. If not specified, a name
* is generated.
* @param arg optional, attributes to be used to initialize the mutex.
* If using @c ACE_SV_Semaphore_Complex as the underlying mechanism,
* this argument is ignored.
* @param mode optional, the protection mode for either the backing store
* file (for ACE_Mutex use) or the ACE_SV_Semaphore_Complex that's created.
*/
ACE_Process_Mutex (const char *name = 0,
void *arg = 0,
mode_t mode = ACE_DEFAULT_FILE_PERMS);
#if defined (ACE_HAS_WCHAR)
/**
* Create a Process_Mutex, passing in the optional @c name. (@c wchar_t
* version)
*
* @param name optional, null-terminated string containing the name of
* the object. Multiple users of the same @c ACE_Process_Mutex must use
* the same name to access the same object. If not specified, a name
* is generated.
* @param arg optional, attributes to be used to initialize the mutex.
* If using @c ACE_SV_Semaphore_Complex as the underlying mechanism,
* this argument is ignored.
* @param mode optional, the protection mode for either the backing store
* file (for ACE_Mutex use) or the ACE_SV_Semaphore_Complex that's created.
*/
ACE_Process_Mutex (const wchar_t *name,
void *arg = 0,
mode_t mode = ACE_DEFAULT_FILE_PERMS);
#endif /* ACE_HAS_WCHAR */
~ACE_Process_Mutex (void);
/**
* Explicitly destroy the mutex. Note that only one thread should
* call this method since it doesn't protect against race
* conditions.
*
* @return 0 on success; -1 on failure.
*/
int remove (void);
/**
* Acquire lock ownership (wait on queue if necessary).
*
* @return 0 on success; -1 on failure.
*/
int acquire (void);
/**
* Acquire lock ownership, but timeout if lock if hasn't been
* acquired by given time.
*
* @param tv the absolute time until which the caller is willing to
* wait to acquire the lock.
*
* @return 0 on success; -1 on failure.
*/
int acquire (ACE_Time_Value &tv);
/**
* Conditionally acquire lock (i.e., don't wait on queue).
*
* @return 0 on success; -1 on failure. If the lock could not be acquired
* because someone else already had the lock, @c errno is set to @c EBUSY.
*/
int tryacquire (void);
/// Release lock and unblock a thread at head of queue.
int release (void);
/// Acquire lock ownership (wait on queue if necessary).
int acquire_read (void);
/// Acquire lock ownership (wait on queue if necessary).
int acquire_write (void);
/**
* Conditionally acquire a lock (i.e., won't block). Returns -1 on
* failure. If we "failed" because someone else already had the
* lock, <errno> is set to <EBUSY>.
*/
int tryacquire_read (void);
/**
* Conditionally acquire a lock (i.e., won't block). Returns -1 on
* failure. If we "failed" because someone else already had the
* lock, <errno> is set to <EBUSY>.
*/
int tryacquire_write (void);
/**
* This is only here for consistency with the other synchronization
* APIs and usability with Lock adapters. Assumes the caller already has
* acquired the mutex and returns 0 in all cases.
*/
int tryacquire_write_upgrade (void);
#if !defined (_ACE_USE_SV_SEM)
/// Return the underlying mutex.
const ACE_mutex_t &lock (void) const;
#endif /* !_ACE_USE_SV_SEM */
/// Dump the state of an object.
void dump (void) const;
/// Declare the dynamic allocation hooks.
ACE_ALLOC_HOOK_DECLARE;
private:
/// If the user does not provide a name we generate a unique name in
/// this buffer.
ACE_TCHAR name_[ACE_UNIQUE_NAME_LEN];
/// Create and return the unique name.
const ACE_TCHAR *unique_name (void);
#if defined (_ACE_USE_SV_SEM)
/// We need this to get the right semantics...
ACE_SV_Semaphore_Complex lock_;
#else
ACE_Mutex lock_;
#endif /* _ACE_USE_SV_SEM */
};
#if defined (__ACE_INLINE__)
#include "ace/Process_Mutex.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* ACE_PROCESS_MUTEX_H */
|
