12
12
You should have received a copy of the GNU General Public License
13
13
along with this program; if not, write to the Free Software
14
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
14
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */
16
16
/* This file is included in all heap-files */
20
#include <drizzled/base.h> /* This includes global */
26
#include <mysys/my_pthread.h>
17
#ifndef PLUGIN_MEMORY_HEAP_PRIV_H
18
#define PLUGIN_MEMORY_HEAP_PRIV_H
21
#include <drizzled/base.h>
23
#include "drizzled/internal/my_sys.h"
24
#include "drizzled/charset_info.h"
25
#include "drizzled/internal/my_pthread.h"
27
26
#include "heap.h" /* Structs & some defines */
28
#include <mysys/my_tree.h>
27
#include "drizzled/tree.h"
30
#include <boost/thread/mutex.hpp>
31
33
When allocating keys /rows in the internal block structure, do it
35
37
as possible and keep memory consumption down.
38
#define HP_MIN_RECORDS_IN_BLOCK 16
39
#define HP_MAX_RECORDS_IN_BLOCK 8192
41
40
#define CHUNK_STATUS_DELETED 0 /* this chunk has been deleted and can be reused */
42
41
#define CHUNK_STATUS_ACTIVE 1 /* this chunk represents the first part of a live record */
43
42
#define CHUNK_STATUS_LINKED 2 /* this chunk is a continuation from another chunk (part of chunkset) */
45
44
/* Some extern variables */
47
extern LIST *heap_open_list,*heap_share_list;
46
extern std::list<HP_SHARE *> heap_share_list;
47
extern std::list<HP_INFO *> heap_open_list;
49
49
#define test_active(info) \
50
50
if (!(info->update & HA_STATE_AKTIV))\
51
{ my_errno=HA_ERR_NO_ACTIVE_RECORD; return(-1); }
51
{ errno=HA_ERR_NO_ACTIVE_RECORD; return(-1); }
52
52
#define hp_find_hash(A,B) ((HASH_INFO*) hp_find_block((A),(B)))
54
54
/* Find pos for record and update it in info->current_ptr */
55
#define hp_find_record(info,pos) (info)->current_ptr= hp_find_block(&(info)->s->recordspace.block,pos)
55
#define hp_find_record(info,pos) (info)->current_ptr= hp_find_block(&(info)->getShare()->recordspace.block,pos)
57
57
#define get_chunk_status(info,ptr) (ptr[(info)->offset_status])
78
72
extern int hp_get_new_block(HP_BLOCK *info, size_t* alloc_length);
79
73
extern void hp_free(HP_SHARE *info);
80
74
extern unsigned char *hp_free_level(HP_BLOCK *block,uint32_t level,HP_PTRS *pos,
81
unsigned char *last_pos);
75
unsigned char *last_pos);
82
76
extern int hp_write_key(HP_INFO *info, HP_KEYDEF *keyinfo,
83
77
const unsigned char *record, unsigned char *recpos);
84
extern int hp_rb_write_key(HP_INFO *info, HP_KEYDEF *keyinfo,
85
const unsigned char *record, unsigned char *recpos);
86
extern int hp_rb_delete_key(HP_INFO *info,HP_KEYDEF *keyinfo,
87
const unsigned char *record,unsigned char *recpos,int flag);
88
78
extern int hp_delete_key(HP_INFO *info,HP_KEYDEF *keyinfo,
89
79
const unsigned char *record,unsigned char *recpos,int flag);
90
80
extern HASH_INFO *_heap_find_hash(HP_BLOCK *block,uint32_t pos);
92
82
uint32_t nextflag);
93
83
extern unsigned char *hp_search_next(HP_INFO *info, HP_KEYDEF *keyinfo,
94
84
const unsigned char *key, HASH_INFO *pos);
95
extern uint32_t hp_hashnr(HP_KEYDEF *keyinfo,const unsigned char *key);
96
85
extern uint32_t hp_rec_hashnr(HP_KEYDEF *keyinfo,const unsigned char *rec);
97
86
extern uint32_t hp_mask(uint32_t hashnr,uint32_t buffmax,uint32_t maxlength);
98
87
extern void hp_movelink(HASH_INFO *pos,HASH_INFO *next_link,
100
89
extern int hp_rec_key_cmp(HP_KEYDEF *keydef,const unsigned char *rec1,
101
90
const unsigned char *rec2,
102
91
bool diff_if_only_endspace_difference);
103
extern int hp_key_cmp(HP_KEYDEF *keydef,const unsigned char *rec,
104
const unsigned char *key);
105
92
extern void hp_make_key(HP_KEYDEF *keydef,unsigned char *key,const unsigned char *rec);
106
extern uint32_t hp_rb_make_key(HP_KEYDEF *keydef, unsigned char *key,
107
const unsigned char *rec, unsigned char *recpos);
108
extern uint32_t hp_rb_key_length(HP_KEYDEF *keydef, const unsigned char *key);
109
extern uint32_t hp_rb_null_key_length(HP_KEYDEF *keydef, const unsigned char *key);
110
extern uint32_t hp_rb_var_key_length(HP_KEYDEF *keydef, const unsigned char *key);
111
93
extern bool hp_if_null_in_key(HP_KEYDEF *keyinfo, const unsigned char *record);
112
extern int hp_close(register HP_INFO *info);
94
extern int hp_close(HP_INFO *info);
113
95
extern void hp_clear(HP_SHARE *info);
114
extern void hp_clear_keys(HP_SHARE *info);
115
extern uint32_t hp_rb_pack_key(HP_KEYDEF *keydef, unsigned char *key, const unsigned char *old,
116
key_part_map keypart_map);
118
97
/* Chunkset management (alloc/free/encode/decode) functions */
120
99
extern unsigned char *hp_allocate_chunkset(HP_DATASPACE *info, uint32_t chunk_count);
121
extern int hp_reallocate_chunkset(HP_DATASPACE *info, uint32_t chunk_count, unsigned char* pos);
122
100
extern void hp_free_chunks(HP_DATASPACE *info, unsigned char *pos);
123
101
extern void hp_clear_dataspace(HP_DATASPACE *info);
125
103
extern uint32_t hp_get_encoded_data_length(HP_SHARE *info, const unsigned char *record, uint32_t *chunk_count);
126
104
extern void hp_copy_record_data_to_chunkset(HP_SHARE *info, const unsigned char *record, unsigned char *pos);
127
105
extern void hp_extract_record(HP_SHARE *info, unsigned char *record, const unsigned char *pos);
128
extern uint32_t hp_process_record_data_to_chunkset(HP_SHARE *info, const unsigned char *record, unsigned char *pos, uint32_t is_compare);
132
extern pthread_mutex_t THR_LOCK_heap;
138
#endif /* HEAPDEF_H */
106
extern bool hp_compare_record_data_to_chunkset(HP_SHARE *info, const unsigned char *record, unsigned char *pos);
108
extern boost::mutex THR_LOCK_heap;
110
#endif /* PLUGIN_MEMORY_HEAP_PRIV_H */