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
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 2000, 2015 Oracle and/or its affiliates. All rights reserved.
*
* $Id$
*/
#include "db_config.h"
#include "db_int.h"
#include "dbinc/db_page.h"
#include "dbinc/db_am.h"
#include "dbinc/mp.h"
#include "dbinc/partition.h"
#include "dbinc/qam.h"
static int __env_lsn_reset __P((ENV *, DB_THREAD_INFO *, const char *, int));
/*
* __env_lsn_reset_pp --
* ENV->lsn_reset pre/post processing.
*
* PUBLIC: int __env_lsn_reset_pp __P((DB_ENV *, const char *, u_int32_t));
*/
int
__env_lsn_reset_pp(dbenv, name, flags)
DB_ENV *dbenv;
const char *name;
u_int32_t flags;
{
DB_THREAD_INFO *ip;
ENV *env;
int ret;
env = dbenv->env;
ENV_ILLEGAL_BEFORE_OPEN(env, "DB_ENV->lsn_reset");
/*
* !!!
* The actual argument checking is simple, do it inline, outside of
* the replication block.
*/
if (flags != 0 && flags != DB_ENCRYPT)
return (__db_ferr(env, "DB_ENV->lsn_reset", 0));
ENV_ENTER(env, ip);
REPLICATION_WRAP(env,
(__env_lsn_reset(env, ip, name, LF_ISSET(DB_ENCRYPT) ? 1 : 0)),
1, ret);
ENV_LEAVE(env, ip);
return (ret);
}
/*
* __env_lsn_reset --
* Reset the LSNs for every page in the file.
*/
static int
__env_lsn_reset(env, ip, name, encrypted)
ENV *env;
DB_THREAD_INFO *ip;
const char *name;
int encrypted;
{
DB *dbp;
int t_ret, ret;
/* Create the DB object. */
if ((ret = __db_create_internal(&dbp, env, 0)) != 0)
return (ret);
/* If configured with a password, the databases are encrypted. */
if (encrypted && (ret = __db_set_flags(dbp, DB_ENCRYPT)) != 0)
goto err;
/*
* Open the DB file.
*
* !!!
* Note DB_RDWRMASTER flag, we need to open the master database file
* for writing in this case.
*/
if ((ret = __db_open(dbp, ip, NULL,
name, NULL, DB_UNKNOWN, DB_RDWRMASTER, 0, PGNO_BASE_MD)) != 0) {
__db_err(env, ret, "%s", name);
goto err;
}
ret = __db_lsn_reset(dbp->mpf, ip);
#ifdef HAVE_PARTITION
if (ret == 0 && DB_IS_PARTITIONED(dbp))
ret = __part_lsn_reset(dbp, ip);
else
#endif
if (ret == 0 && dbp->type == DB_QUEUE)
#ifdef HAVE_QUEUE
ret = __qam_lsn_reset(dbp, ip);
#else
ret = __db_no_queue_am(env);
#endif
err: if ((t_ret = __db_close(dbp, NULL, 0)) != 0 && ret == 0)
ret = t_ret;
return (ret);
}
/*
* __db_lsn_reset -- reset the lsn for a db mpool handle.
* PUBLIC: int __db_lsn_reset __P((DB_MPOOLFILE *, DB_THREAD_INFO *));
*/
int
__db_lsn_reset(mpf, ip)
DB_MPOOLFILE *mpf;
DB_THREAD_INFO *ip;
{
PAGE *pagep;
db_pgno_t pgno;
int ret;
/* Reset the LSN on every page of the database file. */
for (pgno = 0;
(ret = __memp_fget(mpf,
&pgno, ip, NULL, DB_MPOOL_DIRTY, &pagep)) == 0;
++pgno) {
LSN_NOT_LOGGED(pagep->lsn);
if ((ret = __memp_fput(mpf,
ip, pagep, DB_PRIORITY_UNCHANGED)) != 0)
break;
}
if (ret == DB_PAGE_NOTFOUND)
ret = 0;
return (ret);
}
|
