#include "db_config.h"
#include "db_int.h"
#include "dbinc/db_page.h"
#include "dbinc/fop.h"
#include "dbinc/btree.h"
#include "dbinc/hash.h"
#include "dbinc/log.h"
#include "dbinc/mp.h"
#include "dbinc/qam.h"
#include "dbinc/txn.h"
#ifndef lint
static const char copyright[] =
"Copyright (c) 1996,2007 Oracle. All rights reserved.\n";
#endif
static int __db_log_corrupt __P((DB_ENV *, DB_LSN *));
static int __env_init_rec_42 __P((DB_ENV *));
static int __env_init_rec_43 __P((DB_ENV *));
static int __env_init_rec_46 __P((DB_ENV *));
static int __log_earliest __P((DB_ENV *, DB_LOGC *, int32_t *, DB_LSN *));
#ifndef HAVE_BREW
static double __lsn_diff __P((DB_LSN *, DB_LSN *, DB_LSN *, u_int32_t, int));
#endif
int
__db_apprec(dbenv, max_lsn, trunclsn, update, flags)
DB_ENV *dbenv;
DB_LSN *max_lsn, *trunclsn;
int update;
u_int32_t flags;
{
DBT data;
DB_LOGC *logc;
DB_LSN ckp_lsn, first_lsn, last_lsn, lowlsn, lsn, stop_lsn, tlsn;
DB_TXNHEAD *txninfo;
DB_TXNREGION *region;
REGENV *renv;
REGINFO *infop;
__txn_ckp_args *ckp_args;
time_t now, tlow;
double nfiles;
u_int32_t hi_txn, log_size, txnid;
int32_t low;
int have_rec, progress, ret, t_ret;
char *p, *pass;
char t1[CTIME_BUFLEN], t2[CTIME_BUFLEN], time_buf[CTIME_BUFLEN];
COMPQUIET(nfiles, (double)0.001);
logc = NULL;
ckp_args = NULL;
hi_txn = TXN_MAXIMUM;
txninfo = NULL;
pass = "initial";
ZERO_LSN(lsn);
log_size = ((LOG *)dbenv->lg_handle->reginfo.primary)->log_size;
if (update && REP_ON(dbenv)) {
infop = dbenv->reginfo;
renv = infop->primary;
(void)time(&renv->rep_timestamp);
}
F_SET(dbenv->lg_handle, DBLOG_RECOVER);
region = dbenv->tx_handle->reginfo.primary;
F_SET(region, TXN_IN_RECOVERY);
if ((ret = __log_cursor(dbenv, &logc)) != 0)
goto err;
ZERO_LSN(lowlsn);
if (max_lsn != NULL) {
if ((ret = __log_backup(dbenv, logc, max_lsn, &lowlsn,
CKPLSN_CMP)) != 0)
goto err;
} else if (dbenv->tx_timestamp != 0) {
if ((ret = __log_earliest(dbenv, logc, &low, &lowlsn)) != 0)
goto err;
if ((int32_t)dbenv->tx_timestamp < low) {
t1[sizeof(t1) - 1] = '\0';
(void)strncpy(t1, __db_ctime(
&dbenv->tx_timestamp, time_buf), sizeof(t1) - 1);
if ((p = strchr(t1, '\n')) != NULL)
*p = '\0';
t2[sizeof(t2) - 1] = '\0';
tlow = (time_t)low;
(void)strncpy(t2, __db_ctime(
&tlow, time_buf), sizeof(t2) - 1);
if ((p = strchr(t2, '\n')) != NULL)
*p = '\0';
__db_errx(dbenv,
"Invalid recovery timestamp %s; earliest time is %s",
t1, t2);
ret = EINVAL;
goto err;
}
}
#ifdef UMRW
ZERO_LSN(last_lsn);
#endif
memset(&data, 0, sizeof(data));
if ((ret = __logc_get(logc, &last_lsn, &data, DB_LAST)) != 0) {
if (ret == DB_NOTFOUND)
ret = 0;
else
__db_errx(dbenv, "Last log record not found");
goto err;
}
do {
memcpy(&txnid,
(u_int8_t *)data.data + sizeof(u_int32_t), sizeof(txnid));
if (txnid != 0)
break;
} while ((ret = __logc_get(logc, &lsn, &data, DB_PREV)) == 0);
if (ret == DB_NOTFOUND)
ret = 0;
else if (ret != 0)
goto err;
hi_txn = txnid;
if ((ret = __logc_get(logc, &ckp_lsn, &data, DB_FIRST)) != 0) {
if (ret == DB_NOTFOUND)
ret = 0;
else
__db_errx(dbenv, "First log record not found");
goto err;
}
first_lsn = ckp_lsn;
have_rec = 1;
if (!LF_ISSET(DB_RECOVER_FATAL)) {
if ((ret = __txn_getckp(dbenv, &ckp_lsn)) == 0 &&
(ret = __logc_get(logc, &ckp_lsn, &data, DB_SET)) == 0) {
if ((ret = __txn_ckp_read(dbenv,
data.data, &ckp_args)) != 0) {
__db_errx(dbenv,
"Invalid checkpoint record at [%ld][%ld]",
(u_long)ckp_lsn.file,
(u_long)ckp_lsn.offset);
goto err;
}
first_lsn = ckp_args->ckp_lsn;
__os_free(dbenv, ckp_args);
have_rec = 0;
}
if ((dbenv->tx_timestamp != 0 || max_lsn != NULL) &&
LOG_COMPARE(&lowlsn, &first_lsn) < 0) {
DB_ASSERT(dbenv, have_rec == 0);
first_lsn = lowlsn;
}
}
if (!have_rec &&
(ret = __logc_get(logc, &first_lsn, &data, DB_SET)) != 0) {
__db_errx(dbenv, "Checkpoint LSN record [%ld][%ld] not found",
(u_long)first_lsn.file, (u_long)first_lsn.offset);
goto err;
}
#ifndef HAVE_BREW
if (dbenv->db_feedback != NULL) {
if (last_lsn.file == first_lsn.file)
nfiles = (double)
(last_lsn.offset - first_lsn.offset) / log_size;
else
nfiles = (double)(last_lsn.file - first_lsn.file) +
(double)((log_size - first_lsn.offset) +
last_lsn.offset) / log_size;
if (nfiles < 0.001)
nfiles = 0.001;
}
#endif
ret = 0;
if (hi_txn != 0) do {
memcpy(&txnid,
(u_int8_t *)data.data + sizeof(u_int32_t), sizeof(txnid));
if (txnid != 0)
break;
} while ((ret = __logc_get(logc, &lsn, &data, DB_NEXT)) == 0);
if (ret == DB_NOTFOUND) {
if (LOG_COMPARE(&lsn, &last_lsn) != 0)
ret = __db_log_corrupt(dbenv, &lsn);
else
ret = 0;
}
if (ret != 0 ||
(ret = __logc_get(logc, &first_lsn, &data, DB_SET)) != 0)
goto err;
if ((ret =
__db_txnlist_init(dbenv, txnid, hi_txn, max_lsn, &txninfo)) != 0)
goto err;
if ((ret = __env_openfiles(dbenv, logc,
txninfo, &data, &first_lsn, &last_lsn, nfiles, 1)) != 0)
goto err;
if (hi_txn == 0 && max_lsn == NULL)
goto done;
if (FLD_ISSET(dbenv->verbose, DB_VERB_RECOVERY))
__db_msg(dbenv, "Recovery starting from [%lu][%lu]",
(u_long)first_lsn.file, (u_long)first_lsn.offset);
pass = "backward";
for (ret = __logc_get(logc, &lsn, &data, DB_LAST);
ret == 0 && LOG_COMPARE(&lsn, &first_lsn) >= 0;
ret = __logc_get(logc, &lsn, &data, DB_PREV)) {
#ifdef HAVE_BREW
COMPQUIET(progress, 0);
#else
if (dbenv->db_feedback != NULL) {
progress = 34 + (int)(33 * (__lsn_diff(&first_lsn,
&last_lsn, &lsn, log_size, 0) / nfiles));
dbenv->db_feedback(dbenv, DB_RECOVER, progress);
}
#endif
tlsn = lsn;
ret = __db_dispatch(dbenv, dbenv->recover_dtab,
dbenv->recover_dtab_size, &data, &tlsn,
DB_TXN_BACKWARD_ROLL, txninfo);
if (ret != 0) {
if (ret != DB_TXN_CKP)
goto msgerr;
else
ret = 0;
}
}
if (ret == DB_NOTFOUND) {
if (LOG_COMPARE(&lsn, &first_lsn) > 0)
ret = __db_log_corrupt(dbenv, &lsn);
else
ret = 0;
}
if (ret != 0)
goto err;
pass = "forward";
stop_lsn = last_lsn;
if (max_lsn != NULL || dbenv->tx_timestamp != 0)
stop_lsn = ((DB_TXNHEAD *)txninfo)->maxlsn;
for (ret = __logc_get(logc, &lsn, &data, DB_NEXT);
ret == 0; ret = __logc_get(logc, &lsn, &data, DB_NEXT)) {
#ifndef HAVE_BREW
if (dbenv->db_feedback != NULL) {
progress = 67 + (int)(33 * (__lsn_diff(&first_lsn,
&last_lsn, &lsn, log_size, 1) / nfiles));
dbenv->db_feedback(dbenv, DB_RECOVER, progress);
}
#endif
tlsn = lsn;
ret = __db_dispatch(dbenv, dbenv->recover_dtab,
dbenv->recover_dtab_size, &data, &tlsn,
DB_TXN_FORWARD_ROLL, txninfo);
if (ret != 0) {
if (ret != DB_TXN_CKP)
goto msgerr;
else
ret = 0;
}
if (LOG_COMPARE(&lsn, &stop_lsn) >= 0)
break;
}
if (ret == DB_NOTFOUND)
ret = __db_log_corrupt(dbenv, &lsn);
if (ret != 0)
goto err;
#ifndef HAVE_FTRUNCATE
if ((ret = __db_do_the_limbo(dbenv, NULL, NULL, txninfo,
dbenv->tx_timestamp != 0 ? LIMBO_TIMESTAMP : LIMBO_RECOVER)) != 0)
goto err;
#endif
if (max_lsn == NULL)
region->last_txnid = ((DB_TXNHEAD *)txninfo)->maxid;
if (dbenv->tx_timestamp != 0) {
if (logc != NULL) {
if ((ret = __logc_close(logc)) != 0)
goto err;
logc = NULL;
}
if ((ret = __memp_sync_int(dbenv, NULL, 0,
DB_SYNC_CACHE | DB_SYNC_SUPPRESS_WRITE, NULL, NULL)) != 0)
goto err;
region->last_ckp = ((DB_TXNHEAD *)txninfo)->ckplsn;
if ((ret = __log_vtruncate(dbenv,
&((DB_TXNHEAD *)txninfo)->maxlsn,
&((DB_TXNHEAD *)txninfo)->ckplsn, trunclsn)) != 0)
goto err;
#ifndef HAVE_FTRUNCATE
if ((ret = __db_do_the_limbo(dbenv,
NULL, NULL, txninfo, LIMBO_COMPENSATE)) != 0)
goto err;
#endif
}
done:
if (!IS_REP_CLIENT(dbenv) && (ret = __txn_checkpoint(dbenv, 0, 0,
DB_CKP_INTERNAL | DB_FORCE)) != 0) {
if (max_lsn == NULL && ret == ENOSPC)
ret = 0;
else
goto err;
}
if (region->stat.st_nrestores == 0) {
if ((ret = __dbreg_close_files(dbenv, 0)) != 0)
goto err;
} else {
if ((ret = __dbreg_mark_restored(dbenv)) != 0)
goto err;
F_SET(dbenv->lg_handle, DBLOG_OPENFILES);
}
if (max_lsn != NULL) {
if (!IS_ZERO_LSN(((DB_TXNHEAD *)txninfo)->ckplsn))
region->last_ckp = ((DB_TXNHEAD *)txninfo)->ckplsn;
else if ((ret =
__txn_findlastckp(dbenv, ®ion->last_ckp, max_lsn)) != 0)
goto err;
if (logc != NULL && (ret = __logc_close(logc)) != 0)
goto err;
logc = NULL;
if ((ret = __log_vtruncate(dbenv,
max_lsn, &((DB_TXNHEAD *)txninfo)->ckplsn, trunclsn)) != 0)
goto err;
if ((ret = __log_cursor(dbenv, &logc)) != 0)
goto err;
if ((ret =
__logc_get(logc, &first_lsn, &data, DB_FIRST)) != 0) {
if (ret == DB_NOTFOUND)
ret = 0;
else
__db_errx(dbenv, "First log record not found");
goto err;
}
if ((ret = __txn_getckp(dbenv, &first_lsn)) == 0 &&
(ret = __logc_get(logc, &first_lsn, &data, DB_SET)) == 0) {
if ((ret = __txn_ckp_read(dbenv,
data.data, &ckp_args)) != 0) {
__db_errx(dbenv,
"Invalid checkpoint record at [%ld][%ld]",
(u_long)first_lsn.file,
(u_long)first_lsn.offset);
goto err;
}
first_lsn = ckp_args->ckp_lsn;
__os_free(dbenv, ckp_args);
}
if ((ret = __logc_get(logc, &first_lsn, &data, DB_SET)) != 0)
goto err;
if ((ret = __env_openfiles(dbenv, logc,
txninfo, &data, &first_lsn, max_lsn, nfiles, 1)) != 0)
goto err;
} else if (region->stat.st_nrestores == 0) {
if ((ret = __txn_reset(dbenv)) != 0)
goto err;
} else {
if ((ret = __txn_recycle_id(dbenv)) != 0)
goto err;
}
if (max_lsn == NULL && dbenv->tx_timestamp == 0) {
if (logc != NULL && (ret = __logc_close(logc)) != 0)
goto err;
logc = NULL;
if ((ret =
__log_current_lsn(dbenv, &last_lsn, NULL, NULL)) != 0)
goto err;
if ((ret = __log_vtruncate(dbenv,
&last_lsn, ®ion->last_ckp, NULL)) != 0)
goto err;
}
if (FLD_ISSET(dbenv->verbose, DB_VERB_RECOVERY)) {
(void)time(&now);
__db_msg(dbenv,
"Recovery complete at %.24s", __db_ctime(&now, time_buf));
__db_msg(dbenv, "%s %lx %s [%lu][%lu]",
"Maximum transaction ID",
(u_long)(txninfo == NULL ?
TXN_MINIMUM : ((DB_TXNHEAD *)txninfo)->maxid),
"Recovery checkpoint",
(u_long)region->last_ckp.file,
(u_long)region->last_ckp.offset);
}
if (0) {
msgerr: __db_errx(dbenv,
"Recovery function for LSN %lu %lu failed on %s pass",
(u_long)lsn.file, (u_long)lsn.offset, pass);
}
err: if (logc != NULL && (t_ret = __logc_close(logc)) != 0 && ret == 0)
ret = t_ret;
if (txninfo != NULL)
__db_txnlist_end(dbenv, txninfo);
dbenv->tx_timestamp = 0;
F_CLR(dbenv->lg_handle, DBLOG_RECOVER);
F_CLR(region, TXN_IN_RECOVERY);
return (ret);
}
#ifndef HAVE_BREW
static double
__lsn_diff(low, high, current, max, is_forward)
DB_LSN *low, *high, *current;
u_int32_t max;
int is_forward;
{
double nf;
if (is_forward) {
if (current->file == low->file)
nf = (double)(current->offset - low->offset) / max;
else if (current->offset < low->offset)
nf = (double)((current->file - low->file) - 1) +
(double)((max - low->offset) + current->offset) /
max;
else
nf = (double)(current->file - low->file) +
(double)(current->offset - low->offset) / max;
} else {
if (current->file == high->file)
nf = (double)(high->offset - current->offset) / max;
else if (current->offset > high->offset)
nf = (double)((high->file - current->file) - 1) +
(double)
((max - current->offset) + high->offset) / max;
else
nf = (double)(high->file - current->file) +
(double)(high->offset - current->offset) / max;
}
return (nf);
}
#endif
int
__log_backup(dbenv, logc, max_lsn, start_lsn, cmp)
DB_ENV *dbenv;
DB_LOGC *logc;
DB_LSN *max_lsn, *start_lsn;
u_int32_t cmp;
{
DB_LSN cmp_lsn, lsn;
DBT data;
__txn_ckp_args *ckp_args;
int lcmp, ret;
memset(&data, 0, sizeof(data));
ckp_args = NULL;
if (cmp != CKPLSN_CMP && cmp != LASTCKP_CMP)
return (EINVAL);
if ((ret = __txn_getckp(dbenv, &lsn)) != 0)
goto err;
while ((ret = __logc_get(logc, &lsn, &data, DB_SET)) == 0) {
if ((ret = __txn_ckp_read(dbenv, data.data, &ckp_args)) != 0)
return (ret);
if (cmp == CKPLSN_CMP) {
cmp_lsn = ckp_args->ckp_lsn;
lcmp = (LOG_COMPARE(&cmp_lsn, max_lsn) <= 0);
} else {
cmp_lsn = lsn;
lcmp = (LOG_COMPARE(&cmp_lsn, max_lsn) < 0);
}
if (lcmp) {
*start_lsn = cmp_lsn;
break;
}
lsn = ckp_args->last_ckp;
if (IS_ZERO_LSN(lsn)) {
ret = DB_NOTFOUND;
break;
}
__os_free(dbenv, ckp_args);
ckp_args = NULL;
}
if (ckp_args != NULL)
__os_free(dbenv, ckp_args);
err: if (IS_ZERO_LSN(*start_lsn) && cmp == CKPLSN_CMP &&
(ret == 0 || ret == DB_NOTFOUND))
ret = __logc_get(logc, start_lsn, &data, DB_FIRST);
return (ret);
}
static int
__log_earliest(dbenv, logc, lowtime, lowlsn)
DB_ENV *dbenv;
DB_LOGC *logc;
int32_t *lowtime;
DB_LSN *lowlsn;
{
DB_LSN first_lsn, lsn;
DBT data;
__txn_ckp_args *ckpargs;
u_int32_t rectype;
int cmp, ret;
memset(&data, 0, sizeof(data));
for (ret = __logc_get(logc, &first_lsn, &data, DB_FIRST);
ret == 0; ret = __logc_get(logc, &lsn, &data, DB_NEXT)) {
memcpy(&rectype, data.data, sizeof(rectype));
if (rectype != DB___txn_ckp)
continue;
if ((ret = __txn_ckp_read(dbenv, data.data, &ckpargs)) == 0) {
cmp = LOG_COMPARE(&ckpargs->ckp_lsn, &first_lsn);
*lowlsn = ckpargs->ckp_lsn;
*lowtime = ckpargs->timestamp;
__os_free(dbenv, ckpargs);
if (cmp >= 0)
break;
}
}
return (ret);
}
int
__env_openfiles(dbenv, logc, txninfo,
data, open_lsn, last_lsn, nfiles, in_recovery)
DB_ENV *dbenv;
DB_LOGC *logc;
void *txninfo;
DBT *data;
DB_LSN *open_lsn, *last_lsn;
int in_recovery;
double nfiles;
{
DB_LSN lsn, tlsn;
u_int32_t log_size;
int progress, ret;
log_size = ((LOG *)dbenv->lg_handle->reginfo.primary)->log_size;
lsn = *open_lsn;
for (;;) {
#ifdef HAVE_BREW
COMPQUIET(nfiles, (double)0.001);
COMPQUIET(progress, 0);
#else
if (in_recovery && dbenv->db_feedback != NULL) {
DB_ASSERT(dbenv, last_lsn != NULL);
progress = (int)(33 * (__lsn_diff(open_lsn,
last_lsn, &lsn, log_size, 1) / nfiles));
dbenv->db_feedback(dbenv, DB_RECOVER, progress);
}
#endif
tlsn = lsn;
ret = __db_dispatch(dbenv,
dbenv->recover_dtab, dbenv->recover_dtab_size, data, &tlsn,
in_recovery ? DB_TXN_OPENFILES : DB_TXN_POPENFILES,
txninfo);
if (ret != 0 && ret != DB_TXN_CKP) {
__db_errx(dbenv,
"Recovery function for LSN %lu %lu failed",
(u_long)lsn.file, (u_long)lsn.offset);
break;
}
if ((ret = __logc_get(logc, &lsn, data, DB_NEXT)) != 0) {
if (ret == DB_NOTFOUND) {
if (last_lsn != NULL &&
LOG_COMPARE(&lsn, last_lsn) != 0)
ret = __db_log_corrupt(dbenv, &lsn);
else
ret = 0;
}
break;
}
}
return (ret);
}
static int
__db_log_corrupt(dbenv, lsnp)
DB_ENV *dbenv;
DB_LSN *lsnp;
{
__db_errx(dbenv, "Log file corrupt at LSN: [%lu][%lu]",
(u_long)lsnp->file, (u_long)lsnp->offset);
return (EINVAL);
}
int
__env_init_rec(dbenv, version)
DB_ENV *dbenv;
u_int32_t version;
{
int ret;
if ((ret = __env_init_rec_46(dbenv)) != 0)
return (ret);
ret = 0;
switch (version) {
case DB_LOGVERSION_46:
case DB_LOGVERSION_45:
case DB_LOGVERSION_44:
break;
case DB_LOGVERSION_43:
ret = __env_init_rec_43(dbenv);
break;
case DB_LOGVERSION_42:
ret = __env_init_rec_42(dbenv);
break;
default:
__db_errx(dbenv, "Unknown version %lu", (u_long)version);
ret = EINVAL;
break;
}
return (ret);
}
static int
__env_init_rec_42(dbenv)
DB_ENV *dbenv;
{
int ret;
if ((ret = __db_add_recovery(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size, __db_relink_42_recover,
DB___db_relink_42)) != 0)
goto err;
if ((ret = __db_add_recovery(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size, __db_pg_alloc_42_recover,
DB___db_pg_alloc_42)) != 0)
goto err;
if ((ret = __db_add_recovery(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size, __db_pg_free_42_recover,
DB___db_pg_free_42)) != 0)
goto err;
if ((ret = __db_add_recovery(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size, __db_pg_freedata_42_recover,
DB___db_pg_freedata_42)) != 0)
goto err;
if ((ret = __db_add_recovery(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size, __ham_metagroup_42_recover,
DB___ham_metagroup_42)) != 0)
goto err;
if ((ret = __db_add_recovery(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size, __ham_groupalloc_42_recover,
DB___ham_groupalloc_42)) != 0)
goto err;
if ((ret = __db_add_recovery(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size, __txn_ckp_42_recover,
DB___txn_ckp_42)) != 0)
goto err;
if ((ret = __db_add_recovery(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size, __txn_regop_42_recover,
DB___txn_regop_42)) != 0)
goto err;
err:
return (ret);
}
static int
__env_init_rec_43(dbenv)
DB_ENV *dbenv;
{
int ret;
if ((ret = __db_add_recovery(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size, __bam_relink_43_recover,
DB___bam_relink_43)) != 0)
goto err;
if ((ret = __db_add_recovery(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size, __txn_regop_42_recover,
DB___txn_regop_42)) != 0)
goto err;
err:
return (ret);
}
static int
__env_init_rec_46(dbenv)
DB_ENV *dbenv;
{
int ret;
if ((ret = __bam_init_recover(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size)) != 0)
goto err;
if ((ret = __crdel_init_recover(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size)) != 0)
goto err;
if ((ret = __db_init_recover(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size)) != 0)
goto err;
if ((ret = __dbreg_init_recover(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size)) != 0)
goto err;
if ((ret = __fop_init_recover(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size)) != 0)
goto err;
if ((ret = __ham_init_recover(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size)) != 0)
goto err;
if ((ret = __qam_init_recover(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size)) != 0)
goto err;
if ((ret = __txn_init_recover(dbenv, &dbenv->recover_dtab,
&dbenv->recover_dtab_size)) != 0)
goto err;
err:
return (ret);
}