File network_interface_cl.h¶

FileList > communication > network_interface_cl.h

#include <stdio.h>
#include <vector>
#include "dbtype_def.h"
#include "lob_locator.hpp"
#include "replication.h"
#include "server_interface.h"
#include "perf_monitor.h"
#include "storage_common.h"
#include "object_domain.h"
#include "query_list.h"
#include "query_monitoring.hpp"
#include "statistics.h"
#include "connection_defs.h"
#include "log_writer.h"
#include "language_support.h"
#include "log_common_impl.h"
#include "parse_tree.h"
#include "load_common.hpp"
#include "timezone_lib_common.h"
#include "dynamic_array.h"
#include "flashback_cl.h"
#include "pl_struct_compile.hpp"
#include "pl_signature.hpp"
#include "memory_monitor_common.hpp"
#include "network_cl.h"

Classes¶

Type	Name
struct	one_tran_info
struct	trans_info

Public Types¶

Type	Name
typedef struct one_tran_info	ONE_TRAN_INFO
typedef struct trans_info	TRANS_INFO

Public Functions¶

Type	Name
void	acl_dump (FILE * outfp)
int	acl_reload (void)
VOLID	boot_add_volume_extension (DBDEF_VOL_EXT_INFO * ext_info)
int	boot_backup (const char * backup_path, FILEIO_BACKUP_LEVEL backup_level, bool delete_unneeded_logarchives, const char * backup_verbose_file, int num_threads, FILEIO_ZIP_METHOD zip_method, FILEIO_ZIP_LEVEL zip_level, int skip_activelog, int sleep_msecs, bool separate_keys)
HA_SERVER_STATE	boot_change_ha_mode (HA_SERVER_STATE state, bool force, int timeout)
int	boot_check_db_consistency (int check_flag, OID * oids, int num_oids, BTID * idx_btid)
int	boot_compact_classes (OID class_oids, int num_classes, int space_to_process, int instance_lock_timeout, int class_lock_timeout, bool delete_old_repr, OID** * last_processed_class_oid, OID * last_processed_oid, int * total_objects, int * failed_objects, int * modified_objects, int * big_objects, int * ids_repr)
int	boot_copy (const char * from_dbname, const char * new_db_name, const char * new_db_path, const char * new_log_path, const char * new_lob_path, const char * new_db_server_host, const char * new_volext_path, const char * fileof_vols_and_copypaths, bool newdb_overwrite)
int	boot_delete (const char * db_name, bool force_delete)
int	boot_emergency_patch (const char * db_name, bool recreate_log, DKNPAGES log_npages, const char * db_locale, FILE * out_fp)
VOLID	boot_find_last_permanent (void)
int	boot_find_last_temp (void)
int	boot_find_number_permanent_volumes (void)
int	boot_find_number_temp_volumes (void)
int	boot_get_server_locales (LANG_COLL_COMPAT server_collations, LANG_LOCALE_COMPAT server_locales, int * server_coll_cnt, int * server_locales_cnt)
int	boot_get_server_timezone_checksum (char * timezone_checksum)
int	boot_heap_compact (OID * class_oid)
int	boot_initialize_server (const BOOT_CLIENT_CREDENTIAL * client_credential, BOOT_DB_PATH_INFO * db_path_info, bool db_overwrite, const char * file_addmore_vols, DKNPAGES db_npages, PGLENGTH db_desired_pagesize, DKNPAGES log_npages, PGLENGTH db_desired_log_page_size, OID * rootclass_oid, HFID * rootclass_hfid, int client_lock_wait, TRAN_ISOLATION client_isolation)
int	boot_notify_ha_log_applier_state (HA_LOG_APPLIER_STATE state)
int	boot_register_client (BOOT_CLIENT_CREDENTIAL * client_credential, int client_lock_wait, TRAN_ISOLATION client_isolation, TRAN_STATE * tran_state, BOOT_SERVER_CREDENTIAL * server_credential)
int	boot_restart_from_backup (int print_restart, const char * db_name, bo_restart_arg * r_args)
bool	boot_shutdown_server (ER_FINAL_CODE iserfinal)
int	boot_soft_rename (const char * old_db_name, const char * new_db_name, const char * new_db_path, const char * new_log_path, const char * new_db_server_host, const char * new_volext_path, const char * fileof_vols_and_renamepaths, bool newdb_overwrite, bool extern_rename, bool force_delete)
int	boot_unregister_client (int tran_index)
int	btree_add_index (BTID * btid, TP_DOMAIN * key_type, OID * class_oid, int attr_id, int unique_pk, int deduplicate_key_pos)
int	btree_class_test_unique (char * buf, int buf_size)
int	btree_delete_index (BTID * btid)
BTREE_SEARCH	btree_find_multi_uniques (OID * class_oid, int pruning_type, BTID * btids, DB_VALUE * keys, int count, SCAN_OPERATION_TYPE op_type, OID oids, int** * oids_count)
BTREE_SEARCH	btree_find_unique (BTID * btid, DB_VALUE * key, OID * class_oid, OID * oid)
int	btree_get_index_key_type (BTID btid, TP_DOMAIN ** key_type_p)
int	btree_get_statistics (BTID * btid, BTREE_STATS * stat_info)
int	btree_load_index (BTID * btid, const char * bt_name, TP_DOMAIN * key_type, OID * class_oids, int n_classes, int n_attrs, int * attr_ids, int * attrs_prefix_length, HFID * hfids, int unique_pk, int not_null_flag, OID * fk_refcls_oid, BTID * fk_refcls_pk_btid, const char * fk_name, char * pred_stream, int pred_stream_size, char * expr_stream, int expr_stream_size, int func_col_id, int func_attr_index_start, SM_INDEX_STATUS index_status)
int	catalog_check_rep_dir (OID * class_id, OID * rep_dir_p)
int	chksum_insert_repl_log_and_demote_table_lock (REPL_INFO * repl_info, const OID * class_oidp)
int	clogin_user (const char * username)
int	compact_db_start (void)
int	compact_db_stop (void)
int	csession_create_prepared_statement (const char * name, const char * alias_print, char * stmt_info, int info_length)
int	csession_delete_prepared_statement (const char * name)
int	csession_drop_session_variables (DB_VALUE * variables, const int count)
int	csession_end_session (SESSION_ID session_id, bool is_keep_session)
int	csession_find_or_create_session (SESSION_ID * session_id, int * row_count, char * server_session_key, const char * db_user, const char * host, const char * program_name)
int	csession_get_last_insert_id (DB_VALUE * value, bool update_last_insert_id)
int	csession_get_prepared_statement (const char * name, XASL_ID * xasl_id, char stmt_info, xasl_node_header** * xasl_header_p)
int	csession_get_row_count (int * rows)
int	csession_get_variable (DB_VALUE * name, DB_VALUE * value)
int	csession_reset_cur_insert_id (void)
int	csession_set_row_count (int rows)
int	csession_set_session_variables (DB_VALUE * variables, const int count)
int	cvacuum (void)
int	db_local_transaction_id (DB_VALUE * trid)
DKNPAGES	disk_get_free_numpages (VOLID volid)
char *	disk_get_fullname (VOLID volid, char * vol_fullname)
char *	disk_get_remarks (VOLID volid)
DKNPAGES	disk_get_total_numpages (VOLID volid)
int	es_posix_copy_file (const char * src_path, const char * metaname, char * new_path)
int	es_posix_create_file (char * new_path)
int	es_posix_delete_file (const char * path)
off_t	es_posix_get_file_size (const char * path)
ssize_t	es_posix_read_file (const char * path, void * buf, size_t count, off_t offset)
int	es_posix_rename_file (const char * src_path, const char * metaname, char * new_path)
ssize_t	es_posix_write_file (const char * path, const void * buf, size_t count, off_t offset)
int	file_apply_tde_to_class_files (const OID * class_oid)
int	file_clean_invalid_file (int * heap, int * heap_ovf, int * btree, int * btree_ovf)
int	file_delete_target_file (const char * target_vfid_str)
int	file_dump_file_list (FILE * outfp, bool invalid_only)
int	flashback_get_and_show_summary (dynamic_array * class_list, const char * user, time_t start_time, time_t end_time, FLASHBACK_SUMMARY_INFO_MAP * summary, OID oid_list, char invalid_class, time_t * invalid_time)
int	flashback_get_loginfo (int trid, char * user, OID * classlist, int num_class, LOG_LSA * start_lsa, LOG_LSA * end_lsa, int * num_item, bool forward, char info_list, int** * invalid_class_idx)
int	heap_create (HFID * hfid, const OID * class_oid, bool reuse_oid)
int	heap_destroy (const HFID * hfid)
int	heap_destroy_newly_created (const HFID * hfid, const OID * class_oid, const bool force=false)
int	heap_get_class_num_objects_pages (HFID * hfid, int approximation, int * nobjs, int * npages)
int	heap_get_maxslotted_reclength (int & maxslotted_reclength)
int	heap_has_instance (HFID * hfid, OID * class_oid, int has_visible_instance)
int	heap_reclaim_addresses (const HFID * hfid)
int	loaddb_destroy ()
int	loaddb_fetch_status (load_status & status)
int	loaddb_init (cubload::load_args & args)
int	loaddb_install_class (const cubload::batch & batch, bool & class_is_ignored, std::string & class_name)
int	loaddb_interrupt ()
int	loaddb_load_batch (const cubload::batch & batch, bool use_temp_batch, bool & is_batch_accepted, load_status & status)
int	loaddb_update_stats (bool verbose)
int	lob_create_dir (HFID * hfid, int * attrid_arr, int attrid_arr_length)
int	lob_remove_dir (HFID * hfid, int attrid)
int	locator_assign_oid (const HFID * hfid, OID * perm_oid, int expected_length, OID * class_oid, const char * class_name)
int	locator_assign_oid_batch (LC_OIDSET * oidset)
int	locator_check_fk_validity (OID * cls_oid, HFID * hfid, TP_DOMAIN * key_type, int n_attrs, int * attr_ids, OID * pk_cls_oid, BTID * pk_btid, char * fk_name)
LC_FIND_CLASSNAME	locator_delete_class_name (const char * class_name)
int	locator_demote_class_lock (const OID * class_oid, LOCK lock, LOCK * ex_lock)
int	locator_does_exist (OID * oidp, int chn, LOCK lock, OID * class_oid, int class_chn, int need_fetching, int prefetch, LC_COPYAREA fetch_copyarea, LC_FETCH_VERSION_TYPE** fetch_version_type)
int	locator_fetch (OID * oidp, int chn, LOCK lock, LC_FETCH_VERSION_TYPE fetch_type, OID * class_oid, int class_chn, int prefetch, LC_COPYAREA ** fetch_copyarea)
int	locator_fetch_all (const HFID * hfid, LOCK * lock, LC_FETCH_VERSION_TYPE fetch_version_type, OID * class_oidp, int * nobjects, int * nfetched, OID * last_oidp, LC_COPYAREA fetch_copyarea, int request_pages, int nsplit_process, int** nselection_key)
int	locator_fetch_all_reference_lockset (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_copyarea)
int	locator_fetch_lockhint_classes (LC_LOCKHINT * lockhint, LC_COPYAREA ** fetch_area)
int	locator_fetch_lockset (LC_LOCKSET * lockset, LC_COPYAREA ** fetch_copyarea)
LC_FIND_CLASSNAME	locator_find_class_oid (const char * class_name, OID * class_oid, LOCK lock)
LC_FIND_CLASSNAME	locator_find_lockhint_class_oids (int num_classes, const char many_classnames, LOCK** * many_locks, int * many_need_subclasses, LC_PREFETCH_FLAGS * many_flags, OID * guessed_class_oids, int * guessed_class_chns, int quit_on_errors, LOCK lock_rr_tran, LC_LOCKHINT lockhint, LC_COPYAREA fetch_copyarea)
int	locator_force (LC_COPYAREA * copy_area, int num_ignore_error_list, int * ignore_error_list, int content_size)
int	locator_get_class (OID * class_oid, int class_chn, const OID * oid, LOCK lock, int prefetching, LC_COPYAREA ** fetch_copyarea)
int	locator_get_reserved_class_name_oid (const char * classname, OID * class_oid)
int	locator_log_force_nologging (void)
int	locator_notify_isolation_incons (LC_COPYAREA ** synch_copyarea)
int	locator_prefetch_repl_insert (OID * class_oid, RECDES * recdes)
int	locator_redistribute_partition_data (OID * class_oid, int no_oids, OID * oid_list)
int	locator_remove_class_from_index (OID * oid, BTID * btid, HFID * hfid)
LC_FIND_CLASSNAME	locator_rename_class_name (const char * old_name, const char * new_name, OID * class_oid)
int	locator_repl_force (LC_COPYAREA * copy_area, LC_COPYAREA ** reply_copy_area)
LC_FIND_CLASSNAME	locator_reserve_class_names (const int num_classes, const char class_names, OID** * class_oids)
int	locator_upgrade_instances_domain (OID * class_oid, int attribute_id)
void	lock_dump (FILE * outfp, int is_contention)
int	log_add_lob_locator (const char * locator, LOB_LOCATOR_STATE state)
int	log_change_state_of_locator (const char * locator, const char * real_locator, LOB_LOCATOR_STATE state)
int	log_checkpoint (void)
int	log_does_active_user_exist (const char * user_name, bool * existed)
int	log_drop_lob_locator (const char * locator)
void	log_dump_stat (FILE * outfp)
LOB_LOCATOR_STATE	log_find_lob_locator (const char * locator, char * real_locator)
int	log_get_mvcc_snapshot (void)
int	log_reset_isolation (TRAN_ISOLATION isolation)
int	log_reset_wait_msecs (int wait_msecs)
void	log_set_interrupt (int set)
int	log_set_suppress_repl_on_transaction (int set)
int	log_supplement_statement (int ddl_type, int objtype, OID * classoid, OID * objoid, const char * stmt_text)
void	logtb_dump_trantable (FILE * outfp)
void	logtb_free_trans_info (TRANS_INFO * info)
int	logtb_get_pack_tran_table (char buffer_p, int** * size_p, bool include_query_exec_info)
TRANS_INFO *	logtb_get_trans_info (bool include_query_exec_info)
int	logwr_get_log_pages (LOGWR_CONTEXT * ctx_ptr)
int	mmon_disable_force ()
int	mmon_get_server_info (MMON_SERVER_INFO & server_info)
int	netcl_spacedb (SPACEDB_ALL * spaceall, SPACEDB_ONEVOL spacevols, SPACEDB_FILES** * spacefiles)
int	perfmon_server_copy_global_stats (UINT64 * to_stats)
int	perfmon_server_copy_stats (UINT64 * to_stats)
int	perfmon_server_start_stats (void)
int	perfmon_server_stop_stats (void)
int	pl_call (const cubpl::pl_signature & sig, const std::vector< std::reference_wrapper< DB_VALUE > > & args, std::vector< DB_VALUE > & out_args, DB_VALUE & result)
int	pl_get_server_port (void)
int	plcsql_transfer_file (const PLCSQL_COMPILE_REQUEST & compile_request, PLCSQL_COMPILE_RESPONSE & compile_response)
int	qfile_get_list_file_page (QUERY_ID query_id, VOLID volid, PAGEID pageid, char * buffer, int * buffer_size)
int	qmgr_drop_all_query_plans (void)
int	qmgr_drop_query_plans_by_sha1 (char * sha1)
void	qmgr_dump_query_cache (FILE * outfp)
void	qmgr_dump_query_plans (FILE * outfp)
int	qmgr_end_query (QUERY_ID query_id)
QFILE_LIST_ID *	qmgr_execute_query (const XASL_ID * xasl_id, QUERY_ID * query_idp, int dbval_cnt, const DB_VALUE * dbvals, QUERY_FLAG flag, CACHE_TIME * clt_cache_time, CACHE_TIME * srv_cache_time, int query_timeout)
QFILE_LIST_ID *	qmgr_prepare_and_execute_query (char * xasl_stream, int xasl_stream_size, QUERY_ID * query_id, int dbval_cnt, DB_VALUE * dbval_ptr, QUERY_FLAG flag, int query_timeout)
int	qmgr_prepare_query (struct compile_context * context, xasl_stream * stream)
int	qp_get_server_info (PARSER_CONTEXT * parser, int server_info_bits)
int	qp_get_sys_timestamp (DB_VALUE * value)
BTREE_SEARCH	repl_btree_find_unique (BTID * btid, DB_VALUE * key, OID * class_oid, OID * oid)
int	repl_log_get_append_lsa (LOG_LSA * lsa)
int	repl_set_info (REPL_INFO * repl_info)
int	serial_decache (OID * oid)
int	serial_get_current_value (DB_VALUE * value, OID * oid_p, int cached_num)
int	serial_get_next_value (DB_VALUE * value, OID * oid_p, int cached_num, int num_alloc, int is_auto_increment)
int	stats_get_statistics_from_server (OID * classoid, unsigned int timestamp, int * length_ptr, char ** stats_buffer)
int	stats_update_all_statistics (int with_fullscan)
int	stats_update_statistics (MOP classop, int with_fullscan)
int	synonym_remove_xasl_by_oid (OID * oid)
int	tde_change_mk_on_server (int mk_index)
int	tde_get_mk_file_path (char * mk_path)
int	tde_get_mk_info (int * mk_index, time_t * created_time, time_t * set_time)
int	tde_is_loaded (int * is_loaded)
void	tdes_reset_query_start_info (PT_NODE * node)
void	tdes_set_query_start_info (char * sql_user_text)
void	thread_dump_cs_stat (FILE * outfp)
int	thread_kill_or_interrupt_tran (int * tran_index_list, int num_tran_index, bool is_dba_group_member, bool interrupt_only, int * num_killed)
int	thread_kill_tran_index (int kill_tran_index, char * kill_user, char * kill_host, int kill_pid)
const char *	tran_get_tranlist_state_name (TRAN_STATE state)
bool	tran_is_blocked (int tran_index)
int	tran_lock_rep_read (LOCK lock_rr_tran)
int	tran_server_2pc_attach_global_tran (int gtrid)
TRAN_STATE	tran_server_2pc_prepare (void)
TRAN_STATE	tran_server_2pc_prepare_global_tran (int gtrid)
int	tran_server_2pc_recovery_prepared (int gtrids, int size)
int	tran_server_2pc_start (void)
TRAN_STATE	tran_server_abort (void)
TRAN_STATE	tran_server_commit (bool retain_lock)
TRAN_STATE	tran_server_end_topop (LOG_RESULT_TOPOP result, LOG_LSA * topop_lsa)
int	tran_server_get_global_tran_info (int gtrid, void * buffer, int size)
int	tran_server_has_updated (void)
int	tran_server_is_active_and_has_updated (void)
TRAN_STATE	tran_server_partial_abort (const char * savept_name, LOG_LSA * savept_lsa)
int	tran_server_savepoint (const char * savept_name, LOG_LSA * savept_lsa)
int	tran_server_set_global_tran_info (int gtrid, void * info, int size)
int	tran_server_start_topop (LOG_LSA * topop_lsa)
int	tran_wait_server_active_trans (void)
void	vacuum_dump (FILE * outfp)

