Loading client/mysqlbinlog.cc +13 −14 Original line number Diff line number Diff line Loading @@ -155,11 +155,7 @@ class Load_log_processor public: Load_log_processor() {} ~Load_log_processor() { destroy(); delete_dynamic(&file_names); } ~Load_log_processor() {} int init() { Loading Loading @@ -191,6 +187,8 @@ class Load_log_processor bzero((char *)ptr, sizeof(File_name_record)); } } delete_dynamic(&file_names); } /* Loading Loading @@ -1517,6 +1515,7 @@ int main(int argc, char** argv) cleanup(); free_defaults(defaults_argv); my_free_open_file_info(); load_processor.destroy(); /* We cannot free DBUG, it is used in global destructors after exit(). */ my_end(MY_DONT_FREE_DBUG); exit(exit_value); Loading include/my_sys.h +9 −8 Original line number Diff line number Diff line Loading @@ -322,8 +322,17 @@ struct st_my_file_info extern struct st_my_file_info *my_file_info; typedef struct st_dynamic_array { char *buffer; uint elements,max_element; uint alloc_increment; uint size_of_element; } DYNAMIC_ARRAY; typedef struct st_my_tmpdir { DYNAMIC_ARRAY full_list; char **list; uint cur, max; #ifdef THREAD Loading @@ -331,14 +340,6 @@ typedef struct st_my_tmpdir #endif } MY_TMPDIR; typedef struct st_dynamic_array { char *buffer; uint elements,max_element; uint alloc_increment; uint size_of_element; } DYNAMIC_ARRAY; typedef struct st_dynamic_string { char *str; Loading mysys/array.c +0 −4 Original line number Diff line number Diff line Loading @@ -15,10 +15,6 @@ /* Handling of arrays that can grow dynamicly. */ #if defined(WIN32) || defined(__WIN__) #undef SAFEMALLOC /* Problems with threads */ #endif #include "mysys_priv.h" #include "m_string.h" Loading mysys/mf_tempdir.c +6 −7 Original line number Diff line number Diff line Loading @@ -26,9 +26,8 @@ my_bool init_tmpdir(MY_TMPDIR *tmpdir, const char *pathlist) { char *end, *copy; char buff[FN_REFLEN]; DYNAMIC_ARRAY t_arr; pthread_mutex_init(&tmpdir->mutex, MY_MUTEX_INIT_FAST); if (my_init_dynamic_array(&t_arr, sizeof(char*), 1, 5)) if (my_init_dynamic_array(&tmpdir->full_list, sizeof(char*), 1, 5)) return TRUE; if (!pathlist || !pathlist[0]) { Loading @@ -49,14 +48,14 @@ my_bool init_tmpdir(MY_TMPDIR *tmpdir, const char *pathlist) convert_dirname(buff, pathlist, end); if (!(copy=my_strdup(buff, MYF(MY_WME)))) return TRUE; if (insert_dynamic(&t_arr, (gptr)©)) if (insert_dynamic(&tmpdir->full_list, (gptr)©)) return TRUE; pathlist=end+1; } while (*end); freeze_size(&t_arr); tmpdir->list=(char **)t_arr.buffer; tmpdir->max=t_arr.elements-1; freeze_size(&tmpdir->full_list); tmpdir->list=(char **)tmpdir->full_list.buffer; tmpdir->max=tmpdir->full_list.elements-1; tmpdir->cur=0; return FALSE; } Loading @@ -76,7 +75,7 @@ void free_tmpdir(MY_TMPDIR *tmpdir) uint i; for (i=0; i<=tmpdir->max; i++) my_free(tmpdir->list[i], MYF(0)); my_free((gptr)tmpdir->list, MYF(0)); delete_dynamic(&tmpdir->full_list); pthread_mutex_destroy(&tmpdir->mutex); } Loading
client/mysqlbinlog.cc +13 −14 Original line number Diff line number Diff line Loading @@ -155,11 +155,7 @@ class Load_log_processor public: Load_log_processor() {} ~Load_log_processor() { destroy(); delete_dynamic(&file_names); } ~Load_log_processor() {} int init() { Loading Loading @@ -191,6 +187,8 @@ class Load_log_processor bzero((char *)ptr, sizeof(File_name_record)); } } delete_dynamic(&file_names); } /* Loading Loading @@ -1517,6 +1515,7 @@ int main(int argc, char** argv) cleanup(); free_defaults(defaults_argv); my_free_open_file_info(); load_processor.destroy(); /* We cannot free DBUG, it is used in global destructors after exit(). */ my_end(MY_DONT_FREE_DBUG); exit(exit_value); Loading
include/my_sys.h +9 −8 Original line number Diff line number Diff line Loading @@ -322,8 +322,17 @@ struct st_my_file_info extern struct st_my_file_info *my_file_info; typedef struct st_dynamic_array { char *buffer; uint elements,max_element; uint alloc_increment; uint size_of_element; } DYNAMIC_ARRAY; typedef struct st_my_tmpdir { DYNAMIC_ARRAY full_list; char **list; uint cur, max; #ifdef THREAD Loading @@ -331,14 +340,6 @@ typedef struct st_my_tmpdir #endif } MY_TMPDIR; typedef struct st_dynamic_array { char *buffer; uint elements,max_element; uint alloc_increment; uint size_of_element; } DYNAMIC_ARRAY; typedef struct st_dynamic_string { char *str; Loading
mysys/array.c +0 −4 Original line number Diff line number Diff line Loading @@ -15,10 +15,6 @@ /* Handling of arrays that can grow dynamicly. */ #if defined(WIN32) || defined(__WIN__) #undef SAFEMALLOC /* Problems with threads */ #endif #include "mysys_priv.h" #include "m_string.h" Loading
mysys/mf_tempdir.c +6 −7 Original line number Diff line number Diff line Loading @@ -26,9 +26,8 @@ my_bool init_tmpdir(MY_TMPDIR *tmpdir, const char *pathlist) { char *end, *copy; char buff[FN_REFLEN]; DYNAMIC_ARRAY t_arr; pthread_mutex_init(&tmpdir->mutex, MY_MUTEX_INIT_FAST); if (my_init_dynamic_array(&t_arr, sizeof(char*), 1, 5)) if (my_init_dynamic_array(&tmpdir->full_list, sizeof(char*), 1, 5)) return TRUE; if (!pathlist || !pathlist[0]) { Loading @@ -49,14 +48,14 @@ my_bool init_tmpdir(MY_TMPDIR *tmpdir, const char *pathlist) convert_dirname(buff, pathlist, end); if (!(copy=my_strdup(buff, MYF(MY_WME)))) return TRUE; if (insert_dynamic(&t_arr, (gptr)©)) if (insert_dynamic(&tmpdir->full_list, (gptr)©)) return TRUE; pathlist=end+1; } while (*end); freeze_size(&t_arr); tmpdir->list=(char **)t_arr.buffer; tmpdir->max=t_arr.elements-1; freeze_size(&tmpdir->full_list); tmpdir->list=(char **)tmpdir->full_list.buffer; tmpdir->max=tmpdir->full_list.elements-1; tmpdir->cur=0; return FALSE; } Loading @@ -76,7 +75,7 @@ void free_tmpdir(MY_TMPDIR *tmpdir) uint i; for (i=0; i<=tmpdir->max; i++) my_free(tmpdir->list[i], MYF(0)); my_free((gptr)tmpdir->list, MYF(0)); delete_dynamic(&tmpdir->full_list); pthread_mutex_destroy(&tmpdir->mutex); }