File log_manager.h¶

FileList > cubrid > src > transaction > log_manager.h

#include "config.h"
#include "disk_manager.h"
#include "error_manager.h"
#include "file_io.h"
#include "log_comm.h"
#include "log_impl.h"
#include "log_lsa.hpp"
#include "recovery.h"
#include "storage_common.h"
#include "thread_compat.hpp"
#include <time.h>

Classes¶

Type	Name
struct	log_topop_range

Public Types¶

Type	Name
typedef struct log_topop_range	LOG_TOPOP_RANGE

Public Functions¶

Type	Name
void	LOG_CS_DEMOTE (THREAD_ENTRY * thread_p)
void	LOG_CS_ENTER (THREAD_ENTRY * thread_p)
void	LOG_CS_ENTER_READ_MODE (THREAD_ENTRY * thread_p)
void	LOG_CS_EXIT (THREAD_ENTRY * thread_p)
bool	LOG_CS_OWN (THREAD_ENTRY * thread_p)
bool	LOG_CS_OWN_WRITE_MODE (THREAD_ENTRY * thread_p)
void	LOG_CS_PROMOTE (THREAD_ENTRY * thread_p)
int	cdc_cleanup ()
void	cdc_cleanup_consumer ()
void	cdc_daemons_destroy ()
void	cdc_daemons_init ()
int	cdc_finalize ()
int	cdc_find_lsa (THREAD_ENTRY * thread_p, time_t * input_time, LOG_LSA * start_lsa)
int	cdc_free_extraction_filter ()
int	cdc_get_loginfo_metadata (LOG_LSA * lsa, int * length, int * num_log_info)
int	cdc_get_logitem_info (THREAD_ENTRY * thread_p, LOG_LSA * start_lsa, int * total_length, int * num_log_info)
int	cdc_get_recdes (THREAD_ENTRY * thread_p, LOG_LSA * undo_lsa, RECDES * undo_recdes, LOG_LSA * redo_lsa, RECDES * redo_recdes, bool is_flashback)
SCAN_CODE	cdc_get_undo_record (THREAD_ENTRY * thread_p, LOG_PAGE * log_page_p, LOG_LSA lsa, RECDES * undo_recdes)
int	cdc_initialize ()
void	cdc_kill_producer ()
int	cdc_make_dml_loginfo (THREAD_ENTRY * thread_p, int trid, char * user, CDC_DML_TYPE dml_type, OID classoid, RECDES * undo_recdes, RECDES * redo_recdes, CDC_LOGINFO_ENTRY * dml_entry, bool is_flashback)
int	cdc_make_loginfo (THREAD_ENTRY * thread_p, LOG_LSA * start_lsa)
LOG_PAGEID	cdc_min_log_pageid_to_keep ()
void	cdc_pause_consumer ()
void	cdc_pause_producer ()
void	cdc_reinitialize_queue (LOG_LSA * start_lsa)
int	cdc_set_configuration (int max_log_item, int timeout, int all_in_cond, char user, int num_user, uint64_t** * classoids, int num_class)
int	cdc_set_extraction_lsa (LOG_LSA * lsa)
int	cdc_validate_lsa (THREAD_ENTRY * thread_p, LOG_LSA * lsa)
void	cdc_wakeup_consumer ()
void	cdc_wakeup_producer ()
TRAN_STATE	log_abort (THREAD_ENTRY * thread_p, int tran_index)
void	log_abort_all_active_transaction (THREAD_ENTRY * thread_p)
TRAN_STATE	log_abort_local (THREAD_ENTRY * thread_p, LOG_TDES * tdes, bool is_local_tran)
TRAN_STATE	log_abort_partial (THREAD_ENTRY * thread_p, const char * savepoint_name, LOG_LSA * savept_lsa)
int	log_active_log_header_end_scan (THREAD_ENTRY * thread_p, void ** ptr)
SCAN_CODE	log_active_log_header_next_scan (THREAD_ENTRY * thread_p, int cursor, DB_VALUE out_values, int out_cnt, void** * ptr)
int	log_active_log_header_start_scan (THREAD_ENTRY * thread_p, int show_type, DB_VALUE arg_values, int arg_cnt, void ptr)
int	log_add_to_modified_class_list (THREAD_ENTRY * thread_p, const char * classname, const OID * class_oid)
void	log_append_compensate (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, const VPID * vpid, PGLENGTH offset, PAGE_PTR pgptr, int length, const void * data, LOG_TDES * tdes)
void	log_append_compensate_with_undo_nxlsa (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, const VPID * vpid, PGLENGTH offset, PAGE_PTR pgptr, int length, const void * data, LOG_TDES * tdes, const LOG_LSA * undo_nxlsa)
void	log_append_dboutside_redo (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, int length, const void * data)
void	log_append_empty_record (THREAD_ENTRY * thread_p, LOG_RECTYPE logrec_type, LOG_DATA_ADDR * addr)
void	log_append_ha_server_state (THREAD_ENTRY * thread_p, int state)
void	log_append_postpone (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, LOG_DATA_ADDR * addr, int length, const void * data)
void	log_append_redo_crumbs (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, LOG_DATA_ADDR * addr, int num_crumbs, const LOG_CRUMB * crumbs)
void	log_append_redo_data (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, LOG_DATA_ADDR * addr, int length, const void * data)
void	log_append_redo_data2 (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, const VFID * vfid, PAGE_PTR pgptr, PGLENGTH offset, int length, const void * data)
void	log_append_redo_recdes (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, LOG_DATA_ADDR * addr, const RECDES * recdes)
void	log_append_redo_recdes2 (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, const VFID * vfid, PAGE_PTR pgptr, PGLENGTH offset, const RECDES * recdes)
void	log_append_repl_info (THREAD_ENTRY * thread_p, LOG_TDES * tdes, bool is_commit)
void	log_append_run_postpone (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, LOG_DATA_ADDR * addr, const VPID * rcv_vpid, int length, const void * data, const LOG_LSA * ref_lsa)
LOG_LSA *	log_append_savepoint (THREAD_ENTRY * thread_p, const char * savept_name)
void	log_append_supplemental_info (THREAD_ENTRY * thread_p, SUPPLEMENT_REC_TYPE rec_type, int length, const void * data)
int	log_append_supplemental_lsa (THREAD_ENTRY * thread_p, SUPPLEMENT_REC_TYPE rec_type, OID * classoid, LOG_LSA * undo_lsa, LOG_LSA * redo_lsa)
int	log_append_supplemental_serial (THREAD_ENTRY * thread_p, const char * serial_name, int cached_num, OID * classoid, const OID * serial_oid)
int	log_append_supplemental_undo_record (THREAD_ENTRY * thread_p, RECDES * undo_recdes)
void	log_append_undo_crumbs (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, LOG_DATA_ADDR * addr, int num_crumbs, const LOG_CRUMB * crumbs)
void	log_append_undo_data (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, LOG_DATA_ADDR * addr, int length, const void * data)
void	log_append_undo_data2 (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, const VFID * vfid, PAGE_PTR pgptr, PGLENGTH offset, int length, const void * data)
void	log_append_undo_recdes (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, LOG_DATA_ADDR * addr, const RECDES * recdes)
void	log_append_undo_recdes2 (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, const VFID * vfid, PAGE_PTR pgptr, PGLENGTH offset, const RECDES * recdes)
void	log_append_undoredo_crumbs (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, LOG_DATA_ADDR * addr, int num_undo_crumbs, int num_redo_crumbs, const LOG_CRUMB * undo_crumbs, const LOG_CRUMB * redo_crumbs)
void	log_append_undoredo_data (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, LOG_DATA_ADDR * addr, int undo_length, int redo_length, const void * undo_data, const void * redo_data)
void	log_append_undoredo_data2 (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, const VFID * vfid, PAGE_PTR pgptr, PGLENGTH offset, int undo_length, int redo_length, const void * undo_data, const void * redo_data)
void	log_append_undoredo_recdes (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, LOG_DATA_ADDR * addr, const RECDES * undo_recdes, const RECDES * redo_recdes)
void	log_append_undoredo_recdes2 (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, const VFID * vfid, PAGE_PTR pgptr, PGLENGTH offset, const RECDES * undo_recdes, const RECDES * redo_recdes)
int	log_archive_log_header_end_scan (THREAD_ENTRY * thread_p, void ** ptr)
SCAN_CODE	log_archive_log_header_next_scan (THREAD_ENTRY * thread_p, int cursor, DB_VALUE out_values, int out_cnt, void** * ptr)
int	log_archive_log_header_start_scan (THREAD_ENTRY * thread_p, int show_type, DB_VALUE arg_values, int arg_cnt, void ptr)
bool	log_check_system_op_is_started (THREAD_ENTRY * thread_p)
TRAN_STATE	log_commit (THREAD_ENTRY * thread_p, int tran_index, bool retain_lock)
TRAN_STATE	log_commit_local (THREAD_ENTRY * thread_p, LOG_TDES * tdes, bool retain_lock, bool is_local_tran)
TRAN_STATE	log_complete (THREAD_ENTRY * thread_p, LOG_TDES * tdes, LOG_RECTYPE iscommitted, LOG_GETNEWTRID get_newtrid, LOG_WRITE_EOT_LOG wrote_eot_log)
TRAN_STATE	log_complete_for_2pc (THREAD_ENTRY * thread_p, LOG_TDES * tdes, LOG_RECTYPE iscommitted, LOG_GETNEWTRID get_newtrid)
int	log_create (THREAD_ENTRY * thread_p, const char * db_fullname, const char * logpath, const char * prefix_logname, DKNPAGES npages)
void	log_do_postpone (THREAD_ENTRY * thread_p, LOG_TDES * tdes, LOG_LSA * start_posplsa)
int	log_execute_run_postpone (THREAD_ENTRY * thread_p, LOG_LSA * log_lsa, LOG_REC_REDO * redo, char * redo_rcv_data)
void	log_final (THREAD_ENTRY * thread_p)
void	log_flush_daemon_get_stats (UINT64 * statsp)
LOG_LSA *	log_get_append_lsa (void)
int	log_get_charset_from_header_page (THREAD_ENTRY * thread_p, const char * db_fullname, const char * logpath, const char * prefix_logname)
INT64	log_get_clock_msec (void)
LOG_LSA *	log_get_crash_point_lsa (void)
int	log_get_db_start_parameters (INT64 * db_creation, LOG_LSA * chkpt_lsa)
LOG_LSA *	log_get_eof_lsa (void)
PGLENGTH	log_get_io_page_size (THREAD_ENTRY * thread_p, const char * db_fullname, const char * logpath, const char * prefix_logname)
int	log_get_next_nested_top (THREAD_ENTRY * thread_p, LOG_TDES * tdes, LOG_LSA * start_postpone_lsa, LOG_TOPOP_RANGE ** out_nxtop_range_stack)
int	log_get_num_pages_for_creation (int db_npages)
LOG_LSA *	log_get_parent_lsa_system_op (THREAD_ENTRY * thread_p, LOG_LSA * parent_lsa)
LOG_LSA *	log_get_restart_lsa (void)
SCAN_CODE	log_get_undo_record (THREAD_ENTRY * thread_p, LOG_PAGE * log_page_p, LOG_LSA process_lsa, RECDES * recdes)
void	log_initialize (THREAD_ENTRY * thread_p, const char * db_fullname, const char * logpath, const char * prefix_logname, int ismedia_crash, bo_restart_arg * r_args)
bool	log_is_active_log_sane (THREAD_ENTRY * thread_p, const char * db_fullname, const char * logpath, const char * prefix_logname)
bool	log_is_class_being_modified (THREAD_ENTRY * thread_p, const OID * class_oid)
bool	log_is_in_crash_recovery (void)
bool	log_is_in_crash_recovery_and_not_yet_completes_redo (void)
bool	log_is_log_flush_daemon_available ()
bool	log_is_logged_since_restart (const LOG_LSA * lsa_ptr)
bool	log_is_tran_in_system_op (THREAD_ENTRY * thread_p)
int	log_read_sysop_start_postpone (THREAD_ENTRY * thread_p, LOG_LSA * log_lsa, LOG_PAGE * log_page, bool with_undo_data, LOG_REC_SYSOP_START_POSTPONE * sysop_start_postpone, int * undo_buffer_size, char undo_buffer, int** * undo_size, char ** undo_data)
int	log_recreate (THREAD_ENTRY * thread_p, const char * db_fullname, const char * logpath, const char * prefix_logname, DKNPAGES log_npages, FILE * outfp)
void	log_restart_emergency (THREAD_ENTRY * thread_p, const char * db_fullname, const char * logpath, const char * prefix_logname)
int	log_rv_copy_char (THREAD_ENTRY * thread_p, LOG_RCV * rcv)
void	log_rv_dump_char (FILE * fp, int length, void * data)
void	log_rv_dump_hexa (FILE * fp, int length, void * data)
int	log_rv_outside_noop_redo (THREAD_ENTRY * thread_p, LOG_RCV * rcv)
void	log_simulate_crash (THREAD_ENTRY * thread_p, int flush_log, int flush_data_pages)
void	log_skip_logging (THREAD_ENTRY * thread_p, LOG_DATA_ADDR * addr)
void	log_skip_logging_set_lsa (THREAD_ENTRY * thread_p, LOG_DATA_ADDR * addr)
void	log_stop_ha_delay_registration ()
void	log_sysop_abort (THREAD_ENTRY * thread_p)
void	log_sysop_attach_to_outer (THREAD_ENTRY * thread_p)
void	log_sysop_commit (THREAD_ENTRY * thread_p)
void	log_sysop_end_logical_compensate (THREAD_ENTRY * thread_p, LOG_LSA * undo_nxlsa)
void	log_sysop_end_logical_run_postpone (THREAD_ENTRY * thread_p, LOG_LSA * posp_lsa)
void	log_sysop_end_logical_undo (THREAD_ENTRY * thread_p, LOG_RCVINDEX rcvindex, const VFID * vfid, int undo_size, const char * undo_data)
void	log_sysop_end_recovery_postpone (THREAD_ENTRY * thread_p, LOG_REC_SYSOP_END * log_record, int data_size, const char * data)
const char *	log_sysop_end_type_string (LOG_SYSOP_END_TYPE end_type)
void	log_sysop_start (THREAD_ENTRY * thread_p)
void	log_sysop_start_atomic (THREAD_ENTRY * thread_p)
const char *	log_to_string (LOG_RECTYPE type)
int	log_update_compatibility_and_release (THREAD_ENTRY * thread_p, float compatibility, char release)
void	log_update_global_btid_online_index_stats (THREAD_ENTRY * thread_p)
void	log_wakeup_checkpoint_daemon ()
void	log_wakeup_log_flush_daemon ()
void	log_wakeup_remove_log_archive_daemon ()
void	xlog_dump (THREAD_ENTRY * thread_p, FILE * out_fp, int isforward, LOG_PAGEID start_logpageid, DKNPAGES dump_npages, TRANID desired_tranid)

