connection_control.cc File Reference

#include "connection_control.h"
#include <mysql/components/service_implementation.h>
#include <mysql/components/services/bits/psi_memory_bits.h>
#include <mysql/components/services/connection_control_pfs.h>
#include <mysql/components/services/log_builtins.h>
#include <mysql/components/services/mysql_cond.h>
#include <mysql/components/services/mysql_mutex.h>
#include <mysql/components/services/psi_memory.h>
#include <mysqld_error.h>
#include <template_utils.h>
#include "connection_control_coordinator.h"
#include "connection_control_memory.h"
#include "connection_control_pfs_table.h"
#include "connection_delay.h"
#include "connection_delay_api.h"
#include "failed_attempts_list_imp.h"
#include "option_usage.h"

Functions
static void	register_instruments ()
static int	check_failed_connections_threshold (MYSQL_THD thd, SYS_VAR *var, void *save, struct st_mysql_value *value)
	check() function for connection_control_failed_connections_threshold More...
static void	update_failed_connections_threshold (MYSQL_THD thd, SYS_VAR *var, void *var_ptr, const void *save)
	update() function for connection_control_failed_connections_threshold More...
static int	check_min_connection_delay (MYSQL_THD thd, SYS_VAR *var, void *save, struct st_mysql_value *value)
	check() function for connection_control_min_connection_delay More...
static void	update_min_connection_delay (MYSQL_THD thd, SYS_VAR *var, void *var_ptr, const void *save)
	update() function for connection_control_min_connection_delay More...
static int	check_max_connection_delay (MYSQL_THD thd, SYS_VAR *var, void *save, struct st_mysql_value *value)
	check() function for connection_control_max_connection_delay More...
static void	update_max_connection_delay (MYSQL_THD thd, SYS_VAR *var, void *var_ptr, const void *save)
	update() function for connection_control_max_connection_delay More...
static int	show_status_variable (int var_index, SHOW_VAR *var, char *buff)
	Helper function to display value for status variable defined by its index within the array of all status variables. More...
static int	show_delay_generated (MYSQL_THD thd, SHOW_VAR *var, char *buff)
	Function to display value for status variable : Connection_control_delay_generated. More...
static int	show_exempted_users (MYSQL_THD thd, SHOW_VAR *var, char *buff)
	Function to display value for status variable : Component_connection_control_exempted_unknown_users. More...
static void	update_exempt_unknown_users (MYSQL_THD thd, SYS_VAR *var, void *var_ptr, const void *save)
static int	register_status_variables ()
static int	register_system_variables ()
static int	unregister_status_variables ()
static int	unregister_system_variables ()
static void	log_service_init ()
	logger services initialization method for Component used when loading the Component. More...
static mysql_service_status_t	connection_control_init ()
	Component initialization function. More...
static mysql_service_status_t	connection_control_deinit ()
	Component deinitialization. More...
	IMPLEMENTS_SERVICE_EVENT_TRACKING_CONNECTION (connection_control)
	PROVIDES_SERVICE_EVENT_TRACKING_CONNECTION (connection_control)
	END_COMPONENT_PROVIDES ()
	REQUIRES_SERVICE_PLACEHOLDER (pfs_plugin_column_string_v2)
	REQUIRES_SERVICE_PLACEHOLDER (mysql_thd_security_context)
	REQUIRES_SERVICE_PLACEHOLDER (pfs_plugin_column_integer_v1)
	REQUIRES_SERVICE_PLACEHOLDER (pfs_plugin_table_v1)
	REQUIRES_SERVICE_PLACEHOLDER (mysql_security_context_options)
	REQUIRES_SERVICE_PLACEHOLDER (log_builtins)
	REQUIRES_SERVICE_PLACEHOLDER (log_builtins_string)
	REQUIRES_SERVICE_PLACEHOLDER (component_sys_variable_register)
	REQUIRES_SERVICE_PLACEHOLDER (component_sys_variable_unregister)
	REQUIRES_SERVICE_PLACEHOLDER (status_variable_registration)
	REQUIRES_SERVICE_PLACEHOLDER (registry_registration)
	REQUIRES_SERVICE_PLACEHOLDER (mysql_current_thread_reader)
	REQUIRES_SERVICE (log_builtins)
	REQUIRES_SERVICE (log_builtins_string)
	REQUIRES_SERVICE (pfs_plugin_column_integer_v1)
	REQUIRES_SERVICE (pfs_plugin_table_v1)
	REQUIRES_SERVICE (pfs_plugin_column_string_v2)
	REQUIRES_SERVICE (registry_registration)
	REQUIRES_SERVICE (component_sys_variable_register)
	REQUIRES_SERVICE (component_sys_variable_unregister)
	REQUIRES_SERVICE (status_variable_registration)
	REQUIRES_SERVICE (mysql_current_thread_reader)
	REQUIRES_SERVICE (mysql_thd_security_context)
	REQUIRES_SERVICE (mysql_security_context_options)
	END_COMPONENT_REQUIRES ()
	METADATA ("mysql.author", "Oracle Corporation")
	METADATA ("mysql.license", "GPL")
	METADATA ("connection_control_service", "1")
	END_COMPONENT_METADATA ()

