File network_interface_cl.c
FileList > communication > network_interface_cl.c
Go to the source code of this file
#include "config.h"#include <stdio.h>#include <string.h>#include <assert.h>#include <algorithm>#include "porting.h"#include "network.h"#include "network_interface_cl.h"#include "memory_alloc.h"#include "mem_block.hpp"#include "storage_common.h"#include "server_interface.h"#include "boot_cl.h"#include "schema_manager.h"#include "oid.h"#include "error_manager.h"#include "object_primitive.h"#include "object_representation.h"#include "log_comm.h"#include "log_writer.h"#include "arithmetic.h"#include "transaction_cl.h"#include "language_support.h"#include "statistics.h"#include "system_parameter.h"#include "replication.h"#include "es.h"#include "db.h"#include "db_query.h"#include "dbtype.h"#include "compile_context.h"#include "thread_manager.hpp"#include "pl_compile_handler.hpp"#include "pl_executor.hpp"#include "xasl.h"#include "lob_locator.hpp"#include "crypt_opfunc.h"#include "method_error.hpp"#include "message_catalog.h"#include "utility.h"#include "sp_constants.hpp"#include "locator_cl.h"
Public Attributes
Public Static Attributes
Public Functions
| Type |
Name |
| void |
acl_dump (FILE * outfp)
|
| int |
acl_reload ()
|
| 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 * index_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 new_db_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 new_db_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 * result_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)
|
| 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 lob_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_version_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 nparallel_process, int nparallel_process_idx)
|
| 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_copyarea)
|
| 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_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 * new_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_idp, int dbval_cnt, DB_VALUE * dbval_ptr, QUERY_FLAG flag, int query_timeout)
|
| int |
qmgr_prepare_query (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)
|
| 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)
|
| SYSPRM_ERR |
sysprm_change_server_parameters (const SYSPRM_ASSIGN_VALUE * assignments)
|
| void |
sysprm_dump_server_parameters (FILE * outfp, unsigned int in_flags, SYSPRM_DUMP_CONDITION if_cond, unsigned int out_flags, SYSPRM_DUMP_CONDITION of_cond, bool old_style)
|
| int |
sysprm_get_force_server_parameters (SYSPRM_ASSIGN_VALUE ** change_values)
|
| SYSPRM_ERR |
sysprm_obtain_server_parameters (SYSPRM_ASSIGN_VALUE ** prm_values_ptr)
|
| 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 Static Functions
Macros
Public Attributes Documentation
variable db_on_server
unsigned int db_on_server;
Public Static Attributes Documentation
variable net_Deferred_end_queries
QUERY_ID net_Deferred_end_queries[5];
variable net_Deferred_end_queries_count
int net_Deferred_end_queries_count;
Public Functions Documentation
function acl_dump
void acl_dump (
FILE * outfp
)
function acl_reload
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 * index_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 new_db_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 new_db_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
function db_local_transaction_id
int db_local_transaction_id (
DB_VALUE * result_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
)
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
)
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
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
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 lob_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_version_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 nparallel_process,
int nparallel_process_idx
)
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_copyarea
)
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_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 * new_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_idp,
int dbval_cnt,
DB_VALUE * dbval_ptr,
QUERY_FLAG flag,
int query_timeout
)
function qmgr_prepare_query
int qmgr_prepare_query (
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_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 sysprm_change_server_parameters
SYSPRM_ERR sysprm_change_server_parameters (
const SYSPRM_ASSIGN_VALUE * assignments
)
function sysprm_dump_server_parameters
void sysprm_dump_server_parameters (
FILE * outfp,
unsigned int in_flags,
SYSPRM_DUMP_CONDITION if_cond,
unsigned int out_flags,
SYSPRM_DUMP_CONDITION of_cond,
bool old_style
)
function sysprm_get_force_server_parameters
int sysprm_get_force_server_parameters (
SYSPRM_ASSIGN_VALUE ** change_values
)
function sysprm_obtain_server_parameters
SYSPRM_ERR sysprm_obtain_server_parameters (
SYSPRM_ASSIGN_VALUE ** prm_values_ptr
)
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
)
Public Static Functions Documentation
function enter_server
static THREAD_ENTRY * enter_server (
void
)
function enter_server_no_thread_entry
static void enter_server_no_thread_entry (
void
)
function exit_server
static void exit_server (
const THREAD_ENTRY & thread_ref
)
function exit_server_no_thread_entry
static void exit_server_no_thread_entry (
void
)
function is_top_level_class
static int is_top_level_class (
MOBJ mobj
)
function length_const_string
static int length_const_string (
const char * cstring,
int * strlen
)
function length_string_with_null_padding
static int length_string_with_null_padding (
int len
)
function pack_const_string
static char * pack_const_string (
char * buffer,
const char * cstring
)
function pack_const_string_with_length
static char * pack_const_string_with_length (
char * buffer,
const char * cstring,
int strlen
)
function pack_string_with_null_padding
static char * pack_string_with_null_padding (
char * buffer,
const char * stream,
int len
)
Macro Definition Documentation
define NET_COPY_AREA_SENDRECV_SIZE
#define NET_COPY_AREA_SENDRECV_SIZE `( OR_INT_SIZE * 3)`
define NET_DEFER_END_QUERIES_MAX
#define NET_DEFER_END_QUERIES_MAX `5`
define NET_SENDRECV_BUFFSIZE
#define NET_SENDRECV_BUFFSIZE `( OR_INT_SIZE )`
The documentation for this class was generated from the following file cubrid/src/communication/network_interface_cl.c