/*- * See the file LICENSE for redistribution information. * * Copyright (c) 1996-2003 * Sleepycat Software. All rights reserved. * * $Id: db_am.h,v 1.2 2004/03/30 01:21:28 jtownsen Exp $ */ #ifndef _DB_AM_H_ #define _DB_AM_H_ /* * IS_AUTO_COMMIT -- * Test for local auto-commit flag or global flag with no local DbTxn * handle. */ #define IS_AUTO_COMMIT(dbenv, txn, flags) \ (LF_ISSET(DB_AUTO_COMMIT) || \ ((txn) == NULL && F_ISSET((dbenv), DB_ENV_AUTO_COMMIT) && \ !LF_ISSET(DB_NO_AUTO_COMMIT))) /* DB recovery operation codes. */ #define DB_ADD_DUP 1 #define DB_REM_DUP 2 #define DB_ADD_BIG 3 #define DB_REM_BIG 4 #define DB_ADD_PAGE 5 #define DB_REM_PAGE 6 /* * Standard initialization and shutdown macros for all recovery functions. */ #define REC_INTRO(func, inc_count) do { \ argp = NULL; \ dbc = NULL; \ file_dbp = NULL; \ mpf = NULL; \ if ((ret = func(dbenv, dbtp->data, &argp)) != 0) \ goto out; \ if ((ret = __dbreg_id_to_db(dbenv, argp->txnid, \ &file_dbp, argp->fileid, inc_count)) != 0) { \ if (ret == DB_DELETED) { \ ret = 0; \ goto done; \ } \ goto out; \ } \ if ((ret = __db_cursor(file_dbp, NULL, &dbc, 0)) != 0) \ goto out; \ F_SET(dbc, DBC_RECOVER); \ mpf = file_dbp->mpf; \ } while (0) #define REC_CLOSE { \ int __t_ret; \ if (argp != NULL) \ __os_free(dbenv, argp); \ if (dbc != NULL && \ (__t_ret = __db_c_close(dbc)) != 0 && ret == 0) \ ret = __t_ret; \ } \ return (ret) /* * No-op versions of the same macros. */ #define REC_NOOP_INTRO(func) do { \ argp = NULL; \ if ((ret = func(dbenv, dbtp->data, &argp)) != 0) \ return (ret); \ } while (0) #define REC_NOOP_CLOSE \ if (argp != NULL) \ __os_free(dbenv, argp); \ return (ret) /* * Standard debugging macro for all recovery functions. */ #ifdef DEBUG_RECOVER #define REC_PRINT(func) \ (void)func(dbenv, dbtp, lsnp, op, info); #else #define REC_PRINT(func) #endif /* * Actions to __db_lget */ #define LCK_ALWAYS 1 /* Lock even for off page dup cursors */ #define LCK_COUPLE 2 /* Lock Couple */ #define LCK_COUPLE_ALWAYS 3 /* Lock Couple even in txn. */ #define LCK_DOWNGRADE 4 /* Downgrade the lock. (internal) */ #define LCK_ROLLBACK 5 /* Lock even if in rollback */ /* * If doing transactions we have to hold the locks associated with a data item * from a page for the entire transaction. However, we don't have to hold the * locks associated with walking the tree. Distinguish between the two so that * we don't tie up the internal pages of the tree longer than necessary. */ #define __LPUT(dbc, lock) \ (LOCK_ISSET(lock) ? __lock_put((dbc)->dbp->dbenv, &(lock)) : 0) /* * __TLPUT -- transactional lock put * If the lock is valid then * If we are not in a transaction put the lock. * Else if the cursor is doing dirty reads and this was a read then * put the lock. * Else if the db is supporting dirty reads and this is a write then * downgrade it. * Else do nothing. */ #define __TLPUT(dbc, lock) \ (LOCK_ISSET(lock) ? __db_lput(dbc, &(lock)) : 0) typedef struct { DBC *dbc; u_int32_t count; } db_trunc_param; #include "dbinc/db_dispatch.h" #include "dbinc_auto/db_auto.h" #include "dbinc_auto/crdel_auto.h" #include "dbinc_auto/db_ext.h" #endif /* !_DB_AM_H_ */