trx0sys.h

Go to the documentation of this file.

/*****************************************************************************

Copyright (c) 1996, 2012, Oracle and/or its affiliates. All Rights Reserved.

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, Suite 500, Boston, MA 02110-1335 USA

*****************************************************************************/

/**************************************************/
#ifndef trx0sys_h
#define trx0sys_h

#include "univ.i"

#include "trx0types.h"
#include "fsp0types.h"
#include "fil0fil.h"
#include "buf0buf.h"
#ifndef UNIV_HOTBACKUP
#include "mtr0mtr.h"
#include "ut0byte.h"
#include "mem0mem.h"
#include "sync0sync.h"
#include "ut0lst.h"
#include "ut0bh.h"
#include "read0types.h"
#include "page0types.h"
#include "ut0bh.h"

typedef UT_LIST_BASE_NODE_T(trx_t) trx_list_t;

/* @{ */
extern char             trx_sys_mysql_master_log_name[];
extern ib_int64_t       trx_sys_mysql_master_log_pos;
/* @} */

/* @{ */
extern char             trx_sys_mysql_bin_log_name[];
extern ib_int64_t       trx_sys_mysql_bin_log_pos;
/* @} */

extern trx_sys_t*       trx_sys;

/***************************************************************/
UNIV_INLINE
ibool
trx_sys_hdr_page(
/*=============*/
        ulint   space,  
        ulint   page_no);
/*****************************************************************/
UNIV_INTERN
ib_bh_t*
trx_sys_init_at_db_start(void);
/*==========================*/
/*****************************************************************/
UNIV_INTERN
void
trx_sys_create(void);
/*================*/
/*****************************************************************/
UNIV_INTERN
void
trx_sys_create_sys_pages(void);
/*==========================*/
/****************************************************************/
UNIV_INTERN
ulint
trx_sysf_rseg_find_free(
/*====================*/
        mtr_t*          mtr);           
/***************************************************************/
UNIV_INLINE
trx_rseg_t*
trx_sys_get_nth_rseg(
/*=================*/
        trx_sys_t*      sys,    
        ulint           n);     
/**********************************************************************/
UNIV_INLINE
trx_sysf_t*
trx_sysf_get(
/*=========*/
        mtr_t*  mtr);   
/*****************************************************************/
UNIV_INLINE
ulint
trx_sysf_rseg_get_space(
/*====================*/
        trx_sysf_t*     sys_header,     
        ulint           i,              
        mtr_t*          mtr);           
/*****************************************************************/
UNIV_INLINE
ulint
trx_sysf_rseg_get_page_no(
/*======================*/
        trx_sysf_t*     sys_header,     
        ulint           i,              
        mtr_t*          mtr);           
/*****************************************************************/
UNIV_INLINE
void
trx_sysf_rseg_set_space(
/*====================*/
        trx_sysf_t*     sys_header,     
        ulint           i,              
        ulint           space,          
        mtr_t*          mtr);           
/*****************************************************************/
UNIV_INLINE
void
trx_sysf_rseg_set_page_no(
/*======================*/
        trx_sysf_t*     sys_header,     
        ulint           i,              
        ulint           page_no,        
        mtr_t*          mtr);           
/*****************************************************************/
UNIV_INLINE
trx_id_t
trx_sys_get_new_trx_id(void);
/*========================*/
/*****************************************************************/
UNIV_INLINE
trx_id_t
trx_sys_get_max_trx_id(void);
/*========================*/

#ifdef UNIV_DEBUG
/* Flag to control TRX_RSEG_N_SLOTS behavior debugging. */
extern uint                     trx_rseg_n_slots_debug;
#endif

/*****************************************************************/
UNIV_INLINE
void
trx_write_trx_id(
/*=============*/
        byte*           ptr,    
        trx_id_t        id);    
/*****************************************************************/
UNIV_INLINE
trx_id_t
trx_read_trx_id(
/*============*/
        const byte*     ptr);   
/****************************************************************/
UNIV_INLINE
trx_t*
trx_get_rw_trx_by_id(
/*=================*/
        trx_id_t        trx_id);
/****************************************************************/
UNIV_INLINE
trx_id_t
trx_rw_min_trx_id(void);
/*===================*/
/****************************************************************/
UNIV_INLINE
trx_t*
trx_rw_is_active_low(
/*=================*/
        trx_id_t        trx_id,         
        ibool*          corrupt);       
/****************************************************************/
UNIV_INLINE
trx_t*
trx_rw_is_active(
/*=============*/
        trx_id_t        trx_id,         
        ibool*          corrupt);       
