Na}{

File Content: `thread_pool_priv.h`

/*
  Copyright (c) 2010, 2022, Oracle and/or its affiliates.

  This program is free software; you can redistribute it and/or modify
  it under the terms of the GNU General Public License, version 2.0,
  as published by the Free Software Foundation.

  This program is also distributed with certain software (including
  but not limited to OpenSSL) that is licensed under separate terms,
  as designated in a particular file or component or in included license
  documentation.  The authors of MySQL hereby grant you an additional
  permission to link the program and your derivative works with the
  separately licensed software that they have included with MySQL.

  This program is distributed in the hope that it will be useful,
  but WITHOUT ANY WARRANTY; without even the implied warranty of
  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  GNU General Public License, version 2.0, for more details.

  You should have received a copy of the GNU General Public License
  along with this program; if not, write to the Free Software
  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301  USA
*/

#ifndef THREAD_POOL_PRIV_INCLUDED
#define THREAD_POOL_PRIV_INCLUDED

/*
  The thread pool requires access to some MySQL server error codes, this is
  accessed from mysqld_error.h.
  We need access to the struct that defines the thread pool plugin interface
  which is accessed through scheduler.h.
  All accesses to THD variables and functions are defined in this header file.
  A thread pool can also use DEBUG_SYNC and must thus include
  debug_sync.h
  To handle definitions of Information Schema plugins it is also required
  to include sql_profile.h and table.h.
*/
#include <mysqld_error.h> /* To get ER_ERROR_ON_READ */
#define MYSQL_SERVER 1
#include <conn_handler/channel_info.h>
#include <conn_handler/connection_handler_manager.h>
#include <debug_sync.h>
#include <sql_profile.h>
#include <table.h>
#include "field.h"
#include "sql_thd_internal_api.h"
#include <set>

#ifdef __cplusplus
extern "C" {
#endif

/**
   This structure must be populated by plugins which implement connection
   handlers and passed as an argument to my_connection_handler_set() in
   order to activate the connection handler.

   The structure contains pointers to plugin functions which the server
   will call when a new client connects or when the connection handler is
   unloaded. It also containts the maximum number of threads the connection
   handler will create.
*/
struct Connection_handler_functions
{
  /**
     The maximum number of threads this connection handler will create.
  */
  uint max_threads;

  /**
     Called by the server when a new client connects.

     @param channel_info  Pointer to object containing information
                          about the new connection.

     @retval true  failure
     @retval false success
  */
  bool (*add_connection)(Channel_info *channel_info);

  /**
     Called by the server when the connection handler is destroyed.
  */
  void (*end)(void);
};

/* create thd from channel_info object */
THD* create_thd(Channel_info* channel_info);
/* destroy channel_info object */
void destroy_channel_info(Channel_info* channel_info);
/* Decrement connection counter */
void dec_connection_count();
/*
  thread_created is maintained by thread pool when activated since
  user threads are created by the thread pool (and also special
  threads to maintain the thread pool). This is done through
  inc_thread_created.
*/
void inc_thread_created();

void thd_lock_thread_count(THD *thd);
void thd_unlock_thread_count(THD *thd);

#ifdef __cplusplus
}
#endif

/*
  Interface to global thread list iterator functions.
  Executes a function with signature 'void f(THD*, uint64)' for all THDs.
*/
typedef void (do_thd_impl_uint64)(THD*, uint64);
void do_for_all_thd(do_thd_impl_uint64, uint64);

/* Needed to get access to scheduler variables */
void* thd_get_scheduler_data(THD *thd);
void thd_set_scheduler_data(THD *thd, void *data);
PSI_thread* thd_get_psi(THD *thd);
void thd_set_psi(THD *thd, PSI_thread *psi);

/* Interface to THD variables and functions */
void thd_set_killed(THD *thd);
void thd_clear_errors(THD *thd);
void thd_close_connection(THD *thd);
THD *thd_get_current_thd();
void thd_lock_data(THD *thd);
void thd_unlock_data(THD *thd);
bool thd_is_transaction_active(THD *thd);
int thd_connection_has_data(THD *thd);
void thd_set_net_read_write(THD *thd, uint val);
uint thd_get_net_read_write(THD *thd);
void thd_set_not_killable(THD *thd);
ulong  thd_get_net_wait_timeout(THD *thd);
my_socket thd_get_fd(THD *thd);
int thd_store_globals(THD* thd);

/* Print to the MySQL error log */
void sql_print_error(const char *format, ...);
void sql_print_warning(const char *format, ...);
void sql_print_information(const char *format, ...);

/* Store a table record */
bool schema_table_store_record(THD *thd, TABLE *table);

/*
  The thread pool must be able to execute statements using the connection
  state in THD object. This is the main objective of the thread pool to
  schedule the start of these commands.
*/
bool do_command(THD *thd);

/*
  The thread pool requires an interface to the connection logic in the
  MySQL Server since the thread pool will maintain the event logic on
  the TCP connection of the MySQL Server. Thus new connections, dropped
  connections will be discovered by the thread pool and it needs to
  ensure that the proper MySQL Server logic attached to these events is
  executed.
*/
/* Prepare connection as part of connection set-up */
bool thd_prepare_connection(THD *thd);
/* Release auditing before executing statement */
void mysql_audit_release(THD *thd);
/* Check if connection is still alive */
bool thd_connection_alive(THD *thd);
/* Close connection with possible error code */
void close_connection(THD *thd, uint sql_errno,
                      bool server_shutdown, bool generate_event);
/* End the connection before closing it */
void end_connection(THD *thd);
/* Reset thread globals */
void reset_thread_globals(THD *thd);

/*
  max_connections is needed to calculate the maximum number of threads
  that is allowed to be started by the thread pool. The method
  get_max_connections() gets reference to this variable.
*/
ulong get_max_connections(void);
/*
  connection_attrib is the thread attributes for connection threads,
  the method get_connection_attrib provides a reference to these
  attributes.
*/
my_thread_attr_t *get_connection_attrib(void);

/* Increment the status variable 'Aborted_connects'. */
#ifndef EMBEDDED_LIBRARY
void increment_aborted_connects();
#endif
#endif // THREAD_POOL_PRIV_INCLUDED

Name	Size	Permission
psi	---	0755
client_authentication.h	1658 bytes	0644
client_plugin.h	7143 bytes	0644
client_plugin.h.pp	1988 bytes	0644
com_data.h	3515 bytes	0644
get_password.h	1601 bytes	0644
group_replication_priv.h	5138 bytes	0644
innodb_priv.h	2570 bytes	0644
mysql_lex_string.h	1505 bytes	0644
plugin.h	26707 bytes	0644
plugin_audit.h	17944 bytes	0644
plugin_audit.h.pp	14023 bytes	0644
plugin_audit.h.pp.lve	13897 bytes	0644
plugin_auth.h	5767 bytes	0644
plugin_auth.h.pp	5147 bytes	0644
plugin_auth_common.h	5529 bytes	0644
plugin_ftparser.h	8047 bytes	0644
plugin_ftparser.h.pp	4871 bytes	0644
plugin_group_replication.h	6072 bytes	0644
plugin_keyring.h	6694 bytes	0644
plugin_keyring.h.pp	4458 bytes	0644
plugin_trace.h	12551 bytes	0644
plugin_validate_password.h	1986 bytes	0644
service_command.h	13882 bytes	0644
service_locking.h	4737 bytes	0644
service_my_plugin_log.h	2082 bytes	0644
service_my_snprintf.h	3812 bytes	0644
service_mysql_alloc.h	3163 bytes	0644
service_mysql_keyring.h	2858 bytes	0644
service_mysql_password_policy.h	2840 bytes	0644
service_mysql_string.h	5758 bytes	0644
service_parser.h	9814 bytes	0644
service_rpl_transaction_ctx.h	2764 bytes	0644
service_rpl_transaction_write_set.h	3663 bytes	0644
service_rules_table.h	5499 bytes	0644
service_security_context.h	4467 bytes	0644
service_srv_session.h	5300 bytes	0644
service_srv_session_info.h	5646 bytes	0644
service_ssl_wrapper.h	5558 bytes	0644
service_thd_alloc.h	4734 bytes	0644
service_thd_engine_lock.h	1898 bytes	0644
service_thd_wait.h	4348 bytes	0644
service_thread_scheduler.h	3079 bytes	0644
services.h	2351 bytes	0644
services.h.pp	22307 bytes	0644
thread_pool_priv.h	6652 bytes	0644
thread_type.h	1787 bytes	0644

File Content: thread_pool_priv.h

File Content: `thread_pool_priv.h`