#include "db_config.h"
#include "db_int.h"
#include "dbinc/db_page.h"
#include "dbinc/btree.h"
#include "dbinc/hash.h"
#include "dbinc/log.h"
#include "dbinc/mp.h"
static int __ham_alloc_pages __P((DB *, __ham_groupalloc_args *, DB_LSN *));
static int __ham_alloc_pages_42
__P((DB *, __ham_groupalloc_42_args *, DB_LSN *));
int
__ham_insdel_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__ham_insdel_args *argp;
DB *file_dbp;
DBC *dbc;
DB_MPOOLFILE *mpf;
PAGE *pagep;
db_indx_t dindx;
u_int32_t opcode;
int cmp_n, cmp_p, dtype, ktype, ret;
pagep = NULL;
REC_PRINT(__ham_insdel_print);
REC_INTRO(__ham_insdel_read, 1, 0);
if ((ret = __memp_fget(mpf, &argp->pgno, 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;
}
}
#ifdef HAVE_FTRUNCATE
if (!IS_ZERO_LSN(argp->pagelsn))
goto done;
#endif
if ((ret = __memp_fget(mpf, &argp->pgno, NULL,
DB_MPOOL_CREATE, &pagep)) != 0) {
ret = __db_pgerr(file_dbp, argp->pgno, ret);
goto out;
}
}
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->pagelsn);
CHECK_LSN(dbenv, op, cmp_p, &LSN(pagep), &argp->pagelsn);
opcode = OPCODE_OF(argp->opcode);
if ((opcode == DELPAIR && cmp_n == 0 && DB_UNDO(op)) ||
(opcode == PUTPAIR && cmp_p == 0 && DB_REDO(op))) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
ktype = DB_UNDO(op) || PAIR_ISKEYBIG(argp->opcode) ?
H_OFFPAGE : H_KEYDATA;
if (PAIR_ISDATADUP(argp->opcode))
dtype = H_DUPLICATE;
else if (DB_UNDO(op) || PAIR_ISDATABIG(argp->opcode))
dtype = H_OFFPAGE;
else
dtype = H_KEYDATA;
dindx = (db_indx_t)argp->ndx;
if ((ret = __ham_insertpair(file_dbp, NULL, pagep, &dindx,
&argp->key, &argp->data, ktype, dtype)) != 0)
goto out;
LSN(pagep) = DB_REDO(op) ? *lsnp : argp->pagelsn;
} else if ((opcode == DELPAIR && cmp_p == 0 && DB_REDO(op)) ||
(opcode == PUTPAIR && cmp_n == 0 && DB_UNDO(op))) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
__ham_dpair(file_dbp, pagep, argp->ndx);
LSN(pagep) = DB_REDO(op) ? *lsnp : argp->pagelsn;
}
if ((ret = __memp_fput(mpf, pagep, file_dbp->priority)) != 0)
goto out;
pagep = NULL;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, pagep, file_dbp->priority);
REC_CLOSE;
}
int
__ham_newpage_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__ham_newpage_args *argp;
DB *file_dbp;
DBC *dbc;
DB_MPOOLFILE *mpf;
PAGE *pagep;
int change, cmp_n, cmp_p, ret;
pagep = NULL;
REC_PRINT(__ham_newpage_print);
REC_INTRO(__ham_newpage_read, 1, 0);
REC_FGET(mpf, argp->new_pgno, &pagep, ppage);
change = 0;
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->pagelsn);
CHECK_LSN(dbenv, op, cmp_p, &LSN(pagep), &argp->pagelsn);
if ((cmp_p == 0 && DB_REDO(op) && argp->opcode == PUTOVFL) ||
(cmp_n == 0 && DB_UNDO(op) && argp->opcode == DELOVFL)) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
P_INIT(pagep, file_dbp->pgsize, argp->new_pgno,
argp->prev_pgno, argp->next_pgno, 0, P_HASH);
change = 1;
} else if ((cmp_p == 0 && DB_REDO(op) && argp->opcode == DELOVFL) ||
(cmp_n == 0 && DB_UNDO(op) && argp->opcode == PUTOVFL)) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
change = 1;
}
if (change)
LSN(pagep) = DB_REDO(op) ? *lsnp : argp->pagelsn;
if ((ret = __memp_fput(mpf, pagep, file_dbp->priority)) != 0)
goto out;
pagep = NULL;
ppage: if (argp->prev_pgno != PGNO_INVALID) {
REC_FGET(mpf, argp->prev_pgno, &pagep, npage);
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->prevlsn);
CHECK_LSN(dbenv, op, cmp_p, &LSN(pagep), &argp->prevlsn);
change = 0;
if ((cmp_p == 0 && DB_REDO(op) && argp->opcode == PUTOVFL) ||
(cmp_n == 0 && DB_UNDO(op) && argp->opcode == DELOVFL)) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
pagep->next_pgno = argp->new_pgno;
change = 1;
} else if ((cmp_p == 0 &&
DB_REDO(op) && argp->opcode == DELOVFL) ||
(cmp_n == 0 && DB_UNDO(op) && argp->opcode == PUTOVFL)) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
pagep->next_pgno = argp->next_pgno;
change = 1;
}
if (change)
LSN(pagep) = DB_REDO(op) ? *lsnp : argp->prevlsn;
if ((ret = __memp_fput(mpf, pagep, file_dbp->priority)) != 0)
goto out;
pagep = NULL;
}
npage: if (argp->next_pgno != PGNO_INVALID) {
REC_FGET(mpf, argp->next_pgno, &pagep, done);
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->nextlsn);
CHECK_LSN(dbenv, op, cmp_p, &LSN(pagep), &argp->nextlsn);
change = 0;
if ((cmp_p == 0 && DB_REDO(op) && argp->opcode == PUTOVFL) ||
(cmp_n == 0 && DB_UNDO(op) && argp->opcode == DELOVFL)) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
pagep->prev_pgno = argp->new_pgno;
change = 1;
} else if ((cmp_p == 0 &&
DB_REDO(op) && argp->opcode == DELOVFL) ||
(cmp_n == 0 && DB_UNDO(op) && argp->opcode == PUTOVFL)) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
pagep->prev_pgno = argp->prev_pgno;
change = 1;
}
if (change)
LSN(pagep) = DB_REDO(op) ? *lsnp : argp->nextlsn;
if ((ret = __memp_fput(mpf, pagep, file_dbp->priority)) != 0)
goto out;
pagep = NULL;
}
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, pagep, file_dbp->priority);
REC_CLOSE;
}
int
__ham_replace_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__ham_replace_args *argp;
DB *file_dbp;
DBC *dbc;
DB_MPOOLFILE *mpf;
DBT dbt;
PAGE *pagep;
u_int32_t change;
int cmp_n, cmp_p, is_plus, modified, ret;
u_int8_t *hk;
pagep = NULL;
REC_PRINT(__ham_replace_print);
REC_INTRO(__ham_replace_read, 1, 0);
REC_FGET(mpf, argp->pgno, &pagep, done);
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->pagelsn);
CHECK_LSN(dbenv, op, cmp_p, &LSN(pagep), &argp->pagelsn);
memset(&dbt, 0, sizeof(dbt));
modified = 0;
if (argp->newitem.size > argp->olditem.size) {
change = argp->newitem.size - argp->olditem.size;
is_plus = 1;
} else {
change = argp->olditem.size - argp->newitem.size;
is_plus = 0;
}
if (cmp_p == 0 && DB_REDO(op)) {
dbt.data = argp->newitem.data;
dbt.size = argp->newitem.size;
REC_DIRTY(mpf, file_dbp->priority, &pagep);
LSN(pagep) = *lsnp;
modified = 1;
} else if (cmp_n == 0 && DB_UNDO(op)) {
dbt.data = argp->olditem.data;
dbt.size = argp->olditem.size;
is_plus = !is_plus;
REC_DIRTY(mpf, file_dbp->priority, &pagep);
LSN(pagep) = argp->pagelsn;
modified = 1;
}
if (modified) {
__ham_onpage_replace(file_dbp, pagep,
argp->ndx, argp->off, change, is_plus, &dbt);
if (argp->makedup) {
hk = P_ENTRY(file_dbp, pagep, argp->ndx);
if (DB_REDO(op))
HPAGE_PTYPE(hk) = H_DUPLICATE;
else
HPAGE_PTYPE(hk) = H_KEYDATA;
}
}
if ((ret = __memp_fput(mpf, pagep, file_dbp->priority)) != 0)
goto out;
pagep = NULL;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, pagep, file_dbp->priority);
REC_CLOSE;
}
int
__ham_splitdata_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__ham_splitdata_args *argp;
DB *file_dbp;
DBC *dbc;
DB_MPOOLFILE *mpf;
PAGE *pagep;
int cmp_n, cmp_p, ret;
pagep = NULL;
REC_PRINT(__ham_splitdata_print);
REC_INTRO(__ham_splitdata_read, 1, 0);
if ((ret = __memp_fget(mpf, &argp->pgno, 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;
}
}
#ifdef HAVE_FTRUNCATE
if (!IS_ZERO_LSN(argp->pagelsn))
goto done;
#endif
if ((ret = __memp_fget(mpf, &argp->pgno,
NULL, DB_MPOOL_CREATE, &pagep)) != 0) {
ret = __db_pgerr(file_dbp, argp->pgno, ret);
goto out;
}
}
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->pagelsn);
CHECK_LSN(dbenv, op, cmp_p, &LSN(pagep), &argp->pagelsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
if (argp->opcode == SPLITNEW)
memcpy(pagep, argp->pageimage.data,
argp->pageimage.size);
else if (argp->opcode == SORTPAGE) {
if ((ret = __ham_sort_page(file_dbp,
NULL, NULL, pagep)) != 0)
goto out;
}
LSN(pagep) = *lsnp;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
if (argp->opcode == SPLITOLD || argp->opcode == SORTPAGE) {
memcpy(pagep, argp->pageimage.data,
argp->pageimage.size);
} else
P_INIT(pagep, file_dbp->pgsize, argp->pgno,
PGNO_INVALID, PGNO_INVALID, 0, P_HASH);
LSN(pagep) = argp->pagelsn;
}
if ((ret = __memp_fput(mpf, pagep, file_dbp->priority)) != 0)
goto out;
pagep = NULL;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, pagep, file_dbp->priority);
REC_CLOSE;
}
int
__ham_copypage_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__ham_copypage_args *argp;
DB *file_dbp;
DBC *dbc;
DB_MPOOLFILE *mpf;
PAGE *pagep;
int cmp_n, cmp_p, ret;
pagep = NULL;
REC_PRINT(__ham_copypage_print);
REC_INTRO(__ham_copypage_read, 1, 0);
REC_FGET(mpf, argp->pgno, &pagep, donext);
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->pagelsn);
CHECK_LSN(dbenv, op, cmp_p, &LSN(pagep), &argp->pagelsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
memcpy(pagep, argp->page.data, argp->page.size);
PGNO(pagep) = argp->pgno;
PREV_PGNO(pagep) = PGNO_INVALID;
LSN(pagep) = *lsnp;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
P_INIT(pagep, file_dbp->pgsize, argp->pgno, PGNO_INVALID,
argp->next_pgno, 0, P_HASH);
LSN(pagep) = argp->pagelsn;
}
if ((ret = __memp_fput(mpf, pagep, file_dbp->priority)) != 0)
goto out;
pagep = NULL;
donext:
REC_FGET(mpf, argp->next_pgno, &pagep, do_nn);
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->nextlsn);
CHECK_LSN(dbenv, op, cmp_p, &LSN(pagep), &argp->nextlsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
LSN(pagep) = *lsnp;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
memcpy(pagep, argp->page.data, argp->page.size);
}
if ((ret = __memp_fput(mpf, pagep, file_dbp->priority)) != 0)
goto out;
pagep = NULL;
do_nn: if (argp->nnext_pgno == PGNO_INVALID)
goto done;
REC_FGET(mpf, argp->nnext_pgno, &pagep, done);
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->nnextlsn);
CHECK_LSN(dbenv, op, cmp_p, &LSN(pagep), &argp->nnextlsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
PREV_PGNO(pagep) = argp->pgno;
LSN(pagep) = *lsnp;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
PREV_PGNO(pagep) = argp->next_pgno;
LSN(pagep) = argp->nnextlsn;
}
if ((ret = __memp_fput(mpf, pagep, file_dbp->priority)) != 0)
goto out;
pagep = NULL;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, pagep, file_dbp->priority);
REC_CLOSE;
}
int
__ham_metagroup_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__ham_metagroup_args *argp;
HASH_CURSOR *hcp;
DB *file_dbp;
DBMETA *mmeta;
DBC *dbc;
DB_MPOOLFILE *mpf;
PAGE *pagep;
db_pgno_t pgno;
u_int32_t flags;
int cmp_n, cmp_p, did_alloc, groupgrow, ret;
did_alloc = 0;
mmeta = NULL;
REC_PRINT(__ham_metagroup_print);
REC_INTRO(__ham_metagroup_read, 1, 1);
groupgrow =
(u_int32_t)(1 << __db_log2(argp->bucket + 1)) == argp->bucket + 1;
pgno = argp->pgno;
if (argp->newalloc)
pgno += argp->bucket;
flags = 0;
pagep = NULL;
#ifndef HAVE_FTRUNCATE
LF_SET(DB_MPOOL_CREATE);
#endif
ret = __memp_fget(mpf, &pgno, NULL, flags, &pagep);
#ifdef HAVE_FTRUNCATE
if (ret != 0 && DB_REDO(op))
ret = __memp_fget(mpf,
&pgno, NULL, DB_MPOOL_CREATE, &pagep);
else if (ret == DB_PAGE_NOTFOUND)
goto do_meta;
#endif
if (ret != 0) {
if (ret != ENOSPC)
goto out;
pgno = 0;
goto do_meta;
}
did_alloc = groupgrow;
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->pagelsn);
CHECK_LSN(dbenv, op, cmp_p, &LSN(pagep), &argp->pagelsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, dbc->priority, &pagep);
pagep->lsn = *lsnp;
} else if (cmp_n == 0 && DB_UNDO(op)) {
#ifdef HAVE_FTRUNCATE
if (argp->newalloc) {
if (pagep != NULL && (ret = __memp_fput(mpf,
pagep, DB_PRIORITY_VERY_LOW)) != 0)
goto out;
pagep = NULL;
if ((ret = __memp_ftruncate(mpf, argp->pgno, 0)) != 0)
goto out;
} else
#endif
{
REC_DIRTY(mpf, dbc->priority, &pagep);
pagep->lsn = argp->pagelsn;
}
}
if (pagep != NULL &&
(ret = __memp_fput(mpf, pagep, dbc->priority)) != 0)
goto out;
do_meta:
hcp = (HASH_CURSOR *)dbc->internal;
if ((ret = __ham_get_meta(dbc)) != 0)
goto out;
cmp_n = LOG_COMPARE(lsnp, &hcp->hdr->dbmeta.lsn);
cmp_p = LOG_COMPARE(&hcp->hdr->dbmeta.lsn, &argp->metalsn);
CHECK_LSN(dbenv, op, cmp_p, &hcp->hdr->dbmeta.lsn, &argp->metalsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, dbc->priority, &hcp->hdr);
++hcp->hdr->max_bucket;
if (groupgrow) {
hcp->hdr->low_mask = hcp->hdr->high_mask;
hcp->hdr->high_mask =
(argp->bucket + 1) | hcp->hdr->low_mask;
}
hcp->hdr->dbmeta.lsn = *lsnp;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, dbc->priority, &hcp->hdr);
hcp->hdr->max_bucket = argp->bucket;
if (groupgrow) {
hcp->hdr->high_mask = argp->bucket;
hcp->hdr->low_mask = hcp->hdr->high_mask >> 1;
}
hcp->hdr->dbmeta.lsn = argp->metalsn;
}
if (did_alloc &&
#ifdef HAVE_FTRUNCATE
!DB_UNDO(op) &&
#endif
hcp->hdr->spares[__db_log2(argp->bucket + 1) + 1] == PGNO_INVALID) {
REC_DIRTY(mpf, dbc->priority, &hcp->hdr);
hcp->hdr->spares[__db_log2(argp->bucket + 1) + 1] =
(argp->pgno - argp->bucket) - 1;
}
#ifdef HAVE_FTRUNCATE
if (cmp_n == 0 && groupgrow && DB_UNDO(op)) {
REC_DIRTY(mpf, dbc->priority, &hcp->hdr);
hcp->hdr->spares[
__db_log2(argp->bucket + 1) + 1] = PGNO_INVALID;
}
#endif
if (argp->mmpgno != argp->mpgno) {
if ((ret = __memp_fget(mpf, &argp->mmpgno, NULL,
DB_MPOOL_EDIT, &mmeta)) != 0) {
if (DB_UNDO(op) && ret == DB_PAGE_NOTFOUND)
ret = 0;
goto out;
}
cmp_n = LOG_COMPARE(lsnp, &mmeta->lsn);
cmp_p = LOG_COMPARE(&mmeta->lsn, &argp->mmetalsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, dbc->priority, &mmeta);
mmeta->lsn = *lsnp;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, dbc->priority, &mmeta);
mmeta->lsn = argp->mmetalsn;
}
} else {
mmeta = (DBMETA *)hcp->hdr;
REC_DIRTY(mpf, dbc->priority, &mmeta);
}
#ifdef HAVE_FTRUNCATE
if (cmp_n == 0 && DB_UNDO(op))
mmeta->last_pgno = argp->last_pgno;
else if (DB_REDO(op))
#endif
if (mmeta->last_pgno < pgno)
mmeta->last_pgno = pgno;
if (argp->mmpgno != argp->mpgno &&
(ret = __memp_fput(mpf, mmeta, dbc->priority)) != 0)
goto out;
mmeta = NULL;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (mmeta != NULL)
(void)__memp_fput(mpf, mmeta, dbc->priority);
if (dbc != NULL)
(void)__ham_release_meta(dbc);
if (ret == ENOENT && op == DB_TXN_BACKWARD_ALLOC)
ret = 0;
REC_CLOSE;
}
int
__ham_groupalloc_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__ham_groupalloc_args *argp;
DBMETA *mmeta;
DB_MPOOLFILE *mpf;
DB *file_dbp;
DBC *dbc;
PAGE *pagep;
db_pgno_t pgno;
int cmp_n, cmp_p, ret;
mmeta = NULL;
REC_PRINT(__ham_groupalloc_print);
REC_INTRO(__ham_groupalloc_read, 0, 0);
pgno = PGNO_BASE_MD;
if ((ret = __memp_fget(mpf, &pgno, NULL,
0, &mmeta)) != 0) {
if (DB_REDO(op)) {
ret = __db_pgerr(file_dbp, pgno, ret);
goto out;
} else
goto done;
}
cmp_n = LOG_COMPARE(lsnp, &LSN(mmeta));
cmp_p = LOG_COMPARE(&LSN(mmeta), &argp->meta_lsn);
CHECK_LSN(dbenv, op, cmp_p, &LSN(mmeta), &argp->meta_lsn);
pgno = argp->start_pgno + argp->num - 1;
if (DB_REDO(op)) {
if ((ret = __ham_alloc_pages(file_dbp, argp, lsnp)) != 0)
goto out;
if (cmp_p == 0) {
REC_DIRTY(mpf, file_dbp->priority, &mmeta);
LSN(mmeta) = *lsnp;
}
} else if (DB_UNDO(op)) {
pagep = NULL;
if ((ret = __memp_fget(mpf, &pgno, NULL,
DB_MPOOL_EDIT, &pagep)) == 0) {
if (LOG_COMPARE(&pagep->lsn, lsnp) != 0) {
if ((ret = __memp_fput(mpf, pagep,
DB_PRIORITY_VERY_LOW)) != 0)
goto out;
pagep = NULL;
}
} else if (ret != DB_PAGE_NOTFOUND)
goto out;
#ifdef HAVE_FTRUNCATE
if (pagep != NULL) {
if ((ret = __memp_fput(mpf,
pagep, DB_PRIORITY_VERY_LOW)) != 0)
goto out;
if ((ret =
__memp_ftruncate(mpf, argp->start_pgno, 0)) != 0)
goto out;
}
if (cmp_n == 0) {
REC_DIRTY(mpf, file_dbp->priority, &mmeta);
mmeta->last_pgno = argp->last_pgno;
}
pgno = 0;
#else
if (pagep != NULL) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
if (LOG_COMPARE(&pagep->lsn, lsnp) == 0)
ZERO_LSN(pagep->lsn);
if ((ret =
__memp_fput(mpf, pagep, file_dbp->priority)) != 0)
goto out;
}
if ((ret = __db_add_limbo(dbenv,
info, argp->fileid, argp->start_pgno, argp->num)) != 0)
goto out;
#endif
if (cmp_n == 0) {
REC_DIRTY(mpf, file_dbp->priority, &mmeta);
LSN(mmeta) = argp->meta_lsn;
}
}
if (pgno > mmeta->last_pgno) {
REC_DIRTY(mpf, file_dbp->priority, &mmeta);
mmeta->last_pgno = pgno;
}
done: if (ret == 0)
*lsnp = argp->prev_lsn;
ret = 0;
out: if (mmeta != NULL)
(void)__memp_fput(mpf, mmeta, file_dbp->priority);
if (ret == ENOENT && op == DB_TXN_BACKWARD_ALLOC)
ret = 0;
REC_CLOSE;
}
static int
__ham_alloc_pages(file_dbp, argp, lsnp)
DB *file_dbp;
__ham_groupalloc_args *argp;
DB_LSN *lsnp;
{
DB_MPOOLFILE *mpf;
PAGE *pagep;
db_pgno_t pgno;
int ret;
mpf = file_dbp->mpf;
pgno = argp->start_pgno + argp->num - 1;
if ((ret =
__memp_fget(mpf, &pgno, NULL, 0, &pagep)) == 0) {
if (NUM_ENT(pagep) == 0 && IS_ZERO_LSN(pagep->lsn))
goto reinit_page;
return (__memp_fput(mpf, pagep, file_dbp->priority));
}
if ((ret = __memp_fget(
mpf, &pgno, NULL, DB_MPOOL_CREATE, &pagep)) != 0)
return (__db_pgerr(file_dbp, pgno, ret));
reinit_page:
REC_DIRTY(mpf, file_dbp->priority, &pagep);
P_INIT(pagep, file_dbp->pgsize,
pgno, PGNO_INVALID, PGNO_INVALID, 0, P_HASH);
pagep->lsn = *lsnp;
out: return (__memp_fput(mpf, pagep, file_dbp->priority));
}
int
__ham_curadj_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__ham_curadj_args *argp;
DB_MPOOLFILE *mpf;
DB *file_dbp;
DBC *dbc;
int ret;
HASH_CURSOR *hcp;
db_ham_curadj mode, hamc_mode;
REC_PRINT(__ham_curadj_print);
REC_INTRO(__ham_curadj_read, 0, 1);
if (op != DB_TXN_ABORT)
goto done;
mode = (db_ham_curadj)argp->add;
switch (mode) {
case DB_HAM_CURADJ_DEL:
hamc_mode = DB_HAM_CURADJ_ADD;
break;
case DB_HAM_CURADJ_ADD:
hamc_mode = DB_HAM_CURADJ_DEL;
break;
case DB_HAM_CURADJ_ADDMOD:
hamc_mode = DB_HAM_CURADJ_DELMOD;
break;
case DB_HAM_CURADJ_DELMOD:
hamc_mode = DB_HAM_CURADJ_ADDMOD;
break;
default:
__db_errx(dbenv,
"Invalid flag in __ham_curadj_recover");
ret = EINVAL;
goto out;
}
hcp = (HASH_CURSOR *)dbc->internal;
hcp->pgno = argp->pgno;
hcp->indx = argp->indx;
hcp->dup_off = argp->dup_off;
hcp->order = argp->order;
if (mode == DB_HAM_CURADJ_DEL)
F_SET(hcp, H_DELETED);
(void)__hamc_update(dbc, argp->len, hamc_mode, argp->is_dup);
done: *lsnp = argp->prev_lsn;
out: REC_CLOSE;
}
int
__ham_chgpg_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__ham_chgpg_args *argp;
BTREE_CURSOR *opdcp;
DB_MPOOLFILE *mpf;
DB *file_dbp, *ldbp;
DBC *dbc;
int ret;
DBC *cp;
HASH_CURSOR *lcp;
u_int32_t order, indx;
REC_PRINT(__ham_chgpg_print);
REC_INTRO(__ham_chgpg_read, 0, 0);
if (op != DB_TXN_ABORT)
goto done;
indx = argp->old_indx;
order = argp->new_indx;
MUTEX_LOCK(dbenv, dbenv->mtx_dblist);
FIND_FIRST_DB_MATCH(dbenv, file_dbp, ldbp);
for (;
ldbp != NULL && ldbp->adj_fileid == file_dbp->adj_fileid;
ldbp = TAILQ_NEXT(ldbp, dblistlinks)) {
MUTEX_LOCK(dbenv, file_dbp->mutex);
TAILQ_FOREACH(cp, &ldbp->active_queue, links) {
lcp = (HASH_CURSOR *)cp->internal;
switch (argp->mode) {
case DB_HAM_DELFIRSTPG:
if (lcp->pgno != argp->new_pgno ||
MVCC_SKIP_CURADJ(cp, lcp->pgno))
break;
if (lcp->indx != indx ||
!F_ISSET(lcp, H_DELETED) ||
lcp->order >= order) {
lcp->pgno = argp->old_pgno;
if (lcp->indx == indx)
lcp->order -= order;
}
break;
case DB_HAM_DELMIDPG:
case DB_HAM_DELLASTPG:
if (lcp->pgno == argp->new_pgno &&
lcp->indx == indx &&
F_ISSET(lcp, H_DELETED) &&
lcp->order >= order &&
!MVCC_SKIP_CURADJ(cp, lcp->pgno)) {
lcp->pgno = argp->old_pgno;
lcp->order -= order;
lcp->indx = 0;
}
break;
case DB_HAM_CHGPG:
if (F_ISSET(lcp, H_DELETED))
break;
case DB_HAM_SPLIT:
if (lcp->pgno == argp->new_pgno &&
lcp->indx == argp->new_indx &&
!MVCC_SKIP_CURADJ(cp, lcp->pgno)) {
lcp->indx = argp->old_indx;
lcp->pgno = argp->old_pgno;
}
break;
case DB_HAM_DUP:
if (lcp->opd == NULL)
break;
opdcp = (BTREE_CURSOR *)lcp->opd->internal;
if (opdcp->pgno != argp->new_pgno ||
opdcp->indx != argp->new_indx ||
MVCC_SKIP_CURADJ(lcp->opd, opdcp->pgno))
break;
if (F_ISSET(opdcp, C_DELETED))
F_SET(lcp, H_DELETED);
MUTEX_UNLOCK(dbenv, file_dbp->mutex);
if ((ret = __dbc_close(lcp->opd)) != 0)
goto out;
MUTEX_LOCK(dbenv, file_dbp->mutex);
lcp->opd = NULL;
break;
}
}
MUTEX_UNLOCK(dbenv, file_dbp->mutex);
}
MUTEX_UNLOCK(dbenv, dbenv->mtx_dblist);
done: *lsnp = argp->prev_lsn;
out: REC_CLOSE;
}
int
__ham_metagroup_42_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__ham_metagroup_42_args *argp;
HASH_CURSOR *hcp;
DB *file_dbp;
DBMETA *mmeta;
DBC *dbc;
DB_MPOOLFILE *mpf;
PAGE *pagep;
db_pgno_t pgno;
u_int32_t flags;
int cmp_n, cmp_p, did_alloc, groupgrow, ret;
did_alloc = 0;
mmeta = NULL;
REC_PRINT(__ham_metagroup_42_print);
REC_INTRO(__ham_metagroup_42_read, 1, 1);
groupgrow =
(u_int32_t)(1 << __db_log2(argp->bucket + 1)) == argp->bucket + 1;
pgno = argp->pgno;
if (argp->newalloc)
pgno += argp->bucket;
flags = 0;
pagep = NULL;
LF_SET(DB_MPOOL_CREATE);
ret = __memp_fget(mpf, &pgno, NULL, flags, &pagep);
if (ret != 0) {
if (ret != ENOSPC)
goto out;
pgno = 0;
goto do_meta;
}
did_alloc = groupgrow;
cmp_n = LOG_COMPARE(lsnp, &LSN(pagep));
cmp_p = LOG_COMPARE(&LSN(pagep), &argp->pagelsn);
CHECK_LSN(dbenv, op, cmp_p, &LSN(pagep), &argp->pagelsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, dbc->priority, &pagep);
pagep->lsn = *lsnp;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, dbc->priority, &pagep);
pagep->lsn = argp->pagelsn;
}
if (pagep != NULL &&
(ret = __memp_fput(mpf, pagep, dbc->priority)) != 0)
goto out;
do_meta:
hcp = (HASH_CURSOR *)dbc->internal;
if ((ret = __ham_get_meta(dbc)) != 0)
goto out;
cmp_n = LOG_COMPARE(lsnp, &hcp->hdr->dbmeta.lsn);
cmp_p = LOG_COMPARE(&hcp->hdr->dbmeta.lsn, &argp->metalsn);
CHECK_LSN(dbenv, op, cmp_p, &hcp->hdr->dbmeta.lsn, &argp->metalsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, dbc->priority, &hcp->hdr);
++hcp->hdr->max_bucket;
if (groupgrow) {
hcp->hdr->low_mask = hcp->hdr->high_mask;
hcp->hdr->high_mask =
(argp->bucket + 1) | hcp->hdr->low_mask;
}
hcp->hdr->dbmeta.lsn = *lsnp;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, dbc->priority, &hcp->hdr);
hcp->hdr->max_bucket = argp->bucket;
if (groupgrow) {
hcp->hdr->high_mask = argp->bucket;
hcp->hdr->low_mask = hcp->hdr->high_mask >> 1;
}
hcp->hdr->dbmeta.lsn = argp->metalsn;
}
if (did_alloc &&
hcp->hdr->spares[__db_log2(argp->bucket + 1) + 1] == PGNO_INVALID) {
REC_DIRTY(mpf, dbc->priority, &hcp->hdr);
hcp->hdr->spares[__db_log2(argp->bucket + 1) + 1] =
(argp->pgno - argp->bucket) - 1;
}
if (argp->mmpgno != argp->mpgno) {
if ((ret = __memp_fget(mpf, &argp->mmpgno, NULL,
DB_MPOOL_EDIT, &mmeta)) != 0) {
if (DB_UNDO(op) && ret == DB_PAGE_NOTFOUND)
ret = 0;
goto out;
}
cmp_n = LOG_COMPARE(lsnp, &mmeta->lsn);
cmp_p = LOG_COMPARE(&mmeta->lsn, &argp->mmetalsn);
if (cmp_p == 0 && DB_REDO(op)) {
REC_DIRTY(mpf, dbc->priority, &mmeta);
mmeta->lsn = *lsnp;
} else if (cmp_n == 0 && DB_UNDO(op)) {
REC_DIRTY(mpf, dbc->priority, &mmeta);
mmeta->lsn = argp->mmetalsn;
}
} else {
mmeta = (DBMETA *)hcp->hdr;
REC_DIRTY(mpf, dbc->priority, &mmeta);
}
if (mmeta->last_pgno < pgno)
mmeta->last_pgno = pgno;
if (argp->mmpgno != argp->mpgno &&
(ret = __memp_fput(mpf, mmeta, dbc->priority)) != 0)
goto out;
mmeta = NULL;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (mmeta != NULL)
(void)__memp_fput(mpf, mmeta, dbc->priority);
if (dbc != NULL)
(void)__ham_release_meta(dbc);
if (ret == ENOENT && op == DB_TXN_BACKWARD_ALLOC)
ret = 0;
REC_CLOSE;
}
int
__ham_groupalloc_42_recover(dbenv, dbtp, lsnp, op, info)
DB_ENV *dbenv;
DBT *dbtp;
DB_LSN *lsnp;
db_recops op;
void *info;
{
__ham_groupalloc_42_args *argp;
DBMETA *mmeta;
DB_MPOOLFILE *mpf;
DB *file_dbp;
DBC *dbc;
PAGE *pagep;
db_pgno_t pgno;
int cmp_n, cmp_p, ret;
mmeta = NULL;
REC_PRINT(__ham_groupalloc_42_print);
REC_INTRO(__ham_groupalloc_42_read, 0, 0);
pgno = PGNO_BASE_MD;
if ((ret = __memp_fget(mpf, &pgno, NULL, 0, &mmeta)) != 0) {
if (DB_REDO(op)) {
ret = __db_pgerr(file_dbp, pgno, ret);
goto out;
} else
goto done;
}
cmp_n = LOG_COMPARE(lsnp, &LSN(mmeta));
cmp_p = LOG_COMPARE(&LSN(mmeta), &argp->meta_lsn);
CHECK_LSN(dbenv, op, cmp_p, &LSN(mmeta), &argp->meta_lsn);
pgno = argp->start_pgno + argp->num - 1;
if (DB_REDO(op)) {
if ((ret = __ham_alloc_pages_42(file_dbp, argp, lsnp)) != 0)
goto out;
if (cmp_p == 0) {
REC_DIRTY(mpf, file_dbp->priority, &mmeta);
LSN(mmeta) = *lsnp;
}
} else if (DB_UNDO(op)) {
pagep = NULL;
if ((ret = __memp_fget(mpf, &pgno, NULL, 0, &pagep)) == 0) {
if (LOG_COMPARE(&pagep->lsn, lsnp) != 0) {
if ((ret = __memp_fput(mpf, pagep,
DB_PRIORITY_VERY_LOW)) != 0)
goto out;
pagep = NULL;
}
} else if (ret != DB_PAGE_NOTFOUND)
goto out;
if (pagep != NULL) {
if (LOG_COMPARE(&pagep->lsn, lsnp) == 0) {
REC_DIRTY(mpf, file_dbp->priority, &pagep);
ZERO_LSN(pagep->lsn);
}
if ((ret =
__memp_fput(mpf, pagep, file_dbp->priority)) != 0)
goto out;
}
if ((ret = __db_add_limbo(dbenv,
info, argp->fileid, argp->start_pgno, argp->num)) != 0)
goto out;
if (cmp_n == 0) {
REC_DIRTY(mpf, file_dbp->priority, &mmeta);
LSN(mmeta) = argp->meta_lsn;
}
}
if (pgno > mmeta->last_pgno) {
REC_DIRTY(mpf, file_dbp->priority, &mmeta);
mmeta->last_pgno = pgno;
}
done: if (ret == 0)
*lsnp = argp->prev_lsn;
ret = 0;
out: if (mmeta != NULL)
(void)__memp_fput(mpf, mmeta, file_dbp->priority);
if (ret == ENOENT && op == DB_TXN_BACKWARD_ALLOC)
ret = 0;
REC_CLOSE;
}
static int
__ham_alloc_pages_42(dbp, argp, lsnp)
DB *dbp;
__ham_groupalloc_42_args *argp;
DB_LSN *lsnp;
{
DB_MPOOLFILE *mpf;
PAGE *pagep;
db_pgno_t pgno;
int ret;
mpf = dbp->mpf;
pgno = argp->start_pgno + argp->num - 1;
if ((ret = __memp_fget(mpf, &pgno, NULL, 0, &pagep)) == 0) {
if (NUM_ENT(pagep) == 0 && IS_ZERO_LSN(pagep->lsn))
goto reinit_page;
if ((ret = __memp_fput(mpf, pagep, dbp->priority)) != 0)
return (ret);
return (0);
}
if ((ret = __memp_fget(mpf, &pgno, NULL,
DB_MPOOL_CREATE | DB_MPOOL_DIRTY, &pagep)) != 0)
return (__db_pgerr(dbp, pgno, ret));
reinit_page:
P_INIT(pagep, dbp->pgsize, pgno, PGNO_INVALID, PGNO_INVALID, 0, P_HASH);
pagep->lsn = *lsnp;
if ((ret = __memp_fput(mpf, pagep, dbp->priority)) != 0)
return (ret);
return (0);
}