File log_append.hpp¶

FileList > cubrid > src > transaction > log_append.hpp

#include "log_lsa.hpp"
#include "log_record.hpp"
#include "log_storage.hpp"
#include "memory_alloc.h"
#include "object_representation_constants.h"
#include "recovery.h"
#include "storage_common.h"
#include "log_compress.h"
#include <atomic>
#include <mutex>

Classes¶

Type	Name
struct	log_append_info
struct	log_crumb
struct	log_data_addr
struct	log_prior_lsa_info
struct	log_prior_node

Public Types¶

Type	Name
typedef struct log_append_info	LOG_APPEND_INFO
typedef struct log_crumb	LOG_CRUMB
typedef struct log_data_addr	LOG_DATA_ADDR
typedef struct log_prior_lsa_info	LOG_PRIOR_LSA_INFO
enum	LOG_PRIOR_LSA_LOCK
typedef struct log_prior_node	LOG_PRIOR_NODE
typedef log_data_addr::offset_type	log_rv_record_flag_type

Public Attributes¶

Type	Name
const log_rv_record_flag_type	LOG_RV_RECORD_DELETE = `0x4000`
const log_rv_record_flag_type	LOG_RV_RECORD_INSERT = `([log\_rv\_record\_flag\_type](log__append_8hpp.md#typedef-log_rv_record_flag_type)) 0x8000`
const log_rv_record_flag_type	LOG_RV_RECORD_MODIFY_MASK = `([log\_rv\_record\_flag\_type](log__append_8hpp.md#typedef-log_rv_record_flag_type)) 0xC000`
const log_rv_record_flag_type	LOG_RV_RECORD_UPDATE_ALL = `([log\_rv\_record\_flag\_type](log__append_8hpp.md#typedef-log_rv_record_flag_type)) 0xC000`
const log_rv_record_flag_type	LOG_RV_RECORD_UPDATE_PARTIAL = `0x0000`
int	log_Zip_min_size_to_compress
bool	log_Zip_support

Public Functions¶

Type	Name
char *	LOG_APPEND_PTR ()
void	LOG_RESET_APPEND_LSA (const LOG_LSA * lsa)
void	LOG_RESET_PREV_LSA (const LOG_LSA * lsa)
bool	LOG_RV_RECORD_IS_DELETE (log_rv_record_flag_type flags)
bool	LOG_RV_RECORD_IS_INSERT (log_rv_record_flag_type flags)
bool	LOG_RV_RECORD_IS_UPDATE_ALL (log_rv_record_flag_type flags)
bool	LOG_RV_RECORD_IS_UPDATE_PARTIAL (log_rv_record_flag_type flags)
void	LOG_RV_RECORD_SET_MODIFY_MODE (log_data_addr * addr, log_rv_record_flag_type mode)
constexpr size_t	LOG_RV_RECORD_UPDPARTIAL_ALIGNED_SIZE (size_t new_data_size)
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)
size_t	logpb_get_memsize ()
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)

Macros¶

Type	Name
define	LOG_DATA_ADDR_INITIALIZER `{ [NULL](freelistheap_8h.md#define-null), [NULL](freelistheap_8h.md#define-null), 0 }`

Public Types Documentation¶

typedef LOG_APPEND_INFO¶

typedef struct log_append_info LOG_APPEND_INFO;

typedef LOG_CRUMB¶

typedef struct log_crumb LOG_CRUMB;

typedef LOG_DATA_ADDR¶

typedef struct log_data_addr LOG_DATA_ADDR;

typedef LOG_PRIOR_LSA_INFO¶

typedef struct log_prior_lsa_info LOG_PRIOR_LSA_INFO;

enum LOG_PRIOR_LSA_LOCK¶

enum LOG_PRIOR_LSA_LOCK {
    LOG_PRIOR_LSA_WITHOUT_LOCK = 0,
    LOG_PRIOR_LSA_WITH_LOCK = 1
};

typedef LOG_PRIOR_NODE¶

typedef struct log_prior_node LOG_PRIOR_NODE;

typedef log_rv_record_flag_type¶

using log_rv_record_flag_type =  log_data_addr::offset_type;

Public Attributes Documentation¶

variable LOG_RV_RECORD_DELETE¶

const log_rv_record_flag_type LOG_RV_RECORD_DELETE;

variable LOG_RV_RECORD_INSERT¶

const log_rv_record_flag_type LOG_RV_RECORD_INSERT;

variable LOG_RV_RECORD_MODIFY_MASK¶

const log_rv_record_flag_type LOG_RV_RECORD_MODIFY_MASK;

variable LOG_RV_RECORD_UPDATE_ALL¶

const log_rv_record_flag_type LOG_RV_RECORD_UPDATE_ALL;

variable LOG_RV_RECORD_UPDATE_PARTIAL¶

const log_rv_record_flag_type LOG_RV_RECORD_UPDATE_PARTIAL;

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_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_RV_RECORD_IS_DELETE¶

inline bool LOG_RV_RECORD_IS_DELETE (
    log_rv_record_flag_type flags
)

function LOG_RV_RECORD_IS_INSERT¶

inline bool LOG_RV_RECORD_IS_INSERT (
    log_rv_record_flag_type flags
)

function LOG_RV_RECORD_IS_UPDATE_ALL¶

inline bool LOG_RV_RECORD_IS_UPDATE_ALL (
    log_rv_record_flag_type flags
)

function LOG_RV_RECORD_IS_UPDATE_PARTIAL¶

inline bool LOG_RV_RECORD_IS_UPDATE_PARTIAL (
    log_rv_record_flag_type flags
)

function LOG_RV_RECORD_SET_MODIFY_MODE¶

inline void LOG_RV_RECORD_SET_MODIFY_MODE (
    log_data_addr * addr,
    log_rv_record_flag_type mode
)

function LOG_RV_RECORD_UPDPARTIAL_ALIGNED_SIZE¶

constexpr  size_t LOG_RV_RECORD_UPDPARTIAL_ALIGNED_SIZE (
    size_t new_data_size
)

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 logpb_get_memsize¶

size_t logpb_get_memsize ()

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
)

Macro Definition Documentation¶

define LOG_DATA_ADDR_INITIALIZER¶

#define LOG_DATA_ADDR_INITIALIZER `{ NULL , NULL , 0 }`

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