Commit f6fcb348 authored by Sergei Golubchik's avatar Sergei Golubchik

remove sys_var specific restore_pluginvar_names() function,

use generic restore_ptr_backup() approach
parent 47ee7219
...@@ -257,15 +257,6 @@ class sys_var_pluginvar: public sys_var ...@@ -257,15 +257,6 @@ class sys_var_pluginvar: public sys_var
public: public:
struct st_plugin_int *plugin; struct st_plugin_int *plugin;
struct st_mysql_sys_var *plugin_var; struct st_mysql_sys_var *plugin_var;
/**
variable name from whatever is hard-coded in the plugin source
and doesn't have pluginname- prefix is replaced by an allocated name
with a plugin prefix. When plugin is uninstalled we need to restore the
pointer to point to the hard-coded value, because plugin may be
installed/uninstalled many times without reloading the shared object.
*/
const char *orig_pluginvar_name;
static void *operator new(size_t size, MEM_ROOT *mem_root) static void *operator new(size_t size, MEM_ROOT *mem_root)
{ return (void*) alloc_root(mem_root, size); } { return (void*) alloc_root(mem_root, size); }
static void operator delete(void *ptr_arg,size_t size) static void operator delete(void *ptr_arg,size_t size)
...@@ -278,7 +269,7 @@ class sys_var_pluginvar: public sys_var ...@@ -278,7 +269,7 @@ class sys_var_pluginvar: public sys_var
(plugin_var_arg->flags & PLUGIN_VAR_READONLY ? READONLY : 0), (plugin_var_arg->flags & PLUGIN_VAR_READONLY ? READONLY : 0),
0, -1, NO_ARG, pluginvar_show_type(plugin_var_arg), 0, 0, 0, -1, NO_ARG, pluginvar_show_type(plugin_var_arg), 0, 0,
VARIABLE_NOT_IN_BINLOG, NULL, NULL, NULL), VARIABLE_NOT_IN_BINLOG, NULL, NULL, NULL),
plugin_var(plugin_var_arg), orig_pluginvar_name(plugin_var_arg->name) plugin_var(plugin_var_arg)
{ plugin_var->name= name_arg; } { plugin_var->name= name_arg; }
sys_var_pluginvar *cast_pluginvar() { return this; } sys_var_pluginvar *cast_pluginvar() { return this; }
bool check_update_type(Item_result type); bool check_update_type(Item_result type);
...@@ -308,7 +299,6 @@ static bool register_builtin(struct st_maria_plugin *, struct st_plugin_int *, ...@@ -308,7 +299,6 @@ static bool register_builtin(struct st_maria_plugin *, struct st_plugin_int *,
static void unlock_variables(THD *thd, struct system_variables *vars); static void unlock_variables(THD *thd, struct system_variables *vars);
static void cleanup_variables(THD *thd, struct system_variables *vars); static void cleanup_variables(THD *thd, struct system_variables *vars);
static void plugin_vars_free_values(sys_var *vars); static void plugin_vars_free_values(sys_var *vars);
static void restore_pluginvar_names(sys_var *first);
static void restore_ptr_backup(uint n, st_ptr_backup *backup); static void restore_ptr_backup(uint n, st_ptr_backup *backup);
static plugin_ref intern_plugin_lock(LEX *lex, plugin_ref plugin); static plugin_ref intern_plugin_lock(LEX *lex, plugin_ref plugin);
static void intern_plugin_unlock(LEX *lex, plugin_ref plugin); static void intern_plugin_unlock(LEX *lex, plugin_ref plugin);
...@@ -1122,7 +1112,6 @@ static bool plugin_add(MEM_ROOT *tmp_root, ...@@ -1122,7 +1112,6 @@ static bool plugin_add(MEM_ROOT *tmp_root,
if (!(tmp_plugin_ptr= plugin_insert_or_reuse(&tmp))) if (!(tmp_plugin_ptr= plugin_insert_or_reuse(&tmp)))
{ {
mysql_del_sys_var_chain(tmp.system_vars); mysql_del_sys_var_chain(tmp.system_vars);
restore_pluginvar_names(tmp.system_vars);
goto err; goto err;
} }
plugin_array_version++; plugin_array_version++;
...@@ -1139,6 +1128,8 @@ static bool plugin_add(MEM_ROOT *tmp_root, ...@@ -1139,6 +1128,8 @@ static bool plugin_add(MEM_ROOT *tmp_root,
err: err:
errs++; errs++;
if (tmp.nbackups)
restore_ptr_backup(tmp.nbackups, tmp.ptr_backup);
if (name->str) if (name->str)
break; break;
} }
...@@ -1217,7 +1208,7 @@ static void plugin_del(struct st_plugin_int *plugin) ...@@ -1217,7 +1208,7 @@ static void plugin_del(struct st_plugin_int *plugin)
mysql_rwlock_wrlock(&LOCK_system_variables_hash); mysql_rwlock_wrlock(&LOCK_system_variables_hash);
mysql_del_sys_var_chain(plugin->system_vars); mysql_del_sys_var_chain(plugin->system_vars);
mysql_rwlock_unlock(&LOCK_system_variables_hash); mysql_rwlock_unlock(&LOCK_system_variables_hash);
restore_pluginvar_names(plugin->system_vars); restore_ptr_backup(plugin->nbackups, plugin->ptr_backup);
plugin_vars_free_values(plugin->system_vars); plugin_vars_free_values(plugin->system_vars);
my_hash_delete(&plugin_hash[plugin->plugin->type], (uchar*)plugin); my_hash_delete(&plugin_hash[plugin->plugin->type], (uchar*)plugin);
plugin_dl_del(plugin->plugin_dl); plugin_dl_del(plugin->plugin_dl);
...@@ -2938,16 +2929,6 @@ static st_bookmark *register_var(const char *plugin, const char *name, ...@@ -2938,16 +2929,6 @@ static st_bookmark *register_var(const char *plugin, const char *name,
return result; return result;
} }
static void restore_pluginvar_names(sys_var *first)
{
for (sys_var *var= first; var; var= var->next)
{
sys_var_pluginvar *pv= var->cast_pluginvar();
pv->plugin_var->name= pv->orig_pluginvar_name;
}
}
/* /*
returns a pointer to the memory which holds the thd-local variable or returns a pointer to the memory which holds the thd-local variable or
a pointer to the global variable if thd==null. a pointer to the global variable if thd==null.
...@@ -3823,7 +3804,7 @@ static my_option *construct_help_options(MEM_ROOT *mem_root, ...@@ -3823,7 +3804,7 @@ static my_option *construct_help_options(MEM_ROOT *mem_root,
to get the correct (not double-prefixed) help text. to get the correct (not double-prefixed) help text.
We won't need @@sysvars anymore and don't care about their proper names. We won't need @@sysvars anymore and don't care about their proper names.
*/ */
restore_pluginvar_names(p->system_vars); restore_ptr_backup(p->nbackups, p->ptr_backup);
if (construct_options(mem_root, p, opts)) if (construct_options(mem_root, p, opts))
DBUG_RETURN(NULL); DBUG_RETURN(NULL);
...@@ -3868,6 +3849,7 @@ static int test_plugin_options(MEM_ROOT *tmp_root, struct st_plugin_int *tmp, ...@@ -3868,6 +3849,7 @@ static int test_plugin_options(MEM_ROOT *tmp_root, struct st_plugin_int *tmp,
sys_var *v __attribute__((unused)); sys_var *v __attribute__((unused));
struct st_bookmark *var; struct st_bookmark *var;
uint len, count= EXTRA_OPTIONS; uint len, count= EXTRA_OPTIONS;
st_ptr_backup *tmp_backup= 0;
DBUG_ENTER("test_plugin_options"); DBUG_ENTER("test_plugin_options");
DBUG_ASSERT(tmp->plugin && tmp->name.str); DBUG_ASSERT(tmp->plugin && tmp->name.str);
...@@ -3940,7 +3922,15 @@ static int test_plugin_options(MEM_ROOT *tmp_root, struct st_plugin_int *tmp, ...@@ -3940,7 +3922,15 @@ static int test_plugin_options(MEM_ROOT *tmp_root, struct st_plugin_int *tmp,
plugin_name= tmp->name; plugin_name= tmp->name;
error= 1; error= 1;
for (opt= tmp->plugin->system_vars; opt && *opt; opt++)
if (tmp->plugin->system_vars)
{
for (len=0, opt= tmp->plugin->system_vars; *opt; len++, opt++) /* no-op */;
tmp_backup= (st_ptr_backup *)my_alloca(len * sizeof(tmp_backup[0]));
DBUG_ASSERT(tmp->nbackups == 0);
DBUG_ASSERT(tmp->ptr_backup == 0);
for (opt= tmp->plugin->system_vars; *opt; opt++)
{ {
st_mysql_sys_var *o= *opt; st_mysql_sys_var *o= *opt;
...@@ -3966,6 +3956,7 @@ static int test_plugin_options(MEM_ROOT *tmp_root, struct st_plugin_int *tmp, ...@@ -3966,6 +3956,7 @@ static int test_plugin_options(MEM_ROOT *tmp_root, struct st_plugin_int *tmp,
if (o->flags & PLUGIN_VAR_NOSYSVAR) if (o->flags & PLUGIN_VAR_NOSYSVAR)
continue; continue;
tmp_backup[tmp->nbackups++].save(&o->name);
if ((var= find_bookmark(plugin_name.str, o->name, o->flags))) if ((var= find_bookmark(plugin_name.str, o->name, o->flags)))
v= new (mem_root) sys_var_pluginvar(&chain, var->key + 1, o); v= new (mem_root) sys_var_pluginvar(&chain, var->key + 1, o);
else else
...@@ -3979,6 +3970,19 @@ static int test_plugin_options(MEM_ROOT *tmp_root, struct st_plugin_int *tmp, ...@@ -3979,6 +3970,19 @@ static int test_plugin_options(MEM_ROOT *tmp_root, struct st_plugin_int *tmp,
} }
DBUG_ASSERT(v); /* check that an object was actually constructed */ DBUG_ASSERT(v); /* check that an object was actually constructed */
} /* end for */ } /* end for */
if (tmp->nbackups)
{
size_t bytes= tmp->nbackups * sizeof(tmp->ptr_backup[0]);
tmp->ptr_backup= (st_ptr_backup *)alloc_root(mem_root, bytes);
if (!tmp->ptr_backup)
{
restore_ptr_backup(tmp->nbackups, tmp_backup);
goto err;
}
memcpy(tmp->ptr_backup, tmp_backup, bytes);
}
if (chain.first) if (chain.first)
{ {
chain.last->next = NULL; chain.last->next = NULL;
...@@ -3990,9 +3994,13 @@ static int test_plugin_options(MEM_ROOT *tmp_root, struct st_plugin_int *tmp, ...@@ -3990,9 +3994,13 @@ static int test_plugin_options(MEM_ROOT *tmp_root, struct st_plugin_int *tmp,
} }
tmp->system_vars= chain.first; tmp->system_vars= chain.first;
} }
}
DBUG_RETURN(0); DBUG_RETURN(0);
err: err:
if (tmp_backup)
my_afree(tmp_backup);
if (opts) if (opts)
my_cleanup_options(opts); my_cleanup_options(opts);
DBUG_RETURN(error); DBUG_RETURN(error);
......
...@@ -85,6 +85,7 @@ struct st_ptr_backup { ...@@ -85,6 +85,7 @@ struct st_ptr_backup {
void **ptr; void **ptr;
void *value; void *value;
void save(void **p) { ptr= p; value= *p; } void save(void **p) { ptr= p; value= *p; }
void save(const char **p) { save((void**)p); }
void restore() { *ptr= value; } void restore() { *ptr= value; }
}; };
...@@ -108,6 +109,8 @@ struct st_plugin_int ...@@ -108,6 +109,8 @@ struct st_plugin_int
LEX_STRING name; LEX_STRING name;
struct st_maria_plugin *plugin; struct st_maria_plugin *plugin;
struct st_plugin_dl *plugin_dl; struct st_plugin_dl *plugin_dl;
st_ptr_backup *ptr_backup;
uint nbackups;
uint state; uint state;
uint ref_count; /* number of threads using the plugin */ uint ref_count; /* number of threads using the plugin */
uint locks_total; /* how many times the plugin was locked */ uint locks_total; /* how many times the plugin was locked */
......
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