diff options
author | unknown <monty@hundin.mysql.fi> | 2001-08-19 14:43:51 +0300 |
---|---|---|
committer | unknown <monty@hundin.mysql.fi> | 2001-08-19 14:43:51 +0300 |
commit | cfdf5fee2087dde1db4239b4d9a9f16bfb78ac05 (patch) | |
tree | e2a8b10d8dae9fee5283beb230210199e135ef74 /heap | |
parent | e3a9e7e40e63e8bed554cfbceacf29490df1a14a (diff) | |
download | mariadb-git-cfdf5fee2087dde1db4239b4d9a9f16bfb78ac05.tar.gz |
Fix of UNION code
Added heap_delete_table
Added HA_EXTRA_PREPARE_FOR_DELETE
Added and use my_dup() for faster open of tables.
Removed not working no-mix-table-type
BitKeeper/deleted/.del-=6~33f33b0a159dc5d5:
Delete: =6
heap/hp_clear.c:
Cleanup
heap/hp_close.c:
Added delayed delete
heap/hp_create.c:
Added heap_delete_table
heap/hp_delete.c:
cleanup
heap/hp_test2.c:
Added heap_delete_table
include/heap.h:
Added heap_delete_table
include/my_base.h:
Added HA_EXTRA_PREPARE_FOR_DELETE
include/my_sys.h:
Adde my_dup and set_prealloc_root
isam/extra.c:
Added HA_EXTRA_PREPARE_FOR_DELETE
myisam/mi_check.c:
use my_dup
myisam/mi_extra.c:
use my_dup
myisam/mi_open.c:
use my_dup
myisam/myisamchk.c:
use my_dup
myisam/myisamdef.h:
use my_dup
mysys/Makefile.am:
my_dup
mysys/hash.c:
Add hash_replace
mysys/mf_pack.c:
cleanup
mysys/my_alloc.c:
Add set_prealloc_root
mysys/my_fstream.c:
cleanup
mysys/my_lib.c:
cleanup
mysys/my_seek.c:
cleanup
sql/ha_heap.cc:
Uses heap_delete_table()
sql/mysqld.cc:
Fix SIGHUP usage
Remove no-mix-table-types
sql/share/czech/errmsg.txt:
new error message
sql/share/danish/errmsg.txt:
new error message
sql/share/dutch/errmsg.txt:
new error message
sql/share/english/errmsg.txt:
new error message
sql/share/estonian/errmsg.txt:
new error message
sql/share/french/errmsg.txt:
new error message
sql/share/german/errmsg.txt:
new error message
sql/share/greek/errmsg.txt:
new error message
sql/share/hungarian/errmsg.txt:
new error message
sql/share/italian/errmsg.txt:
new error message
sql/share/japanese/errmsg.txt:
new error message
sql/share/korean/errmsg.txt:
new error message
sql/share/norwegian-ny/errmsg.txt:
new error message
sql/share/norwegian/errmsg.txt:
new error message
sql/share/polish/errmsg.txt:
new error message
sql/share/portuguese/errmsg.txt:
new error message
sql/share/romanian/errmsg.txt:
new error message
sql/share/russian/errmsg.txt:
new error message
sql/share/slovak/errmsg.txt:
new error message
sql/share/spanish/errmsg.txt:
new error message
sql/share/swedish/errmsg.txt:
new error message
sql/sql_base.cc:
remove no-mix-table-type
sql/sql_parse.cc:
Fix UNION code
Diffstat (limited to 'heap')
-rw-r--r-- | heap/hp_clear.c | 2 | ||||
-rw-r--r-- | heap/hp_close.c | 5 | ||||
-rw-r--r-- | heap/hp_create.c | 38 | ||||
-rw-r--r-- | heap/hp_delete.c | 6 | ||||
-rw-r--r-- | heap/hp_test2.c | 2 |
5 files changed, 36 insertions, 17 deletions
diff --git a/heap/hp_clear.c b/heap/hp_clear.c index 702c2e09d29..dcab35acd4e 100644 --- a/heap/hp_clear.c +++ b/heap/hp_clear.c @@ -44,7 +44,7 @@ void _hp_clear(HP_SHARE *info) block->levels=0; block->last_allocated=0; } - info->records=info->deleted=info->data_length=info->index_length=0;; + info->records=info->deleted=info->data_length=info->index_length=0; info->blength=1; info->changed=0; info->del_link=0; diff --git a/heap/hp_close.c b/heap/hp_close.c index 583602e98cb..267a068350b 100644 --- a/heap/hp_close.c +++ b/heap/hp_close.c @@ -19,7 +19,7 @@ #include "heapdef.h" /* Close a database open by hp_open() */ - /* Data is not deallocated */ + /* Data is normally not deallocated */ int heap_close(HP_INFO *info) { @@ -43,8 +43,9 @@ int _hp_close(register HP_INFO *info) } #endif info->s->changed=0; - info->s->open_count--; heap_open_list=list_delete(heap_open_list,&info->open_list); + if (!--info->s->open_count && info->s->delete_on_close) + _hp_free(info->s); /* Table was deleted */ my_free((gptr) info,MYF(0)); DBUG_RETURN(error); } diff --git a/heap/hp_create.c b/heap/hp_create.c index 01c5f43adfd..da91e412180 100644 --- a/heap/hp_create.c +++ b/heap/hp_create.c @@ -21,33 +21,49 @@ #include "heapdef.h" + int heap_create(const char *name) { + reg1 HP_SHARE *share; DBUG_ENTER("heap_create"); - (void) heap_delete_all(name); + pthread_mutex_lock(&THR_LOCK_heap); + if ((share=_hp_find_named_heap(name))) + { + if (share->open_count == 0) + _hp_free(share); + } + else + { + my_errno=ENOENT; + } + pthread_mutex_unlock(&THR_LOCK_heap); DBUG_RETURN(0); } -int heap_delete_all(const char *name) +int heap_delete_table(const char *name) { - reg1 HP_SHARE *info; - int found; - DBUG_ENTER("heap_delete_all"); + int result; + reg1 HP_SHARE *share; + DBUG_ENTER("heap_delete_table"); + pthread_mutex_lock(&THR_LOCK_heap); - if ((info=_hp_find_named_heap(name))) + if ((share=_hp_find_named_heap(name))) { - if (info->open_count == 0) - _hp_free(info); - found=0; + if (share->open_count == 0) + _hp_free(share); + else + share->delete_on_close=1; + result=0; } else { - found=my_errno=ENOENT; + result=my_errno=ENOENT; } pthread_mutex_unlock(&THR_LOCK_heap); - DBUG_RETURN(found); + DBUG_RETURN(result); } + void _hp_free(HP_SHARE *share) { heap_share_list=list_delete(heap_share_list,&share->open_list); diff --git a/heap/hp_delete.c b/heap/hp_delete.c index a6e77fe5f27..921b6cf36e6 100644 --- a/heap/hp_delete.c +++ b/heap/hp_delete.c @@ -50,7 +50,8 @@ int heap_delete(HP_INFO *info, const byte *record) info->current_hash_ptr=0; DBUG_RETURN(0); err: - if( ++(share->records) == share->blength) share->blength+= share->blength; + if (++(share->records) == share->blength) + share->blength+= share->blength; DBUG_RETURN(my_errno); } @@ -66,7 +67,8 @@ int _hp_delete_key(HP_INFO *info, register HP_KEYDEF *keyinfo, DBUG_ENTER("_hp_delete_key"); blength=share->blength; - if (share->records+1 == blength) blength+= blength; + if (share->records+1 == blength) + blength+= blength; lastpos=hp_find_hash(&keyinfo->block,share->records); last_ptr=0; diff --git a/heap/hp_test2.c b/heap/hp_test2.c index e3ed7a90df5..0f7afca5a93 100644 --- a/heap/hp_test2.c +++ b/heap/hp_test2.c @@ -574,7 +574,7 @@ end: heap_clear(file); if (heap_close(file) || (file2 && heap_close(file2))) goto err; - heap_delete_all(filename2); + heap_delete_table(filename2); heap_panic(HA_PANIC_CLOSE); my_end(MY_GIVE_INFO); return(0); |