mirror of
https://github.com/MariaDB/server.git
synced 2025-07-29 05:21:33 +03:00
fix autobuild failures
This commit is contained in:
@ -85,7 +85,7 @@ int Buffer::reserve(uint position, uint len_arg)
|
|||||||
min(MAX_BUFFER_SIZE,
|
min(MAX_BUFFER_SIZE,
|
||||||
max((uint) (buffer_size*1.5),
|
max((uint) (buffer_size*1.5),
|
||||||
position + len_arg)));
|
position + len_arg)));
|
||||||
if (buffer= NULL)
|
if (buffer == NULL)
|
||||||
goto err;
|
goto err;
|
||||||
buffer_size= (uint) (buffer_size*1.5);
|
buffer_size= (uint) (buffer_size*1.5);
|
||||||
}
|
}
|
||||||
|
@ -63,7 +63,7 @@ int Show_instances::do_command(struct st_net *net)
|
|||||||
Instance_map::Iterator iterator(instance_map);
|
Instance_map::Iterator iterator(instance_map);
|
||||||
|
|
||||||
instance_map->lock();
|
instance_map->lock();
|
||||||
while (instance= iterator.next())
|
while ((instance= iterator.next()))
|
||||||
{
|
{
|
||||||
position= 0;
|
position= 0;
|
||||||
store_to_string(&send_buff, instance->options.instance_name, &position);
|
store_to_string(&send_buff, instance->options.instance_name, &position);
|
||||||
@ -117,7 +117,7 @@ Show_instance_status::Show_instance_status(Instance_map *instance_map_arg,
|
|||||||
Instance *instance;
|
Instance *instance;
|
||||||
|
|
||||||
/* we make a search here, since we don't want t store the name */
|
/* we make a search here, since we don't want t store the name */
|
||||||
if (instance= instance_map->find(name, len))
|
if ((instance= instance_map->find(name, len)))
|
||||||
{
|
{
|
||||||
instance_name= instance->options.instance_name;
|
instance_name= instance->options.instance_name;
|
||||||
}
|
}
|
||||||
@ -222,7 +222,7 @@ Show_instance_options::Show_instance_options(Instance_map *instance_map_arg,
|
|||||||
Instance *instance;
|
Instance *instance;
|
||||||
|
|
||||||
/* we make a search here, since we don't want t store the name */
|
/* we make a search here, since we don't want t store the name */
|
||||||
if (instance= instance_map->find(name, len))
|
if ((instance= instance_map->find(name, len)))
|
||||||
{
|
{
|
||||||
instance_name= instance->options.instance_name;
|
instance_name= instance->options.instance_name;
|
||||||
}
|
}
|
||||||
@ -306,7 +306,7 @@ int Show_instance_options::do_command(struct st_net *net,
|
|||||||
}
|
}
|
||||||
|
|
||||||
/* loop through the options stored in DYNAMIC_ARRAY */
|
/* loop through the options stored in DYNAMIC_ARRAY */
|
||||||
for (int i= 0; i < instance->options.options_array.elements; i++)
|
for (uint i= 0; i < instance->options.options_array.elements; i++)
|
||||||
{
|
{
|
||||||
char *tmp_option, *option_value;
|
char *tmp_option, *option_value;
|
||||||
get_dynamic(&(instance->options.options_array), (gptr) &tmp_option, i);
|
get_dynamic(&(instance->options.options_array), (gptr) &tmp_option, i);
|
||||||
@ -355,7 +355,7 @@ Start_instance::Start_instance(Instance_map *instance_map_arg,
|
|||||||
:Command(instance_map_arg)
|
:Command(instance_map_arg)
|
||||||
{
|
{
|
||||||
/* we make a search here, since we don't want t store the name */
|
/* we make a search here, since we don't want t store the name */
|
||||||
if (instance= instance_map->find(name, len))
|
if ((instance= instance_map->find(name, len)))
|
||||||
instance_name= instance->options.instance_name;
|
instance_name= instance->options.instance_name;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -388,7 +388,7 @@ Stop_instance::Stop_instance(Instance_map *instance_map_arg,
|
|||||||
:Command(instance_map_arg)
|
:Command(instance_map_arg)
|
||||||
{
|
{
|
||||||
/* we make a search here, since we don't want t store the name */
|
/* we make a search here, since we don't want t store the name */
|
||||||
if (instance= instance_map->find(name, len))
|
if ((instance= instance_map->find(name, len)))
|
||||||
instance_name= instance->options.instance_name;
|
instance_name= instance->options.instance_name;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -406,7 +406,7 @@ int Stop_instance::execute(struct st_net *net, ulong connection_id)
|
|||||||
if (instance->options.is_guarded != NULL)
|
if (instance->options.is_guarded != NULL)
|
||||||
instance_map->guardian->
|
instance_map->guardian->
|
||||||
stop_guard(instance);
|
stop_guard(instance);
|
||||||
if (err_code= instance->stop())
|
if ((err_code= instance->stop()))
|
||||||
return err_code;
|
return err_code;
|
||||||
printf("instance was stopped\n");
|
printf("instance was stopped\n");
|
||||||
net_send_ok(net, connection_id);
|
net_send_ok(net, connection_id);
|
||||||
|
@ -110,7 +110,7 @@ int Guardian_thread::start()
|
|||||||
Instance_map::Iterator iterator(instance_map);
|
Instance_map::Iterator iterator(instance_map);
|
||||||
|
|
||||||
instance_map->lock();
|
instance_map->lock();
|
||||||
while (instance= iterator.next())
|
while ((instance= iterator.next()))
|
||||||
{
|
{
|
||||||
if ((instance->options.is_guarded != NULL) && (instance->is_running()))
|
if ((instance->options.is_guarded != NULL) && (instance->is_running()))
|
||||||
if (guard(instance))
|
if (guard(instance))
|
||||||
|
@ -88,8 +88,8 @@ Instance::~Instance()
|
|||||||
|
|
||||||
bool Instance::is_running()
|
bool Instance::is_running()
|
||||||
{
|
{
|
||||||
uint port;
|
uint port= 0;
|
||||||
const char *socket;
|
const char *socket= NULL;
|
||||||
|
|
||||||
if (options.mysqld_port)
|
if (options.mysqld_port)
|
||||||
port= atoi(strchr(options.mysqld_port, '=') + 1);
|
port= atoi(strchr(options.mysqld_port, '=') + 1);
|
||||||
|
@ -203,9 +203,12 @@ int Instance_map::cleanup()
|
|||||||
while (i < hash.records)
|
while (i < hash.records)
|
||||||
{
|
{
|
||||||
instance= (Instance *) hash_element(&hash, i);
|
instance= (Instance *) hash_element(&hash, i);
|
||||||
instance->cleanup();
|
if (instance->cleanup())
|
||||||
|
return 1;
|
||||||
i++;
|
i++;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ -250,7 +253,7 @@ Instance *Instance_map::Iterator::next()
|
|||||||
{
|
{
|
||||||
if (current_instance < instance_map->hash.records)
|
if (current_instance < instance_map->hash.records)
|
||||||
return (Instance *) hash_element(&instance_map->hash, current_instance++);
|
return (Instance *) hash_element(&instance_map->hash, current_instance++);
|
||||||
else
|
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -38,7 +38,6 @@ extern void free_groups(char **groups);
|
|||||||
|
|
||||||
class Instance_map
|
class Instance_map
|
||||||
{
|
{
|
||||||
friend class Iterator;
|
|
||||||
public:
|
public:
|
||||||
/* Instance_map iterator */
|
/* Instance_map iterator */
|
||||||
class Iterator
|
class Iterator
|
||||||
@ -54,6 +53,7 @@ public:
|
|||||||
void go_to_first();
|
void go_to_first();
|
||||||
Instance *next();
|
Instance *next();
|
||||||
};
|
};
|
||||||
|
friend class Iterator;
|
||||||
public:
|
public:
|
||||||
/* returns a pointer to the instance or NULL, if there is no such instance */
|
/* returns a pointer to the instance or NULL, if there is no such instance */
|
||||||
Instance *find(const char *name, uint name_len);
|
Instance *find(const char *name, uint name_len);
|
||||||
|
Reference in New Issue
Block a user