1 files changed, 101 insertions, 0 deletions
diff --git a/db-4.8.30/txn/txn_failchk.c b/db-4.8.30/txn/txn_failchk.c
new file mode 100644
index 0000000..0a17abc
--- /dev/null
+++ b/db-4.8.30/txn/txn_failchk.c
@@ -0,0 +1,101 @@
+/*-
+ * See the file LICENSE for redistribution information.
+ *
+ * Copyright (c) 2005-2009 Oracle.  All rights reserved.
+ *
+ * $Id$
+ */
+
+#include "db_config.h"
+
+#include "db_int.h"
+#include "dbinc/txn.h"
+
+/*
+ * __txn_failchk --
+ *	Check for transactions started by dead threads of control.
+ *
+ * PUBLIC: int __txn_failchk __P((ENV *));
+ */
+int
+__txn_failchk(env)
+	ENV *env;
+{
+	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 = env->tx_handle;
+	dbenv = env->dbenv;
+	region = mgr->reginfo.primary;
+
+retry:	TXN_SYSTEM_LOCK(env);
+
+	SH_TAILQ_FOREACH(td, &region->active_txn, links, __txn_detail) {
+		/*
+		 * If this is a child transaction, skip it.
+		 * The parent will take care of it.
+		 */
+		if (td->parent != INVALID_ROFF)
+			continue;
+		/*
+		 * If the txn is prepared, then it does not matter
+		 * what the state of the thread is.
+		 */
+		if (td->status == TXN_PREPARED)
+			continue;
+
+		/* If the thread is still alive, it's not a problem. */
+		if (dbenv->is_alive(dbenv, td->pid, td->tid, 0))
+			continue;
+
+		if (F_ISSET(td, TXN_DTL_INMEMORY)) {
+			TXN_SYSTEM_UNLOCK(env);
+			return (__db_failed(env,
+			     "Transaction has in memory logs",
+			     td->pid, td->tid));
+		}
+
+		/* Abort the transaction. */
+		TXN_SYSTEM_UNLOCK(env);
+		if ((ret = __os_calloc(env, 1, sizeof(DB_TXN), &txn)) != 0)
+			return (ret);
+		if ((ret = __txn_continue(env, 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(env,
+				     "Transaction has in memory logs",
+				     td->pid, td->tid));
+			if ((ret =
+			    __os_calloc(env, 1, sizeof(DB_TXN), &ktxn)) != 0)
+				return (ret);
+			if ((ret = __txn_continue(env, 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(env,
+		    "Aborting txn %#lx: %s", (u_long)txn->txnid, buf);
+		if ((ret = __txn_abort(txn)) != 0)
+			return (__db_failed(env,
+			     "Transaction abort failed", pid, tid));
+		goto retry;
+	}
+
+	TXN_SYSTEM_UNLOCK(env);
+
+	return (0);
+}