Public Types Documentation¶

typedef ONE_TRAN_INFO¶

typedef struct one_tran_info ONE_TRAN_INFO;

typedef TRANS_INFO¶

typedef struct trans_info TRANS_INFO;

Public Functions Documentation¶

function acl_dump¶

void acl_dump (
    FILE * outfp
)

function acl_reload¶

int acl_reload (
    void
)

function boot_add_volume_extension¶

VOLID boot_add_volume_extension (
    DBDEF_VOL_EXT_INFO * ext_info
)

function boot_backup¶

int boot_backup (
    const  char * backup_path,
    FILEIO_BACKUP_LEVEL backup_level,
    bool delete_unneeded_logarchives,
    const  char * backup_verbose_file,
    int num_threads,
    FILEIO_ZIP_METHOD zip_method,
    FILEIO_ZIP_LEVEL zip_level,
    int skip_activelog,
    int sleep_msecs,
    bool separate_keys
)

function boot_change_ha_mode¶

HA_SERVER_STATE boot_change_ha_mode (
    HA_SERVER_STATE state,
    bool force,
    int timeout
)

function boot_check_db_consistency¶

int boot_check_db_consistency (
    int check_flag,
    OID * oids,
    int num_oids,
    BTID * idx_btid
)

function boot_compact_classes¶

