Commit 44a3c9e7 authored by unknown's avatar unknown

Merge latest PBXT fixes from Paul.

parents dc8534c7 4de39a7a
...@@ -3041,14 +3041,6 @@ xtPublic MX_CHARSET_INFO *myxt_getcharset(bool convert) ...@@ -3041,14 +3041,6 @@ xtPublic MX_CHARSET_INFO *myxt_getcharset(bool convert)
return (MX_CHARSET_INFO *)&my_charset_utf8_general_ci; return (MX_CHARSET_INFO *)&my_charset_utf8_general_ci;
} }
#ifdef DBUG_OFF
//typedef struct st_plugin_int *plugin_ref;
#define REF_MYSQL_PLUGIN(x) (x)
#else
//typedef struct st_plugin_int **plugin_ref;
#define REF_MYSQL_PLUGIN(x) (*(x))
#endif
xtPublic void *myxt_create_thread() xtPublic void *myxt_create_thread()
{ {
#ifdef DRIZZLED #ifdef DRIZZLED
...@@ -3109,14 +3101,18 @@ xtPublic void *myxt_create_thread() ...@@ -3109,14 +3101,18 @@ xtPublic void *myxt_create_thread()
/* /*
* If PBXT is the default storage engine, then creating any THD objects will add extra * If PBXT is the default storage engine, then creating any THD objects will add extra
* references to the PBXT plugin object and will effectively deadlock the plugin so * references to the PBXT plugin object. because the threads are created but PBXT
* that server will have to force plugin shutdown. To avoid deadlocking and forced shutdown * this creates a self reference, and the reference count does not go to zero
* we must dereference the plugin after creating THD objects. * on shutdown.
*
* The server then issues a message that it is forcing shutdown of the plugin.
*
* However, the engine reference is not required by the THDs used by PBXT, so
* I just remove them here.
*/ */
LEX_STRING& plugin_name = REF_MYSQL_PLUGIN(new_thd->variables.table_plugin)->name; plugin_unlock(NULL, new_thd->variables.table_plugin);
if ((plugin_name.length == 4) && (strncmp(plugin_name.str, "PBXT", plugin_name.length) == 0)) { new_thd->variables.table_plugin = NULL;
REF_MYSQL_PLUGIN(new_thd->variables.table_plugin)->ref_count--;
}
new_thd->thread_stack = (char *) &new_thd; new_thd->thread_stack = (char *) &new_thd;
new_thd->store_globals(); new_thd->store_globals();
lex_start(new_thd); lex_start(new_thd);
...@@ -3152,17 +3148,6 @@ xtPublic void myxt_destroy_thread(void *thread, xtBool end_threads) ...@@ -3152,17 +3148,6 @@ xtPublic void myxt_destroy_thread(void *thread, xtBool end_threads)
close_thread_tables(thd); close_thread_tables(thd);
#endif #endif
/*
* In myxt_create_thread we decremented plugin ref-count to avoid dead-locking.
* Here we need to increment ref-count to avoid assertion failures.
*/
if (thd->variables.table_plugin) {
LEX_STRING& plugin_name = REF_MYSQL_PLUGIN(thd->variables.table_plugin)->name;
if ((plugin_name.length == 4) && (strncmp(plugin_name.str, "PBXT", plugin_name.length) == 0)) {
REF_MYSQL_PLUGIN(thd->variables.table_plugin)->ref_count++;
}
}
delete thd; delete thd;
/* Remember that we don't have a THD */ /* Remember that we don't have a THD */
......
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