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
|
/*-
* Copyright (c) 2008-2014 WiredTiger, Inc.
* All rights reserved.
*
* See the file LICENSE for redistribution information.
*/
/* Standard entry points to the API: declares/initializes local variables. */
#define API_SESSION_INIT(s, h, n, cur, dh) \
WT_DATA_HANDLE *__olddh = (s)->dhandle; \
const char *__oldname = (s)->name; \
(s)->cursor = (cur); \
(s)->dhandle = (dh); \
(s)->name = #h "." #n;
#define API_CALL_NOCONF(s, h, n, cur, dh) do { \
API_SESSION_INIT(s, h, n, cur, dh); \
WT_ERR(F_ISSET(S2C(s), WT_CONN_PANIC) ? __wt_panic(s) : 0); \
WT_ERR(__wt_verbose((s), WT_VERB_API, "CALL: " #h ":" #n))
#define API_CALL(s, h, n, cur, dh, config, cfg) do { \
const char *cfg[] = \
{ WT_CONFIG_BASE(s, h##_##n), config, NULL }; \
API_SESSION_INIT(s, h, n, cur, dh); \
WT_ERR(F_ISSET(S2C(s), WT_CONN_PANIC) ? __wt_panic(s) : 0); \
WT_ERR(((config) != NULL) ? \
__wt_config_check((s), \
WT_CONFIG_REF(session, h##_##n), (config), 0) : 0); \
WT_ERR(__wt_verbose((s), WT_VERB_API, "CALL: " #h ":" #n))
#define API_END(s, ret) \
if ((s) != NULL) { \
(s)->dhandle = __olddh; \
(s)->name = __oldname; \
if (F_ISSET(&(s)->txn, TXN_RUNNING) && \
(ret) != 0 && \
(ret) != WT_NOTFOUND && \
(ret) != WT_DUPLICATE_KEY) \
F_SET(&(s)->txn, TXN_ERROR); \
} \
} while (0)
/* An API call wrapped in a transaction if necessary. */
#define TXN_API_CALL(s, h, n, cur, bt, config, cfg) do { \
int __autotxn = 0; \
API_CALL(s, h, n, bt, cur, config, cfg); \
__autotxn = !F_ISSET(&(s)->txn, TXN_AUTOCOMMIT | TXN_RUNNING); \
if (__autotxn) \
F_SET(&(s)->txn, TXN_AUTOCOMMIT)
/* An API call wrapped in a transaction if necessary. */
#define TXN_API_CALL_NOCONF(s, h, n, cur, bt) do { \
int __autotxn = 0; \
API_CALL_NOCONF(s, h, n, cur, bt); \
__autotxn = !F_ISSET(&(s)->txn, TXN_AUTOCOMMIT | TXN_RUNNING); \
if (__autotxn) \
F_SET(&(s)->txn, TXN_AUTOCOMMIT)
/* End a transactional API call, optional retry on deadlock. */
#define TXN_API_END_RETRY(s, ret, retry) \
API_END(s, ret); \
if (__autotxn) { \
if (F_ISSET(&(s)->txn, TXN_AUTOCOMMIT)) \
F_CLR(&(s)->txn, TXN_AUTOCOMMIT); \
else if (ret == 0 && !F_ISSET(&(s)->txn, TXN_ERROR)) \
ret = __wt_txn_commit((s), NULL); \
else { \
WT_TRET(__wt_txn_rollback((s), NULL)); \
if ((ret == 0 || ret == WT_DEADLOCK) && \
(retry)) { \
ret = 0; \
continue; \
} \
WT_TRET(__wt_session_reset_cursors(s)); \
} \
} \
break; \
} while (ret == 0)
/* End a transactional API call, retry on deadlock. */
#define TXN_API_END(s, ret) TXN_API_END_RETRY(s, ret, 1)
/*
* In almost all cases, API_END is returning immediately, make it simple.
* If a session or connection method is about to return WT_NOTFOUND (some
* underlying object was not found), map it to ENOENT, only cursor methods
* return WT_NOTFOUND.
*/
#define API_END_RET(s, ret) \
API_END(s, ret); \
return (ret)
#define API_END_RET_NOTFOUND_MAP(s, ret) \
API_END(s, ret); \
return ((ret) == WT_NOTFOUND ? ENOENT : (ret))
#define CONNECTION_API_CALL(conn, s, n, config, cfg) \
s = (conn)->default_session; \
API_CALL(s, connection, n, NULL, NULL, config, cfg)
#define CONNECTION_API_CALL_NOCONF(conn, s, n) \
s = (conn)->default_session; \
API_CALL_NOCONF(s, connection, n, NULL, NULL)
#define SESSION_API_CALL(s, n, config, cfg) \
API_CALL(s, session, n, NULL, NULL, config, cfg)
#define SESSION_API_CALL_NO_CONF(s, n) \
API_CALL_NOCONF(s, session, n, NULL, NULL)
#define SESSION_TXN_API_CALL(s, n, config, cfg) \
TXN_API_CALL(s, session, n, NULL, NULL, config, cfg)
#define CURSOR_API_CALL(cur, s, n, bt) \
(s) = (WT_SESSION_IMPL *)(cur)->session; \
API_CALL_NOCONF(s, cursor, n, cur, \
((bt) == NULL) ? NULL : ((WT_BTREE *)(bt))->dhandle)
#define CURSOR_UPDATE_API_CALL(cur, s, n, bt) \
(s) = (WT_SESSION_IMPL *)(cur)->session; \
TXN_API_CALL_NOCONF(s, cursor, n, cur, \
((bt) == NULL) ? NULL : ((WT_BTREE *)(bt))->dhandle)
#define CURSOR_UPDATE_API_END(s, ret) \
TXN_API_END(s, ret)
#define ASYNCOP_API_CALL(conn, s, n) \
s = (conn)->default_session; \
API_CALL_NOCONF(s, asyncop, n, NULL, NULL)
|