int boot_compact_classes (
    OID ** class_oids,
    int num_classes,
    int space_to_process,
    int instance_lock_timeout,
    int class_lock_timeout,
    bool delete_old_repr,
    OID * last_processed_class_oid,
    OID * last_processed_oid,
    int * total_objects,
    int * failed_objects,
    int * modified_objects,
    int * big_objects,
    int * ids_repr
)

function boot_copy¶

int boot_copy (
    const  char * from_dbname,
    const  char * new_db_name,
    const  char * new_db_path,
    const  char * new_log_path,
    const  char * new_lob_path,
    const  char * new_db_server_host,
    const  char * new_volext_path,
    const  char * fileof_vols_and_copypaths,
    bool newdb_overwrite
)

function boot_delete¶

int boot_delete (
    const  char * db_name,
    bool force_delete
)

function boot_emergency_patch¶

int boot_emergency_patch (
    const  char * db_name,
    bool recreate_log,
    DKNPAGES log_npages,
    const  char * db_locale,
    FILE * out_fp
)

function boot_find_last_permanent¶

VOLID boot_find_last_permanent (
    void
)

function boot_find_last_temp¶

int boot_find_last_temp (
    void
)

function boot_find_number_permanent_volumes¶

int boot_find_number_permanent_volumes (
    void
)

