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

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 heap-database */
  14. #include "heapdef.h"
  15. #ifdef VMS
  16. #include "hp_static.c" /* Stupid vms-linker */
  17. #endif
  18. #include "my_sys.h"
  19. HP_INFO *heap_open(const char *name, int mode)
  20. {
  21.   HP_INFO *info;
  22.   HP_SHARE *share;
  23.   DBUG_ENTER("heap_open");
  24.   pthread_mutex_lock(&THR_LOCK_heap);
  25.   if (!(share= hp_find_named_heap(name)))
  26.   {
  27.     my_errno= ENOENT;
  28.     pthread_mutex_unlock(&THR_LOCK_heap);
  29.     DBUG_RETURN(0);
  30.   }
  31.   if (!(info= (HP_INFO*) my_malloc((uint) sizeof(HP_INFO) +
  32.   2 * share->max_key_length,
  33.   MYF(MY_ZEROFILL))))
  34.   {
  35.     pthread_mutex_unlock(&THR_LOCK_heap);
  36.     DBUG_RETURN(0);
  37.   }
  38.   share->open_count++; 
  39. #ifdef THREAD
  40.   thr_lock_data_init(&share->lock,&info->lock,NULL);
  41. #endif
  42.   info->open_list.data= (void*) info;
  43.   heap_open_list= list_add(heap_open_list,&info->open_list);
  44.   pthread_mutex_unlock(&THR_LOCK_heap);
  45.   info->s= share;
  46.   info->lastkey= (byte*) (info + 1);
  47.   info->recbuf= (byte*) (info->lastkey + share->max_key_length);
  48.   info->mode= mode;
  49.   info->current_record= (ulong) ~0L; /* No current record */
  50.   info->current_ptr= 0;
  51.   info->current_hash_ptr= 0;
  52.   info->lastinx= info->errkey= -1;
  53.   info->update= 0;
  54. #ifndef DBUG_OFF
  55.   info->opt_flag= READ_CHECK_USED; /* Check when changing */
  56. #endif
  57.   DBUG_PRINT("exit",("heap: %lx  reclength: %d  records_in_block: %d",
  58.      info,share->reclength,share->block.records_in_block));
  59.   DBUG_RETURN(info);
  60. }
  61. /* map name to a heap-nr. If name isn't found return 0 */
  62. HP_SHARE *hp_find_named_heap(const char *name)
  63. {
  64.   LIST *pos;
  65.   HP_SHARE *info;
  66.   DBUG_ENTER("heap_find");
  67.   DBUG_PRINT("enter",("name: %s",name));
  68.   for (pos= heap_share_list; pos; pos= pos->next)
  69.   {
  70.     info= (HP_SHARE*) pos->data;
  71.     if (!strcmp(name, info->name))
  72.     {
  73.       DBUG_PRINT("exit", ("Old heap_database: %lx",info));
  74.       DBUG_RETURN(info);
  75.     }
  76.   }
  77.   DBUG_RETURN((HP_SHARE *) 0);
  78. }