1berry/MariaDB-server
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

automerge

Browse Source
This commit is contained in:
Sergey Glukhov 2008-10-02 16:22:24 +05:00
commit aff5670aca
3 changed files with 171 additions and 94 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

88
include/hash.h
View File

@ -21,6 +21,40 @@
extern "C" { extern "C" {
#endif #endif
/*
There was a problem on MacOSX with a shared object ha_example.so.
It used hash_search(). During build of ha_example.so no libmysys
was specified. Since MacOSX had a hash_search() in the system
library, it built the shared object so that the dynamic linker
linked hash_search() to the system library, which caused a crash
when called. To come around this, we renamed hash_search() to
my_hash_search(), as we did long ago with hash_insert() and
hash_reset(). However, this time we made the move complete with
all names. To keep compatibility, we redefine the old names.
Since every C and C++ file, that uses HASH, needs to include
this file, the change is complete. Both names could be used
in the code, but the my_* versions are recommended now.
*/
#define hash_get_key my_hash_get_key
#define hash_free_key my_hash_free_key
#define hash_init my_hash_init
#define hash_init2 my_hash_init2
#define _hash_init _my_hash_init
#define hash_free my_hash_free
#define hash_reset my_hash_reset
#define hash_element my_hash_element
#define hash_search my_hash_search
#define hash_first my_hash_first
#define hash_next my_hash_next
#define hash_insert my_hash_insert
#define hash_delete my_hash_delete
#define hash_update my_hash_update
#define hash_replace my_hash_replace
#define hash_check my_hash_check
#define hash_clear my_hash_clear
#define hash_inited my_hash_inited
#define hash_init_opt my_hash_init_opt
/* /*
Overhead to store an element in hash Overhead to store an element in hash
Can be used to approximate memory consumption for a hash Can be used to approximate memory consumption for a hash
@ -30,8 +64,8 @@ extern "C" {
/* flags for hash_init */ /* flags for hash_init */
#define HASH_UNIQUE 1 /* hash_insert fails on duplicate key */ #define HASH_UNIQUE 1 /* hash_insert fails on duplicate key */
typedef uchar *(*hash_get_key)(const uchar *,size_t*,my_bool); typedef uchar *(*my_hash_get_key)(const uchar *,size_t*,my_bool);
typedef void (*hash_free_key)(void *); typedef void (*my_hash_free_key)(void *);
typedef struct st_hash { typedef struct st_hash {
size_t key_offset,key_length; /* Length of key if const length */ size_t key_offset,key_length; /* Length of key if const length */
@ -39,7 +73,7 @@ typedef struct st_hash {
ulong records; ulong records;
uint flags; uint flags;
DYNAMIC_ARRAY array; /* Place for hash_keys */ DYNAMIC_ARRAY array; /* Place for hash_keys */
hash_get_key get_key; my_hash_get_key get_key;
void (*free)(void *); void (*free)(void *);
CHARSET_INFO *charset; CHARSET_INFO *charset;
} HASH; } HASH;
@ -47,30 +81,34 @@ typedef struct st_hash {
/* A search iterator state */ /* A search iterator state */
typedef uint HASH_SEARCH_STATE; typedef uint HASH_SEARCH_STATE;
#define hash_init(A,B,C,D,E,F,G,H) _hash_init(A,0,B,C,D,E,F,G,H CALLER_INFO) #define my_hash_init(A,B,C,D,E,F,G,H) \
#define hash_init2(A,B,C,D,E,F,G,H,I) _hash_init(A,B,C,D,E,F,G,H,I CALLER_INFO) _my_hash_init(A,0,B,C,D,E,F,G,H CALLER_INFO)
my_bool _hash_init(HASH *hash, uint growth_size,CHARSET_INFO *charset, #define my_hash_init2(A,B,C,D,E,F,G,H,I) \
ulong default_array_elements, size_t key_offset, _my_hash_init(A,B,C,D,E,F,G,H,I CALLER_INFO)
size_t key_length, hash_get_key get_key, my_bool _my_hash_init(HASH *hash, uint growth_size, CHARSET_INFO *charset,
void (*free_element)(void*), uint flags CALLER_INFO_PROTO); ulong default_array_elements, size_t key_offset,
void hash_free(HASH *tree); size_t key_length, my_hash_get_key get_key,
void (*free_element)(void*),
uint flags CALLER_INFO_PROTO);
void my_hash_free(HASH *tree);
void my_hash_reset(HASH *hash); void my_hash_reset(HASH *hash);
uchar *hash_element(HASH *hash,ulong idx); uchar *my_hash_element(HASH *hash, ulong idx);
uchar *hash_search(const HASH *info, const uchar *key, size_t length); uchar *my_hash_search(const HASH *info, const uchar *key, size_t length);
uchar *hash_first(const HASH *info, const uchar *key, size_t length, uchar *my_hash_first(const HASH *info, const uchar *key, size_t length,
HASH_SEARCH_STATE *state); HASH_SEARCH_STATE *state);
uchar *hash_next(const HASH *info, const uchar *key, size_t length, uchar *my_hash_next(const HASH *info, const uchar *key, size_t length,
HASH_SEARCH_STATE *state); HASH_SEARCH_STATE *state);
my_bool my_hash_insert(HASH *info,const uchar *data); my_bool my_hash_insert(HASH *info, const uchar *data);
my_bool hash_delete(HASH *hash,uchar *record); my_bool my_hash_delete(HASH *hash, uchar *record);
my_bool hash_update(HASH *hash,uchar *record,uchar *old_key,size_t old_key_length); my_bool my_hash_update(HASH *hash, uchar *record, uchar *old_key,
void hash_replace(HASH *hash, HASH_SEARCH_STATE *state, uchar *new_row); size_t old_key_length);
my_bool hash_check(HASH *hash); /* Only in debug library */ void my_hash_replace(HASH *hash, HASH_SEARCH_STATE *state, uchar *new_row);
my_bool my_hash_check(HASH *hash); /* Only in debug library */
#define hash_clear(H) bzero((char*) (H),sizeof(*(H))) #define my_hash_clear(H) bzero((char*) (H), sizeof(*(H)))
#define hash_inited(H) ((H)->array.buffer != 0) #define my_hash_inited(H) ((H)->array.buffer != 0)
#define hash_init_opt(A,B,C,D,E,F,G,H) \ #define my_hash_init_opt(A,B,C,D,E,F,G,H) \
(!hash_inited(A) && _hash_init(A,0,B,C,D,E,F,G, H CALLER_INFO)) (!my_hash_inited(A) && _my_hash_init(A,0,B,C,D,E,F,G, H CALLER_INFO))
#ifdef __cplusplus #ifdef __cplusplus
} }

138
mysys/hash.c
View File

@ -33,7 +33,7 @@ typedef struct st_hash_info {
uchar *data; /* data for current entry */ uchar *data; /* data for current entry */
} HASH_LINK; } HASH_LINK;
static uint hash_mask(uint hashnr,uint buffmax,uint maxlength); static uint my_hash_mask(uint hashnr, uint buffmax, uint maxlength);
static void movelink(HASH_LINK *array,uint pos,uint next_link,uint newlink); static void movelink(HASH_LINK *array,uint pos,uint next_link,uint newlink);
static int hashcmp(const HASH *hash, HASH_LINK *pos, const uchar *key, static int hashcmp(const HASH *hash, HASH_LINK *pos, const uchar *key,
size_t length); size_t length);
@ -46,19 +46,19 @@ static uint calc_hash(const HASH *hash, const uchar *key, size_t length)
} }
my_bool my_bool
_hash_init(HASH *hash,uint growth_size, CHARSET_INFO *charset, _my_hash_init(HASH *hash, uint growth_size, CHARSET_INFO *charset,
ulong size, size_t key_offset, size_t key_length, ulong size, size_t key_offset, size_t key_length,
hash_get_key get_key, my_hash_get_key get_key,
void (*free_element)(void*),uint flags CALLER_INFO_PROTO) void (*free_element)(void*), uint flags CALLER_INFO_PROTO)
{ {
DBUG_ENTER("hash_init"); DBUG_ENTER("my_hash_init");
DBUG_PRINT("enter",("hash: 0x%lx size: %u", (long) hash, (uint) size)); DBUG_PRINT("enter",("hash: 0x%lx size: %u", (long) hash, (uint) size));
hash->records=0; hash->records=0;
if (my_init_dynamic_array_ci(&hash->array, sizeof(HASH_LINK), size, if (my_init_dynamic_array_ci(&hash->array, sizeof(HASH_LINK), size,
growth_size)) growth_size))
{ {
hash->free=0; /* Allow call to hash_free */ hash->free=0; /* Allow call to my_hash_free */
DBUG_RETURN(1); DBUG_RETURN(1);
} }
hash->key_offset=key_offset; hash->key_offset=key_offset;
@ -76,14 +76,14 @@ _hash_init(HASH *hash,uint growth_size, CHARSET_INFO *charset,
Call hash->free on all elements in hash. Call hash->free on all elements in hash.
SYNOPSIS SYNOPSIS
hash_free_elements() my_hash_free_elements()
hash hash table hash hash table
NOTES: NOTES:
Sets records to 0 Sets records to 0
*/ */
static inline void hash_free_elements(HASH *hash) static inline void my_hash_free_elements(HASH *hash)
{ {
if (hash->free) if (hash->free)
{ {
@ -100,18 +100,18 @@ static inline void hash_free_elements(HASH *hash)
Free memory used by hash. Free memory used by hash.
SYNOPSIS SYNOPSIS
hash_free() my_hash_free()
hash the hash to delete elements of hash the hash to delete elements of
NOTES: Hash can't be reused without calling hash_init again. NOTES: Hash can't be reused without calling my_hash_init again.
*/ */
void hash_free(HASH *hash) void my_hash_free(HASH *hash)
{ {
DBUG_ENTER("hash_free"); DBUG_ENTER("my_hash_free");
DBUG_PRINT("enter",("hash: 0x%lx", (long) hash)); DBUG_PRINT("enter",("hash: 0x%lx", (long) hash));
hash_free_elements(hash); my_hash_free_elements(hash);
hash->free= 0; hash->free= 0;
delete_dynamic(&hash->array); delete_dynamic(&hash->array);
DBUG_VOID_RETURN; DBUG_VOID_RETURN;
@ -131,7 +131,7 @@ void my_hash_reset(HASH *hash)
DBUG_ENTER("my_hash_reset"); DBUG_ENTER("my_hash_reset");
DBUG_PRINT("enter",("hash: 0x%lxd", (long) hash)); DBUG_PRINT("enter",("hash: 0x%lxd", (long) hash));
hash_free_elements(hash); my_hash_free_elements(hash);
reset_dynamic(&hash->array); reset_dynamic(&hash->array);
/* Set row pointers so that the hash can be reused at once */ /* Set row pointers so that the hash can be reused at once */
hash->blength= 1; hash->blength= 1;
@ -146,8 +146,8 @@ void my_hash_reset(HASH *hash)
*/ */
static inline char* static inline char*
hash_key(const HASH *hash, const uchar *record, size_t *length, my_hash_key(const HASH *hash, const uchar *record, size_t *length,
my_bool first) my_bool first)
{ {
if (hash->get_key) if (hash->get_key)
return (char*) (*hash->get_key)(record,length,first); return (char*) (*hash->get_key)(record,length,first);
@ -157,18 +157,18 @@ hash_key(const HASH *hash, const uchar *record, size_t *length,
/* Calculate pos according to keys */ /* Calculate pos according to keys */
static uint hash_mask(uint hashnr,uint buffmax,uint maxlength) static uint my_hash_mask(uint hashnr, uint buffmax, uint maxlength)
{ {
if ((hashnr & (buffmax-1)) < maxlength) return (hashnr & (buffmax-1)); if ((hashnr & (buffmax-1)) < maxlength) return (hashnr & (buffmax-1));
return (hashnr & ((buffmax >> 1) -1)); return (hashnr & ((buffmax >> 1) -1));
} }
static uint hash_rec_mask(const HASH *hash, HASH_LINK *pos, static uint my_hash_rec_mask(const HASH *hash, HASH_LINK *pos,
uint buffmax, uint maxlength) uint buffmax, uint maxlength)
{ {
size_t length; size_t length;
uchar *key= (uchar*) hash_key(hash,pos->data,&length,0); uchar *key= (uchar*) my_hash_key(hash, pos->data, &length, 0);
return hash_mask(calc_hash(hash,key,length),buffmax,maxlength); return my_hash_mask(calc_hash(hash, key, length), buffmax, maxlength);
} }
@ -181,15 +181,15 @@ inline
unsigned int rec_hashnr(HASH *hash,const uchar *record) unsigned int rec_hashnr(HASH *hash,const uchar *record)
{ {
size_t length; size_t length;
uchar *key= (uchar*) hash_key(hash,record,&length,0); uchar *key= (uchar*) my_hash_key(hash, record, &length, 0);
return calc_hash(hash,key,length); return calc_hash(hash,key,length);
} }
uchar* hash_search(const HASH *hash, const uchar *key, size_t length) uchar* my_hash_search(const HASH *hash, const uchar *key, size_t length)
{ {
HASH_SEARCH_STATE state; HASH_SEARCH_STATE state;
return hash_first(hash, key, length, &state); return my_hash_first(hash, key, length, &state);
} }
/* /*
@ -199,18 +199,18 @@ uchar* hash_search(const HASH *hash, const uchar *key, size_t length)
Assigns the number of the found record to HASH_SEARCH_STATE state Assigns the number of the found record to HASH_SEARCH_STATE state
*/ */
uchar* hash_first(const HASH *hash, const uchar *key, size_t length, uchar* my_hash_first(const HASH *hash, const uchar *key, size_t length,
HASH_SEARCH_STATE *current_record) HASH_SEARCH_STATE *current_record)
{ {
HASH_LINK *pos; HASH_LINK *pos;
uint flag,idx; uint flag,idx;
DBUG_ENTER("hash_first"); DBUG_ENTER("my_hash_first");
flag=1; flag=1;
if (hash->records) if (hash->records)
{ {
idx=hash_mask(calc_hash(hash,key,length ? length : hash->key_length), idx= my_hash_mask(calc_hash(hash, key, length ? length : hash->key_length),
hash->blength,hash->records); hash->blength, hash->records);
do do
{ {
pos= dynamic_element(&hash->array,idx,HASH_LINK*); pos= dynamic_element(&hash->array,idx,HASH_LINK*);
@ -223,7 +223,7 @@ uchar* hash_first(const HASH *hash, const uchar *key, size_t length,
if (flag) if (flag)
{ {
flag=0; /* Reset flag */ flag=0; /* Reset flag */
if (hash_rec_mask(hash,pos,hash->blength,hash->records) != idx) if (my_hash_rec_mask(hash, pos, hash->blength, hash->records) != idx)
break; /* Wrong link */ break; /* Wrong link */
} }
} }
@ -234,10 +234,10 @@ uchar* hash_first(const HASH *hash, const uchar *key, size_t length,
} }
/* Get next record with identical key */ /* Get next record with identical key */
/* Can only be called if previous calls was hash_search */ /* Can only be called if previous calls was my_hash_search */
uchar* hash_next(const HASH *hash, const uchar *key, size_t length, uchar* my_hash_next(const HASH *hash, const uchar *key, size_t length,
HASH_SEARCH_STATE *current_record) HASH_SEARCH_STATE *current_record)
{ {
HASH_LINK *pos; HASH_LINK *pos;
uint idx; uint idx;
@ -297,7 +297,7 @@ static int hashcmp(const HASH *hash, HASH_LINK *pos, const uchar *key,
size_t length) size_t length)
{ {
size_t rec_keylength; size_t rec_keylength;
uchar *rec_key= (uchar*) hash_key(hash,pos->data,&rec_keylength,1); uchar *rec_key= (uchar*) my_hash_key(hash, pos->data, &rec_keylength, 1);
return ((length && length != rec_keylength) || return ((length && length != rec_keylength) ||
my_strnncoll(hash->charset, (uchar*) rec_key, rec_keylength, my_strnncoll(hash->charset, (uchar*) rec_key, rec_keylength,
(uchar*) key, rec_keylength)); (uchar*) key, rec_keylength));
@ -306,7 +306,7 @@ static int hashcmp(const HASH *hash, HASH_LINK *pos, const uchar *key,
/* Write a hash-key to the hash-index */ /* Write a hash-key to the hash-index */
my_bool my_hash_insert(HASH *info,const uchar *record) my_bool my_hash_insert(HASH *info, const uchar *record)
{ {
int flag; int flag;
size_t idx; size_t idx;
@ -321,8 +321,8 @@ my_bool my_hash_insert(HASH *info,const uchar *record)
if (HASH_UNIQUE & info->flags) if (HASH_UNIQUE & info->flags)
{ {
uchar *key= (uchar*) hash_key(info, record, &idx, 1); uchar *key= (uchar*) my_hash_key(info, record, &idx, 1);
if (hash_search(info, key, idx)) if (my_hash_search(info, key, idx))
return(TRUE); /* Duplicate entry */ return(TRUE); /* Duplicate entry */
} }
@ -341,7 +341,7 @@ my_bool my_hash_insert(HASH *info,const uchar *record)
pos=data+idx; pos=data+idx;
hash_nr=rec_hashnr(info,pos->data); hash_nr=rec_hashnr(info,pos->data);
if (flag == 0) /* First loop; Check if ok */ if (flag == 0) /* First loop; Check if ok */
if (hash_mask(hash_nr,info->blength,info->records) != first_index) if (my_hash_mask(hash_nr, info->blength, info->records) != first_index)
break; break;
if (!(hash_nr & halfbuff)) if (!(hash_nr & halfbuff))
{ /* Key will not move */ { /* Key will not move */
@ -413,7 +413,7 @@ my_bool my_hash_insert(HASH *info,const uchar *record)
} }
/* Check if we are at the empty position */ /* Check if we are at the empty position */
idx=hash_mask(rec_hashnr(info,record),info->blength,info->records+1); idx= my_hash_mask(rec_hashnr(info, record), info->blength, info->records + 1);
pos=data+idx; pos=data+idx;
if (pos == empty) if (pos == empty)
{ {
@ -424,7 +424,7 @@ my_bool my_hash_insert(HASH *info,const uchar *record)
{ {
/* Check if more records in same hash-nr family */ /* Check if more records in same hash-nr family */
empty[0]=pos[0]; empty[0]=pos[0];
gpos=data+hash_rec_mask(info,pos,info->blength,info->records+1); gpos= data + my_hash_rec_mask(info, pos, info->blength, info->records + 1);
if (pos == gpos) if (pos == gpos)
{ {
pos->data=(uchar*) record; pos->data=(uchar*) record;
@ -449,18 +449,18 @@ my_bool my_hash_insert(HASH *info,const uchar *record)
** if there is a free-function it's called for record if found ** if there is a free-function it's called for record if found
******************************************************************************/ ******************************************************************************/
my_bool hash_delete(HASH *hash,uchar *record) my_bool my_hash_delete(HASH *hash, uchar *record)
{ {
uint blength,pos2,pos_hashnr,lastpos_hashnr,idx,empty_index; uint blength,pos2,pos_hashnr,lastpos_hashnr,idx,empty_index;
HASH_LINK *data,*lastpos,*gpos,*pos,*pos3,*empty; HASH_LINK *data,*lastpos,*gpos,*pos,*pos3,*empty;
DBUG_ENTER("hash_delete"); DBUG_ENTER("my_hash_delete");
if (!hash->records) if (!hash->records)
DBUG_RETURN(1); DBUG_RETURN(1);
blength=hash->blength; blength=hash->blength;
data=dynamic_element(&hash->array,0,HASH_LINK*); data=dynamic_element(&hash->array,0,HASH_LINK*);
/* Search after record with key */ /* Search after record with key */
pos=data+ hash_mask(rec_hashnr(hash,record),blength,hash->records); pos= data + my_hash_mask(rec_hashnr(hash, record), blength, hash->records);
gpos = 0; gpos = 0;
while (pos->data != record) while (pos->data != record)
@ -491,7 +491,7 @@ my_bool hash_delete(HASH *hash,uchar *record)
/* Move the last key (lastpos) */ /* Move the last key (lastpos) */
lastpos_hashnr=rec_hashnr(hash,lastpos->data); lastpos_hashnr=rec_hashnr(hash,lastpos->data);
/* pos is where lastpos should be */ /* pos is where lastpos should be */
pos=data+hash_mask(lastpos_hashnr,hash->blength,hash->records); pos= data + my_hash_mask(lastpos_hashnr, hash->blength, hash->records);
if (pos == empty) /* Move to empty position. */ if (pos == empty) /* Move to empty position. */
{ {
empty[0]=lastpos[0]; empty[0]=lastpos[0];
@ -499,7 +499,7 @@ my_bool hash_delete(HASH *hash,uchar *record)
} }
pos_hashnr=rec_hashnr(hash,pos->data); pos_hashnr=rec_hashnr(hash,pos->data);
/* pos3 is where the pos should be */ /* pos3 is where the pos should be */
pos3= data+hash_mask(pos_hashnr,hash->blength,hash->records); pos3= data + my_hash_mask(pos_hashnr, hash->blength, hash->records);
if (pos != pos3) if (pos != pos3)
{ /* pos is on wrong posit */ { /* pos is on wrong posit */
empty[0]=pos[0]; /* Save it here */ empty[0]=pos[0]; /* Save it here */
@ -507,8 +507,8 @@ my_bool hash_delete(HASH *hash,uchar *record)
movelink(data,(uint) (pos-data),(uint) (pos3-data),empty_index); movelink(data,(uint) (pos-data),(uint) (pos3-data),empty_index);
goto exit; goto exit;
} }
pos2= hash_mask(lastpos_hashnr,blength,hash->records+1); pos2= my_hash_mask(lastpos_hashnr, blength, hash->records + 1);
if (pos2 == hash_mask(pos_hashnr,blength,hash->records+1)) if (pos2 == my_hash_mask(pos_hashnr, blength, hash->records + 1))
{ /* Identical key-positions */ { /* Identical key-positions */
if (pos2 != hash->records) if (pos2 != hash->records)
{ {
@ -536,26 +536,26 @@ exit:
This is much more efficent than using a delete & insert. This is much more efficent than using a delete & insert.
*/ */
my_bool hash_update(HASH *hash, uchar *record, uchar *old_key, my_bool my_hash_update(HASH *hash, uchar *record, uchar *old_key,
size_t old_key_length) size_t old_key_length)
{ {
uint new_index,new_pos_index,blength,records,empty; uint new_index,new_pos_index,blength,records,empty;
size_t idx; size_t idx;
HASH_LINK org_link,*data,*previous,*pos; HASH_LINK org_link,*data,*previous,*pos;
DBUG_ENTER("hash_update"); DBUG_ENTER("my_hash_update");
if (HASH_UNIQUE & hash->flags) if (HASH_UNIQUE & hash->flags)
{ {
HASH_SEARCH_STATE state; HASH_SEARCH_STATE state;
uchar *found, *new_key= (uchar*) hash_key(hash, record, &idx, 1); uchar *found, *new_key= (uchar*) my_hash_key(hash, record, &idx, 1);
if ((found= hash_first(hash, new_key, idx, &state))) if ((found= my_hash_first(hash, new_key, idx, &state)))
{ {
do do
{ {
if (found != record) if (found != record)
DBUG_RETURN(1); /* Duplicate entry */ DBUG_RETURN(1); /* Duplicate entry */
} }
while ((found= hash_next(hash, new_key, idx, &state))); while ((found= my_hash_next(hash, new_key, idx, &state)));
} }
} }
@ -564,11 +564,11 @@ my_bool hash_update(HASH *hash, uchar *record, uchar *old_key,
/* Search after record with key */ /* Search after record with key */
idx=hash_mask(calc_hash(hash, old_key,(old_key_length ? idx= my_hash_mask(calc_hash(hash, old_key, (old_key_length ?
old_key_length : old_key_length :
hash->key_length)), hash->key_length)),
blength,records); blength, records);
new_index=hash_mask(rec_hashnr(hash,record),blength,records); new_index= my_hash_mask(rec_hashnr(hash, record), blength, records);
if (idx == new_index) if (idx == new_index)
DBUG_RETURN(0); /* Nothing to do (No record check) */ DBUG_RETURN(0); /* Nothing to do (No record check) */
previous=0; previous=0;
@ -618,7 +618,7 @@ my_bool hash_update(HASH *hash, uchar *record, uchar *old_key,
DBUG_RETURN(0); DBUG_RETURN(0);
} }
pos=data+new_index; pos=data+new_index;
new_pos_index=hash_rec_mask(hash,pos,blength,records); new_pos_index= my_hash_rec_mask(hash, pos, blength, records);
if (new_index != new_pos_index) if (new_index != new_pos_index)
{ /* Other record in wrong position */ { /* Other record in wrong position */
data[empty] = *pos; data[empty] = *pos;
@ -636,7 +636,7 @@ my_bool hash_update(HASH *hash, uchar *record, uchar *old_key,
} }
uchar *hash_element(HASH *hash,ulong idx) uchar *my_hash_element(HASH *hash, ulong idx)
{ {
if (idx < hash->records) if (idx < hash->records)
return dynamic_element(&hash->array,idx,HASH_LINK*)->data; return dynamic_element(&hash->array,idx,HASH_LINK*)->data;
@ -649,7 +649,8 @@ uchar *hash_element(HASH *hash,ulong idx)
isn't changed isn't changed
*/ */
void hash_replace(HASH *hash, HASH_SEARCH_STATE *current_record, uchar *new_row) void my_hash_replace(HASH *hash, HASH_SEARCH_STATE *current_record,
uchar *new_row)
{ {
if (*current_record != NO_RECORD) /* Safety */ if (*current_record != NO_RECORD) /* Safety */
dynamic_element(&hash->array, *current_record, HASH_LINK*)->data= new_row; dynamic_element(&hash->array, *current_record, HASH_LINK*)->data= new_row;
@ -658,7 +659,7 @@ void hash_replace(HASH *hash, HASH_SEARCH_STATE *current_record, uchar *new_row)
#ifndef DBUG_OFF #ifndef DBUG_OFF
my_bool hash_check(HASH *hash) my_bool my_hash_check(HASH *hash)
{ {
int error; int error;
uint i,rec_link,found,max_links,seek,links,idx; uint i,rec_link,found,max_links,seek,links,idx;
@ -671,7 +672,7 @@ my_bool hash_check(HASH *hash)
for (i=found=max_links=seek=0 ; i < records ; i++) for (i=found=max_links=seek=0 ; i < records ; i++)
{ {
if (hash_rec_mask(hash,data+i,blength,records) == i) if (my_hash_rec_mask(hash, data + i, blength, records) == i)
{ {
found++; seek++; links=1; found++; seek++; links=1;
for (idx=data[i].next ; for (idx=data[i].next ;
@ -687,11 +688,12 @@ my_bool hash_check(HASH *hash)
} }
hash_info=data+idx; hash_info=data+idx;
seek+= ++links; seek+= ++links;
if ((rec_link=hash_rec_mask(hash,hash_info,blength,records)) != i) if ((rec_link= my_hash_rec_mask(hash, hash_info,
blength, records)) != i)
{ {
DBUG_PRINT("error", DBUG_PRINT("error", ("Record in wrong link at %d: Start %d "
("Record in wrong link at %d: Start %d Record: 0x%lx Record-link %d", "Record: 0x%lx Record-link %d",
idx, i, (long) hash_info->data, rec_link)); idx, i, (long) hash_info->data, rec_link));
error=1; error=1;
} }
else else

39
sql/handler.cc
View File

@ -373,6 +373,10 @@ int ha_finalize_handlerton(st_plugin_int *plugin)
handlerton *hton= (handlerton *)plugin->data; handlerton *hton= (handlerton *)plugin->data;
DBUG_ENTER("ha_finalize_handlerton"); DBUG_ENTER("ha_finalize_handlerton");
/* hton can be NULL here, if ha_initialize_handlerton() failed. */
if (!hton)
goto end;
switch (hton->state) switch (hton->state)
{ {
case SHOW_OPTION_NO: case SHOW_OPTION_NO:
@ -401,8 +405,16 @@ int ha_finalize_handlerton(st_plugin_int *plugin)
} }
} }
/*
In case a plugin is uninstalled and re-installed later, it should
reuse an array slot. Otherwise the number of uninstall/install
cycles would be limited.
*/
hton2plugin[hton->slot]= NULL;
my_free((uchar*)hton, MYF(0)); my_free((uchar*)hton, MYF(0));
end:
DBUG_RETURN(0); DBUG_RETURN(0);
} }
@ -437,6 +449,7 @@ int ha_initialize_handlerton(st_plugin_int *plugin)
case SHOW_OPTION_YES: case SHOW_OPTION_YES:
{ {
uint tmp; uint tmp;
ulong fslot;
/* now check the db_type for conflict */ /* now check the db_type for conflict */
if (hton->db_type <= DB_TYPE_UNKNOWN || if (hton->db_type <= DB_TYPE_UNKNOWN ||
hton->db_type >= DB_TYPE_DEFAULT || hton->db_type >= DB_TYPE_DEFAULT ||
@ -461,7 +474,31 @@ int ha_initialize_handlerton(st_plugin_int *plugin)
tmp= hton->savepoint_offset; tmp= hton->savepoint_offset;
hton->savepoint_offset= savepoint_alloc_size; hton->savepoint_offset= savepoint_alloc_size;
savepoint_alloc_size+= tmp; savepoint_alloc_size+= tmp;
hton->slot= total_ha++;
/*
In case a plugin is uninstalled and re-installed later, it should
reuse an array slot. Otherwise the number of uninstall/install
cycles would be limited. So look for a free slot.
*/
DBUG_PRINT("plugin", ("total_ha: %lu", total_ha));
for (fslot= 0; fslot < total_ha; fslot++)
{
if (!hton2plugin[fslot])
break;
}
if (fslot < total_ha)
hton->slot= fslot;
else
{
if (total_ha >= MAX_HA)
{
sql_print_error("Too many plugins loaded. Limit is %lu. "
"Failed on '%s'", (ulong) MAX_HA, plugin->name.str);
goto err;
}
hton->slot= total_ha++;
}
hton2plugin[hton->slot]=plugin; hton2plugin[hton->slot]=plugin;
if (hton->prepare) if (hton->prepare)
total_ha_2pc++; total_ha_2pc++;