heapdef.h 4.03 KB
Newer Older
unknown's avatar
unknown committed
1
/* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
unknown's avatar
unknown committed
2

unknown's avatar
unknown committed
3 4 5 6
   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.
unknown's avatar
unknown committed
7

unknown's avatar
unknown committed
8 9 10 11
   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.
unknown's avatar
unknown committed
12

unknown's avatar
unknown committed
13 14 15 16 17 18 19 20 21 22 23
   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 */

/* This file is included in all heap-files */

#include <my_base.h>			/* This includes global */
#ifdef THREAD
#include <my_pthread.h>
#endif
#include "heap.h"			/* Structs & some defines */
24
#include "my_tree.h"
unknown's avatar
unknown committed
25

26 27 28 29 30 31 32 33 34 35 36
/*
  When allocating keys /rows in the internal block structure, do it
  within the following boundaries.

  The challenge is to find the balance between allocate as few blocks
  as possible and keep memory consumption down.
*/

#define HP_MIN_RECORDS_IN_BLOCK 16
#define HP_MAX_RECORDS_IN_BLOCK 8192

unknown's avatar
unknown committed
37 38 39 40 41 42 43
	/* Some extern variables */

extern LIST *heap_open_list,*heap_share_list;

#define test_active(info) \
if (!(info->update & HA_STATE_AKTIV))\
{ my_errno=HA_ERR_NO_ACTIVE_RECORD; DBUG_RETURN(-1); }
44
#define hp_find_hash(A,B) ((HASH_INFO*) hp_find_block((A),(B)))
unknown's avatar
unknown committed
45 46

	/* Find pos for record and update it in info->current_ptr */
47
#define hp_find_record(info,pos) (info)->current_ptr= hp_find_block(&(info)->s->block,pos)
unknown's avatar
unknown committed
48

unknown's avatar
unknown committed
49
typedef struct st_hp_hash_info
unknown's avatar
unknown committed
50
{
unknown's avatar
unknown committed
51
  struct st_hp_hash_info *next_key;
unknown's avatar
unknown committed
52 53 54
  byte *ptr_to_rec;
} HASH_INFO;

55
typedef struct {
unknown's avatar
unknown committed
56
  HA_KEYSEG *keyseg;
57 58 59 60
  uint key_length;
  uint search_flag;
} heap_rb_param;
      
unknown's avatar
unknown committed
61 62
	/* Prototypes for intern functions */

63 64 65 66 67 68 69 70 71 72 73 74 75 76 77
extern HP_SHARE *hp_find_named_heap(const char *name);
extern int hp_rectest(HP_INFO *info,const byte *old);
extern byte *hp_find_block(HP_BLOCK *info,ulong pos);
extern int hp_get_new_block(HP_BLOCK *info, ulong* alloc_length);
extern void hp_free(HP_SHARE *info);
extern byte *hp_free_level(HP_BLOCK *block,uint level,HP_PTRS *pos,
			   byte *last_pos);
extern int hp_write_key(HP_INFO *info, HP_KEYDEF *keyinfo,
			const byte *record, byte *recpos);
extern int hp_rb_write_key(HP_INFO *info, HP_KEYDEF *keyinfo, 
			   const byte *record, byte *recpos);
extern int hp_rb_delete_key(HP_INFO *info,HP_KEYDEF *keyinfo,
			    const byte *record,byte *recpos,int flag);
extern int hp_delete_key(HP_INFO *info,HP_KEYDEF *keyinfo,
			 const byte *record,byte *recpos,int flag);
unknown's avatar
unknown committed
78
extern HASH_INFO *_heap_find_hash(HP_BLOCK *block,ulong pos);
79 80 81 82 83 84 85 86
extern byte *hp_search(HP_INFO *info,HP_KEYDEF *keyinfo,const byte *key,
		       uint nextflag);
extern byte *hp_search_next(HP_INFO *info, HP_KEYDEF *keyinfo,
			    const byte *key, HASH_INFO *pos);
extern ulong hp_hashnr(HP_KEYDEF *keyinfo,const byte *key);
extern ulong hp_rec_hashnr(HP_KEYDEF *keyinfo,const byte *rec);
extern ulong hp_mask(ulong hashnr,ulong buffmax,ulong maxlength);
extern void hp_movelink(HASH_INFO *pos,HASH_INFO *next_link,
unknown's avatar
unknown committed
87
			 HASH_INFO *newlink);
88 89 90 91 92
extern int hp_rec_key_cmp(HP_KEYDEF *keydef,const byte *rec1,
			  const byte *rec2);
extern int hp_key_cmp(HP_KEYDEF *keydef,const byte *rec,
		      const byte *key);
extern void hp_make_key(HP_KEYDEF *keydef,byte *key,const byte *rec);
93
extern uint hp_rb_make_key(HP_KEYDEF *keydef, byte *key, 
94
			   const byte *rec, byte *recpos);
95
extern uint hp_rb_key_length(HP_KEYDEF *keydef, const byte *key);
unknown's avatar
unknown committed
96
extern uint hp_rb_null_key_length(HP_KEYDEF *keydef, const byte *key);
97
extern my_bool hp_if_null_in_key(HP_KEYDEF *keyinfo, const byte *record);
98 99
extern int hp_close(register HP_INFO *info);
extern void hp_clear(HP_SHARE *info);
unknown's avatar
unknown committed
100 101
extern uint hp_rb_pack_key(HP_KEYDEF *keydef, uchar *key, const uchar *old, 
			   uint k_len);
unknown's avatar
unknown committed
102 103 104 105 106 107
#ifdef THREAD
extern pthread_mutex_t THR_LOCK_heap;
#else
#define pthread_mutex_lock(A)
#define pthread_mutex_unlock(A)
#endif