Merge rkalimullin@work.mysql.com:/home/bk/mysql-4.1

into mysql.r18.ru:/usr/home/ram/work/mysql-4.1.bdb

bdb/dist/s_include

@@ -71,7 +71,7 @@ head defonly _DB_INT_DEF_IN_ > $i_dfile
 
 # Process the standard directories, creating per-directory prototype
 # files and adding to the external prototype and #define files.
-for i in db btree clib common crypto dbreg env fileops hash hmac \
+for i in db btree clib common dbreg env fileops hash hmac \
     lock log mp mutex os qam rep rpc_client rpc_server tcl txn xa; do
 	head "_${i}_ext_h_" > $i_pfile
 

bdb/dist/s_recover

@@ -66,4 +66,4 @@ for i in db dbreg btree fileops hash qam txn; do
 done
 
 # Build the example application's recovery routines.
-(cd ../examples_c/ex_apprec && sh auto_rebuild)
+#(cd ../examples_c/ex_apprec && sh auto_rebuild)

bdb/dist/s_symlink

@@ -14,7 +14,7 @@ build btree/tags ../dist/tags
 build build_unix/tags ../dist/tags
 build clib/tags ../dist/tags
 build common/tags ../dist/tags
-build crypto/tags ../dist/tags
+#build crypto/tags ../dist/tags
 build cxx/tags ../dist/tags
 build db/tags ../dist/tags
 build db185/tags ../dist/tags
@@ -34,9 +34,9 @@ build dbinc_auto/tags ../dist/tags
 build dbm/tags ../dist/tags
 build dbreg/tags ../dist/tags
 build env/tags ../dist/tags
-build examples_c/tags ../dist/tags
-build examples_cxx/tags ../dist/tags
-build examples_java java/src/com/sleepycat/examples
+#build examples_c/tags ../dist/tags
+#build examples_cxx/tags ../dist/tags
+#build examples_java java/src/com/sleepycat/examples
 build fileops/tags ../dist/tags
 build hash/tags ../dist/tags
 build hmac/tags ../dist/tags

bdb/examples_c/README

-# $Id: README,v 11.5 2002/02/26 16:22:45 krinsky Exp $
-
-ex_access.c	Using just the DB access methods.
-
-ex_apprec	Application-specific recovery.
-
-ex_btrec.c	Using the BTREE access method with record numbers.
-
-ex_env.c	Setting up the DB environment.
-
-ex_lock.c	Locking.
-
-ex_mpool.c	Shared memory buffer pools.
-
-ex_repquote	Replication.  This creates a toy stock quote server
-		with DB's single-master, multiple-client replication,
-		with communication over TCP.
-
-ex_tpcb.c	TPC/B.
-		Ex_tpcb sets up a framework in which to run a TPC/B test.
-		Database initialization (the -i flag) and running the
-		benchmark (-n flag) must take place separately (i.e.,
-		first create the database, then run 1 or more copies of
-		the benchmark).  Furthermore, when running more than one
-		TPCB process, it is necessary to run the deadlock detector
-		(db_deadlock), since it is possible for concurrent tpcb
-		processes to deadlock.  For performance measurement, it
-		will also be beneficial to run the db_checkpoint process
-		as well.

bdb/examples_c/bench_001.c

-/*-
- * Copyright (c) 2001-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: bench_001.c,v 1.13 2002/08/15 02:45:39 bostic Exp $
- */
-
-/*
- * bench_001 - time bulk fetch interface.
- *	Without -R builds a btree acording to the arguments.
- *	With -R runs and times bulk fetches.  If -d is specified
- *	during reads the DB_MULTIPLE interface is used
- *	otherwise the DB_MULTIPLE_KEY interface is used.
- *
- * ARGUMENTS:
- *	-c	cachesize [1000 * pagesize]
- *	-d	number of duplicates [none]
- *	-E	don't use environment
- *	-I	Just initialize the environment
- *	-i	number of read iterations [1000000]
- *	-l	length of data item [20]
- *	-n	number of keys [1000000]
- *	-p	pagesize [65536]
- *	-R	perform read test.
- *	-T	incorporate transactions.
- *
- * COMPILE:
- *	cc -I /usr/local/BerkeleyDB/include \
- *	    -o bench_001 -O2 bench_001.c /usr/local/BerkeleyDB/lib/libdb.so
- */
-#include <sys/types.h>
-
-#include <sys/time.h>
-#include <stdlib.h>
-#include <string.h>
-#include <unistd.h>
-
-#include <db.h>
-
-#define	DATABASE	"bench_001.db"
-
-int	main(int, char *[]);
-void	usage(void);
-
-const char
-	*progname = "bench_001";		/* Program name. */
-/*
- * db_init --
- *	Initialize the environment.
- */
-DB_ENV *
-db_init(home, prefix, cachesize, txn)
-	char *home, *prefix;
-	int cachesize, txn;
-{
-	DB_ENV *dbenv;
-	int flags, ret;
-
-	if ((ret = db_env_create(&dbenv, 0)) != 0) {
-		dbenv->err(dbenv, ret, "db_env_create");
-		return (NULL);
-	}
-	dbenv->set_errfile(dbenv, stderr);
-	dbenv->set_errpfx(dbenv, prefix);
-	(void)dbenv->set_cachesize(dbenv, 0,
-	    cachesize == 0 ? 50 * 1024 * 1024 : (u_int32_t)cachesize, 0);
-
-	flags = DB_CREATE | DB_INIT_MPOOL;
-	if (txn)
-		flags |= DB_INIT_TXN | DB_INIT_LOCK;
-	if ((ret = dbenv->open(dbenv, home, flags, 0)) != 0) {
-		dbenv->err(dbenv, ret, "DB_ENV->open: %s", home);
-		(void)dbenv->close(dbenv, 0);
-		return (NULL);
-	}
-	return (dbenv);
-}
-
-/*
- * get -- loop getting batches of records.
- *
- */
-int
-get(dbp, txn, datalen, num, dups, iter, countp)
-	DB *dbp;
-	int txn, datalen, num, dups, iter, *countp;
-{
-	DBC *dbcp;
-	DBT key, data;
-	DB_TXN *txnp;
-	u_int32_t len, klen;
-	int count, flags, i, j, ret;
-	void *pointer, *dp, *kp;
-
-	memset(&key, 0, sizeof(key));
-	key.data = &j;
-	key.size = sizeof(j);
-	memset(&data, 0, sizeof(data));
-	data.flags = DB_DBT_USERMEM;
-	data.data = malloc(datalen*1024*1024);
-	data.ulen = data.size = datalen*1024*1024;
-	count = 0;
-	flags = DB_SET;
-	if (!dups)
-		flags |= DB_MULTIPLE_KEY;
-	else
-		flags |= DB_MULTIPLE;
-	for (i = 0; i < iter; i++) {
-		txnp = NULL;
-		if (txn)
-			dbp->dbenv->txn_begin(dbp->dbenv, NULL, &txnp, 0);
-		dbp->cursor(dbp, txnp, &dbcp, 0);
-
-		j = random() % num;
-		switch (ret = dbcp->c_get(dbcp, &key, &data, flags)) {
-		case 0:
-			break;
-		default:
-			dbp->err(dbcp->dbp, ret, "DBC->c_get");
-			return (ret);
-		}
-		DB_MULTIPLE_INIT(pointer, &data);
-		if (dups)
-			while (pointer != NULL) {
-				DB_MULTIPLE_NEXT(pointer, &data, dp, len);
-				if (dp != NULL)
-					count++;
-			}
-		else
-			while (pointer != NULL) {
-				DB_MULTIPLE_KEY_NEXT(pointer,
-				    &data, kp, klen, dp, len);
-				if (kp != NULL)
-					count++;
-			}
-		dbcp->c_close(dbcp);
-		if (txn)
-			txnp->commit(txnp, 0);
-	}
-
-	*countp = count;
-	return (0);
-}
-
-/*
- * fill - fill a db
- *	Since we open/created the db with transactions (potentially),
- * we need to populate it with transactions.  We'll bundle the puts
- * 10 to a transaction.
- */
-#define	PUTS_PER_TXN	10
-int
-fill(dbenv, dbp, txn, datalen, num, dups)
-	DB_ENV *dbenv;
-	DB *dbp;
-	int txn, datalen, num, dups;
-{
-	DBT key, data;
-	DB_TXN *txnp;
-	struct data {
-		int id;
-		char str[1];
-	} *data_val;
-	int count, i, ret;
-	/*
-	 * Insert records into the database, where the key is the user
-	 * input and the data is the user input in reverse order.
-	 */
-	txnp = NULL;
-	ret = 0;
-	count = 0;
-	memset(&key, 0, sizeof(DBT));
-	memset(&data, 0, sizeof(DBT));
-	key.data = &i;
-	key.size = sizeof(i);
-	data.data = data_val = (struct data *) malloc(datalen);
-	memcpy(data_val->str, "0123456789012345678901234567890123456789",
-	    datalen - sizeof (data_val->id));
-	data.size = datalen;
-	data.flags = DB_DBT_USERMEM;
-
-	for (i = 0; i < num; i++) {
-		if (txn != 0 && i % PUTS_PER_TXN == 0) {
-			if (txnp != NULL) {
-				ret = txnp->commit(txnp, 0);
-				txnp = NULL;
-				if (ret != 0)
-					goto err;
-			}
-			if ((ret =
-			    dbenv->txn_begin(dbenv, NULL, &txnp, 0)) != 0)
-				goto err;
-		}
-		data_val->id = 0;
-		do {
-			switch (ret =
-			    dbp->put(dbp, txnp, &key, &data, 0)) {
-			case 0:
-				count++;
-				break;
-			default:
-				dbp->err(dbp, ret, "DB->put");
-				goto err;
-			}
-		} while (++data_val->id < dups);
-	}
-	if (txnp != NULL)
-		ret = txnp->commit(txnp, 0);
-
-	printf("%d\n", count);
-	return (ret);
-
-err:	if (txnp != NULL)
-		(void)txnp->abort(txnp);
-	return (ret);
-}
-
-int
-main(argc, argv)
-	int argc;
-	char *argv[];
-{
-	extern char *optarg;
-	extern int optind;
-	DB *dbp;
-	DB_ENV *dbenv;
-	DB_TXN *txnp;
-	struct timeval start_time, end_time;
-	double secs;
-	int cache, ch, count, datalen, dups, env, init, iter, num, pagesize;
-	int ret, rflag, txn;
-
-	txnp = NULL;
-	datalen = 20;
-	iter = num = 1000000;
-	env = 1;
-	dups = init = rflag = txn = 0;
-
-	pagesize = 65536;
-	cache = 1000 * pagesize;
-
-	while ((ch = getopt(argc, argv, "c:d:EIi:l:n:p:RT")) != EOF)
-		switch (ch) {
-		case 'c':
-			cache = atoi(optarg);
-			break;
-		case 'd':
-			dups = atoi(optarg);
-			break;
-		case 'E':
-			env = 0;
-			break;
-		case 'I':
-			init = 1;
-			break;
-		case 'i':
-			iter = atoi(optarg);
-			break;
-		case 'l':
-			datalen = atoi(optarg);
-			break;
-		case 'n':
-			num = atoi(optarg);
-			break;
-		case 'p':
-			pagesize = atoi(optarg);
-			break;
-		case 'R':
-			rflag = 1;
-			break;
-		case 'T':
-			txn = 1;
-			break;
-		case '?':
-		default:
-			usage();
-		}
-	argc -= optind;
-	argv += optind;
-
-	/* Remove the previous database. */
-	if (!rflag) {
-		if (env)
-			system("rm -rf BENCH_001; mkdir BENCH_001");
-		else
-			(void)unlink(DATABASE);
-	}
-
-	dbenv = NULL;
-	if (env == 1 &&
-	    (dbenv = db_init("BENCH_001", "bench_001", cache, txn)) == NULL)
-		return (-1);
-	if (init)
-		exit(0);
-	/* Create and initialize database object, open the database. */
-	if ((ret = db_create(&dbp, dbenv, 0)) != 0) {
-		fprintf(stderr,
-		    "%s: db_create: %s\n", progname, db_strerror(ret));
-		exit(EXIT_FAILURE);
-	}
-	dbp->set_errfile(dbp, stderr);
-	dbp->set_errpfx(dbp, progname);
-	if ((ret = dbp->set_pagesize(dbp, pagesize)) != 0) {
-		dbp->err(dbp, ret, "set_pagesize");
-		goto err1;
-	}
-	if (dups && (ret = dbp->set_flags(dbp, DB_DUP)) != 0) {
-		dbp->err(dbp, ret, "set_flags");
-		goto err1;
-	}
-
-	if (env == 0 && (ret = dbp->set_cachesize(dbp, 0, cache, 0)) != 0) {
-		dbp->err(dbp, ret, "set_cachesize");
-		goto err1;
-	}
-
-	if ((ret = dbp->set_flags(dbp, DB_DUP)) != 0) {
-		dbp->err(dbp, ret, "set_flags");
-		goto err1;
-	}
-
-	if (txn != 0)
-		if ((ret = dbenv->txn_begin(dbenv, NULL, &txnp, 0)) != 0)
-			goto err1;
-
-	if ((ret = dbp->open(
-	    dbp, txnp, DATABASE, NULL, DB_BTREE, DB_CREATE, 0664)) != 0) {
-		dbp->err(dbp, ret, "%s: open", DATABASE);
-		if (txnp != NULL)
-			(void)txnp->abort(txnp);
-		goto err1;
-	}
-
-	if (txnp != NULL)
-		ret = txnp->commit(txnp, 0);
-	txnp = NULL;
-	if (ret != 0)
-		goto err1;
-
-	if (rflag) {
-		/* If no environment, fill the cache. */
-		if (!env && (ret =
-		    get(dbp, txn, datalen, num, dups, iter, &count)) != 0)
-			goto err1;
-
-		/* Time the get loop. */
-		gettimeofday(&start_time, NULL);
-		if ((ret =
-		    get(dbp, txn, datalen, num, dups, iter, &count)) != 0)
-			goto err1;
-		gettimeofday(&end_time, NULL);
-		secs =
-		    (((double)end_time.tv_sec * 1000000 + end_time.tv_usec) -
-		    ((double)start_time.tv_sec * 1000000 + start_time.tv_usec))
-		    / 1000000;
-		printf("%d records read using %d batches in %.2f seconds: ",
-		    count, iter, secs);
-		printf("%.0f records/second\n", (double)count / secs);
-
-	} else if ((ret = fill(dbenv, dbp, txn, datalen, num, dups)) != 0)
-		goto err1;
-
-	/* Close everything down. */
-	if ((ret = dbp->close(dbp, rflag ? DB_NOSYNC : 0)) != 0) {
-		fprintf(stderr,
-		    "%s: DB->close: %s\n", progname, db_strerror(ret));
-		return (1);
-	}
-	return (ret);
-
-err1:	(void)dbp->close(dbp, 0);
-	return (1);
-}
-
-void
-usage()
-{
-	(void)fprintf(stderr, "usage: %s %s\n\t%s\n",
-	    progname, "[-EIRT] [-c cachesize] [-d dups]",
-	    "[-i iterations] [-l datalen] [-n keys] [-p pagesize]");
-	exit(EXIT_FAILURE);
-}

