qam_stat.c

Go to the documentation of this file.

/*-
 * See the file LICENSE for redistribution information.
 *
 * Copyright (c) 1999, 2000
 *      Sleepycat Software.  All rights reserved.
 */

#include "config.h"

#ifndef lint
static const char revid[] = "$Id: qam__stat_8c-source.html,v 1.1 2008/06/08 10:21:46 sebdiaz Exp $";
#endif /* not lint */

#ifndef NO_SYSTEM_INCLUDES
#include <sys/types.h>

#include <string.h>
#endif

#include "db_int.h"
#include "db_page.h"
#include "db_shash.h"
#include "db_am.h"
#include "lock.h"
#include "qam.h"

/*
 * CDB___qam_stat --
 *      Gather/print the qam statistics
 *
 * PUBLIC: int CDB___qam_stat __P((DB *, void *, void *(*)(size_t), u_int32_t));
 */
int
CDB___qam_stat(dbp, spp, db_malloc, flags)
        DB *dbp;
        void *spp;
        void *(*db_malloc) __P((size_t));
        u_int32_t flags;
{
        QUEUE *t;
        DBC *dbc;
        DB_LOCK lock;
        DB_QUEUE_STAT *sp;
        PAGE *h;
        QAMDATA *qp, *ep;
        QMETA *meta;
        db_indx_t indx;
        db_pgno_t lastpgno, pgno;
        u_int32_t re_len;
        int ret, t_ret;

        PANIC_CHECK(dbp->dbenv);
        DB_ILLEGAL_BEFORE_OPEN(dbp, "DB->stat");

        t = dbp->q_internal;
        sp = NULL;
        lock.off = LOCK_INVALID;

        /* Check for invalid flags. */
        if ((ret = CDB___db_statchk(dbp, flags)) != 0)
                return (ret);

        if (spp == NULL)
                return (0);

        /* Acquire a cursor. */
        if ((ret = dbp->cursor(dbp, NULL, &dbc, 0)) != 0)
                return (ret);

        DEBUG_LWRITE(dbc, NULL, "qam_stat", NULL, NULL, flags);

        /* Allocate and clear the structure. */
        if ((ret = CDB___os_malloc(dbp->dbenv, sizeof(*sp), db_malloc, &sp)) != 0)
                goto err;
        memset(sp, 0, sizeof(*sp));

        re_len = ((QUEUE *)dbp->q_internal)->re_len;
        if (flags == DB_CACHED_COUNTS) {
                if ((ret = CDB___db_lget(dbc,
                    0, t->q_meta, DB_LOCK_READ, 0, &lock)) != 0)
                        goto err;
                if ((ret =
                    CDB_memp_fget(dbp->mpf, &t->q_meta, 0, (PAGE **)&meta)) != 0)
                        goto err;
                sp->qs_nkeys = meta->dbmeta.key_count;
                sp->qs_ndata = meta->dbmeta.record_count;

                goto done;
        }

        /* Determine the last page of the database. */
        if ((ret = CDB_memp_fget(dbp->mpf, &lastpgno, DB_MPOOL_LAST, &h)) != 0)
                goto err;
        if ((ret = CDB_memp_fput(dbp->mpf, h, 0)) != 0)
                goto err;

        /* Walk through the pages and count. */
        for (pgno = t->q_root; pgno <= lastpgno; ++pgno) {
                if ((ret =
                    CDB___db_lget(dbc, 0, pgno, DB_LOCK_READ, 0, &lock)) != 0)
                        goto err;
                if ((ret = CDB_memp_fget(dbp->mpf, &pgno, 0, &h)) != 0)
                        goto err;

                ++sp->qs_pages;

                ep = (QAMDATA *)((u_int8_t *)h + dbp->pgsize - re_len);
                for (indx = 0, qp = QAM_GET_RECORD(dbp, h, indx);
                    qp <= ep;
                    ++indx,  qp = QAM_GET_RECORD(dbp, h, indx)) {
                        if (F_ISSET(qp, QAM_VALID))
                                sp->qs_ndata++;
                        else
                                sp->qs_pgfree += re_len;
                }

                if ((ret = CDB_memp_fput(dbp->mpf, h, 0)) != 0)
                        goto err;
                (void)__LPUT(dbc, lock);
        }

        /* Get the meta-data page. */
        if ((ret = CDB___db_lget(dbc,
            0, t->q_meta, F_ISSET(dbp, DB_AM_RDONLY) ?
            DB_LOCK_READ : DB_LOCK_WRITE, 0, &lock)) != 0)
                goto err;
        if ((ret = CDB_memp_fget(dbp->mpf, &t->q_meta, 0, (PAGE **)&meta)) != 0)
                goto err;

        /* Get the metadata fields. */
        sp->qs_magic = meta->dbmeta.magic;
        sp->qs_version = meta->dbmeta.version;
        sp->qs_metaflags = meta->dbmeta.flags;
        sp->qs_pagesize = meta->dbmeta.pagesize;
        sp->qs_re_len = meta->re_len;
        sp->qs_re_pad = meta->re_pad;
        sp->qs_start = meta->start;
        sp->qs_first_recno = meta->first_recno;
        sp->qs_cur_recno = meta->cur_recno;
        sp->qs_nkeys = sp->qs_ndata;
        if (!F_ISSET(dbp, DB_AM_RDONLY))
                meta->dbmeta.key_count =
                    meta->dbmeta.record_count = sp->qs_ndata;

done:
        /* Discard the meta-data page. */
        if ((ret = CDB_memp_fput(dbp->mpf, meta, !F_ISSET(dbp, DB_AM_RDONLY))) != 0)
                goto err;
        (void)__LPUT(dbc, lock);

        *(DB_QUEUE_STAT **)spp = sp;
        ret = 0;

        if (0) {
err:            if (sp != NULL)
                        CDB___os_free(sp, sizeof(*sp));
        }

        if (lock.off != LOCK_INVALID)
                (void)__LPUT(dbc, lock);

        if ((t_ret = dbc->c_close(dbc)) != 0 && ret == 0)
                ret = t_ret;

        return (ret);
}

---