File shard_proxy_handler.h¶

FileList > broker > shard_proxy_handler.h

#include "porting.h"
#include "shard_proxy_common.h"

Public Types¶

Type	Name
typedef int(*	T_PROXY_EVENT_FUNC
typedef int(*	T_PROXY_EVENT_FUNC_EX

Public Functions¶

Type	Name
T_CONTEXT_STMT *	proxy_context_add_stmt (T_PROXY_CONTEXT * ctx_p, T_SHARD_STMT * stmt_p)
void	proxy_context_clear_error (T_PROXY_CONTEXT * ctx_p)
T_PROXY_CONTEXT *	proxy_context_find (int cid, unsigned int uid)
T_PROXY_CONTEXT *	proxy_context_find_by_socket_client_io (T_SOCKET_IO * sock_io_p)
T_CONTEXT_STMT *	proxy_context_find_stmt (T_PROXY_CONTEXT * ctx_p, int stmt_h_id)
void	proxy_context_free (T_PROXY_CONTEXT * ctx_p)
void	proxy_context_free_by_cid (int cid, unsigned int uid)
void	proxy_context_free_stmt (T_PROXY_CONTEXT * ctx_p)
T_PROXY_CONTEXT *	proxy_context_new (void)
int	proxy_context_send_error (T_PROXY_CONTEXT * ctx_p)
void	proxy_context_set_error (T_PROXY_CONTEXT * ctx_p, int error_ind, int error_code)
void	proxy_context_set_error_with_msg (T_PROXY_CONTEXT * ctx_p, int error_ind, int error_code, const char * error_msg)
void	proxy_context_set_in_tran (T_PROXY_CONTEXT * ctx_p, int shard_id, int cas_id)
void	proxy_context_set_out_tran (T_PROXY_CONTEXT * ctx_p)
void	proxy_context_timeout (T_PROXY_CONTEXT * ctx_p)
int	proxy_event_alloc_buffer (T_PROXY_EVENT * event_p, unsigned int size)
T_PROXY_EVENT *	proxy_event_dup (T_PROXY_EVENT * event_p)
void	proxy_event_free (T_PROXY_EVENT * event_p)
bool	proxy_event_io_read_complete (T_PROXY_EVENT * event_p)
bool	proxy_event_io_write_complete (T_PROXY_EVENT * event_p)
T_PROXY_EVENT *	proxy_event_new (unsigned int type, int from_cas)
T_PROXY_EVENT *	proxy_event_new_with_error (char * driver_info, unsigned int type, int from, int()(char* driver_info, char* buffer, int error_ind, int error_code, const char** error_msg, char* is_in_tran) err_func, int error_ind, int error_code, const char * error_msg, char is_in_tran)
T_PROXY_EVENT *	proxy_event_new_with_req (char * driver_info, unsigned int type, int from, T_PROXY_EVENT_FUNC req_func)
T_PROXY_EVENT *	proxy_event_new_with_rsp (char * driver_info, unsigned int type, int from, T_PROXY_EVENT_FUNC resp_func)
T_PROXY_EVENT *	proxy_event_new_with_rsp_ex (char * driver_info, unsigned int type, int from, T_PROXY_EVENT_FUNC_EX resp_func, void * argv)
int	proxy_event_realloc_buffer (T_PROXY_EVENT * event_p, unsigned int size)
void	proxy_event_set_buffer (T_PROXY_EVENT * event_p, char * data, unsigned int size)
void	proxy_event_set_context (T_PROXY_EVENT * event_p, int cid, unsigned int uid)
void	proxy_event_set_shard (T_PROXY_EVENT * event_p, int shard_id, int cas_id)
void	proxy_event_set_type_from (T_PROXY_EVENT * event_p, unsigned int type, int from_cas)
void	proxy_handler_destroy (void)
int	proxy_handler_initialize (void)
bool	proxy_handler_is_cas_in_tran (int shard_id, int cas_id)
void	proxy_handler_process (void)
char *	proxy_str_context (T_PROXY_CONTEXT * ctx_p)
char *	proxy_str_event (T_PROXY_EVENT * event_p)
void	proxy_timer_process (void)
int	proxy_waiter_comp_fn (const void * arg1, const void * arg2)
void	proxy_waiter_free (T_WAIT_CONTEXT * waiter)
T_WAIT_CONTEXT *	proxy_waiter_new (int ctx_cid, unsigned int ctx_uid, int timeout)
void	proxy_waiter_timeout (T_SHARD_QUEUE * waitq, INT64 * counter, int now)
int	proxy_wakeup_context_by_shard (T_WAIT_CONTEXT * waiter_p, int shard_id, int cas_id)
int	proxy_wakeup_context_by_statement (T_WAIT_CONTEXT * waiter_p)
char *	shard_str_sqls (char * sql)

Public Types Documentation¶

typedef T_PROXY_EVENT_FUNC¶

typedef int(* T_PROXY_EVENT_FUNC) (char *driver_info, char **buffer);

typedef T_PROXY_EVENT_FUNC_EX¶

typedef int(* T_PROXY_EVENT_FUNC_EX) (char *driver_info, char **buffer, void *argv);

Public Functions Documentation¶

function proxy_context_add_stmt¶

T_CONTEXT_STMT * proxy_context_add_stmt (
    T_PROXY_CONTEXT * ctx_p,
    T_SHARD_STMT * stmt_p
)

function proxy_context_clear_error¶

void proxy_context_clear_error (
    T_PROXY_CONTEXT * ctx_p
)

function proxy_context_find¶

T_PROXY_CONTEXT * proxy_context_find (
    int cid,
    unsigned  int uid
)

function proxy_context_find_by_socket_client_io¶

T_PROXY_CONTEXT * proxy_context_find_by_socket_client_io (
    T_SOCKET_IO * sock_io_p
)

function proxy_context_find_stmt¶

T_CONTEXT_STMT * proxy_context_find_stmt (
    T_PROXY_CONTEXT * ctx_p,
    int stmt_h_id
)

function proxy_context_free¶

void proxy_context_free (
    T_PROXY_CONTEXT * ctx_p
)

function proxy_context_free_by_cid¶

void proxy_context_free_by_cid (
    int cid,
    unsigned  int uid
)

function proxy_context_free_stmt¶

void proxy_context_free_stmt (
    T_PROXY_CONTEXT * ctx_p
)

function proxy_context_new¶

T_PROXY_CONTEXT * proxy_context_new (
    void
)

function proxy_context_send_error¶

int proxy_context_send_error (
    T_PROXY_CONTEXT * ctx_p
)

function proxy_context_set_error¶

void proxy_context_set_error (
    T_PROXY_CONTEXT * ctx_p,
    int error_ind,
    int error_code
)

function proxy_context_set_error_with_msg¶

void proxy_context_set_error_with_msg (
    T_PROXY_CONTEXT * ctx_p,
    int error_ind,
    int error_code,
    const  char * error_msg
)

function proxy_context_set_in_tran¶

void proxy_context_set_in_tran (
    T_PROXY_CONTEXT * ctx_p,
    int shard_id,
    int cas_id
)

function proxy_context_set_out_tran¶

void proxy_context_set_out_tran (
    T_PROXY_CONTEXT * ctx_p
)

function proxy_context_timeout¶

void proxy_context_timeout (
    T_PROXY_CONTEXT * ctx_p
)

function proxy_event_alloc_buffer¶

int proxy_event_alloc_buffer (
    T_PROXY_EVENT * event_p,
    unsigned  int size
)

function proxy_event_dup¶

T_PROXY_EVENT * proxy_event_dup (
    T_PROXY_EVENT * event_p
)

function proxy_event_free¶

void proxy_event_free (
    T_PROXY_EVENT * event_p
)

function proxy_event_io_read_complete¶

bool proxy_event_io_read_complete (
    T_PROXY_EVENT * event_p
)

function proxy_event_io_write_complete¶

bool proxy_event_io_write_complete (
    T_PROXY_EVENT * event_p
)

function proxy_event_new¶

T_PROXY_EVENT * proxy_event_new (
    unsigned  int type,
    int from_cas
)

function proxy_event_new_with_error¶

T_PROXY_EVENT * proxy_event_new_with_error (
    char * driver_info,
    unsigned  int type,
    int from,
    int (*)( char *driver_info, char **buffer, int error_ind, int error_code, const  char *error_msg, char is_in_tran) err_func,
    int error_ind,
    int error_code,
    const  char * error_msg,
    char is_in_tran
)

function proxy_event_new_with_req¶

T_PROXY_EVENT * proxy_event_new_with_req (
    char * driver_info,
    unsigned  int type,
    int from,
    T_PROXY_EVENT_FUNC req_func
)

function proxy_event_new_with_rsp¶

T_PROXY_EVENT * proxy_event_new_with_rsp (
    char * driver_info,
    unsigned  int type,
    int from,
    T_PROXY_EVENT_FUNC resp_func
)

function proxy_event_new_with_rsp_ex¶

T_PROXY_EVENT * proxy_event_new_with_rsp_ex (
    char * driver_info,
    unsigned  int type,
    int from,
    T_PROXY_EVENT_FUNC_EX resp_func,
    void * argv
)

function proxy_event_realloc_buffer¶

int proxy_event_realloc_buffer (
    T_PROXY_EVENT * event_p,
    unsigned  int size
)

function proxy_event_set_buffer¶

void proxy_event_set_buffer (
    T_PROXY_EVENT * event_p,
    char * data,
    unsigned  int size
)

function proxy_event_set_context¶

void proxy_event_set_context (
    T_PROXY_EVENT * event_p,
    int cid,
    unsigned  int uid
)

function proxy_event_set_shard¶

void proxy_event_set_shard (
    T_PROXY_EVENT * event_p,
    int shard_id,
    int cas_id
)

function proxy_event_set_type_from¶

void proxy_event_set_type_from (
    T_PROXY_EVENT * event_p,
    unsigned  int type,
    int from_cas
)

function proxy_handler_destroy¶

void proxy_handler_destroy (
    void
)

function proxy_handler_initialize¶

int proxy_handler_initialize (
    void
)

function proxy_handler_is_cas_in_tran¶

bool proxy_handler_is_cas_in_tran (
    int shard_id,
    int cas_id
)

function proxy_handler_process¶

void proxy_handler_process (
    void
)

function proxy_str_context¶

char * proxy_str_context (
    T_PROXY_CONTEXT * ctx_p
)

function proxy_str_event¶

char * proxy_str_event (
    T_PROXY_EVENT * event_p
)

function proxy_timer_process¶

void proxy_timer_process (
    void
)

function proxy_waiter_comp_fn¶

int proxy_waiter_comp_fn (
    const  void * arg1,
    const  void * arg2
)

function proxy_waiter_free¶

void proxy_waiter_free (
    T_WAIT_CONTEXT * waiter
)

function proxy_waiter_new¶

T_WAIT_CONTEXT * proxy_waiter_new (
    int ctx_cid,
    unsigned  int ctx_uid,
    int timeout
)

function proxy_waiter_timeout¶

void proxy_waiter_timeout (
    T_SHARD_QUEUE * waitq,
    INT64 * counter,
    int now
)

function proxy_wakeup_context_by_shard¶

int proxy_wakeup_context_by_shard (
    T_WAIT_CONTEXT * waiter_p,
    int shard_id,
    int cas_id
)

function proxy_wakeup_context_by_statement¶

int proxy_wakeup_context_by_statement (
    T_WAIT_CONTEXT * waiter_p
)

function shard_str_sqls¶

char * shard_str_sqls (
    char * sql
)

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