function boot_find_number_temp_volumes¶

int boot_find_number_temp_volumes (
    void
)

function boot_get_server_locales¶

int boot_get_server_locales (
    LANG_COLL_COMPAT ** server_collations,
    LANG_LOCALE_COMPAT ** server_locales,
    int * server_coll_cnt,
    int * server_locales_cnt
)

function boot_get_server_timezone_checksum¶

int boot_get_server_timezone_checksum (
    char * timezone_checksum
)

function boot_heap_compact¶

int boot_heap_compact (
    OID * class_oid
)

function boot_initialize_server¶

int boot_initialize_server (
    const  BOOT_CLIENT_CREDENTIAL * client_credential,
    BOOT_DB_PATH_INFO * db_path_info,
    bool db_overwrite,
    const  char * file_addmore_vols,
    DKNPAGES db_npages,
    PGLENGTH db_desired_pagesize,
    DKNPAGES log_npages,
    PGLENGTH db_desired_log_page_size,
    OID * rootclass_oid,
    HFID * rootclass_hfid,
    int client_lock_wait,
    TRAN_ISOLATION client_isolation
)

function boot_notify_ha_log_applier_state¶

int boot_notify_ha_log_applier_state (
    HA_LOG_APPLIER_STATE state
)

function boot_register_client¶

int boot_register_client (
    BOOT_CLIENT_CREDENTIAL * client_credential,
    int client_lock_wait,
    TRAN_ISOLATION client_isolation,
    TRAN_STATE * tran_state,
    BOOT_SERVER_CREDENTIAL * server_credential
)

function boot_restart_from_backup¶

