File cas_common_main.c¶

FileList > broker > cas_common_main.c

#include <string.h>
#include <assert.h>
#include <strings.h>
#include <sys/time.h>
#include <time.h>
#include <unistd.h>
#include <signal.h>
#include <fcntl.h>
#include "cas_common_main.h"
#include "broker_shm.h"
#include "cas_log.h"
#include "cas_handle.h"
#include "error_manager.h"
#include "ddl_log.h"
#include "broker_process_size.h"
#include "cas_common_execute.h"
#include "cas_protocol.h"
#include "cas_common_vars.h"
#include "dbi.h"
#include "perf_monitor.h"
#include "cas_network.h"
#include "broker_env_def.h"
#include "broker_filename.h"
#include "cas_sql_log2.h"
#include "broker_acl.h"
#include "cas_ssl.h"
#include "broker_util.h"
#include "broker_recv_fd.h"
#include <netinet/tcp.h>

Public Attributes¶

Type	Name
FN_RETURN	cas_main_fn_ret = `FN\_KEEP\_CONN`

Public Static Attributes¶

Type	Name
cas_cleanup_callback_t	cleanup_callback = `[NULL](freelistheap_8h.md#define-null)`
cas_database_shutdown_callback_t	database_shutdown_callback = `[NULL](freelistheap_8h.md#define-null)`
int	query_sequence_num

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_db_connect_status (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_set_db_connect_status (int status)
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)

Public Attributes Documentation¶

variable cas_main_fn_ret¶

FN_RETURN cas_main_fn_ret;

Public Static Attributes Documentation¶

variable cleanup_callback¶

cas_cleanup_callback_t cleanup_callback;

variable database_shutdown_callback¶

cas_database_shutdown_callback_t database_shutdown_callback;

variable query_sequence_num¶

int query_sequence_num;

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_db_connect_status¶

int cas_get_db_connect_status (
    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_set_db_connect_status¶

void cas_set_db_connect_status (
    int status
)

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
)

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