Skip to content

M
mariadb
Commit 9af5e6b7 authored by monty@mashka.mysql.fi's avatar monty@mashka.mysql.fi
Browse files
Options

Avoid memory overruns when buffer_length is too small (when fetching binary... 

Avoid memory overruns when buffer_length is too small (when fetching binary data in prepared statements)
parent 7d4fd474
Show whitespace changes
Inline Side-by-side
Showing with 160 additions and 145 deletions
include/errmsg.h
View file @ 9af5e6b7
...@@ -30,7 +30,7 @@ extern const char *client_errors[]; /* Error messages */ ...@@ -30,7 +30,7 @@ extern const char *client_errors[]; /* Error messages */
#define CR_MAX_ERROR 2999 #define CR_MAX_ERROR 2999
#if defined(OS2) && defined(MYSQL_SERVER) #if defined(OS2) && defined(MYSQL_SERVER)
#define CER(X) client_errors[(X)-CR_MIN_ERROR] #define CER(X) client_errors[(X)-CR_MIN_ERROR]
#else #elif !defined(ER)
#define ER(X) client_errors[(X)-CR_MIN_ERROR] #define ER(X) client_errors[(X)-CR_MIN_ERROR]
#endif #endif
#define CLIENT_ERRMAP 2 /* Errormap used by my_error() */ #define CLIENT_ERRMAP 2 /* Errormap used by my_error() */
......
libmysql/libmysql.c
View file @ 9af5e6b7
...@@ -4500,6 +4500,7 @@ static void send_data_long(MYSQL_BIND *param, longlong value) ...@@ -4500,6 +4500,7 @@ static void send_data_long(MYSQL_BIND *param, longlong value)
} }
} }
/* Convert Double to buffer types */ /* Convert Double to buffer types */
static void send_data_double(MYSQL_BIND *param, double value) static void send_data_double(MYSQL_BIND *param, double value)
{ {
...@@ -4589,6 +4590,7 @@ static void send_data_str(MYSQL_BIND *param, char *value, uint length) ...@@ -4589,6 +4590,7 @@ static void send_data_str(MYSQL_BIND *param, char *value, uint length)
*param->length= length; *param->length= length;
length= min(length, param->buffer_length); length= min(length, param->buffer_length);
memcpy(buffer, value, length); memcpy(buffer, value, length);
if (length != param->buffer_length)
buffer[length]='\0'; buffer[length]='\0';
} }
} }
...@@ -4808,6 +4810,8 @@ static void fetch_result_str(MYSQL_BIND *param, uchar **row) ...@@ -4808,6 +4810,8 @@ static void fetch_result_str(MYSQL_BIND *param, uchar **row)
ulong length= net_field_length(row); ulong length= net_field_length(row);
ulong copy_length= min(length, param->buffer_length); ulong copy_length= min(length, param->buffer_length);
memcpy(param->buffer, (char *)*row, copy_length); memcpy(param->buffer, (char *)*row, copy_length);
/* Add an end null if there is room in the buffer */
if (copy_length != param->buffer_length)
*(param->buffer+copy_length)= '\0'; *(param->buffer+copy_length)= '\0';
*param->length= length; // return total length *param->length= length; // return total length
*row+= length; *row+= length;
......
libmysqld/lib_sql.cc
View file @ 9af5e6b7
...@@ -47,7 +47,8 @@ static bool check_user(THD *thd, enum_server_command command, ...@@ -47,7 +47,8 @@ static bool check_user(THD *thd, enum_server_command command,
char * get_mysql_home(){ return mysql_home;}; char * get_mysql_home(){ return mysql_home;};
char * get_mysql_real_data_home(){ return mysql_real_data_home;}; char * get_mysql_real_data_home(){ return mysql_real_data_home;};
my_bool simple_command(MYSQL *mysql,enum enum_server_command command, const char *arg, my_bool simple_command(MYSQL *mysql,enum enum_server_command command,
const char *arg,
ulong length, my_bool skipp_check) ulong length, my_bool skipp_check)
{ {
my_bool result= 1; my_bool result= 1;
...@@ -56,7 +57,8 @@ my_bool simple_command(MYSQL *mysql,enum enum_server_command command, const char ...@@ -56,7 +57,8 @@ my_bool simple_command(MYSQL *mysql,enum enum_server_command command, const char
/* Check that we are calling the client functions in right order */ /* Check that we are calling the client functions in right order */
if (mysql->status != MYSQL_STATUS_READY) if (mysql->status != MYSQL_STATUS_READY)
{ {
strmov(thd->net.last_error,ER(thd->net.last_errno=CR_COMMANDS_OUT_OF_SYNC)); strmov(thd->net.last_error,
ER(thd->net.last_errno=CR_COMMANDS_OUT_OF_SYNC));
return 1; return 1;
} }
...@@ -199,7 +201,7 @@ int STDCALL mysql_server_init(int argc, char **argv, char **groups) ...@@ -199,7 +201,7 @@ int STDCALL mysql_server_init(int argc, char **argv, char **groups)
if (!opt_mysql_tmpdir || !opt_mysql_tmpdir[0]) if (!opt_mysql_tmpdir || !opt_mysql_tmpdir[0])
opt_mysql_tmpdir=(char*) P_tmpdir; /* purecov: inspected */ opt_mysql_tmpdir=(char*) P_tmpdir; /* purecov: inspected */
if (init_thread_environement()) if (init_thread_environment())
{ {
mysql_server_end(); mysql_server_end();
return 1; return 1;
......
sql/mysqld.cc
View file @ 9af5e6b7
...@@ -670,6 +670,7 @@ static void close_connections(void) ...@@ -670,6 +670,7 @@ static void close_connections(void)
} }
#endif /*EMBEDDED_LIBRARY*/ #endif /*EMBEDDED_LIBRARY*/
static void close_server_sock() static void close_server_sock()
{ {
#ifdef HAVE_CLOSE_SERVER_SOCK #ifdef HAVE_CLOSE_SERVER_SOCK
...@@ -760,8 +761,6 @@ void kill_mysql(void) ...@@ -760,8 +761,6 @@ void kill_mysql(void)
DBUG_VOID_RETURN; DBUG_VOID_RETURN;
} }
#ifndef EMBEDDED_LIBRARY
/* Force server down. kill all connections and threads and exit */ /* Force server down. kill all connections and threads and exit */
#if defined(OS2) #if defined(OS2)
...@@ -777,7 +776,7 @@ static void __cdecl kill_server(int sig_ptr) ...@@ -777,7 +776,7 @@ static void __cdecl kill_server(int sig_ptr)
{ {
int sig=(int) (long) sig_ptr; // This is passed a int int sig=(int) (long) sig_ptr; // This is passed a int
DBUG_ENTER("kill_server"); DBUG_ENTER("kill_server");
#ifndef EMBEDDED_LIBRARY
// if there is a signal during the kill in progress, ignore the other // if there is a signal during the kill in progress, ignore the other
if (kill_in_progress) // Safety if (kill_in_progress) // Safety
RETURN_FROM_KILL_SERVER; RETURN_FROM_KILL_SERVER;
...@@ -798,19 +797,17 @@ static void __cdecl kill_server(int sig_ptr) ...@@ -798,19 +797,17 @@ static void __cdecl kill_server(int sig_ptr)
else else
unireg_end(); unireg_end();
pthread_exit(0); /* purecov: deadcode */ pthread_exit(0); /* purecov: deadcode */
#endif /* EMBEDDED_LIBRARY */
RETURN_FROM_KILL_SERVER; RETURN_FROM_KILL_SERVER;
} }
#endif /* EMBEDDED_LIBRARY */
#ifdef USE_ONE_SIGNAL_HAND #ifdef USE_ONE_SIGNAL_HAND
extern "C" pthread_handler_decl(kill_server_thread,arg __attribute__((unused))) extern "C" pthread_handler_decl(kill_server_thread,arg __attribute__((unused)))
{ {
SHUTDOWN_THD; SHUTDOWN_THD;
my_thread_init(); // Initialize new thread my_thread_init(); // Initialize new thread
#ifndef EMBEDDED_LIBRARY
kill_server(0); kill_server(0);
#endif /* EMBEDDED_LIBRARY */
my_thread_end(); // Normally never reached my_thread_end(); // Normally never reached
return 0; return 0;
} }
...@@ -1047,6 +1044,7 @@ static void set_root(const char *path) ...@@ -1047,6 +1044,7 @@ static void set_root(const char *path)
#endif #endif
} }
static void server_init(void) static void server_init(void)
{ {
struct sockaddr_in IPaddr; struct sockaddr_in IPaddr;
...@@ -1158,7 +1156,7 @@ static void server_init(void) ...@@ -1158,7 +1156,7 @@ static void server_init(void)
{ {
DBUG_PRINT("general",("UNIX Socket is %s",mysql_unix_port)); DBUG_PRINT("general",("UNIX Socket is %s",mysql_unix_port));
if ((unix_sock = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) if ((unix_sock= socket(AF_UNIX, SOCK_STREAM, 0)) < 0)
{ {
sql_perror("Can't start server : UNIX Socket "); /* purecov: inspected */ sql_perror("Can't start server : UNIX Socket "); /* purecov: inspected */
unireg_abort(1); /* purecov: inspected */ unireg_abort(1); /* purecov: inspected */
...@@ -1201,6 +1199,7 @@ void yyerror(const char *s) ...@@ -1201,6 +1199,7 @@ void yyerror(const char *s)
thd->lex.yylineno); thd->lex.yylineno);
} }
#ifndef EMBEDDED_LIBRARY #ifndef EMBEDDED_LIBRARY
void close_connection(NET *net,uint errcode,bool lock) void close_connection(NET *net,uint errcode,bool lock)
{ {
...@@ -1221,7 +1220,8 @@ void close_connection(NET *net,uint errcode,bool lock) ...@@ -1221,7 +1220,8 @@ void close_connection(NET *net,uint errcode,bool lock)
(void) pthread_mutex_unlock(&LOCK_thread_count); (void) pthread_mutex_unlock(&LOCK_thread_count);
DBUG_VOID_RETURN; DBUG_VOID_RETURN;
} }
#endif #endif /* EMBEDDED_LIBRARY */
/* Called when a thread is aborted */ /* Called when a thread is aborted */
/* ARGSUSED */ /* ARGSUSED */
...@@ -1772,7 +1772,7 @@ extern "C" pthread_handler_decl(handle_shutdown,arg) ...@@ -1772,7 +1772,7 @@ extern "C" pthread_handler_decl(handle_shutdown,arg)
PeekMessage(&msg, NULL, 1, 65534,PM_NOREMOVE); PeekMessage(&msg, NULL, 1, 65534,PM_NOREMOVE);
#if !defined(EMBEDDED_LIBRARY) #if !defined(EMBEDDED_LIBRARY)
if (WaitForSingleObject(hEventShutdown,INFINITE)==WAIT_OBJECT_0) if (WaitForSingleObject(hEventShutdown,INFINITE)==WAIT_OBJECT_0)
#endif #endif /* EMBEDDED_LIBRARY */
kill_server(MYSQL_KILL_SIGNAL); kill_server(MYSQL_KILL_SIGNAL);
return 0; return 0;
} }
...@@ -1789,6 +1789,7 @@ int __stdcall handle_kill(ulong ctrl_type) ...@@ -1789,6 +1789,7 @@ int __stdcall handle_kill(ulong ctrl_type)
} }
#endif #endif
#ifdef OS2 #ifdef OS2
extern "C" pthread_handler_decl(handle_shutdown,arg) extern "C" pthread_handler_decl(handle_shutdown,arg)
{ {
...@@ -1856,8 +1857,8 @@ bool open_log(MYSQL_LOG *log, const char *hostname, ...@@ -1856,8 +1857,8 @@ bool open_log(MYSQL_LOG *log, const char *hostname,
} }
static int init_common_variables(const char *conf_file_name, int argc, char **argv, static int init_common_variables(const char *conf_file_name, int argc,
const char **groups) char **argv, const char **groups)
{ {
my_umask=0660; // Default umask for new files my_umask=0660; // Default umask for new files
my_umask_dir=0700; // Default umask for new directories my_umask_dir=0700; // Default umask for new directories
...@@ -1943,12 +1944,12 @@ static int init_common_variables(const char *conf_file_name, int argc, char **ar ...@@ -1943,12 +1944,12 @@ static int init_common_variables(const char *conf_file_name, int argc, char **ar
charsets_list= list_charsets(MYF(MY_CS_COMPILED | MY_CS_CONFIG)); charsets_list= list_charsets(MYF(MY_CS_COMPILED | MY_CS_CONFIG));
if (use_temp_pool && bitmap_init(&temp_pool,1024,1)) if (use_temp_pool && bitmap_init(&temp_pool,1024,1))
return 2; return 1;
return 0; return 0;
} }
static int init_thread_environement()
static int init_thread_environment()
{ {
(void) pthread_mutex_init(&LOCK_mysql_create_db,MY_MUTEX_INIT_SLOW); (void) pthread_mutex_init(&LOCK_mysql_create_db,MY_MUTEX_INIT_SLOW);
(void) pthread_mutex_init(&LOCK_Acl,MY_MUTEX_INIT_SLOW); (void) pthread_mutex_init(&LOCK_Acl,MY_MUTEX_INIT_SLOW);
...@@ -1966,9 +1967,6 @@ static int init_thread_environement() ...@@ -1966,9 +1967,6 @@ static int init_thread_environement()
(void) pthread_mutex_init(&LOCK_bytes_received,MY_MUTEX_INIT_FAST); (void) pthread_mutex_init(&LOCK_bytes_received,MY_MUTEX_INIT_FAST);
(void) pthread_mutex_init(&LOCK_timezone,MY_MUTEX_INIT_FAST); (void) pthread_mutex_init(&LOCK_timezone,MY_MUTEX_INIT_FAST);
(void) pthread_mutex_init(&LOCK_user_conn, MY_MUTEX_INIT_FAST); (void) pthread_mutex_init(&LOCK_user_conn, MY_MUTEX_INIT_FAST);
#ifdef HAVE_REPLICATION
(void) pthread_mutex_init(&LOCK_rpl_status, MY_MUTEX_INIT_FAST);
#endif
(void) pthread_mutex_init(&LOCK_active_mi, MY_MUTEX_INIT_FAST); (void) pthread_mutex_init(&LOCK_active_mi, MY_MUTEX_INIT_FAST);
(void) pthread_mutex_init(&LOCK_global_system_variables, MY_MUTEX_INIT_FAST); (void) pthread_mutex_init(&LOCK_global_system_variables, MY_MUTEX_INIT_FAST);
(void) my_rwlock_init(&LOCK_grant, NULL); (void) my_rwlock_init(&LOCK_grant, NULL);
...@@ -1978,14 +1976,16 @@ static int init_thread_environement() ...@@ -1978,14 +1976,16 @@ static int init_thread_environement()
(void) pthread_cond_init(&COND_flush_thread_cache,NULL); (void) pthread_cond_init(&COND_flush_thread_cache,NULL);
(void) pthread_cond_init(&COND_manager,NULL); (void) pthread_cond_init(&COND_manager,NULL);
#ifdef HAVE_REPLICATION #ifdef HAVE_REPLICATION
(void) pthread_mutex_init(&LOCK_rpl_status, MY_MUTEX_INIT_FAST);
(void) pthread_cond_init(&COND_rpl_status, NULL); (void) pthread_cond_init(&COND_rpl_status, NULL);
#endif #endif
/* Parameter for threads created for connections */ /* Parameter for threads created for connections */
(void) pthread_attr_init(&connection_attrib); (void) pthread_attr_init(&connection_attrib);
(void) pthread_attr_setdetachstate(&connection_attrib, (void) pthread_attr_setdetachstate(&connection_attrib,
PTHREAD_CREATE_DETACHED); PTHREAD_CREATE_DETACHED);
pthread_attr_setstacksize(&connection_attrib,thread_stack);
pthread_attr_setscope(&connection_attrib, PTHREAD_SCOPE_SYSTEM); pthread_attr_setscope(&connection_attrib, PTHREAD_SCOPE_SYSTEM);
if (!(opt_specialflag & SPECIAL_NO_PRIOR))
my_pthread_attr_setprio(&connection_attrib,WAIT_PRIOR);
if (pthread_key_create(&THR_THD,NULL) || if (pthread_key_create(&THR_THD,NULL) ||
pthread_key_create(&THR_MALLOC,NULL)) pthread_key_create(&THR_MALLOC,NULL))
...@@ -1993,12 +1993,10 @@ static int init_thread_environement() ...@@ -1993,12 +1993,10 @@ static int init_thread_environement()
sql_print_error("Can't create thread-keys"); sql_print_error("Can't create thread-keys");
return 1; return 1;
} }
(void) thr_setconcurrency(concurrency); // 10 by default
return 0; return 0;
} }
static void init_ssl() static void init_ssl()
{ {
#ifdef HAVE_OPENSSL #ifdef HAVE_OPENSSL
...@@ -2017,6 +2015,7 @@ static void init_ssl() ...@@ -2017,6 +2015,7 @@ static void init_ssl()
#endif /* HAVE_OPENSSL */ #endif /* HAVE_OPENSSL */
} }
static int init_server_components() static int init_server_components()
{ {
table_cache_init(); table_cache_init();
...@@ -2039,15 +2038,24 @@ static int init_server_components() ...@@ -2039,15 +2038,24 @@ static int init_server_components()
NullS, LOG_NEW); NullS, LOG_NEW);
using_update_log=1; using_update_log=1;
} }
if (opt_slow_log) if (opt_slow_log)
open_log(&mysql_slow_log, glob_hostname, opt_slow_logname, "-slow.log", open_log(&mysql_slow_log, glob_hostname, opt_slow_logname, "-slow.log",
NullS, LOG_NORMAL); NullS, LOG_NORMAL);
if (opt_bin_log)
{
open_log(&mysql_bin_log, glob_hostname, opt_bin_logname, "-bin",
opt_binlog_index_name,LOG_BIN);
using_update_log=1;
}
if (ha_init()) if (ha_init())
{ {
sql_print_error("Can't init databases"); sql_print_error("Can't init databases");
return 1; return 1;
} }
if (opt_myisam_log)
(void) mi_log(1);
ha_key_cache(); ha_key_cache();
#if defined(HAVE_MLOCKALL) && defined(MCL_CURRENT) #if defined(HAVE_MLOCKALL) && defined(MCL_CURRENT)
...@@ -2064,23 +2072,14 @@ static int init_server_components() ...@@ -2064,23 +2072,14 @@ static int init_server_components()
locked_in_memory=0; locked_in_memory=0;
#endif #endif
if (opt_myisam_log)
(void) mi_log( 1 );
ft_init_stopwords(ft_precompiled_stopwords); ft_init_stopwords(ft_precompiled_stopwords);
init_max_user_conn(); init_max_user_conn();
init_update_queries(); init_update_queries();
if (opt_bin_log)
{
open_log(&mysql_bin_log, glob_hostname, opt_bin_logname, "-bin",
opt_binlog_index_name,LOG_BIN);
using_update_log=1;
}
return 0; return 0;
} }
static void create_maintenance_thread() static void create_maintenance_thread()
{ {
if ( if (
...@@ -2095,47 +2094,47 @@ static void create_maintenance_thread() ...@@ -2095,47 +2094,47 @@ static void create_maintenance_thread()
} }
} }
static void create_shutdown_thread() static void create_shutdown_thread()
{ {
#ifdef __WIN__ #ifdef __WIN__
{ hEventShutdown=CreateEvent(0, FALSE, FALSE, shutdown_event_name);
hEventShutdown=CreateEvent(0, FALSE, FALSE, event_name);
pthread_t hThread; pthread_t hThread;
if (pthread_create(&hThread,&connection_attrib,handle_shutdown,0)) if (pthread_create(&hThread,&connection_attrib,handle_shutdown,0))
sql_print_error("Warning: Can't create thread to handle shutdown requests"); sql_print_error("Warning: Can't create thread to handle shutdown requests");
// On "Stop Service" we have to do regular shutdown // On "Stop Service" we have to do regular shutdown
Service.SetShutdownEvent(hEventShutdown); Service.SetShutdownEvent(hEventShutdown);
}
#endif #endif
#ifdef OS2 #ifdef OS2
{ pthread_cond_init(&eventShutdown, NULL);
pthread_cond_init( &eventShutdown, NULL);
pthread_t hThread; pthread_t hThread;
if (pthread_create(&hThread,&connection_attrib,handle_shutdown,0)) if (pthread_create(&hThread,&connection_attrib,handle_shutdown,0))
sql_print_error("Warning: Can't create thread to handle shutdown requests"); sql_print_error("Warning: Can't create thread to handle shutdown requests");
}
#endif #endif
} }
#ifdef __NT__
void create_named_pipe_thread() #if defined(__NT__) || defined(HAVE_SMEM)
static void handle_connections_methods()
{ {
pthread_t hThread;
DBUG_ENTER("handle_connections_methods");
#ifdef __NT__
if (hPipe == INVALID_HANDLE_VALUE && if (hPipe == INVALID_HANDLE_VALUE &&
(!have_tcpip || opt_disable_networking)) (!have_tcpip || opt_disable_networking) &&
!opt_enable_shared_memory)
{ {
sql_print_error("TCP/IP or --enable-named-pipe should be configured on NT OS"); sql_print_error("TCP/IP,--shared-memory or --named-pipe should be configured on NT OS");
unireg_abort(1); unireg_abort(1); // Will not return
} }
else #endif
{
pthread_mutex_lock(&LOCK_thread_count); pthread_mutex_lock(&LOCK_thread_count);
(void) pthread_cond_init(&COND_handler_count,NULL); (void) pthread_cond_init(&COND_handler_count,NULL);
{
pthread_t hThread;
handler_count=0; handler_count=0;
if (hPipe != INVALID_HANDLE_VALUE && opt_enable_named_pipe) #ifdef __NT__
if (hPipe != INVALID_HANDLE_VALUE)
{ {
handler_count++; handler_count++;
if (pthread_create(&hThread,&connection_attrib, if (pthread_create(&hThread,&connection_attrib,
...@@ -2145,23 +2144,37 @@ void create_named_pipe_thread() ...@@ -2145,23 +2144,37 @@ void create_named_pipe_thread()
handler_count--; handler_count--;
} }
} }
#endif /* __NT__ */
if (have_tcpip && !opt_disable_networking) if (have_tcpip && !opt_disable_networking)
{ {
handler_count++; handler_count++;
if (pthread_create(&hThread,&connection_attrib, if (pthread_create(&hThread,&connection_attrib,
handle_connections_sockets, 0)) handle_connections_sockets, 0))
{ {
sql_print_error("Warning: Can't create thread to handle named pipes"); sql_print_error("Warning: Can't create thread to handle TCP/IP");
handler_count--;
}
}
#ifdef HAVE_SMEM
if (opt_enable_shared_memory)
{
handler_count++;
if (pthread_create(&hThread,&connection_attrib,
handle_connections_shared_memory, 0))
{
sql_print_error("Warning: Can't create thread to handle shared memory");
handler_count--; handler_count--;
} }
} }
#endif
while (handler_count > 0) while (handler_count > 0)
pthread_cond_wait(&COND_handler_count,&LOCK_thread_count); pthread_cond_wait(&COND_handler_count,&LOCK_thread_count);
}
pthread_mutex_unlock(&LOCK_thread_count); pthread_mutex_unlock(&LOCK_thread_count);
} DBUG_VOID_RETURN;
} }
#endif #endif /* defined(__NT__) || defined(HAVE_SMEM) */
#ifndef EMBEDDED_LIBRARY #ifndef EMBEDDED_LIBRARY
#ifdef __WIN__ #ifdef __WIN__
...@@ -2170,10 +2183,10 @@ int win_main(int argc, char **argv) ...@@ -2170,10 +2183,10 @@ int win_main(int argc, char **argv)
int main(int argc, char **argv) int main(int argc, char **argv)
#endif #endif
{ {
int init_error;
DEBUGGER_OFF; DEBUGGER_OFF;
MY_INIT(argv[0]); // init my_sys library & pthreads
#ifdef _CUSTOMSTARTUPCONFIG_ #ifdef _CUSTOMSTARTUPCONFIG_
if (_cust_check_startup()) if (_cust_check_startup())
{ {
...@@ -2182,26 +2195,20 @@ int main(int argc, char **argv) ...@@ -2182,26 +2195,20 @@ int main(int argc, char **argv)
} }
#endif #endif
MY_INIT(argv[0]); // init my_sys library & pthreads if (init_common_variables(MYSQL_CONFIG_NAME,
argc, argv, load_default_groups))
if ((init_error=init_common_variables(MYSQL_CONFIG_NAME, unireg_abort(1); // Will do exit
argc, argv, load_default_groups)))
if (init_error == 2)
unireg_abort(1);
else
exit(1);
init_signals(); init_signals();
if (init_thread_environement())
exit(1);
select_thread=pthread_self();
select_thread_in_use=1;
if (!(opt_specialflag & SPECIAL_NO_PRIOR)) if (!(opt_specialflag & SPECIAL_NO_PRIOR))
my_pthread_setprio(pthread_self(),CONNECT_PRIOR); my_pthread_setprio(pthread_self(),CONNECT_PRIOR);
if (init_thread_environment())
unireg_abort(1);
pthread_attr_setstacksize(&connection_attrib,thread_stack);
(void) thr_setconcurrency(concurrency); // 10 by default
if (!(opt_specialflag & SPECIAL_NO_PRIOR)) select_thread=pthread_self();
my_pthread_attr_setprio(&connection_attrib,WAIT_PRIOR); select_thread_in_use=1;
init_ssl(); init_ssl();
#ifdef HAVE_LIBWRAP #ifdef HAVE_LIBWRAP
...@@ -2224,21 +2231,21 @@ int main(int argc, char **argv) ...@@ -2224,21 +2231,21 @@ int main(int argc, char **argv)
if (opt_bin_log && !server_id) if (opt_bin_log && !server_id)
{ {
server_id= !master_host ? 1 : 2; server_id= !master_host ? 1 : 2;
switch (server_id) {
#ifdef EXTRA_DEBUG #ifdef EXTRA_DEBUG
switch (server_id) {
case 1: case 1:
sql_print_error("\ sql_print_error("\
Warning: You have enabled the binary log, but you haven't set server-id:\n\ Warning: You have enabled the binary log, but you haven't set server-id:\n\
Updates will be logged to the binary log, but connections to slaves will\n\ Updates will be logged to the binary log, but connections to slaves will\n\
not be accepted."); not be accepted.");
break; break;
#endif
case 2: case 2:
sql_print_error("\ sql_print_error("\
Warning: You should set server-id to a non-0 value if master_host is set.\n\ Warning: You should set server-id to a non-0 value if master_host is set.\n\
The server will not act as a slave."); The server will not act as a slave.");
break; break;
} }
#endif
} }
if (init_server_components()) if (init_server_components())
...@@ -2250,12 +2257,8 @@ The server will not act as a slave."); ...@@ -2250,12 +2257,8 @@ The server will not act as a slave.");
{ {
freopen(MYSQL_ERR_FILE,"a+",stdout); freopen(MYSQL_ERR_FILE,"a+",stdout);
freopen(MYSQL_ERR_FILE,"a+",stderr); freopen(MYSQL_ERR_FILE,"a+",stderr);
}
#endif
#ifdef __WIN__
if (!opt_console)
FreeConsole(); // Remove window FreeConsole(); // Remove window
}
#endif #endif
/* /*
...@@ -2273,6 +2276,8 @@ The server will not act as a slave."); ...@@ -2273,6 +2276,8 @@ The server will not act as a slave.");
if (!opt_bootstrap) if (!opt_bootstrap)
(void) my_delete(pidfile_name,MYF(MY_WME)); // Not needed anymore (void) my_delete(pidfile_name,MYF(MY_WME)); // Not needed anymore
#endif #endif
if (unix_sock != INVALID_SOCKET)
unlink(mysql_unix_port);
exit(1); exit(1);
} }
if (!opt_noacl) if (!opt_noacl)
...@@ -2306,13 +2311,10 @@ The server will not act as a slave."); ...@@ -2306,13 +2311,10 @@ The server will not act as a slave.");
printf(ER(ER_READY),my_progname,server_version,""); printf(ER(ER_READY),my_progname,server_version,"");
fflush(stdout); fflush(stdout);
#ifdef __NT__ #if defined(__NT__) || defined(HAVE_SMEM)
create_named_pipe_thread(); handle_connections_methods();
#else #else
handle_connections_sockets(0); handle_connections_sockets(0);
#ifdef EXTRA_DEBUG2
sql_print_error("Exiting main thread");
#endif
#endif /* __NT__ */ #endif /* __NT__ */
/* (void) pthread_attr_destroy(&connection_attrib); */ /* (void) pthread_attr_destroy(&connection_attrib); */
...@@ -2494,13 +2496,14 @@ int main(int argc, char **argv) ...@@ -2494,13 +2496,14 @@ int main(int argc, char **argv)
Execute all commands from a file. Used by the mysql_install_db script to Execute all commands from a file. Used by the mysql_install_db script to
create MySQL privilege tables without having to start a full MySQL server. create MySQL privilege tables without having to start a full MySQL server.
*/ */
#ifndef EMBEDDED_LIBRARY
static int bootstrap(FILE *file) static int bootstrap(FILE *file)
{ {
THD *thd= new THD; THD *thd;
int error; int error= 0;
DBUG_ENTER("bootstrap"); DBUG_ENTER("bootstrap");
#ifndef EMBEDDED_LIBRARY // TODO: Enable this
thd= new THD;
thd->bootstrap=1; thd->bootstrap=1;
thd->client_capabilities=0; thd->client_capabilities=0;
my_net_init(&thd->net,(st_vio*) 0); my_net_init(&thd->net,(st_vio*) 0);
...@@ -2528,10 +2531,10 @@ static int bootstrap(FILE *file) ...@@ -2528,10 +2531,10 @@ static int bootstrap(FILE *file)
net_end(&thd->net); net_end(&thd->net);
thd->cleanup(); thd->cleanup();
delete thd; delete thd;
#endif /* EMBEDDED_LIBRARY */
DBUG_RETURN(error); DBUG_RETURN(error);
} }
#endif
static bool read_init_file(char *file_name) static bool read_init_file(char *file_name)
{ {
...@@ -2540,15 +2543,13 @@ static bool read_init_file(char *file_name) ...@@ -2540,15 +2543,13 @@ static bool read_init_file(char *file_name)
DBUG_PRINT("enter",("name: %s",file_name)); DBUG_PRINT("enter",("name: %s",file_name));
if (!(file=my_fopen(file_name,O_RDONLY,MYF(MY_WME)))) if (!(file=my_fopen(file_name,O_RDONLY,MYF(MY_WME))))
return(1); return(1);
#ifndef EMBEDDED_LIBRARY
bootstrap(file); /* Ignore errors from this */ bootstrap(file); /* Ignore errors from this */
#endif
(void) my_fclose(file,MYF(MY_WME)); (void) my_fclose(file,MYF(MY_WME));
return 0; return 0;
} }
#ifndef EMBEDDED_LIBRARY
#ifndef EMBEDDED_LIBRARY
static void create_new_thread(THD *thd) static void create_new_thread(THD *thd)
{ {
DBUG_ENTER("create_new_thread"); DBUG_ENTER("create_new_thread");
...@@ -2629,7 +2630,8 @@ static void create_new_thread(THD *thd) ...@@ -2629,7 +2630,8 @@ static void create_new_thread(THD *thd)
DBUG_PRINT("info",("Thread created")); DBUG_PRINT("info",("Thread created"));
DBUG_VOID_RETURN; DBUG_VOID_RETURN;
} }
#endif #endif /* EMBEDDED_LIBRARY */
#ifdef SIGNALS_DONT_BREAK_READ #ifdef SIGNALS_DONT_BREAK_READ
inline void kill_broken_server() inline void kill_broken_server()
...@@ -2647,10 +2649,11 @@ inline void kill_broken_server() ...@@ -2647,10 +2649,11 @@ inline void kill_broken_server()
#define MAYBE_BROKEN_SYSCALL #define MAYBE_BROKEN_SYSCALL
#endif #endif
#ifndef EMBEDDED_LIBRARY
/* Handle new connections and spawn new process to handle them */ /* Handle new connections and spawn new process to handle them */
extern "C" pthread_handler_decl(handle_connections_sockets,arg __attribute__((unused))) #ifndef EMBEDDED_LIBRARY
extern "C" pthread_handler_decl(handle_connections_sockets,
arg __attribute__((unused)))
{ {
my_socket sock,new_sock; my_socket sock,new_sock;
uint error_count=0; uint error_count=0;
...@@ -2939,6 +2942,7 @@ extern "C" pthread_handler_decl(handle_connections_namedpipes,arg) ...@@ -2939,6 +2942,7 @@ extern "C" pthread_handler_decl(handle_connections_namedpipes,arg)
} }
#endif /* __NT__ */ #endif /* __NT__ */
/* /*
Thread of shared memory's service Thread of shared memory's service
...@@ -2947,6 +2951,7 @@ extern "C" pthread_handler_decl(handle_connections_namedpipes,arg) ...@@ -2947,6 +2951,7 @@ extern "C" pthread_handler_decl(handle_connections_namedpipes,arg)
handle_connections_shared_memory Thread handle handle_connections_shared_memory Thread handle
arg Arguments of thread arg Arguments of thread
*/ */
#ifdef HAVE_SMEM #ifdef HAVE_SMEM
pthread_handler_decl(handle_connections_shared_memory,arg) pthread_handler_decl(handle_connections_shared_memory,arg)
{ {
...@@ -2979,13 +2984,13 @@ pthread_handler_decl(handle_connections_shared_memory,arg) ...@@ -2979,13 +2984,13 @@ pthread_handler_decl(handle_connections_shared_memory,arg)
DBUG_PRINT("general",("Waiting for allocated shared memory.")); DBUG_PRINT("general",("Waiting for allocated shared memory."));
/* /*
The name of event and file-mapping events create agree next rule: The name of event and file-mapping events create agree next rule:
shared_memory_base_name+unique_part shared_memory_base_name+unique_part
Where: Where:
shared_memory_base_name is unique value for each server shared_memory_base_name is unique value for each server
unique_part is unique value for each object (events and file-mapping) unique_part is unique value for each object (events and file-mapping)
*/ */
suffix_pos = strxmov(tmp,shared_memory_base_name,"_",NullS); suffix_pos = strxmov(tmp,shared_memory_base_name,"_",NullS);
strmov(suffix_pos, "CONNECT_REQUEST"); strmov(suffix_pos, "CONNECT_REQUEST");
if ((event_connect_request = CreateEvent(NULL,FALSE,FALSE,tmp)) == 0) if ((event_connect_request = CreateEvent(NULL,FALSE,FALSE,tmp)) == 0)
...@@ -3151,14 +3156,15 @@ error: ...@@ -3151,14 +3156,15 @@ error:
DBUG_RETURN(0); DBUG_RETURN(0);
} }
#endif /* HAVE_SMEM */ #endif /* HAVE_SMEM */
#endif /* EMBEDDED_LIBRARY */ #endif /* EMBEDDED_LIBRARY */
/******************************************************************************
** handle start options /****************************************************************************
Handle start options
******************************************************************************/ ******************************************************************************/
enum options { enum options
{
OPT_ISAM_LOG=256, OPT_SKIP_NEW, OPT_ISAM_LOG=256, OPT_SKIP_NEW,
OPT_SKIP_GRANT, OPT_SKIP_LOCK, OPT_SKIP_GRANT, OPT_SKIP_LOCK,
OPT_ENABLE_LOCK, OPT_USE_LOCKING, OPT_ENABLE_LOCK, OPT_USE_LOCKING,
...@@ -4039,7 +4045,7 @@ struct my_option my_long_options[] = ...@@ -4039,7 +4045,7 @@ struct my_option my_long_options[] =
"Number of seconds to wait for more data from a master/slave connection before aborting the read.", "Number of seconds to wait for more data from a master/slave connection before aborting the read.",
(gptr*) &slave_net_timeout, (gptr*) &slave_net_timeout, 0, (gptr*) &slave_net_timeout, (gptr*) &slave_net_timeout, 0,
GET_ULONG, REQUIRED_ARG, SLAVE_NET_TIMEOUT, 1, LONG_TIMEOUT, 0, 1, 0}, GET_ULONG, REQUIRED_ARG, SLAVE_NET_TIMEOUT, 1, LONG_TIMEOUT, 0, 1, 0},
#endif #endif /* HAVE_REPLICATION */
{"slow_launch_time", OPT_SLOW_LAUNCH_TIME, {"slow_launch_time", OPT_SLOW_LAUNCH_TIME,
"If creating the thread takes longer than this value (in seconds), the Slow_launch_threads counter will be incremented.", "If creating the thread takes longer than this value (in seconds), the Slow_launch_threads counter will be incremented.",
(gptr*) &slow_launch_time, (gptr*) &slow_launch_time, 0, GET_ULONG, (gptr*) &slow_launch_time, (gptr*) &slow_launch_time, 0, GET_ULONG,
...@@ -4941,7 +4947,7 @@ static void fix_paths(void) ...@@ -4941,7 +4947,7 @@ static void fix_paths(void)
if (!(slave_load_tmpdir = (char*) my_strdup(mysql_tmpdir, MYF(MY_FAE)))) if (!(slave_load_tmpdir = (char*) my_strdup(mysql_tmpdir, MYF(MY_FAE))))
exit(1); exit(1);
} }
#endif #endif /* HAVE_REPLICATION */
} }
......
sql/sql_parse.cc
View file @ 9af5e6b7
...@@ -1208,23 +1208,26 @@ bool dispatch_command(enum enum_server_command command, THD *thd, ...@@ -1208,23 +1208,26 @@ bool dispatch_command(enum enum_server_command command, THD *thd,
while (!thd->fatal_error && thd->lex.found_colon) while (!thd->fatal_error && thd->lex.found_colon)
{ {
char *packet= thd->lex.found_colon;
/* /*
Multiple queries exits, execute them individually Multiple queries exits, execute them individually
*/ */
if (thd->lock || thd->open_tables || thd->derived_tables) if (thd->lock || thd->open_tables || thd->derived_tables)
close_thread_tables(thd); close_thread_tables(thd);
uint length= thd->query_length-(uint)(thd->lex.found_colon-thd->query); ulong length= thd->query_length-(ulong)(thd->lex.found_colon-thd->query);
/* Remove garbage at start of query */ /* Remove garbage at start of query */
char *packet= thd->lex.found_colon; while (my_isspace(system_charset_info, *packet) && length > 0)
while (my_isspace(system_charset_info,packet[0]) && length > 0)
{ {
packet++; packet++;
length--; length--;
} }
thd->query= packet;
thd->query_length= length; thd->query_length= length;
thd->query= packet;
VOID(pthread_mutex_lock(&LOCK_thread_count));
thd->query_id= query_id++;
VOID(pthread_mutex_unlock(&LOCK_thread_count));
mysql_parse(thd, packet, length); mysql_parse(thd, packet, length);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7