home *** CD-ROM | disk | FTP | other *** search
/ Chip 2001 January / Chip_2001-01_cd1.bin / tema / mysql / mysql-3.23.28g-win-source.exe / myisammrg / myrg_open.c < prev    next >
C/C++ Source or Header  |  2000-09-21  |  4KB  |  153 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. /* open a MYMERGE_-database */
  18.  
  19. #include "mymrgdef.h"
  20. #include <stddef.h>
  21. #include <errno.h>
  22. #ifdef VMS
  23. #include "mrg_static.c"
  24. #endif
  25.  
  26. /*    open a MYMERGE_-database.
  27.  
  28.     if handle_locking is 0 then exit with error if some database is locked
  29.     if handle_locking is 1 then wait if database is locked
  30. */
  31.  
  32.  
  33. MYRG_INFO *myrg_open(name,mode,handle_locking)
  34. const char *name;
  35. int mode;
  36. int handle_locking;
  37. {
  38.   int save_errno,i,errpos;
  39.   uint files,dir_length;
  40.   ulonglong file_offset;
  41.   char name_buff[FN_REFLEN*2],buff[FN_REFLEN],*end;
  42.   MYRG_INFO info,*m_info;
  43.   FILE *file;
  44.   MI_INFO *isam,*last_isam;
  45.   DBUG_ENTER("myrg_open");
  46.  
  47.   LINT_INIT(last_isam);
  48.   isam=0;
  49.   errpos=files=0;
  50.   bzero((gptr) &info,sizeof(info));
  51.   if (!(file=my_fopen(fn_format(name_buff,name,"",MYRG_NAME_EXT,4),
  52.               O_RDONLY | O_SHARE,MYF(0))))
  53.     goto err;
  54.   errpos=1;
  55.   dir_length=dirname_part(name_buff,name);
  56.   info.reclength=0;
  57.   while (fgets(buff,FN_REFLEN-1,file))
  58.   {
  59.     if ((end=strend(buff))[-1] == '\n')
  60.       end[-1]='\0';
  61.     if (buff[0] && buff[0] != '#')    /* Skipp empty lines and comments */
  62.     {
  63.       last_isam=isam;
  64.       if (!test_if_hard_path(buff))
  65.       {
  66.     VOID(strmake(name_buff+dir_length,buff,
  67.              sizeof(name_buff)-1-dir_length));
  68.     VOID(cleanup_dirname(buff,name_buff));
  69.       }
  70.       if (!(isam=mi_open(buff,mode,test(handle_locking))))
  71.     goto err;
  72.       files++;
  73.     }
  74.     last_isam=isam;
  75.     if (info.reclength && info.reclength != isam->s->base.reclength)
  76.     {
  77.       my_errno=HA_ERR_WRONG_IN_RECORD;
  78.       goto err;
  79.     }
  80.     info.reclength=isam->s->base.reclength;
  81.   }
  82.   if (!(m_info= (MYRG_INFO*) my_malloc(sizeof(MYRG_INFO)+
  83.                        files*sizeof(MYRG_TABLE),
  84.                        MYF(MY_WME))))
  85.     goto err;
  86.   *m_info=info;
  87.   m_info->open_tables=(MYRG_TABLE *) (m_info+1);
  88.   m_info->tables=files;
  89.   errpos=2;
  90.  
  91.   for (i=files ; i-- > 0 ; )
  92.   {
  93.     m_info->open_tables[i].table=isam;
  94.     m_info->options|=isam->s->options;
  95.     m_info->records+=isam->state->records;
  96.     m_info->del+=isam->state->del;
  97.     m_info->data_file_length+=isam->state->data_file_length;
  98.     if (i)
  99.       isam=(MI_INFO*) (isam->open_list.next->data);
  100.   }
  101.   /* Fix fileinfo for easyer debugging (actually set by rrnd) */
  102.   file_offset=0;
  103.   for (i=0 ; (uint) i < files ; i++)
  104.   {
  105.     m_info->open_tables[i].file_offset=(my_off_t) file_offset;
  106.     file_offset+=m_info->open_tables[i].table->state->data_file_length;
  107.   }
  108.   if (sizeof(my_off_t) == 4 && file_offset > (ulonglong) (ulong) ~0L)
  109.   {
  110.     my_errno=HA_ERR_RECORD_FILE_FULL;
  111.     goto err;
  112.   }
  113.   /* Allocate memory for queue */
  114.   m_info->keys=0;
  115.   if (files)
  116.   {
  117.     if ((m_info->keys=m_info->open_tables->table->s->base.keys) &&
  118.     _myrg_init_queue(m_info,0,HA_READ_KEY_EXACT))
  119.       goto err;
  120.   }
  121.   else
  122.     bzero((char*) &m_info->by_key,sizeof(m_info->by_key));
  123.  
  124.   m_info->end_table=m_info->open_tables+files;
  125.   m_info->last_used_table=m_info->open_tables;
  126.  
  127.   VOID(my_fclose(file,MYF(0)));
  128.   m_info->open_list.data=(void*) m_info;
  129.   pthread_mutex_lock(&THR_LOCK_open);
  130.   myrg_open_list=list_add(myrg_open_list,&m_info->open_list);
  131.   pthread_mutex_unlock(&THR_LOCK_open);
  132.   DBUG_RETURN(m_info);
  133.  
  134. err:
  135.   save_errno=my_errno;
  136.   switch (errpos) {
  137.   case 2:
  138.     my_free((char*) m_info,MYF(0));
  139.     /* Fall through */
  140.   case 1:
  141.     VOID(my_fclose(file,MYF(0)));
  142.     for (i=files ; i-- > 0 ; )
  143.     {
  144.       isam=last_isam;
  145.       if (i)
  146.     last_isam=(MI_INFO*) (isam->open_list.next->data);
  147.       mi_close(isam);
  148.     }
  149.   }
  150.   my_errno=save_errno;
  151.   DBUG_RETURN (NULL);
  152. }
  153.