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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */
14
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
16
16
/* This file is included in all heap-files */
17
#ifndef PLUGIN_MEMORY_HEAP_PRIV_H
18
#define PLUGIN_MEMORY_HEAP_PRIV_H
17
#ifndef PLUGIN_HEAP_HEAP_PRIV_H
18
#define PLUGIN_HEAP_HEAP_PRIV_H
20
#include <drizzled/global.h>
21
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>
23
#include <mysys/my_sys.h>
24
#include <mystrings/m_ctype.h>
25
#include <mysys/my_pthread.h>
26
26
#include "heap.h" /* Structs & some defines */
27
#include <drizzled/tree.h>
27
#include <mysys/my_tree.h>
30
#include <boost/thread/mutex.hpp>
33
31
When allocating keys /rows in the internal block structure, do it
34
32
within the following boundaries.
37
35
as possible and keep memory consumption down.
40
42
#define CHUNK_STATUS_DELETED 0 /* this chunk has been deleted and can be reused */
41
43
#define CHUNK_STATUS_ACTIVE 1 /* this chunk represents the first part of a live record */
44
#define CHUNK_STATUS_LINKED 2 /* this chunk is a continuation from another chunk (part of chunkset) */
43
46
/* Some extern variables */
48
51
#define test_active(info) \
49
52
if (!(info->update & HA_STATE_AKTIV))\
50
{ errno= drizzled::HA_ERR_NO_ACTIVE_RECORD; return(-1); }
53
{ my_errno=HA_ERR_NO_ACTIVE_RECORD; return(-1); }
51
54
#define hp_find_hash(A,B) ((HASH_INFO*) hp_find_block((A),(B)))
53
56
/* Find pos for record and update it in info->current_ptr */
54
#define hp_find_record(info,pos) (info)->current_ptr= hp_find_block(&(info)->getShare()->recordspace.block,pos)
57
#define hp_find_record(info,pos) (info)->current_ptr= hp_find_block(&(info)->s->recordspace.block,pos)
56
59
#define get_chunk_status(info,ptr) (ptr[(info)->offset_status])
61
#define get_chunk_count(info,rec_length) ((rec_length + (info)->chunk_dataspace_length - 1) / (info)->chunk_dataspace_length)
58
63
typedef struct st_hp_hash_info
60
65
struct st_hp_hash_info *next_key;
61
66
unsigned char *ptr_to_rec;
64
75
/* Prototypes for intern functions */
66
77
extern HP_SHARE *hp_find_named_heap(const char *name);
69
80
extern int hp_get_new_block(HP_BLOCK *info, size_t* alloc_length);
70
81
extern void hp_free(HP_SHARE *info);
71
82
extern unsigned char *hp_free_level(HP_BLOCK *block,uint32_t level,HP_PTRS *pos,
72
unsigned char *last_pos);
83
unsigned char *last_pos);
73
84
extern int hp_write_key(HP_INFO *info, HP_KEYDEF *keyinfo,
74
85
const unsigned char *record, unsigned char *recpos);
86
extern int hp_rb_write_key(HP_INFO *info, HP_KEYDEF *keyinfo,
87
const unsigned char *record, unsigned char *recpos);
88
extern int hp_rb_delete_key(HP_INFO *info,HP_KEYDEF *keyinfo,
89
const unsigned char *record,unsigned char *recpos,int flag);
75
90
extern int hp_delete_key(HP_INFO *info,HP_KEYDEF *keyinfo,
76
91
const unsigned char *record,unsigned char *recpos,int flag);
77
92
extern HASH_INFO *_heap_find_hash(HP_BLOCK *block,uint32_t pos);
87
102
const unsigned char *rec2,
88
103
bool diff_if_only_endspace_difference);
89
104
extern void hp_make_key(HP_KEYDEF *keydef,unsigned char *key,const unsigned char *rec);
105
extern uint32_t hp_rb_make_key(HP_KEYDEF *keydef, unsigned char *key,
106
const unsigned char *rec, unsigned char *recpos);
107
extern uint32_t hp_rb_key_length(HP_KEYDEF *keydef, const unsigned char *key);
108
extern uint32_t hp_rb_null_key_length(HP_KEYDEF *keydef, const unsigned char *key);
109
extern uint32_t hp_rb_var_key_length(HP_KEYDEF *keydef, const unsigned char *key);
90
110
extern bool hp_if_null_in_key(HP_KEYDEF *keyinfo, const unsigned char *record);
91
111
extern int hp_close(HP_INFO *info);
92
112
extern void hp_clear(HP_SHARE *info);
113
extern uint32_t hp_rb_pack_key(HP_KEYDEF *keydef, unsigned char *key, const unsigned char *old,
114
key_part_map keypart_map);
94
116
/* Chunkset management (alloc/free/encode/decode) functions */
96
118
extern unsigned char *hp_allocate_chunkset(HP_DATASPACE *info, uint32_t chunk_count);
119
extern int hp_reallocate_chunkset(HP_DATASPACE *info, uint32_t chunk_count, unsigned char* pos);
97
120
extern void hp_free_chunks(HP_DATASPACE *info, unsigned char *pos);
98
121
extern void hp_clear_dataspace(HP_DATASPACE *info);
100
123
extern uint32_t hp_get_encoded_data_length(HP_SHARE *info, const unsigned char *record, uint32_t *chunk_count);
101
124
extern void hp_copy_record_data_to_chunkset(HP_SHARE *info, const unsigned char *record, unsigned char *pos);
102
125
extern void hp_extract_record(HP_SHARE *info, unsigned char *record, const unsigned char *pos);
103
extern bool hp_compare_record_data_to_chunkset(HP_SHARE *info, const unsigned char *record, unsigned char *pos);
105
extern boost::mutex THR_LOCK_heap;
107
#endif /* PLUGIN_MEMORY_HEAP_PRIV_H */
126
extern uint32_t hp_process_record_data_to_chunkset(HP_SHARE *info, const unsigned char *record, unsigned char *pos, uint32_t is_compare);
130
extern pthread_mutex_t THR_LOCK_heap;
136
#endif /* PLUGIN_HEAP_HEAP_PRIV_H */