#ifdef UNIV_DEBUG
/****************************************************************/
UNIV_INTERN
ibool
trx_in_trx_list(
/*============*/
        const trx_t*    in_trx)         
        __attribute__((nonnull, warn_unused_result));
#endif /* UNIV_DEBUG */
#if defined UNIV_DEBUG || defined UNIV_BLOB_LIGHT_DEBUG
/***********************************************************/
UNIV_INLINE
ibool
trx_assert_recovered(
/*=================*/
        trx_id_t        trx_id)         
        __attribute__((warn_unused_result));
#endif /* UNIV_DEBUG || UNIV_BLOB_LIGHT_DEBUG */
/*****************************************************************/
UNIV_INTERN
void
trx_sys_update_mysql_binlog_offset(
/*===============================*/
        const char*     file_name,
        ib_int64_t      offset, 
        ulint           field,  
        mtr_t*          mtr);   
/*****************************************************************/
UNIV_INTERN
void
trx_sys_print_mysql_binlog_offset(void);
/*===================================*/
/*****************************************************************/
UNIV_INTERN
void
trx_sys_print_mysql_master_log_pos(void);
/*====================================*/
/*****************************************************************/
UNIV_INTERN
void
trx_sys_file_format_init(void);
/*==========================*/
/*****************************************************************/
UNIV_INTERN
void
trx_sys_file_format_close(void);
/*===========================*/
/********************************************************************/
UNIV_INTERN
void
trx_sys_file_format_tag_init(void);
/*==============================*/
/*****************************************************************/
UNIV_INTERN
void
trx_sys_close(void);
/*===============*/
/*****************************************************************/
UNIV_INTERN
const char*
trx_sys_file_format_id_to_name(
/*===========================*/
        const ulint     id);            
/*****************************************************************/
UNIV_INTERN
ibool
trx_sys_file_format_max_set(
/*========================*/
        ulint           format_id,      
        const char**    name);          
/*********************************************************************
Creates the rollback segments
@return number of rollback segments that are active. */
UNIV_INTERN
ulint
trx_sys_create_rsegs(
/*=================*/
        ulint   n_spaces,       
        ulint   n_rsegs);       
/*****************************************************************/
UNIV_INLINE
ulint
trx_sys_get_n_rw_trx(void);
/*======================*/

/*********************************************************************
Check if there are any active (non-prepared) transactions.
@return total number of active transactions or 0 if none */
UNIV_INTERN
ulint
trx_sys_any_active_transactions(void);
/*=================================*/
#else /* !UNIV_HOTBACKUP */
/*****************************************************************/
UNIV_INTERN
void
trx_sys_print_mysql_binlog_offset_from_page(
/*========================================*/
        const byte*     page);  
/*****************************************************************/
UNIV_INTERN
ibool
trx_sys_read_file_format_id(
/*========================*/
        const char *pathname,   
        ulint *format_id);      
/*****************************************************************/
UNIV_INTERN
ibool
trx_sys_read_pertable_file_format_id(
/*=================================*/
        const char *pathname,   
        ulint *format_id);      
#endif /* !UNIV_HOTBACKUP */
/*****************************************************************/
UNIV_INTERN
const char*
trx_sys_file_format_max_get(void);
/*=============================*/
/*****************************************************************/
UNIV_INTERN
dberr_t
trx_sys_file_format_max_check(
/*==========================*/
        ulint           max_format_id); 
/********************************************************************/
UNIV_INTERN
ibool
trx_sys_file_format_max_upgrade(
/*============================*/
        const char**    name,           
        ulint           format_id);     
/*****************************************************************/
UNIV_INTERN
const char*
trx_sys_file_format_id_to_name(
/*===========================*/
        const ulint     id);    
#ifdef UNIV_DEBUG
/*************************************************************/
UNIV_INTERN
ibool
trx_sys_validate_trx_list(void);
/*===========================*/
#endif /* UNIV_DEBUG */

/* The automatically created system rollback segment has this id */
#define TRX_SYS_SYSTEM_RSEG_ID  0

/* Space id and page no where the trx system file copy resides */
#define TRX_SYS_SPACE   0       /* the SYSTEM tablespace */
#include "fsp0fsp.h"
#define TRX_SYS_PAGE_NO FSP_TRX_SYS_PAGE_NO

/* The offset of the transaction system header on the page */
#define TRX_SYS         FSEG_PAGE_DATA

