#ifndef _DB_AM_H_
#define _DB_AM_H_
#if defined(__cplusplus)
extern "C" {
#endif
#define IS_ENV_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)))
#define IS_DB_AUTO_COMMIT(dbp, txn) \
((txn) == NULL && F_ISSET((dbp), DB_AM_TXN))
#define STRIP_AUTO_COMMIT(f) FLD_CLR((f), DB_AUTO_COMMIT)
#define DB_ADD_DUP 1
#define DB_REM_DUP 2
#define DB_ADD_BIG 3
#define DB_REM_BIG 4
#define DB_ADD_PAGE_COMPAT 5
#define DB_REM_PAGE_COMPAT 6
#define REC_INTRO(func, inc_count, do_cursor) do { \
argp = NULL; \
file_dbp = NULL; \
COMPQUIET(dbc, NULL); \
\
COMPQUIET(mpf, NULL); \
if ((ret = func(dbenv, dbtp->data, &argp)) != 0) \
goto out; \
if (info != NULL) \
argp->txnp->td = ((DB_TXNHEAD *)info)->td; \
if ((ret = __dbreg_id_to_db(dbenv, argp->txnp, \
&file_dbp, argp->fileid, inc_count)) != 0) { \
if (ret == DB_DELETED) { \
ret = 0; \
goto done; \
} \
goto out; \
} \
if (do_cursor) { \
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 = __dbc_close(dbc)) != 0 && ret == 0) \
ret = __t_ret; \
} \
return (ret)
#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)
#ifndef HAVE_FTRUNCATE
#define REC_FGET(mpf, pgno, pagep, cont) \
if ((ret = __memp_fget(mpf, &(pgno), NULL, 0, pagep)) != 0) { \
if (ret != DB_PAGE_NOTFOUND || DB_REDO(op)) { \
ret = __db_pgerr(file_dbp, pgno, ret); \
goto out; \
} else \
goto cont; \
}
#else
#define REC_FGET(mpf, pgno, pagep, cont) \
if ((ret = __memp_fget(mpf, &(pgno), NULL, 0, pagep)) != 0) { \
if (ret != DB_PAGE_NOTFOUND) { \
ret = __db_pgerr(file_dbp, pgno, ret); \
goto out; \
} else \
goto cont; \
}
#endif
#define REC_DIRTY(mpf, priority, pagep) \
if ((ret = __memp_dirty(mpf, \
pagep, NULL, priority, DB_MPOOL_EDIT)) != 0) { \
ret = __db_pgerr(file_dbp, PGNO(*(pagep)), ret); \
goto out; \
}
#ifdef DEBUG_RECOVER
#define REC_PRINT(func) \
(void)func(dbenv, dbtp, lsnp, op, info);
#else
#define REC_PRINT(func)
#endif
#define LCK_ALWAYS 1
#define LCK_COUPLE 2
#define LCK_COUPLE_ALWAYS 3
#define LCK_DOWNGRADE 4
#define LCK_ROLLBACK 5
#define __LPUT(dbc, lock) \
__ENV_LPUT((dbc)->dbp->dbenv, lock)
#define __ENV_LPUT(dbenv, lock) \
(LOCK_ISSET(lock) ? __lock_put(dbenv, &(lock)) : 0)
#define __TLPUT(dbc, lock) \
(LOCK_ISSET(lock) ? __db_lput(dbc, &(lock)) : 0)
typedef struct {
DBC *dbc;
u_int32_t count;
} db_trunc_param;
#define DB_IS_READONLY(dbp) \
(F_ISSET(dbp, DB_AM_RDONLY) || \
(IS_REP_CLIENT((dbp)->dbenv) && !F_ISSET((dbp), DB_AM_NOT_DURABLE)))
#include "dbinc/db_swap.h"
#define SWAP_IF_NEEDED(sdbp, pkey) \
do { \
if (((sdbp)->s_primary->type == DB_QUEUE || \
(sdbp)->s_primary->type == DB_RECNO) && \
F_ISSET((sdbp), DB_AM_SWAP)) \
P_32_SWAP((pkey)->data); \
} while (0)
#define FIND_FIRST_DB_MATCH(dbenv, dbp, tdbp) do { \
for ((tdbp) = (dbp); \
TAILQ_PREV((tdbp), __dblist, dblistlinks) != NULL && \
TAILQ_PREV((tdbp), \
__dblist, dblistlinks)->adj_fileid == (dbp)->adj_fileid;\
(tdbp) = TAILQ_PREV((tdbp), __dblist, dblistlinks)) \
; \
} while (0)
#define DB_BINARY_SEARCH_FOR(base, limit, page, adjust) \
for (base = 0, limit = NUM_ENT(page) / (db_indx_t)(adjust); \
(limit) != 0; (limit) >>= 1)
#define DB_BINARY_SEARCH_INCR(index, base, limit, adjust) \
index = (base) + (((limit) >> 1) * (adjust))
#define DB_BINARY_SEARCH_SHIFT_BASE(index, base, limit, adjust) do { \
base = (index) + (adjust); \
--(limit); \
} while (0)
#define DB_CHK_META 0x01
#define DB_CHK_NOLSN 0x02
#if defined(__cplusplus)
}
#endif
#include "dbinc/db_dispatch.h"
#include "dbinc_auto/db_auto.h"
#include "dbinc_auto/crdel_auto.h"
#include "dbinc_auto/db_ext.h"
#endif