File xserver_interface.h
FileList > base > xserver_interface.h
Go to the source code of this file
#include "boot.h"
#include "config.h"
#include "error_manager.h"
#include "file_io.h"
#include "intl_support.h"
#include "locator.h"
#include "log_comm.h"
#include "log_lsa.hpp"
#include "query_list.h"
#include "query_manager.h"
#include "perf_monitor.h"
#include "replication.h"
#include "storage_common.h"
#include "thread_compat.hpp"
#include <vector>
Public Functions
| Type |
Name |
| int |
disk_get_boot_db_charset (THREAD_ENTRY * thread_p, INT16 volid, INTL_CODESET * db_charset)
|
| float |
log_get_db_compatibility (void)
|
| LOG_LSA * |
log_get_final_restored_lsa (void)
|
| bool |
log_is_no_logging (void)
|
| int |
log_set_no_logging (void)
|
| bool |
logtb_has_updated (THREAD_ENTRY * thread_p)
|
| void |
xacl_dump (THREAD_ENTRY * thread_p, FILE * outfp)
|
| int |
xacl_reload (THREAD_ENTRY * thread_p)
|
| VOLID |
xboot_add_volume_extension (THREAD_ENTRY * thread_p, DBDEF_VOL_EXT_INFO * ext_info)
|
| int |
xboot_backup (THREAD_ENTRY * thread_p, 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)
|
| int |
xboot_check_db_consistency (THREAD_ENTRY * thread_p, int check_flag, OID * oids, int num_oids, BTID * index_btid)
|
| DISK_ISVALID |
xboot_checkdb_table (THREAD_ENTRY * thread_p, int check_flag, OID * oid, BTID * index_btid)
|
| int |
xboot_compact_db (THREAD_ENTRY * thread_p, OID * class_oids, int n_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 * initial_last_repr_id)
|
| int |
xboot_compact_start (THREAD_ENTRY * thread_p)
|
| int |
xboot_compact_stop (THREAD_ENTRY * thread_p)
|
| VOLID |
xboot_find_last_permanent (THREAD_ENTRY * thread_p)
|
| VOLID |
xboot_find_last_temp (THREAD_ENTRY * thread_p)
|
| int |
xboot_find_number_permanent_volumes (THREAD_ENTRY * thread_p)
|
| int |
xboot_find_number_temp_volumes (THREAD_ENTRY * thread_p)
|
| const char * |
xboot_get_server_session_key (void)
|
| int |
xboot_heap_compact (THREAD_ENTRY * thread_p, OID * class_oid)
|
| int |
xboot_initialize_server (const BOOT_CLIENT_CREDENTIAL * client_credential, BOOT_DB_PATH_INFO * db_path_info, bool db_overwrite, const char * file_addmore_vols, volatile DKNPAGES db_npages, PGLENGTH db_desired_pagesize, volatile DKNPAGES xlog_npages, PGLENGTH db_desired_log_page_size, OID * rootclass_oid, HFID * rootclass_hfid, int client_lock_wait, TRAN_ISOLATION client_isolation)
|
| VOLID |
xboot_peek_last_permanent (THREAD_ENTRY * thread_p)
|
| int |
xboot_register_client (THREAD_ENTRY * thread_p, BOOT_CLIENT_CREDENTIAL * client_credential, int client_lock_wait, TRAN_ISOLATION client_isolation, TRAN_STATE * tran_state, BOOT_SERVER_CREDENTIAL * server_credential)
|
| int |
xboot_unregister_client (THREAD_ENTRY *& thread_p, int tran_index)
|
| BTID * |
xbtree_add_index (THREAD_ENTRY * thread_p, BTID * btid, TP_DOMAIN * key_type, OID * class_oid, int attr_id, int unique_pk, long long num_oids, long long num_nulls, long long num_keys, int deduplicate_key_pos)
|
| int |
xbtree_class_test_unique (THREAD_ENTRY * thread_p, char * buf, int buf_size)
|
| int |
xbtree_delete_index (THREAD_ENTRY * thread_p, BTID * btid)
|
| BTREE_SEARCH |
xbtree_find_multi_uniques (THREAD_ENTRY * thread_p, OID * class_oid, int pruning_type, BTID * btids, DB_VALUE * values, int count, SCAN_OPERATION_TYPE op_type, OID ** oids, int * oids_count)
|
| BTREE_SEARCH |
xbtree_find_unique (THREAD_ENTRY * thread_p, BTID * btid, SCAN_OPERATION_TYPE scan_op_type, DB_VALUE * key, OID * class_oid, OID * oid, bool is_all_class_srch)
|
| BTID * |
xbtree_load_index (THREAD_ENTRY * thread_p, 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_steram_size, int func_col_id, int func_attr_index_start)
|
| BTID * |
xbtree_load_online_index (THREAD_ENTRY * thread_p, 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_steram_size, int func_col_id, int func_attr_index_start, int ib_thread_count)
|
| int |
xcatalog_check_rep_dir (THREAD_ENTRY * thread_p, OID * class_id, OID * rep_dir_p)
|
| int |
xchksum_insert_repl_log_and_demote_table_lock (THREAD_ENTRY * thread_p, REPL_INFO * repl_info, const OID * class_oidp)
|
| DKNPAGES |
xdisk_get_free_numpages (THREAD_ENTRY * thread_p, VOLID volid)
|
| char * |
xdisk_get_fullname (THREAD_ENTRY * thread_p, VOLID volid, char * vol_fullname)
|
| DISK_VOLPURPOSE |
xdisk_get_purpose (THREAD_ENTRY * thread_p, VOLID volid)
|
| int |
xdisk_get_purpose_and_space_info (THREAD_ENTRY * thread_p, VOLID volid, DISK_VOLPURPOSE * vol_purpose, DISK_VOLUME_SPACE_INFO * space_info)
|
| char * |
xdisk_get_remarks (THREAD_ENTRY * thread_p, VOLID volid)
|
| DKNPAGES |
xdisk_get_total_numpages (THREAD_ENTRY * thread_p, VOLID volid)
|
| bool |
xdisk_is_volume_exist (THREAD_ENTRY * thread_p, VOLID volid)
|
| EHID * |
xehash_create (THREAD_ENTRY * thread_p, EHID * ehid, DB_TYPE key_type, int exp_num_entries, OID * class_oid, int attr_id, bool is_tmp)
|
| int |
xehash_destroy (THREAD_ENTRY * thread_p, EHID * ehid)
|
| int |
xfile_apply_tde_to_class_files (THREAD_ENTRY * thread_p, const OID * class_oid)
|
| int |
xfile_tracker_clean_invalid_file (THREAD_ENTRY * thread_p, int * heap, int * heap_ovf, int * btree, int * btree_ovf)
|
| int |
xfile_tracker_delete_target_file (THREAD_ENTRY * thread_p, const char * target_vfid_str)
|
| int |
xfile_tracker_dump_file_list (THREAD_ENTRY * thread_p, FILE * outfp, bool invalid_only)
|
| int |
xheap_create (THREAD_ENTRY * thread_p, HFID * hfid, const OID * class_oid, bool reuse_oid)
|
| int |
xheap_destroy (THREAD_ENTRY * thread_p, const HFID * hfid, const OID * class_oid)
|
| int |
xheap_destroy_newly_created (THREAD_ENTRY * thread_p, const HFID * hfid, const OID * class_oid, const bool force=false)
|
| int |
xlob_create_dir (THREAD_ENTRY * thread_p, HFID * hfid, int * attrid_arr, int attrid_arr_length)
|
| int |
xlob_remove_dir (THREAD_ENTRY * thread_p, HFID * hfid, int attrid)
|
| int |
xlocator_assign_oid (THREAD_ENTRY * thread_p, const HFID * hfid, OID * perm_oid, int expected_length, OID * class_oid, const char * classname)
|
| int |
xlocator_assign_oid_batch (THREAD_ENTRY * thread_p, LC_OIDSET * oidset)
|
| int |
xlocator_check_fk_validity (THREAD_ENTRY * thread_p, 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 |
xlocator_delete_class_name (THREAD_ENTRY * thread_p, const char * classname)
|
| int |
xlocator_demote_class_lock (THREAD_ENTRY * thread_p, const OID * class_oid, LOCK lock, LOCK * ex_lock)
|
| int |
xlocator_does_exist (THREAD_ENTRY * thread_p, OID * oid, int chn, LOCK lock, LC_FETCH_VERSION_TYPE fetch_version_type, OID * class_oid, int class_chn, int need_fetching, int prefetching, LC_COPYAREA ** fetch_area)
|
| int |
xlocator_fetch (THREAD_ENTRY * thrd, OID * oid, int chn, LOCK lock, LC_FETCH_VERSION_TYPE fetch_version_type, LC_FETCH_VERSION_TYPE initial_fetch_version_type, OID * class_oid, int class_chn, int prefetching, LC_COPYAREA ** fetch_area)
|
| int |
xlocator_fetch_all (THREAD_ENTRY * thread_p, const HFID * hfid, LOCK * lock, LC_FETCH_VERSION_TYPE fetch_type, OID * class_oid, int * nobjects, int * nfetched, OID * last_oid, LC_COPYAREA ** fetch_area, int request_pages)
|
| int |
xlocator_fetch_all_reference_lockset (THREAD_ENTRY * thread_p, 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_fetch_lockhint_classes (THREAD_ENTRY * thread_p, LC_LOCKHINT * lockhint, LC_COPYAREA ** fetch_area)
|
| int |
xlocator_fetch_lockset (THREAD_ENTRY * thread_p, LC_LOCKSET * lockset, LC_COPYAREA ** fetch_area)
|
| LC_FIND_CLASSNAME |
xlocator_find_class_oid (THREAD_ENTRY * thread_p, const char * classname, OID * class_oid, LOCK lock)
|
| LC_FIND_CLASSNAME |
xlocator_find_lockhint_class_oids (THREAD_ENTRY * thread_p, 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, bool quit_on_errors, LC_LOCKHINT ** hlock, LC_COPYAREA ** fetch_area)
|
| int |
xlocator_force (THREAD_ENTRY * thread_p, LC_COPYAREA * copy_area, int num_ignore_error_list, int * ignore_error_list)
|
| int |
xlocator_get_class (THREAD_ENTRY * thread_p, OID * class_oid, int class_chn, const OID * oid, LOCK lock, int prefetching, LC_COPYAREA ** fetch_area)
|
| int |
xlocator_get_reserved_class_name_oid (THREAD_ENTRY * thread_p, const char * classname, OID * class_oid)
|
| int |
xlocator_lock_and_fetch_all (THREAD_ENTRY * thread_p, const HFID * hfid, LOCK * instance_lock, int * instance_lock_timeout, OID * class_oid, LOCK * class_lock, int * nobjects, int * nfetched, int * nfailed_instance_locks, OID * last_oid, LC_COPYAREA ** fetch_area, MVCC_SNAPSHOT * mvcc_snapshot)
|
| bool |
xlocator_notify_isolation_incons (THREAD_ENTRY * thread_p, LC_COPYAREA ** synch_area)
|
| int |
xlocator_remove_class_from_index (THREAD_ENTRY * thread_p, OID * oid, BTID * btid, HFID * hfid)
|
| LC_FIND_CLASSNAME |
xlocator_rename_class_name (THREAD_ENTRY * thread_p, const char * oldname, const char * newname, OID * class_oid)
|
| int |
xlocator_repl_force (THREAD_ENTRY * thread_p, LC_COPYAREA * copy_area, LC_COPYAREA ** reply_area)
|
| LC_FIND_CLASSNAME |
xlocator_reserve_class_names (THREAD_ENTRY * thread_p, const int num_classes, const char ** classname, OID * class_oid)
|
| int |
xlocator_upgrade_instances_domain (THREAD_ENTRY * thread_p, OID * class_oid, int att_id)
|
| void |
xlock_dump (THREAD_ENTRY * thread_p, FILE * outfp, int is_contention)
|
| int |
xlogin_user (THREAD_ENTRY * thread_p, const char * username)
|
| bool |
xlogtb_does_active_user_exist (THREAD_ENTRY * thread_p, const char * user_name)
|
| int |
xlogtb_get_pack_tran_table (THREAD_ENTRY * thread_p, char ** buffer_p, int * size_p, int include_query_exec_info)
|
| int |
xlogtb_reset_isolation (THREAD_ENTRY * thread_p, TRAN_ISOLATION isolation)
|
| int |
xlogtb_reset_wait_msecs (THREAD_ENTRY * thread_p, int wait_msecs)
|
| void |
xlogtb_set_interrupt (THREAD_ENTRY * thread_p, int set)
|
| void |
xlogtb_set_suppress_repl_on_transaction (THREAD_ENTRY * thread_p, int set)
|
| void |
xperfmon_server_copy_global_stats (UINT64 * to_stats)
|
| void |
xperfmon_server_copy_stats (THREAD_ENTRY * thread_p, UINT64 * to_stats, bool need_pgbuf_stat)
|
| void |
xperfmon_server_copy_stats_for_trace (THREAD_ENTRY * thread_p, UINT64 * to_stats)
|
| int |
xqfile_get_list_file_page (THREAD_ENTRY * thread_p, QUERY_ID query_id, VOLID volid, PAGEID pageid, char * page_bufp, int * page_sizep)
|
| int |
xqmgr_drop_all_query_plans (THREAD_ENTRY * thread_p)
|
| int |
xqmgr_drop_query_plans_by_sha1 (THREAD_ENTRY * thread_p, char * sha1)
|
| void |
xqmgr_dump_query_cache (THREAD_ENTRY * thread_p, FILE * outfp)
|
| void |
xqmgr_dump_query_plans (THREAD_ENTRY * thread_p, FILE * outfp)
|
| int |
xqmgr_end_query (THREAD_ENTRY * thrd, QUERY_ID query_id)
|
| QFILE_LIST_ID * |
xqmgr_execute_query (THREAD_ENTRY * thrd, const XASL_ID * xasl_id, QUERY_ID * query_idp, int dbval_cnt, void * data, QUERY_FLAG * flagp, CACHE_TIME * clt_cache_time, CACHE_TIME * srv_cache_time, int query_timeout, xasl_cache_ent ** ret_cache_entry_p)
|
| QFILE_LIST_ID * |
xqmgr_prepare_and_execute_query (THREAD_ENTRY * thrd, char * xasl_stream, int xasl_stream_size, QUERY_ID * query_id, int dbval_cnt, void * data, QUERY_FLAG * flag, int query_timeout)
|
| int |
xqmgr_prepare_query (THREAD_ENTRY * thrd, compile_context * ctx, xasl_stream * stream)
|
| LOG_LSA * |
xrepl_log_get_append_lsa (void)
|
| int |
xrepl_set_info (THREAD_ENTRY * thread_p, REPL_INFO * repl_info)
|
| int |
xsession_check_session (THREAD_ENTRY * thread_p, const SESSION_ID id)
|
| int |
xsession_clear_query_entry_info (THREAD_ENTRY * thread_p, const QUERY_ID query_id)
|
| int |
xsession_create_new (THREAD_ENTRY * thread_p, SESSION_ID * id)
|
| int |
xsession_create_prepared_statement (THREAD_ENTRY * thread_p, char * name, char * alias_print, SHA1Hash * sha1, char * info, int info_len)
|
| int |
xsession_delete_prepared_statement (THREAD_ENTRY * thread_p, const char * name)
|
| int |
xsession_drop_session_variables (THREAD_ENTRY * thread_p, DB_VALUE * values, const int count)
|
| int |
xsession_end_session (THREAD_ENTRY * thread, const SESSION_ID id, bool is_keep_session)
|
| int |
xsession_get_last_insert_id (THREAD_ENTRY * thread_p, DB_VALUE * value, bool update_last_insert_id)
|
| int |
xsession_get_prepared_statement (THREAD_ENTRY * thread_p, const char * name, char ** info, int * info_len, XASL_ID * xasl_id, xasl_node_header * xasl_header_p)
|
| int |
xsession_get_row_count (THREAD_ENTRY * thread_p, int * row_count)
|
| int |
xsession_get_session_variable (THREAD_ENTRY * thread_p, const DB_VALUE * name, DB_VALUE * value)
|
| int |
xsession_get_session_variable_no_copy (THREAD_ENTRY * thread_p, const DB_VALUE * name, DB_VALUE ** value)
|
| int |
xsession_load_query_entry_info (THREAD_ENTRY * thread_p, QMGR_QUERY_ENTRY * qentry_p)
|
| int |
xsession_remove_query_entry_info (THREAD_ENTRY * thread_p, const QUERY_ID query_id)
|
| int |
xsession_reset_cur_insert_id (THREAD_ENTRY * thread_p)
|
| int |
xsession_set_cur_insert_id (THREAD_ENTRY * thread_p, const DB_VALUE * value, bool force)
|
| int |
xsession_set_is_keep_session (THREAD_ENTRY * thread_p, bool is_keep_session)
|
| int |
xsession_set_row_count (THREAD_ENTRY * thread_p, int row_count)
|
| int |
xsession_set_session_variables (THREAD_ENTRY * thread_p, DB_VALUE * values, const int count)
|
| int |
xsession_set_tran_auto_commit (THREAD_ENTRY * thread_p, bool auto_commit)
|
| void |
xsession_store_query_entry_info (THREAD_ENTRY * thread_p, QMGR_QUERY_ENTRY * qentry_p)
|
| char * |
xstats_get_statistics_from_server (THREAD_ENTRY * thread_p, OID * class_id, unsigned int timestamp, int * length)
|
| int |
xstats_update_statistics (THREAD_ENTRY * thread_p, OID * classoid, bool with_fullscan, CLASS_ATTR_NDV * class_attr_ndv)
|
| void |
xsynonym_remove_xasl_by_oid (THREAD_ENTRY * thread_p, OID * oidp)
|
| int |
xtde_change_mk_without_flock (THREAD_ENTRY * thread_p, const int mk_index)
|
| int |
xtde_get_mk_info (THREAD_ENTRY * thread_p, int * mk_index, time_t * created_time, time_t * set_time)
|
| bool |
xtran_is_blocked (THREAD_ENTRY * thread_p, int tran_index)
|
| int |
xtran_lock_rep_read (THREAD_ENTRY * thread_p, LOCK lock_rr_tran)
|
| int |
xtran_server_2pc_attach_global_tran (THREAD_ENTRY * thread_p, int gtrid)
|
| TRAN_STATE |
xtran_server_2pc_prepare (THREAD_ENTRY * thread_p)
|
| TRAN_STATE |
xtran_server_2pc_prepare_global_tran (THREAD_ENTRY * thread_p, int gtrid)
|
| int |
xtran_server_2pc_recovery_prepared (THREAD_ENTRY * thread_p, int gtrids, int size)
|
| int |
xtran_server_2pc_start (THREAD_ENTRY * thread_p)
|
| TRAN_STATE |
xtran_server_abort (THREAD_ENTRY * thrd)
|
| TRAN_STATE |
xtran_server_commit (THREAD_ENTRY * thrd, bool retain_lock)
|
| TRAN_STATE |
xtran_server_end_topop (THREAD_ENTRY * thread_p, LOG_RESULT_TOPOP result, LOG_LSA * topop_lsa)
|
| int |
xtran_server_get_global_tran_info (THREAD_ENTRY * thread_p, int gtrid, void * buffer, int size)
|
| bool |
xtran_server_has_updated (THREAD_ENTRY * thread_p)
|
| int |
xtran_server_is_active_and_has_updated (THREAD_ENTRY * thread_p)
|
| TRAN_STATE |
xtran_server_partial_abort (THREAD_ENTRY * thread_p, const char * savept_name, LOG_LSA * savept_lsa)
|
| int |
xtran_server_savepoint (THREAD_ENTRY * thread_p, const char * savept_name, LOG_LSA * savept_lsa)
|
| int |
xtran_server_set_global_tran_info (THREAD_ENTRY * thread_p, int gtrid, void * info, int size)
|
| int |
xtran_server_start_topop (THREAD_ENTRY * thread_p, LOG_LSA * topop_lsa)
|
| bool |
xtran_should_connection_reset (THREAD_ENTRY * thread_p, bool has_updated)
|
| int |
xtran_wait_server_active_trans (THREAD_ENTRY * thrd)
|
Public Functions Documentation
function disk_get_boot_db_charset
int disk_get_boot_db_charset (
THREAD_ENTRY * thread_p,
INT16 volid,
INTL_CODESET * db_charset
)
function log_get_db_compatibility
float log_get_db_compatibility (
void
)
function log_get_final_restored_lsa
LOG_LSA * log_get_final_restored_lsa (
void
)
function log_is_no_logging
bool log_is_no_logging (
void
)
function log_set_no_logging
int log_set_no_logging (
void
)
function logtb_has_updated
bool logtb_has_updated (
THREAD_ENTRY * thread_p
)
function xacl_dump
void xacl_dump (
THREAD_ENTRY * thread_p,
FILE * outfp
)
function xacl_reload
int xacl_reload (
THREAD_ENTRY * thread_p
)
function xboot_add_volume_extension
VOLID xboot_add_volume_extension (
THREAD_ENTRY * thread_p,
DBDEF_VOL_EXT_INFO * ext_info
)
function xboot_backup
int xboot_backup (
THREAD_ENTRY * thread_p,
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 xboot_check_db_consistency
int xboot_check_db_consistency (
THREAD_ENTRY * thread_p,
int check_flag,
OID * oids,
int num_oids,
BTID * index_btid
)
function xboot_checkdb_table
DISK_ISVALID xboot_checkdb_table (
THREAD_ENTRY * thread_p,
int check_flag,
OID * oid,
BTID * index_btid
)
function xboot_compact_db
int xboot_compact_db (
THREAD_ENTRY * thread_p,
OID * class_oids,
int n_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 * initial_last_repr_id
)
function xboot_compact_start
int xboot_compact_start (
THREAD_ENTRY * thread_p
)
function xboot_compact_stop
int xboot_compact_stop (
THREAD_ENTRY * thread_p
)
function xboot_find_last_permanent
VOLID xboot_find_last_permanent (
THREAD_ENTRY * thread_p
)
function xboot_find_last_temp
VOLID xboot_find_last_temp (
THREAD_ENTRY * thread_p
)
function xboot_find_number_permanent_volumes
int xboot_find_number_permanent_volumes (
THREAD_ENTRY * thread_p
)
function xboot_find_number_temp_volumes
int xboot_find_number_temp_volumes (
THREAD_ENTRY * thread_p
)
function xboot_get_server_session_key
const char * xboot_get_server_session_key (
void
)
function xboot_heap_compact
int xboot_heap_compact (
THREAD_ENTRY * thread_p,
OID * class_oid
)
function xboot_initialize_server
int xboot_initialize_server (
const BOOT_CLIENT_CREDENTIAL * client_credential,
BOOT_DB_PATH_INFO * db_path_info,
bool db_overwrite,
const char * file_addmore_vols,
volatile DKNPAGES db_npages,
PGLENGTH db_desired_pagesize,
volatile DKNPAGES xlog_npages,
PGLENGTH db_desired_log_page_size,
OID * rootclass_oid,
HFID * rootclass_hfid,
int client_lock_wait,
TRAN_ISOLATION client_isolation
)
function xboot_peek_last_permanent
VOLID xboot_peek_last_permanent (
THREAD_ENTRY * thread_p
)
function xboot_register_client
int xboot_register_client (
THREAD_ENTRY * thread_p,
BOOT_CLIENT_CREDENTIAL * client_credential,
int client_lock_wait,
TRAN_ISOLATION client_isolation,
TRAN_STATE * tran_state,
BOOT_SERVER_CREDENTIAL * server_credential
)
function xboot_unregister_client
int xboot_unregister_client (
THREAD_ENTRY *& thread_p,
int tran_index
)
function xbtree_add_index
BTID * xbtree_add_index (
THREAD_ENTRY * thread_p,
BTID * btid,
TP_DOMAIN * key_type,
OID * class_oid,
int attr_id,
int unique_pk,
long long num_oids,
long long num_nulls,
long long num_keys,
int deduplicate_key_pos
)
function xbtree_class_test_unique
int xbtree_class_test_unique (
THREAD_ENTRY * thread_p,
char * buf,
int buf_size
)
function xbtree_delete_index
int xbtree_delete_index (
THREAD_ENTRY * thread_p,
BTID * btid
)
function xbtree_find_multi_uniques
BTREE_SEARCH xbtree_find_multi_uniques (
THREAD_ENTRY * thread_p,
OID * class_oid,
int pruning_type,
BTID * btids,
DB_VALUE * values,
int count,
SCAN_OPERATION_TYPE op_type,
OID ** oids,
int * oids_count
)
function xbtree_find_unique
BTREE_SEARCH xbtree_find_unique (
THREAD_ENTRY * thread_p,
BTID * btid,
SCAN_OPERATION_TYPE scan_op_type,
DB_VALUE * key,
OID * class_oid,
OID * oid,
bool is_all_class_srch
)
function xbtree_load_index
BTID * xbtree_load_index (
THREAD_ENTRY * thread_p,
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_steram_size,
int func_col_id,
int func_attr_index_start
)
function xbtree_load_online_index
BTID * xbtree_load_online_index (
THREAD_ENTRY * thread_p,
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_steram_size,
int func_col_id,
int func_attr_index_start,
int ib_thread_count
)
function xcatalog_check_rep_dir
int xcatalog_check_rep_dir (
THREAD_ENTRY * thread_p,
OID * class_id,
OID * rep_dir_p
)
function xchksum_insert_repl_log_and_demote_table_lock
int xchksum_insert_repl_log_and_demote_table_lock (
THREAD_ENTRY * thread_p,
REPL_INFO * repl_info,
const OID * class_oidp
)
function xdisk_get_free_numpages
DKNPAGES xdisk_get_free_numpages (
THREAD_ENTRY * thread_p,
VOLID volid
)
function xdisk_get_fullname
char * xdisk_get_fullname (
THREAD_ENTRY * thread_p,
VOLID volid,
char * vol_fullname
)
function xdisk_get_purpose
DISK_VOLPURPOSE xdisk_get_purpose (
THREAD_ENTRY * thread_p,
VOLID volid
)
function xdisk_get_purpose_and_space_info
int xdisk_get_purpose_and_space_info (
THREAD_ENTRY * thread_p,
VOLID volid,
DISK_VOLPURPOSE * vol_purpose,
DISK_VOLUME_SPACE_INFO * space_info
)
char * xdisk_get_remarks (
THREAD_ENTRY * thread_p,
VOLID volid
)
function xdisk_get_total_numpages
DKNPAGES xdisk_get_total_numpages (
THREAD_ENTRY * thread_p,
VOLID volid
)
function xdisk_is_volume_exist
bool xdisk_is_volume_exist (
THREAD_ENTRY * thread_p,
VOLID volid
)
function xehash_create
EHID * xehash_create (
THREAD_ENTRY * thread_p,
EHID * ehid,
DB_TYPE key_type,
int exp_num_entries,
OID * class_oid,
int attr_id,
bool is_tmp
)
function xehash_destroy
int xehash_destroy (
THREAD_ENTRY * thread_p,
EHID * ehid
)
function xfile_apply_tde_to_class_files
int xfile_apply_tde_to_class_files (
THREAD_ENTRY * thread_p,
const OID * class_oid
)
function xfile_tracker_clean_invalid_file
int xfile_tracker_clean_invalid_file (
THREAD_ENTRY * thread_p,
int * heap,
int * heap_ovf,
int * btree,
int * btree_ovf
)
function xfile_tracker_delete_target_file
int xfile_tracker_delete_target_file (
THREAD_ENTRY * thread_p,
const char * target_vfid_str
)
function xfile_tracker_dump_file_list
int xfile_tracker_dump_file_list (
THREAD_ENTRY * thread_p,
FILE * outfp,
bool invalid_only
)
function xheap_create
int xheap_create (
THREAD_ENTRY * thread_p,
HFID * hfid,
const OID * class_oid,
bool reuse_oid
)
function xheap_destroy
int xheap_destroy (
THREAD_ENTRY * thread_p,
const HFID * hfid,
const OID * class_oid
)
function xheap_destroy_newly_created
int xheap_destroy_newly_created (
THREAD_ENTRY * thread_p,
const HFID * hfid,
const OID * class_oid,
const bool force=false
)
function xlob_create_dir
int xlob_create_dir (
THREAD_ENTRY * thread_p,
HFID * hfid,
int * attrid_arr,
int attrid_arr_length
)
function xlob_remove_dir
int xlob_remove_dir (
THREAD_ENTRY * thread_p,
HFID * hfid,
int attrid
)
function xlocator_assign_oid
int xlocator_assign_oid (
THREAD_ENTRY * thread_p,
const HFID * hfid,
OID * perm_oid,
int expected_length,
OID * class_oid,
const char * classname
)
function xlocator_assign_oid_batch
int xlocator_assign_oid_batch (
THREAD_ENTRY * thread_p,
LC_OIDSET * oidset
)
function xlocator_check_fk_validity
int xlocator_check_fk_validity (
THREAD_ENTRY * thread_p,
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 xlocator_delete_class_name
LC_FIND_CLASSNAME xlocator_delete_class_name (
THREAD_ENTRY * thread_p,
const char * classname
)
function xlocator_demote_class_lock
int xlocator_demote_class_lock (
THREAD_ENTRY * thread_p,
const OID * class_oid,
LOCK lock,
LOCK * ex_lock
)
function xlocator_does_exist
int xlocator_does_exist (
THREAD_ENTRY * thread_p,
OID * oid,
int chn,
LOCK lock,
LC_FETCH_VERSION_TYPE fetch_version_type,
OID * class_oid,
int class_chn,
int need_fetching,
int prefetching,
LC_COPYAREA ** fetch_area
)
function xlocator_fetch
int xlocator_fetch (
THREAD_ENTRY * thrd,
OID * oid,
int chn,
LOCK lock,
LC_FETCH_VERSION_TYPE fetch_version_type,
LC_FETCH_VERSION_TYPE initial_fetch_version_type,
OID * class_oid,
int class_chn,
int prefetching,
LC_COPYAREA ** fetch_area
)
function xlocator_fetch_all
int xlocator_fetch_all (
THREAD_ENTRY * thread_p,
const HFID * hfid,
LOCK * lock,
LC_FETCH_VERSION_TYPE fetch_type,
OID * class_oid,
int * nobjects,
int * nfetched,
OID * last_oid,
LC_COPYAREA ** fetch_area,
int request_pages
)
function xlocator_fetch_all_reference_lockset
int xlocator_fetch_all_reference_lockset (
THREAD_ENTRY * thread_p,
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_fetch_lockhint_classes
int xlocator_fetch_lockhint_classes (
THREAD_ENTRY * thread_p,
LC_LOCKHINT * lockhint,
LC_COPYAREA ** fetch_area
)
function xlocator_fetch_lockset
int xlocator_fetch_lockset (
THREAD_ENTRY * thread_p,
LC_LOCKSET * lockset,
LC_COPYAREA ** fetch_area
)
function xlocator_find_class_oid
LC_FIND_CLASSNAME xlocator_find_class_oid (
THREAD_ENTRY * thread_p,
const char * classname,
OID * class_oid,
LOCK lock
)
function xlocator_find_lockhint_class_oids
LC_FIND_CLASSNAME xlocator_find_lockhint_class_oids (
THREAD_ENTRY * thread_p,
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,
bool quit_on_errors,
LC_LOCKHINT ** hlock,
LC_COPYAREA ** fetch_area
)
function xlocator_force
int xlocator_force (
THREAD_ENTRY * thread_p,
LC_COPYAREA * copy_area,
int num_ignore_error_list,
int * ignore_error_list
)
function xlocator_get_class
int xlocator_get_class (
THREAD_ENTRY * thread_p,
OID * class_oid,
int class_chn,
const OID * oid,
LOCK lock,
int prefetching,
LC_COPYAREA ** fetch_area
)
function xlocator_get_reserved_class_name_oid
int xlocator_get_reserved_class_name_oid (
THREAD_ENTRY * thread_p,
const char * classname,
OID * class_oid
)
function xlocator_lock_and_fetch_all
int xlocator_lock_and_fetch_all (
THREAD_ENTRY * thread_p,
const HFID * hfid,
LOCK * instance_lock,
int * instance_lock_timeout,
OID * class_oid,
LOCK * class_lock,
int * nobjects,
int * nfetched,
int * nfailed_instance_locks,
OID * last_oid,
LC_COPYAREA ** fetch_area,
MVCC_SNAPSHOT * mvcc_snapshot
)
function xlocator_notify_isolation_incons
bool xlocator_notify_isolation_incons (
THREAD_ENTRY * thread_p,
LC_COPYAREA ** synch_area
)
function xlocator_remove_class_from_index
int xlocator_remove_class_from_index (
THREAD_ENTRY * thread_p,
OID * oid,
BTID * btid,
HFID * hfid
)
function xlocator_rename_class_name
LC_FIND_CLASSNAME xlocator_rename_class_name (
THREAD_ENTRY * thread_p,
const char * oldname,
const char * newname,
OID * class_oid
)
function xlocator_repl_force
int xlocator_repl_force (
THREAD_ENTRY * thread_p,
LC_COPYAREA * copy_area,
LC_COPYAREA ** reply_area
)
function xlocator_reserve_class_names
LC_FIND_CLASSNAME xlocator_reserve_class_names (
THREAD_ENTRY * thread_p,
const int num_classes,
const char ** classname,
OID * class_oid
)
function xlocator_upgrade_instances_domain
int xlocator_upgrade_instances_domain (
THREAD_ENTRY * thread_p,
OID * class_oid,
int att_id
)
function xlock_dump
void xlock_dump (
THREAD_ENTRY * thread_p,
FILE * outfp,
int is_contention
)
function xlogin_user
int xlogin_user (
THREAD_ENTRY * thread_p,
const char * username
)
function xlogtb_does_active_user_exist
bool xlogtb_does_active_user_exist (
THREAD_ENTRY * thread_p,
const char * user_name
)
function xlogtb_get_pack_tran_table
int xlogtb_get_pack_tran_table (
THREAD_ENTRY * thread_p,
char ** buffer_p,
int * size_p,
int include_query_exec_info
)
function xlogtb_reset_isolation
int xlogtb_reset_isolation (
THREAD_ENTRY * thread_p,
TRAN_ISOLATION isolation
)
function xlogtb_reset_wait_msecs
int xlogtb_reset_wait_msecs (
THREAD_ENTRY * thread_p,
int wait_msecs
)
function xlogtb_set_interrupt
void xlogtb_set_interrupt (
THREAD_ENTRY * thread_p,
int set
)
function xlogtb_set_suppress_repl_on_transaction
void xlogtb_set_suppress_repl_on_transaction (
THREAD_ENTRY * thread_p,
int set
)
function xperfmon_server_copy_global_stats
void xperfmon_server_copy_global_stats (
UINT64 * to_stats
)
function xperfmon_server_copy_stats
void xperfmon_server_copy_stats (
THREAD_ENTRY * thread_p,
UINT64 * to_stats,
bool need_pgbuf_stat
)
function xperfmon_server_copy_stats_for_trace
void xperfmon_server_copy_stats_for_trace (
THREAD_ENTRY * thread_p,
UINT64 * to_stats
)
function xqfile_get_list_file_page
int xqfile_get_list_file_page (
THREAD_ENTRY * thread_p,
QUERY_ID query_id,
VOLID volid,
PAGEID pageid,
char * page_bufp,
int * page_sizep
)
function xqmgr_drop_all_query_plans
int xqmgr_drop_all_query_plans (
THREAD_ENTRY * thread_p
)
function xqmgr_drop_query_plans_by_sha1
int xqmgr_drop_query_plans_by_sha1 (
THREAD_ENTRY * thread_p,
char * sha1
)
function xqmgr_dump_query_cache
void xqmgr_dump_query_cache (
THREAD_ENTRY * thread_p,
FILE * outfp
)
function xqmgr_dump_query_plans
void xqmgr_dump_query_plans (
THREAD_ENTRY * thread_p,
FILE * outfp
)
function xqmgr_end_query
int xqmgr_end_query (
THREAD_ENTRY * thrd,
QUERY_ID query_id
)
function xqmgr_execute_query
QFILE_LIST_ID * xqmgr_execute_query (
THREAD_ENTRY * thrd,
const XASL_ID * xasl_id,
QUERY_ID * query_idp,
int dbval_cnt,
void * data,
QUERY_FLAG * flagp,
CACHE_TIME * clt_cache_time,
CACHE_TIME * srv_cache_time,
int query_timeout,
xasl_cache_ent ** ret_cache_entry_p
)
function xqmgr_prepare_and_execute_query
QFILE_LIST_ID * xqmgr_prepare_and_execute_query (
THREAD_ENTRY * thrd,
char * xasl_stream,
int xasl_stream_size,
QUERY_ID * query_id,
int dbval_cnt,
void * data,
QUERY_FLAG * flag,
int query_timeout
)
function xqmgr_prepare_query
int xqmgr_prepare_query (
THREAD_ENTRY * thrd,
compile_context * ctx,
xasl_stream * stream
)
function xrepl_log_get_append_lsa
LOG_LSA * xrepl_log_get_append_lsa (
void
)
function xrepl_set_info
int xrepl_set_info (
THREAD_ENTRY * thread_p,
REPL_INFO * repl_info
)
function xsession_check_session
int xsession_check_session (
THREAD_ENTRY * thread_p,
const SESSION_ID id
)
function xsession_clear_query_entry_info
int xsession_clear_query_entry_info (
THREAD_ENTRY * thread_p,
const QUERY_ID query_id
)
function xsession_create_new
int xsession_create_new (
THREAD_ENTRY * thread_p,
SESSION_ID * id
)
function xsession_create_prepared_statement
int xsession_create_prepared_statement (
THREAD_ENTRY * thread_p,
char * name,
char * alias_print,
SHA1Hash * sha1,
char * info,
int info_len
)
function xsession_delete_prepared_statement
int xsession_delete_prepared_statement (
THREAD_ENTRY * thread_p,
const char * name
)
function xsession_drop_session_variables
int xsession_drop_session_variables (
THREAD_ENTRY * thread_p,
DB_VALUE * values,
const int count
)
function xsession_end_session
int xsession_end_session (
THREAD_ENTRY * thread,
const SESSION_ID id,
bool is_keep_session
)
function xsession_get_last_insert_id
int xsession_get_last_insert_id (
THREAD_ENTRY * thread_p,
DB_VALUE * value,
bool update_last_insert_id
)
function xsession_get_prepared_statement
int xsession_get_prepared_statement (
THREAD_ENTRY * thread_p,
const char * name,
char ** info,
int * info_len,
XASL_ID * xasl_id,
xasl_node_header * xasl_header_p
)
function xsession_get_row_count
int xsession_get_row_count (
THREAD_ENTRY * thread_p,
int * row_count
)
function xsession_get_session_variable
int xsession_get_session_variable (
THREAD_ENTRY * thread_p,
const DB_VALUE * name,
DB_VALUE * value
)
function xsession_get_session_variable_no_copy
int xsession_get_session_variable_no_copy (
THREAD_ENTRY * thread_p,
const DB_VALUE * name,
DB_VALUE ** value
)
function xsession_load_query_entry_info
int xsession_load_query_entry_info (
THREAD_ENTRY * thread_p,
QMGR_QUERY_ENTRY * qentry_p
)
function xsession_remove_query_entry_info
int xsession_remove_query_entry_info (
THREAD_ENTRY * thread_p,
const QUERY_ID query_id
)
function xsession_reset_cur_insert_id
int xsession_reset_cur_insert_id (
THREAD_ENTRY * thread_p
)
function xsession_set_cur_insert_id
int xsession_set_cur_insert_id (
THREAD_ENTRY * thread_p,
const DB_VALUE * value,
bool force
)
function xsession_set_is_keep_session
int xsession_set_is_keep_session (
THREAD_ENTRY * thread_p,
bool is_keep_session
)
function xsession_set_row_count
int xsession_set_row_count (
THREAD_ENTRY * thread_p,
int row_count
)
function xsession_set_session_variables
int xsession_set_session_variables (
THREAD_ENTRY * thread_p,
DB_VALUE * values,
const int count
)
function xsession_set_tran_auto_commit
int xsession_set_tran_auto_commit (
THREAD_ENTRY * thread_p,
bool auto_commit
)
function xsession_store_query_entry_info
void xsession_store_query_entry_info (
THREAD_ENTRY * thread_p,
QMGR_QUERY_ENTRY * qentry_p
)
function xstats_get_statistics_from_server
char * xstats_get_statistics_from_server (
THREAD_ENTRY * thread_p,
OID * class_id,
unsigned int timestamp,
int * length
)
function xstats_update_statistics
int xstats_update_statistics (
THREAD_ENTRY * thread_p,
OID * classoid,
bool with_fullscan,
CLASS_ATTR_NDV * class_attr_ndv
)
function xsynonym_remove_xasl_by_oid
void xsynonym_remove_xasl_by_oid (
THREAD_ENTRY * thread_p,
OID * oidp
)
function xtde_change_mk_without_flock
int xtde_change_mk_without_flock (
THREAD_ENTRY * thread_p,
const int mk_index
)
function xtde_get_mk_info
int xtde_get_mk_info (
THREAD_ENTRY * thread_p,
int * mk_index,
time_t * created_time,
time_t * set_time
)
function xtran_is_blocked
bool xtran_is_blocked (
THREAD_ENTRY * thread_p,
int tran_index
)
function xtran_lock_rep_read
int xtran_lock_rep_read (
THREAD_ENTRY * thread_p,
LOCK lock_rr_tran
)
function xtran_server_2pc_attach_global_tran
int xtran_server_2pc_attach_global_tran (
THREAD_ENTRY * thread_p,
int gtrid
)
function xtran_server_2pc_prepare
TRAN_STATE xtran_server_2pc_prepare (
THREAD_ENTRY * thread_p
)
function xtran_server_2pc_prepare_global_tran
TRAN_STATE xtran_server_2pc_prepare_global_tran (
THREAD_ENTRY * thread_p,
int gtrid
)
function xtran_server_2pc_recovery_prepared
int xtran_server_2pc_recovery_prepared (
THREAD_ENTRY * thread_p,
int gtrids,
int size
)
function xtran_server_2pc_start
int xtran_server_2pc_start (
THREAD_ENTRY * thread_p
)
function xtran_server_abort
TRAN_STATE xtran_server_abort (
THREAD_ENTRY * thrd
)
function xtran_server_commit
TRAN_STATE xtran_server_commit (
THREAD_ENTRY * thrd,
bool retain_lock
)
function xtran_server_end_topop
TRAN_STATE xtran_server_end_topop (
THREAD_ENTRY * thread_p,
LOG_RESULT_TOPOP result,
LOG_LSA * topop_lsa
)
function xtran_server_get_global_tran_info
int xtran_server_get_global_tran_info (
THREAD_ENTRY * thread_p,
int gtrid,
void * buffer,
int size
)
function xtran_server_has_updated
bool xtran_server_has_updated (
THREAD_ENTRY * thread_p
)
function xtran_server_is_active_and_has_updated
int xtran_server_is_active_and_has_updated (
THREAD_ENTRY * thread_p
)
function xtran_server_partial_abort
TRAN_STATE xtran_server_partial_abort (
THREAD_ENTRY * thread_p,
const char * savept_name,
LOG_LSA * savept_lsa
)
function xtran_server_savepoint
int xtran_server_savepoint (
THREAD_ENTRY * thread_p,
const char * savept_name,
LOG_LSA * savept_lsa
)
function xtran_server_set_global_tran_info
int xtran_server_set_global_tran_info (
THREAD_ENTRY * thread_p,
int gtrid,
void * info,
int size
)
function xtran_server_start_topop
int xtran_server_start_topop (
THREAD_ENTRY * thread_p,
LOG_LSA * topop_lsa
)
function xtran_should_connection_reset
bool xtran_should_connection_reset (
THREAD_ENTRY * thread_p,
bool has_updated
)
function xtran_wait_server_active_trans
int xtran_wait_server_active_trans (
THREAD_ENTRY * thrd
)
The documentation for this class was generated from the following file cubrid/src/base/xserver_interface.h