File log_append.cpp¶

FileList > cubrid > src > transaction > log_append.cpp

#include "log_append.hpp"
#include "file_manager.h"
#include "log_compress.h"
#include "log_impl.h"
#include "log_manager.h"
#include "log_record.hpp"
#include "page_buffer.h"
#include "perf_monitor.h"
#include "thread_entry.hpp"
#include "thread_manager.hpp"
#include "vacuum.h"
#include "memory_wrapper.hpp"

Public Attributes¶

Type	Name
int	log_Zip_min_size_to_compress = `255`
bool	log_Zip_support = `[false](broker__monitor_8c.md#function-timeout)`

Public Functions¶

Type	Name
char *	LOG_APPEND_PTR ()
size_t	LOG_PRIOR_LSA_LAST_APPEND_OFFSET ()
void	LOG_RESET_APPEND_LSA (const LOG_LSA * lsa)
void	LOG_RESET_PREV_LSA (const LOG_LSA * lsa)
void	log_append_final_zip ()
LOG_ZIP *	log_append_get_zip_redo (THREAD_ENTRY * thread_p)
LOG_ZIP *	log_append_get_zip_undo (THREAD_ENTRY * thread_p)
void	log_append_init_zip ()
bool	log_prior_has_worker_log_records (THREAD_ENTRY * thread_p)
bool	prior_is_tde_encrypted (const log_prior_node * node)
LOG_PRIOR_NODE *	prior_lsa_alloc_and_copy_crumbs (THREAD_ENTRY * thread_p, LOG_RECTYPE rec_type, LOG_RCVINDEX rcvindex, LOG_DATA_ADDR * addr, const int num_ucrumbs, const LOG_CRUMB * ucrumbs, const int num_rcrumbs, const LOG_CRUMB * rcrumbs)
LOG_PRIOR_NODE *	prior_lsa_alloc_and_copy_data (THREAD_ENTRY * thread_p, LOG_RECTYPE rec_type, LOG_RCVINDEX rcvindex, LOG_DATA_ADDR * addr, int ulength, const char * udata, int rlength, const char * rdata)
LOG_LSA	prior_lsa_next_record (THREAD_ENTRY * thread_p, LOG_PRIOR_NODE * node, log_tdes * tdes)
LOG_LSA	prior_lsa_next_record_with_lock (THREAD_ENTRY * thread_p, LOG_PRIOR_NODE * node, log_tdes * tdes)
int	prior_set_tde_encrypted (log_prior_node * node, LOG_RCVINDEX recvindex)

Public Static Functions¶

Type	Name
char *	log_append_get_data_ptr (THREAD_ENTRY * thread_p)
bool	log_append_realloc_data_ptr (THREAD_ENTRY * thread_p, int length)
void	log_prior_lsa_append_add_align (size_t add)
void	log_prior_lsa_append_advance_when_doesnot_fit (size_t length)
void	log_prior_lsa_append_align ()
void	prior_lsa_append_data (int length)
int	prior_lsa_copy_redo_crumbs_to_node (LOG_PRIOR_NODE * node, int num_crumbs, const LOG_CRUMB * crumbs)
int	prior_lsa_copy_redo_data_to_node (LOG_PRIOR_NODE * node, int length, const char * data)
int	prior_lsa_copy_undo_crumbs_to_node (LOG_PRIOR_NODE * node, int num_crumbs, const LOG_CRUMB * crumbs)
int	prior_lsa_copy_undo_data_to_node (LOG_PRIOR_NODE * node, int length, const char * data)
void	prior_lsa_end_append (THREAD_ENTRY * thread_p, LOG_PRIOR_NODE * node)
int	prior_lsa_gen_2pc_prepare_record (THREAD_ENTRY * thread_p, LOG_PRIOR_NODE * node, int gtran_length, const char * gtran_data, int lock_length, const char * lock_data)
int	prior_lsa_gen_dbout_redo_record (THREAD_ENTRY * thread_p, LOG_PRIOR_NODE * node, LOG_RCVINDEX rcvindex, int length, const char * data)
int	prior_lsa_gen_end_chkpt_record (THREAD_ENTRY * thread_p, LOG_PRIOR_NODE * node, int tran_length, const char * tran_data, int topop_length, const char * topop_data)
int	prior_lsa_gen_postpone_record (THREAD_ENTRY * thread_p, LOG_PRIOR_NODE * node, LOG_RCVINDEX rcvindex, LOG_DATA_ADDR * addr, int length, const char * data)
int	prior_lsa_gen_record (THREAD_ENTRY * thread_p, LOG_PRIOR_NODE * node, LOG_RECTYPE rec_type, int length, const char * data)
int	prior_lsa_gen_undoredo_record_from_crumbs (THREAD_ENTRY * thread_p, LOG_PRIOR_NODE * node, LOG_RCVINDEX rcvindex, LOG_DATA_ADDR * addr, int num_ucrumbs, const LOG_CRUMB * ucrumbs, int num_rcrumbs, const LOG_CRUMB * rcrumbs)
LOG_LSA	prior_lsa_next_record_internal (THREAD_ENTRY * thread_p, LOG_PRIOR_NODE * node, LOG_TDES * tdes, int with_lock)
void	prior_lsa_start_append (THREAD_ENTRY * thread_p, LOG_PRIOR_NODE * node, LOG_TDES * tdes)
void	prior_update_header_mvcc_info (const LOG_LSA & record_lsa, MVCCID mvccid)

