1 /* Copyright (c) 2000, 2019, Oracle and/or its affiliates. All rights reserved. 2 3 This program is free software; you can redistribute it and/or modify 4 it under the terms of the GNU General Public License, version 2.0, 5 as published by the Free Software Foundation. 6 7 This program is also distributed with certain software (including 8 but not limited to OpenSSL) that is licensed under separate terms, 9 as designated in a particular file or component or in included license 10 documentation. The authors of MySQL hereby grant you an additional 11 permission to link the program and your derivative works with the 12 separately licensed software that they have included with MySQL. 13 14 This program is distributed in the hope that it will be useful, 15 but WITHOUT ANY WARRANTY; without even the implied warranty of 16 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 17 GNU General Public License, version 2.0, for more details. 18 19 You should have received a copy of the GNU General Public License 20 along with this program; if not, write to the Free Software 21 Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */ 22 23 /* This file is included in all heap-files */ 24 25 #include "heap.h" /* Structs & some defines */ 26 #include "m_string.h" 27 #include "my_base.h" /* This includes global */ 28 #include "my_sys.h" 29 #include "my_thread.h" 30 #include "my_thread_local.h" 31 #include "my_tree.h" 32 33 /* 34 When allocating keys /rows in the internal block structure, do it 35 within the following boundaries. 36 37 The challenge is to find the balance between allocate as few blocks 38 as possible and keep memory consumption down. 39 */ 40 41 #define HP_MIN_RECORDS_IN_BLOCK 16 42 #define HP_MAX_RECORDS_IN_BLOCK 8192 43 44 /* Some extern variables */ 45 46 extern LIST *heap_open_list, *heap_share_list; 47 48 #define test_active(info) \ 49 if (!(info->update & HA_STATE_AKTIV)) { \ 50 set_my_errno(HA_ERR_NO_ACTIVE_RECORD); \ 51 return -1; \ 52 } 53 #define hp_find_hash(A, B) ((HASH_INFO *)hp_find_block((A), (B))) 54 55 /* Find pos for record and update it in info->current_ptr */ 56 #define hp_find_record(info, pos) \ 57 (info)->current_ptr = hp_find_block(&(info)->s->block, pos) 58 59 struct HASH_INFO { 60 HASH_INFO *next_key; 61 uchar *ptr_to_rec; 62 ulong hash; /* Cached key hash value. */ 63 }; 64 65 typedef struct { 66 HA_KEYSEG *keyseg; 67 uint key_length; 68 uint search_flag; 69 } heap_rb_param; 70 71 /* Prototypes for intern functions */ 72 73 extern HP_SHARE *hp_find_named_heap(const char *name); 74 extern int hp_rectest(HP_INFO *info, const uchar *old); 75 extern uchar *hp_find_block(HP_BLOCK *info, ulong pos); 76 extern int hp_get_new_block(HP_BLOCK *info, size_t *alloc_length); 77 extern void hp_free(HP_SHARE *info); 78 extern uchar *hp_free_level(HP_BLOCK *block, uint level, HP_PTRS *pos, 79 uchar *last_pos); 80 extern int hp_write_key(HP_INFO *info, HP_KEYDEF *keyinfo, const uchar *record, 81 uchar *recpos); 82 extern int hp_rb_write_key(HP_INFO *info, HP_KEYDEF *keyinfo, 83 const uchar *record, uchar *recpos); 84 extern int hp_rb_delete_key(HP_INFO *info, HP_KEYDEF *keyinfo, 85 const uchar *record, uchar *recpos, int flag); 86 extern int hp_delete_key(HP_INFO *info, HP_KEYDEF *keyinfo, const uchar *record, 87 uchar *recpos, int flag); 88 extern HASH_INFO *_heap_find_hash(HP_BLOCK *block, ulong pos); 89 extern uchar *hp_search(HP_INFO *info, HP_KEYDEF *keyinfo, const uchar *key, 90 uint nextflag); 91 extern uchar *hp_search_next(HP_INFO *info, HP_KEYDEF *keyinfo, 92 const uchar *key, HASH_INFO *pos); 93 extern uint64 hp_hashnr(HP_KEYDEF *keyinfo, const uchar *key); 94 extern uint64 hp_rec_hashnr(HP_KEYDEF *keyinfo, const uchar *rec); 95 extern uint64 hp_mask(uint64 hashnr, uint64 buffmax, uint64 maxlength); 96 extern void hp_movelink(HASH_INFO *pos, HASH_INFO *next_link, 97 HASH_INFO *newlink); 98 extern int hp_rec_key_cmp(HP_KEYDEF *keydef, const uchar *rec1, 99 const uchar *rec2); 100 extern int hp_key_cmp(HP_KEYDEF *keydef, const uchar *rec, const uchar *key); 101 extern void hp_make_key(HP_KEYDEF *keydef, uchar *key, const uchar *rec); 102 extern uint hp_rb_make_key(HP_KEYDEF *keydef, uchar *key, const uchar *rec, 103 uchar *recpos); 104 extern uint hp_rb_key_length(HP_KEYDEF *keydef, const uchar *key); 105 extern uint hp_rb_null_key_length(HP_KEYDEF *keydef, const uchar *key); 106 extern uint hp_rb_var_key_length(HP_KEYDEF *keydef, const uchar *key); 107 extern bool hp_if_null_in_key(HP_KEYDEF *keyinfo, const uchar *record); 108 extern int hp_close(HP_INFO *info); 109 extern void hp_clear(HP_SHARE *info); 110 extern void hp_clear_keys(HP_SHARE *info); 111 extern uint hp_rb_pack_key(const HP_KEYDEF *keydef, uchar *key, 112 const uchar *old, key_part_map keypart_map); 113 114 extern mysql_mutex_t THR_LOCK_heap; 115 116 extern PSI_memory_key hp_key_memory_HP_SHARE; 117 extern PSI_memory_key hp_key_memory_HP_INFO; 118 extern PSI_memory_key hp_key_memory_HP_PTRS; 119 extern PSI_memory_key hp_key_memory_HP_KEYDEF; 120 121 #ifdef HAVE_PSI_INTERFACE 122 123 void init_heap_psi_keys(); 124 #endif /* HAVE_PSI_INTERFACE */ 125