File locator_sr.h¶

FileList > cubrid > src > transaction > locator_sr.h

#include "config.h"
#include "disk_manager.h"
#include "error_manager.h"
#include "extendible_hash.h"
#include "heap_file.h"
#include "locator.h"
#include "lock_manager.h"
#include "oid.h"
#include "partition_sr.h"
#include "query_evaluator.h"
#include "replication.h"
#include "storage_common.h"
#include "thread_compat.hpp"

Namespaces¶

Type	Name
namespace	cubquery

Public Types¶

Type	Name
typedef cubquery::mvcc_reev_data	MVCC_REEV_DATA
enum	locator__sr_8h_1a737c1bdca78a4eec48fa026fcca3dd9b

Public Attributes¶

Type	Name
bool	locator_Dont_check_foreign_key

Public Functions¶

Type	Name
bool	has_errors_filtered_for_insert (std::vector< int > error_filter_array)
int	locator_add_or_remove_index (THREAD_ENTRY * thread_p, RECDES * recdes, OID * inst_oid, OID * class_oid, int is_insert, int op_type, HEAP_SCANCACHE * scan_cache, bool datayn, bool replyn, HFID * hfid, FUNC_PRED_UNPACK_INFO * func_preds, bool has_BU_lock, bool skip_checking_fk)
LC_COPYAREA *	locator_allocate_copy_area_by_attr_info (THREAD_ENTRY * thread_p, HEAP_CACHE_ATTRINFO * attr_info, RECDES * old_recdes, RECDES * new_recdes, const int copyarea_length_hint, int lob_create_flag)
int	locator_attribute_info_force (THREAD_ENTRY * thread_p, const HFID * hfid, OID * oid, HEAP_CACHE_ATTRINFO * attr_info, ATTR_ID * att_id, int n_att_id, LC_COPYAREA_OPERATION operation, int op_type, HEAP_SCANCACHE * scan_cache, int * force_count, bool not_check_fk, REPL_INFO_TYPE repl_info, int pruning_type, PRUNING_CONTEXT * pcontext, FUNC_PRED_UNPACK_INFO * func_preds, MVCC_REEV_DATA * mvcc_reev_data, UPDATE_INPLACE_STYLE force_update_inplace, RECDES * rec_descriptor, bool need_locking)
DISK_ISVALID	locator_check_all_entries_of_all_btrees (THREAD_ENTRY * thread_p, bool repair)
DISK_ISVALID	locator_check_btree_entries (THREAD_ENTRY * thread_p, BTID * btid, HFID * hfid, OID * class_oid, int n_attr_ids, ATTR_ID * attr_ids, int * atts_prefix_length, const char * btname, bool repair)
DISK_ISVALID	locator_check_by_class_oid (THREAD_ENTRY * thread_p, OID * cls_oid, HFID * hfid, BTID * index_btid, bool repair)
DISK_ISVALID	locator_check_class (THREAD_ENTRY * thtread_p, OID * class_oid, RECDES * peek, HFID * class_hfid, BTID * index_btid, bool repair)
DISK_ISVALID	locator_check_class_names (THREAD_ENTRY * thread_p)
SCAN_OPERATION_TYPE	locator_decide_operation_type (LOCK lock_mode, LC_FETCH_VERSION_TYPE fetch_version_type)
int	locator_delete_force (THREAD_ENTRY * thread_p, HFID * hfid, OID * oid, int has_index, int op_type, HEAP_SCANCACHE * scan_cache, int * force_count, MVCC_REEV_DATA * mvcc_reev_data, bool need_locking)
int	locator_delete_lob_force (THREAD_ENTRY * thread_p, OID * class_oid, OID * oid, RECDES * recdes)
int	locator_drop_transient_class_name_entries (THREAD_ENTRY * thread_p, LOG_LSA * savep_lsa)
void	locator_dump_class_names (THREAD_ENTRY * thread_p, FILE * out_fp)
void	locator_end_force_scan_cache (THREAD_ENTRY * thread_p, HEAP_SCANCACHE * scan_cache)
void	locator_finalize (THREAD_ENTRY * thread_p)
LOCK	locator_get_lock_mode_from_op_type (SCAN_OPERATION_TYPE op_type)
SCAN_CODE	locator_get_object (THREAD_ENTRY * thread_p, const OID * oid, OID * class_oid, RECDES * recdes, HEAP_SCANCACHE * scan_cache, SCAN_OPERATION_TYPE op_type, LOCK lock_mode, int ispeeking, int chn)
PRUNING_SCAN_CACHE *	locator_get_partition_scancache (PRUNING_CONTEXT * pcontext, const OID * class_oid, const HFID * hfid, int op_type, bool has_function_index)
int	locator_initialize (THREAD_ENTRY * thread_p)
int	locator_insert_force (THREAD_ENTRY * thread_p, HFID * hfid, OID * class_oid, OID * oid, RECDES * recdes, int has_index, int op_type, HEAP_SCANCACHE * scan_cache, int * force_count, int pruning_type, PRUNING_CONTEXT * pcontext, FUNC_PRED_UNPACK_INFO * func_preds, UPDATE_INPLACE_STYLE force_in_place, PGBUF_WATCHER * home_hint_p, bool has_BU_lock, bool dont_check_fk, bool use_bulk_logging=false)
SCAN_CODE	locator_lock_and_get_object (THREAD_ENTRY * thread_p, const OID * oid, OID * class_oid, RECDES * recdes, HEAP_SCANCACHE * scan_cache, LOCK lock, int ispeeking, int old_chn, NON_EXISTENT_HANDLING non_ex_handling_type)
SCAN_CODE	locator_lock_and_get_object_with_evaluation (THREAD_ENTRY * thread_p, OID * oid, OID * class_oid, RECDES * recdes, HEAP_SCANCACHE * scan_cache, int ispeeking, int old_chn, MVCC_REEV_DATA * mvcc_reev_data, NON_EXISTENT_HANDLING non_ex_handling_type)
int	locator_multi_insert_force (THREAD_ENTRY * thread_p, HFID * hfid, OID * class_oid, const std::vector< record_descriptor > & recdes, int has_index, int op_type, HEAP_SCANCACHE * scan_cache, int * force_count, int pruning_type, PRUNING_CONTEXT * pcontext, FUNC_PRED_UNPACK_INFO * func_preds, UPDATE_INPLACE_STYLE force_in_place, bool dont_check_fk)
int	locator_other_insert_delete (THREAD_ENTRY * thread_p, HFID * hfid, OID * oid, BTID * btid, bool btid_dup_key_locked, HFID * newhfid, OID * newoid, HEAP_CACHE_ATTRINFO * attr_info, HEAP_SCANCACHE * scan_cache, int * force_count, OID * prev_oid, REPR_ID * new_reprid)
int	locator_rv_redo_rename (THREAD_ENTRY * thread_p, LOG_RCV * rcv)
int	locator_savepoint_transient_class_name_entries (THREAD_ENTRY * thread_p, LOG_LSA * savep_lsa)
int	locator_start_force_scan_cache (THREAD_ENTRY * thread_p, HEAP_SCANCACHE * scan_cache, const HFID * hfid, const OID * class_oid, int op_type)
int	locator_update_index (THREAD_ENTRY * thread_p, RECDES * new_recdes, RECDES * old_recdes, ATTR_ID * att_id, int n_att_id, OID * oid, OID * class_oid, int op_type, HEAP_SCANCACHE * scan_cache, REPL_INFO * repl_info)
int	xlc_fetch_allrefslockset (OID * oid, int chn, OID * class_oid, int class_chn, LOCK lock, int quit_on_errors, int prune_level, LC_LOCKSET lockset, LC_COPYAREA fetch_area)
int	xlocator_redistribute_partition_data (THREAD_ENTRY * thread_p, OID * class_oid, int no_oids, OID * oid_list)

