#include <sys/types.h>
#include <sys/socket.h>
#include "porting.h"

Include dependency graph for cas_common.h:

Macros
#define	makestring1(x) #x

#define	makestring(x) makestring1(x)

#define	MAX_SERVER_H_ID 256

#define	MAX_BIND_VALUE 10240

#define	MAX_QUERY_LEN 100000

#define	CAS_RUNNER_CONF "cas_runner.conf"

#define	CAS_RUNNER_CONF_ENV "CAS_RUNNER_CONF"

#define	CAS_USE_DEFAULT_DB_PARAM -2

#define	ON 1

#define	OFF 0

#define	TRUE 1

#define	FALSE 0

#define	INT_STR_LEN 16

#define	MALLOC(SIZE) malloc(SIZE)

#define	REALLOC(PTR, SIZE) ((PTR == NULL) ? malloc(SIZE) : realloc(PTR, SIZE))

#define	FREE(PTR) free(PTR)

#define	FREE_MEM(PTR)

#define	ALLOC_COPY(PTR, STR)

#define	CLOSE_SOCKET(X)

#define	ALLOC_N_COPY(PTR, STR, SIZE)

#define	SLEEP_SEC(X) sleep(X)

#define	SLEEP_MILISEC(sec, msec)

#define	THREAD_BEGIN(THR_ID, FUNC, ARG)

#define	READ_FROM_SOCKET(fd, buf, size) read(fd, buf, size)

#define	WRITE_TO_SOCKET(fd, buf, size) write(fd, buf, size)

#define	THREAD_FUNC void*

#define	CAS_SCHEMA_DEFAULT_CHARSET (lang_charset ())

Typedefs
typedef socklen_t	T_SOCKLEN

Enumerations
enum	{ FN_STATUS_NONE = -2, FN_STATUS_IDLE = -1, FN_STATUS_CONN = 0, FN_STATUS_BUSY = 1, FN_STATUS_DONE = 2 }

Functions
int	uts_key_check_local_host (void)

Macro Definition Documentation

#define ALLOC_COPY	(	PTR,
		STR
	)

Value:

do {                    \
	  if (STR == NULL)         \
        PTR = NULL;             \
	  else {               \
        PTR = (char *) MALLOC(strlen(STR) + 1); \
	    if (PTR) {             \
          strcpy(PTR, STR);         \
        }                   \
      }                 \
    } while (0)

Definition at line 66 of file cas_common.h.

Referenced by log_unformat_ahead_volumes(), logddl_set_err_msg(), logpb_delete(), net_buf_column_info_set(), net_buf_cp_post_send_file(), prepare_column_list_info_set(), str_like(), and ux_prepare().

#define ALLOC_N_COPY	(	PTR,
		STR,
		SIZE
	)

Value:

do {                    \
	  if (STR == NULL)         \
        PTR = NULL;             \
	  else {               \
        PTR = MALLOC(SIZE);         \
	    if (PTR) {             \
          strncpy(PTR, STR, SIZE);      \
          PTR[SIZE - 1] = '\0';     \
        }                   \
      }                 \
    } while (0)

Definition at line 92 of file cas_common.h.

#define CAS_RUNNER_CONF "cas_runner.conf"

Definition at line 41 of file cas_common.h.

Referenced by read_conf().

#define CAS_RUNNER_CONF_ENV "CAS_RUNNER_CONF"

Definition at line 42 of file cas_common.h.

Referenced by read_conf().

#define CAS_SCHEMA_DEFAULT_CHARSET (lang_charset ())

Definition at line 170 of file cas_common.h.

Referenced by add_res_data_bigint(), add_res_data_bytes(), add_res_data_date(), add_res_data_datetime(), add_res_data_datetimetz(), add_res_data_double(), add_res_data_float(), add_res_data_int(), add_res_data_lob_handle(), add_res_data_object(), add_res_data_short(), add_res_data_time(), add_res_data_timestamp(), add_res_data_timestamptz(), bind_value_print(), dbval_to_net_buf(), fetch_attribute(), fetch_class(), fetch_constraint(), fetch_foreign_keys(), fetch_methfile(), fetch_method(), fetch_privilege(), fetch_trigger(), prepare_column_list_info_set(), schema_attr_meta(), schema_attrpriv_meta(), schema_classpriv_meta(), schema_constraint_meta(), schema_directsuper_meta(), schema_fk_info_meta(), schema_method_meta(), schema_methodfile_meta(), schema_primarykey_meta(), schema_query_spec_meta(), schema_superclasss_meta(), schema_table_meta(), and schema_trigger_meta().

#define CAS_USE_DEFAULT_DB_PARAM -2

Definition at line 43 of file cas_common.h.