int boot_restart_from_backup (
    int print_restart,
    const  char * db_name,
    bo_restart_arg * r_args
)

function boot_shutdown_server¶

bool boot_shutdown_server (
    ER_FINAL_CODE iserfinal
)

function boot_soft_rename¶

int boot_soft_rename (
    const  char * old_db_name,
    const  char * new_db_name,
    const  char * new_db_path,
    const  char * new_log_path,
    const  char * new_db_server_host,
    const  char * new_volext_path,
    const  char * fileof_vols_and_renamepaths,
    bool newdb_overwrite,
    bool extern_rename,
    bool force_delete
)

function boot_unregister_client¶

int boot_unregister_client (
    int tran_index
)

function btree_add_index¶

int btree_add_index (
    BTID * btid,
    TP_DOMAIN * key_type,
    OID * class_oid,
    int attr_id,
    int unique_pk,
    int deduplicate_key_pos
)

function btree_class_test_unique¶

int btree_class_test_unique (
    char * buf,
    int buf_size
)

function btree_delete_index¶

int btree_delete_index (
    BTID * btid
)

function btree_find_multi_uniques¶

BTREE_SEARCH btree_find_multi_uniques (
    OID * class_oid,
    int pruning_type,
    BTID * btids,
    DB_VALUE * keys,
    int count,
    SCAN_OPERATION_TYPE op_type,
    OID ** oids,
    int * oids_count
)

function btree_find_unique¶

BTREE_SEARCH btree_find_unique (
    BTID * btid,
    DB_VALUE * key,
    OID * class_oid,
    OID * oid
)

function btree_get_index_key_type¶

int btree_get_index_key_type (
    BTID btid,
    TP_DOMAIN ** key_type_p
)

function btree_get_statistics¶

int btree_get_statistics (
    BTID * btid,
    BTREE_STATS * stat_info
)

function btree_load_index¶

int btree_load_index (
    BTID * btid,
    const  char * bt_name,
    TP_DOMAIN * key_type,
    OID * class_oids,
    int n_classes,
    int n_attrs,
    int * attr_ids,
    int * attrs_prefix_length,
    HFID * hfids,
    int unique_pk,
    int not_null_flag,
    OID * fk_refcls_oid,
    BTID * fk_refcls_pk_btid,
    const  char * fk_name,
    char * pred_stream,
    int pred_stream_size,
    char * expr_stream,
    int expr_stream_size,
    int func_col_id,
    int func_attr_index_start,
    SM_INDEX_STATUS index_status
)

function catalog_check_rep_dir¶

int catalog_check_rep_dir (
    OID * class_id,
    OID * rep_dir_p
)

function chksum_insert_repl_log_and_demote_table_lock¶

int chksum_insert_repl_log_and_demote_table_lock (
    REPL_INFO * repl_info,
    const  OID * class_oidp
)

function clogin_user¶

int clogin_user (
    const  char * username
)

function compact_db_start¶

int compact_db_start (
    void
)

function compact_db_stop¶

int compact_db_stop (
    void
)

function csession_create_prepared_statement¶

int csession_create_prepared_statement (
    const  char * name,
    const  char * alias_print,
    char * stmt_info,
    int info_length
)

function csession_delete_prepared_statement¶

int csession_delete_prepared_statement (
    const  char * name
)

function csession_drop_session_variables¶

int csession_drop_session_variables (
    DB_VALUE * variables,
    const  int count
)

function csession_end_session¶

int csession_end_session (
    SESSION_ID session_id,
    bool is_keep_session
)

function csession_find_or_create_session¶

int csession_find_or_create_session (
    SESSION_ID * session_id,
    int * row_count,
    char * server_session_key,
    const  char * db_user,
    const  char * host,
    const  char * program_name
)

function csession_get_last_insert_id¶

int csession_get_last_insert_id (
    DB_VALUE * value,
    bool update_last_insert_id
)

function csession_get_prepared_statement¶

int csession_get_prepared_statement (
    const  char * name,
    XASL_ID * xasl_id,
    char ** stmt_info,
    xasl_node_header * xasl_header_p
)

function csession_get_row_count¶

int csession_get_row_count (
    int * rows
)

function csession_get_variable¶

int csession_get_variable (
    DB_VALUE * name,
    DB_VALUE * value
)

function csession_reset_cur_insert_id¶

int csession_reset_cur_insert_id (
    void
)

function csession_set_row_count¶

int csession_set_row_count (
    int rows
)

function csession_set_session_variables¶

int csession_set_session_variables (
    DB_VALUE * variables,
    const  int count
)

function cvacuum¶

int cvacuum (
    void
)

function db_local_transaction_id¶

int db_local_transaction_id (
    DB_VALUE * trid
)

function disk_get_free_numpages¶

DKNPAGES disk_get_free_numpages (
    VOLID volid
)

function disk_get_fullname¶

char * disk_get_fullname (
    VOLID volid,
    char * vol_fullname
)

function disk_get_remarks¶

char * disk_get_remarks (
    VOLID volid
)

function disk_get_total_numpages¶

DKNPAGES disk_get_total_numpages (
    VOLID volid
)

function es_posix_copy_file¶

int es_posix_copy_file (
    const  char * src_path,
    const  char * metaname,
    char * new_path
)

function es_posix_create_file¶

int es_posix_create_file (
    char * new_path
)

function es_posix_delete_file¶

int es_posix_delete_file (
    const  char * path
)

function es_posix_get_file_size¶

off_t es_posix_get_file_size (
    const  char * path
)

function es_posix_read_file¶

ssize_t es_posix_read_file (
    const  char * path,
    void * buf,
    size_t count,
    off_t offset
)

function es_posix_rename_file¶

int es_posix_rename_file (
    const  char * src_path,
    const  char * metaname,
    char * new_path
)

function es_posix_write_file¶

ssize_t es_posix_write_file (
    const  char * path,
    const  void * buf,
    size_t count,
    off_t offset
)

