mirror of
https://github.com/MariaDB/server.git
synced 2025-01-20 14:02:32 +01:00
d0e8003b2f
The followin mysql-tests failed (and they are known to fail): main.information_schema [ fail ] main.innodb_file_per_table_basic[ fail ] main.type_bit_innodb [ fail ] Tested against : MYSQL_SERVER_VERSION "5.1.28"
312 lines
11 KiB
C
312 lines
11 KiB
C
/******************************************************
|
|
Transaction rollback
|
|
|
|
(c) 1996 Innobase Oy
|
|
|
|
Created 3/26/1996 Heikki Tuuri
|
|
*******************************************************/
|
|
|
|
#ifndef trx0roll_h
|
|
#define trx0roll_h
|
|
|
|
#include "univ.i"
|
|
#include "trx0trx.h"
|
|
#include "trx0types.h"
|
|
#include "mtr0mtr.h"
|
|
#include "trx0sys.h"
|
|
|
|
/***********************************************************************
|
|
Determines if this transaction is rolling back an incomplete transaction
|
|
in crash recovery. */
|
|
UNIV_INTERN
|
|
ibool
|
|
trx_is_recv(
|
|
/*========*/
|
|
/* out: TRUE if trx is an incomplete
|
|
transaction that is being rolled back
|
|
in crash recovery */
|
|
const trx_t* trx); /* in: transaction */
|
|
/***********************************************************************
|
|
Returns a transaction savepoint taken at this point in time. */
|
|
UNIV_INTERN
|
|
trx_savept_t
|
|
trx_savept_take(
|
|
/*============*/
|
|
/* out: savepoint */
|
|
trx_t* trx); /* in: transaction */
|
|
/***********************************************************************
|
|
Creates an undo number array. */
|
|
UNIV_INTERN
|
|
trx_undo_arr_t*
|
|
trx_undo_arr_create(void);
|
|
/*=====================*/
|
|
/***********************************************************************
|
|
Frees an undo number array. */
|
|
UNIV_INTERN
|
|
void
|
|
trx_undo_arr_free(
|
|
/*==============*/
|
|
trx_undo_arr_t* arr); /* in: undo number array */
|
|
/***********************************************************************
|
|
Returns pointer to nth element in an undo number array. */
|
|
UNIV_INLINE
|
|
trx_undo_inf_t*
|
|
trx_undo_arr_get_nth_info(
|
|
/*======================*/
|
|
/* out: pointer to the nth element */
|
|
trx_undo_arr_t* arr, /* in: undo number array */
|
|
ulint n); /* in: position */
|
|
/***************************************************************************
|
|
Tries truncate the undo logs. */
|
|
UNIV_INTERN
|
|
void
|
|
trx_roll_try_truncate(
|
|
/*==================*/
|
|
trx_t* trx); /* in: transaction */
|
|
/************************************************************************
|
|
Pops the topmost record when the two undo logs of a transaction are seen
|
|
as a single stack of records ordered by their undo numbers. Inserts the
|
|
undo number of the popped undo record to the array of currently processed
|
|
undo numbers in the transaction. When the query thread finishes processing
|
|
of this undo record, it must be released with trx_undo_rec_release. */
|
|
UNIV_INTERN
|
|
trx_undo_rec_t*
|
|
trx_roll_pop_top_rec_of_trx(
|
|
/*========================*/
|
|
/* out: undo log record copied to heap, NULL
|
|
if none left, or if the undo number of the
|
|
top record would be less than the limit */
|
|
trx_t* trx, /* in: transaction */
|
|
dulint limit, /* in: least undo number we need */
|
|
dulint* roll_ptr,/* out: roll pointer to undo record */
|
|
mem_heap_t* heap); /* in: memory heap where copied */
|
|
/************************************************************************
|
|
Reserves an undo log record for a query thread to undo. This should be
|
|
called if the query thread gets the undo log record not using the pop
|
|
function above. */
|
|
UNIV_INTERN
|
|
ibool
|
|
trx_undo_rec_reserve(
|
|
/*=================*/
|
|
/* out: TRUE if succeeded */
|
|
trx_t* trx, /* in: transaction */
|
|
dulint undo_no);/* in: undo number of the record */
|
|
/***********************************************************************
|
|
Releases a reserved undo record. */
|
|
UNIV_INTERN
|
|
void
|
|
trx_undo_rec_release(
|
|
/*=================*/
|
|
trx_t* trx, /* in: transaction */
|
|
dulint undo_no);/* in: undo number */
|
|
/*************************************************************************
|
|
Starts a rollback operation. */
|
|
UNIV_INTERN
|
|
void
|
|
trx_rollback(
|
|
/*=========*/
|
|
trx_t* trx, /* in: transaction */
|
|
trx_sig_t* sig, /* in: signal starting the rollback */
|
|
que_thr_t** next_thr);/* in/out: next query thread to run;
|
|
if the value which is passed in is
|
|
a pointer to a NULL pointer, then the
|
|
calling function can start running
|
|
a new query thread */
|
|
/***********************************************************************
|
|
Rollback or clean up any incomplete transactions which were
|
|
encountered in crash recovery. If the transaction already was
|
|
committed, then we clean up a possible insert undo log. If the
|
|
transaction was not yet committed, then we roll it back.
|
|
Note: this is done in a background thread. */
|
|
UNIV_INTERN
|
|
os_thread_ret_t
|
|
trx_rollback_or_clean_all_recovered(
|
|
/*================================*/
|
|
/* out: a dummy parameter */
|
|
void* arg __attribute__((unused)));
|
|
/* in: a dummy parameter required by
|
|
os_thread_create */
|
|
/********************************************************************
|
|
Finishes a transaction rollback. */
|
|
UNIV_INTERN
|
|
void
|
|
trx_finish_rollback_off_kernel(
|
|
/*===========================*/
|
|
que_t* graph, /* in: undo graph which can now be freed */
|
|
trx_t* trx, /* in: transaction */
|
|
que_thr_t** next_thr);/* in/out: next query thread to run;
|
|
if the value which is passed in is
|
|
a pointer to a NULL pointer, then the
|
|
calling function can start running
|
|
a new query thread; if this parameter is
|
|
NULL, it is ignored */
|
|
/********************************************************************
|
|
Builds an undo 'query' graph for a transaction. The actual rollback is
|
|
performed by executing this query graph like a query subprocedure call.
|
|
The reply about the completion of the rollback will be sent by this
|
|
graph. */
|
|
UNIV_INTERN
|
|
que_t*
|
|
trx_roll_graph_build(
|
|
/*=================*/
|
|
/* out, own: the query graph */
|
|
trx_t* trx); /* in: trx handle */
|
|
/*************************************************************************
|
|
Creates a rollback command node struct. */
|
|
UNIV_INTERN
|
|
roll_node_t*
|
|
roll_node_create(
|
|
/*=============*/
|
|
/* out, own: rollback node struct */
|
|
mem_heap_t* heap); /* in: mem heap where created */
|
|
/***************************************************************
|
|
Performs an execution step for a rollback command node in a query graph. */
|
|
UNIV_INTERN
|
|
que_thr_t*
|
|
trx_rollback_step(
|
|
/*==============*/
|
|
/* out: query thread to run next, or NULL */
|
|
que_thr_t* thr); /* in: query thread */
|
|
/***********************************************************************
|
|
Rollback a transaction used in MySQL. */
|
|
UNIV_INTERN
|
|
int
|
|
trx_rollback_for_mysql(
|
|
/*===================*/
|
|
/* out: error code or DB_SUCCESS */
|
|
trx_t* trx); /* in: transaction handle */
|
|
/***********************************************************************
|
|
Rollback the latest SQL statement for MySQL. */
|
|
UNIV_INTERN
|
|
int
|
|
trx_rollback_last_sql_stat_for_mysql(
|
|
/*=================================*/
|
|
/* out: error code or DB_SUCCESS */
|
|
trx_t* trx); /* in: transaction handle */
|
|
/***********************************************************************
|
|
Rollback a transaction used in MySQL. */
|
|
UNIV_INTERN
|
|
int
|
|
trx_general_rollback_for_mysql(
|
|
/*===========================*/
|
|
/* out: error code or DB_SUCCESS */
|
|
trx_t* trx, /* in: transaction handle */
|
|
ibool partial,/* in: TRUE if partial rollback requested */
|
|
trx_savept_t* savept);/* in: pointer to savepoint undo number, if
|
|
partial rollback requested */
|
|
/***********************************************************************
|
|
Rolls back a transaction back to a named savepoint. Modifications after the
|
|
savepoint are undone but InnoDB does NOT release the corresponding locks
|
|
which are stored in memory. If a lock is 'implicit', that is, a new inserted
|
|
row holds a lock where the lock information is carried by the trx id stored in
|
|
the row, these locks are naturally released in the rollback. Savepoints which
|
|
were set after this savepoint are deleted. */
|
|
UNIV_INTERN
|
|
ulint
|
|
trx_rollback_to_savepoint_for_mysql(
|
|
/*================================*/
|
|
/* out: if no savepoint
|
|
of the name found then
|
|
DB_NO_SAVEPOINT,
|
|
otherwise DB_SUCCESS */
|
|
trx_t* trx, /* in: transaction handle */
|
|
const char* savepoint_name, /* in: savepoint name */
|
|
ib_int64_t* mysql_binlog_cache_pos);/* out: the MySQL binlog cache
|
|
position corresponding to this
|
|
savepoint; MySQL needs this
|
|
information to remove the
|
|
binlog entries of the queries
|
|
executed after the savepoint */
|
|
/***********************************************************************
|
|
Creates a named savepoint. If the transaction is not yet started, starts it.
|
|
If there is already a savepoint of the same name, this call erases that old
|
|
savepoint and replaces it with a new. Savepoints are deleted in a transaction
|
|
commit or rollback. */
|
|
UNIV_INTERN
|
|
ulint
|
|
trx_savepoint_for_mysql(
|
|
/*====================*/
|
|
/* out: always DB_SUCCESS */
|
|
trx_t* trx, /* in: transaction handle */
|
|
const char* savepoint_name, /* in: savepoint name */
|
|
ib_int64_t binlog_cache_pos); /* in: MySQL binlog cache
|
|
position corresponding to this
|
|
connection at the time of the
|
|
savepoint */
|
|
|
|
/***********************************************************************
|
|
Releases a named savepoint. Savepoints which
|
|
were set after this savepoint are deleted. */
|
|
UNIV_INTERN
|
|
ulint
|
|
trx_release_savepoint_for_mysql(
|
|
/*============================*/
|
|
/* out: if no savepoint
|
|
of the name found then
|
|
DB_NO_SAVEPOINT,
|
|
otherwise DB_SUCCESS */
|
|
trx_t* trx, /* in: transaction handle */
|
|
const char* savepoint_name); /* in: savepoint name */
|
|
|
|
/***********************************************************************
|
|
Frees savepoint structs. */
|
|
UNIV_INTERN
|
|
void
|
|
trx_roll_savepoints_free(
|
|
/*=====================*/
|
|
trx_t* trx, /* in: transaction handle */
|
|
trx_named_savept_t* savep); /* in: free all savepoints > this one;
|
|
if this is NULL, free all savepoints
|
|
of trx */
|
|
|
|
/* A cell in the array used during a rollback and a purge */
|
|
struct trx_undo_inf_struct{
|
|
dulint trx_no; /* transaction number: not defined during
|
|
a rollback */
|
|
dulint undo_no; /* undo number of an undo record */
|
|
ibool in_use; /* TRUE if the cell is in use */
|
|
};
|
|
|
|
/* During a rollback and a purge, undo numbers of undo records currently being
|
|
processed are stored in this array */
|
|
|
|
struct trx_undo_arr_struct{
|
|
ulint n_cells; /* number of cells in the array */
|
|
ulint n_used; /* number of cells currently in use */
|
|
trx_undo_inf_t* infos; /* the array of undo infos */
|
|
mem_heap_t* heap; /* memory heap from which allocated */
|
|
};
|
|
|
|
/* Rollback command node in a query graph */
|
|
struct roll_node_struct{
|
|
que_common_t common; /* node type: QUE_NODE_ROLLBACK */
|
|
ulint state; /* node execution state */
|
|
ibool partial;/* TRUE if we want a partial rollback */
|
|
trx_savept_t savept; /* savepoint to which to roll back, in the
|
|
case of a partial rollback */
|
|
};
|
|
|
|
/* A savepoint set with SQL's "SAVEPOINT savepoint_id" command */
|
|
struct trx_named_savept_struct{
|
|
char* name; /* savepoint name */
|
|
trx_savept_t savept; /* the undo number corresponding to
|
|
the savepoint */
|
|
ib_int64_t mysql_binlog_cache_pos;
|
|
/* the MySQL binlog cache position
|
|
corresponding to this savepoint, not
|
|
defined if the MySQL binlogging is not
|
|
enabled */
|
|
UT_LIST_NODE_T(trx_named_savept_t)
|
|
trx_savepoints; /* the list of savepoints of a
|
|
transaction */
|
|
};
|
|
|
|
/* Rollback node states */
|
|
#define ROLL_NODE_SEND 1
|
|
#define ROLL_NODE_WAIT 2
|
|
|
|
#ifndef UNIV_NONINL
|
|
#include "trx0roll.ic"
|
|
#endif
|
|
|
|
#endif
|