File server_support.h¶

FileList > connection > server_support.h

#include "connection_defs.h"
#include "connection_sr.h"
#include "thread_entry.hpp"
#include "thread_entry_task.hpp"

Public Types¶

Type	Name
enum	css_thread_stop_type

Public Functions¶

Type	Name
char *	css_add_client_version_string (THREAD_ENTRY * thread_p, const char * version_string)
bool	css_are_all_request_handlers_suspended (void)
void	css_block_all_active_conn (unsigned short stop_phase)
int	css_change_ha_server_state (THREAD_ENTRY * thread_p, HA_SERVER_STATE state, bool force, int timeout, bool heartbeat)
int	css_check_accessibility (SOCKET new_fd)
int	css_check_conn (CSS_CONN_ENTRY * p)
int	css_check_ha_server_state_for_client (THREAD_ENTRY * thread_p, int whence)
void	css_cleanup_server_queues (unsigned int eid)
size_t	css_count_transaction_worker_threads (THREAD_ENTRY * thread_p, int tran_index, int client_id)
void	css_end_server_request (CSS_CONN_ENTRY * conn)
int	css_get_client_id (THREAD_ENTRY * thread_p)
char *	css_get_client_version_string (void)
unsigned int	css_get_comm_request_id (THREAD_ENTRY * thread_p)
struct css_conn_entry *	css_get_current_conn_entry (void)
int	css_get_ha_num_of_hosts (void)
size_t	css_get_max_connections ()
size_t	css_get_max_task_count ()
size_t	css_get_max_workers ()
size_t	css_get_num_request_workers (void)
struct timeval *	css_get_shutdown_timeout (void)
void	css_get_task_stats (UINT64 * stats_out)
void	css_get_thread_stats (UINT64 * stats_out)
HA_SERVER_STATE	css_ha_server_state (void)
int	css_init (THREAD_ENTRY * thread_p, char * server_name, int server_name_length, int connection_id)
void	css_initialize_server_interfaces (int()(THREAD_ENTRY* thrd, unsigned* int eid, int request, int size, char *buffer) request_handler)
bool	css_is_ha_repl_delayed (void)
bool	css_is_shutdown_timeout_expired (void)
bool	css_is_shutdowning_server ()
int	css_job_queues_start_scan (THREAD_ENTRY * thread_p, int show_type, DB_VALUE arg_values, int arg_cnt, void ptr)
int	css_notify_ha_log_applier_state (THREAD_ENTRY * thread_p, HA_LOG_APPLIER_STATE state)
char *	css_pack_server_name (const char * server_name, int * name_length)
void	css_push_external_task (CSS_CONN_ENTRY * conn, cubthread::entry_task * task)
void	css_push_server_task (CSS_CONN_ENTRY & conn_ref)
unsigned int	css_receive_data_from_client (CSS_CONN_ENTRY * conn, unsigned int eid, char buffer, int** * size)
unsigned int	css_receive_data_from_client_with_timeout (CSS_CONN_ENTRY * conn, unsigned int eid, char buffer, int** * size, int timeout)
unsigned int	css_send_abort_to_client (CSS_CONN_ENTRY * conn, unsigned int eid)
unsigned int	css_send_data_to_client (CSS_CONN_ENTRY * conn, unsigned int eid, char * buffer, int buffer_size, int wait_time=0)
unsigned int	css_send_error_to_client (CSS_CONN_ENTRY * conn, unsigned int eid, char * buffer, int buffer_size)
unsigned int	css_send_reply_and_2_data_to_client (CSS_CONN_ENTRY * conn, unsigned int eid, char * reply, int reply_size, char * buffer1, int buffer1_size, char * buffer2, int buffer2_size, std::function< void() > && deleter)
unsigned int	css_send_reply_and_3_data_to_client (CSS_CONN_ENTRY * conn, unsigned int eid, char * reply, int reply_size, char * buffer1, int buffer1_size, char * buffer2, int buffer2_size, char * buffer3, int buffer3_size, std::function< void() > && deleter)
unsigned int	css_send_reply_and_data_to_client (CSS_CONN_ENTRY * conn, unsigned int eid, char * reply, int reply_size, char * buffer, int buffer_size, std::function< void() > && deleter)
unsigned int	css_send_reply_and_data_to_client_direct (CSS_CONN_ENTRY * conn, unsigned int eid, char * reply, int reply_size, char * buffer, int buffer_size)
void	css_set_ha_num_of_hosts (int num)
void	css_set_ha_repl_delayed (void)
void	css_set_thread_info (THREAD_ENTRY * thread_p, int client_id, int rid, int tran_index, int net_request_index)
void	css_start_shutdown_server ()
void	css_unset_ha_repl_delayed (void)