function file_apply_tde_to_class_files¶

int file_apply_tde_to_class_files (
    const  OID * class_oid
)

function file_clean_invalid_file¶

int file_clean_invalid_file (
    int * heap,
    int * heap_ovf,
    int * btree,
    int * btree_ovf
)

function file_delete_target_file¶

int file_delete_target_file (
    const  char * target_vfid_str
)

function file_dump_file_list¶

int file_dump_file_list (
    FILE * outfp,
    bool invalid_only
)

function flashback_get_and_show_summary¶

int flashback_get_and_show_summary (
    dynamic_array * class_list,
    const  char * user,
    time_t start_time,
    time_t end_time,
    FLASHBACK_SUMMARY_INFO_MAP * summary,
    OID ** oid_list,
    char ** invalid_class,
    time_t * invalid_time
)

function flashback_get_loginfo¶

int flashback_get_loginfo (
    int trid,
    char * user,
    OID * classlist,
    int num_class,
    LOG_LSA * start_lsa,
    LOG_LSA * end_lsa,
    int * num_item,
    bool forward,
    char ** info_list,
    int * invalid_class_idx
)

function heap_create¶

int heap_create (
    HFID * hfid,
    const  OID * class_oid,
    bool reuse_oid
)

function heap_destroy¶

int heap_destroy (
    const  HFID * hfid
)

function heap_destroy_newly_created¶

int heap_destroy_newly_created (
    const  HFID * hfid,
    const  OID * class_oid,
    const  bool force=false
)

function heap_get_class_num_objects_pages¶

int heap_get_class_num_objects_pages (
    HFID * hfid,
    int approximation,
    int * nobjs,
    int * npages
)

function heap_get_maxslotted_reclength¶

int heap_get_maxslotted_reclength (
    int & maxslotted_reclength
)

function heap_has_instance¶

int heap_has_instance (
    HFID * hfid,
    OID * class_oid,
    int has_visible_instance
)

function heap_reclaim_addresses¶

int heap_reclaim_addresses (
    const  HFID * hfid
)

function loaddb_destroy¶

int loaddb_destroy ()

function loaddb_fetch_status¶

int loaddb_fetch_status (
    load_status & status
)

function loaddb_init¶

int loaddb_init (
    cubload::load_args & args
)

function loaddb_install_class¶

int loaddb_install_class (
    const  cubload::batch & batch,
    bool & class_is_ignored,
    std::string & class_name
)

function loaddb_interrupt¶

int loaddb_interrupt ()

function loaddb_load_batch¶

int loaddb_load_batch (
    const  cubload::batch & batch,
    bool use_temp_batch,
    bool & is_batch_accepted,
    load_status & status
)

function loaddb_update_stats¶

int loaddb_update_stats (
    bool verbose
)

function lob_create_dir¶

int lob_create_dir (
    HFID * hfid,
    int * attrid_arr,
    int attrid_arr_length
)

function lob_remove_dir¶

int lob_remove_dir (
    HFID * hfid,
    int attrid
)

function locator_assign_oid¶

int locator_assign_oid (
    const  HFID * hfid,
    OID * perm_oid,
    int expected_length,
    OID * class_oid,
    const  char * class_name
)

function locator_assign_oid_batch¶

int locator_assign_oid_batch (
    LC_OIDSET * oidset
)

function locator_check_fk_validity¶

int locator_check_fk_validity (
    OID * cls_oid,
    HFID * hfid,
    TP_DOMAIN * key_type,
    int n_attrs,
    int * attr_ids,
    OID * pk_cls_oid,
    BTID * pk_btid,
    char * fk_name
)

function locator_delete_class_name¶

LC_FIND_CLASSNAME locator_delete_class_name (
    const  char * class_name
)

function locator_demote_class_lock¶

int locator_demote_class_lock (
    const  OID * class_oid,
    LOCK lock,
    LOCK * ex_lock
)

function locator_does_exist¶

int locator_does_exist (
    OID * oidp,
    int chn,
    LOCK lock,
    OID * class_oid,
    int class_chn,
    int need_fetching,
    int prefetch,
    LC_COPYAREA ** fetch_copyarea,
    LC_FETCH_VERSION_TYPE fetch_version_type
)

function locator_fetch¶

int locator_fetch (
    OID * oidp,
    int chn,
    LOCK lock,
    LC_FETCH_VERSION_TYPE fetch_type,
    OID * class_oid,
    int class_chn,
    int prefetch,
    LC_COPYAREA ** fetch_copyarea
)

function locator_fetch_all¶

int locator_fetch_all (
    const  HFID * hfid,
    LOCK * lock,
    LC_FETCH_VERSION_TYPE fetch_version_type,
    OID * class_oidp,
    int * nobjects,
    int * nfetched,
    OID * last_oidp,
    LC_COPYAREA ** fetch_copyarea,
    int request_pages,
    int nsplit_process,
    int nselection_key
)

function locator_fetch_all_reference_lockset¶

int locator_fetch_all_reference_lockset (
    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_copyarea
)

function locator_fetch_lockhint_classes¶

int locator_fetch_lockhint_classes (
    LC_LOCKHINT * lockhint,
    LC_COPYAREA ** fetch_area
)

function locator_fetch_lockset¶

int locator_fetch_lockset (
    LC_LOCKSET * lockset,
    LC_COPYAREA ** fetch_copyarea
)

function locator_find_class_oid¶

LC_FIND_CLASSNAME locator_find_class_oid (
    const  char * class_name,
    OID * class_oid,
    LOCK lock
)

function locator_find_lockhint_class_oids¶

LC_FIND_CLASSNAME locator_find_lockhint_class_oids (
    int num_classes,
    const  char ** many_classnames,
    LOCK * many_locks,
    int * many_need_subclasses,
    LC_PREFETCH_FLAGS * many_flags,
    OID * guessed_class_oids,
    int * guessed_class_chns,
    int quit_on_errors,
    LOCK lock_rr_tran,
    LC_LOCKHINT ** lockhint,
    LC_COPYAREA ** fetch_copyarea
)

