mi_page.c
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:5k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
  2.    This program is free software; you can redistribute it and/or modify
  3.    it under the terms of the GNU General Public License as published by
  4.    the Free Software Foundation; either version 2 of the License, or
  5.    (at your option) any later version.
  6.    This program is distributed in the hope that it will be useful,
  7.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  8.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  9.    GNU General Public License for more details.
  10.    You should have received a copy of the GNU General Public License
  11.    along with this program; if not, write to the Free Software
  12.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  13. /* Read and write key blocks */
  14. #include "myisamdef.h"
  15. /* Fetch a key-page in memory */
  16. uchar *_mi_fetch_keypage(register MI_INFO *info, MI_KEYDEF *keyinfo,
  17.  my_off_t page, int level, 
  18.                          uchar *buff, int return_buffer)
  19. {
  20.   uchar *tmp;
  21.   uint page_size;
  22.   DBUG_ENTER("_mi_fetch_keypage");
  23.   DBUG_PRINT("enter",("page: %ld",page));
  24.   tmp=(uchar*) key_cache_read(info->s->key_cache,
  25.                              info->s->kfile, page, level, (byte*) buff,
  26.      (uint) keyinfo->block_length,
  27.      (uint) keyinfo->block_length,
  28.      return_buffer);
  29.   if (tmp == info->buff)
  30.     info->buff_used=1;
  31.   else if (!tmp)
  32.   {
  33.     DBUG_PRINT("error",("Got errno: %d from key_cache_read",my_errno));
  34.     info->last_keypage=HA_OFFSET_ERROR;
  35.     my_errno=HA_ERR_CRASHED;
  36.     DBUG_RETURN(0);
  37.   }
  38.   info->last_keypage=page;
  39.   page_size=mi_getint(tmp);
  40.   if (page_size < 4 || page_size > keyinfo->block_length)
  41.   {
  42.     DBUG_PRINT("error",("page %lu had wrong page length: %u",
  43. (ulong) page, page_size));
  44.     DBUG_DUMP("page", (char*) tmp, keyinfo->block_length);
  45.     info->last_keypage = HA_OFFSET_ERROR;
  46.     my_errno = HA_ERR_CRASHED;
  47.     tmp = 0;
  48.   }
  49.   DBUG_RETURN(tmp);
  50. } /* _mi_fetch_keypage */
  51. /* Write a key-page on disk */
  52. int _mi_write_keypage(register MI_INFO *info, register MI_KEYDEF *keyinfo,
  53.       my_off_t page, int level, uchar *buff)
  54. {
  55.   reg3 uint length;
  56.   DBUG_ENTER("_mi_write_keypage");
  57. #ifndef FAST /* Safety check */
  58.   if (page < info->s->base.keystart ||
  59.       page+keyinfo->block_length > info->state->key_file_length ||
  60.       (page & (MI_MIN_KEY_BLOCK_LENGTH-1)))
  61.   {
  62.     DBUG_PRINT("error",("Trying to write inside key status region: key_start: %lu  length: %lu  page: %lu",
  63. (long) info->s->base.keystart,
  64. (long) info->state->key_file_length,
  65. (long) page));
  66.     my_errno=EINVAL;
  67.     DBUG_RETURN((-1));
  68.   }
  69.   DBUG_PRINT("page",("write page at: %lu",(long) page,buff));
  70.   DBUG_DUMP("buff",(byte*) buff,mi_getint(buff));
  71. #endif
  72.   if ((length=keyinfo->block_length) > IO_SIZE*2 &&
  73.       info->state->key_file_length != page+length)
  74.     length= ((mi_getint(buff)+IO_SIZE-1) & (uint) ~(IO_SIZE-1));
  75. #ifdef HAVE_purify
  76.   {
  77.     length=mi_getint(buff);
  78.     bzero((byte*) buff+length,keyinfo->block_length-length);
  79.     length=keyinfo->block_length;
  80.   }
  81. #endif
  82.   DBUG_RETURN((key_cache_write(info->s->key_cache,
  83.                          info->s->kfile,page, level, (byte*) buff,length,
  84.  (uint) keyinfo->block_length,
  85.  (int) ((info->lock_type != F_UNLCK) ||
  86. info->s->delay_key_write))));
  87. } /* mi_write_keypage */
  88. /* Remove page from disk */
  89. int _mi_dispose(register MI_INFO *info, MI_KEYDEF *keyinfo, my_off_t pos,
  90.                 int level)
  91. {
  92.   my_off_t old_link;
  93.   char buff[8];
  94.   DBUG_ENTER("_mi_dispose");
  95.   DBUG_PRINT("enter",("pos: %ld", (long) pos));
  96.   old_link=info->s->state.key_del[keyinfo->block_size];
  97.   info->s->state.key_del[keyinfo->block_size]=pos;
  98.   mi_sizestore(buff,old_link);
  99.   info->s->state.changed|= STATE_NOT_SORTED_PAGES;
  100.   DBUG_RETURN(key_cache_write(info->s->key_cache,
  101.                               info->s->kfile, pos , level, buff,
  102.       sizeof(buff),
  103.       (uint) keyinfo->block_length,
  104.       (int) (info->lock_type != F_UNLCK)));
  105. } /* _mi_dispose */
  106. /* Make new page on disk */
  107. my_off_t _mi_new(register MI_INFO *info, MI_KEYDEF *keyinfo, int level)
  108. {
  109.   my_off_t pos;
  110.   char buff[8];
  111.   DBUG_ENTER("_mi_new");
  112.   if ((pos=info->s->state.key_del[keyinfo->block_size]) == HA_OFFSET_ERROR)
  113.   {
  114.     if (info->state->key_file_length >=
  115. info->s->base.max_key_file_length - keyinfo->block_length)
  116.     {
  117.       my_errno=HA_ERR_INDEX_FILE_FULL;
  118.       DBUG_RETURN(HA_OFFSET_ERROR);
  119.     }
  120.     pos=info->state->key_file_length;
  121.     info->state->key_file_length+= keyinfo->block_length;
  122.   }
  123.   else
  124.   {
  125.     if (!key_cache_read(info->s->key_cache,
  126.                         info->s->kfile, pos, level,
  127. buff,
  128. (uint) sizeof(buff),
  129. (uint) keyinfo->block_length,0))
  130.       pos= HA_OFFSET_ERROR;
  131.     else
  132.       info->s->state.key_del[keyinfo->block_size]=mi_sizekorr(buff);
  133.   }
  134.   info->s->state.changed|= STATE_NOT_SORTED_PAGES;
  135.   DBUG_PRINT("exit",("Pos: %ld",(long) pos));
  136.   DBUG_RETURN(pos);
  137. } /* _mi_new */