/*------------------------------------------------------------- @{ */
#define TRX_SYS_TRX_ID_STORE    0       
#define TRX_SYS_FSEG_HEADER     8       
#define TRX_SYS_RSEGS           (8 + FSEG_HEADER_SIZE)

/*------------------------------------------------------------- @} */

/* Max number of rollback segments: the number of segment specification slots
in the transaction system array; rollback segment id must fit in one (signed)
byte, therefore 128; each slot is currently 8 bytes in size. If you want
to raise the level to 256 then you will need to fix some assertions that
impose the 7 bit restriction. e.g., mach_write_to_3() */
#define TRX_SYS_N_RSEGS                 128
/* Originally, InnoDB defined TRX_SYS_N_RSEGS as 256 but created only one
rollback segment.  It initialized some arrays with this number of entries.
We must remember this limit in order to keep file compatibility. */
#define TRX_SYS_OLD_N_RSEGS             256

#define TRX_SYS_MYSQL_LOG_NAME_LEN      512

#define TRX_SYS_MYSQL_LOG_MAGIC_N       873422344

#if UNIV_PAGE_SIZE_MIN < 4096
# error "UNIV_PAGE_SIZE_MIN < 4096"
#endif

#define TRX_SYS_MYSQL_MASTER_LOG_INFO   (UNIV_PAGE_SIZE - 2000)

#define TRX_SYS_MYSQL_LOG_INFO          (UNIV_PAGE_SIZE - 1000)
#define TRX_SYS_MYSQL_LOG_MAGIC_N_FLD   0       
#define TRX_SYS_MYSQL_LOG_OFFSET_HIGH   4       
#define TRX_SYS_MYSQL_LOG_OFFSET_LOW    8       
#define TRX_SYS_MYSQL_LOG_NAME          12      
/* @{ */

#define TRX_SYS_DOUBLEWRITE             (UNIV_PAGE_SIZE - 200)
/*-------------------------------------------------------------*/
#define TRX_SYS_DOUBLEWRITE_FSEG        0       
#define TRX_SYS_DOUBLEWRITE_MAGIC       FSEG_HEADER_SIZE

#define TRX_SYS_DOUBLEWRITE_BLOCK1      (4 + FSEG_HEADER_SIZE)

#define TRX_SYS_DOUBLEWRITE_BLOCK2      (8 + FSEG_HEADER_SIZE)

#define TRX_SYS_DOUBLEWRITE_REPEAT      12      
#define TRX_SYS_DOUBLEWRITE_SPACE_ID_STORED (24 + FSEG_HEADER_SIZE)

/*-------------------------------------------------------------*/
#define TRX_SYS_DOUBLEWRITE_MAGIC_N     536853855

#define TRX_SYS_DOUBLEWRITE_SPACE_ID_STORED_N 1783657386

#define TRX_SYS_DOUBLEWRITE_BLOCK_SIZE  FSP_EXTENT_SIZE
/* @} */

/* @{ */
#define TRX_SYS_FILE_FORMAT_TAG         (UNIV_PAGE_SIZE - 16)

#define TRX_SYS_FILE_FORMAT_TAG_MAGIC_N_LOW     3645922177UL

#define TRX_SYS_FILE_FORMAT_TAG_MAGIC_N_HIGH    2745987765UL

#define TRX_SYS_FILE_FORMAT_TAG_MAGIC_N                                 \
        ((ib_uint64_t) TRX_SYS_FILE_FORMAT_TAG_MAGIC_N_HIGH << 32       \
         | TRX_SYS_FILE_FORMAT_TAG_MAGIC_N_LOW)
/* @} */

#ifndef UNIV_HOTBACKUP

struct trx_sys_t{

        ib_mutex_t              mutex;          
        ulint           n_prepared_trx; 
        ulint           n_prepared_recovered_trx; 
        trx_id_t        max_trx_id;     
#ifdef UNIV_DEBUG
        trx_id_t        rw_max_trx_id;  
#endif
        trx_list_t      rw_trx_list;    
        trx_list_t      ro_trx_list;    
        trx_list_t      mysql_trx_list; 
        trx_rseg_t*     const rseg_array[TRX_SYS_N_RSEGS];
        ulint           rseg_history_len;
        UT_LIST_BASE_NODE_T(read_view_t) view_list;
};

#define TRX_SYS_TRX_ID_WRITE_MARGIN     256
#endif /* !UNIV_HOTBACKUP */

#ifndef UNIV_NONINL
#include "trx0sys.ic"
#endif

#endif