Referenced by fn_proxy_client_set_db_parameter(), set_db_parameter(), and shard_shm_init_client_info().

#define CLOSE_SOCKET ( X )

Value:

do {            \
	  if (!IS_INVALID_SOCKET(X)) close(X);     \
      (X) = INVALID_SOCKET; \
    } while (0)

Definition at line 85 of file cas_common.h.

Referenced by br_activate(), cas_main(), cleanup(), connect_srv(), dispatch_thr_f(), init_proxy_env(), net_connect_proxy(), net_init_env(), proxy_convert_error_code(), proxy_io_cas_lsnr(), proxy_io_close_all_fd(), proxy_io_process(), proxy_io_register_to_broker(), proxy_listener_thr_f(), proxy_process_cas_read_error(), proxy_process_cas_write_error(), proxy_process_client_read_error(), proxy_process_client_write_error(), proxy_socket_io_add(), proxy_socket_io_delete(), proxy_socket_io_destroy(), proxy_socket_io_new_client(), receiver_thr_f(), shard_cas_main(), and shard_dispatch_thr_f().

#define FALSE 0

Definition at line 49 of file cas_common.h.

#define FREE ( PTR ) free(PTR)

Definition at line 56 of file cas_common.h.

Referenced by btree_fix_ovfl_oid_page(), btree_key_append_object_as_new_overflow(), btree_log_page(), catalog_add_class_info(), catalog_drop_all_representation_and_class(), catalog_drop_disk_representation_from_page(), catalog_drop_old_representations(), catalog_drop_representation_class_from_page(), catalog_drop_representation_item(), catalog_insert_representation_item(), catalog_put_record_into_page(), catalog_put_representation_item(), catalog_update_class_info(), dbval_to_net_buf(), disk_set_boot_hfid(), disk_set_checkpoint(), disk_set_creation(), disk_set_link(), disk_stab_init(), ehash_connect_bucket(), ehash_create_helper(), ehash_expand_directory(), ehash_shrink_directory(), file_create(), file_descriptor_update(), heap_create_internal(), heap_reuse(), heap_stats_update_internal(), heap_update_bigone(), logpb_check_and_reset_temp_lsa(), pgbuf_copy_from_area(), pgbuf_flush(), pgbuf_set_dirty(), qfile_add_overflow_tuple_to_list(), qfile_add_tuple_get_pos_in_list(), qfile_add_tuple_to_list(), qfile_allocate_new_ovf_page(), qfile_allocate_new_page(), qfile_copy_list_pages(), qfile_overwrite_tuple(), qmgr_set_dirty_page(), serialize_collection_as_string(), shard_cas_main(), vacuum_add_dropped_file(), vacuum_cleanup_dropped_files(), vacuum_consume_buffer_log_blocks(), vacuum_create_file_for_dropped_files(), vacuum_heap_record(), vacuum_heap_record_insid_and_prev_version(), and xbtree_add_index().

#define FREE_MEM ( PTR )

Value:

do {            \
	  if (PTR) {       \
	    FREE(PTR);     \
        PTR = 0;    \
      }         \
    } while (0)

Definition at line 58 of file cas_common.h.

Referenced by broker_delete_proxy_conn_by_fd(), broker_delete_proxy_conn_by_proxy_id(), broker_free_all_proxy_conn_ent(), cas_main(), cas_runner(), col_update_info_free(), conf_item_free(), dbval_to_net_buf(), delete_node(), fetch_attribute(), fn_collection(), fn_proxy_client_prepare(), free_br_tester_info(), free_env(), free_node(), get_attr_name_from_argv(), get_domain_str(), hm_qresult_end(), hm_srv_handle_free(), hm_srv_handle_free_all(), info_add(), init_default_conn_info(), link_list_add(), log_converter(), logddl_destroy(), logddl_free(), logddl_init(), logddl_set_err_msg(), logddl_set_sql_text(), main(), make_bind_value(), make_env(), make_node_info(), make_prepare_call_info(), make_sql_stmt(), net_buf_clear(), net_buf_column_info_set(), net_buf_cp_post_send_file(), net_buf_destroy(), net_decode_str(), prepare_column_list_info_set(), print_result(), print_result_set(), process_request(), proxy_client_check_waiter_and_wakeup(), proxy_client_execute_internal(), proxy_client_io_destroy(), proxy_context_add_stmt(), proxy_context_destroy(), proxy_context_free_stmt(), proxy_event_dup(), proxy_event_free(), proxy_handler_process_client_request(), proxy_io_buffer_clear(), proxy_io_destroy(), proxy_send_prepared_stmt_to_client(), proxy_shard_io_destroy(), proxy_socket_io_destroy(), proxy_waiter_free(), query_info_add(), query_info_add_ne(), query_info_clear(), release_all_fk_info_results(), sch_attr_priv(), sch_class_priv(), shard_cqueue_destroy(), shard_queue_dequeue(), shard_queue_destroy(), shard_stmt_check_waiter_and_wakeup(), shard_stmt_destroy(), shard_stmt_free(), shard_stmt_save_prepare_request(), sql_info_write(), srv_handle_content_free(), str_like(), t_string_free(), t_string_make(), uc_change_config(), uc_info_free(), uc_unicas_conf_free(), ut_get_line(), ux_cursor(), ux_cursor_update(), ux_execute(), ux_execute_all(), ux_execute_array(), ux_execute_call(), ux_get_attr_type_str(), ux_oid_get(), ux_oid_put(), ux_prepare(), ux_prepare_call_info_free(), and ux_use_sp_out().

