CUBRID Engine: src/broker/cas.h File Reference

CUBRID Engine latest

#include "broker_shm.h"
#include "cas_protocol.h"
#include "cas_cci.h"
#include "cas_common.h"

Include dependency graph for cas.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	t_object

struct	t_lob_handle

struct	t_req_info

struct	t_error_info

Macros
#define	CAS

#define	ERROR_INDICATOR_UNSET 0

#define	CAS_ERROR_INDICATOR -1

#define	DBMS_ERROR_INDICATOR -2

#define	CAS_NO_ERROR 0

#define	ERR_MSG_LENGTH 1024

#define	ERR_FILE_LENGTH 256

#define	MAX_SHARD_INFO_LENGTH 30

#define	MAX_HA_DBINFO_LENGTH (SRV_CON_DBNAME_SIZE + MAX_CONN_INFO_LENGTH)

Typedefs
typedef struct t_object	T_OBJECT

typedef struct t_lob_handle	T_LOB_HANDLE

typedef struct t_req_info	T_REQ_INFO

typedef struct t_error_info	T_ERROR_INFO

Enumerations
enum	tran_auto_commit { TRAN_NOT_AUTOCOMMIT = 0, TRAN_AUTOCOMMIT = 1, TRAN_AUTOROLLBACK = 2 }

Functions
int	restart_is_needed (void)

bool	is_xa_prepared (void)

void	set_xa_prepare_flag (void)

void	unset_xa_prepare_flag (void)

int	query_seq_num_next_value (void)

int	query_seq_num_current_value (void)

void	set_hang_check_time (void)

void	unset_hang_check_time (void)

bool	check_server_alive (const char db_name, const char db_host)

void	cas_set_db_connect_status (int status)

int	cas_get_db_connect_status (void)

T_BROKER_VERSION	cas_get_client_version (void)

Variables
int	cas_shard_flag

int	shm_shard_id

const char *	program_name

char	broker_name [BROKER_NAME_LEN]

int	shm_proxy_id

int	shm_shard_cas_id

int	shm_as_index

T_SHM_APPL_SERVER *	shm_appl

T_APPL_SERVER_INFO *	as_info

struct timeval	tran_start_time

struct timeval	query_start_time

int	tran_timeout

int	query_timeout

INT64	query_cancel_time

char	query_cancel_flag

int	errors_in_transaction

char	stripped_column_name

char	cas_client_type

int	cas_default_isolation_level

int	cas_default_lock_timeout

bool	cas_default_ansi_quotes

bool	cas_default_no_backslash_escapes

int	cas_send_result_flag

int	cas_info_size

T_ERROR_INFO	err_info

Macro Definition Documentation

#define CAS

Definition at line 30 of file cas.h.

#define CAS_ERROR_INDICATOR -1

Definition at line 39 of file cas.h.

Referenced by cas_main(), cfg_get_dbinfo(), cfg_read_dbinfo(), create_srv_handle_with_query_result(), dbval_to_net_buf(), err_msg_set(), error_info_set_with_msg(), fetch_attribute(), fetch_call(), fetch_class(), fetch_methfile(), fetch_method(), fetch_privilege(), fetch_result(), fetch_trigger(), fn_check_cas(), fn_close_req_handle(), fn_collection(), fn_cursor(), fn_cursor_update(), fn_deprecated(), fn_end_tran(), fn_execute_internal(), fn_fetch(), fn_get_attr_type_str(), fn_get_class_num_objs(), fn_get_db_parameter(), fn_get_db_version(), fn_get_generated_keys(), fn_get_query_info(), fn_lob_new(), fn_lob_read(), fn_lob_write(), fn_make_out_rs(), fn_next_result(), fn_not_supported(), fn_oid(), fn_oid_get(), fn_oid_put(), fn_parameter_info(), fn_prepare_internal(), fn_proxy_cas_prepare(), fn_proxy_client_cursor(), fn_proxy_client_fetch(), fn_proxy_client_get_db_parameter(), fn_proxy_client_get_db_version(), fn_proxy_client_not_supported(), fn_proxy_client_prepare(), fn_proxy_client_prepare_and_execute(), fn_proxy_client_schema_info(), fn_proxy_client_set_db_parameter(), fn_savepoint(), fn_schema_info(), fn_set_cas_change_mode(), fn_set_db_parameter(), fn_xa_end_tran(), fn_xa_prepare(), fn_xa_recover(), get_attr_name(), get_attr_name_from_argv(), hm_new_srv_handle(), make_bind_value(), net_buf_error_msg_set(), net_read_to_file(), net_write_error(), netval_to_dbval(), prepare_column_list_info_set(), process_request(), proxy_client_execute_internal(), proxy_context_timeout(), proxy_convert_error_code(), proxy_is_invalid_statement(), proxy_send_request_to_cas_with_new_event(), sch_attr_priv(), sch_class_priv(), sch_exported_keys_or_cross_reference(), sch_imported_keys(), sch_query_execute(), sch_superclass(), set_host_variables(), ux_auto_commit(), ux_check_object(), ux_cursor(), ux_cursor_update(), ux_database_connect(), ux_end_tran(), ux_execute(), ux_execute_all(), ux_execute_array(), ux_fetch(), ux_get_parameter_info(), ux_get_query_info(), ux_make_out_rs(), ux_next_result(), ux_prepare(), and ux_schema_info().