Macros¶

Type	Name
define	LOG_IS_SYSTEM_OP_STARTED (tdes) `(([tdes](broker__monitor_8c.md#function-timeout))->topops.last >= 0)`
define	LOG_TOPOP_STACK_INIT_SIZE `1024`

Public Types Documentation¶

typedef LOG_TOPOP_RANGE¶

typedef struct log_topop_range LOG_TOPOP_RANGE;

Public Functions Documentation¶

function LOG_CS_DEMOTE¶

void LOG_CS_DEMOTE (
    THREAD_ENTRY * thread_p
)

function LOG_CS_ENTER¶

void LOG_CS_ENTER (
    THREAD_ENTRY * thread_p
)

function LOG_CS_ENTER_READ_MODE¶

void LOG_CS_ENTER_READ_MODE (
    THREAD_ENTRY * thread_p
)

function LOG_CS_EXIT¶

void LOG_CS_EXIT (
    THREAD_ENTRY * thread_p
)

function LOG_CS_OWN¶

bool LOG_CS_OWN (
    THREAD_ENTRY * thread_p
)

function LOG_CS_OWN_WRITE_MODE¶

bool LOG_CS_OWN_WRITE_MODE (
    THREAD_ENTRY * thread_p
)

function LOG_CS_PROMOTE¶

