home *** CD-ROM | disk | FTP | other *** search
/ Chip 2001 January / Chip_2001-01_cd1.bin / tema / mysql / mysql-3.23.28g-win-source.exe / isam / _statrec.c < prev    next >
C/C++ Source or Header  |  2000-08-31  |  8KB  |  266 lines
  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.  
  17.     /* Functions to handle fixed-length-records */
  18.  
  19. #include "isamdef.h"
  20.  
  21.  
  22. int _nisam_write_static_record(N_INFO *info, const byte *record)
  23. {
  24.   uchar temp[4];                /* Not sizeof(long) */
  25.  
  26.   if (info->s->state.dellink != NI_POS_ERROR)
  27.   {
  28.     ulong filepos=info->s->state.dellink;
  29.     info->rec_cache.seek_not_done=1;        /* We have done a seek */
  30.     VOID(my_seek(info->dfile,info->s->state.dellink+1,MY_SEEK_SET,MYF(0)));
  31.  
  32.     if (my_read(info->dfile,(char*) &temp[0],sizeof(temp), MYF(MY_NABP)))
  33.       goto err;
  34.     info->s->state.dellink=uint4korr(temp);
  35.     if (info->s->state.dellink == (uint32) ~0)    /* Fix for 64 bit long */
  36.       info->s->state.dellink=NI_POS_ERROR;
  37.     info->s->state.del--;
  38.     info->s->state.empty-=info->s->base.reclength;
  39.     VOID(my_seek(info->dfile,filepos,MY_SEEK_SET,MYF(0)));
  40.     if (my_write(info->dfile, (char*) record, info->s->base.reclength,
  41.          MYF(MY_NABP)))
  42.       goto err;
  43.   }
  44.   else
  45.   {
  46.     if (info->s->state.data_file_length > info->s->base.max_data_file_length)
  47.     {
  48.       my_errno=HA_ERR_RECORD_FILE_FULL;
  49.       return(2);
  50.     }
  51.     if (info->opt_flag & WRITE_CACHE_USED)
  52.     {                /* Cash in use */
  53.       if (my_b_write(&info->rec_cache, (byte*) record, info->s->base.reclength))
  54.     goto err;
  55.     }
  56.     else
  57.     {
  58.       info->rec_cache.seek_not_done=1;        /* We have done a seek */
  59.       VOID(my_seek(info->dfile,info->s->state.data_file_length,
  60.            MY_SEEK_SET,MYF(0)));
  61.       if (my_write(info->dfile,(char*) record,info->s->base.reclength,
  62.            MYF(MY_NABP | MY_WAIT_IF_FULL)))
  63.     goto err;
  64.     }
  65.     info->s->state.data_file_length+=info->s->base.reclength;
  66.     info->s->state.splitt++;
  67.   }
  68.   return 0;
  69.  err:
  70.   return 1;
  71. }
  72.  
  73. int _nisam_update_static_record(N_INFO *info, ulong pos, const byte *record)
  74. {
  75.   info->rec_cache.seek_not_done=1;        /* We have done a seek */
  76.   VOID(my_seek(info->dfile,pos,MY_SEEK_SET,MYF(0)));
  77.   return (my_write(info->dfile,(char*) record,info->s->base.reclength,
  78.            MYF(MY_NABP)) != 0);
  79. }
  80.  
  81.  
  82. int _nisam_delete_static_record(N_INFO *info)
  83. {
  84.   uchar temp[5];                /* 1+sizeof(uint32) */
  85.  
  86.   info->s->state.del++;
  87.   info->s->state.empty+=info->s->base.reclength;
  88.   temp[0]= '\0';            /* Mark that record is deleted */
  89.   int4store(temp+1,info->s->state.dellink);
  90.   info->s->state.dellink = info->lastpos;
  91.   info->rec_cache.seek_not_done=1;
  92.   VOID(my_seek(info->dfile,info->lastpos,MY_SEEK_SET,MYF(0)));
  93.   return (my_write(info->dfile,(byte*) temp,(uint) sizeof(temp),
  94.            MYF(MY_NABP)) != 0);
  95. }
  96.  
  97.  
  98. int _nisam_cmp_static_record(register N_INFO *info, register const byte *old)
  99. {
  100.   DBUG_ENTER("_nisam_rectest");
  101.  
  102.   /* We are going to do changes; dont let anybody disturb */
  103.   dont_break();                /* Dont allow SIGHUP or SIGINT */
  104.  
  105.   if (info->opt_flag & WRITE_CACHE_USED)
  106.   {
  107.     if (flush_io_cache(&info->rec_cache))
  108.     {
  109.       DBUG_RETURN(-1);
  110.     }
  111.     info->rec_cache.seek_not_done=1;        /* We have done a seek */
  112.   }
  113.  
  114.   if ((info->opt_flag & READ_CHECK_USED))
  115.   {                        /* If check isn't disabled  */
  116.     info->rec_cache.seek_not_done=1;        /* We have done a seek */
  117.     VOID(my_seek(info->dfile,info->lastpos,MY_SEEK_SET,MYF(0)));
  118.     if (my_read(info->dfile, (char*) info->rec_buff, info->s->base.reclength,
  119.         MYF(MY_NABP)))
  120.       DBUG_RETURN(-1);
  121.     if (memcmp((byte*) info->rec_buff, (byte*) old,
  122.            (uint) info->s->base.reclength))
  123.     {
  124.       DBUG_DUMP("read",old,info->s->base.reclength);
  125.       DBUG_DUMP("disk",info->rec_buff,info->s->base.reclength);
  126.       my_errno=HA_ERR_RECORD_CHANGED;        /* Record have changed */
  127.       DBUG_RETURN(1);
  128.     }
  129.   }
  130.   DBUG_RETURN(0);
  131. }
  132.  
  133.     /* Read a fixed-length-record */
  134.     /* Returns 0 if Ok. */
  135.     /*       1 if record is deleted */
  136.     /*      MY_FILE_ERROR on read-error or locking-error */
  137.  
  138. int _nisam_read_static_record(register N_INFO *info, register ulong pos,
  139.                register byte *record)
  140. {
  141.   int error;
  142.  
  143.   if (pos != NI_POS_ERROR)
  144.   {
  145.     if (info->opt_flag & WRITE_CACHE_USED &&
  146.     info->rec_cache.pos_in_file <= pos &&
  147.     flush_io_cache(&info->rec_cache))
  148.       return(-1);
  149.     info->rec_cache.seek_not_done=1;    /* We have done a seek */
  150.  
  151.     error=my_pread(info->dfile,(char*) record,info->s->base.reclength,
  152.            pos,MYF(MY_NABP)) != 0;
  153.     if (info->s->r_locks == 0 && info->s->w_locks == 0)
  154.       VOID(_nisam_writeinfo(info,0));
  155.     if (! error)
  156.     {
  157.       if (!*record) return(1);        /* Record is deleted */
  158.       info->update|= HA_STATE_AKTIV;    /* Record is read */
  159.       my_errno=HA_ERR_RECORD_DELETED;
  160.       return(0);
  161.     }
  162.     return(-1);                /* Error on read */
  163.   }
  164.   VOID(_nisam_writeinfo(info,0));    /* No such record */
  165.   return(-1);
  166. } /* _nisam_read_record */
  167.  
  168.  
  169. int _nisam_read_rnd_static_record(N_INFO *info, byte *buf,
  170.                   register ulong filepos,
  171.                   int skipp_deleted_blocks)
  172. {
  173.   int locked,error,cache_read;
  174.   uint cache_length;
  175.   ISAM_SHARE *share=info->s;
  176.   DBUG_ENTER("_nisam_read_rnd_static_record");
  177.  
  178.   cache_read=0;
  179.   LINT_INIT(cache_length);
  180.   if (info->opt_flag & WRITE_CACHE_USED &&
  181.       (info->rec_cache.pos_in_file <= filepos || skipp_deleted_blocks) &&
  182.       flush_io_cache(&info->rec_cache))
  183.     DBUG_RETURN(-1);
  184.   if (info->opt_flag & READ_CACHE_USED)
  185.   {                        /* Cash in use */
  186.     if (filepos == my_b_tell(&info->rec_cache) &&
  187.     (skipp_deleted_blocks || !filepos))
  188.     {
  189.       cache_read=1;                /* Read record using cache */
  190.       cache_length=(uint) (info->rec_cache.rc_end - info->rec_cache.rc_pos);
  191.     }
  192.     else
  193.       info->rec_cache.seek_not_done=1;        /* Filepos is changed */
  194.   }
  195. #ifndef NO_LOCKING
  196.   locked=0;
  197.   if (info->lock_type == F_UNLCK)
  198.   {
  199.     if (filepos >= share->state.data_file_length)
  200.     {                        /* Test if new records */
  201.       if (_nisam_readinfo(info,F_RDLCK,0))
  202.     DBUG_RETURN(-1);
  203.       locked=1;
  204.     }
  205.     else
  206.     {                        /* We don't nead new info */
  207. #ifndef UNSAFE_LOCKING
  208.       if ((! cache_read || share->base.reclength > cache_length) &&
  209.       share->r_locks == 0 && share->w_locks == 0)
  210.       {                        /* record not in cache */
  211.     if (my_lock(share->kfile,F_RDLCK,0L,F_TO_EOF,
  212.             MYF(MY_SEEK_NOT_DONE) | info->lock_wait))
  213.       DBUG_RETURN(-1);
  214.     locked=1;
  215.       }
  216. #else
  217.       info->tmp_lock_type=F_RDLCK;
  218. #endif
  219.     }
  220.   }
  221. #endif
  222.   if (filepos >= share->state.data_file_length)
  223.   {
  224. #ifndef NO_LOCKING
  225.     DBUG_PRINT("test",("filepos: %ld (%ld)  records: %ld  del: %ld",
  226.                filepos/share->base.reclength,filepos,
  227.                share->state.records, share->state.del));
  228.     VOID(_nisam_writeinfo(info,0));
  229. #endif
  230.     my_errno=HA_ERR_END_OF_FILE;
  231.     DBUG_RETURN(-1);
  232.   }
  233.   info->lastpos= filepos;
  234.   info->nextpos= filepos+share->base.reclength;
  235.  
  236.   if (! cache_read)            /* No cacheing */
  237.   {
  238.     error=_nisam_read_static_record(info,filepos,buf);
  239.     if (error > 0)
  240.       my_errno=HA_ERR_RECORD_DELETED;
  241.     DBUG_RETURN(error);
  242.   }
  243.  
  244.     /* Read record with cacheing */
  245.   error=my_b_read(&info->rec_cache,(byte*) buf,share->base.reclength);
  246.  
  247. #ifndef NO_LOCKING
  248.   if (locked)
  249.     VOID(_nisam_writeinfo(info,0));        /* Unlock keyfile */
  250. #endif
  251.   if (!error)
  252.   {
  253.     if (!buf[0])
  254.     {                        /* Record is removed */
  255.       my_errno=HA_ERR_RECORD_DELETED;
  256.       DBUG_RETURN(1);
  257.     }
  258.                         /* Found and may be updated */
  259.     info->update|= HA_STATE_AKTIV | HA_STATE_KEY_CHANGED;
  260.     DBUG_RETURN(0);
  261.   }
  262.   if (info->rec_cache.error != -1 || my_errno == 0)
  263.     my_errno=HA_ERR_WRONG_IN_RECORD;
  264.   DBUG_RETURN(-1);                /* Something wrong (EOF?) */
  265. }
  266.