#define CAS_NO_ERROR 0

Definition at line 41 of file cas.h.

Referenced by error_info_clear(), proxy_context_clear_error(), proxy_context_send_error(), proxy_context_set_error(), proxy_io_make_error_msg(), proxy_io_make_no_error(), proxy_process_client_register(), ux_get_generated_keys(), ux_get_generated_keys_client_insert(), and ux_get_generated_keys_server_insert().

#define DBMS_ERROR_INDICATOR -2

Definition at line 40 of file cas.h.

Referenced by cas_main(), class_type(), cur_tuple(), err_msg_set(), error_info_set_with_msg(), fetch_attribute(), fetch_result(), fn_collection(), fn_get_query_info(), fn_oid(), fn_savepoint(), fn_xa_end_tran(), fn_xa_prepare(), fn_xa_recover(), netval_to_dbval(), oid_attr_info_set(), prepare_column_list_info_set(), proxy_check_authorization(), proxy_client_io_new(), proxy_io_make_client_acl_fail(), proxy_process_client_register(), sch_exported_keys_or_cross_reference(), sch_imported_keys(), sch_query_execute(), set_host_variables(), update_error_query_count(), ux_check_object(), ux_col_seq_drop(), ux_col_seq_insert(), ux_col_seq_put(), ux_col_set_add(), ux_col_set_drop(), ux_cursor_update(), ux_database_connect(), ux_end_tran(), ux_execute(), ux_execute_all(), ux_execute_array(), ux_execute_batch(), ux_execute_call(), ux_get_attr_type_str(), ux_get_class_num_objs(), ux_get_generated_keys(), ux_get_generated_keys_client_insert(), ux_get_generated_keys_server_insert(), ux_get_last_insert_id(), ux_get_row_count(), ux_lob_new(), ux_lob_read(), ux_lob_write(), ux_oid_put(), ux_prepare(), and ux_set_isolation_level().

#define ERR_FILE_LENGTH 256

Definition at line 43 of file cas.h.

Referenced by error_info_clear(), and error_info_set_with_msg().

#define ERR_MSG_LENGTH 1024

Definition at line 42 of file cas.h.

Referenced by error_info_clear(), error_info_set_with_msg(), net_buf_error_msg_set(), and net_write_error().

#define ERROR_INDICATOR_UNSET 0

Definition at line 38 of file cas.h.

Referenced by error_info_clear(), error_info_set_with_msg(), and is_error_info_set().

#define MAX_HA_DBINFO_LENGTH (SRV_CON_DBNAME_SIZE + MAX_CONN_INFO_LENGTH)

Definition at line 46 of file cas.h.

Referenced by shard_cas_main(), and ux_check_connection().

#define MAX_SHARD_INFO_LENGTH 30

Definition at line 44 of file cas.h.

Referenced by net_error_append_shard_info().

Typedef Documentation

typedef struct t_error_info T_ERROR_INFO

Definition at line 81 of file cas.h.

typedef struct t_lob_handle T_LOB_HANDLE

Definition at line 56 of file cas.h.

typedef struct t_object T_OBJECT

Definition at line 48 of file cas.h.

typedef struct t_req_info T_REQ_INFO

Definition at line 72 of file cas.h.

Enumeration Type Documentation

enum tran_auto_commit

Enumerator
TRAN_NOT_AUTOCOMMIT
TRAN_AUTOCOMMIT
TRAN_AUTOROLLBACK

Definition at line 65 of file cas.h.

Function Documentation

T_BROKER_VERSION cas_get_client_version ( void )

Definition at line 2947 of file cas.c.

References t_req_info::client_version.

Referenced by cas_main(), shard_cas_main(), and ux_get_generated_keys_server_insert().

Here is the caller graph for this function:

int cas_get_db_connect_status ( void )

Definition at line 9705 of file cas_execute.c.

References db_get_connect_status().

Referenced by process_request(), ux_database_connect(), and ux_end_tran().

Here is the caller graph for this function:

void cas_set_db_connect_status ( int status )

Definition at line 9699 of file cas_execute.c.

