myisamdef.h
上传用户:tsgydb
上传日期:2007-04-14
资源大小:10674k
文件大小:25k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
  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 as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  7.    
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  12.    
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  16. /* This file is included by all internal myisam files */
  17. #include "myisam.h" /* Structs & some defines */
  18. #include "myisampack.h" /* packing of keys */
  19. #ifdef THREAD
  20. #include <my_pthread.h>
  21. #include <thr_lock.h>
  22. #else
  23. #include <my_no_pthread.h>
  24. #endif
  25. #if defined(my_write) && !defined(MAP_TO_USE_RAID)
  26. #undef my_write /* undef map from my_nosys; We need test-if-disk full */
  27. #endif
  28. typedef struct st_mi_status_info
  29. {
  30.   ha_rows records; /* Rows in table */
  31.   ha_rows del; /* Removed rows */
  32.   my_off_t empty; /* lost space in datafile */
  33.   my_off_t key_empty; /* lost space in indexfile */
  34.   my_off_t key_file_length;
  35.   my_off_t data_file_length;
  36. } MI_STATUS_INFO;  
  37. typedef struct st_mi_state_info
  38. {
  39.   struct { /* Fileheader */
  40.     uchar file_version[4];
  41.     uchar options[2];
  42.     uchar header_length[2];
  43.     uchar state_info_length[2];
  44.     uchar base_info_length[2];
  45.     uchar base_pos[2];
  46.     uchar key_parts[2]; /* Key parts */
  47.     uchar unique_key_parts[2]; /* Key parts + unique parts */
  48.     uchar keys; /* number of keys in file */
  49.     uchar uniques; /* number of UNIQUE definitions */
  50.     uchar language; /* Language for indexes */
  51.     uchar max_block_size; /* max keyblock size */
  52.     uchar not_used[2]; /* To align to 8 */
  53.   } header;
  54.   MI_STATUS_INFO state;
  55.   ha_rows split; /* number of split blocks */
  56.   my_off_t dellink; /* Link to next removed block */
  57.   ulonglong auto_increment;
  58.   ulong process; /* process that updated table last */
  59.   ulong unique; /* Unique number for this process */
  60.   ulong update_count; /* Updated for each write lock */
  61.   ulong status;
  62.   my_off_t *key_root; /* Start of key trees */
  63.   my_off_t *key_del; /* delete links for trees */
  64.   ulong sec_index_changed; /* Updated when new sec_index */
  65.   ulong sec_index_used; /* which extra index are in use */
  66.   ulonglong key_map; /* Which keys are in use */
  67.   ha_checksum checksum;
  68.   ulong version; /* timestamp of create */
  69.   time_t create_time; /* Time when created database */
  70.   time_t recover_time; /* Time for last recover */
  71.   time_t check_time; /* Time for last check */
  72.   uint sortkey; /* sorted by this key  (not used) */
  73.   uint open_count;
  74.   uint8 changed; /* Changed since myisamchk */
  75.   my_off_t rec_per_key_rows; /* Rows when calculating rec_per_key */
  76.   ulong *rec_per_key_part;
  77.   /* the following isn't saved on disk */
  78.   uint state_diff_length; /* Should be 0 */
  79.   uint state_length; /* Length of state header in file */
  80.   ulong *key_info;
  81. } MI_STATE_INFO;
  82. #define MI_STATE_INFO_SIZE (24+14*8+7*4+2*2+8)
  83. #define MI_STATE_KEY_SIZE  8
  84. #define MI_STATE_KEYBLOCK_SIZE  8
  85. #define MI_STATE_KEYSEG_SIZE 4
  86. #define MI_STATE_EXTRA_SIZE ((MI_MAX_KEY+MI_MAX_KEY_BLOCK_SIZE)*MI_STATE_KEY_SIZE + MI_MAX_KEY*MI_MAX_KEY_SEG*MI_STATE_KEYSEG_SIZE)
  87. #define MI_KEYDEF_SIZE (2+ 5*2)
  88. #define MI_UNIQUEDEF_SIZE (2+1+1)
  89. #define MI_KEYSEG_SIZE (6+ 2*2 + 4*2)
  90. #define MI_COLUMNDEF_SIZE (2*3+1)
  91. #define MI_BASE_INFO_SIZE (5*8 + 8*4 + 4 + 4*2 + 16)
  92. #define MI_INDEX_BLOCK_MARGIN 16 /* Safety margin for .MYI tables */
  93. typedef struct st_mi_base_info
  94. {
  95.   my_off_t keystart; /* Start of keys */
  96.   my_off_t max_data_file_length;
  97.   my_off_t max_key_file_length;
  98.   my_off_t margin_key_file_length;
  99.   ha_rows records,reloc; /* Create information */
  100.   ulong mean_row_length; /* Create information */
  101.   ulong reclength; /* length of unpacked record */
  102.   ulong pack_reclength; /* Length of full packed rec. */
  103.   ulong min_pack_length;
  104.   ulong max_pack_length; /* Max possibly length of packed rec.*/
  105.   ulong min_block_length;
  106.   ulong fields, /* fields in table */
  107.        pack_fields; /* packed fields in table */
  108.   uint rec_reflength; /* = 2-8 */
  109.   uint key_reflength; /* = 2-8 */
  110.   uint keys; /* same as in state.header */
  111.   uint auto_key; /* Which key-1 is a auto key */
  112.   uint blobs; /* Number of blobs */
  113.   uint pack_bits; /* Length of packed bits */
  114.   uint max_key_block_length; /* Max block length */
  115.   uint max_key_length; /* Max key length */
  116.   /* Extra allocation when using dynamic record format */
  117.   uint extra_alloc_bytes;
  118.   uint extra_alloc_procent;
  119.   /* Info about raid */
  120.   uint raid_type,raid_chunks;
  121.   ulong raid_chunksize;
  122.   /* The following are from the header */
  123.   uint key_parts,all_key_parts;
  124. } MI_BASE_INFO;
  125. /* Structs used intern in database */
  126. typedef struct st_mi_blob /* Info of record */
  127. {
  128.   ulong offset; /* Offset to blob in record */
  129.   uint pack_length; /* Type of packed length */
  130.   ulong length; /* Calc:ed for each record */
  131. } MI_BLOB;
  132. typedef struct st_mi_isam_pack {
  133.   ulong header_length;
  134.   uint ref_length;
  135. } MI_PACK;
  136. typedef struct st_mi_isam_share { /* Shared between opens */
  137.   MI_STATE_INFO state;
  138.   MI_BASE_INFO base;
  139.   MI_KEYDEF  *keyinfo; /* Key definitions */
  140.   MI_UNIQUEDEF *uniqueinfo; /* unique definitions */
  141.   MI_KEYSEG *keyparts; /* key part info */
  142.   MI_COLUMNDEF *rec; /* Pointer to field information */
  143.   MI_PACK    pack; /* Data about packed records */
  144.   MI_BLOB    *blobs; /* Pointer to blobs */
  145.   char *filename; /* Name of indexfile */
  146.   byte *file_map; /* mem-map of file if possible */
  147.   ulong this_process; /* processid */
  148.   ulong last_process; /* For table-change-check */
  149.   ulong last_version; /* Version on start */
  150.   ulong options; /* Options used */
  151.   uint rec_reflength; /* rec_reflength in use now */
  152.   int kfile; /* Shared keyfile */
  153.   int data_file; /* Shared data file */
  154.   int mode; /* mode of file on open */
  155.   uint reopen; /* How many times reopened */
  156.   uint w_locks,r_locks; /* Number of read/write locks */
  157.   uint blocksize; /* blocksize of keyfile */
  158.   ulong min_pack_length; /* Theese are used by packed data */
  159.   ulong max_pack_length;
  160.   ulong state_diff_length;
  161.   my_bool  changed, /* If changed since lock */
  162.     global_changed, /* If changed since open */
  163.     not_flushed,
  164.     temporary,delay_key_write,
  165.     concurrent_insert,
  166.     fulltext_index;
  167.   myf write_flag;
  168.   int rnd; /* rnd-counter */
  169.   MI_DECODE_TREE *decode_trees;
  170.   uint16 *decode_tables;
  171.   enum data_file_type data_file_type;
  172.   int (*read_record)(struct st_myisam_info*, my_off_t, byte*);
  173.   int (*write_record)(struct st_myisam_info*, const byte*);
  174.   int (*update_record)(struct st_myisam_info*, my_off_t, const byte*);
  175.   int (*delete_record)(struct st_myisam_info*);
  176.   int (*read_rnd)(struct st_myisam_info*, byte*, my_off_t, my_bool);
  177.   int (*compare_record)(struct st_myisam_info*, const byte *);
  178.   ha_checksum (*calc_checksum)(struct st_myisam_info*, const byte *);
  179.   int (*compare_unique)(struct st_myisam_info*, MI_UNIQUEDEF *,
  180. const byte *record, my_off_t pos);
  181. #ifdef THREAD
  182.   THR_LOCK lock;
  183.   pthread_mutex_t intern_lock; /* Locking for use with _locking */
  184.   rw_lock_t *key_root_lock;
  185. #endif
  186. } MYISAM_SHARE;
  187. typedef uint mi_bit_type;
  188. typedef struct st_mi_bit_buff { /* Used for packing of record */
  189.   mi_bit_type current_byte;
  190.   uint bits;
  191.   uchar *pos,*end,*blob_pos;
  192.   uint error;
  193. } MI_BIT_BUFF;
  194. struct st_myisam_info {
  195.   MYISAM_SHARE *s; /* Shared between open:s */
  196.   MI_STATUS_INFO *state,save_state;
  197.   MI_BLOB     *blobs; /* Pointer to blobs */
  198.   int dfile; /* The datafile */
  199.   MI_BIT_BUFF   bit_buff;
  200.   uint opt_flag; /* Optim. for space/speed */
  201.   uint update; /* If file changed since open */
  202.   char *filename; /* parameter to open filename */
  203.   ulong this_unique; /* uniq filenumber or thread */
  204.   ulong last_unique; /* last unique number */
  205.   ulong this_loop; /* counter for this open */
  206.   ulong last_loop; /* last used counter */
  207.   my_off_t lastpos, /* Last record position */
  208. nextpos; /* Position to next record */
  209.   my_off_t save_lastpos;
  210.   my_off_t pos; /* Intern variable */
  211.   ha_checksum checksum;
  212.   ulong packed_length,blob_length; /* Length of found, packed record */
  213.   uint alloced_rec_buff_length; /* Max recordlength malloced */
  214.   uchar *buff, /* Temp area for key */
  215. *lastkey,*lastkey2; /* Last used search key */
  216.   byte *rec_buff, /* Tempbuff for recordpack */
  217. *rec_alloc; /* Malloced area for record */
  218.   uchar *int_keypos, /* Save position for next/previous */
  219.     *int_maxpos; /*  -""-  */
  220.   uint32 int_keytree_version; /*  -""-  */
  221.   uint   int_nod_flag; /*  -""-  */
  222.   my_off_t last_keypage; /* Last key page read */
  223.   my_off_t last_search_keypage; /* Last keypage when searching */
  224.   my_off_t dupp_key_pos;
  225.   int lastinx; /* Last used index */
  226.   uint lastkey_length; /* Length of key in lastkey */
  227.   uint last_rkey_length; /* Last length in mi_rkey() */
  228.   uint  save_lastkey_length;
  229.   int errkey; /* Got last error on this key */
  230.   int   lock_type; /* How database was locked */
  231.   int   tmp_lock_type; /* When locked by readinfo */
  232.   uint data_changed; /* Somebody has changed data */
  233.   uint save_update; /* When using KEY_READ */
  234.   int save_lastinx;
  235.   my_bool was_locked; /* Was locked in panic */
  236.   my_bool quick_mode;
  237.   my_bool page_changed; /* If info->buff can't be used for rnext */
  238.   my_bool buff_used; /* If info->buff has to be reread for rnext */
  239.   myf lock_wait; /* is 0 or MY_DONT_WAIT */
  240.   int (*read_record)(struct st_myisam_info*, my_off_t, byte*);
  241.   LIST open_list;
  242.   IO_CACHE rec_cache; /* When cacheing records */
  243. #ifdef THREAD
  244.   THR_LOCK_DATA lock;
  245. #endif
  246. };
  247. /* Some defines used by isam-funktions */
  248. #define USE_WHOLE_KEY MI_MAX_KEY_BUFF*2 /* Use whole key in _mi_search() */
  249. #define F_EXTRA_LCK -1
  250. /* bits in opt_flag */
  251. #define MEMMAP_USED 32
  252. #define REMEMBER_OLD_POS 64
  253. #define WRITEINFO_UPDATE_KEYFILE 1
  254. #define WRITEINFO_NO_UNLOCK 2
  255. /* bits in state.changed */
  256. #define STATE_CHANGED 1
  257. #define STATE_CRASHED 2
  258. #define STATE_CRASHED_ON_REPAIR 4 
  259. #define STATE_NOT_ANALYZED 8
  260. #define STATE_NOT_OPTIMIZED_KEYS 16
  261. #define STATE_NOT_SORTED_PAGES 32
  262. /* options to mi_read_cache */
  263. #define READING_NEXT 1
  264. #define READING_HEADER 2
  265. #define mi_getint(x) ((uint) mi_uint2korr(x) & 32767)
  266. #define mi_putint(x,y,nod) { uint16 boh=(nod ? (uint16) 32768 : 0) + (uint16) (y);
  267.   mi_int2store(x,boh); }
  268. #define mi_test_if_nod(x) (x[0] & 128 ? info->s->base.key_reflength : 0)
  269. #define mi_mark_crashed(x) (x)->s->state.changed|=STATE_CRASHED
  270. #define mi_mark_crashed_on_repair(x) { (x)->s->state.changed|=STATE_CRASHED|STATE_CRASHED_ON_REPAIR ; (x)->update|= HA_STATE_CHANGED; }
  271. #define mi_is_crashed(x) ((x)->s->state.changed & STATE_CRASHED)
  272. #define mi_is_crashed_on_repair(x) ((x)->s->state.changed & STATE_CRASHED_ON_REPAIR)
  273. /* Functions to store length of space packed keys, VARCHAR or BLOB keys */
  274. #define store_key_length_inc(key,length) 
  275. { if ((length) < 255) 
  276.   { *(key)++=(length); } 
  277.   else 
  278.   { *(key)=255; mi_int2store((key)+1,(length)); (key)+=3; } 
  279. }
  280. #define store_key_length(key,length) 
  281. { if ((length) < 255) 
  282.   { *(key)=(length); } 
  283.   else 
  284.   { *(key)=255; mi_int2store((key)+1,(length)); } 
  285. }
  286. #define get_key_length(length,key) 
  287. { if ((uchar) *(key) != 255) 
  288.     length= (uint) (uchar) *((key)++); 
  289.   else 
  290.   { length=mi_uint2korr((key)+1); (key)+=3; } 
  291. }
  292. #define get_key_full_length(length,key) 
  293. { if ((uchar) *(key) != 255) 
  294.     length= ((uint) (uchar) *((key)++))+1; 
  295.   else 
  296.   { length=mi_uint2korr((key)+1)+3; (key)+=3; } 
  297. }
  298. #define get_key_pack_length(length,length_pack,key) 
  299. { if ((uchar) *(key) != 255) 
  300.   { length= (uint) (uchar) *((key)++); length_pack=1; }
  301.   else 
  302.   { length=mi_uint2korr((key)+1); (key)+=3; length_pack=3; } 
  303. }
  304. #define get_pack_length(length) ((length) >= 255 ? 3 : 1)
  305. #define MI_MIN_BLOCK_LENGTH 20 /* Because of delete-link */
  306. #define MI_EXTEND_BLOCK_LENGTH 20 /* Don't use to small record-blocks */
  307. #define MI_SPLIT_LENGTH ((MI_EXTEND_BLOCK_LENGTH+4)*2)
  308. #define MI_MAX_DYN_BLOCK_HEADER 20 /* Max prefix of record-block */
  309. #define MI_BLOCK_INFO_HEADER_LENGTH 20
  310. #define MI_DYN_DELETE_BLOCK_HEADER 20 /* length of delete-block-header */
  311. #define MI_DYN_MAX_BLOCK_LENGTH ((1L << 24)-4L)
  312. #define MI_DYN_MAX_ROW_LENGTH (MI_DYN_MAX_BLOCK_LENGTH - MI_SPLIT_LENGTH)
  313. #define MI_DYN_ALIGN_SIZE 4 /* Align blocks on this */
  314. #define MI_MAX_DYN_HEADER_BYTE 12 /* max header byte for dynamic rows */
  315. #define MEMMAP_EXTRA_MARGIN 7 /* Write this as a suffix for file */
  316. #define PACK_TYPE_SELECTED 1 /* Bits in field->pack_type */
  317. #define PACK_TYPE_SPACE_FIELDS 2
  318. #define PACK_TYPE_ZERO_FILL 4
  319. #define MI_FOUND_WRONG_KEY 32738 /* Impossible value from _mi_key_cmp */
  320. #define MI_KEY_BLOCK_LENGTH 1024 /* Min key block length */
  321. #define MI_MAX_KEY_BLOCK_LENGTH 8192
  322. #define MI_MAX_KEY_BLOCK_SIZE (MI_MAX_KEY_BLOCK_LENGTH/MI_KEY_BLOCK_LENGTH)
  323. #define MI_BLOCK_SIZE(key_length,data_pointer,key_pointer) ((((key_length+data_pointer+key_pointer)*4+key_pointer+2)/MI_KEY_BLOCK_LENGTH+1)*MI_KEY_BLOCK_LENGTH)
  324. #define MI_MAX_KEYPTR_SIZE 5 /* For calculating block lengths */
  325. #define MI_MIN_KEYBLOCK_LENGTH 50 /* When to split delete blocks */
  326. /* The UNIQUE check is done with a hashed long key */
  327. #define MI_UNIQUE_HASH_TYPE HA_KEYTYPE_ULONG_INT
  328. #define mi_unique_store(A,B)    mi_int4store((A),(B))
  329. #ifdef THREAD
  330. extern pthread_mutex_t THR_LOCK_myisam;
  331. #endif
  332. #if !defined(THREAD) || defined(DONT_USE_RW_LOCKS)
  333. #define rw_wrlock(A) {}
  334. #define rw_rdlock(A) {}
  335. #define rw_unlock(A) {}
  336. #endif
  337. /* Some extern variables */
  338. extern LIST *myisam_open_list;
  339. extern uchar NEAR myisam_file_magic[],NEAR myisam_pack_file_magic[];
  340. extern uint NEAR myisam_read_vec[],NEAR myisam_readnext_vec[];
  341. extern uint myisam_quick_table_bits;
  342. extern File myisam_log_file;
  343. extern ulong myisam_pid;
  344. /* This is used by _mi_calc_xxx_key_length och _mi_store_key */
  345. typedef struct st_mi_s_param
  346. {
  347.   uint ref_length,key_length,
  348. n_ref_length,
  349. n_length,
  350. totlength,
  351. part_of_prev_key,prev_length,pack_marker;
  352.   uchar *key, *prev_key,*next_key_pos;
  353.   bool store_not_null;
  354. } MI_KEY_PARAM;
  355. /* Prototypes for intern functions */
  356. extern int _mi_read_dynamic_record(MI_INFO *info,my_off_t filepos,byte *buf);
  357. extern int _mi_write_dynamic_record(MI_INFO*, const byte*);
  358. extern int _mi_update_dynamic_record(MI_INFO*, my_off_t, const byte*);
  359. extern int _mi_delete_dynamic_record(MI_INFO *info);
  360. extern int _mi_cmp_dynamic_record(MI_INFO *info,const byte *record);
  361. extern int _mi_read_rnd_dynamic_record(MI_INFO *, byte *,my_off_t, my_bool);
  362. extern int _mi_write_blob_record(MI_INFO*, const byte*);
  363. extern int _mi_update_blob_record(MI_INFO*, my_off_t, const byte*);
  364. extern int _mi_read_static_record(MI_INFO *info, my_off_t filepos,byte *buf);
  365. extern int _mi_write_static_record(MI_INFO*, const byte*);
  366. extern int _mi_update_static_record(MI_INFO*, my_off_t, const byte*);
  367. extern int _mi_delete_static_record(MI_INFO *info);
  368. extern int _mi_cmp_static_record(MI_INFO *info,const byte *record);
  369. extern int _mi_read_rnd_static_record(MI_INFO*, byte *,my_off_t, my_bool);
  370. extern int _mi_ck_write(MI_INFO *info,uint keynr,uchar *key,uint length);
  371. extern int _mi_enlarge_root(MI_INFO *info,uint keynr,uchar *key);
  372. extern int _mi_insert(MI_INFO *info,MI_KEYDEF *keyinfo,uchar *key,
  373.       uchar *anc_buff,uchar *key_pos,uchar *key_buff,
  374.       uchar *father_buff, uchar *father_keypos,
  375.       my_off_t father_page, my_bool insert_last);
  376. extern int _mi_split_page(MI_INFO *info,MI_KEYDEF *keyinfo,uchar *key,
  377.   uchar *buff,uchar *key_buff, my_bool insert_last);
  378. extern uchar *_mi_find_half_pos(uint nod_flag,MI_KEYDEF *keyinfo,uchar *page,
  379. uchar *key,uint *return_key_length,
  380. uchar **after_key);
  381. extern int _mi_calc_static_key_length(MI_KEYDEF *keyinfo,uint nod_flag,
  382.       uchar *key_pos, uchar *org_key,
  383.       uchar *key_buff,
  384.       uchar *key, MI_KEY_PARAM *s_temp);
  385. extern int _mi_calc_var_key_length(MI_KEYDEF *keyinfo,uint nod_flag,
  386.    uchar *key_pos, uchar *org_key,
  387.    uchar *key_buff,
  388.    uchar *key, MI_KEY_PARAM *s_temp);
  389. extern int _mi_calc_var_pack_key_length(MI_KEYDEF *keyinfo,uint nod_flag,
  390. uchar *key_pos, uchar *org_key,
  391. uchar *prev_key,
  392. uchar *key, MI_KEY_PARAM *s_temp);
  393. extern int _mi_calc_bin_pack_key_length(MI_KEYDEF *keyinfo,uint nod_flag,
  394. uchar *key_pos,uchar *org_key,
  395. uchar *prev_key,
  396. uchar *key, MI_KEY_PARAM *s_temp);
  397. void _mi_store_static_key(MI_KEYDEF *keyinfo,  uchar *key_pos,
  398.    MI_KEY_PARAM *s_temp);
  399. void _mi_store_var_pack_key(MI_KEYDEF *keyinfo,  uchar *key_pos,
  400.      MI_KEY_PARAM *s_temp);
  401. #ifdef NOT_USED
  402. void _mi_store_pack_key(MI_KEYDEF *keyinfo,  uchar *key_pos,
  403.  MI_KEY_PARAM *s_temp);
  404. #endif
  405. void _mi_store_bin_pack_key(MI_KEYDEF *keyinfo,  uchar *key_pos,
  406.     MI_KEY_PARAM *s_temp);
  407. extern int _mi_ck_delete(MI_INFO *info,uint keynr,uchar *key,uint key_length);
  408. extern int _mi_readinfo(MI_INFO *info,int lock_flag,int check_keybuffer);
  409. extern int _mi_writeinfo(MI_INFO *info,uint options);
  410. extern int _mi_test_if_changed(MI_INFO *info);
  411. extern int _mi_mark_file_changed(MI_INFO *info);
  412. extern int _mi_decrement_open_count(MI_INFO *info);
  413. extern int _mi_check_index(MI_INFO *info,int inx);
  414. extern int _mi_search(MI_INFO *info,MI_KEYDEF *keyinfo,uchar *key,uint key_len,
  415.       uint nextflag,my_off_t pos);
  416. extern int _mi_bin_search(struct st_myisam_info *info,MI_KEYDEF *keyinfo,
  417.   uchar *page,uchar *key,uint key_len,uint comp_flag,
  418.   uchar * *ret_pos,uchar *buff, my_bool *was_last_key);
  419. extern int _mi_seq_search(MI_INFO *info,MI_KEYDEF *keyinfo,uchar *page,
  420.   uchar *key,uint key_len,uint comp_flag,
  421.   uchar **ret_pos,uchar *buff, my_bool *was_last_key);
  422. extern int _mi_compare_text(CHARSET_INFO *, uchar *, uint, uchar *, uint ,
  423.     my_bool);
  424. extern my_off_t _mi_kpos(uint nod_flag,uchar *after_key);
  425. extern void _mi_kpointer(MI_INFO *info,uchar *buff,my_off_t pos);
  426. extern my_off_t _mi_dpos(MI_INFO *info, uint nod_flag,uchar *after_key);
  427. extern my_off_t _mi_rec_pos(MYISAM_SHARE *info, uchar *ptr);
  428. extern void _mi_dpointer(MI_INFO *info, uchar *buff,my_off_t pos);
  429. extern int _mi_key_cmp(MI_KEYSEG *keyseg, uchar *a,uchar *b,
  430.        uint key_length,uint nextflag,uint *diff_length);
  431. extern uint _mi_get_static_key(MI_KEYDEF *keyinfo,uint nod_flag,uchar * *page,
  432.        uchar *key);
  433. extern uint _mi_get_pack_key(MI_KEYDEF *keyinfo,uint nod_flag,uchar * *page,
  434.      uchar *key);
  435. extern uint _mi_get_binary_pack_key(MI_KEYDEF *keyinfo, uint nod_flag,
  436.     uchar **page_pos, uchar *key);
  437. extern uchar *_mi_get_last_key(MI_INFO *info,MI_KEYDEF *keyinfo,uchar *keypos,
  438.        uchar *lastkey,uchar *endpos,
  439.        uint *return_key_length);
  440. extern uchar *_mi_get_key(MI_INFO *info, MI_KEYDEF *keyinfo, uchar *page,
  441.   uchar *key, uchar *keypos, uint *return_key_length);
  442. extern uint _mi_keylength(MI_KEYDEF *keyinfo,uchar *key);
  443. extern uchar *_mi_move_key(MI_KEYDEF *keyinfo,uchar *to,uchar *from);
  444. extern int _mi_search_next(MI_INFO *info,MI_KEYDEF *keyinfo,uchar *key,
  445.    uint key_length,uint nextflag,my_off_t pos);
  446. extern int _mi_search_first(MI_INFO *info,MI_KEYDEF *keyinfo,my_off_t pos);
  447. extern int _mi_search_last(MI_INFO *info,MI_KEYDEF *keyinfo,my_off_t pos);
  448. extern uchar *_mi_fetch_keypage(MI_INFO *info,MI_KEYDEF *keyinfo,my_off_t page,
  449. uchar *buff,int return_buffer);
  450. extern int _mi_write_keypage(MI_INFO *info,MI_KEYDEF *keyinfo,my_off_t page,
  451.      uchar *buff);
  452. extern int _mi_dispose(MI_INFO *info,MI_KEYDEF *keyinfo,my_off_t pos);
  453. extern my_off_t _mi_new(MI_INFO *info,MI_KEYDEF *keyinfo);
  454. extern uint _mi_make_key(MI_INFO *info,uint keynr,uchar *key,
  455.  const byte *record,my_off_t filepos);
  456. extern uint _mi_pack_key(MI_INFO *info,uint keynr,uchar *key,uchar *old,
  457.  uint key_length);
  458. extern int _mi_read_key_record(MI_INFO *info,my_off_t filepos,byte *buf);
  459. extern int _mi_read_cache(IO_CACHE *info,byte *buff,my_off_t pos,
  460.   uint length,int re_read_if_possibly);
  461. extern void update_auto_increment(MI_INFO *info,const byte *record);
  462. extern byte *mi_fix_rec_buff_for_blob(MI_INFO *info,ulong blob_length);
  463. extern ulong _mi_rec_unpack(MI_INFO *info,byte *to,byte *from,
  464.     ulong reclength);
  465. extern my_bool _mi_rec_check(MI_INFO *info,const char *from);
  466. extern int _mi_write_part_record(MI_INFO *info,my_off_t filepos,ulong length,
  467.  my_off_t next_filepos,byte **record,
  468.  ulong *reclength,int *flag);
  469. extern void _mi_print_key(FILE *stream,MI_KEYSEG *keyseg,const uchar *key,
  470.   uint length);
  471. extern my_bool _mi_read_pack_info(MI_INFO *info,pbool fix_keys);
  472. extern int _mi_read_pack_record(MI_INFO *info,my_off_t filepos,byte *buf);
  473. extern int _mi_read_rnd_pack_record(MI_INFO*, byte *,my_off_t, my_bool);
  474. extern int _mi_pack_rec_unpack(MI_INFO *info,byte *to,byte *from,
  475.        ulong reclength);
  476. extern ulonglong mi_safe_mul(ulonglong a,ulonglong b);
  477. struct st_sort_info;
  478. typedef struct st_mi_block_info { /* Parameter to _mi_get_block_info */
  479.   uchar header[MI_BLOCK_INFO_HEADER_LENGTH];
  480.   ulong rec_len;
  481.   ulong data_len;
  482.   ulong block_len;
  483.   ulong blob_len;
  484.   my_off_t filepos;
  485.   my_off_t next_filepos;
  486.   my_off_t prev_filepos;
  487.   uint second_read;
  488.   uint offset;
  489. } MI_BLOCK_INFO;
  490. /* bits in return from _mi_get_block_info */
  491. #define BLOCK_FIRST 1
  492. #define BLOCK_LAST 2
  493. #define BLOCK_DELETED 4
  494. #define BLOCK_ERROR 8 /* Wrong data */
  495. #define BLOCK_SYNC_ERROR 16 /* Right data at wrong place */
  496. #define BLOCK_FATAL_ERROR 32 /* hardware-error */
  497. #define NEAD_MEM ((uint) 10*4*(IO_SIZE+32)+32) /* Nead for recursion */
  498. #define MAXERR 20
  499. #define BUFFERS_WHEN_SORTING 16 /* Alloc for sort-key-tree */
  500. #define WRITE_COUNT MY_HOW_OFTEN_TO_WRITE
  501. #define INDEX_TMP_EXT ".TMM"
  502. #define DATA_TMP_EXT ".TMD"
  503. #define UPDATE_TIME 1
  504. #define UPDATE_STAT 2
  505. #define UPDATE_SORT 4
  506. #define UPDATE_AUTO_INC 8
  507. #define UPDATE_OPEN_COUNT 16
  508. #define USE_BUFFER_INIT (((1024L*512L-MALLOC_OVERHEAD)/IO_SIZE)*IO_SIZE)
  509. #define READ_BUFFER_INIT (1024L*256L-MALLOC_OVERHEAD)
  510. #define SORT_BUFFER_INIT (2048L*1024L-MALLOC_OVERHEAD)
  511. #define MIN_SORT_BUFFER (4096-MALLOC_OVERHEAD)
  512. enum myisam_log_commands {
  513.   MI_LOG_OPEN,MI_LOG_WRITE,MI_LOG_UPDATE,MI_LOG_DELETE,MI_LOG_CLOSE,MI_LOG_EXTRA,MI_LOG_LOCK,MI_LOG_DELETE_ALL
  514. };
  515. #define myisam_log(a,b,c,d) if (myisam_log_file >= 0) _myisam_log(a,b,c,d)
  516. #define myisam_log_command(a,b,c,d,e) if (myisam_log_file >= 0) _myisam_log_command(a,b,c,d,e)
  517. #define myisam_log_record(a,b,c,d,e) if (myisam_log_file >= 0) _myisam_log_record(a,b,c,d,e)
  518. #ifdef __cplusplus
  519. extern "C" {
  520. #endif
  521. extern uint _mi_get_block_info(MI_BLOCK_INFO *,File, my_off_t);
  522. extern uint _mi_rec_pack(MI_INFO *info,byte *to,const byte *from);
  523. extern uint _mi_pack_get_block_info(MI_INFO *mysql, MI_BLOCK_INFO *, File,
  524.     my_off_t, char *rec_buf);
  525. extern void _my_store_blob_length(byte *pos,uint pack_length,uint length);
  526. extern void _myisam_log(enum myisam_log_commands command,MI_INFO *info,
  527.        const byte *buffert,uint length);
  528. extern void _myisam_log_command(enum myisam_log_commands command,
  529.        MI_INFO *info, const byte *buffert,
  530.        uint length, int result);
  531. extern void _myisam_log_record(enum myisam_log_commands command,MI_INFO *info,
  532.       const byte *record,my_off_t filepos,
  533.       int result);
  534. extern my_bool _mi_memmap_file(MI_INFO *info);
  535. extern void _mi_unmap_file(MI_INFO *info);
  536. extern uint save_pack_length(byte *block_buff,ulong length);
  537. uint mi_state_info_write(File file, MI_STATE_INFO *state, uint pWrite);
  538. char *mi_state_info_read(char *ptr, MI_STATE_INFO *state);
  539. uint mi_state_info_read_dsk(File file, MI_STATE_INFO *state, my_bool pRead);
  540. uint mi_base_info_write(File file, MI_BASE_INFO *base);
  541. char *my_n_base_info_read(char *ptr, MI_BASE_INFO *base);
  542. int mi_keyseg_write(File file, const MI_KEYSEG *keyseg);
  543. char *mi_keyseg_read(char *ptr, MI_KEYSEG *keyseg);
  544. uint mi_keydef_write(File file, MI_KEYDEF *keydef);
  545. char *mi_keydef_read(char *ptr, MI_KEYDEF *keydef);
  546. uint mi_uniquedef_write(File file, MI_UNIQUEDEF *keydef);
  547. char *mi_uniquedef_read(char *ptr, MI_UNIQUEDEF *keydef);
  548. uint mi_recinfo_write(File file, MI_COLUMNDEF *recinfo);
  549. char *mi_recinfo_read(char *ptr, MI_COLUMNDEF *recinfo);
  550. ulong _my_calc_total_blob_length(MI_INFO *info, const byte *record);
  551. ha_checksum mi_checksum(MI_INFO *info, const byte *buf);
  552. ha_checksum mi_static_checksum(MI_INFO *info, const byte *buf);
  553. my_bool mi_check_unique(MI_INFO *info, MI_UNIQUEDEF *def, byte *record,
  554.      ha_checksum unique_hash, my_off_t pos);
  555. ha_checksum mi_unique_hash(MI_UNIQUEDEF *def, const byte *buf);
  556. int _mi_cmp_static_unique(MI_INFO *info, MI_UNIQUEDEF *def,
  557.    const byte *record, my_off_t pos);
  558. int _mi_cmp_dynamic_unique(MI_INFO *info, MI_UNIQUEDEF *def,
  559.    const byte *record, my_off_t pos);
  560. int mi_unique_comp(MI_UNIQUEDEF *def, const byte *a, const byte *b,
  561.    my_bool null_are_equal);
  562. void mi_get_status(void* param);
  563. void mi_update_status(void* param);
  564. void mi_copy_status(void* to,void *from);
  565. my_bool mi_check_status(void* param);
  566. void mi_disable_non_unique_index(MI_INFO *info, ha_rows rows);
  567. int _mi_rkey(MI_INFO *info, byte *buf, int inx, const byte *key, uint key_len,
  568.      enum ha_rkey_function search_flag, bool raw_key);
  569. my_bool check_table_is_closed(const char *name, const char *where);
  570. int mi_open_datafile(MI_INFO *info, MYISAM_SHARE *share);
  571. int mi_open_keyfile(MYISAM_SHARE *share);
  572. /* Functions needed by mi_check */
  573. void mi_check_print_error _VARARGS((MI_CHECK *param, const char *fmt,...));
  574. void mi_check_print_warning _VARARGS((MI_CHECK *param, const char *fmt,...));
  575. void mi_check_print_info _VARARGS((MI_CHECK *param, const char *fmt,...));
  576. #ifdef __cplusplus
  577. }
  578. #endif