#include "db_config.h"
#include "db_int.h"
#ifndef lint
static const char copyright[] =
"Copyright (c) 1996,2008 Oracle. All rights reserved.\n";
#endif
typedef enum { T_NOTSET, T_DB,
T_ENV, T_LOCK, T_LOG, T_MPOOL, T_MUTEX, T_REP, T_TXN } test_t;
int db_stat_db_init __P((DB_ENV *, char *, test_t, u_int32_t, int *));
int db_stat_main __P((int, char *[]));
int db_stat_usage __P((void));
int db_stat_version_check __P((void));
const char *progname;
int
db_stat(args)
char *args;
{
int argc;
char **argv;
__db_util_arg("db_stat", args, &argc, &argv);
return (db_stat_main(argc, argv) ? EXIT_FAILURE : EXIT_SUCCESS);
}
#include <stdio.h>
#define ERROR_RETURN ERROR
int
db_stat_main(argc, argv)
int argc;
char *argv[];
{
extern char *optarg;
extern int optind, __db_getopt_reset;
DB_ENV *dbenv;
DB *dbp;
test_t ttype;
u_int32_t cache, flags;
int ch, exitval;
int nflag, private, resize, ret;
char *db, *home, *p, *passwd, *subdb;
if ((progname = __db_rpath(argv[0])) == NULL)
progname = argv[0];
else
++progname;
if ((ret = db_stat_version_check()) != 0)
return (ret);
dbenv = NULL;
dbp = NULL;
ttype = T_NOTSET;
cache = MEGABYTE;
exitval = flags = nflag = private = 0;
db = home = passwd = subdb = NULL;
__db_getopt_reset = 1;
while ((ch = getopt(argc,
argv, "C:cd:Eefgh:L:lM:mNP:R:rs:tVxX:Z")) != EOF)
switch (ch) {
case 'C': case 'c':
if (ttype != T_NOTSET && ttype != T_LOCK)
goto argcombo;
ttype = T_LOCK;
if (ch != 'c')
for (p = optarg; *p; ++p)
switch (*p) {
case 'A':
LF_SET(DB_STAT_ALL);
break;
case 'c':
LF_SET(DB_STAT_LOCK_CONF);
break;
case 'l':
LF_SET(DB_STAT_LOCK_LOCKERS);
break;
case 'm':
break;
case 'o':
LF_SET(DB_STAT_LOCK_OBJECTS);
break;
case 'p':
LF_SET(DB_STAT_LOCK_PARAMS);
break;
default:
return (db_stat_usage());
}
break;
case 'd':
if (ttype != T_NOTSET && ttype != T_DB)
goto argcombo;
ttype = T_DB;
db = optarg;
break;
case 'E': case 'e':
if (ttype != T_NOTSET && ttype != T_ENV)
goto argcombo;
ttype = T_ENV;
LF_SET(DB_STAT_SUBSYSTEM);
if (ch == 'E')
LF_SET(DB_STAT_ALL);
break;
case 'f':
if (ttype != T_NOTSET && ttype != T_DB)
goto argcombo;
ttype = T_DB;
LF_SET(DB_FAST_STAT);
break;
case 'h':
home = optarg;
break;
case 'L': case 'l':
if (ttype != T_NOTSET && ttype != T_LOG)
goto argcombo;
ttype = T_LOG;
if (ch != 'l')
for (p = optarg; *p; ++p)
switch (*p) {
case 'A':
LF_SET(DB_STAT_ALL);
break;
default:
return (db_stat_usage());
}
break;
case 'M': case 'm':
if (ttype != T_NOTSET && ttype != T_MPOOL)
goto argcombo;
ttype = T_MPOOL;
if (ch != 'm')
for (p = optarg; *p; ++p)
switch (*p) {
case 'A':
LF_SET(DB_STAT_ALL);
break;
case 'h':
LF_SET(DB_STAT_MEMP_HASH);
break;
case 'm':
break;
default:
return (db_stat_usage());
}
break;
case 'N':
nflag = 1;
break;
case 'P':
passwd = strdup(optarg);
memset(optarg, 0, strlen(optarg));
if (passwd == NULL) {
fprintf(stderr, "%s: strdup: %s\n",
progname, strerror(errno));
return (EXIT_FAILURE);
}
break;
case 'R': case 'r':
if (ttype != T_NOTSET && ttype != T_REP)
goto argcombo;
ttype = T_REP;
if (ch != 'r')
for (p = optarg; *p; ++p)
switch (*p) {
case 'A':
LF_SET(DB_STAT_ALL);
break;
default:
return (db_stat_usage());
}
break;
case 's':
if (ttype != T_NOTSET && ttype != T_DB)
goto argcombo;
ttype = T_DB;
subdb = optarg;
break;
case 't':
if (ttype != T_NOTSET) {
argcombo: fprintf(stderr,
"%s: illegal option combination\n",
progname);
return (db_stat_usage());
}
ttype = T_TXN;
break;
case 'V':
printf("%s\n", db_version(NULL, NULL, NULL));
return (EXIT_SUCCESS);
case 'X': case 'x':
if (ttype != T_NOTSET && ttype != T_MUTEX)
goto argcombo;
ttype = T_MUTEX;
if (ch != 'x')
for (p = optarg; *p; ++p)
switch (*p) {
case 'A':
LF_SET(DB_STAT_ALL);
break;
default:
return (db_stat_usage());
}
break;
case 'Z':
LF_SET(DB_STAT_CLEAR);
break;
case '?':
default:
return (db_stat_usage());
}
argc -= optind;
argv += optind;
switch (ttype) {
case T_DB:
if (db == NULL)
return (db_stat_usage());
break;
case T_ENV:
case T_LOCK:
case T_LOG:
case T_MPOOL:
case T_MUTEX:
case T_REP:
case T_TXN:
break;
case T_NOTSET:
return (db_stat_usage());
}
__db_util_siginit();
retry: if ((ret = db_env_create(&dbenv, 0)) != 0) {
fprintf(stderr,
"%s: db_env_create: %s\n", progname, db_strerror(ret));
goto err;
}
dbenv->set_errfile(dbenv, stderr);
dbenv->set_errpfx(dbenv, progname);
if (nflag) {
if ((ret = dbenv->set_flags(dbenv, DB_NOLOCKING, 1)) != 0) {
dbenv->err(dbenv, ret, "set_flags: DB_NOLOCKING");
goto err;
}
if ((ret = dbenv->set_flags(dbenv, DB_NOPANIC, 1)) != 0) {
dbenv->err(dbenv, ret, "set_flags: DB_NOPANIC");
goto err;
}
}
if (passwd != NULL &&
(ret = dbenv->set_encrypt(dbenv, passwd, DB_ENCRYPT_AES)) != 0) {
dbenv->err(dbenv, ret, "set_passwd");
goto err;
}
if (db_stat_db_init(dbenv, home, ttype, cache, &private) != 0)
goto err;
switch (ttype) {
case T_DB:
if ((ret = db_create(&dbp, dbenv, 0)) != 0) {
dbenv->err(dbenv, ret, "db_create");
goto err;
}
dbenv->set_errfile(dbenv, NULL);
ret = dbp->open(dbp, NULL, db, subdb, DB_UNKNOWN, 0, 0);
dbenv->set_errfile(dbenv, stderr);
if (ret != 0 && (ret = dbp->open(
dbp, NULL, db, subdb, DB_UNKNOWN, DB_RDONLY, 0)) != 0) {
dbenv->err(dbenv, ret, "DB->open: %s", db);
goto err;
}
if (private) {
if ((ret = __db_util_cache(dbp, &cache, &resize)) != 0)
goto err;
if (resize) {
(void)dbp->close(dbp, DB_NOSYNC);
dbp = NULL;
(void)dbenv->close(dbenv, 0);
dbenv = NULL;
goto retry;
}
}
if (dbp->stat_print(dbp, flags))
goto err;
break;
case T_ENV:
if (dbenv->stat_print(dbenv, flags))
goto err;
break;
case T_LOCK:
if (dbenv->lock_stat_print(dbenv, flags))
goto err;
break;
case T_LOG:
if (dbenv->log_stat_print(dbenv, flags))
goto err;
break;
case T_MPOOL:
if (dbenv->memp_stat_print(dbenv, flags))
goto err;
break;
case T_MUTEX:
if (dbenv->mutex_stat_print(dbenv, flags))
goto err;
break;
case T_REP:
#ifdef HAVE_REPLICATION_THREADS
if (dbenv->repmgr_stat_print(dbenv, flags))
goto err;
#endif
if (dbenv->rep_stat_print(dbenv, flags))
goto err;
break;
case T_TXN:
if (dbenv->txn_stat_print(dbenv, flags))
goto err;
break;
case T_NOTSET:
dbenv->errx(dbenv, "Unknown statistics flag");
goto err;
}
if (0) {
err: exitval = 1;
}
if (dbp != NULL && (ret = dbp->close(dbp, DB_NOSYNC)) != 0) {
exitval = 1;
dbenv->err(dbenv, ret, "close");
}
if (dbenv != NULL && (ret = dbenv->close(dbenv, 0)) != 0) {
exitval = 1;
fprintf(stderr,
"%s: dbenv->close: %s\n", progname, db_strerror(ret));
}
if (passwd != NULL)
free(passwd);
__db_util_sigresend();
return (exitval == 0 ? EXIT_SUCCESS : EXIT_FAILURE);
}
int
db_stat_db_init(dbenv, home, ttype, cache, is_private)
DB_ENV *dbenv;
char *home;
test_t ttype;
u_int32_t cache;
int *is_private;
{
u_int32_t oflags;
int ret;
*is_private = 0;
if ((ret = dbenv->open(dbenv, home, DB_USE_ENVIRON, 0)) == 0)
return (0);
if (ret == DB_VERSION_MISMATCH)
goto err;
if (ttype != T_DB && ttype != T_LOG) {
dbenv->err(dbenv, ret, "DB_ENV->open%s%s",
home == NULL ? "" : ": ", home == NULL ? "" : home);
return (1);
}
if ((ret = dbenv->set_cachesize(dbenv, 0, cache, 1)) != 0) {
dbenv->err(dbenv, ret, "set_cachesize");
return (1);
}
*is_private = 1;
oflags = DB_CREATE | DB_PRIVATE | DB_USE_ENVIRON;
if (ttype == T_DB)
oflags |= DB_INIT_MPOOL;
if (ttype == T_LOG)
oflags |= DB_INIT_LOG;
if ((ret = dbenv->open(dbenv, home, oflags, 0)) == 0)
return (0);
err: dbenv->err(dbenv, ret, "DB_ENV->open");
return (1);
}
int
db_stat_usage()
{
fprintf(stderr, "usage: %s %s\n", progname,
"-d file [-fN] [-h home] [-P password] [-s database]");
fprintf(stderr, "usage: %s %s\n\t%s\n", progname,
"[-cEelmNrtVxZ] [-C Aclop]",
"[-h home] [-L A] [-M A] [-P password] [-R A] [-X A]");
return (EXIT_FAILURE);
}
int
db_stat_version_check()
{
int v_major, v_minor, v_patch;
(void)db_version(&v_major, &v_minor, &v_patch);
if (v_major != DB_VERSION_MAJOR || v_minor != DB_VERSION_MINOR) {
fprintf(stderr,
"%s: version %d.%d doesn't match library version %d.%d\n",
progname, DB_VERSION_MAJOR, DB_VERSION_MINOR,
v_major, v_minor);
return (EXIT_FAILURE);
}
return (0);
}