Public Types Documentation¶

typedef MVCC_REEV_DATA¶

using MVCC_REEV_DATA =  cubquery::mvcc_reev_data;

enum locator__sr_8h_1a737c1bdca78a4eec48fa026fcca3dd9b¶

enum locator__sr_8h_1a737c1bdca78a4eec48fa026fcca3dd9b {
    LOB_FLAG_EXCLUDE_LOB,
    LOB_FLAG_INCLUDE_LOB
};

Public Attributes Documentation¶

variable locator_Dont_check_foreign_key¶

bool locator_Dont_check_foreign_key;

Public Functions Documentation¶

function has_errors_filtered_for_insert¶

bool has_errors_filtered_for_insert (
    std::vector< int > error_filter_array
)

function locator_add_or_remove_index¶

int locator_add_or_remove_index (
    THREAD_ENTRY * thread_p,
    RECDES * recdes,
    OID * inst_oid,
    OID * class_oid,
    int is_insert,
    int op_type,
    HEAP_SCANCACHE * scan_cache,
    bool datayn,
    bool replyn,
    HFID * hfid,
    FUNC_PRED_UNPACK_INFO * func_preds,
    bool has_BU_lock,
    bool skip_checking_fk
)

function locator_allocate_copy_area_by_attr_info¶

LC_COPYAREA * locator_allocate_copy_area_by_attr_info (
    THREAD_ENTRY * thread_p,
    HEAP_CACHE_ATTRINFO * attr_info,
    RECDES * old_recdes,
    RECDES * new_recdes,
    const  int copyarea_length_hint,
    int lob_create_flag
)

