hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

mysql_library_end is not called if it wasn't initialized properly.

Browse Source
This commit is contained in:
vraatikka
2013-08-12 13:12:23 +03:00
parent 0c5125a44d
commit 64cb6eca56
1 changed files with 31 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
server/core/gateway.c
View File

@ -89,9 +89,14 @@ static char datadir[1024] = "";
*/
static bool do_exit = FALSE;
/**
* Flag to indicate whether libmysqld is successfully initialized.
*/
static bool libmysqld_started = FALSE;
static void log_flush_shutdown(void);
static void log_flush_cb(void* arg);
static void libmysqld_done(void);
/**
* Handler for SIGHUP signal. Reload the configuration for the
@ -228,6 +233,15 @@ char buf[1024];
}
}
static libmysqld_done(void)
{
if (libmysqld_started) {
mysql_library_end();
}
}
/**
* The main entry point into the gateway
*
@ -277,8 +291,8 @@ ssize_t log_flush_timeout_ms = 0;
"Unable to find a MaxScale configuration file, "
"either install one in /etc/MaxScale.cnf, "
"$MAXSCALE_HOME/etc/MaxScale.cnf "
"or use the -c option with configuration file name."
" Exiting.\n");
"or use the -c option with configuration file "
"name. Exiting.\n");
}
cnf_file = &argv[n][s];
}
@ -325,7 +339,7 @@ ssize_t log_flush_timeout_ms = 0;
gw_daemonize();
}
l = atexit(mysql_library_end);
l = atexit(libmysqld_done);
if (l != 0) {
fprintf(stderr, "Couldn't register exit function.\n");
@ -383,8 +397,9 @@ ssize_t log_flush_timeout_ms = 0;
if (cnf_file == NULL) {
skygw_log_write_flush(
LOGFILE_ERROR,
"Fatal : Unable to find a MaxScale configuration file, either "
"install one in /etc/MaxScale.cnf, $MAXSCALE_HOME/etc/MaxScale.cnf "
"Fatal : Unable to find a MaxScale configuration "
"file, either install one in /etc/MaxScale.cnf, "
"$MAXSCALE_HOME/etc/MaxScale.cnf "
"or use the -c option. Exiting.\n");
exit(1);
}
@ -412,6 +427,7 @@ ssize_t log_flush_timeout_ms = 0;
__LINE__);
exit(1);
}
libmysqld_started = TRUE;
if (!config_load(cnf_file))
{
@ -455,7 +471,7 @@ ssize_t log_flush_timeout_ms = 0;
thread_wait(threads[n]);
/**
* Wait the timer thread.
* Wait the flush thread.
*/
thread_wait(log_flush_thr);