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
|
/*-
* Copyright (c) 2008-2014 WiredTiger, Inc.
* All rights reserved.
*
* See the file LICENSE for redistribution information.
*/
/* Character constants for projection plans */
#define WT_PROJ_KEY 'k' /* Go to key in cursor <arg> */
#define WT_PROJ_NEXT 'n' /* Process the next item (<arg> repeats) */
#define WT_PROJ_REUSE 'r' /* Reuse the previous item (<arg> repeats) */
#define WT_PROJ_SKIP 's' /* Skip a column in the cursor (<arg> repeats) */
#define WT_PROJ_VALUE 'v' /* Go to the value in cursor <arg> */
struct __wt_colgroup {
const char *name; /* Logical name */
const char *source; /* Underlying data source */
const char *config; /* Configuration string */
WT_CONFIG_ITEM colconf; /* List of columns from config */
};
struct __wt_index {
const char *name; /* Logical name */
const char *source; /* Underlying data source */
const char *config; /* Configuration string */
WT_CONFIG_ITEM colconf; /* List of columns from config */
WT_EXTRACTOR *extractor; /* Custom key extractor */
int extractor_owned; /* Extractor is owned by this index */
const char *key_format; /* Key format */
const char *key_plan; /* Key projection plan */
const char *value_plan; /* Value projection plan */
const char *idxkey_format; /* Index key format (hides primary) */
const char *exkey_format; /* Key format for custom extractors */
};
/*
* WT_TABLE --
* Handle for a logical table. A table consists of one or more column
* groups, each of which holds some set of columns all sharing a primary
* key; and zero or more indices, each of which holds some set of columns
* in an index key that can be used to reconstruct the primary key.
*/
struct __wt_table {
const char *name, *config, *plan;
const char *key_format, *value_format;
WT_CONFIG_ITEM cgconf, colconf;
WT_COLGROUP **cgroups;
WT_INDEX **indices;
size_t idx_alloc;
TAILQ_ENTRY(__wt_table) q;
int cg_complete, idx_complete, is_simple;
u_int ncolgroups, nindices, nkey_columns;
uint32_t refcnt; /* Number of open cursors */
uint32_t schema_gen; /* Cached schema generation number */
};
/*
* Tables without explicit column groups have a single default column group
* containing all of the columns.
*/
#define WT_COLGROUPS(t) WT_MAX((t)->ncolgroups, 1)
/*
* WT_WITH_LOCK --
* Acquire a lock, perform an operation, drop the lock.
*/
#define WT_WITH_LOCK(session, lock, flag, op) do { \
if (F_ISSET(session, (flag))) { \
op; \
} else { \
__wt_spin_lock(session, (lock)); \
F_SET(session, (flag)); \
op; \
F_CLR(session, (flag)); \
__wt_spin_unlock(session, (lock)); \
} \
} while (0)
/*
* WT_WITH_DHANDLE_LOCK --
* Acquire the data handle list lock, perform an operation, drop the lock.
*/
#define WT_WITH_DHANDLE_LOCK(session, op) \
WT_WITH_LOCK(session, \
&S2C(session)->dhandle_lock, WT_SESSION_HANDLE_LIST_LOCKED, op)
/*
* WT_WITH_SCHEMA_LOCK --
* Acquire the schema lock, perform an operation, drop the lock.
* Check that we are not already holding some other lock: the schema lock
* must be taken first.
*/
#define WT_WITH_SCHEMA_LOCK(session, op) do { \
WT_ASSERT(session, \
F_ISSET(session, WT_SESSION_SCHEMA_LOCKED) || \
!F_ISSET(session, WT_SESSION_HANDLE_LIST_LOCKED | \
WT_SESSION_NO_SCHEMA_LOCK | WT_SESSION_TABLE_LOCKED)); \
WT_WITH_LOCK(session, \
&S2C(session)->schema_lock, WT_SESSION_SCHEMA_LOCKED, op); \
} while (0)
/*
* WT_WITHOUT_LOCKS --
* Drop the schema lock and/or the handle list lock, perform an operation,
* re-acquire the lock(s).
*/
#define WT_WITHOUT_LOCKS(session, op) do { \
WT_CONNECTION_IMPL *__conn = S2C(session); \
int __handle_locked = \
F_ISSET(session, WT_SESSION_HANDLE_LIST_LOCKED);\
int __schema_locked = \
F_ISSET(session, WT_SESSION_SCHEMA_LOCKED); \
if (__handle_locked) { \
F_CLR(session, WT_SESSION_HANDLE_LIST_LOCKED); \
__wt_spin_unlock(session, &__conn->dhandle_lock);\
} \
if (__schema_locked) { \
F_CLR(session, WT_SESSION_SCHEMA_LOCKED); \
__wt_spin_unlock(session, &__conn->schema_lock);\
} \
op; \
if (__schema_locked) { \
__wt_spin_lock(session, &__conn->schema_lock); \
F_SET(session, WT_SESSION_SCHEMA_LOCKED); \
} \
if (__handle_locked) { \
__wt_spin_lock(session, &__conn->dhandle_lock); \
F_SET(session, WT_SESSION_HANDLE_LIST_LOCKED); \
} \
} while (0)
/*
* WT_WITH_TABLE_LOCK --
* Acquire the table lock, perform an operation, drop the lock.
*/
#define WT_WITH_TABLE_LOCK(session, op) do { \
WT_ASSERT(session, \
F_ISSET(session, WT_SESSION_TABLE_LOCKED) || \
!F_ISSET(session, WT_SESSION_HANDLE_LIST_LOCKED)); \
WT_WITH_LOCK(session, \
&S2C(session)->table_lock, WT_SESSION_TABLE_LOCKED, op); \
} while (0)
|
