#include "db_config.h"
#include "db_int.h"
#include "dbinc/db_page.h"
#include "dbinc/log.h"
#include "dbinc/mp.h"
#include "dbinc/hash.h"
static int __db_pg_free_recover_int __P((ENV *, DB_THREAD_INFO *,
__db_pg_freedata_args *, DB *, DB_LSN *, DB_MPOOLFILE *, db_recops, int));
static int __db_pg_free_recover_42_int __P((ENV *, DB_THREAD_INFO *,
__db_pg_freedata_42_args *,
DB *, DB_LSN *, DB_MPOOLFILE *, db_recops, int));
int
__db_addrem_recover(env, dbtp, lsnp, op, info)
ENV *env;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__db_addrem_args *argp;
DB_THREAD_INFO *ip;
DB *file_dbp;
DBC *dbc;
DB_MPOOLFILE *mpf;
PAGE *pagep;
int cmp_n, cmp_p, modified, ret;
ip = ((DB_TXNHEAD *)info)->thread_info;
pagep = NULL;
REC_PRINT(__db_addrem_print);
REC_INTRO(__db_addrem_read, ip, 1);
REC_FGET(mpf, ip, argp->pgno, &pagep, done);
modified = 0;
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->pagelsn);
CHECK_LSN(env, op, cmp_p, &LSN(pagep), &argp->pagelsn);
if ((cmp_p == 0 && DB_REDO(op) && argp->opcode == DB_ADD_DUP) ||
(cmp_n == 0 && DB_UNDO(op) && argp->opcode == DB_REM_DUP)) {
REC_DIRTY(mpf, ip, dbc->priority, &pagep);
if ((ret = __db_pitem(dbc, pagep, argp->indx, argp->nbytes,
argp->hdr.size == 0 ? NULL : &argp->hdr,
argp->dbt.size == 0 ? NULL : &argp->dbt)) != 0)
goto out;
modified = 1;
} else if ((cmp_n == 0 && DB_UNDO(op) && argp->opcode == DB_ADD_DUP) ||
(cmp_p == 0 && DB_REDO(op) && argp->opcode == DB_REM_DUP)) {
REC_DIRTY(mpf, ip, dbc->priority, &pagep);
if ((ret = __db_ditem(dbc,
pagep, argp->indx, argp->nbytes)) != 0)
goto out;
modified = 1;
}
if (modified) {
if (DB_REDO(op))
LSN(pagep) = *lsnp;
else
LSN(pagep) = argp->pagelsn;
}
if ((ret = __memp_fput(mpf, ip, pagep, dbc->priority)) != 0)
goto out;
pagep = NULL;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, ip, pagep, dbc->priority);
REC_CLOSE;
}
int
__db_big_recover(env, dbtp, lsnp, op, info)
ENV *env;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__db_big_args *argp;
DB_THREAD_INFO *ip;
DB *file_dbp;
DBC *dbc;
DB_MPOOLFILE *mpf;
PAGE *pagep;
int cmp_n, cmp_p, modified, ret;
ip = ((DB_TXNHEAD *)info)->thread_info;
pagep = NULL;
REC_PRINT(__db_big_print);
REC_INTRO(__db_big_read, ip, 0);
REC_FGET(mpf, ip, argp->pgno, &pagep, ppage);
modified = 0;
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->pagelsn);
CHECK_LSN(env, op, cmp_p, &LSN(pagep), &argp->pagelsn);
if ((cmp_p == 0 && DB_REDO(op) && argp->opcode == DB_ADD_BIG) ||
(cmp_n == 0 && DB_UNDO(op) && argp->opcode == DB_REM_BIG)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
P_INIT(pagep, file_dbp->pgsize, argp->pgno, argp->prev_pgno,
argp->next_pgno, 0, P_OVERFLOW);
OV_LEN(pagep) = argp->dbt.size;
OV_REF(pagep) = 1;
memcpy((u_int8_t *)pagep + P_OVERHEAD(file_dbp), argp->dbt.data,
argp->dbt.size);
PREV_PGNO(pagep) = argp->prev_pgno;
modified = 1;
} else if ((cmp_n == 0 && DB_UNDO(op) && argp->opcode == DB_ADD_BIG) ||
(cmp_p == 0 && DB_REDO(op) && argp->opcode == DB_REM_BIG)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
modified = 1;
}
if (modified)
LSN(pagep) = DB_REDO(op) ? *lsnp : argp->pagelsn;
ret = __memp_fput(mpf, ip, pagep, file_dbp->priority);
pagep = NULL;
if (ret != 0)
goto out;
if (argp->opcode == DB_REM_BIG)
goto done;
ppage: if (argp->prev_pgno != PGNO_INVALID) {
REC_FGET(mpf, ip, argp->prev_pgno, &pagep, npage);
modified = 0;
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->prevlsn);
CHECK_LSN(env, op, cmp_p, &LSN(pagep), &argp->prevlsn);
if (cmp_p == 0 && DB_REDO(op) && argp->opcode == DB_ADD_BIG) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
NEXT_PGNO(pagep) = argp->pgno;
modified = 1;
} else if (cmp_n == 0 &&
DB_UNDO(op) && argp->opcode == DB_ADD_BIG) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
NEXT_PGNO(pagep) = argp->next_pgno;
modified = 1;
}
if (modified)
LSN(pagep) = DB_REDO(op) ? *lsnp : argp->prevlsn;
ret = __memp_fput(mpf, ip, pagep, file_dbp->priority);
pagep = NULL;
if (ret != 0)
goto out;
}
pagep = NULL;
npage: if (argp->next_pgno != PGNO_INVALID) {
REC_FGET(mpf, ip, argp->next_pgno, &pagep, done);
modified = 0;
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->nextlsn);
CHECK_LSN(env, op, cmp_p, &LSN(pagep), &argp->nextlsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
PREV_PGNO(pagep) = PGNO_INVALID;
modified = 1;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
PREV_PGNO(pagep) = argp->pgno;
modified = 1;
}
if (modified)
LSN(pagep) = DB_REDO(op) ? *lsnp : argp->nextlsn;
ret = __memp_fput(mpf, ip, pagep, file_dbp->priority);
pagep = NULL;
if (ret != 0)
goto out;
}
pagep = NULL;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, ip, pagep, file_dbp->priority);
REC_CLOSE;
}
int
__db_ovref_recover(env, dbtp, lsnp, op, info)
ENV *env;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__db_ovref_args *argp;
DB_THREAD_INFO *ip;
DB *file_dbp;
DBC *dbc;
DB_MPOOLFILE *mpf;
PAGE *pagep;
int cmp, ret;
ip = ((DB_TXNHEAD *)info)->thread_info;
pagep = NULL;
REC_PRINT(__db_ovref_print);
REC_INTRO(__db_ovref_read, ip, 0);
REC_FGET(mpf, ip, argp->pgno, &pagep, done);
cmp = LOG_COMPARE(&LSN(pagep), &argp->lsn);
CHECK_LSN(env, op, cmp, &LSN(pagep), &argp->lsn);
if (cmp == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
OV_REF(pagep) += argp->adjust;
pagep->lsn = *lsnp;
} else if (LOG_COMPARE(lsnp, &LSN(pagep)) == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
OV_REF(pagep) -= argp->adjust;
pagep->lsn = argp->lsn;
}
ret = __memp_fput(mpf, ip, pagep, file_dbp->priority);
pagep = NULL;
if (ret != 0)
goto out;
pagep = NULL;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, ip, pagep, file_dbp->priority);
REC_CLOSE;
}
int
__db_debug_recover(env, dbtp, lsnp, op, info)
ENV *env;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__db_debug_args *argp;
int ret;
COMPQUIET(op, DB_TXN_ABORT);
COMPQUIET(info, NULL);
REC_PRINT(__db_debug_print);
REC_NOOP_INTRO(__db_debug_read);
*lsnp = argp->prev_lsn;
ret = 0;
REC_NOOP_CLOSE;
}
int
__db_noop_recover(env, dbtp, lsnp, op, info)
ENV *env;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__db_noop_args *argp;
DB_THREAD_INFO *ip;
DB *file_dbp;
DBC *dbc;
DB_MPOOLFILE *mpf;
PAGE *pagep;
int cmp_n, cmp_p, ret;
ip = ((DB_TXNHEAD *)info)->thread_info;
pagep = NULL;
REC_PRINT(__db_noop_print);
REC_INTRO(__db_noop_read, ip, 0);
REC_FGET(mpf, ip, argp->pgno, &pagep, done);
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->prevlsn);
CHECK_LSN(env, op, cmp_p, &LSN(pagep), &argp->prevlsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
LSN(pagep) = *lsnp;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
LSN(pagep) = argp->prevlsn;
}
ret = __memp_fput(mpf, ip, pagep, file_dbp->priority);
pagep = NULL;
done: *lsnp = argp->prev_lsn;
out: if (pagep != NULL)
(void)__memp_fput(mpf,
ip, pagep, file_dbp->priority);
REC_CLOSE;
}
int
__db_pg_alloc_recover(env, dbtp, lsnp, op, info)
ENV *env;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__db_pg_alloc_args *argp;
DB_THREAD_INFO *ip;
DB *file_dbp;
DBC *dbc;
DBMETA *meta;
DB_MPOOLFILE *mpf;
PAGE *pagep;
db_pgno_t pgno;
int cmp_n, cmp_p, created, level, ret;
ip = ((DB_TXNHEAD *)info)->thread_info;
meta = NULL;
pagep = NULL;
created = 0;
REC_PRINT(__db_pg_alloc_print);
REC_INTRO(__db_pg_alloc_read, ip, 0);
pgno = PGNO_BASE_MD;
if ((ret = __memp_fget(mpf, &pgno, ip, NULL, 0, &meta)) != 0) {
if (DB_REDO(op)) {
ret = __db_pgerr(file_dbp, pgno, ret);
goto out;
} else
goto done;
}
cmp_n = LOG_COMPARE(lsnp, &LSN(meta));
cmp_p = LOG_COMPARE(&LSN(meta), &argp->meta_lsn);
CHECK_LSN(env, op, cmp_p, &LSN(meta), &argp->meta_lsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &meta);
LSN(meta) = *lsnp;
meta->free = argp->next;
if (argp->pgno > meta->last_pgno)
meta->last_pgno = argp->pgno;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &meta);
LSN(meta) = argp->meta_lsn;
if (!IS_ZERO_LSN(argp->page_lsn))
meta->free = argp->pgno;
meta->last_pgno = argp->last_pgno;
}
#ifdef HAVE_FTRUNCATE
if (op == DB_TXN_ABORT && !IS_ZERO_LSN(argp->page_lsn)) {
db_pgno_t *list;
u_int32_t nelem;
if ((ret = __memp_get_freelist(mpf, &nelem, &list)) != 0)
goto out;
if (list != NULL) {
if ((ret =
__memp_extend_freelist(mpf, nelem + 1, &list)) != 0)
goto out;
if (nelem != 0)
memmove(list + 1, list, nelem * sizeof(list));
*list = argp->pgno;
}
}
#endif
if ((ret = __memp_fget(mpf, &argp->pgno, ip, NULL, 0, &pagep)) != 0) {
if (DB_UNDO(op))
goto do_truncate;
if ((ret = __memp_fget(mpf, &argp->pgno, ip, NULL,
DB_MPOOL_CREATE, &pagep)) != 0) {
if (DB_UNDO(op) && ret == ENOSPC)
goto do_truncate;
ret = __db_pgerr(file_dbp, argp->pgno, ret);
goto out;
}
created = 1;
}
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->page_lsn);
if (IS_ZERO_LSN(LSN(pagep)))
cmp_p = 0;
CHECK_LSN(env, op, cmp_p, &LSN(pagep), &argp->page_lsn);
if (DB_REDO(op) && cmp_p == 0) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
switch (argp->ptype) {
case P_LBTREE:
case P_LRECNO:
case P_LDUP:
level = LEAFLEVEL;
break;
default:
level = 0;
break;
}
P_INIT(pagep, file_dbp->pgsize,
argp->pgno, PGNO_INVALID, PGNO_INVALID, level, argp->ptype);
pagep->lsn = *lsnp;
} else if (DB_UNDO(op) && (cmp_n == 0 || created)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
P_INIT(pagep, file_dbp->pgsize,
argp->pgno, PGNO_INVALID, argp->next, 0, P_INVALID);
pagep->lsn = argp->page_lsn;
}
do_truncate:
if ((pagep == NULL || IS_ZERO_LSN(LSN(pagep))) &&
IS_ZERO_LSN(argp->page_lsn) && DB_UNDO(op)) {
if (pagep != NULL) {
if ((ret = __memp_fput(mpf, ip,
pagep, DB_PRIORITY_VERY_LOW)) != 0)
goto out;
pagep = NULL;
}
if (meta->last_pgno <= argp->pgno && (ret = __memp_ftruncate(
mpf, ip, argp->pgno, MP_TRUNC_RECOVER)) != 0)
goto out;
}
if (pagep != NULL) {
ret = __memp_fput(mpf, ip, pagep, file_dbp->priority);
pagep = NULL;
if (ret != 0)
goto out;
}
ret = __memp_fput(mpf, ip, meta, file_dbp->priority);
meta = NULL;
if (ret != 0)
goto out;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, ip, pagep, file_dbp->priority);
if (meta != NULL)
(void)__memp_fput(mpf, ip, meta, file_dbp->priority);
REC_CLOSE;
}
static int
__db_pg_free_recover_int(env, ip, argp, file_dbp, lsnp, mpf, op, data)
ENV *env;
DB_THREAD_INFO *ip;
__db_pg_freedata_args *argp;
DB *file_dbp;
DB_LSN *lsnp;
DB_MPOOLFILE *mpf;
db_recops op;
int data;
{
DBMETA *meta;
DB_LSN copy_lsn;
PAGE *pagep, *prevp;
int cmp_n, cmp_p, is_meta, ret;
meta = NULL;
pagep = prevp = NULL;
is_meta = argp->meta_pgno == PGNO_BASE_MD;
REC_FGET(mpf, ip, argp->meta_pgno, &meta, check_meta);
if (argp->meta_pgno != PGNO_BASE_MD)
prevp = (PAGE *)meta;
cmp_n = LOG_COMPARE(lsnp, &LSN(meta));
cmp_p = LOG_COMPARE(&LSN(meta), &argp->meta_lsn);
CHECK_LSN(env, op, cmp_p, &LSN(meta), &argp->meta_lsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &meta);
if (argp->pgno == argp->last_pgno)
meta->last_pgno = argp->pgno - 1;
else if (is_meta)
meta->free = argp->pgno;
else
NEXT_PGNO(prevp) = argp->pgno;
LSN(meta) = *lsnp;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &meta);
if (is_meta) {
if (meta->last_pgno < argp->pgno)
meta->last_pgno = argp->pgno;
meta->free = argp->next;
} else
NEXT_PGNO(prevp) = argp->next;
LSN(meta) = argp->meta_lsn;
}
check_meta:
if (ret != 0 && is_meta) {
ret = __db_pgerr(file_dbp, argp->meta_pgno, ret);
goto out;
}
if (DB_REDO(op) || (is_meta && meta->last_pgno < argp->pgno)) {
if ((ret = __memp_fget(mpf, &argp->pgno,
ip, NULL, 0, &pagep)) != 0) {
if (ret != DB_PAGE_NOTFOUND)
goto out;
if (is_meta &&
DB_REDO(op) && meta->last_pgno <= argp->pgno)
goto trunc;
goto done;
}
} else if ((ret = __memp_fget(mpf, &argp->pgno,
ip, NULL, DB_MPOOL_CREATE, &pagep)) != 0)
goto out;
(void)__ua_memcpy(©_lsn, &LSN(argp->header.data), sizeof(DB_LSN));
cmp_n = IS_ZERO_LSN(LSN(pagep)) ? 0 : LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), ©_lsn);
if (IS_ZERO_LSN(LSN(pagep)))
cmp_p = 0;
CHECK_LSN(env, op, cmp_p, &LSN(pagep), ©_lsn);
if (DB_REDO(op) &&
(cmp_p == 0 ||
(IS_ZERO_LSN(copy_lsn) &&
LOG_COMPARE(&LSN(pagep), &argp->meta_lsn) <= 0))) {
if (is_meta && meta->last_pgno <= argp->pgno &&
argp->last_pgno <= argp->pgno) {
if ((ret = __memp_fput(mpf, ip,
pagep, DB_PRIORITY_VERY_LOW)) != 0)
goto out;
pagep = NULL;
trunc: if ((ret = __memp_ftruncate(mpf, ip,
argp->pgno, MP_TRUNC_RECOVER)) != 0)
goto out;
} else if (argp->last_pgno == argp->pgno) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
P_INIT(pagep, 0, PGNO_INVALID,
PGNO_INVALID, PGNO_INVALID, 0, P_INVALID);
ZERO_LSN(pagep->lsn);
} else {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
P_INIT(pagep, file_dbp->pgsize,
argp->pgno, PGNO_INVALID, argp->next, 0, P_INVALID);
pagep->lsn = *lsnp;
}
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
memcpy(pagep, argp->header.data, argp->header.size);
if (data)
memcpy((u_int8_t*)pagep + HOFFSET(pagep),
argp->data.data, argp->data.size);
}
if (pagep != NULL &&
(ret = __memp_fput(mpf, ip, pagep, file_dbp->priority)) != 0)
goto out;
pagep = NULL;
#ifdef HAVE_FTRUNCATE
if (op == DB_TXN_ABORT && argp->pgno != argp->last_pgno) {
db_pgno_t *lp;
u_int32_t nelem, pos;
if ((ret = __memp_get_freelist(mpf, &nelem, &lp)) != 0)
goto out;
if (lp != NULL) {
pos = 0;
if (!is_meta) {
__db_freelist_pos(argp->pgno, lp, nelem, &pos);
DB_ASSERT(env, argp->pgno == lp[pos]);
DB_ASSERT(env,
argp->meta_pgno == lp[pos - 1]);
}
if (pos < nelem)
memmove(&lp[pos], &lp[pos + 1],
((nelem - pos) - 1) * sizeof(*lp));
if ((ret =
__memp_extend_freelist(mpf, nelem - 1, &lp)) != 0)
goto out;
}
}
#endif
done:
if (meta != NULL &&
(ret = __memp_fput(mpf, ip, meta, file_dbp->priority)) != 0)
goto out;
meta = NULL;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, ip, pagep, file_dbp->priority);
if (meta != NULL)
(void)__memp_fput(mpf, ip, meta, file_dbp->priority);
return (ret);
}
int
__db_pg_free_recover(env, dbtp, lsnp, op, info)
ENV *env;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__db_pg_free_args *argp;
DB *file_dbp;
DBC *dbc;
DB_MPOOLFILE *mpf;
DB_THREAD_INFO *ip;
int ret;
ip = ((DB_TXNHEAD *)info)->thread_info;
REC_PRINT(__db_pg_free_print);
REC_INTRO(__db_pg_free_read, ip, 0);
ret = __db_pg_free_recover_int(env, ip,
(__db_pg_freedata_args *)argp, file_dbp, lsnp, mpf, op, 0);
done: *lsnp = argp->prev_lsn;
out:
REC_CLOSE;
}
int
__db_pg_freedata_recover(env, dbtp, lsnp, op, info)
ENV *env;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__db_pg_freedata_args *argp;
DB *file_dbp;
DBC *dbc;
DB_MPOOLFILE *mpf;
DB_THREAD_INFO *ip;
int ret;
ip = ((DB_TXNHEAD *)info)->thread_info;
REC_PRINT(__db_pg_freedata_print);
REC_INTRO(__db_pg_freedata_read, ip, 0);
ret = __db_pg_free_recover_int(env,
ip, argp, file_dbp, lsnp, mpf, op, 1);
done: *lsnp = argp->prev_lsn;
out:
REC_CLOSE;
}
int
__db_cksum_recover(env, dbtp, lsnp, op, info)
ENV *env;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__db_cksum_args *argp;
int ret;
COMPQUIET(info, NULL);
COMPQUIET(lsnp, NULL);
COMPQUIET(op, DB_TXN_ABORT);
REC_PRINT(__db_cksum_print);
if ((ret = __db_cksum_read(env, dbtp->data, &argp)) != 0)
return (ret);
if (F_ISSET(env, ENV_RECOVER_FATAL))
ret = 0;
else {
__db_errx(env,
"Checksum failure requires catastrophic recovery");
ret = __env_panic(env, DB_RUNRECOVERY);
}
__os_free(env, argp);
return (ret);
}
int
__db_pg_init_recover(env, dbtp, lsnp, op, info)
ENV *env;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__db_pg_init_args *argp;
DB_THREAD_INFO *ip;
DB *file_dbp;
DBC *dbc;
DB_LSN copy_lsn;
DB_MPOOLFILE *mpf;
PAGE *pagep;
int cmp_n, cmp_p, ret, type;
ip = ((DB_TXNHEAD *)info)->thread_info;
REC_PRINT(__db_pg_init_print);
REC_INTRO(__db_pg_init_read, ip, 0);
mpf = file_dbp->mpf;
if ((ret = __memp_fget(mpf, &argp->pgno, ip, NULL, 0, &pagep)) != 0) {
if (DB_UNDO(op)) {
if (ret == DB_PAGE_NOTFOUND)
goto done;
else {
ret = __db_pgerr(file_dbp, argp->pgno, ret);
goto out;
}
}
DB_ASSERT(env, file_dbp->type == DB_HASH);
if ((ret = __memp_fget(mpf, &argp->pgno,
ip, NULL, DB_MPOOL_CREATE, &pagep)) != 0) {
ret = __db_pgerr(file_dbp, argp->pgno, ret);
goto out;
}
}
(void)__ua_memcpy(©_lsn, &LSN(argp->header.data), sizeof(DB_LSN));
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), ©_lsn);
CHECK_LSN(env, op, cmp_p, &LSN(pagep), ©_lsn);
if (cmp_p == 0 && DB_REDO(op)) {
if (TYPE(pagep) == P_HASH)
type = P_HASH;
else
type = file_dbp->type == DB_RECNO ? P_LRECNO : P_LBTREE;
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
P_INIT(pagep, file_dbp->pgsize, PGNO(pagep), PGNO_INVALID,
PGNO_INVALID, TYPE(pagep) == P_HASH ? 0 : 1, type);
pagep->lsn = *lsnp;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
memcpy(pagep, argp->header.data, argp->header.size);
if (argp->data.size > 0)
memcpy((u_int8_t*)pagep + HOFFSET(pagep),
argp->data.data, argp->data.size);
}
if ((ret = __memp_fput(mpf, ip, pagep, file_dbp->priority)) != 0)
goto out;
done: *lsnp = argp->prev_lsn;
out:
REC_CLOSE;
}
int
__db_pg_sort_recover(env, dbtp, lsnp, op, info)
ENV *env;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
#ifdef HAVE_FTRUNCATE
__db_pg_sort_args *argp;
DB_THREAD_INFO *ip;
DB *file_dbp;
DBC *dbc;
DBMETA *meta;
DB_MPOOLFILE *mpf;
PAGE *pagep;
db_pglist_t *pglist, *lp;
db_pgno_t pgno, *list;
u_int32_t felem, nelem;
int ret;
ip = ((DB_TXNHEAD *)info)->thread_info;
REC_PRINT(__db_pg_sort_print);
REC_INTRO(__db_pg_sort_read, ip, 1);
pglist = (db_pglist_t *) argp->list.data;
nelem = argp->list.size / sizeof(db_pglist_t);
if (DB_REDO(op)) {
pgno = argp->last_pgno;
if ((ret = __db_pg_truncate(dbc, NULL,
pglist, NULL, &nelem, &pgno, lsnp, 1)) != 0)
goto out;
if (argp->last_free != PGNO_INVALID) {
if ((ret = __memp_fget(mpf,
&argp->last_free, ip, NULL, 0, &meta)) == 0) {
if (LOG_COMPARE(&LSN(meta),
&argp->last_lsn) == 0) {
REC_DIRTY(mpf,
ip, dbc->priority, &meta);
NEXT_PGNO(meta) = PGNO_INVALID;
LSN(meta) = *lsnp;
}
if ((ret = __memp_fput(mpf, ip,
meta, file_dbp->priority)) != 0)
goto out;
meta = NULL;
} else if (ret != DB_PAGE_NOTFOUND)
goto out;
}
if ((ret = __memp_fget(mpf, &argp->meta, ip, NULL,
0, &meta)) != 0)
goto out;
if (LOG_COMPARE(&LSN(meta), &argp->meta_lsn) == 0) {
REC_DIRTY(mpf, ip, dbc->priority, &meta);
if (argp->last_free == PGNO_INVALID) {
if (nelem == 0)
meta->free = PGNO_INVALID;
else
meta->free = pglist->pgno;
}
meta->last_pgno = pgno;
LSN(meta) = *lsnp;
}
} else {
for (lp = pglist; lp < &pglist[nelem]; lp++) {
if ((ret = __memp_fget(mpf, &lp->pgno, ip,
NULL, DB_MPOOL_CREATE, &pagep)) != 0)
goto out;
if (IS_ZERO_LSN(LSN(pagep)) ||
LOG_COMPARE(&LSN(pagep), lsnp) == 0) {
REC_DIRTY(mpf, ip, dbc->priority, &pagep);
if (lp == &pglist[nelem - 1])
pgno = PGNO_INVALID;
else
pgno = lp[1].pgno;
P_INIT(pagep, file_dbp->pgsize,
lp->pgno, PGNO_INVALID, pgno, 0, P_INVALID);
LSN(pagep) = lp->lsn;
}
if ((ret = __memp_fput(mpf,
ip, pagep, file_dbp->priority)) != 0)
goto out;
}
if (argp->last_free != PGNO_INVALID) {
if ((ret = __memp_fget(mpf, &argp->last_free,
ip, NULL, DB_MPOOL_EDIT, &meta)) == 0) {
if (LOG_COMPARE(&LSN(meta), lsnp) == 0) {
REC_DIRTY(mpf,
ip, dbc->priority, &pagep);
NEXT_PGNO(meta) = pglist->pgno;
LSN(meta) = argp->last_lsn;
}
if ((ret = __memp_fput(mpf, ip,
meta, file_dbp->priority)) != 0)
goto out;
} else if (ret != DB_PAGE_NOTFOUND)
goto out;
meta = NULL;
}
if ((ret = __memp_fget(mpf, &argp->meta,
ip, NULL, DB_MPOOL_EDIT, &meta)) != 0)
goto out;
if (LOG_COMPARE(&LSN(meta), lsnp) == 0) {
REC_DIRTY(mpf, ip, dbc->priority, &meta);
meta->last_pgno = argp->last_pgno;
if (argp->last_free == PGNO_INVALID)
meta->free = pglist->pgno;
LSN(meta) = argp->meta_lsn;
}
}
if (op == DB_TXN_ABORT) {
if ((ret = __memp_get_freelist(mpf, &felem, &list)) != 0)
goto out;
if (list != NULL) {
DB_ASSERT(env, felem == 0 ||
argp->last_free == list[felem - 1]);
if ((ret = __memp_extend_freelist(
mpf, felem + nelem, &list)) != 0)
goto out;
for (lp = pglist; lp < &pglist[nelem]; lp++)
list[felem++] = lp->pgno;
}
}
if ((ret = __memp_fput(mpf, ip, meta, file_dbp->priority)) != 0)
goto out;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: REC_CLOSE;
#else
COMPQUIET(env, NULL);
COMPQUIET(dbtp, NULL);
COMPQUIET(lsnp, NULL);
COMPQUIET(op, DB_TXN_ABORT);
COMPQUIET(info, NULL);
return (EINVAL);
#endif
}
int
__db_pg_alloc_42_recover(env, dbtp, lsnp, op, info)
ENV *env;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__db_pg_alloc_42_args *argp;
DB_THREAD_INFO *ip;
DB *file_dbp;
DBC *dbc;
DBMETA *meta;
DB_MPOOLFILE *mpf;
PAGE *pagep;
db_pgno_t pgno;
int cmp_n, cmp_p, created, level, ret;
ip = ((DB_TXNHEAD *)info)->thread_info;
meta = NULL;
pagep = NULL;
created = 0;
REC_PRINT(__db_pg_alloc_42_print);
REC_INTRO(__db_pg_alloc_42_read, ip, 0);
pgno = PGNO_BASE_MD;
if ((ret = __memp_fget(mpf, &pgno, ip, NULL, 0, &meta)) != 0) {
if (DB_REDO(op)) {
ret = __db_pgerr(file_dbp, pgno, ret);
goto out;
} else
goto done;
}
cmp_n = LOG_COMPARE(lsnp, &LSN(meta));
cmp_p = LOG_COMPARE(&LSN(meta), &argp->meta_lsn);
CHECK_LSN(env, op, cmp_p, &LSN(meta), &argp->meta_lsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &meta);
LSN(meta) = *lsnp;
meta->free = argp->next;
if (argp->pgno > meta->last_pgno)
meta->last_pgno = argp->pgno;
} else if (cmp_n == 0 && DB_UNDO(op)) {
goto no_rollback;
}
if ((ret = __memp_fget(mpf, &argp->pgno, ip, NULL, 0, &pagep)) != 0) {
if ((ret = __memp_fget(mpf, &argp->pgno,
ip, NULL, DB_MPOOL_CREATE, &pagep)) != 0) {
if (DB_UNDO(op) && ret == ENOSPC)
goto do_truncate;
ret = __db_pgerr(file_dbp, argp->pgno, ret);
goto out;
}
created = 1;
}
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->page_lsn);
if (IS_ZERO_LSN(LSN(pagep)) ||
(IS_ZERO_LSN(argp->page_lsn) && IS_INIT_LSN(LSN(pagep))))
cmp_p = 0;
CHECK_LSN(env, op, cmp_p, &LSN(pagep), &argp->page_lsn);
if (DB_REDO(op) && cmp_p == 0) {
switch (argp->ptype) {
case P_LBTREE:
case P_LRECNO:
case P_LDUP:
level = LEAFLEVEL;
break;
default:
level = 0;
break;
}
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
P_INIT(pagep, file_dbp->pgsize,
argp->pgno, PGNO_INVALID, PGNO_INVALID, level, argp->ptype);
pagep->lsn = *lsnp;
} else if (DB_UNDO(op) && (cmp_n == 0 || created)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
P_INIT(pagep, file_dbp->pgsize,
argp->pgno, PGNO_INVALID, argp->next, 0, P_INVALID);
pagep->lsn = argp->page_lsn;
}
do_truncate:
if ((pagep == NULL || IS_ZERO_LSN(LSN(pagep))) &&
IS_ZERO_LSN(argp->page_lsn) && DB_UNDO(op)) {
no_rollback: __db_errx(env,
"Cannot replicate prepared transactions from master running release 4.2 ");
ret = __env_panic(env, EINVAL);
}
if (pagep != NULL &&
(ret = __memp_fput(mpf, ip, pagep, file_dbp->priority)) != 0)
goto out;
pagep = NULL;
if ((ret = __memp_fput(mpf, ip, meta, file_dbp->priority)) != 0)
goto out;
meta = NULL;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, ip, pagep, file_dbp->priority);
if (meta != NULL)
(void)__memp_fput(mpf, ip, meta, file_dbp->priority);
REC_CLOSE;
}
static int
__db_pg_free_recover_42_int(env, ip, argp, file_dbp, lsnp, mpf, op, data)
ENV *env;
DB_THREAD_INFO *ip;
__db_pg_freedata_42_args *argp;
DB *file_dbp;
DB_LSN *lsnp;
DB_MPOOLFILE *mpf;
db_recops op;
int data;
{
DBMETA *meta;
DB_LSN copy_lsn;
PAGE *pagep, *prevp;
int cmp_n, cmp_p, is_meta, ret;
meta = NULL;
pagep = NULL;
prevp = NULL;
is_meta = argp->meta_pgno == PGNO_BASE_MD;
REC_FGET(mpf, ip, argp->meta_pgno, &meta, check_meta);
if (argp->meta_pgno != PGNO_BASE_MD)
prevp = (PAGE *)meta;
cmp_n = LOG_COMPARE(lsnp, &LSN(meta));
cmp_p = LOG_COMPARE(&LSN(meta), &argp->meta_lsn);
CHECK_LSN(env, op, cmp_p, &LSN(meta), &argp->meta_lsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &meta);
if (prevp == NULL)
meta->free = argp->pgno;
else
NEXT_PGNO(prevp) = argp->pgno;
if (prevp == NULL && meta->last_pgno < meta->free)
meta->last_pgno = meta->free;
LSN(meta) = *lsnp;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &meta);
if (prevp == NULL)
meta->free = argp->next;
else
NEXT_PGNO(prevp) = argp->next;
LSN(meta) = argp->meta_lsn;
if (prevp == NULL && meta->last_pgno < argp->pgno)
meta->last_pgno = argp->pgno;
}
check_meta:
if (ret != 0 && is_meta) {
ret = __db_pgerr(file_dbp, argp->meta_pgno, ret);
goto out;
}
if ((ret = __memp_fget(mpf, &argp->pgno,
ip, NULL, DB_MPOOL_CREATE, &pagep)) != 0)
goto out;
(void)__ua_memcpy(©_lsn, &LSN(argp->header.data), sizeof(DB_LSN));
cmp_n = IS_ZERO_LSN(LSN(pagep)) ? 0 : LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), ©_lsn);
CHECK_LSN(env, op, cmp_p, &LSN(pagep), ©_lsn);
if (DB_REDO(op) &&
(cmp_p == 0 ||
(IS_ZERO_LSN(copy_lsn) &&
LOG_COMPARE(&LSN(pagep), &argp->meta_lsn) <= 0))) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
P_INIT(pagep, file_dbp->pgsize,
argp->pgno, PGNO_INVALID, argp->next, 0, P_INVALID);
pagep->lsn = *lsnp;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
memcpy(pagep, argp->header.data, argp->header.size);
if (data)
memcpy((u_int8_t*)pagep + HOFFSET(pagep),
argp->data.data, argp->data.size);
}
if (pagep != NULL &&
(ret = __memp_fput(mpf, ip, pagep, file_dbp->priority)) != 0)
goto out;
pagep = NULL;
if (meta != NULL &&
(ret = __memp_fput(mpf, ip, meta, file_dbp->priority)) != 0)
goto out;
meta = NULL;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, ip, pagep, file_dbp->priority);
if (meta != NULL)
(void)__memp_fput(mpf, ip, meta, file_dbp->priority);
return (ret);
}
int
__db_pg_free_42_recover(env, dbtp, lsnp, op, info)
ENV *env;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__db_pg_free_42_args *argp;
DB *file_dbp;
DBC *dbc;
DB_MPOOLFILE *mpf;
DB_THREAD_INFO *ip;
int ret;
ip = ((DB_TXNHEAD *)info)->thread_info;
REC_PRINT(__db_pg_free_42_print);
REC_INTRO(__db_pg_free_42_read, ip, 0);
ret = __db_pg_free_recover_42_int(env, ip,
(__db_pg_freedata_42_args *)argp, file_dbp, lsnp, mpf, op, 0);
done: *lsnp = argp->prev_lsn;
out:
REC_CLOSE;
}
int
__db_pg_freedata_42_recover(env, dbtp, lsnp, op, info)
ENV *env;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__db_pg_freedata_42_args *argp;
DB *file_dbp;
DBC *dbc;
DB_MPOOLFILE *mpf;
DB_THREAD_INFO *ip;
int ret;
ip = ((DB_TXNHEAD *)info)->thread_info;
REC_PRINT(__db_pg_freedata_42_print);
REC_INTRO(__db_pg_freedata_42_read, ip, 0);
ret = __db_pg_free_recover_42_int(
env, ip, argp, file_dbp, lsnp, mpf, op, 1);
done: *lsnp = argp->prev_lsn;
out:
REC_CLOSE;
}
int
__db_relink_42_recover(env, dbtp, lsnp, op, info)
ENV *env;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__db_relink_42_args *argp;
DB_THREAD_INFO *ip;
DB *file_dbp;
DBC *dbc;
DB_MPOOLFILE *mpf;
PAGE *pagep;
int cmp_n, cmp_p, modified, ret;
ip = ((DB_TXNHEAD *)info)->thread_info;
pagep = NULL;
REC_PRINT(__db_relink_42_print);
REC_INTRO(__db_relink_42_read, ip, 0);
if ((ret = __memp_fget(mpf, &argp->pgno, ip, NULL, 0, &pagep)) != 0) {
if (DB_REDO(op)) {
ret = __db_pgerr(file_dbp, argp->pgno, ret);
goto out;
}
goto next2;
}
if (argp->opcode == DB_ADD_PAGE_COMPAT)
goto next1;
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->lsn);
CHECK_LSN(env, op, cmp_p, &LSN(pagep), &argp->lsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
pagep->lsn = *lsnp;
} else if (LOG_COMPARE(lsnp, &LSN(pagep)) == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
pagep->next_pgno = argp->next;
pagep->prev_pgno = argp->prev;
pagep->lsn = argp->lsn;
}
next1: if ((ret = __memp_fput(mpf, ip, pagep, file_dbp->priority)) != 0)
goto out;
pagep = NULL;
next2: if ((ret = __memp_fget(mpf, &argp->next, ip, NULL, 0, &pagep)) != 0) {
if (DB_REDO(op)) {
ret = __db_pgerr(file_dbp, argp->next, ret);
goto out;
}
goto prev;
}
modified = 0;
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->lsn_next);
CHECK_LSN(env, op, cmp_p, &LSN(pagep), &argp->lsn_next);
if ((argp->opcode == DB_REM_PAGE_COMPAT && cmp_p == 0 && DB_REDO(op)) ||
(argp->opcode == DB_ADD_PAGE_COMPAT && cmp_n == 0 && DB_UNDO(op))) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
pagep->prev_pgno = argp->prev;
modified = 1;
} else if ((argp->opcode == DB_REM_PAGE_COMPAT &&
cmp_n == 0 && DB_UNDO(op)) ||
(argp->opcode == DB_ADD_PAGE_COMPAT && cmp_p == 0 && DB_REDO(op))) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
pagep->prev_pgno = argp->pgno;
modified = 1;
}
if (modified) {
if (DB_UNDO(op))
pagep->lsn = argp->lsn_next;
else
pagep->lsn = *lsnp;
}
if ((ret = __memp_fput(mpf, ip, pagep, file_dbp->priority)) != 0)
goto out;
pagep = NULL;
if (argp->opcode == DB_ADD_PAGE_COMPAT)
goto done;
prev: if ((ret = __memp_fget(mpf, &argp->prev, ip, NULL, 0, &pagep)) != 0) {
if (DB_REDO(op)) {
ret = __db_pgerr(file_dbp, argp->prev, ret);
goto out;
}
goto done;
}
modified = 0;
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->lsn_prev);
CHECK_LSN(env, op, cmp_p, &LSN(pagep), &argp->lsn_prev);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
pagep->next_pgno = argp->next;
modified = 1;
} else if (LOG_COMPARE(lsnp, &LSN(pagep)) == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, ip, file_dbp->priority, &pagep);
pagep->next_pgno = argp->pgno;
modified = 1;
}
if (modified) {
if (DB_UNDO(op))
pagep->lsn = argp->lsn_prev;
else
pagep->lsn = *lsnp;
}
if ((ret = __memp_fput(mpf, ip, pagep, file_dbp->priority)) != 0)
goto out;
pagep = NULL;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, ip, pagep, file_dbp->priority);
REC_CLOSE;
}