connection_handler_per_thread.cc File Reference

#include <stddef.h>
#include <sys/types.h>
#include <list>
#include <new>
#include "my_compiler.h"
#include "my_dbug.h"
#include "my_inttypes.h"
#include "my_macros.h"
#include "my_psi_config.h"
#include "my_thread.h"
#include "mysql/components/services/bits/mysql_cond_bits.h"
#include "mysql/components/services/bits/mysql_mutex_bits.h"
#include "mysql/components/services/bits/psi_bits.h"
#include "mysql/components/services/bits/psi_cond_bits.h"
#include "mysql/components/services/bits/psi_mutex_bits.h"
#include "mysql/components/services/bits/psi_thread_bits.h"
#include "mysql/components/services/log_builtins.h"
#include "mysql/my_loglevel.h"
#include "mysql/psi/mysql_cond.h"
#include "mysql/psi/mysql_mutex.h"
#include "mysql/psi/mysql_socket.h"
#include "mysql/psi/mysql_thread.h"
#include "mysql_com.h"
#include "mysqld_error.h"
#include "pfs_thread_provider.h"
#include "sql/conn_handler/channel_info.h"
#include "sql/conn_handler/connection_handler_impl.h"
#include "sql/conn_handler/connection_handler_manager.h"
#include "sql/log.h"
#include "sql/mysqld.h"
#include "sql/mysqld_thd_manager.h"
#include "sql/protocol_classic.h"
#include "sql/sql_class.h"
#include "sql/sql_connect.h"
#include "sql/sql_error.h"
#include "sql/sql_parse.h"
#include "sql/sql_thd_internal_api.h"
#include "thr_mutex.h"

Functions
static THD *	init_new_thd (Channel_info *channel_info)
	Construct and initialize a THD object for a new connection. More...
static void *	handle_connection (void *arg)
	Thread handler for a connection. More...

Variables
static Error_log_throttle	create_thd_err_log_throttle (Log_throttle ::LOG_THROTTLE_WINDOW_SIZE, ERROR_LEVEL, 0, "connection_handler", "Error log throttle: %10lu" " 'Can't create thread to" " handle new connection'" " error(s) suppressed")
static uint	wake_pthread = 0
static PSI_mutex_key	key_LOCK_thread_cache
static PSI_mutex_info	all_per_thread_mutexes []
static PSI_cond_key	key_COND_thread_cache
static PSI_cond_key	key_COND_flush_thread_cache
static PSI_cond_info	all_per_thread_conds []

Function Documentation

handle_connection()

static void * handle_connection ( void *  arg )

static

Thread handler for a connection.

Parameters

arg	Connection object (Channel_info)

This function (normally) does the following:

• Initialize thread
• Initialize THD to be used with this thread
• Authenticate user
• Execute all queries sent on the connection
• Take connection down
• End thread / Handle next connection using thread from thread cache

init_new_thd()

static THD * init_new_thd ( Channel_info *  channel_info )

static

Construct and initialize a THD object for a new connection.

Parameters

channel_info

Channel_info object representing the new connection. Will be destroyed by this function.

Return values

NULL	Initialization failed.
!NULL	Pointer to new THD object for the new connection.

Variable Documentation

all_per_thread_conds

PSI_cond_info all_per_thread_conds[]

static

Initial value:

= {
    {&key_COND_thread_cache, "COND_thread_cache", PSI_FLAG_SINGLETON, 0,
     PSI_DOCUMENT_ME},
    {&key_COND_flush_thread_cache, "COND_flush_thread_cache",
     PSI_FLAG_SINGLETON, 0, PSI_DOCUMENT_ME}}

all_per_thread_mutexes

PSI_mutex_info all_per_thread_mutexes[]

static

Initial value:

= {
    {&key_LOCK_thread_cache, "LOCK_thread_cache", PSI_FLAG_SINGLETON, 0,
     PSI_DOCUMENT_ME}}

create_thd_err_log_throttle

Error_log_throttle create_thd_err_log_throttle(Log_throttle ::LOG_THROTTLE_WINDOW_SIZE, ERROR_LEVEL, 0, "connection_handler", "Error log throttle: %10lu" " 'Can't create thread to" " handle new connection'" " error(s) suppressed") ( Log_throttle ::LOG_THROTTLE_WINDOW_SIZE  , ERROR_LEVEL  , 0  , "connection_handler"  , "Error log throttle: %10lu" " 'Can't create thread to" " handle new connection'" " error(s) suppressed"    )

static

key_COND_flush_thread_cache

PSI_cond_key key_COND_flush_thread_cache

static

key_COND_thread_cache

PSI_cond_key key_COND_thread_cache

static

key_LOCK_thread_cache

PSI_mutex_key key_LOCK_thread_cache

static

wake_pthread

uint wake_pthread = 0

static