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
|
includefile(include/header)
COMMENT(manpage, section, releasedate, archive, short name)
manpage(FBB::SharedMutex)(3bobcat)(_CurYrs_)(libbobcat-dev__CurVers_)
(Shared Memory Mutex)
manpagename(FBB::SharedMutex)(Mutex for shared memory)
manpagesynopsis()
bf(#include <bobcat/sharedmutex>)nl()
Linking option: tt(-lpthread, -lbobcat )
manpagedescription()
Shared memory may be used by multiple processes. To synchronize access to
shared memory an bf(FBB::SharedMutex) may be defined inside a shared memory
segment. bf(SharedMutex) objects allows clients to lock a shared memory
segment before reading or writing its content. E.g., the Bobcat class
tt(FBB::SharedSegment) defines a bf(SharedMutex) in its shared memory segment.
The bf(SharedMutex) class uses the facilities offered by the
tt(PThread) library to implement (non recursive) shared memory locking. To
force unlocking a (possibly) locked shared memory segment, its destructor can
be called.
bf(SharedMutex) mutexes are non-recursive, resulting in deadlocks if their
tt(lock) member is called twice from the same thread of execution without an
intermediate call to tt(unlock) the mutex. If this causes concern, a variable
can be defined indicating whether the lock has already been obtained.
includefile(include/namespace)
manpagesection(INHERITS FROM)
-
manpagesection(CONSTRUCTORS, DESTRUCTOR )
itemization(
itb(SharedMutex())
The default constructor initializes an bf(FBB::SharedMutex) object to a
shared memory mutex (using the tt(PTHREAD_PROCESS_SHARED)
attribute). As an bf(FBB::SharedMutex) object will normally be defined
inside a shared memory segment the object's memory is already
available. In this case placement new should be used to call the
constructor. E.g., if a shared memory segment is attached to the
current process at tt(d_shared), and an bf(FBB::SharedMutex) should be
defined at tt(d_shared)'s address, then the bf(FBB::SharedMutex)
object can be initialized like this:
verb(
new (d_shared) FBB::SharedMutex;
)
Caveat: when using placement new to initialize a bf(SharedMutex) make
sure that the bf(SharedMutex) fits inside a block (i.e.,
tt(shared.blockOffset() + sizeof(SharedMemory) <
shared.dataSegmentSize())). If not, use tt(seek) to switch to an
offset where this equality holds true, or simply use
tt(SharedMemory::create) like this:
verb(
FBB::SharedMemory::create<FBB::SharedMutex>();
)
itb(~SharedMutex())
The class's destructor releases all of the current process's nested
shared memory segment locks. To destroy an bf(FBB::SharedMutex) object
that has been constructed using the placement tt(new) operator use
verb(
d_sharedMutex->~SharedMutex();
)
(assuming tt(SharedMutex *d_sharedMutex) points to the location where
placement new has previously initialized the bf(FBB::SharedMutex)
object.)
)
Copy and move constructors (and assignment operators) are not available.
manpagesection(MEMBER FUNCTIONS)
itemization(
itb(void lock() const)
When returning from this member, the current process has locked the
shared memory segment. Note that bf(SharedMutex) objects are
non-recursive.
itb(void unlock() const)
The object's lock of the shared memory segment is released. This member
can also be called if the bf(SharedMutex's) lock has not been
obtained.
)
manpagesection(PROTECTED MEMBER FUNCTION)
itemization(
itb(pthread_mutex_t *mutexPtr())
A pointer is returned to the tt(pthread_mutex_t) object used by
the bf(SharedMutex) object;
)
manpagesection(EXAMPLE)
verbinclude(../../sharedmutex/driver/driver.cc)
manpagefiles()
em(bobcat/sharedmutex) - defines the class interface
manpageseealso()
bf(bobcat)(7)
bf(isharedstream)(3bobcat),
bf(osharedstream)(3bobcat),
bf(sharedblock)(3bobcat),
bf(sharedcondition)(3bobcat),
bf(sharedmemory)(3bobcat),
(e.g.,) bf(pthread_mutex_init)(3posix),
bf(sharedpos)(3bobcat),
bf(sharedreadme)(7bobcat),
bf(sharedsegment)(3bobcat),
bf(sharedstream)(3bobcat),
bf(sharedbuf)(3bobcat)
manpagebugs()
None Reported.
includefile(include/trailer)
|