bdb/examples_c/ex_access.c

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 1997-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_access.c,v 11.22 2002/09/03 12:54:26 bostic Exp $
- */
-
-#include <sys/types.h>
-
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-
-#ifdef _WIN32
-extern int getopt(int, char * const *, const char *);
-#else
-#include <unistd.h>
-#endif
-
-#include <db.h>
-
-#define	DATABASE	"access.db"
-int main __P((int, char *[]));
-int usage __P((void));
-
-int
-main(argc, argv)
-	int argc;
-	char *argv[];
-{
-	extern int optind;
-	DB *dbp;
-	DBC *dbcp;
-	DBT key, data;
-	u_int32_t len;
-	int ch, ret, rflag;
-	char *database, *p, *t, buf[1024], rbuf[1024];
-	const char *progname = "ex_access";		/* Program name. */
-
-	rflag = 0;
-	while ((ch = getopt(argc, argv, "r")) != EOF)
-		switch (ch) {
-		case 'r':
-			rflag = 1;
-			break;
-		case '?':
-		default:
-			return (usage());
-		}
-	argc -= optind;
-	argv += optind;
-
-	/* Accept optional database name. */
-	database = *argv == NULL ? DATABASE : argv[0];
-
-	/* Optionally discard the database. */
-	if (rflag)
-		(void)remove(database);
-
-	/* Create and initialize database object, open the database. */
-	if ((ret = db_create(&dbp, NULL, 0)) != 0) {
-		fprintf(stderr,
-		    "%s: db_create: %s\n", progname, db_strerror(ret));
-		return (EXIT_FAILURE);
-	}
-	dbp->set_errfile(dbp, stderr);
-	dbp->set_errpfx(dbp, progname);
-	if ((ret = dbp->set_pagesize(dbp, 1024)) != 0) {
-		dbp->err(dbp, ret, "set_pagesize");
-		goto err1;
-	}
-	if ((ret = dbp->set_cachesize(dbp, 0, 32 * 1024, 0)) != 0) {
-		dbp->err(dbp, ret, "set_cachesize");
-		goto err1;
-	}
-	if ((ret = dbp->open(dbp,
-	    NULL, database, NULL, DB_BTREE, DB_CREATE, 0664)) != 0) {
-		dbp->err(dbp, ret, "%s: open", database);
-		goto err1;
-	}
-
-	/*
-	 * Insert records into the database, where the key is the user
-	 * input and the data is the user input in reverse order.
-	 */
-	memset(&key, 0, sizeof(DBT));
-	memset(&data, 0, sizeof(DBT));
-	for (;;) {
-		printf("input> ");
-		fflush(stdout);
-		if (fgets(buf, sizeof(buf), stdin) == NULL)
-			break;
-		if (strcmp(buf, "exit\n") == 0 || strcmp(buf, "quit\n") == 0)
-			break;
-		if ((len = strlen(buf)) <= 1)
-			continue;
-		for (t = rbuf, p = buf + (len - 2); p >= buf;)
-			*t++ = *p--;
-		*t++ = '\0';
-
-		key.data = buf;
-		data.data = rbuf;
-		data.size = key.size = len - 1;
-
-		switch (ret =
-		    dbp->put(dbp, NULL, &key, &data, DB_NOOVERWRITE)) {
-		case 0:
-			break;
-		default:
-			dbp->err(dbp, ret, "DB->put");
-			if (ret != DB_KEYEXIST)
-				goto err1;
-			break;
-		}
-	}
-	printf("\n");
-
-	/* Acquire a cursor for the database. */
-	if ((ret = dbp->cursor(dbp, NULL, &dbcp, 0)) != 0) {
-		dbp->err(dbp, ret, "DB->cursor");
-		goto err1;
-	}
-
-	/* Initialize the key/data pair so the flags aren't set. */
-	memset(&key, 0, sizeof(key));
-	memset(&data, 0, sizeof(data));
-
-	/* Walk through the database and print out the key/data pairs. */
-	while ((ret = dbcp->c_get(dbcp, &key, &data, DB_NEXT)) == 0)
-		printf("%.*s : %.*s\n",
-		    (int)key.size, (char *)key.data,
-		    (int)data.size, (char *)data.data);
-	if (ret != DB_NOTFOUND) {
-		dbp->err(dbp, ret, "DBcursor->get");
-		goto err2;
-	}
-
-	/* Close everything down. */
-	if ((ret = dbcp->c_close(dbcp)) != 0) {
-		dbp->err(dbp, ret, "DBcursor->close");
-		goto err1;
-	}
-	if ((ret = dbp->close(dbp, 0)) != 0) {
-		fprintf(stderr,
-		    "%s: DB->close: %s\n", progname, db_strerror(ret));
-		return (EXIT_FAILURE);
-	}
-	return (EXIT_SUCCESS);
-
-err2:	(void)dbcp->c_close(dbcp);
-err1:	(void)dbp->close(dbp, 0);
-	return (EXIT_FAILURE);
-}
-
-int
-usage()
-{
-	(void)fprintf(stderr, "usage: ex_access [-r] [database]\n");
-	return (EXIT_FAILURE);
-}

bdb/examples_c/ex_apprec/auto_rebuild

-# Script to rebuild automatically generated files for ex_apprec.
-
-E=../examples_c/ex_apprec
-
-cd ../../dist
-awk -f gen_rec.awk \
-    -v source_file=$E/ex_apprec_auto.c \
-    -v header_file=$E/ex_apprec_auto.h \
-    -v template_file=$E/ex_apprec_template < $E/ex_apprec.src

bdb/examples_c/ex_apprec/ex_apprec.c

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 1996-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_apprec.c,v 1.2 2002/08/06 05:39:01 bostic Exp $
- */
-
-#include <sys/types.h>
-#include <sys/stat.h>
-
-#include <errno.h>
-#include <stddef.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <unistd.h>
-
-#include <db.h>
-
-#include "ex_apprec.h"
-
-int	apprec_dispatch __P((DB_ENV *, DBT *, DB_LSN *, db_recops));
-int	open_env __P((const char *, FILE *, const char *, DB_ENV **));
-int	verify_absence __P((DB_ENV *, const char *));
-int	verify_presence __P((DB_ENV *, const char *));
-
-int
-main(argc, argv)
-	int argc;
-	char *argv[];
-{
-	extern char *optarg;
-	extern int optind;
-	DB_ENV *dbenv;
-	DB_LSN lsn;
-	DB_TXN *txn;
-	DBT dirnamedbt;
-	int ret;
-	const char *home;
-	char ch, dirname[256];
-	const char *progname = "ex_apprec";		/* Program name. */
-
-	/* Default home. */
-	home = "TESTDIR";
-
-	while ((ch = getopt(argc, argv, "h:")) != EOF)
-		switch (ch) {
-		case 'h':
-			home = optarg;
-			break;
-		default:
-			fprintf(stderr, "usage: %s [-h home]", progname);
-			exit(EXIT_FAILURE);
-		}
-
-	printf("Set up environment.\n");
-	if ((ret = open_env(home, stderr, progname, &dbenv)) != 0)
-		return (EXIT_FAILURE);
-
-	printf("Create a directory in a transaction.\n");
-	/*
-	 * This application's convention is to log the full directory name,
-	 * including trailing nul.
-	 */
-	memset(&dirnamedbt, 0, sizeof(dirnamedbt));
-	sprintf(dirname, "%s/MYDIRECTORY", home);
-	dirnamedbt.data = dirname;
-	dirnamedbt.size = strlen(dirname) + 1;
-
-	if ((ret = dbenv->txn_begin(dbenv, NULL, &txn, 0)) != 0) {
-		dbenv->err(dbenv, ret, "txn_begin");
-		return (EXIT_FAILURE);
-	}
-
-	/* Remember, always log actions before you execute them! */
-	memset(&lsn, 0, sizeof(lsn));
-	if ((ret =
-	    ex_apprec_mkdir_log(dbenv, txn, &lsn, 0, &dirnamedbt)) != 0) {
-		dbenv->err(dbenv, ret, "mkdir_log");
-		return (EXIT_FAILURE);
-	}
-	if (mkdir(dirname, 0755) != 0) {
-		dbenv->err(dbenv, errno, "mkdir");
-		return (EXIT_FAILURE);
-	}
-
-	printf("Verify the directory's presence: ");
-	verify_presence(dbenv, dirname);
-	printf("check.\n");
-
-	/* Now abort the transaction and verify that the directory goes away. */
-	printf("Abort the transaction.\n");
-	if ((ret = txn->abort(txn)) != 0) {
-		dbenv->err(dbenv, ret, "txn_abort");
-		return (EXIT_FAILURE);
-	}
-
-	printf("Verify the directory's absence: ");
-	verify_absence(dbenv, dirname);
-	printf("check.\n");
-
-	/* Now do the same thing over again, only with a commit this time. */
-	printf("Create a directory in a transaction.\n");
-	memset(&dirnamedbt, 0, sizeof(dirnamedbt));
-	sprintf(dirname, "%s/MYDIRECTORY", home);
-	dirnamedbt.data = dirname;
-	dirnamedbt.size = strlen(dirname) + 1;
-	if ((ret = dbenv->txn_begin(dbenv, NULL, &txn, 0)) != 0) {
-		dbenv->err(dbenv, ret, "txn_begin");
-		return (EXIT_FAILURE);
-	}
-
-	memset(&lsn, 0, sizeof(lsn));
-	if ((ret =
-	    ex_apprec_mkdir_log(dbenv, txn, &lsn, 0, &dirnamedbt)) != 0) {
-		dbenv->err(dbenv, ret, "mkdir_log");
-		return (EXIT_FAILURE);
-	}
-	if (mkdir(dirname, 0755) != 0) {
-		dbenv->err(dbenv, errno, "mkdir");
-		return (EXIT_FAILURE);
-	}
-
-	printf("Verify the directory's presence: ");
-	verify_presence(dbenv, dirname);
-	printf("check.\n");
-
-	/* Now abort the transaction and verify that the directory goes away. */
-	printf("Commit the transaction.\n");
-	if ((ret = txn->commit(txn, 0)) != 0) {
-		dbenv->err(dbenv, ret, "txn_commit");
-		return (EXIT_FAILURE);
-	}
-
-	printf("Verify the directory's presence: ");
-	verify_presence(dbenv, dirname);
-	printf("check.\n");
-
-	printf("Now remove the directory, then run recovery.\n");
-	if ((ret = dbenv->close(dbenv, 0)) != 0) {
-		fprintf(stderr, "DB_ENV->close: %s\n", db_strerror(ret));
-		return (EXIT_FAILURE);
-	}
-	if (rmdir(dirname) != 0) {
-		fprintf(stderr,
-		    "%s: rmdir failed with error %s", progname,
-		    strerror(errno));
-	}
-	verify_absence(dbenv, dirname);
-
-	/* Opening with DB_RECOVER runs recovery. */
-	if ((ret = open_env(home, stderr, progname, &dbenv)) != 0)
-		return (EXIT_FAILURE);
-
-	printf("Verify the directory's presence: ");
-	verify_presence(dbenv, dirname);
-	printf("check.\n");
-
-	/* Close the handle. */
-	if ((ret = dbenv->close(dbenv, 0)) != 0) {
-		fprintf(stderr, "DB_ENV->close: %s\n", db_strerror(ret));
-		return (EXIT_FAILURE);
-	}
-
-	return (EXIT_SUCCESS);
-}
-
-int
-open_env(home, errfp, progname, dbenvp)
-	const char *home, *progname;
-	FILE *errfp;
-	DB_ENV **dbenvp;
-{
-	DB_ENV *dbenv;
-	int ret;
-
-	/*
-	 * Create an environment object and initialize it for error
-	 * reporting.
-	 */
-	if ((ret = db_env_create(&dbenv, 0)) != 0) {
-		fprintf(errfp, "%s: %s\n", progname, db_strerror(ret));
-		return (ret);
-	}
-	dbenv->set_errfile(dbenv, errfp);
-	dbenv->set_errpfx(dbenv, progname);
-
-	/* Set up our custom recovery dispatch function. */
-	if ((ret = dbenv->set_app_dispatch(dbenv, apprec_dispatch)) != 0) {
-		dbenv->err(dbenv, ret, "set_app_dispatch");
-		return (ret);
-	}
-
-	/*
-	 * Open the environment with full transactional support, running
-	 * recovery.
-	 */
-	if ((ret =
-	    dbenv->open(dbenv, home, DB_CREATE | DB_RECOVER | DB_INIT_LOCK |
-	    DB_INIT_LOG | DB_INIT_MPOOL | DB_INIT_TXN, 0)) != 0) {
-		dbenv->err(dbenv, ret, "environment open: %s", home);
-		dbenv->close(dbenv, 0);
-		return (ret);
-	}
-
-	*dbenvp = dbenv;
-	return (0);
-}
-
-/*
- * Sample application dispatch function to handle user-specified log record
- * types.
- */
-int
-apprec_dispatch(dbenv, dbt, lsn, op)
-	DB_ENV *dbenv;
-	DBT *dbt;
-	DB_LSN *lsn;
-	db_recops op;
-{
-	u_int32_t rectype;
-
-	/* Pull the record type out of the log record. */
-	memcpy(&rectype, dbt->data, sizeof(rectype));
-
-	switch (rectype) {
-	case DB_ex_apprec_mkdir:
-		return (ex_apprec_mkdir_recover(dbenv, dbt, lsn, op, NULL));
-	default:
-		/*
-		 * We've hit an unexpected, allegedly user-defined record
-		 * type.
-		 */
-		dbenv->errx(dbenv, "Unexpected log record type encountered");
-		return (EINVAL);
-	}
-}
-
-int
-verify_absence(dbenv, dirname)
-	DB_ENV *dbenv;
-	const char *dirname;
-{
-
-	if (access(dirname, F_OK) == 0) {
-		dbenv->errx(dbenv, "Error--directory present!");
-		exit(EXIT_FAILURE);
-	}
-
-	return (0);
-}
-
-int
-verify_presence(dbenv, dirname)
-	DB_ENV *dbenv;
-	const char *dirname;
-{
-
-	if (access(dirname, F_OK) != 0) {
-		dbenv->errx(dbenv, "Error--directory not present!");
-		exit(EXIT_FAILURE);
-	}
-
-	return (0);
-}