void LOG_CS_PROMOTE (
    THREAD_ENTRY * thread_p
)

function cdc_cleanup¶

int cdc_cleanup ()

function cdc_cleanup_consumer¶

void cdc_cleanup_consumer ()

function cdc_daemons_destroy¶

void cdc_daemons_destroy ()

function cdc_daemons_init¶

void cdc_daemons_init ()

function cdc_finalize¶

int cdc_finalize ()

function cdc_find_lsa¶

int cdc_find_lsa (
    THREAD_ENTRY * thread_p,
    time_t * input_time,
    LOG_LSA * start_lsa
)

function cdc_free_extraction_filter¶

int cdc_free_extraction_filter ()

function cdc_get_loginfo_metadata¶

int cdc_get_loginfo_metadata (
    LOG_LSA * lsa,
    int * length,
    int * num_log_info
)

function cdc_get_logitem_info¶

int cdc_get_logitem_info (
    THREAD_ENTRY * thread_p,
    LOG_LSA * start_lsa,
    int * total_length,
    int * num_log_info
)

function cdc_get_recdes¶

int cdc_get_recdes (
    THREAD_ENTRY * thread_p,
    LOG_LSA * undo_lsa,
    RECDES * undo_recdes,
    LOG_LSA * redo_lsa,
    RECDES * redo_recdes,
    bool is_flashback
)