Variables
const mysql_service_log_builtins_t *	log_bi = nullptr
const mysql_service_log_builtins_string_t *	log_bs = nullptr
Connection_control_statistics	g_statistics
Connection_control_variables	g_variables
connection_control::Failed_attempts_list_imp	g_failed_attempts_list
static Connection_event_coordinator *	g_connection_event_coordinator = nullptr
PSI_memory_key	key_connection_delay_memory = PSI_NOT_INSTRUMENTED
static PSI_memory_info	all_connection_delay_memory_info []
PSI_mutex_key	key_connection_delay_mutex = PSI_NOT_INSTRUMENTED
static PSI_mutex_info	all_connection_delay_mutex_info []
PSI_rwlock_key	key_connection_event_delay_lock = PSI_NOT_INSTRUMENTED
static PSI_rwlock_info	all_connection_delay_rwlock_info []
PSI_cond_key	key_connection_delay_wait = PSI_NOT_INSTRUMENTED
static PSI_cond_info	all_connection_delay_cond_info []
static SHOW_VAR	component_connection_control_status_variables [STAT_LAST+1]
	REQUIRES_MYSQL_RWLOCK_SERVICE_PLACEHOLDER
	REQUIRES_MYSQL_COND_SERVICE_PLACEHOLDER
	REQUIRES_MYSQL_MUTEX_SERVICE_PLACEHOLDER
	REQUIRES_PSI_MEMORY_SERVICE_PLACEHOLDER
	REQUIRES_MYSQL_MUTEX_SERVICE
	REQUIRES_MYSQL_RWLOCK_SERVICE
	REQUIRES_MYSQL_COND_SERVICE
	REQUIRES_PSI_MEMORY_SERVICE
mysql_component_t	mysql_component_connection_control

Function Documentation

check_failed_connections_threshold()

static int check_failed_connections_threshold ( MYSQL_THD  thd, SYS_VAR *  var, void *  save, struct st_mysql_value *  value  )

static

check() function for connection_control_failed_connections_threshold

Check whether new value is within valid bounds or not.

Parameters

thd	Not used.
var	Not used.
save	Pointer to which new value to be saved.
value	New value for the option.

Returns

whether new value is within valid bounds or not.

Return values

0	Value is ok
1	Value is not within valid bounds

check_max_connection_delay()

static int check_max_connection_delay ( MYSQL_THD  thd, SYS_VAR *  var, void *  save, struct st_mysql_value *  value  )

static

check() function for connection_control_max_connection_delay

Check whether new value is within valid bounds or not.

Parameters

thd	Not used.
var	Not used.
save	Pointer to which new value to be saved.
value	New value for the option.

Returns

whether new value is within valid bounds or not.

Return values

0	Value is ok
1	Value is not within valid bounds

check_min_connection_delay()

static int check_min_connection_delay ( MYSQL_THD  thd, SYS_VAR *  var, void *  save, struct st_mysql_value *  value  )

static

