glibc/db2/mp/mp_pr.c
Ulrich Drepper ec239360d1 Update.
* db2/Makefile (distribute): Remove files which do not exist
	anymore.
1999-06-13 13:36:34 +00:00

305 lines
6.9 KiB
C

/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 1996, 1997, 1998
* Sleepycat Software. All rights reserved.
*/
#include "config.h"
#ifndef lint
static const char sccsid[] = "@(#)mp_pr.c 10.30 (Sleepycat) 10/1/98";
#endif /* not lint */
#ifndef NO_SYSTEM_INCLUDES
#include <sys/types.h>
#include <errno.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#endif
#include "db_int.h"
#include "db_page.h"
#include "shqueue.h"
#include "db_shash.h"
#include "mp.h"
#include "db_auto.h"
#include "db_ext.h"
#include "common_ext.h"
static void __memp_pbh __P((DB_MPOOL *, BH *, size_t *, FILE *));
/*
* memp_stat --
* Display MPOOL statistics.
*/
int
memp_stat(dbmp, gspp, fspp, db_malloc)
DB_MPOOL *dbmp;
DB_MPOOL_STAT **gspp;
DB_MPOOL_FSTAT ***fspp;
void *(*db_malloc) __P((size_t));
{
DB_MPOOL_FSTAT **tfsp;
MPOOLFILE *mfp;
size_t len, nlen;
int ret;
char *name;
MP_PANIC_CHECK(dbmp);
/* Allocate space for the global statistics. */
if (gspp != NULL) {
*gspp = NULL;
if ((ret = __os_malloc(sizeof(**gspp), db_malloc, gspp)) != 0)
return (ret);
LOCKREGION(dbmp);
/* Copy out the global statistics. */
**gspp = dbmp->mp->stat;
(*gspp)->st_hash_buckets = dbmp->mp->htab_buckets;
(*gspp)->st_region_wait =
dbmp->mp->rlayout.lock.mutex_set_wait;
(*gspp)->st_region_nowait =
dbmp->mp->rlayout.lock.mutex_set_nowait;
(*gspp)->st_refcnt = dbmp->mp->rlayout.refcnt;
(*gspp)->st_regsize = dbmp->mp->rlayout.size;
UNLOCKREGION(dbmp);
}
if (fspp != NULL) {
*fspp = NULL;
LOCKREGION(dbmp);
/* Count the MPOOLFILE structures. */
for (len = 0,
mfp = SH_TAILQ_FIRST(&dbmp->mp->mpfq, __mpoolfile);
mfp != NULL;
++len, mfp = SH_TAILQ_NEXT(mfp, q, __mpoolfile))
;
UNLOCKREGION(dbmp);
if (len == 0)
return (0);
/* Allocate space for the pointers. */
len = (len + 1) * sizeof(DB_MPOOL_FSTAT *);
if ((ret = __os_malloc(len, db_malloc, fspp)) != 0)
return (ret);
LOCKREGION(dbmp);
/* Build each individual entry. */
for (tfsp = *fspp,
mfp = SH_TAILQ_FIRST(&dbmp->mp->mpfq, __mpoolfile);
mfp != NULL;
++tfsp, mfp = SH_TAILQ_NEXT(mfp, q, __mpoolfile)) {
name = __memp_fns(dbmp, mfp);
nlen = strlen(name);
len = sizeof(DB_MPOOL_FSTAT) + nlen + 1;
if ((ret = __os_malloc(len, db_malloc, tfsp)) != 0)
return (ret);
**tfsp = mfp->stat;
(*tfsp)->file_name = (char *)
(u_int8_t *)*tfsp + sizeof(DB_MPOOL_FSTAT);
memcpy((*tfsp)->file_name, name, nlen + 1);
}
*tfsp = NULL;
UNLOCKREGION(dbmp);
}
return (0);
}
/*
* __memp_fn --
* On errors we print whatever is available as the file name.
*
* PUBLIC: char * __memp_fn __P((DB_MPOOLFILE *));
*/
char *
__memp_fn(dbmfp)
DB_MPOOLFILE *dbmfp;
{
return (__memp_fns(dbmfp->dbmp, dbmfp->mfp));
}
/*
* __memp_fns --
* On errors we print whatever is available as the file name.
*
* PUBLIC: char * __memp_fns __P((DB_MPOOL *, MPOOLFILE *));
*
*/
char *
__memp_fns(dbmp, mfp)
DB_MPOOL *dbmp;
MPOOLFILE *mfp;
{
if (mfp->path_off == 0)
return ((char *)"temporary");
return ((char *)R_ADDR(dbmp, mfp->path_off));
}
#define FMAP_ENTRIES 200 /* Files we map. */
#define MPOOL_DUMP_HASH 0x01 /* Debug hash chains. */
#define MPOOL_DUMP_LRU 0x02 /* Debug LRU chains. */
#define MPOOL_DUMP_MEM 0x04 /* Debug region memory. */
#define MPOOL_DUMP_ALL 0x07 /* Debug all. */
/*
* __memp_dump_region --
* Display MPOOL structures.
*
* PUBLIC: void __memp_dump_region __P((DB_MPOOL *, char *, FILE *));
*/
void
__memp_dump_region(dbmp, area, fp)
DB_MPOOL *dbmp;
char *area;
FILE *fp;
{
BH *bhp;
DB_HASHTAB *htabp;
DB_MPOOLFILE *dbmfp;
MPOOL *mp;
MPOOLFILE *mfp;
size_t bucket, fmap[FMAP_ENTRIES + 1];
u_int32_t flags;
int cnt;
/* Make it easy to call from the debugger. */
if (fp == NULL)
fp = stderr;
for (flags = 0; *area != '\0'; ++area)
switch (*area) {
case 'A':
LF_SET(MPOOL_DUMP_ALL);
break;
case 'h':
LF_SET(MPOOL_DUMP_HASH);
break;
case 'l':
LF_SET(MPOOL_DUMP_LRU);
break;
case 'm':
LF_SET(MPOOL_DUMP_MEM);
break;
}
LOCKREGION(dbmp);
mp = dbmp->mp;
/* Display MPOOL structures. */
(void)fprintf(fp, "%s\nPool (region addr 0x%lx, alloc addr 0x%lx)\n",
DB_LINE, (u_long)dbmp->reginfo.addr, (u_long)dbmp->addr);
/* Display the MPOOLFILE structures. */
cnt = 0;
for (mfp = SH_TAILQ_FIRST(&dbmp->mp->mpfq, __mpoolfile);
mfp != NULL; mfp = SH_TAILQ_NEXT(mfp, q, __mpoolfile), ++cnt) {
(void)fprintf(fp, "file #%d: %s: refs %lu, type %ld, %s\n",
cnt + 1, __memp_fns(dbmp, mfp), (u_long)mfp->ref,
(long)mfp->ftype,
F_ISSET(mfp, MP_CAN_MMAP) ? "mmap" : "read/write");
if (cnt < FMAP_ENTRIES)
fmap[cnt] = R_OFFSET(dbmp, mfp);
}
for (dbmfp = TAILQ_FIRST(&dbmp->dbmfq);
dbmfp != NULL; dbmfp = TAILQ_NEXT(dbmfp, q), ++cnt) {
(void)fprintf(fp, "file #%d: %s: fd: %d: per-process, %s\n",
cnt + 1, __memp_fn(dbmfp), dbmfp->fd,
F_ISSET(dbmfp, MP_READONLY) ? "readonly" : "read/write");
if (cnt < FMAP_ENTRIES)
fmap[cnt] = R_OFFSET(dbmp, mfp);
}
if (cnt < FMAP_ENTRIES)
fmap[cnt] = INVALID;
else
fmap[FMAP_ENTRIES] = INVALID;
/* Display the hash table list of BH's. */
if (LF_ISSET(MPOOL_DUMP_HASH)) {
(void)fprintf(fp,
"%s\nBH hash table (%lu hash slots)\npageno, file, ref, address\n",
DB_LINE, (u_long)mp->htab_buckets);
for (htabp = dbmp->htab,
bucket = 0; bucket < mp->htab_buckets; ++htabp, ++bucket) {
if (SH_TAILQ_FIRST(&dbmp->htab[bucket], __bh) != NULL)
(void)fprintf(fp, "%lu:\n", (u_long)bucket);
for (bhp = SH_TAILQ_FIRST(&dbmp->htab[bucket], __bh);
bhp != NULL; bhp = SH_TAILQ_NEXT(bhp, hq, __bh))
__memp_pbh(dbmp, bhp, fmap, fp);
}
}
/* Display the LRU list of BH's. */
if (LF_ISSET(MPOOL_DUMP_LRU)) {
(void)fprintf(fp, "%s\nBH LRU list\n", DB_LINE);
(void)fprintf(fp, "pageno, file, ref, address\n");
for (bhp = SH_TAILQ_FIRST(&dbmp->mp->bhq, __bh);
bhp != NULL; bhp = SH_TAILQ_NEXT(bhp, q, __bh))
__memp_pbh(dbmp, bhp, fmap, fp);
}
if (LF_ISSET(MPOOL_DUMP_MEM))
__db_shalloc_dump(dbmp->addr, fp);
UNLOCKREGION(dbmp);
/* Flush in case we're debugging. */
(void)fflush(fp);
}
/*
* __memp_pbh --
* Display a BH structure.
*/
static void
__memp_pbh(dbmp, bhp, fmap, fp)
DB_MPOOL *dbmp;
BH *bhp;
size_t *fmap;
FILE *fp;
{
static const FN fn[] = {
{ BH_CALLPGIN, "callpgin" },
{ BH_DIRTY, "dirty" },
{ BH_DISCARD, "discard" },
{ BH_LOCKED, "locked" },
{ BH_TRASH, "trash" },
{ BH_WRITE, "write" },
{ 0 },
};
int i;
for (i = 0; i < FMAP_ENTRIES; ++i)
if (fmap[i] == INVALID || fmap[i] == bhp->mf_offset)
break;
if (fmap[i] == INVALID)
(void)fprintf(fp, " %4lu, %lu, %2lu, %lu",
(u_long)bhp->pgno, (u_long)bhp->mf_offset,
(u_long)bhp->ref, (u_long)R_OFFSET(dbmp, bhp));
else
(void)fprintf(fp, " %4lu, #%d, %2lu, %lu",
(u_long)bhp->pgno, i + 1,
(u_long)bhp->ref, (u_long)R_OFFSET(dbmp, bhp));
__db_prflags(bhp->flags, fn, fp);
(void)fprintf(fp, "\n");
}