home *** CD-ROM | disk | FTP | other *** search
/ Chip 2001 January / Chip_2001-01_cd1.bin / tema / mysql / mysql-3.23.28g-win-source.exe / mysys / mf_iocache2.c < prev    next >
C/C++ Source or Header  |  2000-11-17  |  6KB  |  219 lines
  1. /* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
  2.    
  3.    This library is free software; you can redistribute it and/or
  4.    modify it under the terms of the GNU Library General Public
  5.    License as published by the Free Software Foundation; either
  6.    version 2 of the License, or (at your option) any later version.
  7.    
  8.    This library 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 GNU
  11.    Library General Public License for more details.
  12.    
  13.    You should have received a copy of the GNU Library General Public
  14.    License along with this library; if not, write to the Free
  15.    Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
  16.    MA 02111-1307, USA */
  17.  
  18. /*
  19.   More functions to be used with IO_CACHE files
  20. */
  21.  
  22. #define MAP_TO_USE_RAID
  23. #include "mysys_priv.h"
  24. #include <m_string.h>
  25. #include <stdarg.h>
  26. #include <m_ctype.h>
  27.  
  28. /*
  29. ** Fix that next read will be made at certain position
  30. ** This only works with READ_CACHE
  31. */
  32.  
  33. void my_b_seek(IO_CACHE *info,my_off_t pos)
  34. {
  35.   info->seek_not_done=1;
  36.   info->pos_in_file=pos;
  37.   info->rc_pos=info->rc_end=info->buffer;
  38. }
  39.  
  40. /*
  41. **  Fill buffer
  42. **  return:  0 on error or EOF (info->error = -1 on error)
  43. **           number of characters
  44. */
  45.  
  46. uint my_b_fill(IO_CACHE *info)
  47. {
  48.   my_off_t pos_in_file=info->pos_in_file+(uint) (info->rc_end - info->buffer);
  49.   my_off_t max_length;
  50.   uint diff_length,length;
  51.   if (info->seek_not_done)
  52.   {                    /* File touched, do seek */
  53.     if (my_seek(info->file,pos_in_file,MY_SEEK_SET,MYF(0)) ==
  54.     MY_FILEPOS_ERROR)
  55.     {
  56.       info->error= 0;
  57.       return 0;
  58.     }
  59.     info->seek_not_done=0;
  60.   }
  61.   diff_length=(uint) (pos_in_file & (IO_SIZE-1));
  62.   max_length= (my_off_t) (info->end_of_file - pos_in_file);
  63.   if (max_length > (my_off_t) (info->read_length-diff_length))
  64.     max_length=(my_off_t) (info->read_length-diff_length);
  65.   if (!max_length)
  66.   {
  67.     info->error= 0;
  68.     return 0;                    /* EOF */
  69.   }
  70.    else if ((length=my_read(info->file,info->buffer,(uint) max_length,
  71.                info->myflags)) == (uint) -1)
  72.   {
  73.     info->error= -1;
  74.     return 0;
  75.   }
  76.   info->rc_pos=info->buffer;
  77.   info->rc_end=info->buffer+length;
  78.   info->pos_in_file=pos_in_file;
  79.   return length;
  80. }
  81.  
  82. /*
  83. ** Read a string ended by '\n' into a buffer of 'max_length' size.
  84. ** Returns number of characters read, 0 on error.
  85. ** last byte is set to '\0'
  86. */
  87.  
  88. uint my_b_gets(IO_CACHE *info, char *to, uint max_length)
  89. {
  90.   uint length;
  91.   max_length--;                    /* Save place for end \0 */
  92.   /* Calculate number of characters in buffer */
  93.   if (!(length= (uint) (info->rc_end - info->rc_pos)))
  94.     if (!(length=my_b_fill(info)))
  95.       return 0;
  96.   for (;;)
  97.   {
  98.     char *pos,*end;
  99.     if (length > max_length)
  100.       length=max_length;
  101.     for (pos=info->rc_pos,end=pos+length ; pos < end ;)
  102.     {
  103.       if ((*to++ = *pos++) == '\n')
  104.       {
  105.     length= (uint) (pos-info->rc_pos);
  106.     info->rc_pos=pos;
  107.     *to='\0';
  108.     return length;
  109.       }
  110.     }
  111.     if (!(max_length-=length))
  112.     {
  113.      /* Found enough charcters;  Return found string */
  114.       info->rc_pos=pos;
  115.       *to='\0';
  116.       return length;
  117.     }
  118.     if (!(length=my_b_fill(info)))
  119.       return 0;
  120.   }
  121. }
  122.  
  123. /*
  124.   Simple printf version.  Supports '%s', '%d', '%u', "%ld" and "%lu"
  125.   Used for logging in MySQL
  126.   returns number of written character, or (uint) -1 on error
  127. */
  128.  
  129. uint my_b_printf(IO_CACHE *info, const char* fmt, ...)
  130. {
  131.   int result;
  132.   va_list args;
  133.   va_start(args,fmt);
  134.   result=my_b_vprintf(info, fmt, args);
  135.   va_end(args);
  136.   return result;
  137. }
  138.  
  139.  
  140. uint my_b_vprintf(IO_CACHE *info, const char* fmt, va_list args)
  141. {
  142.   reg1 char *to= info->rc_pos;
  143.   char *end=info->rc_end;
  144.   uint out_length=0;
  145.  
  146.   for (; *fmt ; fmt++)
  147.   {
  148.     if (*fmt++ != '%')
  149.     {
  150.       /* Copy everything until '%' or end of string */
  151.       const char *start=fmt-1;
  152.       uint length;
  153.       for (; *fmt && *fmt != '%' ; fmt++ ) ;
  154.       length= (uint) (fmt - start);
  155.       out_length+=length;
  156.       if (my_b_write(info, start, length))
  157.     goto err;
  158.       if (!*fmt)                /* End of format */
  159.       {
  160.     return out_length;
  161.       }
  162.       fmt++;
  163.       /* Found one '%' */
  164.     }
  165.     /* Skipp if max size is used (to be compatible with printf) */
  166.     while (isdigit(*fmt) || *fmt == '.' || *fmt == '-')
  167.       fmt++;
  168.     if (*fmt == 's')                /* String parameter */
  169.     {
  170.       reg2 char *par = va_arg(args, char *);
  171.       uint length = (uint) strlen(par);
  172.       out_length+=length;
  173.       if (my_b_write(info, par, length))
  174.     goto err;
  175.     }
  176.     else if (*fmt == 'd' || *fmt == 'u')    /* Integer parameter */
  177.     {
  178.       register int iarg;
  179.       uint length;
  180.       char buff[17];
  181.  
  182.       iarg = va_arg(args, int);
  183.       if (*fmt == 'd')
  184.     length= (uint) (int10_to_str((long) iarg,buff, -10) - buff);
  185.       else
  186.     length= (uint) (int10_to_str((long) (uint) iarg,buff,10)- buff);
  187.       out_length+=length;
  188.       if (my_b_write(info, buff, length))
  189.     goto err;
  190.     }
  191.     else if (*fmt == 'l' && fmt[1] == 'd' || fmt[1] == 'u')/* long parameter */
  192.     {
  193.       register long iarg;
  194.       uint length;
  195.       char buff[17];
  196.  
  197.       iarg = va_arg(args, long);
  198.       if (*++fmt == 'd')
  199.     length= (uint) (int10_to_str(iarg,buff, -10) - buff);
  200.       else
  201.     length= (uint) (int10_to_str(iarg,buff,10)- buff);
  202.       out_length+=length;
  203.       if (my_b_write(info, buff, length))
  204.     goto err;
  205.     }
  206.     else
  207.     {
  208.       /* %% or unknown code */
  209.       if (my_b_write(info, "%", 1))
  210.     goto err;
  211.       out_length++;
  212.     }
  213.   }
  214.   return out_length;
  215.  
  216. err:
  217.   return (uint) -1;
  218. }
  219.