File replication.h¶

FileList > cubrid > src > transaction > replication.h

#include "config.h"
#include "error_manager.h"
#include "log_impl.h"
#include "log_lsa.hpp"
#include "memory_alloc.h"
#include "oid.h"
#include "system_parameter.h"
#include "thread_compat.hpp"

Classes¶

Type	Name
struct	log_repl
struct	repl_info
struct	repl_info_statement

Public Types¶

Type	Name
typedef enum log_repl_flush	LOG_REPL_FLUSH
typedef struct log_repl	LOG_REPL_RECORD
typedef struct repl_info	REPL_INFO
typedef struct repl_info_statement	REPL_INFO_SBR
enum	REPL_INFO_TYPE
enum	log_repl_flush

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_type)
int	repl_log_insert_statement (THREAD_ENTRY * thread_p, REPL_INFO_SBR * repl_info)
void	repl_log_send (void)
void	repl_schema_log_dump (FILE * fp, int length, void * data)
void	repl_start_flush_mark (THREAD_ENTRY * thread_p)

Public Types Documentation¶

typedef LOG_REPL_FLUSH¶

typedef enum log_repl_flush LOG_REPL_FLUSH;

typedef LOG_REPL_RECORD¶

typedef struct log_repl LOG_REPL_RECORD;

typedef REPL_INFO¶

typedef struct repl_info REPL_INFO;

typedef REPL_INFO_SBR¶

typedef struct repl_info_statement REPL_INFO_SBR;

enum REPL_INFO_TYPE¶

enum REPL_INFO_TYPE {
    REPL_INFO_TYPE_SBR,
    REPL_INFO_TYPE_RBR_START,
    REPL_INFO_TYPE_RBR_NORMAL,
    REPL_INFO_TYPE_RBR_END
};

enum log_repl_flush¶

enum log_repl_flush {
    LOG_REPL_DONT_NEED_FLUSH = -1,
    LOG_REPL_COMMIT_NEED_FLUSH = 0,
    LOG_REPL_NEED_FLUSH = 1
};

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_type
)

function repl_log_insert_statement¶

int repl_log_insert_statement (
    THREAD_ENTRY * thread_p,
    REPL_INFO_SBR * repl_info
)

function repl_log_send¶

void repl_log_send (
    void
)

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
)

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