mirror of
https://github.com/MariaDB/server.git
synced 2025-01-17 12:32:27 +01:00
cfab46f546
Fixed memory leak on shutdown (Affects the embedded version & MyODBC) client/client_priv.h: Update copyright client/completion_hash.cc: Update copyright client/completion_hash.h: Update copyright client/connect_test.c: Update copyright client/errmsg.c: Update copyright client/get_password.c: Update copyright client/insert_test.c: Update copyright client/list_test.c: Update copyright client/my_readline.h: Update copyright client/mysql.cc: Update copyright client/mysqladmin.c: Update copyright client/mysqlbinlog.cc: Update copyright client/mysqlcheck.c: Update copyright client/mysqldump.c: Update copyright client/mysqlimport.c: Update copyright client/mysqlmanager-pwgen.c: Update copyright client/mysqlmanagerc.c: Update copyright client/mysqlshow.c: Update copyright client/mysqltest.c: Update copyright client/password.c: Update copyright client/readline.cc: Update copyright client/select_test.c: Update copyright client/showdb_test.c: Update copyright client/sql_string.cc: Update copyright client/sql_string.h: Update copyright client/ssl_test.c: Update copyright client/thimble.cc: Update copyright client/thread_test.c: Update copyright div/deadlock_test.c: Update copyright extra/comp_err.c: Update copyright extra/my_print_defaults.c: Update copyright extra/perror.c: Update copyright extra/replace.c: Update copyright extra/resolve_stack_dump.c: Update copyright extra/resolveip.c: Update copyright fs/database.c: Update copyright fs/libmysqlfs.c: Update copyright fs/mysqlcorbafs.c: Update copyright fs/mysqlcorbafs.h: Update copyright fs/mysqlcorbafs_test.c: Update copyright heap/_check.c: Update copyright heap/_rectest.c: Update copyright heap/heapdef.h: Update copyright heap/hp_block.c: Update copyright heap/hp_clear.c: Update copyright heap/hp_close.c: Update copyright heap/hp_create.c: Update copyright heap/hp_delete.c: Update copyright heap/hp_extra.c: Update copyright heap/hp_hash.c: Update copyright heap/hp_info.c: Update copyright heap/hp_open.c: Update copyright heap/hp_panic.c: Update copyright heap/hp_rename.c: Update copyright heap/hp_rfirst.c: Update copyright heap/hp_rkey.c: Update copyright heap/hp_rlast.c: Update copyright heap/hp_rnext.c: Update copyright heap/hp_rprev.c: Update copyright heap/hp_rrnd.c: Update copyright heap/hp_rsame.c: Update copyright heap/hp_scan.c: Update copyright heap/hp_static.c: Update copyright heap/hp_test1.c: Update copyright heap/hp_test2.c: Update copyright heap/hp_update.c: Update copyright heap/hp_write.c: Update copyright include/config-win.h: Update copyright include/dbug.h: Update copyright include/errmsg.h: Update copyright include/ft_global.h: Update copyright include/getopt.h: Update copyright include/hash.h: Update copyright include/heap.h: Update copyright include/m_ctype.h: Update copyright include/m_string.h: Update copyright include/md5.h: Update copyright include/merge.h: Update copyright include/my_alarm.h: Update copyright include/my_base.h: Update copyright include/my_bitmap.h: Update copyright include/my_dir.h: Update copyright include/my_global.h: Update copyright include/my_list.h: Update copyright include/my_net.h: Update copyright include/my_no_pthread.h: Update copyright include/my_nosys.h: Update copyright include/my_pthread.h: Update copyright include/my_sys.h: Update copyright include/my_tree.h: Update copyright include/myisam.h: Update copyright include/myisammrg.h: Update copyright include/myisampack.h: Update copyright include/mysql.h: Update copyright include/mysql_com.h: Update copyright include/mysql_embed.h: Update copyright include/mysqld_error.h: Update copyright include/mysys_err.h: Update copyright include/nisam.h: Update copyright include/queues.h: Update copyright include/raid.h: Update copyright include/sslopt-case.h: Update copyright include/sslopt-longopts.h: Update copyright include/sslopt-usage.h: Update copyright include/sslopt-vars.h: Update copyright include/t_ctype.h: Update copyright include/thr_alarm.h: Update copyright include/thr_lock.h: Update copyright include/violite.h: Update copyright isam/_cache.c: Update copyright isam/_dbug.c: Update copyright isam/_key.c: Update copyright isam/_locking.c: Update copyright isam/_packrec.c: Update copyright isam/_page.c: Update copyright isam/_search.c: Update copyright isam/_statrec.c: Update copyright isam/changed.c: Update copyright isam/close.c: Update copyright isam/create.c: Update copyright isam/delete.c: Update copyright isam/extra.c: Update copyright isam/info.c: Update copyright isam/isamchk.c: Update copyright isam/isamdef.h: Update copyright isam/log.c: Update copyright isam/open.c: Update copyright isam/panic.c: Update copyright isam/range.c: Update copyright isam/rfirst.c: Update copyright isam/rkey.c: Update copyright isam/rlast.c: Update copyright isam/rnext.c: Update copyright isam/rprev.c: Update copyright isam/rrnd.c: Update copyright isam/rsame.c: Update copyright isam/rsamepos.c: Update copyright isam/sort.c: Update copyright isam/static.c: Update copyright isam/test1.c: Update copyright isam/test2.c: Update copyright isam/test3.c: Update copyright isam/update.c: Update copyright isam/write.c: Update copyright libmysql/conf_to_src.c: Update copyright libmysql/dll.c: Update copyright libmysql/errmsg.c: Update copyright libmysql/get_password.c: Update copyright libmysql/libmysql.c: Update copyright libmysql/manager.c: Update copyright libmysql/net.c: Update copyright libmysql/password.c: Update copyright libmysqld/lib_sql.cc: Update copyright libmysqld/lib_vio.c: Update copyright libmysqld/libmysqld.c: Update copyright merge/mrg_close.c: Update copyright merge/mrg_create.c: Update copyright merge/mrg_def.h: Update copyright merge/mrg_delete.c: Update copyright merge/mrg_extra.c: Update copyright merge/mrg_info.c: Update copyright merge/mrg_locking.c: Update copyright merge/mrg_open.c: Update copyright merge/mrg_panic.c: Update copyright merge/mrg_rrnd.c: Update copyright merge/mrg_rsame.c: Update copyright merge/mrg_static.c: Update copyright merge/mrg_update.c: Update copyright myisam/ft_boolean_search.c: Update copyright myisam/ft_dump.c: Update copyright myisam/ft_eval.h: Update copyright myisam/ft_static.c: Update copyright myisam/ft_stem.c: Update copyright myisam/ft_stopwords.c: Update copyright myisam/ft_test1.h: Update copyright myisam/mi_cache.c: Update copyright myisam/mi_changed.c: Update copyright myisam/mi_check.c: Update copyright myisam/mi_checksum.c: Update copyright myisam/mi_close.c: Update copyright myisam/mi_create.c: Update copyright myisam/mi_dbug.c: Update copyright myisam/mi_delete.c: Update copyright myisam/mi_delete_all.c: Update copyright myisam/mi_delete_table.c: Update copyright myisam/mi_dynrec.c: Update copyright myisam/mi_extra.c: Update copyright myisam/mi_info.c: Update copyright myisam/mi_key.c: Update copyright myisam/mi_locking.c: Update copyright myisam/mi_log.c: Update copyright myisam/mi_open.c: Update copyright myisam/mi_packrec.c: Update copyright myisam/mi_page.c: Update copyright myisam/mi_panic.c: Update copyright myisam/mi_range.c: Update copyright myisam/mi_rename.c: Update copyright myisam/mi_rfirst.c: Update copyright myisam/mi_rlast.c: Update copyright myisam/mi_rnext_same.c: Update copyright myisam/mi_rrnd.c: Update copyright myisam/mi_rsame.c: Update copyright myisam/mi_rsamepos.c: Update copyright myisam/mi_scan.c: Update copyright myisam/mi_search.c: Update copyright myisam/mi_static.c: Update copyright myisam/mi_statrec.c: Update copyright myisam/mi_test1.c: Update copyright myisam/mi_test2.c: Update copyright myisam/mi_test3.c: Update copyright myisam/mi_unique.c: Update copyright myisam/mi_update.c: Update copyright myisam/mi_write.c: Update copyright myisam/myisamchk.c: Update copyright myisam/myisampack.c: Update copyright myisammrg/myrg_close.c: Update copyright myisammrg/myrg_create.c: Update copyright myisammrg/myrg_def.h: Update copyright myisammrg/myrg_delete.c: Update copyright myisammrg/myrg_locking.c: Update copyright myisammrg/myrg_open.c: Update copyright myisammrg/myrg_panic.c: Update copyright myisammrg/myrg_rsame.c: Update copyright myisammrg/myrg_static.c: Update copyright myisammrg/myrg_update.c: Update copyright myisammrg/myrg_write.c: Update copyright mysql-test/r/gcc296.result: Update of benchmark results mysql-test/r/innodb.result: Update of benchmark results mysql-test/r/join_outer.result: Update of benchmark results mysql-test/r/myisam.result: Update of benchmark results mysys/array.c: Update copyright mysys/charset.c: Fix for restart of character sets mysys/checksum.c: Update copyright mysys/default.c: Update copyright mysys/errors.c: Update copyright mysys/getopt.c: Cleanup mysys/getvar.c: Update copyright mysys/hash.c: Update copyright mysys/list.c: Update copyright mysys/make-conf.c: Update copyright mysys/md5.c: Update copyright mysys/mf_brkhant.c: Update copyright mysys/mf_cache.c: Update copyright mysys/mf_casecnv.c: Update copyright mysys/mf_dirname.c: Update copyright mysys/mf_fn_ext.c: Update copyright mysys/mf_format.c: Update copyright mysys/mf_getdate.c: Update copyright mysys/mf_iocache.c: Update copyright mysys/mf_iocache2.c: Update copyright mysys/mf_keycache.c: Update copyright mysys/mf_loadpath.c: Update copyright mysys/mf_pack.c: Update copyright mysys/mf_path.c: Update copyright mysys/mf_qsort.c: Update copyright mysys/mf_qsort2.c: Update copyright mysys/mf_radix.c: Update copyright mysys/mf_same.c: Update copyright mysys/mf_sleep.c: Update copyright mysys/mf_sort.c: Update copyright mysys/mf_soundex.c: Update copyright mysys/mf_stripp.c: Update copyright mysys/mf_tempfile.c: Update copyright mysys/mf_unixpath.c: Update copyright mysys/mf_util.c: Update copyright mysys/mf_wcomp.c: Update copyright mysys/mf_wfile.c: Update copyright mysys/mulalloc.c: Update copyright mysys/my_alarm.c: Update copyright mysys/my_alloc.c: Update copyright mysys/my_append.c: Update copyright mysys/my_bit.c: Update copyright mysys/my_bitmap.c: Update copyright mysys/my_chsize.c: Update copyright mysys/my_clock.c: Update copyright mysys/my_compress.c: Update copyright mysys/my_copy.c: Update copyright mysys/my_create.c: Update copyright mysys/my_delete.c: Update copyright mysys/my_div.c: Update copyright mysys/my_dup.c: Update copyright mysys/my_error.c: Update copyright mysys/my_fopen.c: Update copyright mysys/my_fstream.c: Update copyright mysys/my_getwd.c: Update copyright mysys/my_init.c: Free 'once_alloc' memory at shutdown. mysys/my_lib.c: Update copyright mysys/my_lock.c: Update copyright mysys/my_lockmem.c: Update copyright mysys/my_lread.c: Update copyright mysys/my_lwrite.c: Update copyright mysys/my_malloc.c: Update copyright mysys/my_messnc.c: Update copyright mysys/my_mkdir.c: Update copyright mysys/my_net.c: Update copyright mysys/my_once.c: Update copyright mysys/my_open.c: Update copyright mysys/my_pread.c: Update copyright mysys/my_pthread.c: Update copyright mysys/my_quick.c: Update copyright mysys/my_read.c: Update copyright mysys/my_realloc.c: Update copyright mysys/my_redel.c: Update copyright mysys/my_rename.c: Update copyright mysys/my_seek.c: Update copyright mysys/my_static.c: Update copyright mysys/my_static.h: Update copyright mysys/my_symlink.c: Update copyright mysys/my_symlink2.c: Update copyright mysys/my_tempnam.c: Update copyright mysys/my_thr_init.c: Update copyright mysys/my_vsnprintf.c: Update copyright mysys/my_wincond.c: Update copyright mysys/my_winthread.c: Update copyright mysys/my_write.c: Update copyright mysys/mysys_priv.h: Update copyright mysys/ptr_cmp.c: Update copyright mysys/queues.c: Update copyright mysys/raid.cc: Update copyright mysys/safemalloc.c: Update copyright mysys/string.c: Update copyright mysys/test_charset.c: Update copyright mysys/test_dir.c: Update copyright mysys/test_fn.c: Update copyright mysys/testhash.c: Update copyright mysys/thr_alarm.c: Update copyright mysys/thr_lock.c: Update copyright mysys/thr_mutex.c: Update copyright mysys/thr_rwlock.c: Update copyright mysys/tree.c: Update copyright mysys/typelib.c: Update copyright pstack/debug.c: Update copyright pstack/debug.h: Update copyright pstack/demangle.h: Update copyright pstack/ieee.c: Update copyright pstack/ieee.h: Update copyright pstack/pstack.c: Update copyright readline/bind.c: Cleanup empty lines readline/complete.c: Cleanup empty lines readline/display.c: Cleanup empty lines readline/funmap.c: Cleanup empty lines readline/histexpand.c: Cleanup empty lines readline/histfile.c: Cleanup empty lines readline/history.c: Cleanup empty lines readline/history.h: Cleanup empty lines readline/input.c: Cleanup empty lines readline/kill.c: Cleanup empty lines readline/readline.c: Cleanup empty lines readline/readline.h: Cleanup empty lines readline/vi_mode.c: Cleanup empty lines sql/cache_manager.cc: Update copyright sql/cache_manager.h: Update copyright sql/convert.cc: Update copyright sql/custom_conf.h: Update copyright sql/derror.cc: Update copyright sql/field.cc: Update copyright sql/field.h: Update copyright sql/field_conv.cc: Update copyright sql/filesort.cc: Update copyright sql/frm_crypt.cc: Update copyright sql/ha_berkeley.cc: Update copyright sql/ha_heap.cc: Update copyright sql/ha_heap.h: Update copyright sql/ha_innobase.cc: Update copyright sql/ha_isam.cc: Update copyright sql/ha_isam.h: Update copyright sql/ha_isammrg.cc: Update copyright sql/ha_isammrg.h: Update copyright sql/ha_myisam.cc: Update copyright sql/handler.cc: Update copyright sql/hash_filo.cc: Update copyright sql/hash_filo.h: Update copyright sql/hostname.cc: Update copyright sql/init.cc: Update copyright sql/item.cc: Update copyright sql/item.h: Update copyright sql/item_buff.cc: Update copyright sql/item_cmpfunc.cc: Update copyright sql/item_cmpfunc.h: Update copyright sql/item_create.cc: Update copyright sql/item_create.h: Update copyright sql/item_func.cc: Update copyright sql/item_strfunc.cc: Update copyright sql/item_sum.cc: Update copyright sql/item_sum.h: Update copyright sql/item_timefunc.cc: Update copyright sql/item_timefunc.h: Update copyright sql/item_uniq.cc: Update copyright sql/item_uniq.h: Update copyright sql/key.cc: Update copyright sql/lex_symbol.h: Update copyright sql/lock.cc: Update copyright sql/log.cc: Update copyright sql/log_event.cc: Update copyright sql/log_event.h: Update copyright sql/matherr.c: Update copyright sql/mf_iocache.cc: Update copyright sql/mini_client.cc: Update copyright sql/mini_client.h: Update copyright sql/my_lock.c: Update copyright sql/mysqld.cc: Update copyright sql/net_pkg.cc: Update copyright sql/net_serv.cc: Update copyright sql/opt_sum.cc: Update copyright sql/password.c: Update copyright sql/procedure.cc: Update copyright sql/procedure.h: Update copyright sql/records.cc: Update copyright sql/repl_failsafe.cc: Update copyright sql/slave.cc: Update copyright sql/slave.h: Update copyright sql/sql_acl.cc: Update copyright sql/sql_acl.h: Update copyright sql/sql_analyse.cc: Update copyright sql/sql_analyse.h: Update copyright sql/sql_base.cc: Update copyright sql/sql_cache.cc: Update copyright sql/sql_class.cc: Update copyright sql/sql_class.h: Update copyright sql/sql_crypt.cc: Update copyright sql/sql_crypt.h: Update copyright sql/sql_db.cc: Update copyright sql/sql_delete.cc: Update copyright sql/sql_handler.cc: Update copyright sql/sql_insert.cc: Update copyright sql/sql_lex.cc: Update copyright sql/sql_lex.h: Update copyright sql/sql_list.cc: Update copyright sql/sql_list.h: Update copyright sql/sql_load.cc: Update copyright sql/sql_map.cc: Update copyright sql/sql_map.h: Update copyright sql/sql_parse.cc: Update copyright sql/sql_rename.cc: Update copyright sql/sql_repl.cc: Update copyright sql/sql_select.h: Update copyright sql/sql_string.cc: Update copyright sql/sql_string.h: Update copyright sql/sql_table.cc: Update copyright sql/sql_test.cc: Update copyright sql/sql_udf.cc: Update copyright sql/sql_udf.h: Update copyright sql/stacktrace.c: Update copyright sql/structs.h: Update copyright sql/table.cc: Update copyright sql/table.h: Update copyright sql/thr_malloc.cc: Update copyright sql/time.cc: Update copyright sql/udf_example.cc: Update copyright sql/uniques.cc: Update copyright sql/unireg.cc: Update copyright sql/unireg.h: Update copyright strings/atof.c: Update copyright strings/bchange.c: Update copyright strings/bcmp.c: Update copyright strings/bcopy-duff.c: Update copyright strings/bfill.c: Update copyright strings/bmove.c: Update copyright strings/bmove512.c: Update copyright strings/bmove_upp.c: Update copyright strings/bzero.c: Update copyright strings/conf_to_src.c: Update copyright strings/ctype-big5.c: Update copyright strings/ctype-czech.c: Update copyright strings/ctype-euc_kr.c: Update copyright strings/ctype-gb2312.c: Update copyright strings/ctype-gbk.c: Update copyright strings/ctype-latin1_de.c: Update copyright strings/ctype-sjis.c: Update copyright strings/ctype-tis620.c: Update copyright strings/ctype-ujis.c: Update copyright strings/ctype.c: Update copyright strings/do_ctype.c: Update copyright strings/int2str.c: Update copyright strings/is_prefix.c: Update copyright strings/llstr.c: Update copyright strings/longlong2str.c: Update copyright strings/memcmp.c: Update copyright strings/memcpy.c: Update copyright strings/memset.c: Update copyright strings/r_strinstr.c: Update copyright strings/str2int.c: Update copyright strings/str_test.c: Update copyright strings/strappend.c: Update copyright strings/strcat.c: Update copyright strings/strcend.c: Update copyright strings/strchr.c: Update copyright strings/strcmp.c: Update copyright strings/strcont.c: Update copyright strings/strend.c: Update copyright strings/strfill.c: Update copyright strings/strings-not-used.h: Update copyright strings/strinstr.c: Update copyright strings/strlen.c: Update copyright strings/strmake.c: Update copyright strings/strmov.c: Update copyright strings/strnlen.c: Update copyright strings/strnmov.c: Update copyright strings/strrchr.c: Update copyright strings/strstr.c: Update copyright strings/strto.c: Update copyright strings/strtol.c: Update copyright strings/strtoll.c: Update copyright strings/strtoul.c: Update copyright strings/strtoull.c: Update copyright strings/strxmov.c: Update copyright strings/strxnmov.c: Update copyright strings/t_ctype.h: Update copyright strings/udiv.c: Update copyright tools/mysqlmanager.c: Update copyright vio/test-ssl.c: Update copyright vio/test-sslclient.c: Update copyright vio/test-sslserver.c: Update copyright vio/vio.c: Update copyright vio/viosocket.c: Update copyright vio/viossl.c: Update copyright vio/viosslfactories.c: Update copyright vio/viotest-ssl.c: Update copyright
551 lines
14 KiB
C
551 lines
14 KiB
C
/* Copyright (C) 2000 MySQL AB
|
|
|
|
This program is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation; either version 2 of the License, or
|
|
(at your option) any later version.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
|
|
|
|
/*
|
|
Code for handling red-black (balanced) binary trees.
|
|
key in tree is allocated accrding to following:
|
|
1) If free_element function is given to init_tree or size < 0 then tree
|
|
will not allocate keys and only a pointer to each key is saved in tree.
|
|
key_sizes must be 0 to init and search.
|
|
compare and search functions uses and returns key-pointer.
|
|
2) if key_size is given to init_tree then each node will continue the
|
|
key and calls to insert_key may increase length of key.
|
|
if key_size > sizeof(pointer) and key_size is a multiple of 8 (double
|
|
allign) then key will be put on a 8 alligned adress. Else
|
|
the key will be on adress (element+1). This is transparent for user
|
|
compare and search functions uses a pointer to given key-argument.
|
|
3) If init_tree - keysize is 0 then key_size must be given to tree_insert
|
|
and tree_insert will alloc space for key.
|
|
compare and search functions uses a pointer to given key-argument.
|
|
|
|
The actual key in TREE_ELEMENT is saved as a pointer or after the
|
|
TREE_ELEMENT struct.
|
|
If one uses only pointers in tree one can use tree_set_pointer() to
|
|
change address of data.
|
|
Copyright Monty Program KB.
|
|
By monty.
|
|
*/
|
|
|
|
#include "mysys_priv.h"
|
|
#include <m_string.h>
|
|
#include <my_tree.h>
|
|
|
|
#define BLACK 1
|
|
#define RED 0
|
|
#define DEFAULT_ALLOC_SIZE (8192-MALLOC_OVERHEAD)
|
|
|
|
static void delete_tree_element(TREE *,TREE_ELEMENT *);
|
|
static int tree_walk_left_root_right(TREE *,TREE_ELEMENT *,
|
|
tree_walk_action,void *);
|
|
static int tree_walk_right_root_left(TREE *,TREE_ELEMENT *,
|
|
tree_walk_action,void *);
|
|
static void left_rotate(TREE_ELEMENT **parent,TREE_ELEMENT *leaf);
|
|
static void right_rotate(TREE_ELEMENT **parent, TREE_ELEMENT *leaf);
|
|
static void rb_insert(TREE *tree,TREE_ELEMENT ***parent,
|
|
TREE_ELEMENT *leaf);
|
|
static void rb_delete_fixup(TREE *tree,TREE_ELEMENT ***parent);
|
|
|
|
|
|
/* The actuall code for handling binary trees */
|
|
|
|
#ifndef DBUG_OFF
|
|
static int test_rb_tree(TREE_ELEMENT *element);
|
|
#endif
|
|
|
|
void init_tree(TREE *tree, uint default_alloc_size, uint memory_limit,
|
|
int size, qsort_cmp2 compare, my_bool with_delete,
|
|
tree_element_free free_element, void *custom_arg)
|
|
{
|
|
DBUG_ENTER("init_tree");
|
|
DBUG_PRINT("enter",("tree: %lx size: %d",tree,size));
|
|
|
|
if (!default_alloc_size)
|
|
default_alloc_size= DEFAULT_ALLOC_SIZE;
|
|
bzero((gptr) &tree->null_element,sizeof(tree->null_element));
|
|
tree->root= &tree->null_element;
|
|
tree->compare=compare;
|
|
tree->size_of_element=size > 0 ? (uint) size : 0;
|
|
tree->memory_limit=memory_limit;
|
|
tree->free=free_element;
|
|
tree->allocated=0;
|
|
tree->elements_in_tree=0;
|
|
tree->custom_arg = custom_arg;
|
|
tree->null_element.colour=BLACK;
|
|
tree->null_element.left=tree->null_element.right=0;
|
|
if (!free_element && size >= 0 &&
|
|
((uint) size <= sizeof(void*) || ((uint) size & (sizeof(void*)-1))))
|
|
{
|
|
tree->offset_to_key=sizeof(TREE_ELEMENT); /* Put key after element */
|
|
/* Fix allocation size so that we don't lose any memory */
|
|
default_alloc_size/=(sizeof(TREE_ELEMENT)+size);
|
|
if (!default_alloc_size)
|
|
default_alloc_size=1;
|
|
default_alloc_size*=(sizeof(TREE_ELEMENT)+size);
|
|
}
|
|
else
|
|
{
|
|
tree->offset_to_key=0; /* use key through pointer */
|
|
tree->size_of_element+=sizeof(void*);
|
|
}
|
|
if (!(tree->with_delete=with_delete))
|
|
{
|
|
init_alloc_root(&tree->mem_root, default_alloc_size,0);
|
|
tree->mem_root.min_malloc=(sizeof(TREE_ELEMENT)+tree->size_of_element);
|
|
}
|
|
DBUG_VOID_RETURN;
|
|
}
|
|
|
|
static void free_tree(TREE *tree, myf free_flags)
|
|
{
|
|
DBUG_ENTER("free_tree");
|
|
DBUG_PRINT("enter",("tree: %lx",tree));
|
|
|
|
if (tree->root) /* If initialized */
|
|
{
|
|
if (tree->with_delete)
|
|
delete_tree_element(tree,tree->root);
|
|
else
|
|
{
|
|
if (tree->free)
|
|
{
|
|
if (tree->memory_limit)
|
|
(*tree->free)(NULL, free_init, tree->custom_arg);
|
|
delete_tree_element(tree,tree->root);
|
|
if (tree->memory_limit)
|
|
(*tree->free)(NULL, free_end, tree->custom_arg);
|
|
}
|
|
free_root(&tree->mem_root, free_flags);
|
|
}
|
|
}
|
|
tree->root= &tree->null_element;
|
|
tree->elements_in_tree=0;
|
|
tree->allocated=0;
|
|
|
|
DBUG_VOID_RETURN;
|
|
}
|
|
|
|
void delete_tree(TREE* tree)
|
|
{
|
|
free_tree(tree, MYF(0)); /* my_free() mem_root if applicable */
|
|
}
|
|
|
|
void reset_tree(TREE* tree)
|
|
{
|
|
free_tree(tree, MYF(MY_MARK_BLOCKS_FREE));
|
|
/* do not my_free() mem_root if applicable, just mark blocks as free */
|
|
}
|
|
|
|
|
|
static void delete_tree_element(TREE *tree, TREE_ELEMENT *element)
|
|
{
|
|
if (element != &tree->null_element)
|
|
{
|
|
delete_tree_element(tree,element->left);
|
|
if (tree->free)
|
|
(*tree->free)(ELEMENT_KEY(tree,element), free_free, tree->custom_arg);
|
|
delete_tree_element(tree,element->right);
|
|
if (tree->with_delete)
|
|
my_free((char*) element,MYF(0));
|
|
}
|
|
}
|
|
|
|
/* Code for insert, search and delete of elements */
|
|
/* parent[0] = & parent[-1][0]->left ||
|
|
parent[0] = & parent[-1][0]->right */
|
|
|
|
|
|
TREE_ELEMENT *tree_insert(TREE *tree, void *key, uint key_size)
|
|
{
|
|
int cmp;
|
|
TREE_ELEMENT *element,***parent;
|
|
|
|
parent= tree->parents;
|
|
*parent = &tree->root; element= tree->root;
|
|
for (;;)
|
|
{
|
|
if (element == &tree->null_element ||
|
|
(cmp=(*tree->compare)(tree->custom_arg,
|
|
ELEMENT_KEY(tree,element),key)) == 0)
|
|
break;
|
|
if (cmp < 0)
|
|
{
|
|
*++parent= &element->right; element= element->right;
|
|
}
|
|
else
|
|
{
|
|
*++parent = &element->left; element= element->left;
|
|
}
|
|
}
|
|
if (element == &tree->null_element)
|
|
{
|
|
uint alloc_size=sizeof(TREE_ELEMENT)+key_size+tree->size_of_element;
|
|
tree->allocated+=alloc_size;
|
|
|
|
if (tree->memory_limit && tree->elements_in_tree
|
|
&& tree->allocated > tree->memory_limit)
|
|
{
|
|
reset_tree(tree);
|
|
return tree_insert(tree, key, key_size);
|
|
}
|
|
|
|
key_size+=tree->size_of_element;
|
|
if (tree->with_delete)
|
|
element=(TREE_ELEMENT *) my_malloc(alloc_size, MYF(MY_WME));
|
|
else
|
|
element=(TREE_ELEMENT *)
|
|
alloc_root(&tree->mem_root,alloc_size);
|
|
if (!element)
|
|
return(NULL);
|
|
**parent=element;
|
|
element->left=element->right= &tree->null_element;
|
|
if (!tree->offset_to_key)
|
|
{
|
|
if (key_size == sizeof(void*)) /* no length, save pointer */
|
|
*((void**) (element+1))=key;
|
|
else
|
|
{
|
|
*((void**) (element+1))= (void*) ((void **) (element+1)+1);
|
|
memcpy((byte*) *((void **) (element+1)),key,
|
|
(size_t) (key_size-sizeof(void*)));
|
|
}
|
|
}
|
|
else
|
|
memcpy((byte*) element+tree->offset_to_key,key,(size_t) key_size);
|
|
element->count=1; /* May give warning in purify */
|
|
tree->elements_in_tree++;
|
|
rb_insert(tree,parent,element); /* rebalance tree */
|
|
}
|
|
else
|
|
element->count++;
|
|
DBUG_EXECUTE("check_tree", test_rb_tree(tree->root););
|
|
return element;
|
|
}
|
|
|
|
|
|
int tree_delete(TREE *tree, void *key)
|
|
{
|
|
int cmp,remove_colour;
|
|
TREE_ELEMENT *element,***parent, ***org_parent, *nod;
|
|
if (!tree->with_delete)
|
|
return 1; /* not allowed */
|
|
|
|
parent= tree->parents;
|
|
*parent= &tree->root; element= tree->root;
|
|
for (;;)
|
|
{
|
|
if (element == &tree->null_element)
|
|
return 1; /* Was not in tree */
|
|
if ((cmp=(*tree->compare)(tree->custom_arg,
|
|
ELEMENT_KEY(tree,element),key)) == 0)
|
|
break;
|
|
if (cmp < 0)
|
|
{
|
|
*++parent= &element->right; element= element->right;
|
|
}
|
|
else
|
|
{
|
|
*++parent = &element->left; element= element->left;
|
|
}
|
|
}
|
|
if (element->left == &tree->null_element)
|
|
{
|
|
(**parent)=element->right;
|
|
remove_colour= element->colour;
|
|
}
|
|
else if (element->right == &tree->null_element)
|
|
{
|
|
(**parent)=element->left;
|
|
remove_colour= element->colour;
|
|
}
|
|
else
|
|
{
|
|
org_parent= parent;
|
|
*++parent= &element->right; nod= element->right;
|
|
while (nod->left != &tree->null_element)
|
|
{
|
|
*++parent= &nod->left; nod= nod->left;
|
|
}
|
|
(**parent)=nod->right; /* unlink nod from tree */
|
|
remove_colour= nod->colour;
|
|
org_parent[0][0]=nod; /* put y in place of element */
|
|
org_parent[1]= &nod->right;
|
|
nod->left=element->left;
|
|
nod->right=element->right;
|
|
nod->colour=element->colour;
|
|
}
|
|
if (remove_colour == BLACK)
|
|
rb_delete_fixup(tree,parent);
|
|
if (tree->free)
|
|
(*tree->free)(ELEMENT_KEY(tree,element), free_free, tree->custom_arg);
|
|
my_free((gptr) element,MYF(0));
|
|
tree->elements_in_tree--;
|
|
return 0;
|
|
}
|
|
|
|
|
|
void *tree_search(TREE *tree, void *key)
|
|
{
|
|
int cmp;
|
|
TREE_ELEMENT *element=tree->root;
|
|
|
|
for (;;)
|
|
{
|
|
if (element == &tree->null_element)
|
|
return (void*) 0;
|
|
if ((cmp=(*tree->compare)(tree->custom_arg,
|
|
ELEMENT_KEY(tree,element),key)) == 0)
|
|
return ELEMENT_KEY(tree,element);
|
|
if (cmp < 0)
|
|
element=element->right;
|
|
else
|
|
element=element->left;
|
|
}
|
|
}
|
|
|
|
|
|
int tree_walk(TREE *tree, tree_walk_action action, void *argument, TREE_WALK visit)
|
|
{
|
|
switch (visit) {
|
|
case left_root_right:
|
|
return tree_walk_left_root_right(tree,tree->root,action,argument);
|
|
case right_root_left:
|
|
return tree_walk_right_root_left(tree,tree->root,action,argument);
|
|
}
|
|
return 0; /* Keep gcc happy */
|
|
}
|
|
|
|
static int tree_walk_left_root_right(TREE *tree, TREE_ELEMENT *element, tree_walk_action action, void *argument)
|
|
{
|
|
int error;
|
|
if (element->left) /* Not null_element */
|
|
{
|
|
if ((error=tree_walk_left_root_right(tree,element->left,action,
|
|
argument)) == 0 &&
|
|
(error=(*action)(ELEMENT_KEY(tree,element),
|
|
(element_count) element->count,
|
|
argument)) == 0)
|
|
error=tree_walk_left_root_right(tree,element->right,action,argument);
|
|
return error;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
static int tree_walk_right_root_left(TREE *tree, TREE_ELEMENT *element, tree_walk_action action, void *argument)
|
|
{
|
|
int error;
|
|
if (element->right) /* Not null_element */
|
|
{
|
|
if ((error=tree_walk_right_root_left(tree,element->right,action,
|
|
argument)) == 0 &&
|
|
(error=(*action)(ELEMENT_KEY(tree,element),
|
|
(element_count) element->count,
|
|
argument)) == 0)
|
|
error=tree_walk_right_root_left(tree,element->left,action,argument);
|
|
return error;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
|
|
/* Functions to fix up the tree after insert and delete */
|
|
|
|
static void left_rotate(TREE_ELEMENT **parent, TREE_ELEMENT *leaf)
|
|
{
|
|
TREE_ELEMENT *y;
|
|
|
|
y=leaf->right;
|
|
leaf->right=y->left;
|
|
parent[0]=y;
|
|
y->left=leaf;
|
|
}
|
|
|
|
static void right_rotate(TREE_ELEMENT **parent, TREE_ELEMENT *leaf)
|
|
{
|
|
TREE_ELEMENT *x;
|
|
|
|
x=leaf->left;
|
|
leaf->left=x->right;
|
|
parent[0]=x;
|
|
x->right=leaf;
|
|
}
|
|
|
|
static void rb_insert(TREE *tree, TREE_ELEMENT ***parent, TREE_ELEMENT *leaf)
|
|
{
|
|
TREE_ELEMENT *y,*par,*par2;
|
|
|
|
leaf->colour=RED;
|
|
while (leaf != tree->root && (par=parent[-1][0])->colour == RED)
|
|
{
|
|
if (par == (par2=parent[-2][0])->left)
|
|
{
|
|
y= par2->right;
|
|
if (y->colour == RED)
|
|
{
|
|
par->colour=BLACK;
|
|
y->colour=BLACK;
|
|
leaf=par2;
|
|
parent-=2;
|
|
leaf->colour=RED; /* And the loop continues */
|
|
}
|
|
else
|
|
{
|
|
if (leaf == par->right)
|
|
{
|
|
left_rotate(parent[-1],par);
|
|
par=leaf; /* leaf is now parent to old leaf */
|
|
}
|
|
par->colour=BLACK;
|
|
par2->colour=RED;
|
|
right_rotate(parent[-2],par2);
|
|
break;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
y= par2->left;
|
|
if (y->colour == RED)
|
|
{
|
|
par->colour=BLACK;
|
|
y->colour=BLACK;
|
|
leaf=par2;
|
|
parent-=2;
|
|
leaf->colour=RED; /* And the loop continues */
|
|
}
|
|
else
|
|
{
|
|
if (leaf == par->left)
|
|
{
|
|
right_rotate(parent[-1],par);
|
|
par=leaf;
|
|
}
|
|
par->colour=BLACK;
|
|
par2->colour=RED;
|
|
left_rotate(parent[-2],par2);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
tree->root->colour=BLACK;
|
|
}
|
|
|
|
static void rb_delete_fixup(TREE *tree, TREE_ELEMENT ***parent)
|
|
{
|
|
TREE_ELEMENT *x,*w,*par;
|
|
|
|
x= **parent;
|
|
while (x != tree->root && x->colour == BLACK)
|
|
{
|
|
if (x == (par=parent[-1][0])->left)
|
|
{
|
|
w=par->right;
|
|
if (w->colour == RED)
|
|
{
|
|
w->colour=BLACK;
|
|
par->colour=RED;
|
|
left_rotate(parent[-1],par);
|
|
parent[0]= &w->left;
|
|
*++parent= &par->left;
|
|
w=par->right;
|
|
}
|
|
if (w->left->colour == BLACK && w->right->colour == BLACK)
|
|
{
|
|
w->colour=RED;
|
|
x=par;
|
|
parent--;
|
|
}
|
|
else
|
|
{
|
|
if (w->right->colour == BLACK)
|
|
{
|
|
w->left->colour=BLACK;
|
|
w->colour=RED;
|
|
right_rotate(&par->right,w);
|
|
w=par->right;
|
|
}
|
|
w->colour=par->colour;
|
|
par->colour=BLACK;
|
|
w->right->colour=BLACK;
|
|
left_rotate(parent[-1],par);
|
|
x=tree->root;
|
|
break;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
w=par->left;
|
|
if (w->colour == RED)
|
|
{
|
|
w->colour=BLACK;
|
|
par->colour=RED;
|
|
right_rotate(parent[-1],par);
|
|
parent[0]= &w->right;
|
|
*++parent= &par->right;
|
|
w=par->left;
|
|
}
|
|
if (w->right->colour == BLACK && w->left->colour == BLACK)
|
|
{
|
|
w->colour=RED;
|
|
x=par;
|
|
parent--;
|
|
}
|
|
else
|
|
{
|
|
if (w->left->colour == BLACK)
|
|
{
|
|
w->right->colour=BLACK;
|
|
w->colour=RED;
|
|
left_rotate(&par->left,w);
|
|
w=par->left;
|
|
}
|
|
w->colour=par->colour;
|
|
par->colour=BLACK;
|
|
w->left->colour=BLACK;
|
|
right_rotate(parent[-1],par);
|
|
x=tree->root;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
x->colour=BLACK;
|
|
}
|
|
|
|
#ifndef DBUG_OFF
|
|
|
|
/* Test that the proporties for a red-black tree holds */
|
|
|
|
static int test_rb_tree(TREE_ELEMENT *element)
|
|
{
|
|
int count_l,count_r;
|
|
|
|
if (!element->left)
|
|
return 0; /* Found end of tree */
|
|
if (element->colour == RED &&
|
|
(element->left->colour == RED || element->right->colour == RED))
|
|
{
|
|
printf("Wrong tree: Found two red in a row\n");
|
|
return -1;
|
|
}
|
|
count_l=test_rb_tree(element->left);
|
|
count_r=test_rb_tree(element->right);
|
|
if (count_l >= 0 && count_r >= 0)
|
|
{
|
|
if (count_l == count_r)
|
|
return count_l+(element->colour == BLACK);
|
|
printf("Wrong tree: Incorrect black-count: %d - %d\n",count_l,count_r);
|
|
}
|
|
return -1;
|
|
}
|
|
#endif
|