function cdc_get_undo_record¶

SCAN_CODE cdc_get_undo_record (
    THREAD_ENTRY * thread_p,
    LOG_PAGE * log_page_p,
    LOG_LSA lsa,
    RECDES * undo_recdes
)

function cdc_initialize¶

int cdc_initialize ()

function cdc_kill_producer¶

void cdc_kill_producer ()

function cdc_make_dml_loginfo¶

int cdc_make_dml_loginfo (
    THREAD_ENTRY * thread_p,
    int trid,
    char * user,
    CDC_DML_TYPE dml_type,
    OID classoid,
    RECDES * undo_recdes,
    RECDES * redo_recdes,
    CDC_LOGINFO_ENTRY * dml_entry,
    bool is_flashback
)

function cdc_make_loginfo¶

int cdc_make_loginfo (
    THREAD_ENTRY * thread_p,
    LOG_LSA * start_lsa
)

function cdc_min_log_pageid_to_keep¶

LOG_PAGEID cdc_min_log_pageid_to_keep ()

function cdc_pause_consumer¶

void cdc_pause_consumer ()

function cdc_pause_producer¶

void cdc_pause_producer ()

function cdc_reinitialize_queue¶

void cdc_reinitialize_queue (
    LOG_LSA * start_lsa
)

function cdc_set_configuration¶

