#include "db_config.h"
#include "db_int.h"
#include "dbinc/txn.h"
int
__txn_failchk(dbenv)
DB_ENV *dbenv;
{
DB_TXN *ktxn, *txn;
DB_TXNMGR *mgr;
DB_TXNREGION *region;
TXN_DETAIL *ktd, *td;
db_threadid_t tid;
int ret;
char buf[DB_THREADID_STRLEN];
pid_t pid;
mgr = dbenv->tx_handle;
region = mgr->reginfo.primary;
retry: TXN_SYSTEM_LOCK(dbenv);
SH_TAILQ_FOREACH(td, ®ion->active_txn, links, __txn_detail) {
if (td->parent != INVALID_ROFF)
continue;
if (td->status == TXN_PREPARED)
continue;
if (dbenv->is_alive(dbenv, td->pid, td->tid, 0))
continue;
if (F_ISSET(td, TXN_DTL_INMEMORY))
return (__db_failed(dbenv,
"Transaction has in memory logs",
td->pid, td->tid));
TXN_SYSTEM_UNLOCK(dbenv);
if ((ret = __os_calloc(dbenv, 1, sizeof(DB_TXN), &txn)) != 0)
return (ret);
if ((ret = __txn_continue(dbenv, txn, td)) != 0)
return (ret);
F_SET(txn, TXN_MALLOC);
SH_TAILQ_FOREACH(ktd, &td->kids, klinks, __txn_detail) {
if (F_ISSET(ktd, TXN_DTL_INMEMORY))
return (__db_failed(dbenv,
"Transaction has in memory logs",
td->pid, td->tid));
if ((ret =
__os_calloc(dbenv, 1, sizeof(DB_TXN), &ktxn)) != 0)
return (ret);
if ((ret = __txn_continue(dbenv, ktxn, ktd)) != 0)
return (ret);
F_SET(ktxn, TXN_MALLOC);
ktxn->parent = txn;
TAILQ_INSERT_HEAD(&txn->kids, txn, klinks);
}
TAILQ_INSERT_TAIL(&mgr->txn_chain, txn, links);
pid = td->pid;
tid = td->tid;
(void)dbenv->thread_id_string(dbenv, pid, tid, buf);
__db_msg(dbenv,
"Aborting txn %#lx: %s", (u_long)txn->txnid, buf);
if ((ret = __txn_abort(txn)) != 0)
return (__db_failed(dbenv,
"Transaction abort failed", pid, tid));
goto retry;
}
TXN_SYSTEM_UNLOCK(dbenv);
return (0);
}