bdb/examples_c/ex_apprec/ex_apprec.h

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_apprec.h,v 1.2 2002/08/08 15:47:00 bostic Exp $
- */
-
-#ifndef _EX_APPREC_H_
-#define	_EX_APPREC_H_
-
-#include "ex_apprec_auto.h"
-
-int ex_apprec_mkdir_log
-    __P((DB_ENV *, DB_TXN *, DB_LSN *, u_int32_t, const DBT *));
-int ex_apprec_mkdir_print
-    __P((DB_ENV *, DBT *, DB_LSN *, db_recops, void *));
-int ex_apprec_mkdir_read
-    __P((DB_ENV *, void *, ex_apprec_mkdir_args **));
-int ex_apprec_mkdir_recover
-    __P((DB_ENV *, DBT *, DB_LSN *, db_recops, void *));
-
-#endif /* !_EX_APPREC_H_ */

bdb/examples_c/ex_apprec/ex_apprec.src

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_apprec.src,v 1.3 2002/08/08 15:47:00 bostic Exp $
- */
-
-PREFIX	ex_apprec
-
-/*
- * This is the source file used to generate the application-specific recovery
- * functions used by the ex_apprec example.  It should be turned into usable
- * source code (including a template for the recovery function itself) by
- * invoking changing to the dist directory of the DB distribution and
- * running the gen_rec.awk script there as follows:
- *
- *     awk -f ./gen_rec.awk \
- *         -v source_file=../examples_c/ex_apprec/ex_apprec_auto.c         \
- *         -v header_file=../examples_c/ex_apprec/ex_apprec_auto.h         \
- *         -v template_file=../examples_c/ex_apprec/ex_apprec_template     \
- *         < ../examples_c/ex_apprec/ex_apprec.src
-
-INCLUDE #include <ctype.h>
-INCLUDE #include <errno.h>
-INCLUDE #include <stdlib.h>
-INCLUDE #include <string.h>
-INCLUDE
-INCLUDE #include <db.h>
-INCLUDE
-INCLUDE #include "ex_apprec.h"
-
-/*
- * mkdir: used to create a directory
- *
- * dirname:	relative or absolute pathname of the directory to be created
- */
-BEGIN mkdir	10000
-DBT	dirname		DBT		s
-END

bdb/examples_c/ex_apprec/ex_apprec_rec.c

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 1996-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_apprec_rec.c,v 1.2 2002/08/06 05:39:02 bostic Exp $
- */
-
-/*
- * This file is based on the template file ex_apprec_template.  Note that
- * because ex_apprec_mkdir, like most application-specific recovery functions,
- * does not make use of DB-private structures, it has actually been simplified
- * significantly.
- */
-
-#include <sys/types.h>
-#include <sys/stat.h>
-#include <errno.h>
-#include <stdlib.h>
-#include <unistd.h>
-
-#include <db.h>
-
-#include "ex_apprec.h"
-
-/*
- * ex_apprec_mkdir_recover --
- *	Recovery function for mkdir.
- *
- * PUBLIC: int ex_apprec_mkdir_recover
- * PUBLIC:   __P((DB_ENV *, DBT *, DB_LSN *, db_recops, void *));
- */
-int
-ex_apprec_mkdir_recover(dbenv, dbtp, lsnp, op, info)
-	DB_ENV *dbenv;
-	DBT *dbtp;
-	DB_LSN *lsnp;
-	db_recops op;
-	void *info;
-{
-	ex_apprec_mkdir_args *argp;
-	int ret;
-
-	argp = NULL;
-
-	/*
-	 * Shut up the compiler--"info" is used for the recovery functions
-	 * belonging to transaction meta-operations such as txn_create, and
-	 * need not concern us here either.
-	 */
-	info = NULL;
-
-	if ((ret = ex_apprec_mkdir_read(dbenv, dbtp->data, &argp)) != 0)
-		goto out;
-
-	switch (op) {
-	case DB_TXN_ABORT:
-	case DB_TXN_BACKWARD_ROLL:
-		/*
-		 * If we're aborting, we need to remove the directory if it
-		 * exists.  We log the trailing zero in pathnames, so we can
-		 * simply pass the data part of the DBT into rmdir as a string.
-		 * (Note that we don't have any alignment guarantees, but for
-		 * a char * this doesn't matter.)
-		 *
-		 * Ignore all errors other than ENOENT;  DB may attempt to undo
-		 * or redo operations without knowing whether they have already
-		 * been done or undone, so we should never assume in a recovery
-		 * function that the task definitely needs doing or undoing.
-		 */
-		ret = rmdir(argp->dirname.data);
-		if (ret != 0 && errno != ENOENT)
-			dbenv->err(dbenv, ret, "Error in abort of mkdir");
-		else
-			ret = 0;
-		break;
-	case DB_TXN_FORWARD_ROLL:
-		/*
-		 * The forward direction is just the opposite;  here, we ignore
-		 * EEXIST, because the directory may already exist.
-		 */
-		ret = mkdir(argp->dirname.data, 0755);
-		if (ret != 0 && errno != EEXIST)
-			dbenv->err(dbenv,
-			    ret, "Error in roll-forward of mkdir");
-		else
-			ret = 0;
-		break;
-	default:
-		/*
-		 * We might want to handle DB_TXN_PRINT or DB_TXN_APPLY here,
-		 * too, but we don't try to print the log records and aren't
-		 * using replication, so there's no need to in this example.
-		 */
-		dbenv->errx(dbenv, "Unexpected operation type\n");
-		return (EINVAL);
-	}
-
-	/*
-	 * The recovery function is responsible for returning the LSN of the
-	 * previous log record in this transaction, so that transaction aborts
-	 * can follow the chain backwards.
-	 *
-	 * (If we'd wanted the LSN of this record earlier, we could have
-	 * read it from lsnp, as well--but because we weren't working with
-	 * pages or other objects that store their LSN and base recovery
-	 * decisions on it, we didn't need to.)
-	 */
-	*lsnp = argp->prev_lsn;
-
-out:	if (argp != NULL)
-		free(argp);
-	return (ret);
-}

bdb/examples_c/ex_btrec.c

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 1997-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_btrec.c,v 11.18 2002/01/23 15:33:18 bostic Exp $
- */
-
-#include <sys/types.h>
-
-#include <errno.h>
-#include <stdlib.h>
-#include <string.h>
-
-#include <db.h>
-
-#define	DATABASE	"access.db"
-#define	WORDLIST	"../test/wordlist"
-int	main __P((void));
-
-int	ex_btrec __P((void));
-void	show __P((const char *, DBT *, DBT *));
-
-int
-main()
-{
-	return (ex_btrec() == 1 ? EXIT_FAILURE : EXIT_SUCCESS);
-}
-
-int
-ex_btrec()
-{
-	DB *dbp;
-	DBC *dbcp;
-	DBT key, data;
-	DB_BTREE_STAT *statp;
-	FILE *fp;
-	db_recno_t recno;
-	u_int32_t len;
-	int cnt, ret;
-	char *p, *t, buf[1024], rbuf[1024];
-	const char *progname = "ex_btrec";		/* Program name. */
-
-	/* Open the word database. */
-	if ((fp = fopen(WORDLIST, "r")) == NULL) {
-		fprintf(stderr, "%s: open %s: %s\n",
-		    progname, WORDLIST, db_strerror(errno));
-		return (1);
-	}
-
-	/* Remove the previous database. */
-	(void)remove(DATABASE);
-
-	/* Create and initialize database object, open the database. */
-	if ((ret = db_create(&dbp, NULL, 0)) != 0) {
-		fprintf(stderr,
-		    "%s: db_create: %s\n", progname, db_strerror(ret));
-		return (1);
-	}
-	dbp->set_errfile(dbp, stderr);
-	dbp->set_errpfx(dbp, progname);			/* 1K page sizes. */
-	if ((ret = dbp->set_pagesize(dbp, 1024)) != 0) {
-		dbp->err(dbp, ret, "set_pagesize");
-		return (1);
-	}						/* Record numbers. */
-	if ((ret = dbp->set_flags(dbp, DB_RECNUM)) != 0) {
-		dbp->err(dbp, ret, "set_flags: DB_RECNUM");
-		return (1);
-	}
-	if ((ret = dbp->open(dbp,
-	    NULL, DATABASE, NULL, DB_BTREE, DB_CREATE, 0664)) != 0) {
-		dbp->err(dbp, ret, "open: %s", DATABASE);
-		return (1);
-	}
-
-	/*
-	 * Insert records into the database, where the key is the word
-	 * preceded by its record number, and the data is the same, but
-	 * in reverse order.
-	 */
-	memset(&key, 0, sizeof(DBT));
-	memset(&data, 0, sizeof(DBT));
-	for (cnt = 1; cnt <= 1000; ++cnt) {
-		(void)sprintf(buf, "%04d_", cnt);
-		if (fgets(buf + 4, sizeof(buf) - 4, fp) == NULL)
-			break;
-		len = strlen(buf);
-		for (t = rbuf, p = buf + (len - 2); p >= buf;)
-			*t++ = *p--;
-		*t++ = '\0';
-
-		key.data = buf;
-		data.data = rbuf;
-		data.size = key.size = len - 1;
-
-		if ((ret =
-		    dbp->put(dbp, NULL, &key, &data, DB_NOOVERWRITE)) != 0) {
-			dbp->err(dbp, ret, "DB->put");
-			if (ret != DB_KEYEXIST)
-				goto err1;
-		}
-	}
-
-	/* Close the word database. */
-	(void)fclose(fp);
-
-	/* Print out the number of records in the database. */
-	if ((ret = dbp->stat(dbp, &statp, 0)) != 0) {
-		dbp->err(dbp, ret, "DB->stat");
-		goto err1;
-	}
-	printf("%s: database contains %lu records\n",
-	    progname, (u_long)statp->bt_ndata);
-	free(statp);
-
-	/* Acquire a cursor for the database. */
-	if ((ret = dbp->cursor(dbp, NULL, &dbcp, 0)) != 0) {
-		dbp->err(dbp, ret, "DB->cursor");
-		goto err1;
-	}
-
-	/*
-	 * Prompt the user for a record number, then retrieve and display
-	 * that record.
-	 */
-	for (;;) {
-		/* Get a record number. */
-		printf("recno #> ");
-		fflush(stdout);
-		if (fgets(buf, sizeof(buf), stdin) == NULL)
-			break;
-		recno = atoi(buf);
-
-		/*
-		 * Reset the key each time, the dbp->c_get() routine returns
-		 * the key and data pair, not just the key!
-		 */
-		key.data = &recno;
-		key.size = sizeof(recno);
-		if ((ret = dbcp->c_get(dbcp, &key, &data, DB_SET_RECNO)) != 0)
-			goto get_err;
-
-		/* Display the key and data. */
-		show("k/d\t", &key, &data);
-
-		/* Move the cursor a record forward. */
-		if ((ret = dbcp->c_get(dbcp, &key, &data, DB_NEXT)) != 0)
-			goto get_err;
-
-		/* Display the key and data. */
-		show("next\t", &key, &data);
-
-		/*
-		 * Retrieve the record number for the following record into
-		 * local memory.
-		 */
-		data.data = &recno;
-		data.size = sizeof(recno);
-		data.ulen = sizeof(recno);
-		data.flags |= DB_DBT_USERMEM;
-		if ((ret = dbcp->c_get(dbcp, &key, &data, DB_GET_RECNO)) != 0) {
-get_err:		dbp->err(dbp, ret, "DBcursor->get");
-			if (ret != DB_NOTFOUND && ret != DB_KEYEMPTY)
-				goto err2;
-		} else
-			printf("retrieved recno: %lu\n", (u_long)recno);
-
-		/* Reset the data DBT. */
-		memset(&data, 0, sizeof(data));
-	}
-
-	if ((ret = dbcp->c_close(dbcp)) != 0) {
-		dbp->err(dbp, ret, "DBcursor->close");
-		goto err1;
-	}
-	if ((ret = dbp->close(dbp, 0)) != 0) {
-		fprintf(stderr,
-		    "%s: DB->close: %s\n", progname, db_strerror(ret));
-		return (1);
-	}
-
-	return (0);
-
-err2:	(void)dbcp->c_close(dbcp);
-err1:	(void)dbp->close(dbp, 0);
-	return (ret);
-
-}
-
-/*
- * show --
- *	Display a key/data pair.
- */
-void
-show(msg, key, data)
-	const char *msg;
-	DBT *key, *data;
-{
-	printf("%s%.*s : %.*s\n", msg,
-	    (int)key->size, (char *)key->data,
-	    (int)data->size, (char *)data->data);
-}

