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
|
/*-
* Copyright (c) 2014-2020 MongoDB, Inc.
* Copyright (c) 2008-2014 WiredTiger, Inc.
* All rights reserved.
*
* See the file LICENSE for redistribution information.
*/
#define WT_COMPAT_MSG_PREFIX "Version incompatibility detected: "
#define WT_DEBUG_POINT ((void *)(uintptr_t)0xdeadbeef)
#define WT_DEBUG_BYTE (0xab)
/* In DIAGNOSTIC mode, yield in places where we want to encourage races. */
#ifdef HAVE_DIAGNOSTIC
#define WT_DIAGNOSTIC_YIELD \
do { \
__wt_yield(); \
} while (0)
#else
#define WT_DIAGNOSTIC_YIELD
#endif
#define __wt_err(session, error, ...) __wt_err_func(session, error, __func__, __LINE__, __VA_ARGS__)
#define __wt_errx(session, ...) __wt_errx_func(session, __func__, __LINE__, __VA_ARGS__)
#define __wt_panic(session, error, ...) \
__wt_panic_func(session, error, __func__, __LINE__, __VA_ARGS__)
#define __wt_set_return(session, error) __wt_set_return_func(session, __func__, __LINE__, error)
/* Set "ret" and branch-to-err-label tests. */
#define WT_ERR(a) \
do { \
if ((ret = (a)) != 0) \
goto err; \
} while (0)
#define WT_ERR_MSG(session, v, ...) \
do { \
ret = (v); \
__wt_err(session, ret, __VA_ARGS__); \
goto err; \
} while (0)
#define WT_ERR_TEST(a, v, keep) \
do { \
if (a) { \
ret = (v); \
goto err; \
} else if (!(keep)) \
ret = 0; \
} while (0)
#define WT_ERR_ERROR_OK(a, e, keep) WT_ERR_TEST((ret = (a)) != 0 && ret != (e), ret, keep)
#define WT_ERR_NOTFOUND_OK(a, keep) WT_ERR_ERROR_OK(a, WT_NOTFOUND, keep)
/* Return WT_PANIC regardless of earlier return codes. */
#define WT_ERR_PANIC(session, v, ...) WT_ERR(__wt_panic(session, v, __VA_ARGS__))
/* Return tests. */
#define WT_RET(a) \
do { \
int __ret; \
if ((__ret = (a)) != 0) \
return (__ret); \
} while (0)
#define WT_RET_TRACK(a) \
do { \
int __ret; \
if ((__ret = (a)) != 0) { \
WT_TRACK_OP_END(session); \
return (__ret); \
} \
} while (0)
#define WT_RET_MSG(session, v, ...) \
do { \
int __ret = (v); \
__wt_err(session, __ret, __VA_ARGS__); \
return (__ret); \
} while (0)
#define WT_RET_TEST(a, v) \
do { \
if (a) \
return (v); \
} while (0)
#define WT_RET_ERROR_OK(a, e) \
do { \
int __ret = (a); \
WT_RET_TEST(__ret != 0 && __ret != (e), __ret); \
} while (0)
#define WT_RET_BUSY_OK(a) WT_RET_ERROR_OK(a, EBUSY)
#define WT_RET_NOTFOUND_OK(a) WT_RET_ERROR_OK(a, WT_NOTFOUND)
/* Set "ret" if not already set. */
#define WT_TRET(a) \
do { \
int __ret; \
if ((__ret = (a)) != 0 && (__ret == WT_PANIC || ret == 0 || ret == WT_DUPLICATE_KEY || \
ret == WT_NOTFOUND || ret == WT_RESTART)) \
ret = __ret; \
} while (0)
#define WT_TRET_ERROR_OK(a, e) \
do { \
int __ret; \
if ((__ret = (a)) != 0 && __ret != (e) && \
(__ret == WT_PANIC || ret == 0 || ret == WT_DUPLICATE_KEY || ret == WT_NOTFOUND || \
ret == WT_RESTART)) \
ret = __ret; \
} while (0)
#define WT_TRET_BUSY_OK(a) WT_TRET_ERROR_OK(a, EBUSY)
#define WT_TRET_NOTFOUND_OK(a) WT_TRET_ERROR_OK(a, WT_NOTFOUND)
/* Return WT_PANIC regardless of earlier return codes. */
#define WT_RET_PANIC(session, v, ...) return (__wt_panic(session, v, __VA_ARGS__))
/* Called on unexpected code path: locate the failure. */
#define __wt_illegal_value(session, v) \
__wt_panic(session, EINVAL, "%s: 0x%" PRIxMAX, \
"encountered an illegal file format or internal value", (uintmax_t)(v))
/*
* WT_ERR_ASSERT, WT_RET_ASSERT, WT_ASSERT
* Assert an expression, aborting in diagnostic mode and otherwise exiting
* the function with an error. WT_ASSERT is deprecated, and should be used only
* where required for performance.
*/
#ifdef HAVE_DIAGNOSTIC
#define WT_ASSERT(session, exp) \
do { \
if (!(exp)) { \
__wt_errx(session, "%s", #exp); \
__wt_abort(session); \
} \
} while (0)
#define WT_ERR_ASSERT(session, exp, v, ...) \
do { \
if (!(exp)) { \
__wt_err(session, v, __VA_ARGS__); \
__wt_abort(session); \
} \
} while (0)
#define WT_RET_ASSERT(session, exp, v, ...) \
do { \
if (!(exp)) { \
__wt_err(session, v, __VA_ARGS__); \
__wt_abort(session); \
} \
} while (0)
#define WT_RET_PANIC_ASSERT(session, exp, v, ...) \
do { \
if (!(exp)) { \
__wt_err(session, v, __VA_ARGS__); \
__wt_abort(session); \
} \
} while (0)
#else
#define WT_ASSERT(session, exp) WT_UNUSED(session)
#define WT_ERR_ASSERT(session, exp, v, ...) \
do { \
if (!(exp)) \
WT_ERR_MSG(session, v, __VA_ARGS__); \
} while (0)
#define WT_RET_ASSERT(session, exp, v, ...) \
do { \
if (!(exp)) \
WT_RET_MSG(session, v, __VA_ARGS__); \
} while (0)
#define WT_RET_PANIC_ASSERT(session, exp, v, ...) \
do { \
if (!(exp)) \
WT_RET_PANIC(session, v, __VA_ARGS__); \
} while (0)
#endif
/* Verbose messages. */
#define WT_VERBOSE_ISSET(session, flag) (FLD_ISSET(S2C(session)->verbose, flag))
/*
* __wt_verbose --
* Display a verbose message. Not an inlined function because you can't inline functions taking
* variadic arguments and we don't want to make a function call in production systems just to
* find out a verbose flag isn't set. The macro must take a format string and at least one
* additional argument, there's no portable way to remove the comma before an empty __VA_ARGS__
* value.
*/
#define __wt_verbose(session, flag, fmt, ...) \
do { \
if (WT_VERBOSE_ISSET(session, flag)) \
__wt_verbose_worker(session, "[" #flag "] " fmt, __VA_ARGS__); \
} while (0)
|