int cdc_set_configuration (
    int max_log_item,
    int timeout,
    int all_in_cond,
    char ** user,
    int num_user,
    uint64_t * classoids,
    int num_class
)

function cdc_set_extraction_lsa¶

int cdc_set_extraction_lsa (
    LOG_LSA * lsa
)

function cdc_validate_lsa¶

int cdc_validate_lsa (
    THREAD_ENTRY * thread_p,
    LOG_LSA * lsa
)

function cdc_wakeup_consumer¶

void cdc_wakeup_consumer ()

function cdc_wakeup_producer¶

void cdc_wakeup_producer ()

function log_abort¶

TRAN_STATE log_abort (
    THREAD_ENTRY * thread_p,
    int tran_index
)

function log_abort_all_active_transaction¶

void log_abort_all_active_transaction (
    THREAD_ENTRY * thread_p
)

function log_abort_local¶

TRAN_STATE log_abort_local (
    THREAD_ENTRY * thread_p,
    LOG_TDES * tdes,
    bool is_local_tran
)

function log_abort_partial¶

TRAN_STATE log_abort_partial (
    THREAD_ENTRY * thread_p,
    const  char * savepoint_name,
    LOG_LSA * savept_lsa
)

function log_active_log_header_end_scan¶

int log_active_log_header_end_scan (
    THREAD_ENTRY * thread_p,
    void ** ptr
)

function log_active_log_header_next_scan¶

SCAN_CODE log_active_log_header_next_scan (
    THREAD_ENTRY * thread_p,
    int cursor,
    DB_VALUE ** out_values,
    int out_cnt,
    void * ptr
)

function log_active_log_header_start_scan¶

int log_active_log_header_start_scan (
    THREAD_ENTRY * thread_p,
    int show_type,
    DB_VALUE ** arg_values,
    int arg_cnt,
    void ** ptr
)

function log_add_to_modified_class_list¶

int log_add_to_modified_class_list (
    THREAD_ENTRY * thread_p,
    const  char * classname,
    const  OID * class_oid
)

function log_append_compensate¶

void log_append_compensate (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    const  VPID * vpid,
    PGLENGTH offset,
    PAGE_PTR pgptr,
    int length,
    const  void * data,
    LOG_TDES * tdes
)

function log_append_compensate_with_undo_nxlsa¶

void log_append_compensate_with_undo_nxlsa (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    const  VPID * vpid,
    PGLENGTH offset,
    PAGE_PTR pgptr,
    int length,
    const  void * data,
    LOG_TDES * tdes,
    const  LOG_LSA * undo_nxlsa
)

function log_append_dboutside_redo¶

void log_append_dboutside_redo (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    int length,
    const  void * data
)

function log_append_empty_record¶

void log_append_empty_record (
    THREAD_ENTRY * thread_p,
    LOG_RECTYPE logrec_type,
    LOG_DATA_ADDR * addr
)

function log_append_ha_server_state¶

void log_append_ha_server_state (
    THREAD_ENTRY * thread_p,
    int state
)

function log_append_postpone¶

void log_append_postpone (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    LOG_DATA_ADDR * addr,
    int length,
    const  void * data
)

function log_append_redo_crumbs¶

void log_append_redo_crumbs (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    LOG_DATA_ADDR * addr,
    int num_crumbs,
    const  LOG_CRUMB * crumbs
)

function log_append_redo_data¶

void log_append_redo_data (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    LOG_DATA_ADDR * addr,
    int length,
    const  void * data
)

function log_append_redo_data2¶

void log_append_redo_data2 (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    const  VFID * vfid,
    PAGE_PTR pgptr,
    PGLENGTH offset,
    int length,
    const  void * data
)

function log_append_redo_recdes¶

void log_append_redo_recdes (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    LOG_DATA_ADDR * addr,
    const  RECDES * recdes
)

function log_append_redo_recdes2¶

void log_append_redo_recdes2 (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    const  VFID * vfid,
    PAGE_PTR pgptr,
    PGLENGTH offset,
    const  RECDES * recdes
)