bdb/examples_c/ex_dbclient.c

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 1996-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_dbclient.c,v 1.28 2002/08/06 06:11:24 bostic Exp $
- */
-
-#include <sys/types.h>
-
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <unistd.h>
-
-#include <db.h>
-
-#define	DATABASE_HOME	"database"
-
-#define	DATABASE	"access.db"
-
-int	db_clientrun __P((DB_ENV *, const char *));
-int	ex_dbclient_run __P((const char *, FILE *, const char *, const char *));
-int	main __P((int, char *[]));
-
-/*
- * An example of a program creating/configuring a Berkeley DB environment.
- */
-int
-main(argc, argv)
-	int argc;
-	char *argv[];
-{
-	const char *home;
-
-	if (argc != 2) {
-		fprintf(stderr, "Usage: %s hostname\n", argv[0]);
-		return (EXIT_FAILURE);
-	}
-
-	/*
-	 * All of the shared database files live in DATABASE_HOME, but
-	 * data files will live in CONFIG_DATA_DIR.
-	 */
-	home = DATABASE_HOME;
-	return (ex_dbclient_run(home,
-	    stderr, argv[1], argv[0]) == 0 ? EXIT_SUCCESS : EXIT_FAILURE);
-}
-
-int
-ex_dbclient(host)
-	const char *host;
-{
-	const char *home;
-	const char *progname = "ex_dbclient";		/* Program name. */
-	int ret;
-
-	/*
-	 * All of the shared database files live in DATABASE_HOME, but
-	 * data files will live in CONFIG_DATA_DIR.
-	 */
-	home = DATABASE_HOME;
-
-	if ((ret = ex_dbclient_run(home, stderr, host, progname)) != 0)
-		return (ret);
-
-	return (0);
-}
-
-int
-ex_dbclient_run(home, errfp, host, progname)
-	const char *home, *host, *progname;
-	FILE *errfp;
-{
-	DB_ENV *dbenv;
-	int ret, retry;
-
-	/*
-	 * Create an environment object and initialize it for error
-	 * reporting.
-	 */
-	if ((ret = db_env_create(&dbenv, DB_CLIENT)) != 0) {
-		fprintf(errfp, "%s: %s\n", progname, db_strerror(ret));
-		return (1);
-	}
-	retry = 0;
-retry:
-	while (retry < 5) {
-		/*
-		 * Set the server host we are talking to.
-		 */
-		if ((ret = dbenv->set_rpc_server(dbenv, NULL, host, 10000,
-		    10000, 0)) != 0) {
-			fprintf(stderr, "Try %d: DB_ENV->set_rpc_server: %s\n",
-			    retry, db_strerror(ret));
-			retry++;
-			sleep(15);
-		} else
-			break;
-	}
-
-	if (retry >= 5) {
-		fprintf(stderr,
-		    "DB_ENV->set_rpc_server: %s\n", db_strerror(ret));
-		dbenv->close(dbenv, 0);
-		return (1);
-	}
-	/*
-	 * We want to specify the shared memory buffer pool cachesize,
-	 * but everything else is the default.
-	 */
-	if ((ret = dbenv->set_cachesize(dbenv, 0, 64 * 1024, 0)) != 0) {
-		dbenv->err(dbenv, ret, "set_cachesize");
-		dbenv->close(dbenv, 0);
-		return (1);
-	}
-	/*
-	 * We have multiple processes reading/writing these files, so
-	 * we need concurrency control and a shared buffer pool, but
-	 * not logging or transactions.
-	 */
-	if ((ret = dbenv->open(dbenv, home,
-	    DB_CREATE | DB_INIT_LOCK | DB_INIT_MPOOL, 0)) != 0) {
-		dbenv->err(dbenv, ret, "environment open: %s", home);
-		dbenv->close(dbenv, 0);
-		if (ret == DB_NOSERVER)
-			goto retry;
-		return (1);
-	}
-
-	ret = db_clientrun(dbenv, progname);
-	printf("db_clientrun returned %d\n", ret);
-	if (ret == DB_NOSERVER)
-		goto retry;
-
-	/* Close the handle. */
-	if ((ret = dbenv->close(dbenv, 0)) != 0) {
-		fprintf(stderr, "DB_ENV->close: %s\n", db_strerror(ret));
-		return (1);
-	}
-	return (0);
-}
-
-int
-db_clientrun(dbenv, progname)
-	DB_ENV *dbenv;
-	const char *progname;
-{
-	DB *dbp;
-	DBT key, data;
-	u_int32_t len;
-	int ret;
-	char *p, *t, buf[1024], rbuf[1024];
-
-	/* Remove the previous database. */
-
-	/* Create and initialize database object, open the database. */
-	if ((ret = db_create(&dbp, dbenv, 0)) != 0) {
-		fprintf(stderr,
-		    "%s: db_create: %s\n", progname, db_strerror(ret));
-		return (ret);
-	}
-	if ((ret = dbp->set_pagesize(dbp, 1024)) != 0) {
-		dbp->err(dbp, ret, "set_pagesize");
-		goto err1;
-	}
-	if ((ret = dbp->open(dbp,
-	    NULL, DATABASE, NULL, DB_BTREE, DB_CREATE, 0664)) != 0) {
-		dbp->err(dbp, ret, "%s: open", DATABASE);
-		goto err1;
-	}
-
-	/*
-	 * Insert records into the database, where the key is the user
-	 * input and the data is the user input in reverse order.
-	 */
-	memset(&key, 0, sizeof(DBT));
-	memset(&data, 0, sizeof(DBT));
-	for (;;) {
-		printf("input> ");
-		fflush(stdout);
-		if (fgets(buf, sizeof(buf), stdin) == NULL)
-			break;
-		if ((len = strlen(buf)) <= 1)
-			continue;
-		for (t = rbuf, p = buf + (len - 2); p >= buf;)
-			*t++ = *p--;
-		*t++ = '\0';
-
-		key.data = buf;
-		data.data = rbuf;
-		data.size = key.size = len - 1;
-
-		switch (ret =
-		    dbp->put(dbp, NULL, &key, &data, DB_NOOVERWRITE)) {
-		case 0:
-			break;
-		default:
-			dbp->err(dbp, ret, "DB->put");
-			if (ret != DB_KEYEXIST)
-				goto err1;
-			break;
-		}
-		memset(&data, 0, sizeof(DBT));
-		switch (ret = dbp->get(dbp, NULL, &key, &data, 0)) {
-		case 0:
-			printf("%.*s : %.*s\n",
-			    (int)key.size, (char *)key.data,
-			    (int)data.size, (char *)data.data);
-			break;
-		default:
-			dbp->err(dbp, ret, "DB->get");
-			break;
-		}
-	}
-	if ((ret = dbp->close(dbp, 0)) != 0) {
-		fprintf(stderr,
-		    "%s: DB->close: %s\n", progname, db_strerror(ret));
-		return (1);
-	}
-	return (0);
-
-err1:	(void)dbp->close(dbp, 0);
-	return (ret);
-}

bdb/examples_c/ex_env.c

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 1996-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_env.c,v 11.27 2002/08/15 14:34:11 bostic Exp $
- */
-
-#include <sys/types.h>
-
-#include <stddef.h>
-#include <stdio.h>
-#include <stdlib.h>
-
-#include <db.h>
-
-#ifdef macintosh
-#define	DATABASE_HOME	":database"
-#define	CONFIG_DATA_DIR	":database"
-#else
-#ifdef DB_WIN32
-#define	DATABASE_HOME	"\\tmp\\database"
-#define	CONFIG_DATA_DIR	"\\database\\files"
-#else
-#define	DATABASE_HOME	"/tmp/database"
-#define	CONFIG_DATA_DIR	"/database/files"
-#endif
-#endif
-
-int	db_setup __P((const char *, const char *, FILE *, const char *));
-int	db_teardown __P((const char *, const char *, FILE *, const char *));
-int	main __P((void));
-
-/*
- * An example of a program creating/configuring a Berkeley DB environment.
- */
-int
-main()
-{
-	const char *data_dir, *home;
-	const char *progname = "ex_env";		/* Program name. */
-
-	/*
-	 * All of the shared database files live in DATABASE_HOME, but
-	 * data files will live in CONFIG_DATA_DIR.
-	 */
-	home = DATABASE_HOME;
-	data_dir = CONFIG_DATA_DIR;
-
-	printf("Setup env\n");
-	if (db_setup(home, data_dir, stderr, progname) != 0)
-		return (EXIT_FAILURE);
-
-	printf("Teardown env\n");
-	if (db_teardown(home, data_dir, stderr, progname) != 0)
-		return (EXIT_FAILURE);
-
-	return (EXIT_SUCCESS);
-}
-
-int
-db_setup(home, data_dir, errfp, progname)
-	const char *home, *data_dir, *progname;
-	FILE *errfp;
-{
-	DB_ENV *dbenv;
-	int ret;
-
-	/*
-	 * Create an environment object and initialize it for error
-	 * reporting.
-	 */
-	if ((ret = db_env_create(&dbenv, 0)) != 0) {
-		fprintf(errfp, "%s: %s\n", progname, db_strerror(ret));
-		return (1);
-	}
-	dbenv->set_errfile(dbenv, errfp);
-	dbenv->set_errpfx(dbenv, progname);
-
-	/*
-	 * We want to specify the shared memory buffer pool cachesize,
-	 * but everything else is the default.
-	 */
-	if ((ret = dbenv->set_cachesize(dbenv, 0, 64 * 1024, 0)) != 0) {
-		dbenv->err(dbenv, ret, "set_cachesize");
-		dbenv->close(dbenv, 0);
-		return (1);
-	}
-
-	/* Databases are in a subdirectory. */
-	(void)dbenv->set_data_dir(dbenv, data_dir);
-
-	/* Open the environment with full transactional support. */
-	if ((ret = dbenv->open(dbenv, home,
-    DB_CREATE | DB_INIT_LOCK | DB_INIT_LOG | DB_INIT_MPOOL | DB_INIT_TXN,
-	    0)) != 0) {
-		dbenv->err(dbenv, ret, "environment open: %s", home);
-		dbenv->close(dbenv, 0);
-		return (1);
-	}
-
-	/* Do something interesting... */
-
-	/* Close the handle. */
-	if ((ret = dbenv->close(dbenv, 0)) != 0) {
-		fprintf(stderr, "DB_ENV->close: %s\n", db_strerror(ret));
-		return (1);
-	}
-	return (0);
-}
-
-int
-db_teardown(home, data_dir, errfp, progname)
-	const char *home, *data_dir, *progname;
-	FILE *errfp;
-{
-	DB_ENV *dbenv;
-	int ret;
-
-	/* Remove the shared database regions. */
-	if ((ret = db_env_create(&dbenv, 0)) != 0) {
-		fprintf(errfp, "%s: %s\n", progname, db_strerror(ret));
-		return (1);
-	}
-	dbenv->set_errfile(dbenv, errfp);
-	dbenv->set_errpfx(dbenv, progname);
-
-	(void)dbenv->set_data_dir(dbenv, data_dir);
-	if ((ret = dbenv->remove(dbenv, home, 0)) != 0) {
-		fprintf(stderr, "DB_ENV->remove: %s\n", db_strerror(ret));
-		return (1);
-	}
-	return (0);
-}

bdb/examples_c/ex_lock.c

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 1997-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_lock.c,v 11.18 2002/04/10 21:48:20 bostic Exp $
- */
-
-#include <sys/types.h>
-
-#include <stdlib.h>
-#include <string.h>
-
-#ifdef _WIN32
-extern int getopt(int, char * const *, const char *);
-#else
-#include <unistd.h>
-#endif
-
-#include <db.h>
-
-int db_init __P((const char *, u_int32_t, int));
-int main __P((int, char *[]));
-int usage __P((void));
-
-DB_ENV	 *dbenv;
-const char
-	*progname = "ex_lock";				/* Program name. */
-
-int
-main(argc, argv)
-	int argc;
-	char *argv[];
-{
-	extern char *optarg;
-	extern int optind;
-	DBT lock_dbt;
-	DB_LOCK lock;
-	DB_LOCK *locks;
-	db_lockmode_t lock_type;
-	long held;
-	u_int32_t len, locker, maxlocks;
-	int ch, do_unlink, did_get, i, lockid, lockcount, ret;
-	const char *home;
-	char opbuf[16], objbuf[1024], lockbuf[16];
-
-	home = "TESTDIR";
-	maxlocks = 0;
-	do_unlink = 0;
-	while ((ch = getopt(argc, argv, "h:m:u")) != EOF)
-		switch (ch) {
-		case 'h':
-			home = optarg;
-			break;
-		case 'm':
-			if ((i = atoi(optarg)) <= 0)
-				return (usage());
-			maxlocks = (u_int32_t)i;  /* XXX: possible overflow. */
-			break;
-		case 'u':
-			do_unlink = 1;
-			break;
-		case '?':
-		default:
-			return (usage());
-		}
-	argc -= optind;
-	argv += optind;
-
-	if (argc != 0)
-		return (usage());
-
-	/* Initialize the database environment. */
-	if ((ret = db_init(home, maxlocks, do_unlink)) != 0)
-		return (ret);
-
-	locks = 0;
-	lockcount = 0;
-
-	/*
-	 * Accept lock requests.
-	 */
-	if ((ret = dbenv->lock_id(dbenv, &locker)) != 0) {
-		dbenv->err(dbenv, ret, "unable to get locker id");
-		(void)dbenv->close(dbenv, 0);
-		return (EXIT_FAILURE);
-	}
-	lockid = -1;
-
-	memset(&lock_dbt, 0, sizeof(lock_dbt));
-	for (held = 0, did_get = 0;;) {
-		printf("Operation get/release [get]> ");
-		fflush(stdout);
-		if (fgets(opbuf, sizeof(opbuf), stdin) == NULL)
-			break;
-		if ((len = strlen(opbuf)) <= 1 || strcmp(opbuf, "get\n") == 0) {
-			/* Acquire a lock. */
-			printf("input object (text string) to lock> ");
-			fflush(stdout);
-			if (fgets(objbuf, sizeof(objbuf), stdin) == NULL)
-				break;
-			if ((len = strlen(objbuf)) <= 1)
-				continue;
-
-			do {
-				printf("lock type read/write [read]> ");
-				fflush(stdout);
-				if (fgets(lockbuf,
-				    sizeof(lockbuf), stdin) == NULL)
-					break;
-				len = strlen(lockbuf);
-			} while (len > 1 &&
-			    strcmp(lockbuf, "read\n") != 0 &&
-			    strcmp(lockbuf, "write\n") != 0);
-			if (len == 1 || strcmp(lockbuf, "read\n") == 0)
-				lock_type = DB_LOCK_READ;
-			else
-				lock_type = DB_LOCK_WRITE;
-
-			lock_dbt.data = objbuf;
-			lock_dbt.size = strlen(objbuf);
-			ret = dbenv->lock_get(dbenv, locker,
-			    DB_LOCK_NOWAIT, &lock_dbt, lock_type, &lock);
-			if (ret == 0) {
-				did_get = 1;
-				lockid = lockcount++;
-				if (locks == NULL)
-					locks =
-					    (DB_LOCK *)malloc(sizeof(DB_LOCK));
-				else
-					locks = (DB_LOCK *)realloc(locks,
-					    lockcount * sizeof(DB_LOCK));
-				locks[lockid] = lock;
-			}
-		} else {
-			/* Release a lock. */
-			do {
-				printf("input lock to release> ");
-				fflush(stdout);
-				if (fgets(objbuf,
-				    sizeof(objbuf), stdin) == NULL)
-					break;
-			} while ((len = strlen(objbuf)) <= 1);
-			lockid = strtol(objbuf, NULL, 16);
-			if (lockid < 0 || lockid >= lockcount) {
-				printf("Lock #%d out of range\n", lockid);
-				continue;
-			}
-			lock = locks[lockid];
-			ret = dbenv->lock_put(dbenv, &lock);
-			did_get = 0;
-		}
-		switch (ret) {
-		case 0:
-			printf("Lock #%d %s\n", lockid,
-			    did_get ? "granted" : "released");
-			held += did_get ? 1 : -1;
-			break;
-		case DB_LOCK_NOTGRANTED:
-			dbenv->err(dbenv, ret, NULL);
-			break;
-		case DB_LOCK_DEADLOCK:
-			dbenv->err(dbenv, ret,
-			    "lock_%s", did_get ? "get" : "put");
-			break;
-		default:
-			dbenv->err(dbenv, ret,
-			    "lock_%s", did_get ? "get" : "put");
-			(void)dbenv->close(dbenv, 0);
-			return (EXIT_FAILURE);
-		}
-	}
-
-	printf("\nClosing lock region %ld locks held\n", held);
-
-	if (locks != NULL)
-		free(locks);
-
-	if ((ret = dbenv->close(dbenv, 0)) != 0) {
-		fprintf(stderr,
-		    "%s: dbenv->close: %s\n", progname, db_strerror(ret));
-		return (EXIT_FAILURE);
-	}
-	return (EXIT_SUCCESS);
-}
-
-/*
- * db_init --
- *	Initialize the environment.
- */
-int
-db_init(home, maxlocks, do_unlink)
-	const char *home;
-	u_int32_t maxlocks;
-	int do_unlink;
-{
-	int ret;
-
-	if ((ret = db_env_create(&dbenv, 0)) != 0) {
-		fprintf(stderr, "%s: db_env_create: %s\n",
-		    progname, db_strerror(ret));
-		return (EXIT_FAILURE);
-	}
-
-	if (do_unlink) {
-		if ((ret = dbenv->remove(dbenv, home, DB_FORCE)) != 0) {
-			fprintf(stderr, "%s: dbenv->remove: %s\n",
-			    progname, db_strerror(ret));
-			return (EXIT_FAILURE);
-		}
-		if ((ret = db_env_create(&dbenv, 0)) != 0) {
-			fprintf(stderr, "%s: db_env_create: %s\n",
-			    progname, db_strerror(ret));
-			return (EXIT_FAILURE);
-		}
-	}
-
-	dbenv->set_errfile(dbenv, stderr);
-	dbenv->set_errpfx(dbenv, progname);
-	if (maxlocks != 0)
-		dbenv->set_lk_max_locks(dbenv, maxlocks);
-
-	if ((ret =
-	    dbenv->open(dbenv, home, DB_CREATE | DB_INIT_LOCK, 0)) != 0) {
-		dbenv->err(dbenv, ret, NULL);
-		(void)dbenv->close(dbenv, 0);
-		return (EXIT_FAILURE);
-	}
-	return (0);
-}
-
-int
-usage()
-{
-	(void)fprintf(stderr,
-	    "usage: %s [-u] [-h home] [-m maxlocks]\n", progname);
-	return (EXIT_FAILURE);
-}

