diff options
Diffstat (limited to 'db2/txn/txn_rec.c')
| -rw-r--r-- | db2/txn/txn_rec.c | 296 |
1 files changed, 0 insertions, 296 deletions
diff --git a/db2/txn/txn_rec.c b/db2/txn/txn_rec.c deleted file mode 100644 index f21a0f92c8..0000000000 --- a/db2/txn/txn_rec.c +++ /dev/null @@ -1,296 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1996, 1997, 1998 - * Sleepycat Software. All rights reserved. - */ -/* - * Copyright (c) 1996 - * The President and Fellows of Harvard University. All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * 1. Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * 2. Redistributions in binary form must reproduce the above copyright - * notice, this list of conditions and the following disclaimer in the - * documentation and/or other materials provided with the distribution. - * 3. All advertising materials mentioning features or use of this software - * must display the following acknowledgement: - * This product includes software developed by the University of - * California, Berkeley and its contributors. - * 4. Neither the name of the University nor the names of its contributors - * may be used to endorse or promote products derived from this software - * without specific prior written permission. - * - * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND - * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE - * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE - * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE - * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL - * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS - * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) - * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT - * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY - * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF - * SUCH DAMAGE. - */ - -#include "config.h" - -#ifndef lint -static const char sccsid[] = "@(#)txn_rec.c 10.15 (Sleepycat) 1/3/99"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> - -#include <errno.h> -#endif - -#include "db_int.h" -#include "db_page.h" -#include "shqueue.h" -#include "txn.h" -#include "db_am.h" -#include "log.h" -#include "common_ext.h" - -static int __txn_restore_txn __P((DB_ENV *, DB_LSN *, __txn_xa_regop_args *)); - -#define IS_XA_TXN(R) (R->xid.size != 0) - -/* - * PUBLIC: int __txn_regop_recover - * PUBLIC: __P((DB_LOG *, DBT *, DB_LSN *, int, void *)); - * - * These records are only ever written for commits. - */ -int -__txn_regop_recover(logp, dbtp, lsnp, redo, info) - DB_LOG *logp; - DBT *dbtp; - DB_LSN *lsnp; - int redo; - void *info; -{ - __txn_regop_args *argp; - int ret; - -#ifdef DEBUG_RECOVER - (void)__txn_regop_print(logp, dbtp, lsnp, redo, info); -#endif - COMPQUIET(redo, 0); - COMPQUIET(logp, NULL); - - if ((ret = __txn_regop_read(dbtp->data, &argp)) != 0) - return (ret); - - if (argp->opcode != TXN_COMMIT) - ret = EINVAL; - else - if (__db_txnlist_find(info, argp->txnid->txnid) == DB_NOTFOUND) - ret = __db_txnlist_add(info, argp->txnid->txnid); - - if (ret == 0) - *lsnp = argp->prev_lsn; - __os_free(argp, 0); - - return (ret); -} - -/* - * PUBLIC: int __txn_xa_regop_recover - * PUBLIC: __P((DB_LOG *, DBT *, DB_LSN *, int, void *)); - * - * These records are only ever written for prepares. - */ -int -__txn_xa_regop_recover(logp, dbtp, lsnp, redo, info) - DB_LOG *logp; - DBT *dbtp; - DB_LSN *lsnp; - int redo; - void *info; -{ - __txn_xa_regop_args *argp; - int ret; - -#ifdef DEBUG_RECOVER - (void)__txn_xa_regop_print(logp, dbtp, lsnp, redo, info); -#endif - COMPQUIET(redo, 0); - COMPQUIET(logp, NULL); - - if ((ret = __txn_xa_regop_read(dbtp->data, &argp)) != 0) - return (ret); - - if (argp->opcode != TXN_PREPARE) - ret = EINVAL; - else { - /* - * Whether we are in XA or not, we need to call - * __db_txnlist_find so that we update the maxid. - * If this is an XA transaction, then we treat - * prepares like commits so that we roll forward to - * a point where we can handle commit/abort calls - * from the TMS. If this isn't XA, then a prepare - * is treated like a No-op; we only care about the - * commit. - */ - ret = __db_txnlist_find(info, argp->txnid->txnid); - if (IS_XA_TXN(argp) && ret == DB_NOTFOUND) { - /* - * This is an XA prepared, but not yet committed - * transaction. We need to add it to the - * transaction list, so that it gets rolled - * forward. We also have to add it to the region's - * internal state so it can be properly aborted - * or recovered. - */ - ret = __db_txnlist_add(info, argp->txnid->txnid); - if (ret == 0) - ret = __txn_restore_txn(logp->dbenv, - lsnp, argp); - } - } - - if (ret == 0) - *lsnp = argp->prev_lsn; - __os_free(argp, 0); - - return (ret); -} - -/* - * PUBLIC: int __txn_ckp_recover __P((DB_LOG *, DBT *, DB_LSN *, int, void *)); - */ -int -__txn_ckp_recover(logp, dbtp, lsnp, redo, info) - DB_LOG *logp; - DBT *dbtp; - DB_LSN *lsnp; - int redo; - void *info; -{ - __txn_ckp_args *argp; - int ret; - -#ifdef DEBUG_RECOVER - __txn_ckp_print(logp, dbtp, lsnp, redo, info); -#endif - COMPQUIET(logp, NULL); - - if ((ret = __txn_ckp_read(dbtp->data, &argp)) != 0) - return (ret); - - /* - * Check for 'restart' checkpoint record. This occurs when the - * checkpoint lsn is equal to the lsn of the checkpoint record - * and means that we could set the transaction ID back to 1, so - * that we don't exhaust the transaction ID name space. - */ - if (argp->ckp_lsn.file == lsnp->file && - argp->ckp_lsn.offset == lsnp->offset) - __db_txnlist_gen(info, redo ? -1 : 1); - - *lsnp = argp->last_ckp; - __os_free(argp, 0); - return (DB_TXN_CKP); -} - -/* - * __txn_child_recover - * Recover a commit record for a child transaction. - * - * PUBLIC: int __txn_child_recover - * PUBLIC: __P((DB_LOG *, DBT *, DB_LSN *, int, void *)); - */ -int -__txn_child_recover(logp, dbtp, lsnp, redo, info) - DB_LOG *logp; - DBT *dbtp; - DB_LSN *lsnp; - int redo; - void *info; -{ - __txn_child_args *argp; - int ret; - -#ifdef DEBUG_RECOVER - (void)__txn_child_print(logp, dbtp, lsnp, redo, info); -#endif - COMPQUIET(redo, 0); - COMPQUIET(logp, NULL); - - if ((ret = __txn_child_read(dbtp->data, &argp)) != 0) - return (ret); - - /* - * We count the child as committed only if its parent committed. - * So, if we are not yet in the transaction list, but our parent - * is, then we should go ahead and commit. - */ - if (argp->opcode != TXN_COMMIT) - ret = EINVAL; - else - if (__db_txnlist_find(info, argp->parent) == 0 && - __db_txnlist_find(info, argp->txnid->txnid) == DB_NOTFOUND) - ret = __db_txnlist_add(info, argp->txnid->txnid); - - if (ret == 0) - *lsnp = argp->prev_lsn; - __os_free(argp, 0); - - return (ret); -} - -/* - * __txn_restore_txn -- - * Using only during XA recovery. If we find any transactions that are - * prepared, but not yet committed, then we need to restore the transaction's - * state into the shared region, because the TM is going to issue a txn_abort - * or txn_commit and we need to respond correctly. - * - * lsnp is the LSN of the returned LSN - * argp is the perpare record (in an appropriate structure) - */ -static int -__txn_restore_txn(dbenv, lsnp, argp) - DB_ENV *dbenv; - DB_LSN *lsnp; - __txn_xa_regop_args *argp; -{ - DB_TXNMGR *mgr; - TXN_DETAIL *td; - int ret; - - if (argp->xid.size == 0) - return(0); - - mgr = dbenv->tx_info; - LOCK_TXNREGION(mgr); - - /* Allocate a new transaction detail structure. */ - if ((ret = __db_shalloc(mgr->mem, sizeof(TXN_DETAIL), 0, &td)) != 0) - return (ret); - - /* Place transaction on active transaction list. */ - SH_TAILQ_INSERT_HEAD(&mgr->region->active_txn, td, links, __txn_detail); - - td->txnid = argp->txnid->txnid; - td->begin_lsn = argp->begin_lsn; - td->last_lsn = *lsnp; - td->last_lock = 0; - td->parent = 0; - td->status = TXN_PREPARED; - td->xa_status = TXN_XA_PREPARED; - memcpy(td->xid, argp->xid.data, argp->xid.size); - td->bqual = argp->bqual; - td->gtrid = argp->gtrid; - td->format = argp->formatID; - - UNLOCK_TXNREGION(mgr); - return (0); -} |