#include "db_config.h"
#include "db_int.h"
#include "dbinc/db_page.h"
#include "dbinc/db_verify.h"
#include "dbinc/db_am.h"
#include "dbinc/mp.h"
#include "dbinc/qam.h"
int
__qam_vrfy_meta(dbp, vdp, meta, pgno, flags)
DB *dbp;
VRFY_DBINFO *vdp;
QMETA *meta;
db_pgno_t pgno;
u_int32_t flags;
{
DB_ENV *dbenv;
QUEUE *qp;
VRFY_PAGEINFO *pip;
db_pgno_t *extents, extid, first, last;
size_t len;
int count, i, isbad, nextents, ret, t_ret;
char *buf, **names;
COMPQUIET(count, 0);
dbenv = dbp->dbenv;
qp = (QUEUE *)dbp->q_internal;
extents = NULL;
first = last = 0;
isbad = 0;
buf = NULL;
names = NULL;
if ((ret = __db_vrfy_getpageinfo(vdp, pgno, &pip)) != 0)
return (ret);
if (!F_ISSET(pip, VRFY_INCOMPLETE))
EPRINT((dbenv, "Page %lu: queue databases must be one-per-file",
(u_long)pgno));
if (DB_ALIGN(meta->re_len + sizeof(QAMDATA) - 1, sizeof(u_int32_t)) *
meta->rec_page + QPAGE_SZ(dbp) > dbp->pgsize) {
EPRINT((dbenv,
"Page %lu: queue record length %lu too high for page size and recs/page",
(u_long)pgno, (u_long)meta->re_len));
ret = DB_VERIFY_FATAL;
goto err;
} else {
vdp->re_pad = meta->re_pad;
qp->re_pad = (int)meta->re_pad;
qp->re_len = vdp->re_len = meta->re_len;
qp->rec_page = vdp->rec_page = meta->rec_page;
qp->page_ext = vdp->page_ext = meta->page_ext;
}
if (F_ISSET(vdp, VRFY_QMETA_SET)) {
isbad = 1;
EPRINT((dbenv,
"Page %lu: database contains multiple Queue metadata pages",
(u_long)pgno));
goto err;
}
F_SET(vdp, VRFY_QMETA_SET);
qp->page_ext = meta->page_ext;
dbp->pgsize = meta->dbmeta.pagesize;
qp->q_meta = pgno;
qp->q_root = pgno + 1;
vdp->first_recno = meta->first_recno;
vdp->last_recno = meta->cur_recno;
if (qp->page_ext != 0) {
first = QAM_RECNO_EXTENT(dbp, vdp->first_recno);
last = QAM_RECNO_EXTENT(dbp, vdp->last_recno);
}
if ((ret = __db_appname(dbenv,
DB_APP_DATA, qp->dir, 0, NULL, &buf)) != 0)
goto err;
if ((ret = __os_dirlist(dbenv, buf, &names, &count)) != 0)
goto err;
__os_free(dbenv, buf);
buf = NULL;
len = strlen(QUEUE_EXTENT_HEAD) + strlen(qp->name) + 1;
if ((ret = __os_malloc(dbenv, len, &buf)) != 0)
goto err;
len = (size_t)snprintf(buf, len, QUEUE_EXTENT_HEAD, qp->name);
for (i = nextents = 0; i < count; i++) {
if (strncmp(names[i], buf, len) == 0) {
extid = (db_pgno_t)strtoul(&names[i][len], NULL, 10);
if (qp->page_ext != 0 &&
(last > first ?
(extid >= first && extid <= last) :
(extid >= first || extid <= last)))
continue;
if (extents == NULL && (ret = __os_malloc(
dbenv, (size_t)(count - i) * sizeof(extid),
&extents)) != 0)
goto err;
extents[nextents] = extid;
nextents++;
}
}
if (nextents > 0)
__db_errx(dbenv,
"Warning: %d extra extent files found", nextents);
vdp->nextents = nextents;
vdp->extents = extents;
err: if ((t_ret = __db_vrfy_putpageinfo(dbenv, vdp, pip)) != 0 && ret == 0)
ret = t_ret;
if (names != NULL)
__os_dirfree(dbenv, names, count);
if (buf != NULL)
__os_free(dbenv, buf);
if (ret != 0 && extents != NULL)
__os_free(dbenv, extents);
if (LF_ISSET(DB_SALVAGE) &&
(t_ret = __db_salvage_markdone(vdp, pgno)) != 0 && ret == 0)
ret = t_ret;
return (ret == 0 && isbad == 1 ? DB_VERIFY_BAD : ret);
}
int
__qam_vrfy_data(dbp, vdp, h, pgno, flags)
DB *dbp;
VRFY_DBINFO *vdp;
QPAGE *h;
db_pgno_t pgno;
u_int32_t flags;
{
DB fakedb;
struct __queue fakeq;
QAMDATA *qp;
db_recno_t i;
fakedb.q_internal = &fakeq;
fakedb.flags = dbp->flags;
fakeq.re_len = vdp->re_len;
for (i = 0; i < vdp->rec_page; i++) {
qp = QAM_GET_RECORD(&fakedb, h, i);
if ((u_int8_t *)qp >= (u_int8_t *)h + dbp->pgsize) {
EPRINT((dbp->dbenv,
"Page %lu: queue record %lu extends past end of page",
(u_long)pgno, (u_long)i));
return (DB_VERIFY_BAD);
}
if (qp->flags & ~(QAM_VALID | QAM_SET)) {
EPRINT((dbp->dbenv,
"Page %lu: queue record %lu has bad flags (%#lx)",
(u_long)pgno, (u_long)i, (u_long)qp->flags));
return (DB_VERIFY_BAD);
}
}
return (0);
}
int
__qam_vrfy_structure(dbp, vdp, flags)
DB *dbp;
VRFY_DBINFO *vdp;
u_int32_t flags;
{
VRFY_PAGEINFO *pip;
db_pgno_t i;
int ret, isbad;
isbad = 0;
if ((ret = __db_vrfy_getpageinfo(vdp, PGNO_BASE_MD, &pip)) != 0)
return (ret);
if (pip->type != P_QAMMETA) {
EPRINT((dbp->dbenv,
"Page %lu: queue database has no meta page",
(u_long)PGNO_BASE_MD));
isbad = 1;
goto err;
}
if ((ret = __db_vrfy_pgset_inc(vdp->pgset, 0)) != 0)
goto err;
for (i = 1; i <= vdp->last_pgno; i++) {
if (!LF_ISSET(DB_SALVAGE))
__db_vrfy_struct_feedback(dbp, vdp);
if ((ret = __db_vrfy_putpageinfo(dbp->dbenv, vdp, pip)) != 0 ||
(ret = __db_vrfy_getpageinfo(vdp, i, &pip)) != 0)
return (ret);
if (!F_ISSET(pip, VRFY_IS_ALLZEROES) &&
pip->type != P_QAMDATA) {
EPRINT((dbp->dbenv,
"Page %lu: queue database page of incorrect type %lu",
(u_long)i, (u_long)pip->type));
isbad = 1;
goto err;
} else if ((ret = __db_vrfy_pgset_inc(vdp->pgset, i)) != 0)
goto err;
}
err: if ((ret = __db_vrfy_putpageinfo(dbp->dbenv, vdp, pip)) != 0)
return (ret);
return (isbad == 1 ? DB_VERIFY_BAD : 0);
}
int
__qam_vrfy_walkqueue(dbp, vdp, handle, callback, flags)
DB *dbp;
VRFY_DBINFO *vdp;
void *handle;
int (*callback) __P((void *, const void *));
u_int32_t flags;
{
DB_ENV *dbenv;
PAGE *h;
QUEUE *qp;
VRFY_PAGEINFO *pip;
db_pgno_t first, i, last, pg_ext, stop;
int isbad, nextents, ret, t_ret;
COMPQUIET(h, NULL);
dbenv = dbp->dbenv;
qp = dbp->q_internal;
pip = NULL;
pg_ext = qp->page_ext;
isbad = ret = t_ret = 0;
if (pg_ext == 0)
return (0);
first = QAM_RECNO_PAGE(dbp, vdp->first_recno);
last = QAM_RECNO_PAGE(dbp, vdp->last_recno);
i = first;
if (first > last)
stop = QAM_RECNO_PAGE(dbp, UINT32_MAX);
else
stop = last;
nextents = vdp->nextents;
begin: for (; i <= stop; i++) {
if (LF_ISSET(DB_SALVAGE) && (__db_salvage_isdone(vdp, i) != 0))
continue;
if ((t_ret = __qam_fget(dbp, &i, NULL, 0, &h)) != 0) {
if (t_ret == ENOENT || t_ret == DB_PAGE_NOTFOUND) {
i += (pg_ext - ((i - 1) % pg_ext)) - 1;
continue;
}
if (LF_ISSET(DB_SALVAGE)) {
if (ret == 0)
ret = t_ret;
continue;
} else
return (t_ret);
}
if (LF_ISSET(DB_SALVAGE)) {
if ((t_ret = __db_salvage(dbp,
vdp, i, h, handle, callback, flags)) != 0) {
if (ret == 0)
ret = t_ret;
isbad = 1;
}
} else {
if ((ret = __db_vrfy_common(dbp,
vdp, h, i, flags)) == DB_VERIFY_BAD)
isbad = 1;
else if (ret != 0)
goto err;
__db_vrfy_struct_feedback(dbp, vdp);
if ((ret = __db_vrfy_getpageinfo(vdp, i, &pip)) != 0)
return (ret);
if (F_ISSET(pip, VRFY_IS_ALLZEROES))
goto put;
if (pip->type != P_QAMDATA) {
EPRINT((dbenv,
"Page %lu: queue database page of incorrect type %lu",
(u_long)i, (u_long)pip->type));
isbad = 1;
goto err;
}
if ((ret = __db_vrfy_pgset_inc(vdp->pgset, i)) != 0)
goto err;
if ((ret = __qam_vrfy_data(dbp, vdp,
(QPAGE *)h, i, flags)) == DB_VERIFY_BAD)
isbad = 1;
else if (ret != 0)
goto err;
put: if ((ret = __db_vrfy_putpageinfo(dbenv, vdp, pip)) != 0)
goto err;
pip = NULL;
}
if ((t_ret = __qam_fput(dbp, i, h, dbp->priority)) != 0) {
if (LF_ISSET(DB_SALVAGE)) {
if (ret == 0)
ret = t_ret;
continue;
} else
return (t_ret);
}
}
if (first > last) {
i = 1;
stop = last;
first = last;
goto begin;
}
if (LF_ISSET(DB_SALVAGE) && nextents != 0) {
nextents--;
i = 1 +
vdp->extents[nextents] * vdp->page_ext;
stop = i + vdp->page_ext;
goto begin;
}
if (0) {
err: if ((t_ret = __qam_fput(dbp, i, h, dbp->priority)) != 0)
return (ret == 0 ? t_ret : ret);
if (pip != NULL &&
(t_ret = __db_vrfy_putpageinfo(dbenv, vdp, pip)) != 0)
return (ret == 0 ? t_ret : ret);
}
return ((isbad == 1 && ret == 0) ? DB_VERIFY_BAD : ret);
}
int
__qam_salvage(dbp, vdp, pgno, h, handle, callback, flags)
DB *dbp;
VRFY_DBINFO *vdp;
db_pgno_t pgno;
PAGE *h;
void *handle;
int (*callback) __P((void *, const void *));
u_int32_t flags;
{
DBT dbt, key;
QAMDATA *qp, *qep;
db_recno_t recno;
int ret, err_ret, t_ret;
u_int32_t pagesize, qlen;
u_int32_t i;
memset(&dbt, 0, sizeof(DBT));
memset(&key, 0, sizeof(DBT));
err_ret = ret = 0;
pagesize = (u_int32_t)dbp->mpf->mfp->stat.st_pagesize;
qlen = ((QUEUE *)dbp->q_internal)->re_len;
dbt.size = qlen;
key.data = &recno;
key.size = sizeof(recno);
recno = (pgno - 1) * QAM_RECNO_PER_PAGE(dbp) + 1;
i = 0;
qep = (QAMDATA *)((u_int8_t *)h + pagesize - qlen);
for (qp = QAM_GET_RECORD(dbp, h, i); qp < qep;
recno++, i++, qp = QAM_GET_RECORD(dbp, h, i)) {
if (F_ISSET(qp, ~(QAM_VALID|QAM_SET)))
continue;
if (!F_ISSET(qp, QAM_SET))
continue;
if (!LF_ISSET(DB_AGGRESSIVE) && !F_ISSET(qp, QAM_VALID))
continue;
dbt.data = qp->data;
if ((ret = __db_vrfy_prdbt(&key,
0, " ", handle, callback, 1, vdp)) != 0)
err_ret = ret;
if ((ret = __db_vrfy_prdbt(&dbt,
0, " ", handle, callback, 0, vdp)) != 0)
err_ret = ret;
}
if ((t_ret = __db_salvage_markdone(vdp, pgno)) != 0)
return (t_ret);
return ((ret == 0 && err_ret != 0) ? err_ret : ret);
}