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
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 1996-2006
* Oracle Corporation. All rights reserved.
*
* $Id: mutex.h,v 12.20 2006/08/24 14:45:29 bostic Exp $
*/
#ifndef _DB_MUTEX_H_
#define _DB_MUTEX_H_
#if defined(__cplusplus)
extern "C" {
#endif
/*
* Mutexes are represented by unsigned, 32-bit integral values. As the
* OOB value is 0, mutexes can be initialized by zero-ing out the memory
* in which they reside.
*/
#define MUTEX_INVALID 0
/*
* We track mutex allocations by ID.
*/
#define MTX_APPLICATION 1
#define MTX_DB_HANDLE 2
#define MTX_ENV_DBLIST 3
#define MTX_ENV_REGION 4
#define MTX_LOCK_REGION 5
#define MTX_LOGICAL_LOCK 6
#define MTX_LOG_FILENAME 7
#define MTX_LOG_FLUSH 8
#define MTX_LOG_HANDLE 9
#define MTX_LOG_REGION 10
#define MTX_MPOOLFILE_HANDLE 11
#define MTX_MPOOL_FH 12
#define MTX_MPOOL_FILE_BUCKET 13
#define MTX_MPOOL_HANDLE 14
#define MTX_MPOOL_HASH_BUCKET 15
#define MTX_MPOOL_IO 16
#define MTX_MPOOL_REGION 17
#define MTX_MUTEX_REGION 18
#define MTX_MUTEX_TEST 19
#define MTX_REP_DATABASE 20
#define MTX_REP_REGION 21
#define MTX_SEQUENCE 22
#define MTX_TWISTER 23
#define MTX_TXN_ACTIVE 24
#define MTX_TXN_CHKPT 25
#define MTX_TXN_COMMIT 26
#define MTX_TXN_MVCC 27
#define MTX_TXN_REGION 28
#define MTX_MAX_ENTRY 28
/* Redirect mutex calls to the correct functions. */
#if defined(HAVE_MUTEX_PTHREADS) || \
defined(HAVE_MUTEX_SOLARIS_LWP) || \
defined(HAVE_MUTEX_UI_THREADS)
#define __mutex_init(a, b, c) __db_pthread_mutex_init(a, b, c)
#define __mutex_lock(a, b) __db_pthread_mutex_lock(a, b)
#define __mutex_unlock(a, b) __db_pthread_mutex_unlock(a, b)
#define __mutex_destroy(a, b) __db_pthread_mutex_destroy(a, b)
#endif
#if defined(HAVE_MUTEX_WIN32) || defined(HAVE_MUTEX_WIN32_GCC)
#define __mutex_init(a, b, c) __db_win32_mutex_init(a, b, c)
#define __mutex_lock(a, b) __db_win32_mutex_lock(a, b)
#define __mutex_unlock(a, b) __db_win32_mutex_unlock(a, b)
#define __mutex_destroy(a, b) __db_win32_mutex_destroy(a, b)
#endif
#if defined(HAVE_MUTEX_FCNTL)
#define __mutex_init(a, b, c) __db_fcntl_mutex_init(a, b, c)
#define __mutex_lock(a, b) __db_fcntl_mutex_lock(a, b)
#define __mutex_unlock(a, b) __db_fcntl_mutex_unlock(a, b)
#define __mutex_destroy(a, b) __db_fcntl_mutex_destroy(a, b)
#endif
#ifndef __mutex_init /* Test-and-set is the default */
#define __mutex_init(a, b, c) __db_tas_mutex_init(a, b, c)
#define __mutex_lock(a, b) __db_tas_mutex_lock(a, b)
#define __mutex_unlock(a, b) __db_tas_mutex_unlock(a, b)
#define __mutex_destroy(a, b) __db_tas_mutex_destroy(a, b)
#endif
/*
* Lock/unlock a mutex. If the mutex was never required, the thread of
* control can proceed without it.
*
* We never fail to acquire or release a mutex without panicing. Simplify
* the macros to always return a panic value rather than saving the actual
* return value of the mutex routine.
*/
#define MUTEX_LOCK(dbenv, mutex) do { \
if ((mutex) != MUTEX_INVALID && \
__mutex_lock(dbenv, mutex) != 0) \
return (DB_RUNRECOVERY); \
} while (0)
#define MUTEX_UNLOCK(dbenv, mutex) do { \
if ((mutex) != MUTEX_INVALID && \
__mutex_unlock(dbenv, mutex) != 0) \
return (DB_RUNRECOVERY); \
} while (0)
/*
* Berkeley DB ports may require single-threading at places in the code.
*/
#ifdef HAVE_MUTEX_VXWORKS
#include "taskLib.h"
/*
* Use the taskLock() mutex to eliminate a race where two tasks are
* trying to initialize the global lock at the same time.
*/
#define DB_BEGIN_SINGLE_THREAD do { \
if (DB_GLOBAL(db_global_init)) \
(void)semTake(DB_GLOBAL(db_global_lock), WAIT_FOREVER); \
else { \
taskLock(); \
if (DB_GLOBAL(db_global_init)) { \
taskUnlock(); \
(void)semTake(DB_GLOBAL(db_global_lock), \
WAIT_FOREVER); \
continue; \
} \
DB_GLOBAL(db_global_lock) = \
semBCreate(SEM_Q_FIFO, SEM_EMPTY); \
if (DB_GLOBAL(db_global_lock) != NULL) \
DB_GLOBAL(db_global_init) = 1; \
taskUnlock(); \
} \
} while (DB_GLOBAL(db_global_init) == 0)
#define DB_END_SINGLE_THREAD (void)semGive(DB_GLOBAL(db_global_lock))
#endif
/*
* Single-threading defaults to a no-op.
*/
#ifndef DB_BEGIN_SINGLE_THREAD
#define DB_BEGIN_SINGLE_THREAD
#endif
#ifndef DB_END_SINGLE_THREAD
#define DB_END_SINGLE_THREAD
#endif
#if defined(__cplusplus)
}
#endif
#include "dbinc_auto/mutex_ext.h"
#endif /* !_DB_MUTEX_H_ */
|