#define INT_STR_LEN 16

Definition at line 51 of file cas_common.h.

#define makestring ( x ) makestring1(x)

Definition at line 36 of file cas_common.h.

#define makestring1 ( x ) #x

Definition at line 35 of file cas_common.h.

#define MALLOC ( SIZE ) malloc(SIZE)

#define MAX_BIND_VALUE 10240

Definition at line 39 of file cas_common.h.

Referenced by cas_runner(), and process_bind().

#define MAX_QUERY_LEN 100000

Definition at line 40 of file cas_common.h.

#define MAX_SERVER_H_ID 256

Definition at line 38 of file cas_common.h.

#define OFF 0

Definition at line 46 of file cas_common.h.

#define ON 1

Definition at line 45 of file cas_common.h.

#define READ_FROM_SOCKET	(	fd,
		buf,
		size
	)	read(fd, buf, size)

Definition at line 141 of file cas_common.h.

Referenced by check_cas_log(), and read_from_client_with_timeout().

#define REALLOC	(	PTR,
		SIZE
	)	((PTR == NULL) ? malloc(SIZE) : realloc(PTR, SIZE))

Definition at line 54 of file cas_common.h.

Referenced by get_attr_name(), hm_new_srv_handle(), log_top(), net_buf_realloc(), net_decode_str(), prepare_column_list_info_set(), query_info_add(), query_info_add_ne(), sch_attr_priv(), sch_class_priv(), sch_superclass(), sql_info_add(), t_bind_string_add(), and ux_execute_all().

#define SLEEP_MILISEC	(	sec,
		msec
	)

Value:

do {                        \
      struct timeval sleep_time_val;        \
      sleep_time_val.tv_sec = sec;          \
      sleep_time_val.tv_usec = (msec) * 1000;   \
      select(0, 0, 0, 0, &sleep_time_val);      \
    } while(0)

Definition at line 110 of file cas_common.h.

#define SLEEP_SEC ( X ) sleep(X)

Definition at line 109 of file cas_common.h.

Referenced by admin_restart_cmd(), and shard_cas_main().

#define THREAD_BEGIN	(	THR_ID,
		FUNC,
		ARG
	)

Value:

do {                    \
      pthread_attr_t    thread_attr;    \
      pthread_attr_init(&thread_attr);  \
      pthread_attr_setdetachstate(&thread_attr, PTHREAD_CREATE_DETACHED); \
      pthread_create(&(THR_ID), &thread_attr, FUNC, ARG);   \
      pthread_attr_destroy(&thread_attr);  \
    } while (0)

Definition at line 126 of file cas_common.h.

Referenced by log_top_query(), and main().

#define THREAD_FUNC void*

Definition at line 148 of file cas_common.h.

Referenced by cas_monitor_worker(), dispatch_thr_f(), insert_db_server_check_list(), proxy_check_worker(), proxy_monitor_thr_f(), proxy_monitor_worker(), receiver_thr_f(), server_monitor_thr_f(), and shard_dispatch_thr_f().

#define TRUE 1

Definition at line 48 of file cas_common.h.

#define WRITE_TO_SOCKET	(	fd,
		buf,
		size
	)	write(fd, buf, size)

Definition at line 142 of file cas_common.h.

Referenced by write_to_client_with_timeout().

Typedef Documentation

typedef socklen_t T_SOCKLEN

Definition at line 156 of file cas_common.h.

Enumeration Type Documentation

anonymous enum

Enumerator
FN_STATUS_NONE
FN_STATUS_IDLE
FN_STATUS_CONN
FN_STATUS_BUSY
FN_STATUS_DONE

Definition at line 159 of file cas_common.h.

Function Documentation

int uts_key_check_local_host ( void )

Macros

Typedefs

Enumerations

Functions

Macro Definition Documentation

Typedef Documentation

Enumeration Type Documentation

Function Documentation