Macros¶

Type	Name
define	TIMEOUT_INFINITE `-1`
define	TIMEOUT_NOWAIT `0`

Public Types Documentation¶

enum css_thread_stop_type¶

enum css_thread_stop_type {
    THREAD_STOP_WORKERS_EXCEPT_LOGWR,
    THREAD_STOP_LOGWR
};

Public Functions Documentation¶

function css_add_client_version_string¶

char * css_add_client_version_string (
    THREAD_ENTRY * thread_p,
    const  char * version_string
)

function css_are_all_request_handlers_suspended¶

bool css_are_all_request_handlers_suspended (
    void
)

function css_block_all_active_conn¶

void css_block_all_active_conn (
    unsigned  short stop_phase
)

function css_change_ha_server_state¶

int css_change_ha_server_state (
    THREAD_ENTRY * thread_p,
    HA_SERVER_STATE state,
    bool force,
    int timeout,
    bool heartbeat
)

function css_check_accessibility¶

int css_check_accessibility (
    SOCKET new_fd
)

function css_check_conn¶

int css_check_conn (
    CSS_CONN_ENTRY * p
)

function css_check_ha_server_state_for_client¶

int css_check_ha_server_state_for_client (
    THREAD_ENTRY * thread_p,
    int whence
)

function css_cleanup_server_queues¶

void css_cleanup_server_queues (
    unsigned  int eid
)

function css_count_transaction_worker_threads¶

size_t css_count_transaction_worker_threads (
    THREAD_ENTRY * thread_p,
    int tran_index,
    int client_id
)

function css_end_server_request¶

void css_end_server_request (
    CSS_CONN_ENTRY * conn
)

function css_get_client_id¶

int css_get_client_id (
    THREAD_ENTRY * thread_p
)

function css_get_client_version_string¶

char * css_get_client_version_string (
    void
)

function css_get_comm_request_id¶

unsigned  int css_get_comm_request_id (
    THREAD_ENTRY * thread_p
)

function css_get_current_conn_entry¶

struct  css_conn_entry * css_get_current_conn_entry (
    void
)

function css_get_ha_num_of_hosts¶

int css_get_ha_num_of_hosts (
    void
)

function css_get_max_connections¶

size_t css_get_max_connections ()

function css_get_max_task_count¶

size_t css_get_max_task_count ()

function css_get_max_workers¶

size_t css_get_max_workers ()

function css_get_num_request_workers¶

size_t css_get_num_request_workers (
    void
)

function css_get_shutdown_timeout¶

struct  timeval * css_get_shutdown_timeout (
    void
)

function css_get_task_stats¶

void css_get_task_stats (
    UINT64 * stats_out
)

function css_get_thread_stats¶

void css_get_thread_stats (
    UINT64 * stats_out
)

function css_ha_server_state¶

HA_SERVER_STATE css_ha_server_state (
    void
)

function css_init¶

int css_init (
    THREAD_ENTRY * thread_p,
    char * server_name,
    int server_name_length,
    int connection_id
)

function css_initialize_server_interfaces¶

void css_initialize_server_interfaces (
    int (*)( THREAD_ENTRY *thrd, unsigned  int  eid , int request, int size, char *buffer) request_handler
)

function css_is_ha_repl_delayed¶

bool css_is_ha_repl_delayed (
    void
)

function css_is_shutdown_timeout_expired¶