function log_append_repl_info¶

void log_append_repl_info (
    THREAD_ENTRY * thread_p,
    LOG_TDES * tdes,
    bool is_commit
)

function log_append_run_postpone¶

void log_append_run_postpone (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    LOG_DATA_ADDR * addr,
    const  VPID * rcv_vpid,
    int length,
    const  void * data,
    const  LOG_LSA * ref_lsa
)

function log_append_savepoint¶

LOG_LSA * log_append_savepoint (
    THREAD_ENTRY * thread_p,
    const  char * savept_name
)

function log_append_supplemental_info¶

void log_append_supplemental_info (
    THREAD_ENTRY * thread_p,
    SUPPLEMENT_REC_TYPE rec_type,
    int length,
    const  void * data
)

function log_append_supplemental_lsa¶

int log_append_supplemental_lsa (
    THREAD_ENTRY * thread_p,
    SUPPLEMENT_REC_TYPE rec_type,
    OID * classoid,
    LOG_LSA * undo_lsa,
    LOG_LSA * redo_lsa
)

function log_append_supplemental_serial¶

int log_append_supplemental_serial (
    THREAD_ENTRY * thread_p,
    const  char * serial_name,
    int cached_num,
    OID * classoid,
    const  OID * serial_oid
)

function log_append_supplemental_undo_record¶

int log_append_supplemental_undo_record (
    THREAD_ENTRY * thread_p,
    RECDES * undo_recdes
)

function log_append_undo_crumbs¶

void log_append_undo_crumbs (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    LOG_DATA_ADDR * addr,
    int num_crumbs,
    const  LOG_CRUMB * crumbs
)

function log_append_undo_data¶

void log_append_undo_data (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    LOG_DATA_ADDR * addr,
    int length,
    const  void * data
)

function log_append_undo_data2¶

void log_append_undo_data2 (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    const  VFID * vfid,
    PAGE_PTR pgptr,
    PGLENGTH offset,
    int length,
    const  void * data
)

function log_append_undo_recdes¶

void log_append_undo_recdes (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    LOG_DATA_ADDR * addr,
    const  RECDES * recdes
)

function log_append_undo_recdes2¶

void log_append_undo_recdes2 (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    const  VFID * vfid,
    PAGE_PTR pgptr,
    PGLENGTH offset,
    const  RECDES * recdes
)

function log_append_undoredo_crumbs¶

void log_append_undoredo_crumbs (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    LOG_DATA_ADDR * addr,
    int num_undo_crumbs,
    int num_redo_crumbs,
    const  LOG_CRUMB * undo_crumbs,
    const  LOG_CRUMB * redo_crumbs
)

function log_append_undoredo_data¶

void log_append_undoredo_data (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    LOG_DATA_ADDR * addr,
    int undo_length,
    int redo_length,
    const  void * undo_data,
    const  void * redo_data
)

function log_append_undoredo_data2¶

void log_append_undoredo_data2 (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    const  VFID * vfid,
    PAGE_PTR pgptr,
    PGLENGTH offset,
    int undo_length,
    int redo_length,
    const  void * undo_data,
    const  void * redo_data
)

function log_append_undoredo_recdes¶

void log_append_undoredo_recdes (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    LOG_DATA_ADDR * addr,
    const  RECDES * undo_recdes,
    const  RECDES * redo_recdes
)

function log_append_undoredo_recdes2¶

void log_append_undoredo_recdes2 (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    const  VFID * vfid,
    PAGE_PTR pgptr,
    PGLENGTH offset,
    const  RECDES * undo_recdes,
    const  RECDES * redo_recdes
)

function log_archive_log_header_end_scan¶

int log_archive_log_header_end_scan (
    THREAD_ENTRY * thread_p,
    void ** ptr
)

function log_archive_log_header_next_scan¶

SCAN_CODE log_archive_log_header_next_scan (
    THREAD_ENTRY * thread_p,
    int cursor,
    DB_VALUE ** out_values,
    int out_cnt,
    void * ptr
)

function log_archive_log_header_start_scan¶

int log_archive_log_header_start_scan (
    THREAD_ENTRY * thread_p,
    int show_type,
    DB_VALUE ** arg_values,
    int arg_cnt,
    void ** ptr
)

function log_check_system_op_is_started¶

bool log_check_system_op_is_started (
    THREAD_ENTRY * thread_p
)

function log_commit¶

TRAN_STATE log_commit (
    THREAD_ENTRY * thread_p,
    int tran_index,
    bool retain_lock
)

function log_commit_local¶

TRAN_STATE log_commit_local (
    THREAD_ENTRY * thread_p,
    LOG_TDES * tdes,
    bool retain_lock,
    bool is_local_tran
)

