trx0roll.h

Go to the documentation of this file.

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

Copyright (c) 1996, 2014, 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 trx0roll_h
#define trx0roll_h

#include "univ.i"
#include "trx0trx.h"
#include "trx0types.h"
#include "mtr0mtr.h"
#include "trx0sys.h"

extern bool     trx_rollback_or_clean_is_active;

/*******************************************************************/
UNIV_INTERN
ibool
trx_is_recv(
/*========*/
        const trx_t*    trx);   
/*******************************************************************/
UNIV_INTERN
trx_savept_t
trx_savept_take(
/*============*/
        trx_t*  trx);   
/*******************************************************************/
UNIV_INTERN
void
trx_undo_arr_free(
/*==============*/
        trx_undo_arr_t* arr);   
/*******************************************************************/
UNIV_INLINE
trx_undo_inf_t*
trx_undo_arr_get_nth_info(
/*======================*/
        trx_undo_arr_t* arr,    
        ulint           n);     
/********************************************************************/
UNIV_INTERN
trx_undo_rec_t*
trx_roll_pop_top_rec_of_trx(
/*========================*/
        trx_t*          trx,    
        undo_no_t       limit,  
        roll_ptr_t*     roll_ptr,
        mem_heap_t*     heap);  
/********************************************************************/
UNIV_INTERN
ibool
trx_undo_rec_reserve(
/*=================*/
        trx_t*          trx,    
        undo_no_t       undo_no);
/*******************************************************************/
UNIV_INTERN
void
trx_undo_rec_release(
/*=================*/
        trx_t*          trx,    
        undo_no_t       undo_no);
/*******************************************************************/
UNIV_INTERN
void
trx_rollback_or_clean_recovered(
/*============================*/
        ibool   all);   
/*******************************************************************/
extern "C" UNIV_INTERN
os_thread_ret_t
DECLARE_THREAD(trx_rollback_or_clean_all_recovered)(
/*================================================*/
        void*   arg __attribute__((unused)));
/*********************************************************************/
UNIV_INTERN
roll_node_t*
roll_node_create(
/*=============*/
        mem_heap_t*     heap);  
/***********************************************************/
UNIV_INTERN
que_thr_t*
trx_rollback_step(
/*==============*/
        que_thr_t*      thr);   
/*******************************************************************/
UNIV_INTERN
dberr_t
trx_rollback_for_mysql(
/*===================*/
        trx_t*  trx)    
        __attribute__((nonnull));
/*******************************************************************/
UNIV_INTERN
dberr_t
trx_rollback_last_sql_stat_for_mysql(
/*=================================*/
        trx_t*  trx)    
        __attribute__((nonnull));
/*******************************************************************/
UNIV_INTERN
dberr_t
trx_rollback_to_savepoint(
/*======================*/
        trx_t*          trx,    
        trx_savept_t*   savept) 
        __attribute__((nonnull(1)));
/*******************************************************************/
UNIV_INTERN
dberr_t
trx_rollback_to_savepoint_for_mysql(
/*================================*/
        trx_t*          trx,                    
        const char*     savepoint_name,         
        ib_int64_t*     mysql_binlog_cache_pos) 
        __attribute__((nonnull, warn_unused_result));
/*******************************************************************/
UNIV_INTERN
dberr_t
trx_savepoint_for_mysql(
/*====================*/
        trx_t*          trx,                    
        const char*     savepoint_name,         
        ib_int64_t      binlog_cache_pos)       
        __attribute__((nonnull));
/*******************************************************************/
UNIV_INTERN
dberr_t
trx_release_savepoint_for_mysql(
/*============================*/
        trx_t*          trx,                    
        const char*     savepoint_name)         
        __attribute__((nonnull, warn_unused_result));
/*******************************************************************/
UNIV_INTERN
void
trx_roll_savepoints_free(
/*=====================*/
        trx_t*                  trx,    
        trx_named_savept_t*     savep); 
struct  trx_undo_inf_t{
        ibool           in_use; 
        trx_id_t        trx_no; 
        undo_no_t       undo_no;
};

struct trx_undo_arr_t{
        ulint           n_cells;        
        ulint           n_used;         
        trx_undo_inf_t* infos;          
        mem_heap_t*     heap;           
};

enum roll_node_state {
        ROLL_NODE_NONE = 0,             
        ROLL_NODE_SEND,                 
        ROLL_NODE_WAIT                  
};

struct roll_node_t{
        que_common_t            common; 
        enum roll_node_state    state;  
        ibool                   partial;
        trx_savept_t            savept; 
        que_thr_t*              undo_thr;
};

struct trx_named_savept_t{
        char*           name;           
        trx_savept_t    savept;         
        ib_int64_t      mysql_binlog_cache_pos;
        UT_LIST_NODE_T(trx_named_savept_t)
                        trx_savepoints; 
};

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

#endif