diff options
Diffstat (limited to 'db2/txn/txn_auto.c')
| -rw-r--r-- | db2/txn/txn_auto.c | 621 |
1 files changed, 0 insertions, 621 deletions
diff --git a/db2/txn/txn_auto.c b/db2/txn/txn_auto.c deleted file mode 100644 index e6d431f089..0000000000 --- a/db2/txn/txn_auto.c +++ /dev/null @@ -1,621 +0,0 @@ -/* Do not edit: automatically built by dist/db_gen.sh. */ -#include "config.h" - -#ifndef NO_SYSTEM_INCLUDES -#include <ctype.h> -#include <errno.h> -#include <stddef.h> -#include <stdlib.h> -#include <string.h> -#endif - -#include "db_int.h" -#include "db_page.h" -#include "db_dispatch.h" -#include "txn.h" -#include "db_am.h" -/* - * PUBLIC: int __txn_regop_log - * PUBLIC: __P((DB_LOG *, DB_TXN *, DB_LSN *, u_int32_t, - * PUBLIC: u_int32_t)); - */ -int __txn_regop_log(logp, txnid, ret_lsnp, flags, - opcode) - DB_LOG *logp; - DB_TXN *txnid; - DB_LSN *ret_lsnp; - u_int32_t flags; - u_int32_t opcode; -{ - DBT logrec; - DB_LSN *lsnp, null_lsn; - u_int32_t rectype, txn_num; - int ret; - u_int8_t *bp; - - rectype = DB_txn_regop; - txn_num = txnid == NULL ? 0 : txnid->txnid; - if (txnid == NULL) { - ZERO_LSN(null_lsn); - lsnp = &null_lsn; - } else - lsnp = &txnid->last_lsn; - logrec.size = sizeof(rectype) + sizeof(txn_num) + sizeof(DB_LSN) - + sizeof(opcode); - if ((ret = __os_malloc(logrec.size, NULL, &logrec.data)) != 0) - return (ret); - - bp = logrec.data; - memcpy(bp, &rectype, sizeof(rectype)); - bp += sizeof(rectype); - memcpy(bp, &txn_num, sizeof(txn_num)); - bp += sizeof(txn_num); - memcpy(bp, lsnp, sizeof(DB_LSN)); - bp += sizeof(DB_LSN); - memcpy(bp, &opcode, sizeof(opcode)); - bp += sizeof(opcode); -#ifdef DIAGNOSTIC - if ((u_int32_t)(bp - (u_int8_t *)logrec.data) != logrec.size) - fprintf(stderr, "Error in log record length"); -#endif - ret = log_put(logp, ret_lsnp, (DBT *)&logrec, flags); - if (txnid != NULL) - txnid->last_lsn = *ret_lsnp; - __os_free(logrec.data, 0); - return (ret); -} - -/* - * PUBLIC: int __txn_regop_print - * PUBLIC: __P((DB_LOG *, DBT *, DB_LSN *, int, void *)); - */ -int -__txn_regop_print(notused1, dbtp, lsnp, notused2, notused3) - DB_LOG *notused1; - DBT *dbtp; - DB_LSN *lsnp; - int notused2; - void *notused3; -{ - __txn_regop_args *argp; - u_int32_t i; - u_int ch; - int ret; - - i = 0; - ch = 0; - notused1 = NULL; - notused2 = 0; - notused3 = NULL; - - if ((ret = __txn_regop_read(dbtp->data, &argp)) != 0) - return (ret); - printf("[%lu][%lu]txn_regop: rec: %lu txnid %lx prevlsn [%lu][%lu]\n", - (u_long)lsnp->file, - (u_long)lsnp->offset, - (u_long)argp->type, - (u_long)argp->txnid->txnid, - (u_long)argp->prev_lsn.file, - (u_long)argp->prev_lsn.offset); - printf("\topcode: %lu\n", (u_long)argp->opcode); - printf("\n"); - __os_free(argp, 0); - return (0); -} - -/* - * PUBLIC: int __txn_regop_read __P((void *, __txn_regop_args **)); - */ -int -__txn_regop_read(recbuf, argpp) - void *recbuf; - __txn_regop_args **argpp; -{ - __txn_regop_args *argp; - u_int8_t *bp; - int ret; - - ret = __os_malloc(sizeof(__txn_regop_args) + - sizeof(DB_TXN), NULL, &argp); - if (ret != 0) - return (ret); - argp->txnid = (DB_TXN *)&argp[1]; - bp = recbuf; - memcpy(&argp->type, bp, sizeof(argp->type)); - bp += sizeof(argp->type); - memcpy(&argp->txnid->txnid, bp, sizeof(argp->txnid->txnid)); - bp += sizeof(argp->txnid->txnid); - memcpy(&argp->prev_lsn, bp, sizeof(DB_LSN)); - bp += sizeof(DB_LSN); - memcpy(&argp->opcode, bp, sizeof(argp->opcode)); - bp += sizeof(argp->opcode); - *argpp = argp; - return (0); -} - -/* - * PUBLIC: int __txn_ckp_log - * PUBLIC: __P((DB_LOG *, DB_TXN *, DB_LSN *, u_int32_t, - * PUBLIC: DB_LSN *, DB_LSN *)); - */ -int __txn_ckp_log(logp, txnid, ret_lsnp, flags, - ckp_lsn, last_ckp) - DB_LOG *logp; - DB_TXN *txnid; - DB_LSN *ret_lsnp; - u_int32_t flags; - DB_LSN * ckp_lsn; - DB_LSN * last_ckp; -{ - DBT logrec; - DB_LSN *lsnp, null_lsn; - u_int32_t rectype, txn_num; - int ret; - u_int8_t *bp; - - rectype = DB_txn_ckp; - txn_num = txnid == NULL ? 0 : txnid->txnid; - if (txnid == NULL) { - ZERO_LSN(null_lsn); - lsnp = &null_lsn; - } else - lsnp = &txnid->last_lsn; - logrec.size = sizeof(rectype) + sizeof(txn_num) + sizeof(DB_LSN) - + sizeof(*ckp_lsn) - + sizeof(*last_ckp); - if ((ret = __os_malloc(logrec.size, NULL, &logrec.data)) != 0) - return (ret); - - bp = logrec.data; - memcpy(bp, &rectype, sizeof(rectype)); - bp += sizeof(rectype); - memcpy(bp, &txn_num, sizeof(txn_num)); - bp += sizeof(txn_num); - memcpy(bp, lsnp, sizeof(DB_LSN)); - bp += sizeof(DB_LSN); - if (ckp_lsn != NULL) - memcpy(bp, ckp_lsn, sizeof(*ckp_lsn)); - else - memset(bp, 0, sizeof(*ckp_lsn)); - bp += sizeof(*ckp_lsn); - if (last_ckp != NULL) - memcpy(bp, last_ckp, sizeof(*last_ckp)); - else - memset(bp, 0, sizeof(*last_ckp)); - bp += sizeof(*last_ckp); -#ifdef DIAGNOSTIC - if ((u_int32_t)(bp - (u_int8_t *)logrec.data) != logrec.size) - fprintf(stderr, "Error in log record length"); -#endif - ret = log_put(logp, ret_lsnp, (DBT *)&logrec, flags); - if (txnid != NULL) - txnid->last_lsn = *ret_lsnp; - __os_free(logrec.data, 0); - return (ret); -} - -/* - * PUBLIC: int __txn_ckp_print - * PUBLIC: __P((DB_LOG *, DBT *, DB_LSN *, int, void *)); - */ -int -__txn_ckp_print(notused1, dbtp, lsnp, notused2, notused3) - DB_LOG *notused1; - DBT *dbtp; - DB_LSN *lsnp; - int notused2; - void *notused3; -{ - __txn_ckp_args *argp; - u_int32_t i; - u_int ch; - int ret; - - i = 0; - ch = 0; - notused1 = NULL; - notused2 = 0; - notused3 = NULL; - - if ((ret = __txn_ckp_read(dbtp->data, &argp)) != 0) - return (ret); - printf("[%lu][%lu]txn_ckp: rec: %lu txnid %lx prevlsn [%lu][%lu]\n", - (u_long)lsnp->file, - (u_long)lsnp->offset, - (u_long)argp->type, - (u_long)argp->txnid->txnid, - (u_long)argp->prev_lsn.file, - (u_long)argp->prev_lsn.offset); - printf("\tckp_lsn: [%lu][%lu]\n", - (u_long)argp->ckp_lsn.file, (u_long)argp->ckp_lsn.offset); - printf("\tlast_ckp: [%lu][%lu]\n", - (u_long)argp->last_ckp.file, (u_long)argp->last_ckp.offset); - printf("\n"); - __os_free(argp, 0); - return (0); -} - -/* - * PUBLIC: int __txn_ckp_read __P((void *, __txn_ckp_args **)); - */ -int -__txn_ckp_read(recbuf, argpp) - void *recbuf; - __txn_ckp_args **argpp; -{ - __txn_ckp_args *argp; - u_int8_t *bp; - int ret; - - ret = __os_malloc(sizeof(__txn_ckp_args) + - sizeof(DB_TXN), NULL, &argp); - if (ret != 0) - return (ret); - argp->txnid = (DB_TXN *)&argp[1]; - bp = recbuf; - memcpy(&argp->type, bp, sizeof(argp->type)); - bp += sizeof(argp->type); - memcpy(&argp->txnid->txnid, bp, sizeof(argp->txnid->txnid)); - bp += sizeof(argp->txnid->txnid); - memcpy(&argp->prev_lsn, bp, sizeof(DB_LSN)); - bp += sizeof(DB_LSN); - memcpy(&argp->ckp_lsn, bp, sizeof(argp->ckp_lsn)); - bp += sizeof(argp->ckp_lsn); - memcpy(&argp->last_ckp, bp, sizeof(argp->last_ckp)); - bp += sizeof(argp->last_ckp); - *argpp = argp; - return (0); -} - -/* - * PUBLIC: int __txn_xa_regop_log - * PUBLIC: __P((DB_LOG *, DB_TXN *, DB_LSN *, u_int32_t, - * PUBLIC: u_int32_t, const DBT *, int32_t, u_int32_t, - * PUBLIC: u_int32_t, DB_LSN *)); - */ -int __txn_xa_regop_log(logp, txnid, ret_lsnp, flags, - opcode, xid, formatID, gtrid, bqual, begin_lsn) - DB_LOG *logp; - DB_TXN *txnid; - DB_LSN *ret_lsnp; - u_int32_t flags; - u_int32_t opcode; - const DBT *xid; - int32_t formatID; - u_int32_t gtrid; - u_int32_t bqual; - DB_LSN * begin_lsn; -{ - DBT logrec; - DB_LSN *lsnp, null_lsn; - u_int32_t zero; - u_int32_t rectype, txn_num; - int ret; - u_int8_t *bp; - - rectype = DB_txn_xa_regop; - txn_num = txnid == NULL ? 0 : txnid->txnid; - if (txnid == NULL) { - ZERO_LSN(null_lsn); - lsnp = &null_lsn; - } else - lsnp = &txnid->last_lsn; - logrec.size = sizeof(rectype) + sizeof(txn_num) + sizeof(DB_LSN) - + sizeof(opcode) - + sizeof(u_int32_t) + (xid == NULL ? 0 : xid->size) - + sizeof(formatID) - + sizeof(gtrid) - + sizeof(bqual) - + sizeof(*begin_lsn); - if ((ret = __os_malloc(logrec.size, NULL, &logrec.data)) != 0) - return (ret); - - bp = logrec.data; - memcpy(bp, &rectype, sizeof(rectype)); - bp += sizeof(rectype); - memcpy(bp, &txn_num, sizeof(txn_num)); - bp += sizeof(txn_num); - memcpy(bp, lsnp, sizeof(DB_LSN)); - bp += sizeof(DB_LSN); - memcpy(bp, &opcode, sizeof(opcode)); - bp += sizeof(opcode); - if (xid == NULL) { - zero = 0; - memcpy(bp, &zero, sizeof(u_int32_t)); - bp += sizeof(u_int32_t); - } else { - memcpy(bp, &xid->size, sizeof(xid->size)); - bp += sizeof(xid->size); - memcpy(bp, xid->data, xid->size); - bp += xid->size; - } - memcpy(bp, &formatID, sizeof(formatID)); - bp += sizeof(formatID); - memcpy(bp, >rid, sizeof(gtrid)); - bp += sizeof(gtrid); - memcpy(bp, &bqual, sizeof(bqual)); - bp += sizeof(bqual); - if (begin_lsn != NULL) - memcpy(bp, begin_lsn, sizeof(*begin_lsn)); - else - memset(bp, 0, sizeof(*begin_lsn)); - bp += sizeof(*begin_lsn); -#ifdef DIAGNOSTIC - if ((u_int32_t)(bp - (u_int8_t *)logrec.data) != logrec.size) - fprintf(stderr, "Error in log record length"); -#endif - ret = log_put(logp, ret_lsnp, (DBT *)&logrec, flags); - if (txnid != NULL) - txnid->last_lsn = *ret_lsnp; - __os_free(logrec.data, 0); - return (ret); -} - -/* - * PUBLIC: int __txn_xa_regop_print - * PUBLIC: __P((DB_LOG *, DBT *, DB_LSN *, int, void *)); - */ -int -__txn_xa_regop_print(notused1, dbtp, lsnp, notused2, notused3) - DB_LOG *notused1; - DBT *dbtp; - DB_LSN *lsnp; - int notused2; - void *notused3; -{ - __txn_xa_regop_args *argp; - u_int32_t i; - u_int ch; - int ret; - - i = 0; - ch = 0; - notused1 = NULL; - notused2 = 0; - notused3 = NULL; - - if ((ret = __txn_xa_regop_read(dbtp->data, &argp)) != 0) - return (ret); - printf("[%lu][%lu]txn_xa_regop: rec: %lu txnid %lx prevlsn [%lu][%lu]\n", - (u_long)lsnp->file, - (u_long)lsnp->offset, - (u_long)argp->type, - (u_long)argp->txnid->txnid, - (u_long)argp->prev_lsn.file, - (u_long)argp->prev_lsn.offset); - printf("\topcode: %lu\n", (u_long)argp->opcode); - printf("\txid: "); - for (i = 0; i < argp->xid.size; i++) { - ch = ((u_int8_t *)argp->xid.data)[i]; - if (isprint(ch) || ch == 0xa) - putchar(ch); - else - printf("%#x ", ch); - } - printf("\n"); - printf("\tformatID: %ld\n", (long)argp->formatID); - printf("\tgtrid: %u\n", argp->gtrid); - printf("\tbqual: %u\n", argp->bqual); - printf("\tbegin_lsn: [%lu][%lu]\n", - (u_long)argp->begin_lsn.file, (u_long)argp->begin_lsn.offset); - printf("\n"); - __os_free(argp, 0); - return (0); -} - -/* - * PUBLIC: int __txn_xa_regop_read __P((void *, __txn_xa_regop_args **)); - */ -int -__txn_xa_regop_read(recbuf, argpp) - void *recbuf; - __txn_xa_regop_args **argpp; -{ - __txn_xa_regop_args *argp; - u_int8_t *bp; - int ret; - - ret = __os_malloc(sizeof(__txn_xa_regop_args) + - sizeof(DB_TXN), NULL, &argp); - if (ret != 0) - return (ret); - argp->txnid = (DB_TXN *)&argp[1]; - bp = recbuf; - memcpy(&argp->type, bp, sizeof(argp->type)); - bp += sizeof(argp->type); - memcpy(&argp->txnid->txnid, bp, sizeof(argp->txnid->txnid)); - bp += sizeof(argp->txnid->txnid); - memcpy(&argp->prev_lsn, bp, sizeof(DB_LSN)); - bp += sizeof(DB_LSN); - memcpy(&argp->opcode, bp, sizeof(argp->opcode)); - bp += sizeof(argp->opcode); - memcpy(&argp->xid.size, bp, sizeof(u_int32_t)); - bp += sizeof(u_int32_t); - argp->xid.data = bp; - bp += argp->xid.size; - memcpy(&argp->formatID, bp, sizeof(argp->formatID)); - bp += sizeof(argp->formatID); - memcpy(&argp->gtrid, bp, sizeof(argp->gtrid)); - bp += sizeof(argp->gtrid); - memcpy(&argp->bqual, bp, sizeof(argp->bqual)); - bp += sizeof(argp->bqual); - memcpy(&argp->begin_lsn, bp, sizeof(argp->begin_lsn)); - bp += sizeof(argp->begin_lsn); - *argpp = argp; - return (0); -} - -/* - * PUBLIC: int __txn_child_log - * PUBLIC: __P((DB_LOG *, DB_TXN *, DB_LSN *, u_int32_t, - * PUBLIC: u_int32_t, u_int32_t)); - */ -int __txn_child_log(logp, txnid, ret_lsnp, flags, - opcode, parent) - DB_LOG *logp; - DB_TXN *txnid; - DB_LSN *ret_lsnp; - u_int32_t flags; - u_int32_t opcode; - u_int32_t parent; -{ - DBT logrec; - DB_LSN *lsnp, null_lsn; - u_int32_t rectype, txn_num; - int ret; - u_int8_t *bp; - - rectype = DB_txn_child; - txn_num = txnid == NULL ? 0 : txnid->txnid; - if (txnid == NULL) { - ZERO_LSN(null_lsn); - lsnp = &null_lsn; - } else - lsnp = &txnid->last_lsn; - logrec.size = sizeof(rectype) + sizeof(txn_num) + sizeof(DB_LSN) - + sizeof(opcode) - + sizeof(parent); - if ((ret = __os_malloc(logrec.size, NULL, &logrec.data)) != 0) - return (ret); - - bp = logrec.data; - memcpy(bp, &rectype, sizeof(rectype)); - bp += sizeof(rectype); - memcpy(bp, &txn_num, sizeof(txn_num)); - bp += sizeof(txn_num); - memcpy(bp, lsnp, sizeof(DB_LSN)); - bp += sizeof(DB_LSN); - memcpy(bp, &opcode, sizeof(opcode)); - bp += sizeof(opcode); - memcpy(bp, &parent, sizeof(parent)); - bp += sizeof(parent); -#ifdef DIAGNOSTIC - if ((u_int32_t)(bp - (u_int8_t *)logrec.data) != logrec.size) - fprintf(stderr, "Error in log record length"); -#endif - ret = log_put(logp, ret_lsnp, (DBT *)&logrec, flags); - if (txnid != NULL) - txnid->last_lsn = *ret_lsnp; - __os_free(logrec.data, 0); - return (ret); -} - -/* - * PUBLIC: int __txn_child_print - * PUBLIC: __P((DB_LOG *, DBT *, DB_LSN *, int, void *)); - */ -int -__txn_child_print(notused1, dbtp, lsnp, notused2, notused3) - DB_LOG *notused1; - DBT *dbtp; - DB_LSN *lsnp; - int notused2; - void *notused3; -{ - __txn_child_args *argp; - u_int32_t i; - u_int ch; - int ret; - - i = 0; - ch = 0; - notused1 = NULL; - notused2 = 0; - notused3 = NULL; - - if ((ret = __txn_child_read(dbtp->data, &argp)) != 0) - return (ret); - printf("[%lu][%lu]txn_child: rec: %lu txnid %lx prevlsn [%lu][%lu]\n", - (u_long)lsnp->file, - (u_long)lsnp->offset, - (u_long)argp->type, - (u_long)argp->txnid->txnid, - (u_long)argp->prev_lsn.file, - (u_long)argp->prev_lsn.offset); - printf("\topcode: %lu\n", (u_long)argp->opcode); - printf("\tparent: %lu\n", (u_long)argp->parent); - printf("\n"); - __os_free(argp, 0); - return (0); -} - -/* - * PUBLIC: int __txn_child_read __P((void *, __txn_child_args **)); - */ -int -__txn_child_read(recbuf, argpp) - void *recbuf; - __txn_child_args **argpp; -{ - __txn_child_args *argp; - u_int8_t *bp; - int ret; - - ret = __os_malloc(sizeof(__txn_child_args) + - sizeof(DB_TXN), NULL, &argp); - if (ret != 0) - return (ret); - argp->txnid = (DB_TXN *)&argp[1]; - bp = recbuf; - memcpy(&argp->type, bp, sizeof(argp->type)); - bp += sizeof(argp->type); - memcpy(&argp->txnid->txnid, bp, sizeof(argp->txnid->txnid)); - bp += sizeof(argp->txnid->txnid); - memcpy(&argp->prev_lsn, bp, sizeof(DB_LSN)); - bp += sizeof(DB_LSN); - memcpy(&argp->opcode, bp, sizeof(argp->opcode)); - bp += sizeof(argp->opcode); - memcpy(&argp->parent, bp, sizeof(argp->parent)); - bp += sizeof(argp->parent); - *argpp = argp; - return (0); -} - -/* - * PUBLIC: int __txn_init_print __P((DB_ENV *)); - */ -int -__txn_init_print(dbenv) - DB_ENV *dbenv; -{ - int ret; - - if ((ret = __db_add_recovery(dbenv, - __txn_regop_print, DB_txn_regop)) != 0) - return (ret); - if ((ret = __db_add_recovery(dbenv, - __txn_ckp_print, DB_txn_ckp)) != 0) - return (ret); - if ((ret = __db_add_recovery(dbenv, - __txn_xa_regop_print, DB_txn_xa_regop)) != 0) - return (ret); - if ((ret = __db_add_recovery(dbenv, - __txn_child_print, DB_txn_child)) != 0) - return (ret); - return (0); -} - -/* - * PUBLIC: int __txn_init_recover __P((DB_ENV *)); - */ -int -__txn_init_recover(dbenv) - DB_ENV *dbenv; -{ - int ret; - - if ((ret = __db_add_recovery(dbenv, - __txn_regop_recover, DB_txn_regop)) != 0) - return (ret); - if ((ret = __db_add_recovery(dbenv, - __txn_ckp_recover, DB_txn_ckp)) != 0) - return (ret); - if ((ret = __db_add_recovery(dbenv, - __txn_xa_regop_recover, DB_txn_xa_regop)) != 0) - return (ret); - if ((ret = __db_add_recovery(dbenv, - __txn_child_recover, DB_txn_child)) != 0) - return (ret); - return (0); -} - |