txn.h
上传用户:tsgydb
上传日期:2007-04-14
资源大小:10674k
文件大小:5k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /*-
  2.  * See the file LICENSE for redistribution information.
  3.  *
  4.  * Copyright (c) 1996, 1997, 1998, 1999, 2000
  5.  * Sleepycat Software.  All rights reserved.
  6.  *
  7.  * $Id: txn.h,v 11.12 2001/01/02 17:23:39 margo Exp $
  8.  */
  9. #ifndef _TXN_H_
  10. #define _TXN_H_
  11. #include "xa.h"
  12. struct __db_txnmgr; typedef struct __db_txnmgr DB_TXNMGR;
  13. struct __db_txnregion; typedef struct __db_txnregion DB_TXNREGION;
  14. /*
  15.  * !!!
  16.  * TXN_MINIMUM = (DB_LOCK_MAXID + 1) but this makes compilers complain.
  17.  */
  18. #define TXN_MINIMUM 0x80000000
  19. #define TXN_INVALID 0xffffffff /* Maximum number of txn ids. */
  20. #define TXN_INVALID_ID 0 /* Invalid transaction ID. */
  21. #define DEF_MAX_TXNS 20 /* Default max transactions. */
  22. /* The structure allocated for every transaction. */
  23. struct __db_txn {
  24. DB_TXNMGR *mgrp; /* Pointer to transaction manager. */
  25. DB_TXN *parent; /* Pointer to transaction's parent. */
  26. DB_LSN last_lsn; /* Lsn of last log write. */
  27. u_int32_t txnid; /* Unique transaction id. */
  28. roff_t off; /* Detail structure within region. */
  29. TAILQ_ENTRY(__db_txn) links; /* Links transactions off manager. */
  30. TAILQ_HEAD(__kids, __db_txn) kids; /* Child transactions. */
  31. TAILQ_ENTRY(__db_txn) klinks; /* Links child transactions. */
  32. u_int32_t cursors; /* Number of cursors open for txn */
  33. #define TXN_CHILDCOMMIT 0x01 /* Transaction that has committed. */
  34. #define TXN_MALLOC 0x02 /* Structure allocated by TXN system. */
  35. #define TXN_NOSYNC 0x04 /* Do not sync on prepare and commit. */
  36. #define TXN_NOWAIT 0x08 /* Do not wait on locks. */
  37. #define TXN_SYNC 0x10 /* Sync on prepare and commit. */
  38. u_int32_t flags;
  39. };
  40. /*
  41.  * Internal data maintained in shared memory for each transaction.
  42.  */
  43. typedef char DB_XID[XIDDATASIZE];
  44. typedef struct __txn_detail {
  45. u_int32_t txnid; /* current transaction id
  46.    used to link free list also */
  47. DB_LSN last_lsn; /* last lsn written for this txn */
  48. DB_LSN begin_lsn; /* lsn of begin record */
  49. roff_t parent; /* Offset of transaction's parent. */
  50. #define TXN_RUNNING 1
  51. #define TXN_ABORTED 2
  52. #define TXN_PREPARED 3
  53. #define TXN_COMMITTED 4
  54. u_int32_t status; /* status of the transaction */
  55. SH_TAILQ_ENTRY links; /* free/active list */
  56. #define TXN_XA_ABORTED 1
  57. #define TXN_XA_DEADLOCKED 2
  58. #define TXN_XA_ENDED 3
  59. #define TXN_XA_PREPARED 4
  60. #define TXN_XA_STARTED 5
  61. #define TXN_XA_SUSPENDED 6
  62. u_int32_t xa_status; /* XA status */
  63. /*
  64.  * XID (xid_t) structure: because these fields are logged, the
  65.  * sizes have to be explicit.
  66.  */
  67. DB_XID xid; /* XA global transaction id */
  68. u_int32_t bqual; /* bqual_length from XID */
  69. u_int32_t gtrid; /* gtrid_length from XID */
  70. int32_t format; /* XA format */
  71. } TXN_DETAIL;
  72. /*
  73.  * DB_TXNMGR --
  74.  * The transaction manager encapsulates the transaction system.
  75.  */
  76. struct __db_txnmgr {
  77. /*
  78.  * These fields need to be protected for multi-threaded support.
  79.  *
  80.  * !!!
  81.  * As this structure is allocated in per-process memory, the mutex may need
  82.  * to be stored elsewhere on architectures unable to support mutexes in heap
  83.  * memory, e.g., HP/UX 9.
  84.  */
  85. MUTEX *mutexp; /* Lock list of active transactions
  86.  * (including the content of each
  87.  * TXN_DETAIL structure on the list).
  88.  */
  89. /* List of active transactions. */
  90. TAILQ_HEAD(_chain, __db_txn) txn_chain;
  91. /* These fields are never updated after creation, and so not protected. */
  92. DB_ENV *dbenv; /* Environment. */
  93. REGINFO  reginfo; /* Region information. */
  94. };
  95. /*
  96.  * DB_TXNREGION --
  97.  * The primary transaction data structure in the shared memory region.
  98.  */
  99. struct __db_txnregion {
  100. u_int32_t maxtxns; /* maximum number of active TXNs */
  101. u_int32_t last_txnid; /* last transaction id given out */
  102. DB_LSN pending_ckp; /* last checkpoint did not finish */
  103. DB_LSN last_ckp; /* lsn of the last checkpoint */
  104. time_t time_ckp; /* time of last checkpoint */
  105. u_int32_t logtype; /* type of logging */
  106. u_int32_t locktype; /* lock type */
  107. u_int32_t naborts; /* number of aborted TXNs */
  108. u_int32_t ncommits; /* number of committed TXNs */
  109. u_int32_t nbegins; /* number of begun TXNs */
  110. u_int32_t nactive; /* number of active TXNs */
  111. u_int32_t maxnactive; /* maximum number of active TXNs */
  112. /* active TXN list */
  113. SH_TAILQ_HEAD(__active) active_txn;
  114. };
  115. /*
  116.  * Make the region large enough to hold N transaction detail structures
  117.  * plus some space to hold thread handles and the beginning of the shalloc
  118.  * region.
  119.  */
  120. #define TXN_REGION_SIZE(N)
  121. (sizeof(DB_TXNREGION) + N * sizeof(TXN_DETAIL) + 1000)
  122. /*
  123.  * Log record types.
  124.  */
  125. #define TXN_COMMIT 1
  126. #define TXN_PREPARE 2
  127. #include "txn_auto.h"
  128. #include "txn_ext.h"
  129. #include "xa_ext.h"
  130. #endif /* !_TXN_H_ */