#include "db_config.h"
#ifndef lint
static const char revid[] = "$Id: txn_region.c,v 1.1.1.1 2003/02/15 04:56:20 zarzycki Exp $";
#endif
#ifndef NO_SYSTEM_INCLUDES
#include <sys/types.h>
#if TIME_WITH_SYS_TIME
#include <sys/time.h>
#include <time.h>
#else
#if HAVE_SYS_TIME_H
#include <sys/time.h>
#else
#include <time.h>
#endif
#endif
#include <string.h>
#endif
#include "db_int.h"
#include "dbinc/log.h"
#include "dbinc/txn.h"
static int __txn_findlastckp __P((DB_ENV *, DB_LSN *));
static int __txn_init __P((DB_ENV *, DB_TXNMGR *));
static size_t __txn_region_size __P((DB_ENV *));
int
__txn_open(dbenv)
DB_ENV *dbenv;
{
DB_TXNMGR *tmgrp;
int ret;
if ((ret = __os_calloc(dbenv, 1, sizeof(DB_TXNMGR), &tmgrp)) != 0)
return (ret);
TAILQ_INIT(&tmgrp->txn_chain);
tmgrp->dbenv = dbenv;
tmgrp->reginfo.type = REGION_TYPE_TXN;
tmgrp->reginfo.id = INVALID_REGION_ID;
tmgrp->reginfo.mode = dbenv->db_mode;
tmgrp->reginfo.flags = REGION_JOIN_OK;
if (F_ISSET(dbenv, DB_ENV_CREATE))
F_SET(&tmgrp->reginfo, REGION_CREATE_OK);
if ((ret = __db_r_attach(dbenv,
&tmgrp->reginfo, __txn_region_size(dbenv))) != 0)
goto err;
if (F_ISSET(&tmgrp->reginfo, REGION_CREATE))
if ((ret = __txn_init(dbenv, tmgrp)) != 0)
goto err;
tmgrp->reginfo.primary =
R_ADDR(&tmgrp->reginfo, tmgrp->reginfo.rp->primary);
if (F_ISSET(dbenv, DB_ENV_THREAD) &&
(ret = __db_mutex_setup(dbenv, &tmgrp->reginfo, &tmgrp->mutexp,
MUTEX_ALLOC | MUTEX_NO_RLOCK | MUTEX_THREAD)) != 0)
goto err;
R_UNLOCK(dbenv, &tmgrp->reginfo);
dbenv->tx_handle = tmgrp;
return (0);
err: if (tmgrp->reginfo.addr != NULL) {
if (F_ISSET(&tmgrp->reginfo, REGION_CREATE))
ret = __db_panic(dbenv, ret);
R_UNLOCK(dbenv, &tmgrp->reginfo);
(void)__db_r_detach(dbenv, &tmgrp->reginfo, 0);
}
if (tmgrp->mutexp != NULL)
__db_mutex_free(dbenv, &tmgrp->reginfo, tmgrp->mutexp);
__os_free(dbenv, tmgrp);
return (ret);
}
static int
__txn_init(dbenv, tmgrp)
DB_ENV *dbenv;
DB_TXNMGR *tmgrp;
{
DB_LSN last_ckp;
DB_TXNREGION *region;
int ret;
#ifdef HAVE_MUTEX_SYSTEM_RESOURCES
u_int8_t *addr;
#endif
ZERO_LSN(last_ckp);
if (LOGGING_ON(dbenv)) {
__log_get_cached_ckp_lsn(dbenv, &last_ckp);
if (IS_ZERO_LSN(last_ckp) &&
(ret = __txn_findlastckp(dbenv, &last_ckp)) != 0)
return (ret);
}
if ((ret = __db_shalloc(tmgrp->reginfo.addr,
sizeof(DB_TXNREGION), 0, &tmgrp->reginfo.primary)) != 0) {
__db_err(dbenv,
"Unable to allocate memory for the transaction region");
return (ret);
}
tmgrp->reginfo.rp->primary =
R_OFFSET(&tmgrp->reginfo, tmgrp->reginfo.primary);
region = tmgrp->reginfo.primary;
memset(region, 0, sizeof(*region));
region->maxtxns = dbenv->tx_max;
region->last_txnid = TXN_MINIMUM;
region->cur_maxid = TXN_MAXIMUM;
region->last_ckp = last_ckp;
region->time_ckp = time(NULL);
region->logtype = 0;
region->locktype = 0;
memset(®ion->stat, 0, sizeof(region->stat));
region->stat.st_maxtxns = region->maxtxns;
SH_TAILQ_INIT(®ion->active_txn);
#ifdef HAVE_MUTEX_SYSTEM_RESOURCES
if ((ret = __db_shalloc(tmgrp->reginfo.addr,
sizeof(REGMAINT) + TXN_MAINT_SIZE, 0, &addr)) != 0) {
__db_err(dbenv,
"Unable to allocate memory for mutex maintenance");
return (ret);
}
__db_maintinit(&tmgrp->reginfo, addr, TXN_MAINT_SIZE);
region->maint_off = R_OFFSET(&tmgrp->reginfo, addr);
#endif
return (0);
}
static int
__txn_findlastckp(dbenv, lsnp)
DB_ENV *dbenv;
DB_LSN *lsnp;
{
DB_LOGC *logc;
DB_LSN lsn;
DBT dbt;
int ret, t_ret;
u_int32_t rectype;
if ((ret = dbenv->log_cursor(dbenv, &logc, 0)) != 0)
return (ret);
memset(&dbt, 0, sizeof(dbt));
if ((ret = logc->get(logc, &lsn, &dbt, DB_LAST)) != 0)
goto err;
lsn.offset = 0;
while ((ret = logc->get(logc, &lsn, &dbt, DB_PREV)) == 0) {
if (dbt.size < sizeof(u_int32_t))
continue;
memcpy(&rectype, dbt.data, sizeof(u_int32_t));
if (rectype == DB___txn_ckp) {
*lsnp = lsn;
break;
}
}
err: if ((t_ret = logc->close(logc, 0)) != 0 && ret == 0)
ret = t_ret;
return ((ret == 0 || ret == DB_NOTFOUND) ? 0 : ret);
}
int
__txn_dbenv_refresh(dbenv)
DB_ENV *dbenv;
{
DB_TXN *txnp;
DB_TXNMGR *tmgrp;
u_int32_t txnid;
int ret, t_ret;
ret = 0;
tmgrp = dbenv->tx_handle;
if (TAILQ_FIRST(&tmgrp->txn_chain) != NULL) {
__db_err(dbenv,
"Error: closing the transaction region with active transactions");
ret = EINVAL;
while ((txnp = TAILQ_FIRST(&tmgrp->txn_chain)) != NULL) {
txnid = txnp->txnid;
if ((t_ret = txnp->abort(txnp)) != 0) {
__db_err(dbenv,
"Unable to abort transaction 0x%x: %s",
txnid, db_strerror(t_ret));
ret = __db_panic(dbenv, t_ret);
break;
}
}
}
if (LOGGING_ON(dbenv) &&
(t_ret = dbenv->log_flush(dbenv, NULL)) != 0 && ret == 0)
ret = t_ret;
if (tmgrp->mutexp != NULL)
__db_mutex_free(dbenv, &tmgrp->reginfo, tmgrp->mutexp);
if ((t_ret = __db_r_detach(dbenv, &tmgrp->reginfo, 0)) != 0 && ret == 0)
ret = t_ret;
__os_free(dbenv, tmgrp);
dbenv->tx_handle = NULL;
return (ret);
}
static size_t
__txn_region_size(dbenv)
DB_ENV *dbenv;
{
size_t s;
s = sizeof(DB_TXNREGION) +
dbenv->tx_max * sizeof(TXN_DETAIL) + 10 * 1024;
#ifdef HAVE_MUTEX_SYSTEM_RESOURCES
if (F_ISSET(dbenv, DB_ENV_THREAD))
s += sizeof(REGMAINT) + TXN_MAINT_SIZE;
#endif
return (s);
}
void
__txn_region_destroy(dbenv, infop)
DB_ENV *dbenv;
REGINFO *infop;
{
__db_shlocks_destroy(infop, (REGMAINT *)R_ADDR(infop,
((DB_TXNREGION *)R_ADDR(infop, infop->rp->primary))->maint_off));
COMPQUIET(dbenv, NULL);
COMPQUIET(infop, NULL);
}
#ifdef CONFIG_TEST
int
__txn_id_set(dbenv, cur_txnid, max_txnid)
DB_ENV *dbenv;
u_int32_t cur_txnid, max_txnid;
{
DB_TXNMGR *mgr;
DB_TXNREGION *region;
int ret;
ENV_REQUIRES_CONFIG(dbenv, dbenv->tx_handle, "txn_id_set", DB_INIT_TXN);
mgr = dbenv->tx_handle;
region = mgr->reginfo.primary;
region->last_txnid = cur_txnid;
region->cur_maxid = max_txnid;
ret = 0;
if (cur_txnid < TXN_MINIMUM) {
__db_err(dbenv, "Current ID value %lu below minimum",
cur_txnid);
ret = EINVAL;
}
if (max_txnid < TXN_MINIMUM) {
__db_err(dbenv, "Maximum ID value %lu below minimum",
max_txnid);
ret = EINVAL;
}
return (ret);
}
#endif