#include "shard_key_func.h"
#include "broker_shm.h"
#include "shard_metadata.h"
#include "broker_config.h"

Include dependency graph for shard_key_func.c:

Macros
#define	PROXY_LOG(level, fmt, args...)

Functions
int	register_fn_get_shard_key (void)

int	fn_get_shard_key_default (const char shard_key, T_SHARD_U_TYPE type, const void value, int value_len)

int	proxy_find_shard_id_by_hint_value (SP_VALUE value_p, const char key_column)

Variables
T_SHM_PROXY *	shm_proxy_p

Macro Definition Documentation

#define PROXY_LOG	(	level,
		fmt,
		args...
	)

Definition at line 40 of file shard_key_func.c.

Referenced by fn_get_shard_key_default(), fn_proxy_cas_check_cas(), fn_proxy_cas_end_tran(), fn_proxy_cas_fetch(), fn_proxy_cas_prepare(), fn_proxy_cas_prepare_and_execute(), fn_proxy_cas_relay_only(), fn_proxy_cas_schema_info(), fn_proxy_client_check_cas(), fn_proxy_client_close_req_handle(), fn_proxy_client_cursor(), fn_proxy_client_cursor_close(), fn_proxy_client_end_tran(), fn_proxy_client_get_db_parameter(), fn_proxy_client_get_db_version(), fn_proxy_client_prepare(), fn_proxy_client_prepare_and_execute(), fn_proxy_client_schema_info(), fn_proxy_client_set_db_parameter(), main(), proxy_cas_alloc_anything(), proxy_cas_alloc_by_ctx(), proxy_cas_alloc_by_shard_and_cas_id(), proxy_cas_execute_internal(), proxy_cas_find_io_by_ctx(), proxy_cas_io_free(), proxy_cas_io_free_by_ctx(), proxy_cas_io_new(), proxy_cas_io_write(), proxy_cas_release_by_ctx(), proxy_check_authorization(), proxy_client_check_waiter_and_wakeup(), proxy_client_execute_internal(), proxy_client_io_destroy(), proxy_client_io_find_by_ctx(), proxy_client_io_find_by_fd(), proxy_client_io_initialize(), proxy_client_io_new(), proxy_client_io_write(), proxy_context_destroy(), proxy_context_find_by_socket_client_io(), proxy_context_free(), proxy_context_free_client(), proxy_context_initialize(), proxy_context_new(), proxy_context_send_error(), proxy_context_timeout(), proxy_convert_error_code(), proxy_find_shard_id_by_hint_value(), proxy_get_range_by_param(), proxy_get_shard_id(), proxy_handler_process_cas_conn_error(), proxy_handler_process_cas_error(), proxy_handler_process_cas_response(), proxy_handler_process_client_conn_error(), proxy_handler_process_client_request(), proxy_handler_process_client_wakeup_by_shard(), proxy_io_cas_lsnr(), proxy_io_connect_to_broker(), proxy_io_initialize(), proxy_io_make_check_cas(), proxy_io_make_client_proxy_alive(), proxy_io_make_close_req_handle_ok(), proxy_io_make_end_tran_request(), proxy_io_make_error_msg(), proxy_io_make_ex_get_int(), proxy_io_make_get_db_version(), proxy_io_make_shard_info(), proxy_io_process(), proxy_io_register_to_broker(), proxy_io_set_established_by_ctx(), proxy_make_net_buf(), proxy_process_cas_conn_error(), proxy_process_cas_register(), proxy_process_cas_response(), proxy_process_client_conn_error(), proxy_process_client_register(), proxy_process_client_request(), proxy_send_prepared_stmt_to_client(), proxy_send_request_to_cas(), proxy_send_request_to_cas_with_new_event(), proxy_send_response_to_client(), proxy_send_response_to_client_with_new_event(), proxy_shard_io_destroy(), proxy_socket_io_add(), proxy_socket_io_delete(), proxy_socket_io_destroy(), proxy_socket_io_initialize(), proxy_socket_io_new_client(), proxy_update_shard_stats(), proxy_update_shard_stats_without_hint(), proxy_wakeup_context_by_shard(), register_fn_get_shard_key(), shard_cqueue_enqueue(), shard_cqueue_initialize(), shard_io_set_fl(), shard_queue_enqueue(), shard_queue_ordered_enqueue(), shard_stmt_add_srv_h_id_for_shard_cas(), shard_stmt_change_shard_val_to_id(), shard_stmt_check_waiter_and_wakeup(), shard_stmt_del_srv_h_id_for_shard_cas(), shard_stmt_find_srv_h_id_for_shard_cas(), shard_stmt_get_hint_type(), shard_stmt_initialize(), shard_stmt_new_internal(), shard_stmt_pin(), shard_stmt_save_prepare_request(), shard_stmt_set_hint_list(), shard_stmt_unpin(), sp_create_parser(), sp_create_parser_hint(), and sp_parse_sql().

Function Documentation

int fn_get_shard_key_default	(	const char *	shard_key,
		T_SHARD_U_TYPE	type,
		const void *	value,
		int	value_len
	)

Definition at line 78 of file shard_key_func.c.

References ERROR_ON_ARGUMENT, ERROR_ON_MAKE_SHARD_KEY, NULL, PROXY_LOG, PROXY_LOG_MODE_ERROR, t_shm_proxy::shard_key_modular, SHARD_U_TYPE_BIGINT, SHARD_U_TYPE_INT, SHARD_U_TYPE_SHORT, SHARD_U_TYPE_UBIGINT, SHARD_U_TYPE_UINT, and SHARD_U_TYPE_USHORT.

Referenced by register_fn_get_shard_key().

Here is the caller graph for this function:

int proxy_find_shard_id_by_hint_value	(	SP_VALUE *	value_p,
		const char *	key_column
	)

Definition at line 123 of file shard_key_func.c.

References sp_value::integer, sp_value::length, PROXY_LOG, PROXY_LOG_MODE_ERROR, SHARD_U_TYPE_BIGINT, SHARD_U_TYPE_STRING, sp_value::string, sp_value::type, sp_value::value, VT_INTEGER, and VT_STRING.

Referenced by admin_getid_cmd(), proxy_get_range_by_param(), and shard_stmt_change_shard_val_to_id().

Here is the caller graph for this function:

int register_fn_get_shard_key ( void )

Definition at line 47 of file shard_key_func.c.

References close_shard_key_function(), error(), fn_get_shard_key, fn_get_shard_key_default(), load_shard_key_function(), PROXY_LOG, PROXY_LOG_MODE_ERROR, PROXY_LOG_MODE_NOTICE, t_shm_proxy::shard_key_function_name, and t_shm_proxy::shard_key_library_name.

Referenced by admin_getid_cmd(), and main().

Here is the caller graph for this function:

Variable Documentation

T_SHM_PROXY* shm_proxy_p

Definition at line 109 of file broker_admin_pub.c.

Macros

Functions

Variables

Macro Definition Documentation

Function Documentation

Variable Documentation