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
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 1996, 2015 Oracle and/or its affiliates. All rights reserved.
*
* $Id$
*/
#ifndef _DB_LOG_VERIFY_H_
#define _DB_LOG_VERIFY_H_
#include "db_config.h"
#include "db_int.h"
/*
* Log verification handle, such a handle is shared among all verification
* functions during one verification process.
*/
struct __db_log_verify_info {
DB_ENV *dbenv; /* The database environment. */
DB *txninfo; /* (txnid, __txn_verify_info) map. */
DB *ckps; /* (ckp lrid, __ckpinfo) map. */
DB *fileregs; /* (file-uid, __file_reg_info) map. */
DB *fnameuid; /* (fname, fuid), secondary db of fileregs. */
/* (dbreg-id, __file_reg_info) map, NOT the sec db for fileregs. */
DB *dbregids;
DB *pgtxn; /* (fileid-pageno, txnid) map. */
DB *txnpg; /* (txnid, fileid-pageno), sec db of pgtxn. */
/* lsn, (time-stamp, logtype(txn_regop or txn_ckp)) map. */
DB *lsntime;
/* Secondary db of lsntime, use timestamp as secindex. */
DB *timelsn;
/* Time range database, (u_int32_t, __lv_txnrange) db. */
DB *txnrngs;
/* Store abort txn (lsn, txnid) map. */
DB *txnaborts;
DB_LSN last_lsn; /* Lsn of last log record we verified. */
/* The number of active, abort, commit and prepared txns. */
u_int32_t ntxn_active, ntxn_abort, ntxn_commit, ntxn_prep;
u_int32_t nckp; /* The number of checkpoint log records. */
/*
* Target database file unique id. Set if only verify log records
* of a database.
*/
u_int8_t target_dbid[DB_FILE_ID_LEN];
u_int32_t non_txnup_cnt;/* Number of non-txnal log records. */
u_int32_t unknown_logrec_cnt;/* Number of unknown log record. */
u_int32_t external_logrec_cnt;/* Number of external log record. */
/*
* (Log type, number of record) map. typeids are continuous
* integers, 256 is a big enough number.
*/
u_int32_t lrtypes[256];
u_int32_t aborted_txnid;/* The last aborted txnid. */
DB_LSN aborted_txnlsn; /* Last aborted txn's last log. */
DB_LSN valid_lsn; /* When reach this log,unset DB_LOG_VERIFY_PARTIAL. */
char *logtype_names[256];/* The type name string of each type of log.*/
const DB_LOG_VERIFY_CONFIG *lv_config;
DB_THREAD_INFO *ip;
u_int32_t flags; /* The result of the verification. */
};
/* Transaction information. */
struct __txn_verify_info {
#define TXN_VERIFY_INFO_FIXSIZE (4 * sizeof(DB_LSN) + 9 * sizeof(u_int32_t))
#define TXN_VERIFY_INFO_TOTSIZE(s) \
(TXN_VERIFY_INFO_FIXSIZE + (s).num_recycle * sizeof(DB_LSN) + \
__lv_dbt_arrsz((s).fileups, (s).filenum) + \
sizeof(int32_t) * (s).filenum)
u_int32_t txnid; /* The key, also stored in data here. */
u_int32_t ptxnid; /* The parent txn id. */
DB_LSN first_lsn; /* Lsn of the first log record of this txn. */
DB_LSN last_lsn; /* Last lsn of the txn. */
DB_LSN prep_lsn; /* txn_prepare's lsn.*/
DB_LSN cur_lsn; /* The lsn of the latest db op of this txn. */
u_int32_t num_recycle; /* The number of recycle lsns. */
u_int32_t filenum; /* The number of files updated. */
#define TXN_STAT_ACTIVE 0
#define TXN_STAT_ABORT 1
#define TXN_STAT_COMMIT 2
#define TXN_STAT_PREPARE 3
u_int32_t status; /* Txn status */
/* The number of active, abort and commit children. */
u_int32_t nchild_active;
u_int32_t nchild_abort;
u_int32_t nchild_commit;
u_int32_t flags; /* Copied from the DB_TXN::flags member. */
DB_LSN *recycle_lsns; /* The array of txn_recycle records' lsns. */
/* The array of file unique ids of files updated by this txn. */
DBT *fileups;
int32_t *dbregid;/* The array of dbreg file ids updated by this txn. */
};
/* Database file information. */
struct __lv_filereg_info {
#define FILE_REG_INFO_FIXSIZE (sizeof(u_int32_t))
#define FILE_REG_INFO_TOTSIZE(s) (FILE_REG_INFO_FIXSIZE + (s).fileid.size + \
sizeof((s).fileid.size) + sizeof(int32_t) * (s).regcnt + \
strlen((s).fname) + 1)
u_int32_t regcnt; /* The number of dbregids for this file-uid. */
int32_t *dbregids;
DBT fileid; /* The file unique id. */
char *fname; /* Database file name. */
};
/* Database file dbreg_register information. */
struct __lv_filelife {
int32_t dbregid; /* The primary key. */
DBTYPE dbtype; /* The database type. */
u_int32_t lifetime; /* DBREG_CHKPNT, DBREG_CLOSE, DBREG_OPEN, DBREG_XCHKPNT, DBREG_XOPEN */
db_pgno_t meta_pgno; /* The meta_pgno; */
u_int8_t fileid[DB_FILE_ID_LEN];
DB_LSN lsn; /* The lsn of log updating lifetime. */
};
/* Checkpoint information. */
struct __lv_ckp_info {
int32_t timestamp;
DB_LSN lsn, ckplsn; /* Lsn member is the primary key. */
};
/*
* General information from log records which have timestamps.
* We use it to do time range verifications. Such information is
* acquired when backward-playing the logs before verification.
*/
struct __lv_timestamp_info {
DB_LSN lsn; /* The primary key. */
int32_t timestamp; /* The secondary key. */
/*
* The log types containing a time stamp, so far only txn_ckp
* and txn_regop types.
*/
u_int32_t logtype;
};
/*
* Transaction ranges. Such information is acquired when backward-playing the
* logs before verification. Can be used to find aborted txns.
*/
struct __lv_txnrange {
/*
* Transaction ID, the primary key. The db storing records of this
* type should allow dup since txnids maybe reused.
*/
u_int32_t txnid;
/*
* The parent txn id, ptxnid is the parent of txnid
* during [begin, end].
*/
u_int32_t ptxnid;
/*
* The first and last lsn, end is used to sort dup data because it's
* seen prior to begin in a backward playback, and [begin, end]
* intervals won't overlap.
*/
DB_LSN begin, end;
int32_t when_commit;/* The time of the commit, 0 if aborted. */
};
/* Parameter types for __iterate_txninfo function. */
struct __add_recycle_params {
u_int32_t min, max;/* The recycled txnid range. */
/* The array of txn info to update into db. */
VRFY_TXN_INFO **ti2u;
u_int32_t ti2ui, ti2ul;/* The effective length and array length. */
DB_LSN recycle_lsn;
};
struct __ckp_verify_params {
DB_LSN lsn, ckp_lsn;
ENV *env;
};
/* Helper macros. */
#define LOGTYPE_NAME(lvh, type) (lvh->logtype_names[type] == NULL ? \
NULL : lvh->logtype_names[type] + 3)
#define NUMCMP(i1, i2) ((i1) > (i2) ? 1 : ((i1) < (i2) ? -1 : 0))
#define INVAL_DBREGID -1
/*
* During recovery, DBREG_CHKPNT and DBREG_XCHKPNT can be seen as open,
* and it's followed by a DBREG_RCLOSE or DBREG_CLOSE.
*/
#define IS_DBREG_OPEN(opcode) (opcode == DBREG_OPEN || opcode == \
DBREG_PREOPEN || opcode == DBREG_REOPEN || opcode == DBREG_CHKPNT \
|| opcode == DBREG_XCHKPNT || opcode == DBREG_XOPEN || \
opcode == DBREG_XREOPEN)
#define IS_DBREG_CLOSE(opcode) (opcode == DBREG_CLOSE || opcode == DBREG_RCLOSE)
#define IS_LOG_VRFY_SUPPORTED(version) ((version) == DB_LOGVERSION)
#endif /* !_DB_LOG_VERIFY_H_*/
|