bdb/examples_c/ex_mpool.c

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 1997-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_mpool.c,v 11.26 2002/08/15 14:34:56 bostic Exp $
- */
-
-#include <sys/types.h>
-
-#include <errno.h>
-#include <fcntl.h>
-#include <stdlib.h>
-#include <string.h>
-#include <time.h>
-
-#ifdef _WIN32
-extern int getopt(int, char * const *, const char *);
-#else
-#include <unistd.h>
-#endif
-
-#include <db.h>
-
-int	init __P((const char *, int, int, const char *));
-int	run __P((int, int, int, int, const char *));
-int	run_mpool __P((int, int, int, int, const char *));
-int	main __P((int, char *[]));
-int	usage __P((const char *));
-#define	MPOOL	"mpool"					/* File. */
-
-int
-main(argc, argv)
-	int argc;
-	char *argv[];
-{
-	extern char *optarg;
-	extern int optind;
-	int cachesize, ch, hits, npages, pagesize;
-	char *progname;
-
-	cachesize = 20 * 1024;
-	hits = 1000;
-	npages = 50;
-	pagesize = 1024;
-	progname = argv[0];
-	while ((ch = getopt(argc, argv, "c:h:n:p:")) != EOF)
-		switch (ch) {
-		case 'c':
-			if ((cachesize = atoi(optarg)) < 20 * 1024)
-				return (usage(progname));
-			break;
-		case 'h':
-			if ((hits = atoi(optarg)) <= 0)
-				return (usage(progname));
-			break;
-		case 'n':
-			if ((npages = atoi(optarg)) <= 0)
-				return (usage(progname));
-			break;
-		case 'p':
-			if ((pagesize = atoi(optarg)) <= 0)
-				return (usage(progname));
-			break;
-		case '?':
-		default:
-			return (usage(progname));
-		}
-	argc -= optind;
-	argv += optind;
-
-	return (run_mpool(pagesize, cachesize,
-	    hits, npages, progname) == 0 ? EXIT_SUCCESS : EXIT_FAILURE);
-}
-
-int
-usage(progname)
-	const char *progname;
-{
-	(void)fprintf(stderr,
-	    "usage: %s [-c cachesize] [-h hits] [-n npages] [-p pagesize]\n",
-	    progname);
-	return (EXIT_FAILURE);
-}
-
-int
-run_mpool(pagesize, cachesize, hits, npages, progname)
-	int pagesize, cachesize, hits, npages;
-	const char *progname;
-{
-	int ret;
-
-	/* Initialize the file. */
-	if ((ret = init(MPOOL, pagesize, npages, progname)) != 0)
-		return (ret);
-
-	/* Get the pages. */
-	if ((ret = run(hits, cachesize, pagesize, npages, progname)) != 0)
-		return (ret);
-
-	return (0);
-}
-
-/*
- * init --
- *	Create a backing file.
- */
-int
-init(file, pagesize, npages, progname)
-	const char *file, *progname;
-	int pagesize, npages;
-{
-	FILE *fp;
-	int cnt;
-	char *p;
-
-	/*
-	 * Create a file with the right number of pages, and store a page
-	 * number on each page.
-	 */
-	if ((fp = fopen(file, "wb")) == NULL) {
-		fprintf(stderr,
-		    "%s: %s: %s\n", progname, file, strerror(errno));
-		return (1);
-	}
-	if ((p = (char *)malloc(pagesize)) == NULL) {
-		fprintf(stderr, "%s: %s\n", progname, strerror(ENOMEM));
-		return (1);
-	}
-
-	/* The pages are numbered from 0. */
-	for (cnt = 0; cnt <= npages; ++cnt) {
-		*(int *)p = cnt;
-		if (fwrite(p, pagesize, 1, fp) != 1) {
-			fprintf(stderr,
-			    "%s: %s: %s\n", progname, file, strerror(errno));
-			return (1);
-		}
-	}
-
-	(void)fclose(fp);
-	free(p);
-	return (0);
-}
-
-/*
- * run --
- *	Get a set of pages.
- */
-int
-run(hits, cachesize, pagesize, npages, progname)
-	int hits, cachesize, pagesize, npages;
-	const char *progname;
-{
-	DB_ENV *dbenv;
-	DB_MPOOLFILE *mfp;
-	db_pgno_t pageno;
-	int cnt, ret;
-	void *p;
-
-	dbenv = NULL;
-	mfp = NULL;
-
-	printf("%s: cachesize: %d; pagesize: %d; N pages: %d\n",
-	    progname, cachesize, pagesize, npages);
-
-	/*
-	 * Open a memory pool, specify a cachesize, output error messages
-	 * to stderr.
-	 */
-	if ((ret = db_env_create(&dbenv, 0)) != 0) {
-		fprintf(stderr,
-		    "%s: db_env_create: %s\n", progname, db_strerror(ret));
-		return (1);
-	}
-	dbenv->set_errfile(dbenv, stderr);
-	dbenv->set_errpfx(dbenv, progname);
-#ifdef HAVE_VXWORKS
-	if ((ret = dbenv->set_shm_key(dbenv, VXSHM_KEY)) != 0) {
-		dbenv->err(dbenv, ret, "set_shm_key");
-		return (1);
-	}
-#endif
-
-	/* Set the cachesize. */
-	if ((ret = dbenv->set_cachesize(dbenv, 0, cachesize, 0)) != 0) {
-		dbenv->err(dbenv, ret, "set_cachesize");
-		goto err;
-	}
-
-	/* Open the environment. */
-	if ((ret = dbenv->open(
-	    dbenv, NULL, DB_CREATE | DB_INIT_MPOOL, 0)) != 0) {
-		dbenv->err(dbenv, ret, "DB_ENV->open");
-		goto err;
-	}
-
-	/* Open the file in the environment. */
-	if ((ret = dbenv->memp_fcreate(dbenv, &mfp, 0)) != 0) {
-		dbenv->err(dbenv, ret, "DB_ENV->memp_fcreate: %s", MPOOL);
-		goto err;
-	}
-	if ((ret = mfp->open(mfp, MPOOL, 0, 0, pagesize)) != 0) {
-		dbenv->err(dbenv, ret, "DB_MPOOLFILE->open: %s", MPOOL);
-		goto err;
-	}
-
-	printf("retrieve %d random pages... ", hits);
-
-	srand((u_int)time(NULL));
-	for (cnt = 0; cnt < hits; ++cnt) {
-		pageno = (rand() % npages) + 1;
-		if ((ret = mfp->get(mfp, &pageno, 0, &p)) != 0) {
-			dbenv->err(dbenv, ret,
-			    "unable to retrieve page %lu", (u_long)pageno);
-			goto err;
-		}
-		if (*(db_pgno_t *)p != pageno) {
-			dbenv->errx(dbenv,
-			    "wrong page retrieved (%lu != %d)",
-			    (u_long)pageno, *(int *)p);
-			goto err;
-		}
-		if ((ret = mfp->put(mfp, p, 0)) != 0) {
-			dbenv->err(dbenv, ret,
-			    "unable to return page %lu", (u_long)pageno);
-			goto err;
-		}
-	}
-
-	printf("successful.\n");
-
-	/* Close the file. */
-	if ((ret = mfp->close(mfp, 0)) != 0) {
-		dbenv->err(dbenv, ret, "DB_MPOOLFILE->close");
-		goto err;
-	}
-
-	/* Close the pool. */
-	if ((ret = dbenv->close(dbenv, 0)) != 0) {
-		fprintf(stderr,
-		    "%s: db_env_create: %s\n", progname, db_strerror(ret));
-		return (1);
-	}
-	return (0);
-
-err:	if (mfp != NULL)
-		(void)mfp->close(mfp, 0);
-	if (dbenv != NULL)
-		(void)dbenv->close(dbenv, 0);
-	return (1);
-}

bdb/examples_c/ex_repquote/ex_repquote.h

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 2001-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_repquote.h,v 1.27 2002/04/23 04:27:50 krinsky Exp $
- */
-
-#ifndef _EX_REPQUOTE_H_
-#define	_EX_REPQUOTE_H_
-
-#define	SELF_EID	1
-
-typedef struct {
-	char *host;		/* Host name. */
-	u_int32_t port;		/* Port on which to connect to this site. */
-} repsite_t;
-
-/* Globals */
-extern int master_eid;
-extern char *myaddr;
-
-struct __member;	typedef struct __member member_t;
-struct __machtab;	typedef struct __machtab machtab_t;
-
-/* Arguments for the connect_all thread. */
-typedef struct {
-	DB_ENV *dbenv;
-	const char *progname;
-	const char *home;
-	machtab_t *machtab;
-	repsite_t *sites;
-	int nsites;
-} all_args;
-
-/* Arguments for the connect_loop thread. */
-typedef struct {
-	DB_ENV *dbenv;
-	const char * home;
-	const char * progname;
-	machtab_t *machtab;
-	int port;
-} connect_args;
-
-#define	CACHESIZE	(10 * 1024 * 1024)
-#define	DATABASE	"quote.db"
-#define	SLEEPTIME	3
-
-void *connect_all __P((void *args));
-void *connect_thread __P((void *args));
-int doclient __P((DB_ENV *, const char *, machtab_t *));
-int domaster __P((DB_ENV *, const char *));
-int get_accepted_socket __P((const char *, int));
-int get_connected_socket __P((machtab_t *, const char *, const char *, int, int *, int *));
-int get_next_message __P((int, DBT *, DBT *));
-int listen_socket_init __P((const char *, int));
-int listen_socket_accept __P((machtab_t *, const char *, int, int *));
-int machtab_getinfo __P((machtab_t *, int, u_int32_t *, int *));
-int machtab_init __P((machtab_t **, int, int));
-void machtab_parm __P((machtab_t *, int *, int *, u_int32_t *));
-int machtab_rem __P((machtab_t *, int, int));
-int quote_send __P((DB_ENV *, const DBT *, const DBT *, int, u_int32_t));
-
-#ifndef COMPQUIET
-#define	COMPQUIET(x,y)	x = (y)
-#endif
-
-#endif /* !_EX_REPQUOTE_H_ */

