File replication.c¶

FileList > cubrid > src > transaction > replication.c

#include "replication.h"
#include "dbtype.h"
#include "heap_file.h"
#include "log_lsa.hpp"
#include "object_primitive.h"
#include "object_representation.h"
#include "schema_system_catalog_constants.h"
#include <assert.h>
#include <stdio.h>
#include "memory_wrapper.hpp"

Public Static Attributes¶

Type	Name
const int	REPL_LOG_INFO_ALLOC_SIZE = `100`

Public Functions¶

Type	Name
int	repl_add_update_lsa (THREAD_ENTRY * thread_p, const OID * inst_oid)
void	repl_data_delete_log_dump (FILE * fp, int length, void * data)
void	repl_data_insert_log_dump (FILE * fp, int length, void * data)
void	repl_data_udpate_log_dump (FILE * fp, int length, void * data)
void	repl_debug_info ()
void	repl_end_flush_mark (THREAD_ENTRY * thread_p, bool need_undo)
int	repl_log_abort_after_lsa (LOG_TDES * tdes, LOG_LSA * start_lsa)
int	repl_log_insert (THREAD_ENTRY * thread_p, const OID * class_oid, const OID * inst_oid, LOG_RECTYPE log_type, LOG_RCVINDEX rcvindex, DB_VALUE * key_dbvalue, REPL_INFO_TYPE repl_info)
int	repl_log_insert_statement (THREAD_ENTRY * thread_p, REPL_INFO_SBR * repl_info)
void	repl_schema_log_dump (FILE * fp, int length, void * data)
void	repl_start_flush_mark (THREAD_ENTRY * thread_p)

Public Static Functions¶

Type	Name
int	repl_log_info_alloc (LOG_TDES * tdes, int arr_size, bool need_realloc)

Macros¶

Type	Name
define	REPL_LOG_IS_FULL (tran_index) `/* multi line expression */`
define	REPL_LOG_IS_NOT_EXISTS (tran_index) `(log\_Gl.trantable.all\_tdes[(tran\_index)]->num\_repl\_records == 0)`

Public Static Attributes Documentation¶

variable REPL_LOG_INFO_ALLOC_SIZE¶

const int REPL_LOG_INFO_ALLOC_SIZE;

Public Functions Documentation¶

function repl_add_update_lsa¶

int repl_add_update_lsa (
    THREAD_ENTRY * thread_p,
    const  OID * inst_oid
)

function repl_data_delete_log_dump¶

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

function repl_data_insert_log_dump¶

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

function repl_data_udpate_log_dump¶

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

function repl_debug_info¶

void repl_debug_info ()

function repl_end_flush_mark¶

void repl_end_flush_mark (
    THREAD_ENTRY * thread_p,
    bool need_undo
)

function repl_log_abort_after_lsa¶

int repl_log_abort_after_lsa (
    LOG_TDES * tdes,
    LOG_LSA * start_lsa
)

function repl_log_insert¶

int repl_log_insert (
    THREAD_ENTRY * thread_p,
    const  OID * class_oid,
    const  OID * inst_oid,
    LOG_RECTYPE log_type,
    LOG_RCVINDEX rcvindex,
    DB_VALUE * key_dbvalue,
    REPL_INFO_TYPE repl_info
)

function repl_log_insert_statement¶

int repl_log_insert_statement (
    THREAD_ENTRY * thread_p,
    REPL_INFO_SBR * repl_info
)

function repl_schema_log_dump¶

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

function repl_start_flush_mark¶

void repl_start_flush_mark (
    THREAD_ENTRY * thread_p
)

Public Static Functions Documentation¶

function repl_log_info_alloc¶

static int repl_log_info_alloc (
    LOG_TDES * tdes,
    int arr_size,
    bool need_realloc
)

Macro Definition Documentation¶

define REPL_LOG_IS_FULL¶

#define REPL_LOG_IS_FULL (
    tran_index
) `/* multi line expression */`

define REPL_LOG_IS_NOT_EXISTS¶

#define REPL_LOG_IS_NOT_EXISTS (
    tran_index
) `(log_Gl.trantable.all_tdes[(tran_index)]->num_repl_records == 0)`

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