check() function for connection_control_min_connection_delay

Check whether new value is within valid bounds or not.

Parameters

thd	Not used.
var	Not used.
save	Not used.
value	New value for the option.

Returns

whether new value is within valid bounds or not.

Return values

0	Value is ok
1	Value is not within valid bounds

connection_control_deinit()

static mysql_service_status_t connection_control_deinit ( )

static

Component deinitialization.

Returns

success

connection_control_init()

static mysql_service_status_t connection_control_init ( )

static

Component initialization function.

Returns

initialization status

Return values

0	Success
1	Failure

END_COMPONENT_METADATA()

END_COMPONENT_METADATA

(

)

END_COMPONENT_PROVIDES()

END_COMPONENT_PROVIDES

(

)

END_COMPONENT_REQUIRES()

END_COMPONENT_REQUIRES

(

)

IMPLEMENTS_SERVICE_EVENT_TRACKING_CONNECTION()

IMPLEMENTS_SERVICE_EVENT_TRACKING_CONNECTION

(

connection_control

)

log_service_init()

static void log_service_init ( )

static

logger services initialization method for Component used when loading the Component.

METADATA() [1/3]

METADATA	(	"connection_control_service"	,
		"1"
	)

METADATA() [2/3]

METADATA	(	"mysql.author"	,
		"Oracle Corporation"
	)

METADATA() [3/3]

METADATA	(	"mysql.license"	,
		"GPL"
	)

PROVIDES_SERVICE_EVENT_TRACKING_CONNECTION()

PROVIDES_SERVICE_EVENT_TRACKING_CONNECTION

(

connection_control

)

register_instruments()

static void register_instruments ( )

static

register_status_variables()

static int register_status_variables ( )

static

register_system_variables()

static int register_system_variables ( )

static

REQUIRES_SERVICE() [1/12]

REQUIRES_SERVICE

(

component_sys_variable_register

)

REQUIRES_SERVICE() [2/12]

REQUIRES_SERVICE

(

component_sys_variable_unregister

)

REQUIRES_SERVICE() [3/12]

REQUIRES_SERVICE

(

log_builtins

)

REQUIRES_SERVICE() [4/12]

REQUIRES_SERVICE

(

log_builtins_string

)

REQUIRES_SERVICE() [5/12]

REQUIRES_SERVICE

(

mysql_current_thread_reader

)

REQUIRES_SERVICE() [6/12]

REQUIRES_SERVICE

(

mysql_security_context_options

)

REQUIRES_SERVICE() [7/12]

REQUIRES_SERVICE

(

mysql_thd_security_context

)

REQUIRES_SERVICE() [8/12]

REQUIRES_SERVICE

(

pfs_plugin_column_integer_v1

)

REQUIRES_SERVICE() [9/12]

REQUIRES_SERVICE

(

pfs_plugin_column_string_v2

)

REQUIRES_SERVICE() [10/12]

REQUIRES_SERVICE

(

pfs_plugin_table_v1

)

REQUIRES_SERVICE() [11/12]

REQUIRES_SERVICE

(

registry_registration

)

REQUIRES_SERVICE() [12/12]

REQUIRES_SERVICE

(

status_variable_registration

)

REQUIRES_SERVICE_PLACEHOLDER() [1/12]

REQUIRES_SERVICE_PLACEHOLDER

(

component_sys_variable_register

)

REQUIRES_SERVICE_PLACEHOLDER() [2/12]

REQUIRES_SERVICE_PLACEHOLDER

(

component_sys_variable_unregister

)

REQUIRES_SERVICE_PLACEHOLDER() [3/12]

REQUIRES_SERVICE_PLACEHOLDER

(

log_builtins

)

REQUIRES_SERVICE_PLACEHOLDER() [4/12]

REQUIRES_SERVICE_PLACEHOLDER

(

log_builtins_string

)

REQUIRES_SERVICE_PLACEHOLDER() [5/12]

REQUIRES_SERVICE_PLACEHOLDER

(

mysql_current_thread_reader

)

REQUIRES_SERVICE_PLACEHOLDER() [6/12]