function log_complete¶

TRAN_STATE log_complete (
    THREAD_ENTRY * thread_p,
    LOG_TDES * tdes,
    LOG_RECTYPE iscommitted,
    LOG_GETNEWTRID get_newtrid,
    LOG_WRITE_EOT_LOG wrote_eot_log
)

function log_complete_for_2pc¶

TRAN_STATE log_complete_for_2pc (
    THREAD_ENTRY * thread_p,
    LOG_TDES * tdes,
    LOG_RECTYPE iscommitted,
    LOG_GETNEWTRID get_newtrid
)

function log_create¶

int log_create (
    THREAD_ENTRY * thread_p,
    const  char * db_fullname,
    const  char * logpath,
    const  char * prefix_logname,
    DKNPAGES npages
)

function log_do_postpone¶

void log_do_postpone (
    THREAD_ENTRY * thread_p,
    LOG_TDES * tdes,
    LOG_LSA * start_posplsa
)

function log_execute_run_postpone¶

int log_execute_run_postpone (
    THREAD_ENTRY * thread_p,
    LOG_LSA * log_lsa,
    LOG_REC_REDO * redo,
    char * redo_rcv_data
)

function log_final¶

void log_final (
    THREAD_ENTRY * thread_p
)

function log_flush_daemon_get_stats¶

void log_flush_daemon_get_stats (
    UINT64 * statsp
)

function log_get_append_lsa¶

LOG_LSA * log_get_append_lsa (
    void
)

function log_get_charset_from_header_page¶

int log_get_charset_from_header_page (
    THREAD_ENTRY * thread_p,
    const  char * db_fullname,
    const  char * logpath,
    const  char * prefix_logname
)

function log_get_clock_msec¶

INT64 log_get_clock_msec (
    void
)

function log_get_crash_point_lsa¶

LOG_LSA * log_get_crash_point_lsa (
    void
)

function log_get_db_start_parameters¶

int log_get_db_start_parameters (
    INT64 * db_creation,
    LOG_LSA * chkpt_lsa
)

function log_get_eof_lsa¶

LOG_LSA * log_get_eof_lsa (
    void
)

function log_get_io_page_size¶

PGLENGTH log_get_io_page_size (
    THREAD_ENTRY * thread_p,
    const  char * db_fullname,
    const  char * logpath,
    const  char * prefix_logname
)

function log_get_next_nested_top¶

int log_get_next_nested_top (
    THREAD_ENTRY * thread_p,
    LOG_TDES * tdes,
    LOG_LSA * start_postpone_lsa,
    LOG_TOPOP_RANGE ** out_nxtop_range_stack
)

function log_get_num_pages_for_creation¶

int log_get_num_pages_for_creation (
    int db_npages
)

function log_get_parent_lsa_system_op¶

LOG_LSA * log_get_parent_lsa_system_op (
    THREAD_ENTRY * thread_p,
    LOG_LSA * parent_lsa
)

function log_get_restart_lsa¶

LOG_LSA * log_get_restart_lsa (
    void
)

function log_get_undo_record¶

SCAN_CODE log_get_undo_record (
    THREAD_ENTRY * thread_p,
    LOG_PAGE * log_page_p,
    LOG_LSA process_lsa,
    RECDES * recdes
)

function log_initialize¶

void log_initialize (
    THREAD_ENTRY * thread_p,
    const  char * db_fullname,
    const  char * logpath,
    const  char * prefix_logname,
    int ismedia_crash,
    bo_restart_arg * r_args
)

function log_is_active_log_sane¶

bool log_is_active_log_sane (
    THREAD_ENTRY * thread_p,
    const  char * db_fullname,
    const  char * logpath,
    const  char * prefix_logname
)

function log_is_class_being_modified¶

bool log_is_class_being_modified (
    THREAD_ENTRY * thread_p,
    const  OID * class_oid
)

function log_is_in_crash_recovery¶

bool log_is_in_crash_recovery (
    void
)

function log_is_in_crash_recovery_and_not_yet_completes_redo¶

bool log_is_in_crash_recovery_and_not_yet_completes_redo (
    void
)

function log_is_log_flush_daemon_available¶

bool log_is_log_flush_daemon_available ()

function log_is_logged_since_restart¶

bool log_is_logged_since_restart (
    const  LOG_LSA * lsa_ptr
)

function log_is_tran_in_system_op¶

bool log_is_tran_in_system_op (
    THREAD_ENTRY * thread_p
)

function log_read_sysop_start_postpone¶