bdb/examples_c/ex_repquote/ex_rq_client.c

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 2001-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_rq_client.c,v 1.29 2002/01/23 15:33:19 bostic Exp $
- */
-
-#include <sys/types.h>
-#include <sys/wait.h>
-
-#include <errno.h>
-#include <pthread.h>
-#include <signal.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <unistd.h>
-
-#include <db.h>
-
-#include "ex_repquote.h"
-
-static void *check_loop __P((void *));
-static void *display_loop __P((void *));
-static int print_stocks __P((DBC *));
-
-typedef struct {
-	const char *progname;
-	DB_ENV *dbenv;
-} disploop_args;
-
-typedef struct {
-	DB_ENV *dbenv;
-	machtab_t *machtab;
-} checkloop_args;
-
-int
-doclient(dbenv, progname, machtab)
-	DB_ENV *dbenv;
-	const char *progname;
-	machtab_t *machtab;
-{
-	checkloop_args cargs;
-	disploop_args dargs;
-	pthread_t check_thr, disp_thr;
-	void *cstatus, *dstatus;
-	int rval, s;
-
-	rval = EXIT_SUCCESS;
-	s = -1;
-
-	memset(&dargs, 0, sizeof(dargs));
-	dstatus = (void *)EXIT_FAILURE;
-
-	dargs.progname = progname;
-	dargs.dbenv = dbenv;
-	if (pthread_create(&disp_thr, NULL, display_loop, (void *)&dargs)) {
-		dbenv->err(dbenv, errno, "display_loop pthread_create failed");
-		goto err;
-	}
-
-	cargs.dbenv = dbenv;
-	cargs.machtab = machtab;
-	if (pthread_create(&check_thr, NULL, check_loop, (void *)&cargs)) {
-		dbenv->err(dbenv, errno, "check_thread pthread_create failed");
-		goto err;
-	}
-	if (pthread_join(disp_thr, &dstatus) ||
-	    pthread_join(check_thr, &cstatus)) {
-		dbenv->err(dbenv, errno, "pthread_join failed");
-		goto err;
-	}
-
-	if (0) {
-err:		rval = EXIT_FAILURE;
-	}
-	return (rval);
-}
-
-/*
- * Our only job is to check that the master is valid and if it's not
- * for an extended period, to trigger an election.  We do two phases.
- * If we do not have a master, first we send out a request for a master
- * to identify itself (that would be a call to rep_start).  If that fails,
- * we trigger an election.
- */
-static void *
-check_loop(args)
-	void *args;
-{
-	DB_ENV *dbenv;
-	DBT dbt;
-	checkloop_args *cargs;
-	int count, n, pri;
-	machtab_t *machtab;
-	u_int32_t timeout;
-
-	cargs = (checkloop_args *)args;
-	dbenv = cargs->dbenv;
-	machtab = cargs->machtab;
-
-#define	IDLE_INTERVAL	1
-
-	count = 0;
-	while (master_eid == DB_EID_INVALID) {
-		/*
-		 * Call either rep_start or rep_elect depending on if
-		 * count is 0 or 1.
-		 */
-
-		if (count == 0) {
-			memset(&dbt, 0, sizeof(dbt));
-			dbt.data = myaddr;
-			dbt.size = strlen(myaddr) + 1;
-			(void)dbenv->rep_start(dbenv, &dbt, DB_REP_CLIENT);
-			count = 1;
-		} else {
-			machtab_parm(machtab, &n, &pri, &timeout);
-			(void)dbenv->rep_elect(dbenv,
-			    n, pri, timeout, &master_eid);
-			count = 0;
-		}
-		sleep(IDLE_INTERVAL);
-	}
-
-	return ((void *)EXIT_SUCCESS);
-}
-
-static void *
-display_loop(args)
-	void *args;
-{
-	DB *dbp;
-	DB_ENV *dbenv;
-	DBC *dbc;
-	const char *progname;
-	disploop_args *dargs;
-	int ret, rval;
-
-	dargs = (disploop_args *)args;
-	progname = dargs->progname;
-	dbenv = dargs->dbenv;
-
-	dbc = NULL;
-	dbp = NULL;
-
-	for (;;) {
-		/* If we become master, shut this loop off. */
-		if (master_eid == SELF_EID)
-			break;
-
-		if (dbp == NULL) {
-			if ((ret = db_create(&dbp, dbenv, 0)) != 0) {
-				dbenv->err(dbenv, ret, "db_create");
-				return ((void *)EXIT_FAILURE);
-			}
-
-			if ((ret = dbp->open(dbp, NULL,
-			    DATABASE, NULL, DB_BTREE, DB_RDONLY, 0)) != 0) {
-				if (ret == ENOENT) {
-					printf(
-				    "No stock database yet available.\n");
-					if ((ret = dbp->close(dbp, 0)) != 0) {
-						dbenv->err(dbenv,
-						    ret, "DB->close");
-						goto err;
-					}
-					dbp = NULL;
-					sleep(SLEEPTIME);
-					continue;
-				}
-				dbenv->err(dbenv, ret, "DB->open");
-				goto err;
-			}
-		}
-
-		if ((ret = dbp->cursor(dbp, NULL, &dbc, 0)) != 0) {
-			dbenv->err(dbenv, ret, "DB->cursor");
-			goto err;
-		}
-
-		if ((ret = print_stocks(dbc)) != 0) {
-			dbenv->err(dbenv, ret, "database traversal failed");
-			goto err;
-		}
-
-		if ((ret = dbc->c_close(dbc)) != 0) {
-			dbenv->err(dbenv, ret, "DB->close");
-			goto err;
-		}
-
-		dbc = NULL;
-
-		sleep(SLEEPTIME);
-	}
-
-	rval = EXIT_SUCCESS;
-
-	if (0) {
-err:		rval = EXIT_FAILURE;
-	}
-
-	if (dbc != NULL && (ret = dbc->c_close(dbc)) != 0) {
-		dbenv->err(dbenv, ret, "DB->close");
-		rval = EXIT_FAILURE;
-	}
-
-	if (dbp != NULL && (ret = dbp->close(dbp, 0)) != 0) {
-		dbenv->err(dbenv, ret, "DB->close");
-		return ((void *)EXIT_FAILURE);
-	}
-
-	return ((void *)rval);
-}
-
-static int
-print_stocks(dbc)
-	DBC *dbc;
-{
-	DBT key, data;
-#define	MAXKEYSIZE	10
-#define	MAXDATASIZE	20
-	char keybuf[MAXKEYSIZE + 1], databuf[MAXDATASIZE + 1];
-	int ret;
-	u_int32_t keysize, datasize;
-
-	memset(&key, 0, sizeof(key));
-	memset(&data, 0, sizeof(data));
-
-	printf("\tSymbol\tPrice\n");
-	printf("\t======\t=====\n");
-
-	for (ret = dbc->c_get(dbc, &key, &data, DB_FIRST);
-	    ret == 0;
-	    ret = dbc->c_get(dbc, &key, &data, DB_NEXT)) {
-		keysize = key.size > MAXKEYSIZE ? MAXKEYSIZE : key.size;
-		memcpy(keybuf, key.data, keysize);
-		keybuf[keysize] = '\0';
-
-		datasize = data.size >= MAXDATASIZE ? MAXDATASIZE : data.size;
-		memcpy(databuf, data.data, datasize);
-		databuf[datasize] = '\0';
-
-		printf("\t%s\t%s\n", keybuf, databuf);
-	}
-	printf("\n");
-	return (ret == DB_NOTFOUND ? 0 : ret);
-}

bdb/examples_c/ex_repquote/ex_rq_main.c

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 2001-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_rq_main.c,v 1.23 2002/08/06 05:39:03 bostic Exp $
- */
-
-#include <sys/types.h>
-#include <pthread.h>
-
-#include <errno.h>
-#include <signal.h>
-#include <stdlib.h>
-#include <string.h>
-#include <unistd.h>
-
-#include <db.h>
-
-#include "ex_repquote.h"
-
-/*
- * Process globals (we could put these in the machtab I suppose.
- */
-int master_eid;
-char *myaddr;
-
-static int env_init __P((const char *, const char *, DB_ENV **, machtab_t *,
-    u_int32_t));
-static void usage __P((const char *));
-
-int
-main(argc, argv)
-	int argc;
-	char *argv[];
-{
-	extern char *optarg;
-	extern int optind;
-	DB_ENV *dbenv;
-	DBT local;
-	enum { MASTER, CLIENT, UNKNOWN } whoami;
-	all_args aa;
-	connect_args ca;
-	machtab_t *machtab;
-	pthread_t all_thr, conn_thr;
-	repsite_t site, *sitep, self, *selfp;
-	struct sigaction sigact;
-	int maxsites, nsites, ret, priority, totalsites;
-	char *c, ch;
-	const char *home, *progname;
-	void *astatus, *cstatus;
-
-	master_eid = DB_EID_INVALID;
-
-	dbenv = NULL;
-	whoami = UNKNOWN;
-	machtab = NULL;
-	selfp = sitep = NULL;
-	maxsites = nsites = ret = totalsites = 0;
-	priority = 100;
-	home = "TESTDIR";
-	progname = "ex_repquote";
-
-	while ((ch = getopt(argc, argv, "Ch:Mm:n:o:p:")) != EOF)
-		switch (ch) {
-		case 'M':
-			whoami = MASTER;
-			master_eid = SELF_EID;
-			break;
-		case 'C':
-			whoami = CLIENT;
-			break;
-		case 'h':
-			home = optarg;
-			break;
-		case 'm':
-			if ((myaddr = strdup(optarg)) == NULL) {
-				fprintf(stderr,
-				    "System error %s\n", strerror(errno));
-				goto err;
-			}
-			self.host = optarg;
-			self.host = strtok(self.host, ":");
-			if ((c = strtok(NULL, ":")) == NULL) {
-				fprintf(stderr, "Bad host specification.\n");
-				goto err;
-			}
-			self.port = atoi(c);
-			selfp = &self;
-			break;
-		case 'n':
-			totalsites = atoi(optarg);
-			break;
-		case 'o':
-			site.host = optarg;
-			site.host = strtok(site.host, ":");
-			if ((c = strtok(NULL, ":")) == NULL) {
-				fprintf(stderr, "Bad host specification.\n");
-				goto err;
-			}
-			site.port = atoi(c);
-			if (sitep == NULL || nsites >= maxsites) {
-				maxsites = maxsites == 0 ? 10 : 2 * maxsites;
-				if ((sitep = realloc(sitep,
-				    maxsites * sizeof(repsite_t))) == NULL) {
-					fprintf(stderr, "System error %s\n",
-					    strerror(errno));
-					goto err;
-				}
-			}
-			sitep[nsites++] = site;
-			break;
-		case 'p':
-			priority = atoi(optarg);
-			break;
-		case '?':
-		default:
-			usage(progname);
-		}
-
-	/* Error check command line. */
-	if (whoami == UNKNOWN) {
-		fprintf(stderr, "Must specify -M or -C.\n");
-		goto err;
-	}
-
-	if (selfp == NULL)
-		usage(progname);
-
-	if (home == NULL)
-		usage(progname);
-
-	/*
-	 * Turn off SIGPIPE so that we don't kill processes when they
-	 * happen to lose a connection at the wrong time.
-	 */
-	memset(&sigact, 0, sizeof(sigact));
-	sigact.sa_handler = SIG_IGN;
-	if ((ret = sigaction(SIGPIPE, &sigact, NULL)) != 0) {
-		fprintf(stderr,
-		    "Unable to turn off SIGPIPE: %s\n", strerror(ret));
-		goto err;
-	}
-
-	/*
-	 * We are hardcoding priorities here that all clients have the
-	 * same priority except for a designated master who gets a higher
-	 * priority.
-	 */
-	if ((ret =
-	    machtab_init(&machtab, priority, totalsites)) != 0)
-		goto err;
-
-	/*
-	 * We can know open our environment, although we're not ready to
-	 * begin replicating.  However, we want to have a dbenv around
-	 * so that we can send it into any of our message handlers.
-	 */
-	if ((ret = env_init(progname, home, &dbenv, machtab, DB_RECOVER)) != 0)
-		goto err;
-
-	/*
-	 * Now sets up comm infrastructure.  There are two phases.  First,
-	 * we open our port for listening for incoming connections.  Then
-	 * we attempt to connect to every host we know about.
-	 */
-
-	ca.dbenv = dbenv;
-	ca.home = home;
-	ca.progname = progname;
-	ca.machtab = machtab;
-	ca.port = selfp->port;
-	if ((ret = pthread_create(&conn_thr, NULL, connect_thread, &ca)) != 0)
-		goto err;
-
-	aa.dbenv = dbenv;
-	aa.progname = progname;
-	aa.home = home;
-	aa.machtab = machtab;
-	aa.sites = sitep;
-	aa.nsites = nsites;
-	if ((ret = pthread_create(&all_thr, NULL, connect_all, &aa)) != 0)
-		goto err;
-
-	/*
-	 * We have now got the entire communication infrastructure set up.
-	 * It's time to declare ourselves to be a client or master.
-	 */
-	if (whoami == MASTER) {
-		if ((ret = dbenv->rep_start(dbenv, NULL, DB_REP_MASTER)) != 0) {
-			dbenv->err(dbenv, ret, "dbenv->rep_start failed");
-			goto err;
-		}
-		if ((ret = domaster(dbenv, progname)) != 0) {
-			dbenv->err(dbenv, ret, "Master failed");
-			goto err;
-		}
-	} else {
-		memset(&local, 0, sizeof(local));
-		local.data = myaddr;
-		local.size = strlen(myaddr) + 1;
-		if ((ret =
-		    dbenv->rep_start(dbenv, &local, DB_REP_CLIENT)) != 0) {
-			dbenv->err(dbenv, ret, "dbenv->rep_start failed");
-			goto err;
-		}
-		/* Sleep to give ourselves a minute to find a master. */
-		sleep(5);
-		if ((ret = doclient(dbenv, progname, machtab)) != 0) {
-			dbenv->err(dbenv, ret, "Client failed");
-			goto err;
-		}
-
-	}
-
-	/* Wait on the connection threads. */
-	if (pthread_join(all_thr, &astatus) || pthread_join(conn_thr, &cstatus))
-		ret = errno;
-	if (ret == 0 &&
-	    ((int)astatus != EXIT_SUCCESS || (int)cstatus != EXIT_SUCCESS))
-		ret = -1;
-
-err:	if (machtab != NULL)
-		free(machtab);
-	if (dbenv != NULL)
-		(void)dbenv->close(dbenv, 0);
-	return (ret);
-}
-
-/*
- * In this application, we specify all communication via the command line.
- * In a real application, we would expect that information about the other
- * sites in the system would be maintained in some sort of configuration
- * file.  The critical part of this interface is that we assume at startup
- * that we can find out 1) what host/port we wish to listen on for connections,
- * 2) a (possibly empty) list of other sites we should attempt to connect to.
- * 3) whether we are a master or client (if we don't know, we should come up
- * as a client and see if there is a master out there) and 4) what our
- * Berkeley DB home environment is.
- *
- * These pieces of information are expressed by the following flags.
- * -m host:port (required; m stands for me)
- * -o host:port (optional; o stands for other; any number of these may be
- *	specified)
- * -[MC] M for master/C for client
- * -h home directory
- * -n nsites (optional; number of sites in replication group; defaults to 0
- *	in which case we try to dynamically compute the number of sites in
- *	the replication group.)
- * -p priority (optional: defaults to 100)
- */
-static void
-usage(progname)
-	const char *progname;
-{
-	fprintf(stderr, "usage: %s ", progname);
-	fprintf(stderr, "[-CM][-h home][-o host:port][-m host:port]%s",
-	    "[-n nsites][-p priority]\n");
-	exit(EXIT_FAILURE);
-}
-
-/* Open and configure an environment.  */
-int
-env_init(progname, home, dbenvp, machtab, flags)
-	const char *progname, *home;
-	DB_ENV **dbenvp;
-	machtab_t *machtab;
-	u_int32_t flags;
-{
-	DB_ENV *dbenv;
-	int ret;
-	char *prefix;
-
-	if ((prefix = malloc(strlen(progname) + 2)) == NULL) {
-		fprintf(stderr,
-		    "%s: System error: %s\n", progname, strerror(errno));
-		return (errno);
-	}
-	sprintf(prefix, "%s:", progname);
-
-	if ((ret = db_env_create(&dbenv, 0)) != 0) {
-		fprintf(stderr, "%s: env create failed: %s\n",
-		    progname, db_strerror(ret));
-		return (ret);
-	}
-	dbenv->set_errfile(dbenv, stderr);
-	dbenv->set_errpfx(dbenv, prefix);
-	/* (void)dbenv->set_verbose(dbenv, DB_VERB_REPLICATION, 1); */
-	(void)dbenv->set_cachesize(dbenv, 0, CACHESIZE, 0);
-	/* (void)dbenv->set_flags(dbenv, DB_TXN_NOSYNC, 1); */
-
-	dbenv->app_private = machtab;
-	(void)dbenv->set_rep_transport(dbenv, SELF_EID, quote_send);
-
-	flags |= DB_CREATE | DB_THREAD |
-	    DB_INIT_LOCK | DB_INIT_LOG | DB_INIT_MPOOL | DB_INIT_TXN;
-
-	ret = dbenv->open(dbenv, home, flags, 0);
-
-	*dbenvp = dbenv;
-	return (ret);
-}

