File log_2pc.h¶

FileList > cubrid > src > transaction > log_2pc.h

#include "log_comm.h"
#include "log_lsa.hpp"
#include "log_storage.hpp"
#include "thread_compat.hpp"
#include <cstdio>

Classes¶

Type	Name
struct	log_2pc_coordinator
struct	log_2pc_gtrinfo

Public Types¶

Type	Name
typedef struct log_2pc_coordinator	LOG_2PC_COORDINATOR
typedef enum log_2pc_execute	LOG_2PC_EXECUTE
typedef struct log_2pc_gtrinfo	LOG_2PC_GTRINFO
enum	log_2pc_execute

Public Attributes¶

Type	Name
const bool	LOG_2PC_DONT_OBTAIN_LOCKS = `[false](broker__monitor_8c.md#function-timeout)`
const int	LOG_2PC_NULL_GTRID = `-1`
const bool	LOG_2PC_OBTAIN_LOCKS = `[true](broker__monitor_8c.md#function-timeout)`

Public Functions¶

Type	Name
log_tdes *	log_2pc_alloc_coord_info (log_tdes * tdes, int num_particps, int particp_id_length, void * block_particps_ids)
int	log_2pc_attach_global_tran (THREAD_ENTRY * thread_p, int gtrid)
bool	log_2pc_clear_and_is_tran_distributed (log_tdes * tdes)
TRAN_STATE	log_2pc_commit (THREAD_ENTRY * thread_p, log_tdes * tdes, LOG_2PC_EXECUTE execute_2pc_type, bool * decision)
void	log_2pc_dump_acqobj_locks (FILE * fp, int length, void * data)
void	log_2pc_dump_gtrinfo (FILE * fp, int length, void * data)
void	log_2pc_dump_participants (FILE * fp, int block_length, void * block_particps_ids)
void	log_2pc_free_coord_info (log_tdes * tdes)
int	log_2pc_get_global_tran_info (THREAD_ENTRY * thread_p, int gtrid, void * buffer, int size)
bool	log_2pc_is_tran_distributed (log_tdes * tdes)
TRAN_STATE	log_2pc_prepare (THREAD_ENTRY * thread_p)
TRAN_STATE	log_2pc_prepare_global_tran (THREAD_ENTRY * thread_p, int gtrid)
void	log_2pc_read_prepare (THREAD_ENTRY * thread_p, int acquire_locks, log_tdes * tdes, LOG_LSA * lsa, LOG_PAGE * log_pgptr)
void	log_2pc_read_prepare (THREAD_ENTRY * thread_p, int acquire_locks, log_tdes * tdes, log_reader & log_pgptr_reader)
void	log_2pc_recovery (THREAD_ENTRY * thread_p)
void	log_2pc_recovery_analysis_info (THREAD_ENTRY * thread_p, log_tdes * tdes, LOG_LSA * upto_chain_lsa)
int	log_2pc_recovery_prepared (THREAD_ENTRY * thread_p, int gtrids, int size)
void	log_2pc_send_abort_decision (THREAD_ENTRY * thread_p, int gtrid, int num_particps, void * block_particps_ids)
void	log_2pc_send_commit_decision (THREAD_ENTRY * thread_p, int gtrid, int num_particps, void * block_particps_ids)
bool	log_2pc_send_prepare (THREAD_ENTRY * thread_p, int gtrid, int num_particps, void * block_particps_ids)
int	log_2pc_set_global_tran_info (THREAD_ENTRY * thread_p, int gtrid, void * info, int size)
int	log_2pc_start (THREAD_ENTRY * thread_p)

Public Types Documentation¶

typedef LOG_2PC_COORDINATOR¶

typedef struct log_2pc_coordinator LOG_2PC_COORDINATOR;

typedef LOG_2PC_EXECUTE¶

typedef enum log_2pc_execute LOG_2PC_EXECUTE;

typedef LOG_2PC_GTRINFO¶

typedef struct log_2pc_gtrinfo LOG_2PC_GTRINFO;

enum log_2pc_execute¶