Public Attributes Documentation¶

variable log_Zip_min_size_to_compress¶

int log_Zip_min_size_to_compress;

variable log_Zip_support¶

bool log_Zip_support;

Public Functions Documentation¶

function LOG_APPEND_PTR¶

char * LOG_APPEND_PTR ()

function LOG_PRIOR_LSA_LAST_APPEND_OFFSET¶

size_t LOG_PRIOR_LSA_LAST_APPEND_OFFSET ()

function LOG_RESET_APPEND_LSA¶

void LOG_RESET_APPEND_LSA (
    const  LOG_LSA * lsa
)

function LOG_RESET_PREV_LSA¶

void LOG_RESET_PREV_LSA (
    const  LOG_LSA * lsa
)

function log_append_final_zip¶

void log_append_final_zip ()

function log_append_get_zip_redo¶

LOG_ZIP * log_append_get_zip_redo (
    THREAD_ENTRY * thread_p
)

function log_append_get_zip_undo¶

LOG_ZIP * log_append_get_zip_undo (
    THREAD_ENTRY * thread_p
)

function log_append_init_zip¶

void log_append_init_zip ()

function log_prior_has_worker_log_records¶

bool log_prior_has_worker_log_records (
    THREAD_ENTRY * thread_p
)

function prior_is_tde_encrypted¶

bool prior_is_tde_encrypted (
    const  log_prior_node * node
)

function prior_lsa_alloc_and_copy_crumbs¶

LOG_PRIOR_NODE * prior_lsa_alloc_and_copy_crumbs (
    THREAD_ENTRY * thread_p,
    LOG_RECTYPE rec_type,
    LOG_RCVINDEX rcvindex,
    LOG_DATA_ADDR * addr,
    const  int num_ucrumbs,
    const  LOG_CRUMB * ucrumbs,
    const  int num_rcrumbs,
    const  LOG_CRUMB * rcrumbs
)

function prior_lsa_alloc_and_copy_data¶

LOG_PRIOR_NODE * prior_lsa_alloc_and_copy_data (
    THREAD_ENTRY * thread_p,
    LOG_RECTYPE rec_type,
    LOG_RCVINDEX rcvindex,
    LOG_DATA_ADDR * addr,
    int ulength,
    const  char * udata,
    int rlength,
    const  char * rdata
)

function prior_lsa_next_record¶

LOG_LSA prior_lsa_next_record (
    THREAD_ENTRY * thread_p,
    LOG_PRIOR_NODE * node,
    log_tdes * tdes
)

function prior_lsa_next_record_with_lock¶

LOG_LSA prior_lsa_next_record_with_lock (
    THREAD_ENTRY * thread_p,
    LOG_PRIOR_NODE * node,
    log_tdes * tdes
)

function prior_set_tde_encrypted¶

int prior_set_tde_encrypted (
    log_prior_node * node,
    LOG_RCVINDEX recvindex
)

Public Static Functions Documentation¶

function log_append_get_data_ptr¶

static char * log_append_get_data_ptr (
    THREAD_ENTRY * thread_p
)