References db_set_connect_status().

Referenced by cas_main(), err_msg_set(), and shard_cas_main().

Here is the caller graph for this function:

bool check_server_alive	(	const char *	db_name,
		const char *	db_host
	)

Definition at line 1517 of file cas.c.

References cas_shard_flag, t_appl_server_info::database_host, t_db_server::database_host, t_appl_server_info::database_name, t_db_server::database_name, db_name, i, t_shm_appl_server::monitor_server_flag, NULL, OFF, t_shm_appl_server::unusable_databases, t_shm_appl_server::unusable_databases_cnt, and t_shm_appl_server::unusable_databases_seq.

Referenced by cas_init().

Here is the caller graph for this function:

bool is_xa_prepared ( void )

Definition at line 273 of file cas_xa.c.

References xa_prepare_flag.

Referenced by cas_main(), and shard_cas_main().

Here is the caller graph for this function:

int query_seq_num_current_value ( void )

Definition at line 2941 of file cas.c.

References query_sequence_num.

Referenced by fn_prepare_internal(), and fn_schema_info().

Here is the caller graph for this function:

int query_seq_num_next_value ( void )

Definition at line 2935 of file cas.c.

References query_sequence_num.

Referenced by fn_get_query_info(), fn_prepare_internal(), and fn_schema_info().

Here is the caller graph for this function:

int restart_is_needed ( void )

Definition at line 2684 of file cas.c.

References t_shm_appl_server::appl_server_max_size, t_appl_server_info::cas_change_mode, CAS_CHANGE_MODE_KEEP, cas_req_count, envvar_bindir_file(), FALSE, NULL, t_appl_server_info::num_holdable_results, ONE_K, t_appl_server_info::pid, t_appl_server_info::psize, psize_at_start, TRUE, and ux_database_shutdown().

Referenced by cas_main(), fn_end_tran(), net_read_int_keep_con_auto(), net_read_process(), process_request(), and shard_cas_main().

Here is the caller graph for this function:

void set_hang_check_time ( void )

Definition at line 1488 of file cas.c.

References cas_shard_flag, t_appl_server_info::claimed_alive_time, t_shm_appl_server::monitor_hang_flag, NULL, and OFF.

Referenced by cas_init(), cas_log_begin_hang_check_time(), cas_main(), and process_request().

Here is the caller graph for this function:

void set_xa_prepare_flag ( void )

Definition at line 279 of file cas_xa.c.

References xa_prepare_flag.

Referenced by fn_xa_end_tran(), and fn_xa_prepare().

Here is the caller graph for this function:

void unset_hang_check_time ( void )

Definition at line 1505 of file cas.c.

References cas_shard_flag, t_appl_server_info::claimed_alive_time, t_shm_appl_server::monitor_hang_flag, NULL, and OFF.

Referenced by cas_log_end_hang_check_time(), cas_main(), and process_request().

Here is the caller graph for this function:

void unset_xa_prepare_flag ( void )

Definition at line 285 of file cas_xa.c.

References xa_prepare_flag.

Referenced by ux_end_tran().

Here is the caller graph for this function:

Variable Documentation

T_APPL_SERVER_INFO* as_info

Definition at line 153 of file cas.c.

Referenced by cas_log_begin_hang_check_time(), cas_log_end(), cas_log_open(), cas_log_query_cancel(), cas_log_reset(), cas_log_write(), cas_log_write2(), cas_log_write2_nonl(), cas_log_write_and_end(), cas_log_write_nonl(), cas_log_write_query_string_internal(), cas_log_write_value_string(), cas_slow_log_end(), cas_slow_log_open(), cas_slow_log_reset(), cas_slow_log_write(), cas_slow_log_write2(), cas_slow_log_write_and_end(), cas_slow_log_write_query_string(), cas_slow_log_write_value_string(), err_msg_set(), fn_end_tran(), fn_execute_array(), fn_execute_internal(), fn_prepare_internal(), fn_set_db_parameter(), hm_new_srv_handle(), hm_qresult_end(), hm_srv_handle_free_all(), need_reconnect_on_rctime(), net_buf_error_msg_set(), net_connect_proxy(), proxy_handler_is_cas_in_tran(), sch_query_execute(), uc_as_info(), ux_auto_commit(), ux_check_connection(), ux_cursor_close(), ux_database_connect(), ux_database_shutdown(), ux_end_tran(), ux_execute(), ux_execute_all(), ux_execute_array(), ux_execute_batch(), ux_execute_call(), and ux_set_cas_change_mode().

char broker_name[BROKER_NAME_LEN]

Definition at line 148 of file cas.c.

