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

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. /* L{ser och skriver nyckelblock */
  14. #include "isamdef.h"
  15. #ifdef __WIN__
  16. #include <errno.h>
  17. #endif
  18. /* Fetch a key-page in memory */
  19. uchar *_nisam_fetch_keypage(register N_INFO *info, N_KEYDEF *keyinfo,
  20.     my_off_t page, uchar *buff, int return_buffer)
  21. {
  22.   uchar *tmp;
  23.   tmp=(uchar*) key_cache_read(dflt_key_cache,
  24.                               info->s->kfile,page,DFLT_INIT_HITS,(byte*) buff,
  25.       (uint) keyinfo->base.block_length,
  26.       (uint) keyinfo->base.block_length,
  27.       return_buffer);
  28.   if (tmp == info->buff)
  29.   {
  30.     info->update|=HA_STATE_BUFF_SAVED;
  31.     info->int_pos=(ulong) page;
  32.     info->buff_used=1;
  33.   }
  34.   else
  35.   {
  36.     info->update&= ~HA_STATE_BUFF_SAVED;
  37.     if (tmp)
  38.       info->int_pos=(ulong) page;
  39.     else
  40.     {
  41.       info->int_pos=NI_POS_ERROR;
  42.       DBUG_PRINT("error",("Got errno: %d from key_cache_read",my_errno));
  43.       my_errno=HA_ERR_CRASHED;
  44.     }
  45.   }
  46.   return tmp;
  47. } /* _nisam_fetch_keypage */
  48. /* Write a key-page on disk */
  49. int _nisam_write_keypage(register N_INFO *info, register N_KEYDEF *keyinfo,
  50.       my_off_t page, uchar *buff)
  51. {
  52.   reg3 uint length;
  53. #ifndef QQ /* Safety check */
  54.   if (page < info->s->base.keystart ||
  55.       page+keyinfo->base.block_length > info->s->state.key_file_length ||
  56.       page & (nisam_block_size-1))
  57.   {
  58.     DBUG_PRINT("error",("Trying to write outside key region: %lu",
  59. (long) page));
  60.     my_errno=EINVAL;
  61.     return(-1);
  62.   }
  63.   DBUG_PRINT("page",("write page at: %lu",(long) page,buff));
  64.   DBUG_DUMP("buff",(byte*) buff,getint(buff));
  65. #endif
  66.   if ((length=keyinfo->base.block_length) > IO_SIZE*2 &&
  67.        info->s->state.key_file_length != page+length)
  68.     length= ((getint(buff)+IO_SIZE-1) & (uint) ~(IO_SIZE-1));
  69. #ifdef HAVE_purify
  70.   {
  71.     length=getint(buff);
  72.     bzero((byte*) buff+length,keyinfo->base.block_length-length);
  73.     length=keyinfo->base.block_length;
  74.   }
  75. #endif
  76.   return (key_cache_write(dflt_key_cache,
  77.                           info->s->kfile,page,DFLT_INIT_HITS,
  78.                           (byte*) buff,length,
  79.   (uint) keyinfo->base.block_length,
  80.   (int) (info->lock_type != F_UNLCK)));
  81. } /* nisam_write_keypage */
  82. /* Remove page from disk */
  83. int _nisam_dispose(register N_INFO *info, N_KEYDEF *keyinfo, my_off_t pos)
  84. {
  85.   uint keynr= (uint) (keyinfo - info->s->keyinfo);
  86.   ulong old_link; /* ulong is ok here */
  87.   DBUG_ENTER("_nisam_dispose");
  88.   old_link=info->s->state.key_del[keynr];
  89.   info->s->state.key_del[keynr]=(ulong) pos;
  90.   DBUG_RETURN(key_cache_write(dflt_key_cache,
  91.                               info->s->kfile,pos,DFLT_INIT_HITS,
  92.                               (byte*) &old_link,
  93.       sizeof(long),
  94.       (uint) keyinfo->base.block_length,
  95.       (int) (info->lock_type != F_UNLCK)));
  96. } /* _nisam_dispose */
  97. /* Make new page on disk */
  98. ulong _nisam_new(register N_INFO *info, N_KEYDEF *keyinfo)
  99. {
  100.   uint keynr= (uint) (keyinfo - info->s->keyinfo);
  101.   ulong pos;
  102.   DBUG_ENTER("_nisam_new");
  103.   if ((pos=info->s->state.key_del[keynr]) == NI_POS_ERROR)
  104.   {
  105.     if (info->s->state.key_file_length >= info->s->base.max_key_file_length)
  106.     {
  107.       my_errno=HA_ERR_INDEX_FILE_FULL;
  108.       DBUG_RETURN(NI_POS_ERROR);
  109.     }
  110.     pos=info->s->state.key_file_length;
  111.     info->s->state.key_file_length+= keyinfo->base.block_length;
  112.   }
  113.   else
  114.   {
  115.     if (!key_cache_read(dflt_key_cache,
  116.                         info->s->kfile,pos,DFLT_INIT_HITS,
  117. (byte*) &info->s->state.key_del[keynr],
  118. (uint) sizeof(long),
  119. (uint) keyinfo->base.block_length,0))
  120.       pos= NI_POS_ERROR;
  121.   }
  122.   DBUG_PRINT("exit",("Pos: %d",pos));
  123.   DBUG_RETURN(pos);
  124. } /* _nisam_new */