function log_append_realloc_data_ptr¶

static bool log_append_realloc_data_ptr (
    THREAD_ENTRY * thread_p,
    int length
)

function log_prior_lsa_append_add_align¶

static void log_prior_lsa_append_add_align (
    size_t add
)

function log_prior_lsa_append_advance_when_doesnot_fit¶

static void log_prior_lsa_append_advance_when_doesnot_fit (
    size_t length
)

function log_prior_lsa_append_align¶

static void log_prior_lsa_append_align ()

function prior_lsa_append_data¶

static void prior_lsa_append_data (
    int length
)

function prior_lsa_copy_redo_crumbs_to_node¶

static int prior_lsa_copy_redo_crumbs_to_node (
    LOG_PRIOR_NODE * node,
    int num_crumbs,
    const  LOG_CRUMB * crumbs
)

function prior_lsa_copy_redo_data_to_node¶

static int prior_lsa_copy_redo_data_to_node (
    LOG_PRIOR_NODE * node,
    int length,
    const  char * data
)

function prior_lsa_copy_undo_crumbs_to_node¶

static int prior_lsa_copy_undo_crumbs_to_node (
    LOG_PRIOR_NODE * node,
    int num_crumbs,
    const  LOG_CRUMB * crumbs
)

function prior_lsa_copy_undo_data_to_node¶

static int prior_lsa_copy_undo_data_to_node (
    LOG_PRIOR_NODE * node,
    int length,
    const  char * data
)

function prior_lsa_end_append¶

static void prior_lsa_end_append (
    THREAD_ENTRY * thread_p,
    LOG_PRIOR_NODE * node
)

function prior_lsa_gen_2pc_prepare_record¶

static int prior_lsa_gen_2pc_prepare_record (
    THREAD_ENTRY * thread_p,
    LOG_PRIOR_NODE * node,
    int gtran_length,
    const  char * gtran_data,
    int lock_length,
    const  char * lock_data
)

function prior_lsa_gen_dbout_redo_record¶

static int prior_lsa_gen_dbout_redo_record (
    THREAD_ENTRY * thread_p,
    LOG_PRIOR_NODE * node,
    LOG_RCVINDEX rcvindex,
    int length,
    const  char * data
)

function prior_lsa_gen_end_chkpt_record¶

static int prior_lsa_gen_end_chkpt_record (
    THREAD_ENTRY * thread_p,
    LOG_PRIOR_NODE * node,
    int tran_length,
    const  char * tran_data,
    int topop_length,
    const  char * topop_data
)

function prior_lsa_gen_postpone_record¶

static int prior_lsa_gen_postpone_record (
    THREAD_ENTRY * thread_p,
    LOG_PRIOR_NODE * node,
    LOG_RCVINDEX rcvindex,
    LOG_DATA_ADDR * addr,
    int length,
    const  char * data
)

function prior_lsa_gen_record¶

static int prior_lsa_gen_record (
    THREAD_ENTRY * thread_p,
    LOG_PRIOR_NODE * node,
    LOG_RECTYPE rec_type,
    int length,
    const  char * data
)

function prior_lsa_gen_undoredo_record_from_crumbs¶

static int prior_lsa_gen_undoredo_record_from_crumbs (
    THREAD_ENTRY * thread_p,
    LOG_PRIOR_NODE * node,
    LOG_RCVINDEX rcvindex,
    LOG_DATA_ADDR * addr,
    int num_ucrumbs,
    const  LOG_CRUMB * ucrumbs,
    int num_rcrumbs,
    const  LOG_CRUMB * rcrumbs
)

function prior_lsa_next_record_internal¶

static LOG_LSA prior_lsa_next_record_internal (
    THREAD_ENTRY * thread_p,
    LOG_PRIOR_NODE * node,
    LOG_TDES * tdes,
    int with_lock
)

function prior_lsa_start_append¶

static void prior_lsa_start_append (
    THREAD_ENTRY * thread_p,
    LOG_PRIOR_NODE * node,
    LOG_TDES * tdes
)

function prior_update_header_mvcc_info¶

static void prior_update_header_mvcc_info (
    const  LOG_LSA & record_lsa,
    MVCCID mvccid
)

The documentation for this class was generated from the following file cubrid/src/transaction/log_append.cpp