Referenced by admin_getid_cmd(), brief_monitor(), cas_init(), cas_main(), fn_end_tran(), main(), net_read_int_keep_con_auto(), net_read_process(), process_request(), and shard_cas_main().

char cas_client_type

Definition at line 169 of file cas.c.

Referenced by cas_main(), receiver_thr_f(), and sch_class_info().

bool cas_default_ansi_quotes

Definition at line 178 of file cas.c.

Referenced by get_num_markers(), and ux_get_default_setting().

int cas_default_isolation_level

Definition at line 176 of file cas.c.

Referenced by cas_main(), get_client_result_cache_lifetime(), set_db_parameter(), shard_cas_main(), ux_database_shutdown(), ux_get_default_setting(), and ux_set_default_setting().

int cas_default_lock_timeout

Definition at line 177 of file cas.c.

Referenced by cas_main(), fn_set_db_parameter(), set_db_parameter(), shard_cas_main(), ux_database_shutdown(), ux_get_default_setting(), and ux_set_default_setting().

bool cas_default_no_backslash_escapes

Definition at line 180 of file cas.c.

Referenced by consume_tokens(), fn_get_db_parameter(), and ux_get_default_setting().

int cas_info_size

Definition at line 183 of file cas.c.

Referenced by cas_main(), cas_send_connect_reply_to_driver(), net_read_header(), process_request(), proxy_io_make_client_dbinfo_ok(), and set_cas_info_size().

int cas_send_result_flag

Definition at line 182 of file cas.c.

Referenced by fn_end_tran(), and process_request().

int cas_shard_flag

T_ERROR_INFO err_info

Definition at line 186 of file cas.c.

Referenced by ci_stmt_get_next_error_impl(), err_msg_set(), error_info_clear(), error_info_set_with_msg(), fn_end_tran(), fn_execute_array(), fn_execute_internal(), fn_lob_new(), fn_lob_read(), fn_lob_write(), fn_prepare_internal(), is_error_info_set(), stmt_make_error_info(), stmt_remove_error_info(), and stmt_reset_session_and_parse().

int errors_in_transaction

const char* program_name

Definition at line 147 of file cas.c.

Referenced by createdb(), main(), ssession_find_or_create_session(), tzc_compute_timezone_checksum(), and ux_database_connect().

char query_cancel_flag

Definition at line 162 of file cas.c.

Referenced by cas_log_query_cancel(), cas_main(), and query_cancel().

INT64 query_cancel_time

Definition at line 161 of file cas.c.

Referenced by cas_log_query_cancel(), and query_cancel().

struct timeval query_start_time

Definition at line 158 of file cas.c.

Referenced by cas_main(), fn_end_tran(), fn_execute_array(), fn_execute_internal(), fn_prepare_internal(), shard_cas_main(), and ux_auto_commit().

T_SHM_APPL_SERVER* shm_appl

Definition at line 152 of file cas.c.

int shm_as_index

Definition at line 151 of file cas.c.

Referenced by cas_init(), cas_init_shm(), cas_main(), cas_send_connect_reply_to_driver(), fn_end_tran(), make_error_log_filename(), make_sql_log_filename(), net_read_int_keep_con_auto(), process_request(), and shard_cas_main().

int shm_proxy_id

Definition at line 154 of file cas.c.

Referenced by cas_init(), cas_init_shm(), cas_main(), make_error_log_filename(), make_sql_log_filename(), and shard_cas_main().

int shm_shard_cas_id

Definition at line 155 of file cas.c.

Referenced by cas_init(), cas_init_shm(), cas_main(), cas_register_to_proxy(), make_error_log_filename(), make_sql_log_filename(), and net_error_append_shard_info().

int shm_shard_id

Definition at line 144 of file cas.c.

Referenced by cas_init(), cas_init_shm(), cas_main(), cas_register_to_proxy(), make_error_log_filename(), make_sql_log_filename(), net_error_append_shard_info(), set_db_connection_info(), shard_cas_main(), ux_execute(), ux_execute_all(), ux_execute_array(), ux_execute_batch(), and ux_execute_call().

char stripped_column_name

Definition at line 168 of file cas.c.

Referenced by broker_config_dump(), broker_config_read_internal(), cas_main(), conf_copy_broker(), prepare_column_list_info_set(), shard_cas_main(), and ux_make_out_rs().

struct timeval tran_start_time

Definition at line 157 of file cas.c.

Referenced by appl_info_display(), cas_main(), fn_end_tran(), net_read_int_keep_con_auto(), net_read_process(), shard_cas_main(), and ux_auto_commit().

int tran_timeout

Definition at line 159 of file cas.c.

Referenced by cas_main(), fn_end_tran(), shard_cas_main(), and ux_auto_commit().

src
broker
cas.h
Generated by 1.8.11