/***************************************************************************** Copyright (c) 1996, 2014, Oracle and/or its affiliates. All Rights Reserved. Copyright (c) 2017, 2020, MariaDB Corporation. This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; version 2 of the License. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with this program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1335 USA *****************************************************************************/ /**************************************************//** @file include/trx0types.h Transaction system global type definitions Created 3/26/1996 Heikki Tuuri *******************************************************/ #ifndef trx0types_h #define trx0types_h #include "ut0byte.h" #include "ut0mutex.h" #include /** printf(3) format used for printing DB_TRX_ID and other system fields */ #define TRX_ID_FMT IB_ID_FMT /** maximum length that a formatted trx_t::id could take, not including the terminating NUL character. */ static const ulint TRX_ID_MAX_LEN = 17; /** Space id of the transaction system page (the system tablespace) */ static const ulint TRX_SYS_SPACE = 0; /** Page number of the transaction system page */ #define TRX_SYS_PAGE_NO FSP_TRX_SYS_PAGE_NO /** Random value to check for corruption of trx_t */ static const ulint TRX_MAGIC_N = 91118598; constexpr uint innodb_purge_threads_MAX= 32; /** Transaction execution states when trx->state == TRX_STATE_ACTIVE */ enum trx_que_t { TRX_QUE_RUNNING, /*!< transaction is running */ TRX_QUE_LOCK_WAIT, /*!< transaction is waiting for a lock */ TRX_QUE_ROLLING_BACK, /*!< transaction is rolling back */ TRX_QUE_COMMITTING /*!< transaction is committing */ }; /** Transaction states (trx_t::state) */ enum trx_state_t { TRX_STATE_NOT_STARTED, TRX_STATE_ACTIVE, /** XA PREPARE has been executed; only XA COMMIT or XA ROLLBACK are possible */ TRX_STATE_PREPARED, /** XA PREPARE transaction that was returned to ha_recover() */ TRX_STATE_PREPARED_RECOVERED, TRX_STATE_COMMITTED_IN_MEMORY }; /** Type of data dictionary operation */ enum trx_dict_op_t { /** The transaction is not modifying the data dictionary. */ TRX_DICT_OP_NONE = 0, /** The transaction is creating a table or an index, or dropping a table. The table must be dropped in crash recovery. This and TRX_DICT_OP_NONE are the only possible operation modes in crash recovery. */ TRX_DICT_OP_TABLE = 1, /** The transaction is creating or dropping an index in an existing table. In crash recovery, the data dictionary must be locked, but the table must not be dropped. */ TRX_DICT_OP_INDEX = 2 }; /** Memory objects */ /* @{ */ /** Transaction */ struct trx_t; /** The locks and state of an active transaction */ struct trx_lock_t; /** Signal */ struct trx_sig_t; /** Rollback segment */ struct trx_rseg_t; /** Transaction undo log */ struct trx_undo_t; /** Rollback command node in a query graph */ struct roll_node_t; /** Commit command node in a query graph */ struct commit_node_t; /** SAVEPOINT command node in a query graph */ struct trx_named_savept_t; /* @} */ /** Row identifier (DB_ROW_ID, DATA_ROW_ID) */ typedef ib_id_t row_id_t; /** Transaction identifier (DB_TRX_ID, DATA_TRX_ID) */ typedef ib_id_t trx_id_t; /** Rollback pointer (DB_ROLL_PTR, DATA_ROLL_PTR) */ typedef ib_id_t roll_ptr_t; /** Undo number */ typedef ib_id_t undo_no_t; /** Transaction savepoint */ struct trx_savept_t{ undo_no_t least_undo_no; /*!< least undo number to undo */ }; /** File objects */ /* @{ */ /** Undo segment header */ typedef byte trx_usegf_t; /** Undo log header */ typedef byte trx_ulogf_t; /** Undo log page header */ typedef byte trx_upagef_t; /** Undo log record */ typedef byte trx_undo_rec_t; /* @} */ typedef ib_mutex_t RsegMutex; typedef ib_mutex_t PQMutex; typedef ib_mutex_t TrxSysMutex; typedef std::vector > trx_ids_t; #endif /* trx0types_h */