home *** CD-ROM | disk | FTP | other *** search
/ Chip 2001 January / Chip_2001-01_cd1.bin / tema / mysql / mysql-3.23.28g-win-source.exe / sql / my_lock.c < prev    next >
C/C++ Source or Header  |  2000-08-31  |  3KB  |  83 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. #ifdef __EMX__
  18. #include "../mysys/my_lock.c"
  19. #else
  20.  
  21. #undef MAP_TO_USE_RAID            /* Avoid RAID mappings */
  22. #include <global.h>
  23. #include <my_sys.h>
  24. #include <mysys_err.h>
  25. #include <my_pthread.h>
  26. #include <thr_alarm.h>
  27. #include <errno.h>
  28.  
  29. #ifdef HAVE_FCNTL
  30. static struct flock lock;        /* Must be static for sun-sparc */
  31. #endif
  32.  
  33.     /* Lock a part of a file */
  34.  
  35. int my_lock(File fd,int locktype,my_off_t start,my_off_t length,myf MyFlags)
  36. {
  37.   thr_alarm_t alarmed;
  38.   ALARM    alarm_buff;
  39.   uint wait_for_alarm;
  40.   DBUG_ENTER("my_lock");
  41.   DBUG_PRINT("my",("Fd: %d  Op: %d  start: %ld  Length: %ld  MyFlags: %d",
  42.            fd,locktype,(ulong) start,(ulong) length,MyFlags));
  43.   if (my_disable_locking)
  44.     DBUG_RETURN(0); /* purecov: inspected */
  45.   lock.l_type=(short) locktype;
  46.   lock.l_whence=0L;
  47.   lock.l_start=(long) start;
  48.   lock.l_len=(long) length;
  49.   wait_for_alarm=(MyFlags & MY_DONT_WAIT ? MY_HOW_OFTEN_TO_ALARM :
  50.           (uint) 12*60*60);
  51.   if (fcntl(fd,F_SETLK,&lock) != -1)    /* Check if we can lock */
  52.     DBUG_RETURN(0);            /* Ok, file locked */
  53.   DBUG_PRINT("info",("Was locked, trying with alarm"));
  54.   if (!thr_alarm(&alarmed,wait_for_alarm,&alarm_buff))
  55.   {
  56.     int value;
  57.     while ((value=fcntl(fd,F_SETLKW,&lock)) && !thr_got_alarm(alarmed) &&
  58.        errno == EINTR) ;
  59.     thr_end_alarm(&alarmed);
  60.     if (value != -1)
  61.       DBUG_RETURN(0);
  62.   }
  63.   else
  64.   {
  65.     errno=EINTR;
  66.   }
  67.   if (errno == EINTR || errno == EACCES)
  68.     my_errno=EAGAIN;            /* Easier to check for this */
  69.   else
  70.     my_errno=errno;
  71.  
  72.   if (MyFlags & MY_WME)
  73.   {
  74.     if (locktype == F_UNLCK)
  75.       my_error(EE_CANTUNLOCK,MYF(ME_BELL+ME_WAITTANG),errno);
  76.     else
  77.       my_error(EE_CANTLOCK,MYF(ME_BELL+ME_WAITTANG),errno);
  78.   }
  79.   DBUG_PRINT("error",("errno: %d",errno));
  80.   DBUG_RETURN(-1);
  81. }
  82. #endif
  83.