shard_proxy.c File Reference

#include <signal.h>
#include <errno.h>
#include "porting.h"
#include "shard_proxy.h"
#include "shard_proxy_handler.h"
#include "shard_key_func.h"

Include dependency graph for shard_proxy.c:

Go to the source code of this file.

Macros
#define	ENDLESS   1

Functions
static int	proxy_shm_initialize (void)
static void	cleanup (int signo)
static void	proxy_set_hang_check_time (void)
static void	proxy_unset_hang_check_time (void)
void	proxy_term (void)
int	main (int argc, char *argv[])

Variables
int	appl_server_shm_id = -1
T_SHM_APPL_SERVER *	shm_as_p = NULL
int	proxy_id = -1
int	proxy_shm_id = -1
T_SHM_PROXY *	shm_proxy_p = NULL
T_PROXY_INFO *	proxy_info_p = NULL
T_SHM_SHARD_USER *	shm_user_p = NULL
T_SHM_SHARD_KEY *	shm_key_p = NULL
T_SHM_SHARD_CONN *	shm_conn_p = NULL
bool	proxy_Keep_running

Macro Definition Documentation

#define ENDLESS   1

Definition at line 39 of file shard_proxy.c.

Function Documentation

static void cleanup ( int  signo )

static

Definition at line 81 of file shard_proxy.c.

References proxy_term().

Referenced by main().

Here is the caller graph for this function:

int main	(	int	argc,
		char *	argv[]
	)

Definition at line 163 of file shard_proxy.c.

References cleanup(), error(), t_proxy_info::max_prepared_stmt_count, proxy_handler_initialize(), proxy_handler_process(), proxy_io_initialize(), proxy_io_process(), proxy_Keep_running, PROXY_LOG, PROXY_LOG_MODE_ERROR, PROXY_LOG_MODE_NOTICE, proxy_set_hang_check_time(), proxy_shm_initialize(), proxy_term(), proxy_timer_process(), proxy_unset_hang_check_time(), register_fn_get_shard_key(), shard_stmt_initialize(), and wsa_initialize().

static void proxy_set_hang_check_time ( void  )

static

Definition at line 246 of file shard_proxy.c.

References t_proxy_info::claimed_alive_time, t_shm_appl_server::monitor_hang_flag, and NULL.

Referenced by main().

Here is the caller graph for this function:

int proxy_shm_initialize ( void  )

static

Definition at line 92 of file shard_proxy.c.

References appl_server_shm_id, t_proxy_info::appl_server_shm_id, NULL, p, parse_int(), proxy_id, PROXY_ID_ENV_STR, proxy_shm_id, PROXY_SHM_KEY_STR, SHARD_ERR, shard_metadata_get_conn(), shard_metadata_get_key(), shard_metadata_get_user(), shard_shm_find_proxy_info(), SHM_APPL_SERVER, SHM_MODE_ADMIN, SHM_PROXY, and uw_shm_open().

Referenced by main().

Here is the caller graph for this function:

void proxy_term

(

void

)

Definition at line 65 of file shard_proxy.c.

References proxy_access_log_close(), proxy_handler_destroy(), proxy_io_destroy(), proxy_log_close(), shard_stmt_destroy(), and SLEEP_MILISEC.

Referenced by cleanup(), and main().

Here is the caller graph for this function:

static void proxy_unset_hang_check_time ( void  )

static

Definition at line 255 of file shard_proxy.c.

References t_proxy_info::claimed_alive_time, t_shm_appl_server::monitor_hang_flag, and NULL.

Referenced by main().

Here is the caller graph for this function:

Variable Documentation

int appl_server_shm_id = -1

Definition at line 42 of file shard_proxy.c.

Referenced by admin_getid_cmd(), broker_config_dump(), broker_config_read_internal(), conf_copy_broker(), proxy_shm_initialize(), and uc_as_shm_open().

int proxy_id = -1

Definition at line 45 of file shard_proxy.c.

Referenced by appl_info_display(), broker_register_proxy_conn(), broker_shm_initialize_shm_as(), check_shard_conn(), net_init_env(), print_monitor_items(), proxy_io_make_client_dbinfo_ok(), proxy_io_register_to_broker(), proxy_listener_thr_f(), proxy_log_end(), proxy_log_open(), proxy_log_reset(), proxy_log_write(), proxy_shm_initialize(), shard_shm_find_proxy_info(), and shard_shm_set_param_proxy_internal().

T_PROXY_INFO* proxy_info_p = NULL

Definition at line 48 of file shard_proxy.c.

Referenced by admin_reset_cmd(), br_inactivate(), broker_find_available_proxy(), broker_shm_initialize_shm_as(), cas_monitor_worker(), check_shard_conn(), client_monitor(), hang_check_thr_f(), metadata_monitor(), proxy_activate(), proxy_activate_internal(), proxy_check_worker(), proxy_monitor_thr_f(), psize_check_thr_f(), set_monitor_items(), shard_broker_process(), shard_shm_dump_proxy(), shard_shm_find_proxy_info(), shard_shm_initialize_shm_proxy(), shard_shm_set_param_proxy(), and shard_shm_set_param_proxy_internal().

bool proxy_Keep_running

Definition at line 57 of file shard_proxy.c.

Referenced by main(), proxy_io_process(), proxy_socket_io_add(), and proxy_socket_io_new_client().

int proxy_shm_id = -1

Definition at line 46 of file shard_proxy.c.

Referenced by broker_config_dump(), broker_config_read_internal(), broker_init_shm(), and proxy_shm_initialize().

T_SHM_APPL_SERVER* shm_as_p = NULL

Definition at line 43 of file shard_proxy.c.

Referenced by admin_conf_change(), admin_on_cmd(), admin_reset_cmd(), admin_start_cmd(), broker_shm_initialize_shm_as(), shard_shm_dump_proxy_info(), shard_shm_set_param_as(), and shard_shm_set_param_proxy_internal().

T_SHM_SHARD_CONN* shm_conn_p = NULL

Definition at line 52 of file shard_proxy.c.

Referenced by admin_getid_cmd(), metadata_monitor(), shard_metadata_dump_internal(), shard_metadata_get_conn(), shard_metadata_initialize(), shard_metadata_read_conn(), shard_shm_initialize_shm_proxy(), and shard_shm_set_shard_conn_info().

T_SHM_SHARD_KEY* shm_key_p = NULL

Definition at line 51 of file shard_proxy.c.

Referenced by admin_getid_cmd(), metadata_monitor(), shard_metadata_dump_internal(), shard_metadata_get_key(), shard_metadata_initialize(), shard_metadata_read_key(), and shard_shm_initialize_shm_proxy().

T_SHM_PROXY* shm_proxy_p = NULL

Definition at line 47 of file shard_proxy.c.

T_SHM_SHARD_USER* shm_user_p = NULL

Definition at line 50 of file shard_proxy.c.

Referenced by metadata_monitor(), shard_metadata_dump_internal(), shard_metadata_get_shard_user_from_shm(), shard_metadata_get_user(), shard_metadata_initialize(), shard_metadata_read_user(), and shard_shm_set_shard_conn_info().