function locator_force¶

int locator_force (
    LC_COPYAREA * copy_area,
    int num_ignore_error_list,
    int * ignore_error_list,
    int content_size
)

function locator_get_class¶

int locator_get_class (
    OID * class_oid,
    int class_chn,
    const  OID * oid,
    LOCK lock,
    int prefetching,
    LC_COPYAREA ** fetch_copyarea
)

function locator_get_reserved_class_name_oid¶

int locator_get_reserved_class_name_oid (
    const  char * classname,
    OID * class_oid
)

function locator_log_force_nologging¶

int locator_log_force_nologging (
    void
)

function locator_notify_isolation_incons¶

int locator_notify_isolation_incons (
    LC_COPYAREA ** synch_copyarea
)

function locator_prefetch_repl_insert¶

int locator_prefetch_repl_insert (
    OID * class_oid,
    RECDES * recdes
)

function locator_redistribute_partition_data¶

int locator_redistribute_partition_data (
    OID * class_oid,
    int no_oids,
    OID * oid_list
)

function locator_remove_class_from_index¶

int locator_remove_class_from_index (
    OID * oid,
    BTID * btid,
    HFID * hfid
)

function locator_rename_class_name¶

LC_FIND_CLASSNAME locator_rename_class_name (
    const  char * old_name,
    const  char * new_name,
    OID * class_oid
)

function locator_repl_force¶

int locator_repl_force (
    LC_COPYAREA * copy_area,
    LC_COPYAREA ** reply_copy_area
)

function locator_reserve_class_names¶

LC_FIND_CLASSNAME locator_reserve_class_names (
    const  int num_classes,
    const  char ** class_names,
    OID * class_oids
)

function locator_upgrade_instances_domain¶

int locator_upgrade_instances_domain (
    OID * class_oid,
    int attribute_id
)

function lock_dump¶

void lock_dump (
    FILE * outfp,
    int is_contention
)

function log_add_lob_locator¶

int log_add_lob_locator (
    const  char * locator,
    LOB_LOCATOR_STATE state
)

function log_change_state_of_locator¶

int log_change_state_of_locator (
    const  char * locator,
    const  char * real_locator,
    LOB_LOCATOR_STATE state
)

function log_checkpoint¶

int log_checkpoint (
    void
)

function log_does_active_user_exist¶

int log_does_active_user_exist (
    const  char * user_name,
    bool * existed
)

function log_drop_lob_locator¶

int log_drop_lob_locator (
    const  char * locator
)

function log_dump_stat¶

void log_dump_stat (
    FILE * outfp
)

function log_find_lob_locator¶

LOB_LOCATOR_STATE log_find_lob_locator (
    const  char * locator,
    char * real_locator
)

function log_get_mvcc_snapshot¶

int log_get_mvcc_snapshot (
    void
)

function log_reset_isolation¶

int log_reset_isolation (
    TRAN_ISOLATION isolation
)

function log_reset_wait_msecs¶

int log_reset_wait_msecs (
    int wait_msecs
)

function log_set_interrupt¶

void log_set_interrupt (
    int set
)

function log_set_suppress_repl_on_transaction¶

int log_set_suppress_repl_on_transaction (
    int set
)

function log_supplement_statement¶

int log_supplement_statement (
    int ddl_type,
    int objtype,
    OID * classoid,
    OID * objoid,
    const  char * stmt_text
)

function logtb_dump_trantable¶

void logtb_dump_trantable (
    FILE * outfp
)

function logtb_free_trans_info¶

void logtb_free_trans_info (
    TRANS_INFO * info
)

function logtb_get_pack_tran_table¶

int logtb_get_pack_tran_table (
    char ** buffer_p,
    int * size_p,
    bool include_query_exec_info
)

function logtb_get_trans_info¶

TRANS_INFO * logtb_get_trans_info (
    bool include_query_exec_info
)

function logwr_get_log_pages¶

int logwr_get_log_pages (
    LOGWR_CONTEXT * ctx_ptr
)

function mmon_disable_force¶

int mmon_disable_force ()

function mmon_get_server_info¶

int mmon_get_server_info (
    MMON_SERVER_INFO & server_info
)

function netcl_spacedb¶

int netcl_spacedb (
    SPACEDB_ALL * spaceall,
    SPACEDB_ONEVOL ** spacevols,
    SPACEDB_FILES * spacefiles
)

function perfmon_server_copy_global_stats¶

int perfmon_server_copy_global_stats (
    UINT64 * to_stats
)

function perfmon_server_copy_stats¶

int perfmon_server_copy_stats (
    UINT64 * to_stats
)

function perfmon_server_start_stats¶

int perfmon_server_start_stats (
    void
)

function perfmon_server_stop_stats¶

int perfmon_server_stop_stats (
    void
)

function pl_call¶

int pl_call (
    const  cubpl::pl_signature & sig,
    const std::vector< std::reference_wrapper < DB_VALUE > > & args,
    std::vector< DB_VALUE > & out_args,
    DB_VALUE & result
)

function pl_get_server_port¶

int pl_get_server_port (
    void
)

function plcsql_transfer_file¶

int plcsql_transfer_file (
    const  PLCSQL_COMPILE_REQUEST & compile_request,
    PLCSQL_COMPILE_RESPONSE & compile_response
)

function qfile_get_list_file_page¶

int qfile_get_list_file_page (
    QUERY_ID query_id,
    VOLID volid,
    PAGEID pageid,
    char * buffer,
    int * buffer_size
)

function qmgr_drop_all_query_plans¶

int qmgr_drop_all_query_plans (
    void
)

function qmgr_drop_query_plans_by_sha1¶

int qmgr_drop_query_plans_by_sha1 (
    char * sha1
)

function qmgr_dump_query_cache¶

void qmgr_dump_query_cache (
    FILE * outfp
)

function qmgr_dump_query_plans¶

