File network_interface_sr.cpp¶
FileList > communication > network_interface_sr.cpp
Go to the source code of this file
#include "config.h"#include <stdio.h>#include <string.h>#include <assert.h>#include "filesys.hpp"#include "filesys_temp.hpp"#include "porting.h"#include "porting_inline.hpp"#include "perf_monitor.h"#include "memory_alloc.h"#include "storage_common.h"#include "xserver_interface.h"#include "statistics_sr.h"#include "btree_load.h"#include "log_impl.h"#include "log_lsa.hpp"#include "boot_sr.h"#include "locator_sr.h"#include "server_interface.h"#include "oid.h"#include "error_manager.h"#include "object_representation.h"#include "network.h"#include "log_comm.h"#include "network_interface_sr.h"#include "page_buffer.h"#include "file_manager.h"#include "arithmetic.h"#include "serial.h"#include "query_manager.h"#include "transaction_sr.h"#include "release_string.h"#include "critical_section.h"#include "statistics.h"#include "chartype.h"#include "heap_file.h"#include "pl_sr.h"#include "replication.h"#include "server_support.h"#include "connection_sr.h"#include "log_writer.h"#include "databases_file.h"#include "es.h"#include "es_posix.h"#include "event_log.h"#include "trace_log.h"#include "tsc_timer.h"#include "vacuum.h"#include "object_primitive.h"#include "tz_support.h"#include "dbtype.h"#include "thread_manager.hpp"#include "compile_context.h"#include "load_session.hpp"#include "session.h"#include "xasl.h"#include "xasl_cache.h"#include "elo.h"#include "transaction_transient.hpp"#include "method_invoke_group.hpp"#include "log_manager.h"#include "crypt_opfunc.h"#include "flashback.h"#include "pl_struct_compile.hpp"#include "pl_compile_handler.hpp"#include "pl_session.hpp"#include "pl_executor.hpp"#include "memory_wrapper.hpp"
Public Attributes¶
| Type | Name |
|---|---|
| unsigned int | db_on_server = 1 |
Public Functions¶
Public Static Functions¶
Macros¶
| Type | Name |
|---|---|
| define | NET_COPY_AREA_SENDRECV_SIZE ([**OR\_INT\_SIZE**](object__representation__constants_8h.md#define-or_int_size) \* 3) |
| define | NET_DEFER_END_QUERIES_MAX 10 |
| define | NET_SENDRECV_BUFFSIZE ([**OR\_INT\_SIZE**](object__representation__constants_8h.md#define-or_int_size)) |
| define | QEWC_MAX_DATA_SIZE ([**DB\_PAGESIZE**](storage__common_8h.md#define-db_pagesize) - [**QEWC\_SAFE\_GUARD\_SIZE**](network__interface__sr_8cpp.md#define-qewc_safe_guard_size)) |
| define | QEWC_SAFE_GUARD_SIZE 1024 |
| define | QUERY_INFO_BUF_SIZE (2048 + [**STATDUMP\_BUF\_SIZE**](network__interface__sr_8cpp.md#define-statdump_buf_size)) |
| define | STATDUMP_BUF_SIZE (2 \* 16 \* 1024) |
Public Attributes Documentation¶
variable db_on_server¶
Public Functions Documentation¶
function netsr_spacedb¶
function return_error_to_client¶
function sacl_dump¶
function sacl_reload¶
function sboot_add_volume_extension¶
void sboot_add_volume_extension (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sboot_backup¶
function sboot_change_ha_mode¶
function sboot_check_db_consistency¶
void sboot_check_db_consistency (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sboot_compact_db¶
function sboot_compact_start¶
function sboot_compact_stop¶
function sboot_find_last_permanent¶
void sboot_find_last_permanent (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sboot_find_last_temp¶
function sboot_find_number_permanent_volumes¶
void sboot_find_number_permanent_volumes (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sboot_find_number_temp_volumes¶
void sboot_find_number_temp_volumes (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sboot_get_locales_info¶
void sboot_get_locales_info (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sboot_get_timezone_checksum¶
void sboot_get_timezone_checksum (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sboot_heap_compact¶
function sboot_initialize_server¶
void sboot_initialize_server (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sboot_notify_ha_log_applier_state¶
void sboot_notify_ha_log_applier_state (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sboot_notify_unregister_client¶
void sboot_notify_unregister_client (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sboot_register_client¶
void sboot_register_client (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sbtree_add_index¶
function sbtree_class_test_unique¶
void sbtree_class_test_unique (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sbtree_delete_index¶
function sbtree_find_multi_uniques¶
void sbtree_find_multi_uniques (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sbtree_find_unique¶
function sbtree_get_key_type¶
function sbtree_get_statistics¶
void sbtree_get_statistics (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sbtree_load_index¶
function scdc_end_session¶
function scdc_find_lsa¶
function scdc_get_loginfo¶
function scdc_get_loginfo_metadata¶
void scdc_get_loginfo_metadata (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function scdc_start_session¶
function schksum_insert_repl_log_and_demote_table_lock¶
void schksum_insert_repl_log_and_demote_table_lock (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sct_check_rep_dir¶
function sdk_freepgs¶
function sdk_remarks¶
function sdk_totalpgs¶
function sdk_vlabel¶
function server_ping¶
function server_ping_with_handshake¶
int server_ping_with_handshake (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ses_posix_copy_file¶
function ses_posix_create_file¶
void ses_posix_create_file (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ses_posix_delete_file¶
void ses_posix_delete_file (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ses_posix_get_file_size¶
void ses_posix_get_file_size (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ses_posix_read_file¶
function ses_posix_rename_file¶
void ses_posix_rename_file (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ses_posix_write_file¶
function sfile_apply_tde_to_class_files¶
void sfile_apply_tde_to_class_files (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sfile_tracker_clean_invalid_file¶
void sfile_tracker_clean_invalid_file (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sfile_tracker_delete_target_file¶
void sfile_tracker_delete_target_file (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sfile_tracker_dump_file_list¶
void sfile_tracker_dump_file_list (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sflashback_get_loginfo¶
void sflashback_get_loginfo (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sflashback_get_summary¶
void sflashback_get_summary (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function shf_create¶
function shf_destroy¶
function shf_destroy_when_new¶
function shf_get_class_num_objs_and_pages¶
void shf_get_class_num_objs_and_pages (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function shf_get_maxslotted_reclength¶
void shf_get_maxslotted_reclength (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function shf_has_instance¶
function shf_heap_reclaim_addresses¶
void shf_heap_reclaim_addresses (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sloaddb_destroy¶
function sloaddb_fetch_status¶
function sloaddb_init¶
function sloaddb_install_class¶
void sloaddb_install_class (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sloaddb_interrupt¶
function sloaddb_load_batch¶
function sloaddb_update_stats¶
function slob_create_dir¶
function slob_remove_dir¶
function slocator_assign_oid¶
function slocator_assign_oid_batch¶
void slocator_assign_oid_batch (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slocator_check_fk_validity¶
void slocator_check_fk_validity (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slocator_delete_class_name¶
void slocator_delete_class_name (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slocator_demote_class_lock¶
void slocator_demote_class_lock (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slocator_does_exist¶
function slocator_fetch¶
function slocator_fetch_all¶
function slocator_fetch_all_reference_lockset¶
void slocator_fetch_all_reference_lockset (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slocator_fetch_lockhint_classes¶
void slocator_fetch_lockhint_classes (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slocator_fetch_lockset¶
void slocator_fetch_lockset (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slocator_find_class_oid¶
void slocator_find_class_oid (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slocator_find_lockhint_class_oids¶
void slocator_find_lockhint_class_oids (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slocator_force¶
function slocator_get_class¶
function slocator_get_reserved_class_name_oid¶
void slocator_get_reserved_class_name_oid (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slocator_notify_isolation_incons¶
void slocator_notify_isolation_incons (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slocator_redistribute_partition_data¶
void slocator_redistribute_partition_data (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slocator_remove_class_from_index¶
void slocator_remove_class_from_index (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slocator_rename_class_name¶
void slocator_rename_class_name (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slocator_repl_force¶
function slocator_reserve_classnames¶
void slocator_reserve_classnames (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slocator_upgrade_instances_domain¶
void slocator_upgrade_instances_domain (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slock_dump¶
function slog_add_lob_locator¶
function slog_change_state_of_locator¶
void slog_change_state_of_locator (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slog_checkpoint¶
function slog_drop_lob_locator¶
void slog_drop_lob_locator (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slog_find_lob_locator¶
void slog_find_lob_locator (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slog_supplement_statement¶
void slog_supplement_statement (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slogin_user¶
function slogpb_dump_stat¶
function slogtb_does_active_user_exist¶
void slogtb_does_active_user_exist (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slogtb_dump_trantable¶
void slogtb_dump_trantable (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slogtb_get_mvcc_snapshot¶
void slogtb_get_mvcc_snapshot (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slogtb_get_pack_tran_table¶
void slogtb_get_pack_tran_table (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slogtb_has_updated¶
function slogtb_reset_isolation¶
void slogtb_reset_isolation (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slogtb_reset_wait_msecs¶
void slogtb_reset_wait_msecs (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slogtb_set_interrupt¶
function slogtb_set_suppress_repl_on_transaction¶
void slogtb_set_suppress_repl_on_transaction (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function slogwr_get_log_pages¶
function smmon_disable_force¶
function smmon_get_server_info¶
void smmon_get_server_info (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function smnt_server_copy_global_stats¶
void smnt_server_copy_global_stats (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function smnt_server_copy_stats¶
void smnt_server_copy_stats (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function smnt_server_start_stats¶
void smnt_server_start_stats (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function smnt_server_stop_stats¶
void smnt_server_stop_stats (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function spl_call¶
function spl_get_server_port¶
function splcsql_transfer_file¶
void splcsql_transfer_file (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sprm_server_change_parameters¶
void sprm_server_change_parameters (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sprm_server_dump_parameters¶
void sprm_server_dump_parameters (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sprm_server_get_force_parameters¶
void sprm_server_get_force_parameters (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sprm_server_obtain_parameters¶
void sprm_server_obtain_parameters (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sqfile_get_list_file_page¶
void sqfile_get_list_file_page (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sqmgr_drop_all_query_plans¶
void sqmgr_drop_all_query_plans (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sqmgr_drop_query_plans_by_sha1¶
void sqmgr_drop_query_plans_by_sha1 (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sqmgr_dump_query_cache¶
void sqmgr_dump_query_cache (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sqmgr_dump_query_plans¶
void sqmgr_dump_query_plans (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sqmgr_end_query¶
function sqmgr_execute_query¶
function sqmgr_prepare_and_execute_query¶
void sqmgr_prepare_and_execute_query (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sqmgr_prepare_query¶
function sqp_get_server_info¶
function sqp_get_sys_timestamp¶
void sqp_get_sys_timestamp (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request_ignore,
int reqlen_ignore
)
function sqst_server_get_statistics¶
void sqst_server_get_statistics (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sqst_update_statistics¶
void sqst_update_statistics (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function srepl_log_get_append_lsa¶
void srepl_log_get_append_lsa (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function srepl_set_info¶
function sserial_decache¶
function sserial_get_current_value¶
void sserial_get_current_value (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sserial_get_next_value¶
void sserial_get_next_value (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ssession_create_prepared_statement¶
void ssession_create_prepared_statement (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ssession_delete_prepared_statement¶
void ssession_delete_prepared_statement (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ssession_drop_session_variables¶
void ssession_drop_session_variables (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ssession_end_session¶
function ssession_find_or_create_session¶
void ssession_find_or_create_session (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ssession_get_last_insert_id¶
void ssession_get_last_insert_id (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ssession_get_prepared_statement¶
void ssession_get_prepared_statement (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ssession_get_row_count¶
void ssession_get_row_count (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ssession_get_session_variable¶
void ssession_get_session_variable (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ssession_reset_cur_insert_id¶
void ssession_reset_cur_insert_id (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ssession_set_row_count¶
void ssession_set_row_count (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ssession_set_session_variables¶
void ssession_set_session_variables (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function ssession_stop_attached_threads¶
function ssynonym_remove_xasl_by_oid¶
void ssynonym_remove_xasl_by_oid (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stde_change_mk_on_server¶
void stde_change_mk_on_server (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stde_get_data_keys¶
function stde_get_mk_file_path¶
void stde_get_mk_file_path (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stde_get_mk_info¶
function stde_is_loaded¶
function stdes_reset_query_start_info¶
void stdes_reset_query_start_info (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stdes_set_query_start_info¶
void stdes_set_query_start_info (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sthread_dump_cs_stat¶
function sthread_kill_or_interrupt_tran¶
void sthread_kill_or_interrupt_tran (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function sthread_kill_tran_index¶
void sthread_kill_tran_index (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stran_get_local_transaction_id¶
void stran_get_local_transaction_id (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stran_is_blocked¶
function stran_lock_rep_read¶
function stran_server_2pc_attach_global_tran¶
void stran_server_2pc_attach_global_tran (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stran_server_2pc_prepare¶
void stran_server_2pc_prepare (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stran_server_2pc_prepare_global_tran¶
void stran_server_2pc_prepare_global_tran (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stran_server_2pc_recovery_prepared¶
void stran_server_2pc_recovery_prepared (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stran_server_2pc_start¶
void stran_server_2pc_start (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stran_server_abort¶
function stran_server_commit¶
function stran_server_end_topop¶
void stran_server_end_topop (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stran_server_get_global_tran_info¶
void stran_server_get_global_tran_info (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stran_server_has_updated¶
void stran_server_has_updated (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stran_server_is_active_and_has_updated¶
void stran_server_is_active_and_has_updated (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stran_server_partial_abort¶
void stran_server_partial_abort (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stran_server_savepoint¶
void stran_server_savepoint (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stran_server_set_global_tran_info¶
void stran_server_set_global_tran_info (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stran_server_start_topop¶
void stran_server_start_topop (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function stran_wait_server_active_trans¶
void stran_wait_server_active_trans (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function svacuum¶
function svacuum_dump¶
function xcallback_console_print¶
function xio_send_user_prompt_to_client¶
int xio_send_user_prompt_to_client (
THREAD_ENTRY * thread_p,
FILEIO_REMOTE_PROMPT_TYPE prompt_id,
const char * prompt,
const char * failure_prompt,
int range_low,
int range_high,
const char * secondary_prompt,
int reprompt_value
)
function xlog_get_page_request_with_reply¶
int xlog_get_page_request_with_reply (
THREAD_ENTRY * thread_p,
LOG_PAGEID * fpageid_ptr,
LOGWR_MODE * mode_ptr,
int timeout
)
function xlog_send_log_pages_to_client¶
int xlog_send_log_pages_to_client (
THREAD_ENTRY * thread_p,
char * logpg_area,
int area_size,
LOGWR_MODE mode
)
function xs_receive_data_from_client¶
function xs_receive_data_from_client_with_timeout¶
int xs_receive_data_from_client_with_timeout (
THREAD_ENTRY * thread_p,
char ** area,
int * datasize,
int timeout
)
Public Static Functions Documentation¶
function cdc_check_client_connection¶
function check_client_capabilities¶
static int check_client_capabilities (
THREAD_ENTRY * thread_p,
int client_cap,
int rel_compare,
REL_COMPATIBILITY * compatibility,
const char * client_host
)
function er_log_slow_query¶
static int er_log_slow_query (
THREAD_ENTRY * thread_p,
EXECUTION_INFO * info,
int time,
UINT64 * diff_stats,
char * queryinfo_string
)
function event_log_extend_pages¶
function event_log_many_ioreads¶
static void event_log_many_ioreads (
THREAD_ENTRY * thread_p,
EXECUTION_INFO * info,
int time,
UINT64 * diff_stats
)
function need_to_abort_tran¶
function sbtree_find_unique_internal¶
static void sbtree_find_unique_internal (
THREAD_ENTRY * thread_p,
unsigned int rid,
char * request,
int reqlen
)
function server_capabilities¶
function set_tdes_query_exec_info¶
function stran_can_end_after_query_execution¶
static int stran_can_end_after_query_execution (
THREAD_ENTRY * thread_p,
int query_flag,
QFILE_LIST_ID * list_id,
bool * can_end_transaction
)
function stran_server_abort_internal¶
static TRAN_STATE stran_server_abort_internal (
THREAD_ENTRY * thread_p,
unsigned int rid,
bool retain_lock,
bool * should_conn_reset
)
function stran_server_abort_internal¶
static TRAN_STATE stran_server_abort_internal (
THREAD_ENTRY * thread_p,
unsigned int rid,
bool * should_conn_reset
)
function stran_server_auto_commit_or_abort¶
static void stran_server_auto_commit_or_abort (
THREAD_ENTRY * thread_p,
unsigned int rid,
QUERY_ID * p_end_queries,
int n_query_ids,
bool need_abort,
bool has_updated,
bool * end_query_allowed,
TRAN_STATE * tran_state,
bool * should_conn_reset
)
function stran_server_commit_internal¶
static TRAN_STATE stran_server_commit_internal (
THREAD_ENTRY * thread_p,
unsigned int rid,
bool retain_lock,
bool * should_conn_reset
)
function trace_log_slow_query¶
static int trace_log_slow_query (
THREAD_ENTRY * thread_p,
EXECUTION_INFO * info,
int time,
UINT64 * diff_stats,
char * queryinfo_string,
int trace_level
)
Macro Definition Documentation¶
define NET_COPY_AREA_SENDRECV_SIZE¶
define NET_DEFER_END_QUERIES_MAX¶
define NET_SENDRECV_BUFFSIZE¶
define QEWC_MAX_DATA_SIZE¶
define QEWC_SAFE_GUARD_SIZE¶
define QUERY_INFO_BUF_SIZE¶
define STATDUMP_BUF_SIZE¶
The documentation for this class was generated from the following file cubrid/src/communication/network_interface_sr.cpp