function locator_attribute_info_force¶

int locator_attribute_info_force (
    THREAD_ENTRY * thread_p,
    const  HFID * hfid,
    OID * oid,
    HEAP_CACHE_ATTRINFO * attr_info,
    ATTR_ID * att_id,
    int n_att_id,
    LC_COPYAREA_OPERATION operation,
    int op_type,
    HEAP_SCANCACHE * scan_cache,
    int * force_count,
    bool not_check_fk,
    REPL_INFO_TYPE repl_info,
    int pruning_type,
    PRUNING_CONTEXT * pcontext,
    FUNC_PRED_UNPACK_INFO * func_preds,
    MVCC_REEV_DATA * mvcc_reev_data,
    UPDATE_INPLACE_STYLE force_update_inplace,
    RECDES * rec_descriptor,
    bool need_locking
)

function locator_check_all_entries_of_all_btrees¶

DISK_ISVALID locator_check_all_entries_of_all_btrees (
    THREAD_ENTRY * thread_p,
    bool repair
)

function locator_check_btree_entries¶

DISK_ISVALID locator_check_btree_entries (
    THREAD_ENTRY * thread_p,
    BTID * btid,
    HFID * hfid,
    OID * class_oid,
    int n_attr_ids,
    ATTR_ID * attr_ids,
    int * atts_prefix_length,
    const  char * btname,
    bool repair
)

function locator_check_by_class_oid¶

DISK_ISVALID locator_check_by_class_oid (
    THREAD_ENTRY * thread_p,
    OID * cls_oid,
    HFID * hfid,
    BTID * index_btid,
    bool repair
)

function locator_check_class¶

DISK_ISVALID locator_check_class (
    THREAD_ENTRY * thtread_p,
    OID * class_oid,
    RECDES * peek,
    HFID * class_hfid,
    BTID * index_btid,
    bool repair
)

function locator_check_class_names¶

DISK_ISVALID locator_check_class_names (
    THREAD_ENTRY * thread_p
)

function locator_decide_operation_type¶

SCAN_OPERATION_TYPE locator_decide_operation_type (
    LOCK lock_mode,
    LC_FETCH_VERSION_TYPE fetch_version_type
)

function locator_delete_force¶

int locator_delete_force (
    THREAD_ENTRY * thread_p,
    HFID * hfid,
    OID * oid,
    int has_index,
    int op_type,
    HEAP_SCANCACHE * scan_cache,
    int * force_count,
    MVCC_REEV_DATA * mvcc_reev_data,
    bool need_locking
)

function locator_delete_lob_force¶

int locator_delete_lob_force (
    THREAD_ENTRY * thread_p,
    OID * class_oid,
    OID * oid,
    RECDES * recdes
)

function locator_drop_transient_class_name_entries¶

int locator_drop_transient_class_name_entries (
    THREAD_ENTRY * thread_p,
    LOG_LSA * savep_lsa
)

function locator_dump_class_names¶

void locator_dump_class_names (
    THREAD_ENTRY * thread_p,
    FILE * out_fp
)

function locator_end_force_scan_cache¶

void locator_end_force_scan_cache (
    THREAD_ENTRY * thread_p,
    HEAP_SCANCACHE * scan_cache
)

function locator_finalize¶

void locator_finalize (
    THREAD_ENTRY * thread_p
)

function locator_get_lock_mode_from_op_type¶

LOCK locator_get_lock_mode_from_op_type (
    SCAN_OPERATION_TYPE op_type
)

function locator_get_object¶

SCAN_CODE locator_get_object (
    THREAD_ENTRY * thread_p,
    const  OID * oid,
    OID * class_oid,
    RECDES * recdes,
    HEAP_SCANCACHE * scan_cache,
    SCAN_OPERATION_TYPE op_type,
    LOCK lock_mode,
    int ispeeking,
    int chn
)

