OpenE2K
/
glibc
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
glibc/db2/txn/txn_rec.c

297 lines
7.8 KiB
C
Raw Blame History

/*-
* 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);
}
Reference in New Issue View Git Blame Copy Permalink