bool css_is_shutdown_timeout_expired (
    void
)

function css_is_shutdowning_server¶

bool css_is_shutdowning_server ()

function css_job_queues_start_scan¶

int css_job_queues_start_scan (
    THREAD_ENTRY * thread_p,
    int show_type,
    DB_VALUE ** arg_values,
    int arg_cnt,
    void ** ptr
)

function css_notify_ha_log_applier_state¶

int css_notify_ha_log_applier_state (
    THREAD_ENTRY * thread_p,
    HA_LOG_APPLIER_STATE state
)

function css_pack_server_name¶

char * css_pack_server_name (
    const  char * server_name,
    int * name_length
)

function css_push_external_task¶

void css_push_external_task (
    CSS_CONN_ENTRY * conn,
    cubthread::entry_task * task
)

function css_push_server_task¶

void css_push_server_task (
    CSS_CONN_ENTRY & conn_ref
)

function css_receive_data_from_client¶

unsigned  int css_receive_data_from_client (
    CSS_CONN_ENTRY * conn,
    unsigned  int eid,
    char ** buffer,
    int * size
)

function css_receive_data_from_client_with_timeout¶

unsigned  int css_receive_data_from_client_with_timeout (
    CSS_CONN_ENTRY * conn,
    unsigned  int eid,
    char ** buffer,
    int * size,
    int timeout
)

function css_send_abort_to_client¶

unsigned  int css_send_abort_to_client (
    CSS_CONN_ENTRY * conn,
    unsigned  int eid
)

function css_send_data_to_client¶

unsigned  int css_send_data_to_client (
    CSS_CONN_ENTRY * conn,
    unsigned  int eid,
    char * buffer,
    int buffer_size,
    int wait_time=0
)

function css_send_error_to_client¶

unsigned  int css_send_error_to_client (
    CSS_CONN_ENTRY * conn,
    unsigned  int eid,
    char * buffer,
    int buffer_size
)

function css_send_reply_and_2_data_to_client¶

unsigned  int css_send_reply_and_2_data_to_client (
    CSS_CONN_ENTRY * conn,
    unsigned  int eid,
    char * reply,
    int reply_size,
    char * buffer1,
    int buffer1_size,
    char * buffer2,
    int buffer2_size,
    std::function< void () > && deleter
)

function css_send_reply_and_3_data_to_client¶

unsigned  int css_send_reply_and_3_data_to_client (
    CSS_CONN_ENTRY * conn,
    unsigned  int eid,
    char * reply,
    int reply_size,
    char * buffer1,
    int buffer1_size,
    char * buffer2,
    int buffer2_size,
    char * buffer3,
    int buffer3_size,
    std::function< void () > && deleter
)

function css_send_reply_and_data_to_client¶

unsigned  int css_send_reply_and_data_to_client (
    CSS_CONN_ENTRY * conn,
    unsigned  int eid,
    char * reply,
    int reply_size,
    char * buffer,
    int buffer_size,
    std::function< void () > && deleter
)

function css_send_reply_and_data_to_client_direct¶

unsigned  int css_send_reply_and_data_to_client_direct (
    CSS_CONN_ENTRY * conn,
    unsigned  int eid,
    char * reply,
    int reply_size,
    char * buffer,
    int buffer_size
)

function css_set_ha_num_of_hosts¶

void css_set_ha_num_of_hosts (
    int num
)

function css_set_ha_repl_delayed¶

void css_set_ha_repl_delayed (
    void
)

function css_set_thread_info¶

void css_set_thread_info (
    THREAD_ENTRY * thread_p,
    int client_id,
    int rid,
    int tran_index,
    int net_request_index
)

function css_start_shutdown_server¶

void css_start_shutdown_server ()

function css_unset_ha_repl_delayed¶

void css_unset_ha_repl_delayed (
    void
)

Macro Definition Documentation¶

define TIMEOUT_INFINITE¶

#define TIMEOUT_INFINITE `-1`

define TIMEOUT_NOWAIT¶

#define TIMEOUT_NOWAIT `0`

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