bdb/examples_c/ex_repquote/ex_rq_master.c

-/*-
- * #include <pthread.h>
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 2001-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_rq_master.c,v 1.22 2002/08/06 05:39:03 bostic Exp $
- */
-
-#include <sys/types.h>
-
-#include <errno.h>
-#include <pthread.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <unistd.h>
-
-#include <db.h>
-
-#include "ex_repquote.h"
-
-static void *master_loop __P((void *));
-
-#define	BUFSIZE 1024
-
-int
-domaster(dbenv, progname)
-	DB_ENV *dbenv;
-	const char *progname;
-{
-	int ret, t_ret;
-	pthread_t interface_thr;
-	pthread_attr_t attr;
-
-	COMPQUIET(progname, NULL);
-
-	/* Spawn off a thread to handle the basic master interface. */
-	if ((ret = pthread_attr_init(&attr)) != 0 &&
-	    (ret = pthread_attr_setdetachstate(&attr,
-	    PTHREAD_CREATE_DETACHED)) != 0)
-		goto err;
-
-	if ((ret = pthread_create(&interface_thr,
-	    &attr, master_loop, (void *)dbenv)) != 0)
-		goto err;
-
-err:	if ((t_ret = pthread_attr_destroy(&attr)) != 0 && ret == 0)
-		ret = t_ret;
-
-	return (ret);
-}
-
-static void *
-master_loop(dbenvv)
-	void *dbenvv;
-{
-	DB *dbp;
-	DB_ENV *dbenv;
-	DB_TXN *txn;
-	DBT key, data;
-	char buf[BUFSIZE], *rbuf;
-	int ret;
-
-	dbp = NULL;
-	txn = NULL;
-
-	dbenv = (DB_ENV *)dbenvv;
-	/*
-	 * Check if the database exists and if it verifies cleanly.
-	 * If it does, run with it; else recreate it and go.  Note
-	 * that we have to verify outside of the environment.
-	 */
-#ifdef NOTDEF
-	if ((ret = db_create(&dbp, NULL, 0)) != 0)
-		return (ret);
-	if ((ret = dbp->verify(dbp, DATABASE, NULL, NULL, 0)) != 0) {
-		if ((ret = dbp->remove(dbp, DATABASE, NULL, 0)) != 0 &&
-		    ret != DB_NOTFOUND && ret != ENOENT)
-			return (ret);
-#endif
-		if ((ret = db_create(&dbp, dbenv, 0)) != 0)
-			return ((void *)ret);
-
-		if ((ret = dbenv->txn_begin(dbenv, NULL, &txn, 0)) != 0)
-			goto err;
-		if ((ret = dbp->open(dbp, txn, DATABASE,
-		    NULL, DB_BTREE, DB_CREATE /* | DB_THREAD */, 0)) != 0)
-			goto err;
-		ret = txn->commit(txn, 0);
-		txn = NULL;
-		if (ret != 0) {
-			dbp = NULL;
-			goto err;
-		}
-
-#ifdef NOTDEF
-	} else {
-		/* Reopen in the environment. */
-		if ((ret = dbp->close(dbp, 0)) != 0)
-			return (ret);
-		if ((ret = db_create(&dbp, dbenv, 0)) != 0)
-			return (ret);
-		if ((ret = dbp->open(dbp,
-		    DATABASE, NULL, DB_UNKNOWN, DB_THREAD, 0)) != 0)
-			goto err;
-	}
-#endif
-	/*
-	 * XXX
-	 * It would probably be kind of cool to do this in Tcl and
-	 * have a nice GUI.  It would also be cool to be independently
-	 * wealthy.
-	 */
-	memset(&key, 0, sizeof(key));
-	memset(&data, 0, sizeof(data));
-	for (;;) {
-		printf("QUOTESERVER> ");
-		fflush(stdout);
-
-		if (fgets(buf, sizeof(buf), stdin) == NULL)
-			break;
-		(void)strtok(&buf[0], " \t\n");
-		rbuf = strtok(NULL, " \t\n");
-		if (rbuf == NULL || rbuf[0] == '\0') {
-			if (strncmp(buf, "exit", 4) == 0 ||
-			    strncmp(buf, "quit", 4) == 0)
-				break;
-			dbenv->errx(dbenv, "Format: TICKER VALUE");
-			continue;
-		}
-
-		key.data = buf;
-		key.size = strlen(buf);
-
-		data.data = rbuf;
-		data.size = strlen(rbuf);
-
-		if ((ret = dbenv->txn_begin(dbenv, NULL, &txn, 0)) != 0)
-			goto err;
-		switch (ret =
-		    dbp->put(dbp, txn, &key, &data, 0)) {
-		case 0:
-			break;
-		default:
-			dbp->err(dbp, ret, "DB->put");
-			if (ret != DB_KEYEXIST)
-				goto err;
-			break;
-		}
-		ret = txn->commit(txn, 0);
-		txn = NULL;
-		if (ret != 0)
-			goto err;
-	}
-
-err:	if (txn != NULL)
-		(void)txn->abort(txn);
-
-	if (dbp != NULL)
-		(void)dbp->close(dbp, DB_NOSYNC);
-
-	return ((void *)ret);
-}

bdb/examples_c/ex_repquote/ex_rq_util.c

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 2001-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_rq_util.c,v 1.20 2002/08/06 05:39:04 bostic Exp $
- */
-
-#include <sys/types.h>
-
-#include <errno.h>
-#include <pthread.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <unistd.h>
-
-#include <db.h>
-
-#include "ex_repquote.h"
-
-static int connect_site __P((DB_ENV *, machtab_t *, const char *,
-   repsite_t *, int *, int *));
-void * elect_thread __P((void *));
-
-typedef struct {
-	DB_ENV *dbenv;
-	machtab_t *machtab;
-} elect_args;
-
-typedef struct {
-	DB_ENV *dbenv;
-	const char *progname;
-	const char *home;
-	int fd;
-	u_int32_t eid;
-	machtab_t *tab;
-} hm_loop_args;
-
-/*
- * This is a generic message handling loop that is used both by the
- * master to accept messages from a client as well as by clients
- * to communicate with other clients.
- */
-void *
-hm_loop(args)
-	void *args;
-{
-	DB_ENV *dbenv;
-	DBT rec, control;
-	const char *c, *home, *progname;
-	int fd, eid, n, newm;
-	int open, pri, r, ret, t_ret, tmpid;
-	elect_args *ea;
-	hm_loop_args *ha;
-	machtab_t *tab;
-	pthread_t elect_thr;
-	repsite_t self;
-	u_int32_t timeout;
-	void *status;
-
-	ea = NULL;
-
-	ha = (hm_loop_args *)args;
-	dbenv = ha->dbenv;
-	fd = ha->fd;
-	home = ha->home;
-	eid = ha->eid;
-	progname = ha->progname;
-	tab = ha->tab;
-	free(ha);
-
-	memset(&rec, 0, sizeof(DBT));
-	memset(&control, 0, sizeof(DBT));
-
-	for (ret = 0; ret == 0;) {
-		if ((ret = get_next_message(fd, &rec, &control)) != 0) {
-			/*
-			 * Close this connection; if it's the master call
-			 * for an election.
-			 */
-			close(fd);
-			if ((ret = machtab_rem(tab, eid, 1)) != 0)
-				break;
-
-			/*
-			 * If I'm the master, I just lost a client and this
-			 * thread is done.
-			 */
-			if (master_eid == SELF_EID)
-				break;
-
-			/*
-			 * If I was talking with the master and the master
-			 * went away, I need to call an election; else I'm
-			 * done.
-			 */
-			if (master_eid != eid)
-				break;
-
-			master_eid = DB_EID_INVALID;
-			machtab_parm(tab, &n, &pri, &timeout);
-			if ((ret = dbenv->rep_elect(dbenv,
-			    n, pri, timeout, &newm)) != 0)
-				continue;
-
-			/*
-			 * Regardless of the results, the site I was talking
-			 * to is gone, so I have nothing to do but exit.
-			 */
-			if (newm == SELF_EID && (ret =
-			    dbenv->rep_start(dbenv, NULL, DB_REP_MASTER)) == 0)
-				ret = domaster(dbenv, progname);
-			break;
-		}
-
-		tmpid = eid;
-		switch(r = dbenv->rep_process_message(dbenv,
-		    &control, &rec, &tmpid)) {
-		case DB_REP_NEWSITE:
-			/*
-			 * Check if we got sent connect information and if we
-			 * did, if this is me or if we already have a
-			 * connection to this new site.  If we don't,
-			 * establish a new one.
-			 */
-
-			/* No connect info. */
-			if (rec.size == 0)
-				break;
-
-			/* It's me, do nothing. */
-			if (strncmp(myaddr, rec.data, rec.size) == 0)
-				break;
-
-			self.host = (char *)rec.data;
-			self.host = strtok(self.host, ":");
-			if ((c = strtok(NULL, ":")) == NULL) {
-				dbenv->errx(dbenv, "Bad host specification");
-				goto out;
-			}
-			self.port = atoi(c);
-
-			/*
-			 * We try to connect to the new site.  If we can't,
-			 * we treat it as an error since we know that the site
-			 * should be up if we got a message from it (even
-			 * indirectly).
-			 */
-			if ((ret = connect_site(dbenv,
-			    tab, progname, &self, &open, &eid)) != 0)
-				goto out;
-			break;
-		case DB_REP_HOLDELECTION:
-			if (master_eid == SELF_EID)
-				break;
-			/* Make sure that previous election has finished. */
-			if (ea != NULL) {
-				(void)pthread_join(elect_thr, &status);
-				ea = NULL;
-			}
-			if ((ea = calloc(sizeof(elect_args), 1)) == NULL) {
-				ret = errno;
-				goto out;
-			}
-			ea->dbenv = dbenv;
-			ea->machtab = tab;
-			ret = pthread_create(&elect_thr,
-			    NULL, elect_thread, (void *)ea);
-			break;
-		case DB_REP_NEWMASTER:
-			/* Check if it's us. */
-			master_eid = tmpid;
-			if (tmpid == SELF_EID) {
-				if ((ret = dbenv->rep_start(dbenv,
-				    NULL, DB_REP_MASTER)) != 0)
-					goto out;
-				ret = domaster(dbenv, progname);
-			}
-			break;
-		case 0:
-			break;
-		default:
-			dbenv->err(dbenv, r, "DB_ENV->rep_process_message");
-			break;
-		}
-	}
-
-out:	if ((t_ret = machtab_rem(tab, eid, 1)) != 0 && ret == 0)
-		ret = t_ret;
-
-	/* Don't close the environment before any children exit. */
-	if (ea != NULL)
-		(void)pthread_join(elect_thr, &status);
-
-	return ((void *)ret);
-}
-
-/*
- * This is a generic thread that spawns a thread to listen for connections
- * on a socket and then spawns off child threads to handle each new
- * connection.
- */
-void *
-connect_thread(args)
-	void *args;
-{
-	DB_ENV *dbenv;
-	const char *home, *progname;
-	int fd, i, eid, ns, port, ret;
-	hm_loop_args *ha;
-	connect_args *cargs;
-	machtab_t *machtab;
-#define	MAX_THREADS 25
-	pthread_t hm_thrs[MAX_THREADS];
-	pthread_attr_t attr;
-
-	ha = NULL;
-	cargs = (connect_args *)args;
-	dbenv = cargs->dbenv;
-	home = cargs->home;
-	progname = cargs->progname;
-	machtab = cargs->machtab;
-	port = cargs->port;
-
-	if ((ret = pthread_attr_init(&attr)) != 0)
-		return ((void *)EXIT_FAILURE);
-
-	if ((ret =
-	    pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED)) != 0)
-		goto err;
-
-	/*
-	 * Loop forever, accepting connections from new machines,
-	 * and forking off a thread to handle each.
-	 */
-	if ((fd = listen_socket_init(progname, port)) < 0) {
-		ret = errno;
-		goto err;
-	}
-
-	for (i = 0; i < MAX_THREADS; i++) {
-		if ((ns = listen_socket_accept(machtab,
-		    progname, fd, &eid)) < 0) {
-			ret = errno;
-			goto err;
-		}
-		if ((ha = calloc(sizeof(hm_loop_args), 1)) == NULL)
-			goto err;
-		ha->progname = progname;
-		ha->home = home;
-		ha->fd = ns;
-		ha->eid = eid;
-		ha->tab = machtab;
-		ha->dbenv = dbenv;
-		if ((ret = pthread_create(&hm_thrs[i++], &attr,
-		    hm_loop, (void *)ha)) != 0)
-			goto err;
-		ha = NULL;
-	}
-
-	/* If we fell out, we ended up with too many threads. */
-	dbenv->errx(dbenv, "Too many threads");
-	ret = ENOMEM;
-
-err:	pthread_attr_destroy(&attr);
-	return (ret == 0 ? (void *)EXIT_SUCCESS : (void *)EXIT_FAILURE);
-}
-
-/*
- * Open a connection to everyone that we've been told about.  If we
- * cannot open some connections, keep trying.
- */
-void *
-connect_all(args)
-	void *args;
-{
-	DB_ENV *dbenv;
-	all_args *aa;
-	const char *home, *progname;
-	hm_loop_args *ha;
-	int failed, i, eid, nsites, open, ret, *success;
-	machtab_t *machtab;
-	repsite_t *sites;
-
-	ha = NULL;
-	aa = (all_args *)args;
-	dbenv = aa->dbenv;
-	progname = aa->progname;
-	home = aa->home;
-	machtab = aa->machtab;
-	nsites = aa->nsites;
-	sites = aa->sites;
-
-	ret = 0;
-
-	/* Some implementations of calloc are sad about alloc'ing 0 things. */
-	if ((success = calloc(nsites > 0 ? nsites : 1, sizeof(int))) == NULL) {
-		dbenv->err(dbenv, errno, "connect_all");
-		ret = 1;
-		goto err;
-	}
-
-	for (failed = nsites; failed > 0;) {
-		for (i = 0; i < nsites; i++) {
-			if (success[i])
-				continue;
-
-			ret = connect_site(dbenv, machtab,
-			    progname, &sites[i], &open, &eid);
-
-			/*
-			 * If we couldn't make the connection, this isn't
-			 * fatal to the loop, but we have nothing further
-			 * to do on this machine at the moment.
-			 */
-			if (ret == DB_REP_UNAVAIL)
-				continue;
-
-			if (ret != 0)
-				goto err;
-
-			failed--;
-			success[i] = 1;
-
-			/* If the connection is already open, we're done. */
-			if (ret == 0 && open == 1)
-				continue;
-
-		}
-		sleep(1);
-	}
-
-err:	free(success);
-	return (ret ? (void *)EXIT_FAILURE : (void *)EXIT_SUCCESS);
-}
-
-int
-connect_site(dbenv, machtab, progname, site, is_open, eidp)
-	DB_ENV *dbenv;
-	machtab_t *machtab;
-	const char *progname;
-	repsite_t *site;
-	int *is_open;
-	int *eidp;
-{
-	int ret, s;
-	hm_loop_args *ha;
-	pthread_t hm_thr;
-
-	if ((s = get_connected_socket(machtab, progname,
-	    site->host, site->port, is_open, eidp)) < 0)
-		return (DB_REP_UNAVAIL);
-
-	if (*is_open)
-		return (0);
-
-	if ((ha = calloc(sizeof(hm_loop_args), 1)) == NULL) {
-		ret = errno;
-		goto err;
-	}
-
-	ha->progname = progname;
-	ha->fd = s;
-	ha->eid = *eidp;
-	ha->tab = machtab;
-	ha->dbenv = dbenv;
-
-	if ((ret = pthread_create(&hm_thr, NULL,
-	    hm_loop, (void *)ha)) != 0) {
-		dbenv->err(dbenv, ret, "connect site");
-		goto err1;
-	}
-
-	return (0);
-
-err1:	free(ha);
-err:
-	return (ret);
-}
-
-/*
- * We need to spawn off a new thread in which to hold an election in
- * case we are the only thread listening on for messages.
- */
-void *
-elect_thread(args)
-	void *args;
-{
-	DB_ENV *dbenv;
-	elect_args *eargs;
-	int n, ret, pri;
-	machtab_t *machtab;
-	u_int32_t timeout;
-
-	eargs = (elect_args *)args;
-	dbenv = eargs->dbenv;
-	machtab = eargs->machtab;
-	free(eargs);
-
-	machtab_parm(machtab, &n, &pri, &timeout);
-	while ((ret =
-	    dbenv->rep_elect(dbenv, n, pri, timeout, &master_eid)) != 0)
-		sleep(2);
-
-	/* Check if it's us. */
-	if (master_eid == SELF_EID)
-		ret = dbenv->rep_start(dbenv, NULL, DB_REP_MASTER);
-
-	return ((void *)(ret == 0 ? EXIT_SUCCESS : EXIT_FAILURE));
-}