void qmgr_dump_query_plans (
    FILE * outfp
)

function qmgr_end_query¶

int qmgr_end_query (
    QUERY_ID query_id
)

function qmgr_execute_query¶

QFILE_LIST_ID * qmgr_execute_query (
    const  XASL_ID * xasl_id,
    QUERY_ID * query_idp,
    int dbval_cnt,
    const  DB_VALUE * dbvals,
    QUERY_FLAG flag,
    CACHE_TIME * clt_cache_time,
    CACHE_TIME * srv_cache_time,
    int query_timeout
)

function qmgr_prepare_and_execute_query¶

QFILE_LIST_ID * qmgr_prepare_and_execute_query (
    char * xasl_stream,
    int xasl_stream_size,
    QUERY_ID * query_id,
    int dbval_cnt,
    DB_VALUE * dbval_ptr,
    QUERY_FLAG flag,
    int query_timeout
)

function qmgr_prepare_query¶

int qmgr_prepare_query (
    struct  compile_context * context,
    xasl_stream * stream
)

function qp_get_server_info¶

int qp_get_server_info (
    PARSER_CONTEXT * parser,
    int server_info_bits
)

function qp_get_sys_timestamp¶

int qp_get_sys_timestamp (
    DB_VALUE * value
)

function repl_btree_find_unique¶

BTREE_SEARCH repl_btree_find_unique (
    BTID * btid,
    DB_VALUE * key,
    OID * class_oid,
    OID * oid
)

function repl_log_get_append_lsa¶

int repl_log_get_append_lsa (
    LOG_LSA * lsa
)

function repl_set_info¶

int repl_set_info (
    REPL_INFO * repl_info
)

function serial_decache¶

int serial_decache (
    OID * oid
)

function serial_get_current_value¶

int serial_get_current_value (
    DB_VALUE * value,
    OID * oid_p,
    int cached_num
)

function serial_get_next_value¶

int serial_get_next_value (
    DB_VALUE * value,
    OID * oid_p,
    int cached_num,
    int num_alloc,
    int is_auto_increment
)

function stats_get_statistics_from_server¶

int stats_get_statistics_from_server (
    OID * classoid,
    unsigned  int timestamp,
    int * length_ptr,
    char ** stats_buffer
)

function stats_update_all_statistics¶

int stats_update_all_statistics (
    int with_fullscan
)

function stats_update_statistics¶

int stats_update_statistics (
    MOP classop,
    int with_fullscan
)

function synonym_remove_xasl_by_oid¶

int synonym_remove_xasl_by_oid (
    OID * oid
)

function tde_change_mk_on_server¶

int tde_change_mk_on_server (
    int mk_index
)

function tde_get_mk_file_path¶

int tde_get_mk_file_path (
    char * mk_path
)

function tde_get_mk_info¶

int tde_get_mk_info (
    int * mk_index,
    time_t * created_time,
    time_t * set_time
)

function tde_is_loaded¶

int tde_is_loaded (
    int * is_loaded
)

function tdes_reset_query_start_info¶

void tdes_reset_query_start_info (
    PT_NODE * node
)

function tdes_set_query_start_info¶

void tdes_set_query_start_info (
    char * sql_user_text
)

function thread_dump_cs_stat¶

void thread_dump_cs_stat (
    FILE * outfp
)

function thread_kill_or_interrupt_tran¶

int thread_kill_or_interrupt_tran (
    int * tran_index_list,
    int num_tran_index,
    bool is_dba_group_member,
    bool interrupt_only,
    int * num_killed
)

function thread_kill_tran_index¶

int thread_kill_tran_index (
    int kill_tran_index,
    char * kill_user,
    char * kill_host,
    int kill_pid
)

function tran_get_tranlist_state_name¶

const  char * tran_get_tranlist_state_name (
    TRAN_STATE state
)

function tran_is_blocked¶

bool tran_is_blocked (
    int tran_index
)

function tran_lock_rep_read¶

int tran_lock_rep_read (
    LOCK lock_rr_tran
)

function tran_server_2pc_attach_global_tran¶

int tran_server_2pc_attach_global_tran (
    int gtrid
)

function tran_server_2pc_prepare¶

TRAN_STATE tran_server_2pc_prepare (
    void
)

function tran_server_2pc_prepare_global_tran¶

TRAN_STATE tran_server_2pc_prepare_global_tran (
    int gtrid
)

function tran_server_2pc_recovery_prepared¶

int tran_server_2pc_recovery_prepared (
    int gtrids,
    int size
)

function tran_server_2pc_start¶

int tran_server_2pc_start (
    void
)

function tran_server_abort¶

TRAN_STATE tran_server_abort (
    void
)

function tran_server_commit¶

TRAN_STATE tran_server_commit (
    bool retain_lock
)

function tran_server_end_topop¶

TRAN_STATE tran_server_end_topop (
    LOG_RESULT_TOPOP result,
    LOG_LSA * topop_lsa
)

function tran_server_get_global_tran_info¶

int tran_server_get_global_tran_info (
    int gtrid,
    void * buffer,
    int size
)

function tran_server_has_updated¶

int tran_server_has_updated (
    void
)

function tran_server_is_active_and_has_updated¶

int tran_server_is_active_and_has_updated (
    void
)

function tran_server_partial_abort¶

TRAN_STATE tran_server_partial_abort (
    const  char * savept_name,
    LOG_LSA * savept_lsa
)

function tran_server_savepoint¶

int tran_server_savepoint (
    const  char * savept_name,
    LOG_LSA * savept_lsa
)

function tran_server_set_global_tran_info¶

int tran_server_set_global_tran_info (
    int gtrid,
    void * info,
    int size
)

function tran_server_start_topop¶

int tran_server_start_topop (
    LOG_LSA * topop_lsa
)

function tran_wait_server_active_trans¶

int tran_wait_server_active_trans (
    void
)

function vacuum_dump¶

void vacuum_dump (
    FILE * outfp
)

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