File cas.c¶

#include <stdio.h>
#include <stdlib.h>
#include <signal.h>
#include <assert.h>
#include <unistd.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <sys/socket.h>
#include <sys/time.h>
#include "cas_common.h"
#include "cas_common_main.h"
#include "cas_common_vars.h"
#include "broker_shm.h"
#include "broker_util.h"
#include "broker_env_def.h"
#include "broker_filename.h"
#include "cas_log.h"
#include "cas_common_execute.h"
#include "perf_monitor.h"
#include "cas_sql_log2.h"
#include "error_manager.h"
#include "ddl_log.h"
#include "cas.h"
#include "cas_network.h"
#include "cas_function.h"
#include "cas_net_buf.h"
#include "cas_execute.h"
#include "connection_support.hpp"
#include "broker_process_size.h"
#include "cas_ssl.h"

Classes¶

Type	Name
struct	CAS_CLEANUP_CONTEXT

Public Attributes¶

Type	Name
FN_RETURN	cas_main_fn_ret

Public Static Attributes¶

Type	Name
char	cas_db_name
char	cas_db_passwd
char	cas_db_user
T_SERVER_FUNC	server_fn_table
const char *	server_func_name

Public Functions¶

Type	Name
int	main (int argc, char * argv)

Public Static Functions¶

Type	Name
void	cas_cleanup_session (void)
int	cas_db_connect (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)
int	cas_init (void)
int	cas_init_shm (void)
int	cas_main (void)
void	cas_make_session_for_driver (char * out)
void	cas_post_db_connect (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)
int	cas_register_to_proxy (SOCKET proxy_sock_fd)
void	cas_send_connect_reply_to_driver (T_CAS_PROTOCOL protocol, SOCKET client_sock_fd, char * cas_info)
void	cas_set_session_id (T_CAS_PROTOCOL protocol, char * session)
void	clear_db_connection_info (void)
bool	need_database_reconnect (void)
int	net_read_process (SOCKET proxy_sock_fd, MSG_HEADER * client_msg_header, T_REQ_INFO * req_info)
FN_RETURN	process_request (SOCKET sock_fd, T_NET_BUF * net_buf, T_REQ_INFO * req_info, SOCKET srv_sock_fd)
void	set_db_connection_info (void)
void	set_db_parameter (void)
int	shard_cas_main (void)

Public Attributes Documentation¶

variable cas_main_fn_ret¶

FN_RETURN cas_main_fn_ret;

Public Static Attributes Documentation¶

variable cas_db_name¶

char cas_db_name[(32+((CUB_MAXHOSTNAMELEN+1) *2))];

variable cas_db_passwd¶

char cas_db_passwd[32];

variable cas_db_user¶

char cas_db_user[32];

variable server_fn_table¶

T_SERVER_FUNC server_fn_table[];

variable server_func_name¶

const char* server_func_name[];

Public Functions Documentation¶

function main¶

int main (
    int argc,
    char * argv
)

Public Static Functions Documentation¶

function cas_cleanup_session¶

static void cas_cleanup_session (
    void
)

function cas_db_connect¶

static int cas_db_connect (
    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
)

function cas_init¶

static int cas_init (
    void
)

function cas_init_shm¶

static int cas_init_shm (
    void
)

function cas_main¶

static int cas_main (
    void
)

function cas_make_session_for_driver¶

static void cas_make_session_for_driver (
    char * out
)

function cas_post_db_connect¶

static void cas_post_db_connect (
    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
)

function cas_register_to_proxy¶

static int cas_register_to_proxy (
    SOCKET proxy_sock_fd
)

function cas_send_connect_reply_to_driver¶

static void cas_send_connect_reply_to_driver (
    T_CAS_PROTOCOL protocol,
    SOCKET client_sock_fd,
    char * cas_info
)

function cas_set_session_id¶

static void cas_set_session_id (
    T_CAS_PROTOCOL protocol,
    char * session
)

function clear_db_connection_info¶

static void clear_db_connection_info (
    void
)

function need_database_reconnect¶

static bool need_database_reconnect (
    void
)

function net_read_process¶

static int net_read_process (
    SOCKET proxy_sock_fd,
    MSG_HEADER * client_msg_header,
    T_REQ_INFO * req_info
)

function process_request¶

static FN_RETURN process_request (
    SOCKET sock_fd,
    T_NET_BUF * net_buf,
    T_REQ_INFO * req_info,
    SOCKET srv_sock_fd
)

function set_db_connection_info¶

static void set_db_connection_info (
    void
)

function set_db_parameter¶

static void set_db_parameter (
    void
)

function shard_cas_main¶

static int shard_cas_main (
    void
)

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