enum log_2pc_execute {
    LOG_2PC_EXECUTE_FULL,
    LOG_2PC_EXECUTE_PREPARE,
    LOG_2PC_EXECUTE_COMMIT_DECISION,
    LOG_2PC_EXECUTE_ABORT_DECISION
};

Public Attributes Documentation¶

variable LOG_2PC_DONT_OBTAIN_LOCKS¶

const bool LOG_2PC_DONT_OBTAIN_LOCKS;

variable LOG_2PC_NULL_GTRID¶

const int LOG_2PC_NULL_GTRID;

variable LOG_2PC_OBTAIN_LOCKS¶

const bool LOG_2PC_OBTAIN_LOCKS;

Public Functions Documentation¶

function log_2pc_alloc_coord_info¶

log_tdes * log_2pc_alloc_coord_info (
    log_tdes * tdes,
    int num_particps,
    int particp_id_length,
    void * block_particps_ids
)

function log_2pc_attach_global_tran¶

int log_2pc_attach_global_tran (
    THREAD_ENTRY * thread_p,
    int gtrid
)

function log_2pc_clear_and_is_tran_distributed¶

bool log_2pc_clear_and_is_tran_distributed (
    log_tdes * tdes
)

function log_2pc_commit¶

TRAN_STATE log_2pc_commit (
    THREAD_ENTRY * thread_p,
    log_tdes * tdes,
    LOG_2PC_EXECUTE execute_2pc_type,
    bool * decision
)

function log_2pc_dump_acqobj_locks¶

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

function log_2pc_dump_gtrinfo¶

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

function log_2pc_dump_participants¶

void log_2pc_dump_participants (
    FILE * fp,
    int block_length,
    void * block_particps_ids
)

function log_2pc_free_coord_info¶

void log_2pc_free_coord_info (
    log_tdes * tdes
)

function log_2pc_get_global_tran_info¶

int log_2pc_get_global_tran_info (
    THREAD_ENTRY * thread_p,
    int gtrid,
    void * buffer,
    int size
)

function log_2pc_is_tran_distributed¶

bool log_2pc_is_tran_distributed (
    log_tdes * tdes
)

function log_2pc_prepare¶

TRAN_STATE log_2pc_prepare (
    THREAD_ENTRY * thread_p
)

function log_2pc_prepare_global_tran¶

TRAN_STATE log_2pc_prepare_global_tran (
    THREAD_ENTRY * thread_p,
    int gtrid
)

function log_2pc_read_prepare¶

void log_2pc_read_prepare (
    THREAD_ENTRY * thread_p,
    int acquire_locks,
    log_tdes * tdes,
    LOG_LSA * lsa,
    LOG_PAGE * log_pgptr
)

function log_2pc_read_prepare¶

void log_2pc_read_prepare (
    THREAD_ENTRY * thread_p,
    int acquire_locks,
    log_tdes * tdes,
    log_reader & log_pgptr_reader
)

function log_2pc_recovery¶

void log_2pc_recovery (
    THREAD_ENTRY * thread_p
)

function log_2pc_recovery_analysis_info¶

void log_2pc_recovery_analysis_info (
    THREAD_ENTRY * thread_p,
    log_tdes * tdes,
    LOG_LSA * upto_chain_lsa
)

function log_2pc_recovery_prepared¶

int log_2pc_recovery_prepared (
    THREAD_ENTRY * thread_p,
    int gtrids,
    int size
)

function log_2pc_send_abort_decision¶

void log_2pc_send_abort_decision (
    THREAD_ENTRY * thread_p,
    int gtrid,
    int num_particps,
    void * block_particps_ids
)

function log_2pc_send_commit_decision¶

void log_2pc_send_commit_decision (
    THREAD_ENTRY * thread_p,
    int gtrid,
    int num_particps,
    void * block_particps_ids
)

function log_2pc_send_prepare¶

bool log_2pc_send_prepare (
    THREAD_ENTRY * thread_p,
    int gtrid,
    int num_particps,
    void * block_particps_ids
)

function log_2pc_set_global_tran_info¶

int log_2pc_set_global_tran_info (
    THREAD_ENTRY * thread_p,
    int gtrid,
    void * info,
    int size
)

function log_2pc_start¶

int log_2pc_start (
    THREAD_ENTRY * thread_p
)

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