bdb/examples_c/ex_tpcb.h

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 1996-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: ex_tpcb.h,v 11.6 2002/01/11 15:52:06 bostic Exp $
- */
-
-#ifndef _TPCB_H_
-#define	_TPCB_H_
-
-typedef enum { ACCOUNT, BRANCH, TELLER } FTYPE;
-
-#define	TELLERS_PER_BRANCH	100
-#define	ACCOUNTS_PER_TELLER	1000
-
-#define	ACCOUNTS 1000000
-#define	BRANCHES 10
-#define	TELLERS 1000
-#define	HISTORY	1000000
-#define	HISTORY_LEN 100
-#define	RECLEN 100
-#define	BEGID	1000000
-
-typedef struct _defrec {
-	u_int32_t	id;
-	u_int32_t	balance;
-	u_int8_t	pad[RECLEN - sizeof(u_int32_t) - sizeof(u_int32_t)];
-} defrec;
-
-typedef struct _histrec {
-	u_int32_t	aid;
-	u_int32_t	bid;
-	u_int32_t	tid;
-	u_int32_t	amount;
-	u_int8_t	pad[RECLEN - 4 * sizeof(u_int32_t)];
-} histrec;
-#endif /* _TPCB_H_ */

bdb/examples_cxx/AccessExample.cpp

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 1997-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: AccessExample.cpp,v 11.18 2002/01/23 15:33:20 bostic Exp $
- */
-
-#include <sys/types.h>
-
-#include <iostream>
-#include <iomanip>
-#include <errno.h>
-#include <stdlib.h>
-#include <string.h>
-
-#include <db_cxx.h>
-
-using std::cin;
-using std::cout;
-using std::cerr;
-
-class AccessExample
-{
-public:
-	AccessExample();
-	void run();
-
-private:
-	static const char FileName[];
-
-	// no need for copy and assignment
-	AccessExample(const AccessExample &);
-	void operator = (const AccessExample &);
-};
-
-int main()
-{
-	// Use a try block just to report any errors.
-	// An alternate approach to using exceptions is to
-	// use error models (see DbEnv::set_error_model()) so
-	// that error codes are returned for all Berkeley DB methods.
-	//
-	try {
-		AccessExample app;
-		app.run();
-		return (EXIT_SUCCESS);
-	}
-	catch (DbException &dbe) {
-		cerr << "AccessExample: " << dbe.what() << "\n";
-		return (EXIT_FAILURE);
-	}
-}
-
-const char AccessExample::FileName[] = "access.db";
-
-AccessExample::AccessExample()
-{
-}
-
-void AccessExample::run()
-{
-	// Remove the previous database.
-	(void)remove(FileName);
-
-	// Create the database object.
-	// There is no environment for this simple example.
-	Db db(0, 0);
-
-	db.set_error_stream(&cerr);
-	db.set_errpfx("AccessExample");
-	db.set_pagesize(1024);		/* Page size: 1K. */
-	db.set_cachesize(0, 32 * 1024, 0);
-	db.open(NULL, FileName, NULL, DB_BTREE, DB_CREATE, 0664);
-
-	//
-	// Insert records into the database, where the key is the user
-	// input and the data is the user input in reverse order.
-	//
-	char buf[1024];
-	char rbuf[1024];
-	char *t;
-	char *p;
-	int ret;
-	int len;
-
-	for (;;) {
-		cout << "input> ";
-		cout.flush();
-
-		cin.getline(buf, sizeof(buf));
-		if (cin.eof())
-			break;
-
-		if ((len = strlen(buf)) <= 0)
-			continue;
-		for (t = rbuf, p = buf + (len - 1); p >= buf;)
-			*t++ = *p--;
-		*t++ = '\0';
-
-		Dbt key(buf, len + 1);
-		Dbt data(rbuf, len + 1);
-
-		ret = db.put(0, &key, &data, DB_NOOVERWRITE);
-		if (ret == DB_KEYEXIST) {
-			cout << "Key " << buf << " already exists.\n";
-		}
-	}
-	cout << "\n";
-
-	// We put a try block around this section of code
-	// to ensure that our database is properly closed
-	// in the event of an error.
-	//
-	try {
-		// Acquire a cursor for the table.
-		Dbc *dbcp;
-		db.cursor(NULL, &dbcp, 0);
-
-		// Walk through the table, printing the key/data pairs.
-		Dbt key;
-		Dbt data;
-		while (dbcp->get(&key, &data, DB_NEXT) == 0) {
-			char *key_string = (char *)key.get_data();
-			char *data_string = (char *)data.get_data();
-			cout << key_string << " : " << data_string << "\n";
-		}
-		dbcp->close();
-	}
-	catch (DbException &dbe) {
-		cerr << "AccessExample: " << dbe.what() << "\n";
-	}
-
-	db.close(0);
-}

bdb/examples_cxx/EnvExample.cpp

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 1997-2002
- *	Sleepycat Software.  All rights reserved.
- *
- * $Id: EnvExample.cpp,v 11.24 2002/01/11 15:52:15 bostic Exp $
- */
-
-#include <sys/types.h>
-
-#include <errno.h>
-#include <iostream>
-#include <stddef.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-
-#include <db_cxx.h>
-
-using std::ostream;
-using std::cout;
-using std::cerr;
-
-#ifdef macintosh
-#define	DATABASE_HOME	":database"
-#define	CONFIG_DATA_DIR	":database"
-#else
-#ifdef DB_WIN32
-#define	DATABASE_HOME	"\\tmp\\database"
-#define	CONFIG_DATA_DIR	"\\database\\files"
-#else
-#define	DATABASE_HOME	"/tmp/database"
-#define	CONFIG_DATA_DIR	"/database/files"
-#endif
-#endif
-
-void	db_setup(const char *, const char *, ostream&);
-void	db_teardown(const char *, const char *, ostream&);
-
-const char *progname = "EnvExample";			/* Program name. */
-
-//
-// An example of a program creating/configuring a Berkeley DB environment.
-//
-int
-main(int, char **)
-{
-	//
-	// Note: it may be easiest to put all Berkeley DB operations in a
-	// try block, as seen here.  Alternatively, you can change the
-	// ErrorModel in the DbEnv so that exceptions are never thrown
-	// and check error returns from all methods.
-	//
-	try {
-		const char *data_dir, *home;
-
-		//
-		// All of the shared database files live in /home/database,
-		// but data files live in /database.
-		//
-		home = DATABASE_HOME;
-		data_dir = CONFIG_DATA_DIR;
-
-		cout << "Setup env\n";
-		db_setup(home, data_dir, cerr);
-
-		cout << "Teardown env\n";
-		db_teardown(home, data_dir, cerr);
-		return (EXIT_SUCCESS);
-	}
-	catch (DbException &dbe) {
-		cerr << "EnvExample: " << dbe.what() << "\n";
-		return (EXIT_FAILURE);
-	}
-}
-
-// Note that any of the db calls can throw DbException
-void
-db_setup(const char *home, const char *data_dir, ostream& err_stream)
-{
-	//
-	// Create an environment object and initialize it for error
-	// reporting.
-	//
-	DbEnv *dbenv = new DbEnv(0);
-	dbenv->set_error_stream(&err_stream);
-	dbenv->set_errpfx(progname);
-
-	//
-	// We want to specify the shared memory buffer pool cachesize,
-	// but everything else is the default.
-	//
-	dbenv->set_cachesize(0, 64 * 1024, 0);
-
-	// Databases are in a subdirectory.
-	(void)dbenv->set_data_dir(data_dir);
-
-	// Open the environment with full transactional support.
-	dbenv->open(home,
-    DB_CREATE | DB_INIT_LOCK | DB_INIT_LOG | DB_INIT_MPOOL | DB_INIT_TXN, 0);
-
-	// Do something interesting...
-
-	// Close the handle.
-	dbenv->close(0);
-}
-
-void
-db_teardown(const char *home, const char *data_dir, ostream& err_stream)
-{
-	// Remove the shared database regions.
-	DbEnv *dbenv = new DbEnv(0);
-
-	dbenv->set_error_stream(&err_stream);
-	dbenv->set_errpfx(progname);
-
-	(void)dbenv->set_data_dir(data_dir);
-	dbenv->remove(home, 0);
-	delete dbenv;
-}

bdb/java/src/com/sleepycat/db/DbAppDispatch.java

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 2000-2002
- *      Sleepycat Software.  All rights reserved.
- *
- * $Id: DbAppDispatch.java,v 11.6 2002/02/26 16:23:02 krinsky Exp $
- */
-
-package com.sleepycat.db;
-
-/*
- * This interface is used by DbEnv.set_app_dispatch()
- *
- */
-public interface DbAppDispatch
-{
-    // The value of recops is one of the Db.DB_TXN_* constants
-    public abstract int app_dispatch(DbEnv env, Dbt dbt, DbLsn lsn, int recops);
-}
-
-// end of DbAppDispatch.java

bdb/java/src/com/sleepycat/db/DbAppendRecno.java

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 2000-2002
- *      Sleepycat Software.  All rights reserved.
- *
- * $Id: DbAppendRecno.java,v 11.5 2002/01/11 15:52:33 bostic Exp $
- */
-
-package com.sleepycat.db;
-
-/*
- * This interface is used by Db.set_append_recno()
- *
- */
-public interface DbAppendRecno
-{
-    public abstract void db_append_recno(Db db, Dbt data, int recno)
-        throws DbException;
-}
-
-// end of DbAppendRecno.java

bdb/java/src/com/sleepycat/db/DbBtreeCompare.java

-/*-
- * See the file LICENSE for redistribution information.
- *
- * Copyright (c) 2000-2002
- *      Sleepycat Software.  All rights reserved.
- *
- * $Id: DbBtreeCompare.java,v 11.6 2002/01/11 15:52:33 bostic Exp $
- */
-
-package com.sleepycat.db;
-
-/*
- * This interface is used by DbEnv.set_bt_compare()
- *
- */
-public interface DbBtreeCompare
-{
-    public abstract int bt_compare(Db db, Dbt dbt1, Dbt dbt2);
-}
-
-// end of DbBtreeCompare.java