#include "db_config.h"
#ifndef lint
static const char revid[] = "$Id: hash_rec.c,v 1.2 2004/03/30 01:23:27 jtownsen Exp $";
#endif
#ifndef NO_SYSTEM_INCLUDES
#include <sys/types.h>
#include <string.h>
#endif
#include "db_int.h"
#include "dbinc/db_page.h"
#include "dbinc/db_shash.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 *));
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;
u_int32_t flags, opcode;
int cmp_n, cmp_p, ret, type;
pagep = NULL;
COMPQUIET(info, NULL);
REC_PRINT(__ham_insdel_print);
REC_INTRO(__ham_insdel_read, 1);
if ((ret = __memp_fget(mpf, &argp->pgno, 0, &pagep)) != 0) {
if (DB_UNDO(op)) {
goto done;
} else if ((ret = __memp_fget(mpf,
&argp->pgno, DB_MPOOL_CREATE, &pagep)) != 0)
goto out;
}
cmp_n = log_compare(lsnp, &LSN(pagep));
cmp_p = log_compare(&LSN(pagep), &argp->pagelsn);
CHECK_LSN(op, cmp_p, &LSN(pagep), &argp->pagelsn);
opcode = OPCODE_OF(argp->opcode);
flags = 0;
if ((opcode == DELPAIR && cmp_n == 0 && DB_UNDO(op)) ||
(opcode == PUTPAIR && cmp_p == 0 && DB_REDO(op))) {
if (opcode != DELPAIR ||
argp->ndx == (u_int32_t)NUM_ENT(pagep)) {
__ham_putitem(file_dbp, pagep, &argp->key,
DB_UNDO(op) || PAIR_ISKEYBIG(argp->opcode) ?
H_OFFPAGE : H_KEYDATA);
if (PAIR_ISDATADUP(argp->opcode))
type = H_DUPLICATE;
else if (DB_UNDO(op) || PAIR_ISDATABIG(argp->opcode))
type = H_OFFPAGE;
else
type = H_KEYDATA;
__ham_putitem(file_dbp, pagep, &argp->data, type);
} else
(void)__ham_reputpair(file_dbp, pagep,
argp->ndx, &argp->key, &argp->data);
LSN(pagep) = DB_REDO(op) ? *lsnp : argp->pagelsn;
flags = DB_MPOOL_DIRTY;
} else if ((opcode == DELPAIR && cmp_p == 0 && DB_REDO(op)) ||
(opcode == PUTPAIR && cmp_n == 0 && DB_UNDO(op))) {
__ham_dpair(file_dbp, pagep, argp->ndx);
LSN(pagep) = DB_REDO(op) ? *lsnp : argp->pagelsn;
flags = DB_MPOOL_DIRTY;
}
if ((ret = __memp_fput(mpf, pagep, flags)) != 0)
goto out;
pagep = NULL;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, pagep, 0);
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;
u_int32_t flags;
int cmp_n, cmp_p, ret;
pagep = NULL;
COMPQUIET(info, NULL);
REC_PRINT(__ham_newpage_print);
REC_INTRO(__ham_newpage_read, 1);
if ((ret = __memp_fget(mpf, &argp->new_pgno, 0, &pagep)) != 0) {
if (DB_UNDO(op)) {
ret = 0;
goto ppage;
} else if ((ret = __memp_fget(mpf,
&argp->new_pgno, DB_MPOOL_CREATE, &pagep)) != 0)
goto out;
}
cmp_n = log_compare(lsnp, &LSN(pagep));
cmp_p = log_compare(&LSN(pagep), &argp->pagelsn);
CHECK_LSN(op, cmp_p, &LSN(pagep), &argp->pagelsn);
flags = 0;
if ((cmp_p == 0 && DB_REDO(op) && argp->opcode == PUTOVFL) ||
(cmp_n == 0 && DB_UNDO(op) && argp->opcode == DELOVFL)) {
P_INIT(pagep, file_dbp->pgsize, argp->new_pgno,
argp->prev_pgno, argp->next_pgno, 0, P_HASH);
flags = DB_MPOOL_DIRTY;
} else if ((cmp_p == 0 && DB_REDO(op) && argp->opcode == DELOVFL) ||
(cmp_n == 0 && DB_UNDO(op) && argp->opcode == PUTOVFL)) {
flags = DB_MPOOL_DIRTY;
}
if (flags)
LSN(pagep) = DB_REDO(op) ? *lsnp : argp->pagelsn;
if ((ret = __memp_fput(mpf, pagep, flags)) != 0)
goto out;
pagep = NULL;
ppage: if (argp->prev_pgno != PGNO_INVALID) {
if ((ret =
__memp_fget(mpf, &argp->prev_pgno, 0, &pagep)) != 0) {
if (DB_UNDO(op)) {
ret = 0;
goto npage;
} else if ((ret = __memp_fget(mpf,
&argp->prev_pgno, DB_MPOOL_CREATE, &pagep)) != 0)
goto out;
}
cmp_n = log_compare(lsnp, &LSN(pagep));
cmp_p = log_compare(&LSN(pagep), &argp->prevlsn);
CHECK_LSN(op, cmp_p, &LSN(pagep), &argp->prevlsn);
flags = 0;
if ((cmp_p == 0 && DB_REDO(op) && argp->opcode == PUTOVFL) ||
(cmp_n == 0 && DB_UNDO(op) && argp->opcode == DELOVFL)) {
pagep->next_pgno = argp->new_pgno;
flags = DB_MPOOL_DIRTY;
} else if ((cmp_p == 0 &&
DB_REDO(op) && argp->opcode == DELOVFL) ||
(cmp_n == 0 && DB_UNDO(op) && argp->opcode == PUTOVFL)) {
pagep->next_pgno = argp->next_pgno;
flags = DB_MPOOL_DIRTY;
}
if (flags)
LSN(pagep) = DB_REDO(op) ? *lsnp : argp->prevlsn;
if ((ret = __memp_fput(mpf, pagep, flags)) != 0)
goto out;
pagep = NULL;
}
npage: if (argp->next_pgno != PGNO_INVALID) {
if ((ret =
__memp_fget(mpf, &argp->next_pgno, 0, &pagep)) != 0) {
if (DB_UNDO(op)) {
goto done;
} else if ((ret = __memp_fget(mpf,
&argp->next_pgno, DB_MPOOL_CREATE, &pagep)) != 0)
goto out;
}
cmp_n = log_compare(lsnp, &LSN(pagep));
cmp_p = log_compare(&LSN(pagep), &argp->nextlsn);
CHECK_LSN(op, cmp_p, &LSN(pagep), &argp->nextlsn);
flags = 0;
if ((cmp_p == 0 && DB_REDO(op) && argp->opcode == PUTOVFL) ||
(cmp_n == 0 && DB_UNDO(op) && argp->opcode == DELOVFL)) {
pagep->prev_pgno = argp->new_pgno;
flags = DB_MPOOL_DIRTY;
} else if ((cmp_p == 0 &&
DB_REDO(op) && argp->opcode == DELOVFL) ||
(cmp_n == 0 && DB_UNDO(op) && argp->opcode == PUTOVFL)) {
pagep->prev_pgno = argp->prev_pgno;
flags = DB_MPOOL_DIRTY;
}
if (flags)
LSN(pagep) = DB_REDO(op) ? *lsnp : argp->nextlsn;
if ((ret = __memp_fput(mpf, pagep, flags)) != 0)
goto out;
pagep = NULL;
}
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, pagep, 0);
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 flags;
int32_t grow;
int cmp_n, cmp_p, ret;
u_int8_t *hk;
pagep = NULL;
COMPQUIET(info, NULL);
REC_PRINT(__ham_replace_print);
REC_INTRO(__ham_replace_read, 1);
if ((ret = __memp_fget(mpf, &argp->pgno, 0, &pagep)) != 0) {
if (DB_UNDO(op)) {
goto done;
} else if ((ret = __memp_fget(mpf,
&argp->pgno, DB_MPOOL_CREATE, &pagep)) != 0)
goto out;
}
cmp_n = log_compare(lsnp, &LSN(pagep));
cmp_p = log_compare(&LSN(pagep), &argp->pagelsn);
CHECK_LSN(op, cmp_p, &LSN(pagep), &argp->pagelsn);
memset(&dbt, 0, sizeof(dbt));
flags = 0;
grow = 1;
if (cmp_p == 0 && DB_REDO(op)) {
dbt.data = argp->newitem.data;
dbt.size = argp->newitem.size;
grow = argp->newitem.size - argp->olditem.size;
LSN(pagep) = *lsnp;
flags = DB_MPOOL_DIRTY;
} else if (cmp_n == 0 && DB_UNDO(op)) {
dbt.data = argp->olditem.data;
dbt.size = argp->olditem.size;
grow = argp->olditem.size - argp->newitem.size;
LSN(pagep) = argp->pagelsn;
flags = DB_MPOOL_DIRTY;
}
if (flags) {
__ham_onpage_replace(file_dbp, pagep,
argp->ndx, argp->off, grow, &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, flags)) != 0)
goto out;
pagep = NULL;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, pagep, 0);
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;
u_int32_t flags;
int cmp_n, cmp_p, ret;
pagep = NULL;
COMPQUIET(info, NULL);
REC_PRINT(__ham_splitdata_print);
REC_INTRO(__ham_splitdata_read, 1);
if ((ret = __memp_fget(mpf, &argp->pgno, 0, &pagep)) != 0) {
if (DB_UNDO(op)) {
goto done;
} else if ((ret = __memp_fget(mpf,
&argp->pgno, DB_MPOOL_CREATE, &pagep)) != 0)
goto out;
}
cmp_n = log_compare(lsnp, &LSN(pagep));
cmp_p = log_compare(&LSN(pagep), &argp->pagelsn);
CHECK_LSN(op, cmp_p, &LSN(pagep), &argp->pagelsn);
flags = 0;
if (cmp_p == 0 && DB_REDO(op)) {
if (argp->opcode == SPLITNEW)
memcpy(pagep, argp->pageimage.data,
argp->pageimage.size);
LSN(pagep) = *lsnp;
flags = DB_MPOOL_DIRTY;
} else if (cmp_n == 0 && DB_UNDO(op)) {
if (argp->opcode == SPLITOLD) {
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;
flags = DB_MPOOL_DIRTY;
}
if ((ret = __memp_fput(mpf, pagep, flags)) != 0)
goto out;
pagep = NULL;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, pagep, 0);
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;
u_int32_t flags;
int cmp_n, cmp_p, ret;
pagep = NULL;
COMPQUIET(info, NULL);
REC_PRINT(__ham_copypage_print);
REC_INTRO(__ham_copypage_read, 1);
flags = 0;
if ((ret = __memp_fget(mpf, &argp->pgno, 0, &pagep)) != 0) {
if (DB_UNDO(op)) {
ret = 0;
goto donext;
} else if ((ret = __memp_fget(mpf,
&argp->pgno, DB_MPOOL_CREATE, &pagep)) != 0)
goto out;
}
cmp_n = log_compare(lsnp, &LSN(pagep));
cmp_p = log_compare(&LSN(pagep), &argp->pagelsn);
CHECK_LSN(op, cmp_p, &LSN(pagep), &argp->pagelsn);
if (cmp_p == 0 && DB_REDO(op)) {
memcpy(pagep, argp->page.data, argp->page.size);
PGNO(pagep) = argp->pgno;
PREV_PGNO(pagep) = PGNO_INVALID;
LSN(pagep) = *lsnp;
flags = DB_MPOOL_DIRTY;
} else if (cmp_n == 0 && DB_UNDO(op)) {
P_INIT(pagep, file_dbp->pgsize, argp->pgno, PGNO_INVALID,
argp->next_pgno, 0, P_HASH);
LSN(pagep) = argp->pagelsn;
flags = DB_MPOOL_DIRTY;
}
if ((ret = __memp_fput(mpf, pagep, flags)) != 0)
goto out;
pagep = NULL;
donext:
if ((ret = __memp_fget(mpf, &argp->next_pgno, 0, &pagep)) != 0) {
if (DB_UNDO(op)) {
ret = 0;
goto do_nn;
} else if ((ret = __memp_fget(mpf,
&argp->next_pgno, DB_MPOOL_CREATE, &pagep)) != 0)
goto out;
}
cmp_n = log_compare(lsnp, &LSN(pagep));
cmp_p = log_compare(&LSN(pagep), &argp->nextlsn);
CHECK_LSN(op, cmp_p, &LSN(pagep), &argp->nextlsn);
flags = 0;
if (cmp_p == 0 && DB_REDO(op)) {
LSN(pagep) = *lsnp;
flags = DB_MPOOL_DIRTY;
} else if (cmp_n == 0 && DB_UNDO(op)) {
memcpy(pagep, argp->page.data, argp->page.size);
flags = DB_MPOOL_DIRTY;
}
if ((ret = __memp_fput(mpf, pagep, flags)) != 0)
goto out;
pagep = NULL;
do_nn: if (argp->nnext_pgno == PGNO_INVALID)
goto done;
if ((ret = __memp_fget(mpf, &argp->nnext_pgno, 0, &pagep)) != 0) {
if (DB_UNDO(op)) {
goto done;
} else if ((ret = __memp_fget(mpf,
&argp->nnext_pgno, DB_MPOOL_CREATE, &pagep)) != 0)
goto out;
}
cmp_n = log_compare(lsnp, &LSN(pagep));
cmp_p = log_compare(&LSN(pagep), &argp->nnextlsn);
CHECK_LSN(op, cmp_p, &LSN(pagep), &argp->nnextlsn);
flags = 0;
if (cmp_p == 0 && DB_REDO(op)) {
PREV_PGNO(pagep) = argp->pgno;
LSN(pagep) = *lsnp;
flags = DB_MPOOL_DIRTY;
} else if (cmp_n == 0 && DB_UNDO(op)) {
PREV_PGNO(pagep) = argp->next_pgno;
LSN(pagep) = argp->nnextlsn;
flags = DB_MPOOL_DIRTY;
}
if ((ret = __memp_fput(mpf, pagep, flags)) != 0)
goto out;
pagep = NULL;
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (pagep != NULL)
(void)__memp_fput(mpf, pagep, 0);
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, mmeta_flags;
int cmp_n, cmp_p, did_recover, groupgrow, ret;
COMPQUIET(info, NULL);
mmeta_flags = 0;
mmeta = NULL;
REC_PRINT(__ham_metagroup_print);
REC_INTRO(__ham_metagroup_read, 1);
groupgrow = (u_int32_t)(1 << __db_log2(argp->bucket + 1)) ==
argp->bucket + 1;
pgno = argp->pgno;
if (argp->newalloc)
pgno += argp->bucket;
if ((ret = __memp_fget(mpf, &pgno, DB_MPOOL_CREATE, &pagep)) != 0) {
if (ret != ENOSPC)
goto out;
pgno = 0;
groupgrow = 0;
goto do_meta;
}
cmp_n = log_compare(lsnp, &LSN(pagep));
cmp_p = log_compare(&LSN(pagep), &argp->pagelsn);
CHECK_LSN(op, cmp_p, &LSN(pagep), &argp->pagelsn);
flags = 0;
if ((cmp_p == 0 && DB_REDO(op)) || (cmp_n == 0 && DB_UNDO(op))) {
if (DB_REDO(op))
pagep->lsn = *lsnp;
else
pagep->lsn = argp->pagelsn;
flags = DB_MPOOL_DIRTY;
}
if ((ret = __memp_fput(mpf, pagep, flags)) != 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(op, cmp_p, &hcp->hdr->dbmeta.lsn, &argp->metalsn);
did_recover = 0;
if (cmp_p == 0 && DB_REDO(op)) {
++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;
did_recover = 1;
} else if (cmp_n == 0 && DB_UNDO(op)) {
--hcp->hdr->max_bucket;
if (groupgrow) {
hcp->hdr->high_mask = hcp->hdr->low_mask;
hcp->hdr->low_mask = hcp->hdr->high_mask >> 1;
}
hcp->hdr->dbmeta.lsn = argp->metalsn;
did_recover = 1;
}
if (groupgrow &&
hcp->hdr->spares[__db_log2(argp->bucket + 1) + 1] == PGNO_INVALID) {
hcp->hdr->spares[__db_log2(argp->bucket + 1) + 1] =
argp->pgno - argp->bucket - 1;
did_recover = 1;
}
if (argp->mmpgno != argp->mpgno) {
if ((ret = __memp_fget(mpf, &argp->mmpgno, 0, &mmeta)) != 0)
goto out;
mmeta_flags = 0;
cmp_n = log_compare(lsnp, &mmeta->lsn);
cmp_p = log_compare(&mmeta->lsn, &argp->mmetalsn);
if (cmp_p == 0 && DB_REDO(op)) {
mmeta->lsn = *lsnp;
mmeta_flags = DB_MPOOL_DIRTY;
} else if (cmp_n == 0 && DB_UNDO(op)) {
mmeta->lsn = argp->mmetalsn;
mmeta_flags = DB_MPOOL_DIRTY;
}
} else
mmeta = (DBMETA *)hcp->hdr;
if (mmeta->last_pgno < pgno)
mmeta->last_pgno = pgno;
mmeta_flags = DB_MPOOL_DIRTY;
if (argp->mmpgno != argp->mpgno &&
(ret = __memp_fput(mpf, mmeta, mmeta_flags)) != 0)
goto out;
mmeta = NULL;
if (did_recover)
F_SET(hcp, H_DIRTY);
done: *lsnp = argp->prev_lsn;
ret = 0;
out: if (mmeta != NULL)
(void)__memp_fput(mpf, mmeta, 0);
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, modified, ret;
mmeta = NULL;
modified = 0;
REC_PRINT(__ham_groupalloc_print);
REC_INTRO(__ham_groupalloc_read, 0);
pgno = PGNO_BASE_MD;
if ((ret = __memp_fget(mpf, &pgno, 0, &mmeta)) != 0) {
if (DB_REDO(op)) {
ret = __db_pgerr(file_dbp, pgno, ret);
goto out;
} else {
ret = 0;
goto done;
}
}
cmp_n = log_compare(lsnp, &LSN(mmeta));
cmp_p = log_compare(&LSN(mmeta), &argp->meta_lsn);
CHECK_LSN(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) {
LSN(mmeta) = *lsnp;
modified = 1;
}
} else if (DB_UNDO(op)) {
if ((ret = __memp_fget(mpf, &pgno, 0, &pagep)) == 0) {
if (log_compare(&pagep->lsn, lsnp) == 0)
ZERO_LSN(pagep->lsn);
if ((ret =
__memp_fput(mpf, pagep, DB_MPOOL_DIRTY)) != 0)
goto out;
} else if (ret != DB_PAGE_NOTFOUND)
goto out;
if ((ret = __db_add_limbo(dbenv,
info, argp->fileid, argp->start_pgno, argp->num)) != 0)
goto out;
if (cmp_n == 0) {
LSN(mmeta) = argp->meta_lsn;
modified = 1;
}
}
if (pgno > mmeta->last_pgno) {
mmeta->last_pgno = pgno;
modified = 1;
}
done: if (ret == 0)
*lsnp = argp->prev_lsn;
out: if (mmeta != NULL)
(void)__memp_fput(mpf, mmeta, modified ? DB_MPOOL_DIRTY : 0);
if (ret == ENOENT && op == DB_TXN_BACKWARD_ALLOC)
ret = 0;
REC_CLOSE;
}
static int
__ham_alloc_pages(dbp, argp, lsnp)
DB *dbp;
__ham_groupalloc_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, 0, &pagep)) == 0) {
if (NUM_ENT(pagep) == 0 && IS_ZERO_LSN(pagep->lsn))
goto reinit_page;
if ((ret = __memp_fput(mpf, pagep, 0)) != 0)
return (ret);
return (0);
}
if ((ret = __memp_fget(mpf, &pgno, DB_MPOOL_CREATE, &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, DB_MPOOL_DIRTY)) != 0)
return (ret);
return (0);
}
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;
COMPQUIET(info, NULL);
REC_PRINT(__ham_curadj_print);
REC_INTRO(__ham_curadj_read, 0);
if (op != DB_TXN_ABORT)
goto done;
hcp = (HASH_CURSOR *)dbc->internal;
hcp->pgno = argp->pgno;
hcp->indx = argp->indx;
hcp->dup_off = argp->dup_off;
hcp->order = argp->order;
if (!argp->add)
F_SET(hcp, H_DELETED);
(void)__ham_c_update(dbc, argp->len, !argp->add, 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;
COMPQUIET(info, NULL);
REC_PRINT(__ham_chgpg_print);
REC_INTRO(__ham_chgpg_read, 0);
if (op != DB_TXN_ABORT)
goto done;
indx = argp->old_indx;
order = argp->new_indx;
MUTEX_THREAD_LOCK(dbenv, dbenv->dblist_mutexp);
for (ldbp = __dblist_get(dbenv, file_dbp->adj_fileid);
ldbp != NULL && ldbp->adj_fileid == file_dbp->adj_fileid;
ldbp = LIST_NEXT(ldbp, dblistlinks)) {
MUTEX_THREAD_LOCK(dbenv, file_dbp->mutexp);
for (cp = TAILQ_FIRST(&ldbp->active_queue); cp != NULL;
cp = TAILQ_NEXT(cp, links)) {
lcp = (HASH_CURSOR *)cp->internal;
switch (argp->mode) {
case DB_HAM_DELFIRSTPG:
if (lcp->pgno != argp->new_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) {
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) {
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)
break;
if (F_ISSET(opdcp, C_DELETED))
F_SET(lcp, H_DELETED);
MUTEX_THREAD_UNLOCK(dbenv, file_dbp->mutexp);
if ((ret = __db_c_close(lcp->opd)) != 0)
goto out;
MUTEX_THREAD_LOCK(dbenv, file_dbp->mutexp);
lcp->opd = NULL;
break;
}
}
MUTEX_THREAD_UNLOCK(dbenv, file_dbp->mutexp);
}
MUTEX_THREAD_UNLOCK(dbenv, dbenv->dblist_mutexp);
done: *lsnp = argp->prev_lsn;
out: REC_CLOSE;
}