File cas_common_main.h¶

FileList > broker > cas_common_main.h

#include "cas_protocol.h"
#include "cas_network.h"
#include "cas_common_function.h"

Classes¶

Type	Name
struct	CAS_MAIN_OPS
struct	DB_CONN_INFO

Public Types¶

Type	Name
typedef void(*	cas_cleanup_callback_t
typedef void(*	cas_cleanup_session_fn_t
typedef void(*	cas_database_shutdown_callback_t
typedef int(*	cas_db_connect_fn_t
typedef void(*	cas_db_post_connect_fn_t
typedef int(*	cas_db_pre_connect_fn_t
typedef FN_RETURN(*	cas_process_request_fn_t
typedef void(*	cas_send_connect_reply_fn_t
typedef void(*	cas_set_session_id_fn_t

Public Attributes¶

Type	Name
FN_RETURN	cas_main_fn_ret

Public Functions¶

Type	Name
int	cas_accept_client (SOCKET br_sock_fd, SOCKET * client_sock_fd, int * client_ip_addr)
void	cas_final (void)
void	cas_finish_session (SOCKET client_sock_fd, bool ssl_client)
void	cas_free (bool from_sighandler)
T_BROKER_VERSION	cas_get_client_version (void)
int	cas_get_graceful_down_timeout (void)
int	cas_handle_db_connection (SOCKET client_sock_fd, T_REQ_INFO * req_info, DB_CONN_INFO * conn_info, char * cas_info, int client_ip_addr, CAS_MAIN_OPS * ops, bool is_new_connection)
int	cas_main_init (T_NET_BUF * net_buf, SOCKET * srv_sock_fd)
int	cas_main_loop (CAS_MAIN_OPS * ops)
int	cas_parse_db_info (char * read_buf, int db_info_size, T_REQ_INFO * req_info, DB_CONN_INFO * conn_info)
void	cas_set_cleanup_callback (cas_cleanup_callback_t callback)
void	cas_set_database_shutdown_callback (cas_database_shutdown_callback_t callback)
void	cas_sig_handler (int signo)
bool	check_server_alive (const char * db_name, const char * db_host)
int	net_read_header_keep_con_on (SOCKET clt_sock_fd, MSG_HEADER * client_msg_header)
int	net_read_int_keep_con_auto (SOCKET clt_sock_fd, MSG_HEADER * client_msg_header, T_REQ_INFO * req_info, SOCKET srv_sock_fd)
void	query_cancel (int signo)
int	query_seq_num_current_value (void)
int	query_seq_num_next_value (void)
int	restart_is_needed (void)
void	set_cas_info_size (void)
void	set_hang_check_time (void)
void	unset_hang_check_time (void)

Macros¶

Type	Name
define	FUNC_NEEDS_RESTORING_CON_STATUS (func_code) `/* multi line expression */`

Public Types Documentation¶

typedef cas_cleanup_callback_t¶

typedef void(* cas_cleanup_callback_t) (void);

typedef cas_cleanup_session_fn_t¶

typedef void(* cas_cleanup_session_fn_t) (void);

typedef cas_database_shutdown_callback_t¶

typedef void(* cas_database_shutdown_callback_t) (bool request_server);

typedef cas_db_connect_fn_t¶

typedef int(* cas_db_connect_fn_t) (SOCKET client_sock_fd, const char *db_name, const char *db_user, const char *db_passwd, const char *url, T_REQ_INFO *req_info, char *cas_info);

typedef cas_db_post_connect_fn_t¶

typedef void(* cas_db_post_connect_fn_t) (void *context, struct timeval *cas_start_time, int shm_as_index, int client_ip_addr, char *db_name, char *db_user, const char *url, bool is_new_connection);

typedef cas_db_pre_connect_fn_t¶

typedef int(* cas_db_pre_connect_fn_t) (const char *db_name, const char *db_user, const char *db_passwd, const char *url, void *context);

typedef cas_process_request_fn_t¶

typedef FN_RETURN(* cas_process_request_fn_t) (SOCKET sock_fd, T_NET_BUF *net_buf, T_REQ_INFO *req_info, SOCKET srv_sock_fd);

typedef cas_send_connect_reply_fn_t¶

typedef void(* cas_send_connect_reply_fn_t) (T_CAS_PROTOCOL protocol, SOCKET client_sock_fd, char *cas_info);

typedef cas_set_session_id_fn_t¶

typedef void(* cas_set_session_id_fn_t) (T_CAS_PROTOCOL protocol, char *session);

Public Attributes Documentation¶

variable cas_main_fn_ret¶

FN_RETURN cas_main_fn_ret;

Public Functions Documentation¶

function cas_accept_client¶

int cas_accept_client (
    SOCKET br_sock_fd,
    SOCKET * client_sock_fd,
    int * client_ip_addr
)

function cas_final¶

void cas_final (
    void
)

function cas_finish_session¶

void cas_finish_session (
    SOCKET client_sock_fd,
    bool ssl_client
)

function cas_free¶

void cas_free (
    bool from_sighandler
)

function cas_get_client_version¶

T_BROKER_VERSION cas_get_client_version (
    void
)

function cas_get_graceful_down_timeout¶

int cas_get_graceful_down_timeout (
    void
)

function cas_handle_db_connection¶

int cas_handle_db_connection (
    SOCKET client_sock_fd,
    T_REQ_INFO * req_info,
    DB_CONN_INFO * conn_info,
    char * cas_info,
    int client_ip_addr,
    CAS_MAIN_OPS * ops,
    bool is_new_connection
)

function cas_main_init¶

int cas_main_init (
    T_NET_BUF * net_buf,
    SOCKET * srv_sock_fd
)

function cas_main_loop¶

int cas_main_loop (
    CAS_MAIN_OPS * ops
)

function cas_parse_db_info¶

int cas_parse_db_info (
    char * read_buf,
    int db_info_size,
    T_REQ_INFO * req_info,
    DB_CONN_INFO * conn_info
)

function cas_set_cleanup_callback¶

void cas_set_cleanup_callback (
    cas_cleanup_callback_t callback
)

function cas_set_database_shutdown_callback¶

void cas_set_database_shutdown_callback (
    cas_database_shutdown_callback_t callback
)

function cas_sig_handler¶

void cas_sig_handler (
    int signo
)

function check_server_alive¶

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

function net_read_header_keep_con_on¶

int net_read_header_keep_con_on (
    SOCKET clt_sock_fd,
    MSG_HEADER * client_msg_header
)

function net_read_int_keep_con_auto¶

int net_read_int_keep_con_auto (
    SOCKET clt_sock_fd,
    MSG_HEADER * client_msg_header,
    T_REQ_INFO * req_info,
    SOCKET srv_sock_fd
)

function query_cancel¶

void query_cancel (
    int signo
)

function query_seq_num_current_value¶

int query_seq_num_current_value (
    void
)

function query_seq_num_next_value¶

int query_seq_num_next_value (
    void
)

function restart_is_needed¶

int restart_is_needed (
    void
)

function set_cas_info_size¶

void set_cas_info_size (
    void
)

function set_hang_check_time¶

void set_hang_check_time (
    void
)

function unset_hang_check_time¶

void unset_hang_check_time (
    void
)

Macro Definition Documentation¶

define FUNC_NEEDS_RESTORING_CON_STATUS¶

#define FUNC_NEEDS_RESTORING_CON_STATUS (
    func_code
) `/* multi line expression */`

The documentation for this class was generated from the following file cubrid/src/broker/cas_common_main.h