Commit 0930eb86 authored by Sergei Golubchik's avatar Sergei Golubchik

Spider cannot run DDL (e.g. create tables) before ddl recovery

use signal_ddl_recovery_done callback for that.

also make the server to call signal_ddl_recovery_done() when loading
plugins at run-time (so that plugins would't need to detect that
on their own)
parent e95bba9c
...@@ -629,7 +629,7 @@ int ha_finalize_handlerton(st_plugin_int *plugin) ...@@ -629,7 +629,7 @@ int ha_finalize_handlerton(st_plugin_int *plugin)
const char *hton_no_exts[]= { 0 }; const char *hton_no_exts[]= { 0 };
static bool ddl_recovery_done= false;
int ha_initialize_handlerton(st_plugin_int *plugin) int ha_initialize_handlerton(st_plugin_int *plugin)
{ {
...@@ -779,6 +779,9 @@ int ha_initialize_handlerton(st_plugin_int *plugin) ...@@ -779,6 +779,9 @@ int ha_initialize_handlerton(st_plugin_int *plugin)
resolve_sysvar_table_options(hton); resolve_sysvar_table_options(hton);
update_discovery_counters(hton, 1); update_discovery_counters(hton, 1);
if (ddl_recovery_done && hton->signal_ddl_recovery_done)
hton->signal_ddl_recovery_done(hton);
DBUG_RETURN(ret); DBUG_RETURN(ret);
err_deinit: err_deinit:
...@@ -975,6 +978,7 @@ void ha_signal_ddl_recovery_done() ...@@ -975,6 +978,7 @@ void ha_signal_ddl_recovery_done()
DBUG_ENTER("ha_signal_ddl_recovery_done"); DBUG_ENTER("ha_signal_ddl_recovery_done");
plugin_foreach(NULL, signal_ddl_recovery_done, MYSQL_STORAGE_ENGINE_PLUGIN, plugin_foreach(NULL, signal_ddl_recovery_done, MYSQL_STORAGE_ENGINE_PLUGIN,
NULL); NULL);
ddl_recovery_done= true;
DBUG_VOID_RETURN; DBUG_VOID_RETURN;
} }
......
...@@ -7123,6 +7123,15 @@ bool spider_init_system_tables() ...@@ -7123,6 +7123,15 @@ bool spider_init_system_tables()
} }
/*
Spider is typically loaded before ddl_recovery, but DDL statements
cannot be executed before ddl_recovery, so we delay system table creation.
*/
static void spider_after_ddl_recovery(handlerton *)
{
spider_init_system_tables();
}
int spider_db_init( int spider_db_init(
void *p void *p
) { ) {
...@@ -7153,6 +7162,7 @@ int spider_db_init( ...@@ -7153,6 +7162,7 @@ int spider_db_init(
spider_hton->close_cursor_read_view = spider_close_cursor_read_view; spider_hton->close_cursor_read_view = spider_close_cursor_read_view;
*/ */
spider_hton->panic = spider_panic; spider_hton->panic = spider_panic;
spider_hton->signal_ddl_recovery_done= spider_after_ddl_recovery;
spider_hton->close_connection = spider_close_connection; spider_hton->close_connection = spider_close_connection;
spider_hton->start_consistent_snapshot = spider_start_consistent_snapshot; spider_hton->start_consistent_snapshot = spider_start_consistent_snapshot;
spider_hton->flush_logs = spider_flush_logs; spider_hton->flush_logs = spider_flush_logs;
...@@ -7490,11 +7500,6 @@ int spider_db_init( ...@@ -7490,11 +7500,6 @@ int spider_db_init(
spider_udf_table_mon_list_hash[roop_count].array.size_of_element); spider_udf_table_mon_list_hash[roop_count].array.size_of_element);
} }
if (spider_init_system_tables())
{
goto error_system_table_creation;
}
#ifndef WITHOUT_SPIDER_BG_SEARCH #ifndef WITHOUT_SPIDER_BG_SEARCH
if (!(spider_table_sts_threads = (SPIDER_THREAD *) if (!(spider_table_sts_threads = (SPIDER_THREAD *)
spider_bulk_malloc(NULL, SPD_MID_DB_INIT_12, MYF(MY_WME | MY_ZEROFILL), spider_bulk_malloc(NULL, SPD_MID_DB_INIT_12, MYF(MY_WME | MY_ZEROFILL),
...@@ -7595,7 +7600,6 @@ int spider_db_init( ...@@ -7595,7 +7600,6 @@ int spider_db_init(
error_init_udf_table_mon_cond: error_init_udf_table_mon_cond:
for (; roop_count >= 0; roop_count--) for (; roop_count >= 0; roop_count--)
pthread_cond_destroy(&spider_udf_table_mon_conds[roop_count]); pthread_cond_destroy(&spider_udf_table_mon_conds[roop_count]);
error_system_table_creation:
roop_count = spider_param_udf_table_mon_mutex_count() - 1; roop_count = spider_param_udf_table_mon_mutex_count() - 1;
error_init_udf_table_mon_mutex: error_init_udf_table_mon_mutex:
for (; roop_count >= 0; roop_count--) for (; roop_count >= 0; roop_count--)
......
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