mirror/mariadb
1
0
Fork 0
mirror of https://github.com/MariaDB/server.git synced 2025-01-16 03:52:35 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

Simplifications of server interface to scheduler

Browse source
This commit is contained in:
Mikael Ronström 2011-02-10 19:24:31 +01:00
parent af948cd6fc
commit 8d319b1f29
3 changed files with 30 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
include/mysql/thread_pool_priv.h
View file

@ -34,11 +34,27 @@
*/
#define MYSQL_SERVER 1
#include <sql_class.h>
#include <scheduler.h>
#include <debug_sync.h>
#include <sql_profile.h>
#include <table.h>
struct scheduler_functions
{
uint max_threads;
bool (*init)(void);
bool (*init_new_connection_thread)(void);
void (*add_connection)(THD *thd);
void (*thd_wait_begin)(THD *thd, int wait_type);
void (*thd_wait_end)(THD *thd);
void (*post_kill_notification)(THD *thd);
bool (*end_thread)(THD *thd, bool cache_thread);
void (*end)(void);
};
/* Needed to get access to scheduler variables */
void* thd_get_scheduler(THD *thd);
PSI_thread* thd_get_psi(THD *thd);
/*
The thread pool must be able to execute commands using the connection
state in THD object. This is the main objective of the thread pool to

10
sql/scheduler.cc
View file

@ -160,6 +160,16 @@ thd_scheduler::~thd_scheduler()
{
}
void* thd_get_scheduler(THD *thd)
{
return thd->scheduler.data;
}
PSI_thread* thd_get_psi(THD *thd)
{
return thd->scheduler.m_psi;
}
static scheduler_functions *saved_thread_scheduler;
static uint saved_thread_handling;

8
sql/scheduler.h
View file

@ -72,11 +72,6 @@ enum scheduler_types
void one_thread_per_connection_scheduler();
void one_thread_scheduler();
enum pool_command_op
{
NOT_IN_USE_OP= 0, NORMAL_OP= 1, CONNECT_OP, KILL_OP, DIE_OP
};
/*
To be used for pool-of-threads (implemeneted differently on various OSs)
*/
@ -101,6 +96,9 @@ public:
~thd_scheduler();
};
void *thd_get_scheduler(THD *thd);
PSI_thread* thd_get_psi(THD *thd);
extern scheduler_functions *thread_scheduler;
#endif