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

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. #if defined(__EMX__) || defined(__NETWARE__)
  14. #include "../mysys/my_lock.c"
  15. #else
  16. #undef MAP_TO_USE_RAID /* Avoid RAID mappings */
  17. #include <my_global.h>
  18. #include <my_sys.h>
  19. #include <mysys_err.h>
  20. #include <my_pthread.h>
  21. #include <thr_alarm.h>
  22. #include <errno.h>
  23. /* Lock a part of a file */
  24. int my_lock(File fd,int locktype,my_off_t start,my_off_t length,myf MyFlags)
  25. {
  26.   thr_alarm_t alarmed;
  27.   ALARM alarm_buff;
  28.   uint wait_for_alarm;
  29.   struct flock m_lock;
  30.   DBUG_ENTER("my_lock");
  31.   DBUG_PRINT("my",("Fd: %d  Op: %d  start: %ld  Length: %ld  MyFlags: %d",
  32.    fd,locktype,(ulong) start,(ulong) length,MyFlags));
  33.   if (my_disable_locking)
  34.     DBUG_RETURN(0); /* purecov: inspected */
  35.   m_lock.l_type=(short) locktype;
  36.   m_lock.l_whence=0L;
  37.   m_lock.l_start=(long) start;
  38.   m_lock.l_len=(long) length;
  39.   wait_for_alarm=(MyFlags & MY_DONT_WAIT ? MY_HOW_OFTEN_TO_ALARM :
  40.   (uint) 12*60*60);
  41.   if (fcntl(fd,F_SETLK,&m_lock) != -1) /* Check if we can lock */
  42.     DBUG_RETURN(0); /* Ok, file locked */
  43.   DBUG_PRINT("info",("Was locked, trying with alarm"));
  44.   if (!thr_alarm(&alarmed,wait_for_alarm,&alarm_buff))
  45.   {
  46.     int value;
  47.     while ((value=fcntl(fd,F_SETLKW,&m_lock)) && !thr_got_alarm(&alarmed) &&
  48.    errno == EINTR) ;
  49.     thr_end_alarm(&alarmed);
  50.     if (value != -1)
  51.       DBUG_RETURN(0);
  52.   }
  53.   else
  54.   {
  55.     errno=EINTR;
  56.   }
  57.   if (errno == EINTR || errno == EACCES)
  58.     my_errno=EAGAIN; /* Easier to check for this */
  59.   else
  60.     my_errno=errno;
  61.   if (MyFlags & MY_WME)
  62.   {
  63.     if (locktype == F_UNLCK)
  64.       my_error(EE_CANTUNLOCK,MYF(ME_BELL+ME_WAITTANG),errno);
  65.     else
  66.       my_error(EE_CANTLOCK,MYF(ME_BELL+ME_WAITTANG),errno);
  67.   }
  68.   DBUG_PRINT("error",("errno: %d",errno));
  69.   DBUG_RETURN(-1);
  70. }
  71. #endif