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
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 1996-2002
* Sleepycat Software. All rights reserved.
*
* Id: db_am.h,v 11.61 2002/08/08 03:20:46 bostic Exp
*/
#ifndef _DB_AM_H_
#define _DB_AM_H_
/*
* IS_AUTO_COMMIT --
* Test for local auto-commit flag or global flag with no local DbTxn
* handle.
*/
#define IS_AUTO_COMMIT(dbenv, txn, flags) \
(LF_ISSET(DB_AUTO_COMMIT) || \
((txn) == NULL && F_ISSET((dbenv), DB_ENV_AUTO_COMMIT)))
/* DB recovery operation codes. */
#define DB_ADD_DUP 1
#define DB_REM_DUP 2
#define DB_ADD_BIG 3
#define DB_REM_BIG 4
#define DB_ADD_PAGE 5
#define DB_REM_PAGE 6
/*
* Standard initialization and shutdown macros for all recovery functions.
*/
#define REC_INTRO(func, inc_count) { \
argp = NULL; \
dbc = NULL; \
file_dbp = NULL; \
mpf = NULL; \
if ((ret = func(dbenv, dbtp->data, &argp)) != 0) \
goto out; \
if ((ret = __dbreg_id_to_db(dbenv, argp->txnid, \
&file_dbp, argp->fileid, inc_count)) != 0) { \
if (ret == DB_DELETED) { \
ret = 0; \
goto done; \
} \
goto out; \
} \
if ((ret = file_dbp->cursor(file_dbp, NULL, &dbc, 0)) != 0) \
goto out; \
F_SET(dbc, DBC_RECOVER); \
mpf = file_dbp->mpf; \
}
#define REC_CLOSE { \
int __t_ret; \
if (argp != NULL) \
__os_free(dbenv, argp); \
if (dbc != NULL && \
(__t_ret = dbc->c_close(dbc)) != 0 && ret == 0) \
ret = __t_ret; \
return (ret); \
}
/*
* No-op versions of the same macros.
*/
#define REC_NOOP_INTRO(func) { \
argp = NULL; \
if ((ret = func(dbenv, dbtp->data, &argp)) != 0) \
return (ret); \
}
#define REC_NOOP_CLOSE \
if (argp != NULL) \
__os_free(dbenv, argp); \
return (ret); \
/*
* Standard debugging macro for all recovery functions.
*/
#ifdef DEBUG_RECOVER
#define REC_PRINT(func) \
(void)func(dbenv, dbtp, lsnp, op, info);
#else
#define REC_PRINT(func)
#endif
/*
* Actions to __db_lget
*/
#define LCK_ALWAYS 1 /* Lock even for off page dup cursors */
#define LCK_COUPLE 2 /* Lock Couple */
#define LCK_COUPLE_ALWAYS 3 /* Lock Couple even in txn. */
#define LCK_DOWNGRADE 4 /* Downgrade the lock. (internal) */
#define LCK_ROLLBACK 5 /* Lock even if in rollback */
/*
* If doing transactions we have to hold the locks associated with a data item
* from a page for the entire transaction. However, we don't have to hold the
* locks associated with walking the tree. Distinguish between the two so that
* we don't tie up the internal pages of the tree longer than necessary.
*/
#define __LPUT(dbc, lock) \
(LOCK_ISSET(lock) ? \
(dbc)->dbp->dbenv->lock_put((dbc)->dbp->dbenv, &(lock)) : 0)
/*
* __TLPUT -- transactional lock put
* If the lock is valid then
* If we are not in a transaction put the lock.
* Else if the cursor is doing dirty reads and this was a read then
* put the lock.
* Else if the db is supporting dirty reads and this is a write then
* downgrade it.
* Else do nothing.
*/
#define __TLPUT(dbc, lock) \
(LOCK_ISSET(lock) ? __db_lput(dbc, &(lock)) : 0)
typedef struct {
DBC *dbc;
int count;
} db_trunc_param;
#include "dbinc/db_dispatch.h"
#include "dbinc_auto/db_auto.h"
#include "dbinc_auto/crdel_auto.h"
#include "dbinc_auto/db_ext.h"
#endif /* !_DB_AM_H_ */
|