int log_read_sysop_start_postpone (
    THREAD_ENTRY * thread_p,
    LOG_LSA * log_lsa,
    LOG_PAGE * log_page,
    bool with_undo_data,
    LOG_REC_SYSOP_START_POSTPONE * sysop_start_postpone,
    int * undo_buffer_size,
    char ** undo_buffer,
    int * undo_size,
    char ** undo_data
)

function log_recreate¶

int log_recreate (
    THREAD_ENTRY * thread_p,
    const  char * db_fullname,
    const  char * logpath,
    const  char * prefix_logname,
    DKNPAGES log_npages,
    FILE * outfp
)

function log_restart_emergency¶

void log_restart_emergency (
    THREAD_ENTRY * thread_p,
    const  char * db_fullname,
    const  char * logpath,
    const  char * prefix_logname
)

function log_rv_copy_char¶

int log_rv_copy_char (
    THREAD_ENTRY * thread_p,
    LOG_RCV * rcv
)

function log_rv_dump_char¶

void log_rv_dump_char (
    FILE * fp,
    int length,
    void * data
)

function log_rv_dump_hexa¶

void log_rv_dump_hexa (
    FILE * fp,
    int length,
    void * data
)

function log_rv_outside_noop_redo¶

int log_rv_outside_noop_redo (
    THREAD_ENTRY * thread_p,
    LOG_RCV * rcv
)

function log_simulate_crash¶

void log_simulate_crash (
    THREAD_ENTRY * thread_p,
    int flush_log,
    int flush_data_pages
)

function log_skip_logging¶

void log_skip_logging (
    THREAD_ENTRY * thread_p,
    LOG_DATA_ADDR * addr
)

function log_skip_logging_set_lsa¶

void log_skip_logging_set_lsa (
    THREAD_ENTRY * thread_p,
    LOG_DATA_ADDR * addr
)

function log_stop_ha_delay_registration¶

void log_stop_ha_delay_registration ()

function log_sysop_abort¶

void log_sysop_abort (
    THREAD_ENTRY * thread_p
)

function log_sysop_attach_to_outer¶

void log_sysop_attach_to_outer (
    THREAD_ENTRY * thread_p
)

function log_sysop_commit¶

void log_sysop_commit (
    THREAD_ENTRY * thread_p
)

function log_sysop_end_logical_compensate¶

void log_sysop_end_logical_compensate (
    THREAD_ENTRY * thread_p,
    LOG_LSA * undo_nxlsa
)

function log_sysop_end_logical_run_postpone¶

void log_sysop_end_logical_run_postpone (
    THREAD_ENTRY * thread_p,
    LOG_LSA * posp_lsa
)

function log_sysop_end_logical_undo¶

void log_sysop_end_logical_undo (
    THREAD_ENTRY * thread_p,
    LOG_RCVINDEX rcvindex,
    const  VFID * vfid,
    int undo_size,
    const  char * undo_data
)

function log_sysop_end_recovery_postpone¶

void log_sysop_end_recovery_postpone (
    THREAD_ENTRY * thread_p,
    LOG_REC_SYSOP_END * log_record,
    int data_size,
    const  char * data
)

function log_sysop_end_type_string¶

const  char * log_sysop_end_type_string (
    LOG_SYSOP_END_TYPE end_type
)

function log_sysop_start¶

void log_sysop_start (
    THREAD_ENTRY * thread_p
)

function log_sysop_start_atomic¶

void log_sysop_start_atomic (
    THREAD_ENTRY * thread_p
)

function log_to_string¶

const  char * log_to_string (
    LOG_RECTYPE type
)

function log_update_compatibility_and_release¶

int log_update_compatibility_and_release (
    THREAD_ENTRY * thread_p,
    float compatibility,
    char release
)

function log_update_global_btid_online_index_stats¶

void log_update_global_btid_online_index_stats (
    THREAD_ENTRY * thread_p
)

function log_wakeup_checkpoint_daemon¶

void log_wakeup_checkpoint_daemon ()

function log_wakeup_log_flush_daemon¶

void log_wakeup_log_flush_daemon ()

function log_wakeup_remove_log_archive_daemon¶

void log_wakeup_remove_log_archive_daemon ()

function xlog_dump¶

void xlog_dump (
    THREAD_ENTRY * thread_p,
    FILE * out_fp,
    int isforward,
    LOG_PAGEID start_logpageid,
    DKNPAGES dump_npages,
    TRANID desired_tranid
)

Macro Definition Documentation¶

define LOG_IS_SYSTEM_OP_STARTED¶

#define LOG_IS_SYSTEM_OP_STARTED (
    tdes
) `(( tdes )->topops.last >= 0)`

define LOG_TOPOP_STACK_INIT_SIZE¶

#define LOG_TOPOP_STACK_INIT_SIZE `1024`

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