mrg_open.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. /* open a MERGE-database */
  14. #include "mrg_def.h"
  15. #include <stddef.h>
  16. #include <errno.h>
  17. #ifdef VMS
  18. #include "static.c"
  19. #endif
  20. /* open a MERGE-database.
  21. if handle_locking is 0 then exit with error if some database is locked
  22. if handle_locking is 1 then wait if database is locked
  23. */
  24. MRG_INFO *mrg_open(
  25. const char *name,
  26. int mode,
  27. int handle_locking)
  28. {
  29.   int save_errno,i,errpos;
  30.   uint files,dir_length,length, options;
  31.   ulonglong file_offset;
  32.   char name_buff[FN_REFLEN*2],buff[FN_REFLEN],*end;
  33.   MRG_INFO info,*m_info;
  34.   File fd;
  35.   IO_CACHE file;
  36.   N_INFO *isam,*last_isam;
  37.   DBUG_ENTER("mrg_open");
  38.   LINT_INIT(last_isam);
  39.   isam=0;
  40.   errpos=files=0;
  41.   bzero((gptr) &info,sizeof(info));
  42.   bzero((char*) &file,sizeof(file));
  43.   if ((fd=my_open(fn_format(name_buff,name,"",MRG_NAME_EXT,4),
  44.   O_RDONLY | O_SHARE,MYF(0))) < 0 ||
  45.       init_io_cache(&file, fd, IO_SIZE, READ_CACHE, 0, 0,
  46.     MYF(MY_WME | MY_NABP)))
  47.     goto err;
  48.   errpos=1;
  49.   dir_length=dirname_part(name_buff,name);
  50.   info.reclength=0;
  51.   while ((length=my_b_gets(&file,buff,FN_REFLEN-1)))
  52.   {
  53.     if ((end=buff+length)[-1] == 'n')
  54.       end[-1]='';
  55.     if (buff[0] && buff[0] != '#') /* Skip empty lines and comments */
  56.     {
  57.       last_isam=isam;
  58.       if (!test_if_hard_path(buff))
  59.       {
  60. VOID(strmake(name_buff+dir_length,buff,
  61.      sizeof(name_buff)-1-dir_length));
  62. VOID(cleanup_dirname(buff,name_buff));
  63.       }
  64.       if (!(isam=nisam_open(buff,mode,test(handle_locking))))
  65. goto err;
  66.       files++;
  67.     }
  68.     last_isam=isam;
  69.     if (info.reclength && info.reclength != isam->s->base.reclength)
  70.     {
  71.       my_errno=HA_ERR_WRONG_IN_RECORD;
  72.       goto err;
  73.     }
  74.     info.reclength=isam->s->base.reclength;
  75.   }
  76.   if (!(m_info= (MRG_INFO*) my_malloc(sizeof(MRG_INFO)+files*sizeof(MRG_TABLE),
  77.       MYF(MY_WME))))
  78.     goto err;
  79.   *m_info=info;
  80.   m_info->open_tables=(MRG_TABLE *) (m_info+1);
  81.   m_info->tables=files;
  82.   options= (uint) ~0;
  83.   for (i=files ; i-- > 0 ; )
  84.   {
  85.     m_info->open_tables[i].table=isam;
  86.     m_info->options|=isam->s->base.options;
  87.     options&=isam->s->base.options;
  88.     m_info->records+=isam->s->state.records;
  89.     m_info->del+=isam->s->state.del;
  90.     m_info->data_file_length=isam->s->state.data_file_length;
  91.     if (i)
  92.       isam=(N_INFO*) (isam->open_list.next->data);
  93.   }
  94.   /* Don't force readonly if not all tables are readonly */
  95.   if (! (options & (HA_OPTION_COMPRESS_RECORD | HA_OPTION_READ_ONLY_DATA)))
  96.     m_info->options&= ~(HA_OPTION_COMPRESS_RECORD | HA_OPTION_READ_ONLY_DATA);
  97.   /* Fix fileinfo for easyer debugging (actually set by rrnd) */
  98.   file_offset=0;
  99.   for (i=0 ; (uint) i < files ; i++)
  100.   {
  101.     m_info->open_tables[i].file_offset=(my_off_t) file_offset;
  102.     file_offset+=m_info->open_tables[i].table->s->state.data_file_length;
  103.   }
  104.   if (sizeof(my_off_t) == 4 && file_offset > (ulonglong) (ulong) ~0L)
  105.   {
  106.     my_errno=HA_ERR_RECORD_FILE_FULL;
  107.     my_free((char*) m_info,MYF(0));
  108.     goto err;
  109.   }
  110.   m_info->end_table=m_info->open_tables+files;
  111.   m_info->last_used_table=m_info->open_tables;
  112.   VOID(my_close(fd,MYF(0)));
  113.   end_io_cache(&file);
  114.   m_info->open_list.data=(void*) m_info;
  115.   pthread_mutex_lock(&THR_LOCK_open);
  116.   mrg_open_list=list_add(mrg_open_list,&m_info->open_list);
  117.   pthread_mutex_unlock(&THR_LOCK_open);
  118.   DBUG_RETURN(m_info);
  119. err:
  120.   save_errno=my_errno;
  121.   switch (errpos) {
  122.   case 1:
  123.     VOID(my_close(fd,MYF(0)));
  124.     end_io_cache(&file);
  125.     for (i=files ; i-- > 0 ; )
  126.     {
  127.       isam=last_isam;
  128.       if (i)
  129. last_isam=(N_INFO*) (isam->open_list.next->data);
  130.       nisam_close(isam);
  131.     }
  132.   }
  133.   my_errno=save_errno;
  134.   DBUG_RETURN (NULL);
  135. }