REQUIRES_SERVICE_PLACEHOLDER

(

mysql_security_context_options

)

REQUIRES_SERVICE_PLACEHOLDER() [7/12]

REQUIRES_SERVICE_PLACEHOLDER

(

mysql_thd_security_context

)

REQUIRES_SERVICE_PLACEHOLDER() [8/12]

REQUIRES_SERVICE_PLACEHOLDER

(

pfs_plugin_column_integer_v1

)

REQUIRES_SERVICE_PLACEHOLDER() [9/12]

REQUIRES_SERVICE_PLACEHOLDER

(

pfs_plugin_column_string_v2

)

REQUIRES_SERVICE_PLACEHOLDER() [10/12]

REQUIRES_SERVICE_PLACEHOLDER

(

pfs_plugin_table_v1

)

REQUIRES_SERVICE_PLACEHOLDER() [11/12]

REQUIRES_SERVICE_PLACEHOLDER

(

registry_registration

)

REQUIRES_SERVICE_PLACEHOLDER() [12/12]

REQUIRES_SERVICE_PLACEHOLDER

(

status_variable_registration

)

show_delay_generated()

static int show_delay_generated ( MYSQL_THD  thd, SHOW_VAR *  var, char *  buff  )

static

Function to display value for status variable : Connection_control_delay_generated.

Parameters

thd	MYSQL_THD handle. Unused.
var	Status variable structure
buff	Value buffer.

Returns

Always returns success.

show_exempted_users()

static int show_exempted_users ( MYSQL_THD  thd, SHOW_VAR *  var, char *  buff  )

static

Function to display value for status variable : Component_connection_control_exempted_unknown_users.

Parameters

thd	MYSQL_THD handle. Unused.
var	Status variable structure
buff	Value buffer.

Returns

Always returns success.

show_status_variable()

static int show_status_variable ( int  var_index, SHOW_VAR *  var, char *  buff  )

static

Helper function to display value for status variable defined by its index within the array of all status variables.

Parameters

var_index	Status variable index.
var	Status variable structure
buff	Value buffer.

Returns

Always returns success.

unregister_status_variables()

static int unregister_status_variables ( )

static

unregister_system_variables()

static int unregister_system_variables ( )

static

update_exempt_unknown_users()

static void update_exempt_unknown_users ( MYSQL_THD  thd, SYS_VAR *  var, void *  var_ptr, const void *  save  )

static

update_failed_connections_threshold()

static void update_failed_connections_threshold ( MYSQL_THD  thd, SYS_VAR *  var, void *  var_ptr, const void *  save  )

static

update() function for connection_control_failed_connections_threshold

Updates g_connection_event_coordinator with new value. Also notifies observers about the update.

Parameters

thd	Not used.
var	Not used.
var_ptr	Variable information
save	New value for connection_control_failed_connections_threshold

update_max_connection_delay()

static void update_max_connection_delay ( MYSQL_THD  thd, SYS_VAR *  var, void *  var_ptr, const void *  save  )

static

update() function for connection_control_max_connection_delay

Updates g_connection_event_coordinator with new value. Also notifies observers about the update.

Parameters

thd	Not used.
var	Not used.
var_ptr	Variable information
save	New value for connection_control_max_connection_delay

update_min_connection_delay()

static void update_min_connection_delay ( MYSQL_THD  thd, SYS_VAR *  var, void *  var_ptr, const void *  save  )

static

update() function for connection_control_min_connection_delay

Updates g_connection_event_coordinator with new value. Also notifies observers about the update.

Parameters

thd	Not used.
var	Not used.
var_ptr	Variable information
save	New value for connection_control_min_connection_delay

Variable Documentation

all_connection_delay_cond_info

PSI_cond_info all_connection_delay_cond_info[]

static

Initial value:

= {
    {&key_connection_delay_wait, "connection_delay_wait_condition", 0, 0,
     PSI_DOCUMENT_ME}}

all_connection_delay_memory_info

PSI_memory_info all_connection_delay_memory_info[]

static

Initial value:

= {
    {&key_connection_delay_memory, "component", 0, PSI_VOLATILITY_UNKNOWN,
     "Memory allocated by connection_control component."}}

all_connection_delay_mutex_info

PSI_mutex_info all_connection_delay_mutex_info[]

static

Initial value:

= {
    {&key_connection_delay_mutex, "connection_delay_mutex", 0, 0,
     PSI_DOCUMENT_ME}}

all_connection_delay_rwlock_info

PSI_rwlock_info all_connection_delay_rwlock_info[]

static

Initial value:

= {
    {&key_connection_event_delay_lock, "connection_event_delay_lock",
     PSI_FLAG_SINGLETON, 0, PSI_DOCUMENT_ME}}

component_connection_control_status_variables

SHOW_VAR component_connection_control_status_variables[STAT_LAST+1]

static

Initial value:

= {
    {.name = "Component_connection_control_delay_generated",
     .value = reinterpret_cast<char *>(&show_delay_generated),
     .type = SHOW_FUNC,
     .scope = SHOW_SCOPE_GLOBAL},
    {.name = "option_tracker_usage:Connection control component",
     .value = reinterpret_cast<char *>(
         &connection_control::
             opt_option_tracker_usage_connection_control_component),
     .type = SHOW_LONGLONG,
     .scope = SHOW_SCOPE_GLOBAL},
    {.name = "Component_connection_control_exempted_unknown_users",
     .value = reinterpret_cast<char *>(&show_exempted_users),
     .type = SHOW_FUNC,
     .scope = SHOW_SCOPE_GLOBAL},
    {.name = nullptr,
     .value = nullptr,
     .type = static_cast<enum_mysql_show_type>(0),
     .scope = static_cast<enum_mysql_show_scope>(0)}}

g_connection_event_coordinator

Connection_event_coordinator* g_connection_event_coordinator = nullptr

static

g_failed_attempts_list

connection_control::Failed_attempts_list_imp g_failed_attempts_list

g_statistics

Connection_control_statistics g_statistics

g_variables

Connection_control_variables g_variables

key_connection_delay_memory

PSI_memory_key key_connection_delay_memory = PSI_NOT_INSTRUMENTED

key_connection_delay_mutex

PSI_mutex_key key_connection_delay_mutex = PSI_NOT_INSTRUMENTED

key_connection_delay_wait

PSI_cond_key key_connection_delay_wait = PSI_NOT_INSTRUMENTED

key_connection_event_delay_lock

PSI_rwlock_key key_connection_event_delay_lock = PSI_NOT_INSTRUMENTED

log_bi

const mysql_service_log_builtins_t* log_bi = nullptr

log_bs

const mysql_service_log_builtins_string_t* log_bs = nullptr

mysql_component_connection_control

mysql_component_t mysql_component_connection_control

Initial value:

= {    "mysql:connection_control" , __connection_control_provides, __connection_control_requires,   __connection_control_metadata,
connection_control_init, connection_control_deinit }

REQUIRES_MYSQL_COND_SERVICE

REQUIRES_MYSQL_COND_SERVICE

REQUIRES_MYSQL_COND_SERVICE_PLACEHOLDER

REQUIRES_MYSQL_COND_SERVICE_PLACEHOLDER

REQUIRES_MYSQL_MUTEX_SERVICE

REQUIRES_MYSQL_MUTEX_SERVICE

REQUIRES_MYSQL_MUTEX_SERVICE_PLACEHOLDER

REQUIRES_MYSQL_MUTEX_SERVICE_PLACEHOLDER

REQUIRES_MYSQL_RWLOCK_SERVICE

REQUIRES_MYSQL_RWLOCK_SERVICE

REQUIRES_MYSQL_RWLOCK_SERVICE_PLACEHOLDER

REQUIRES_MYSQL_RWLOCK_SERVICE_PLACEHOLDER

REQUIRES_PSI_MEMORY_SERVICE

REQUIRES_PSI_MEMORY_SERVICE

REQUIRES_PSI_MEMORY_SERVICE_PLACEHOLDER

REQUIRES_PSI_MEMORY_SERVICE_PLACEHOLDER