function locator_get_partition_scancache¶

PRUNING_SCAN_CACHE * locator_get_partition_scancache (
    PRUNING_CONTEXT * pcontext,
    const  OID * class_oid,
    const  HFID * hfid,
    int op_type,
    bool has_function_index
)

function locator_initialize¶

int locator_initialize (
    THREAD_ENTRY * thread_p
)

function locator_insert_force¶

int locator_insert_force (
    THREAD_ENTRY * thread_p,
    HFID * hfid,
    OID * class_oid,
    OID * oid,
    RECDES * recdes,
    int has_index,
    int op_type,
    HEAP_SCANCACHE * scan_cache,
    int * force_count,
    int pruning_type,
    PRUNING_CONTEXT * pcontext,
    FUNC_PRED_UNPACK_INFO * func_preds,
    UPDATE_INPLACE_STYLE force_in_place,
    PGBUF_WATCHER * home_hint_p,
    bool has_BU_lock,
    bool dont_check_fk,
    bool use_bulk_logging=false
)

function locator_lock_and_get_object¶

SCAN_CODE locator_lock_and_get_object (
    THREAD_ENTRY * thread_p,
    const  OID * oid,
    OID * class_oid,
    RECDES * recdes,
    HEAP_SCANCACHE * scan_cache,
    LOCK lock,
    int ispeeking,
    int old_chn,
    NON_EXISTENT_HANDLING non_ex_handling_type
)

function locator_lock_and_get_object_with_evaluation¶

SCAN_CODE locator_lock_and_get_object_with_evaluation (
    THREAD_ENTRY * thread_p,
    OID * oid,
    OID * class_oid,
    RECDES * recdes,
    HEAP_SCANCACHE * scan_cache,
    int ispeeking,
    int old_chn,
    MVCC_REEV_DATA * mvcc_reev_data,
    NON_EXISTENT_HANDLING non_ex_handling_type
)

function locator_multi_insert_force¶

int locator_multi_insert_force (
    THREAD_ENTRY * thread_p,
    HFID * hfid,
    OID * class_oid,
    const std::vector< record_descriptor > & recdes,
    int has_index,
    int op_type,
    HEAP_SCANCACHE * scan_cache,
    int * force_count,
    int pruning_type,
    PRUNING_CONTEXT * pcontext,
    FUNC_PRED_UNPACK_INFO * func_preds,
    UPDATE_INPLACE_STYLE force_in_place,
    bool dont_check_fk
)

function locator_other_insert_delete¶

int locator_other_insert_delete (
    THREAD_ENTRY * thread_p,
    HFID * hfid,
    OID * oid,
    BTID * btid,
    bool btid_dup_key_locked,
    HFID * newhfid,
    OID * newoid,
    HEAP_CACHE_ATTRINFO * attr_info,
    HEAP_SCANCACHE * scan_cache,
    int * force_count,
    OID * prev_oid,
    REPR_ID * new_reprid
)

function locator_rv_redo_rename¶

int locator_rv_redo_rename (
    THREAD_ENTRY * thread_p,
    LOG_RCV * rcv
)

function locator_savepoint_transient_class_name_entries¶

int locator_savepoint_transient_class_name_entries (
    THREAD_ENTRY * thread_p,
    LOG_LSA * savep_lsa
)

function locator_start_force_scan_cache¶

int locator_start_force_scan_cache (
    THREAD_ENTRY * thread_p,
    HEAP_SCANCACHE * scan_cache,
    const  HFID * hfid,
    const  OID * class_oid,
    int op_type
)

function locator_update_index¶

int locator_update_index (
    THREAD_ENTRY * thread_p,
    RECDES * new_recdes,
    RECDES * old_recdes,
    ATTR_ID * att_id,
    int n_att_id,
    OID * oid,
    OID * class_oid,
    int op_type,
    HEAP_SCANCACHE * scan_cache,
    REPL_INFO * repl_info
)

function xlc_fetch_allrefslockset¶

int xlc_fetch_allrefslockset (
    OID * oid,
    int chn,
    OID * class_oid,
    int class_chn,
    LOCK lock,
    int quit_on_errors,
    int prune_level,
    LC_LOCKSET ** lockset,
    LC_COPYAREA ** fetch_area
)

function xlocator_redistribute_partition_data¶

int xlocator_redistribute_partition_data (
    THREAD_ENTRY * thread_p,
    OID * class_oid,
    int no_oids,
    OID * oid_list
)

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