home *** CD-ROM | disk | FTP | other *** search
/ Chip 2001 January / Chip_2001-01_cd1.bin / tema / mysql / mysql-3.23.28g-win-source.exe / mysys / my_lock.c < prev    next >
C/C++ Source or Header  |  2000-10-14  |  5KB  |  169 lines
  1. /* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
  2.    
  3.    This library is free software; you can redistribute it and/or
  4.    modify it under the terms of the GNU Library General Public
  5.    License as published by the Free Software Foundation; either
  6.    version 2 of the License, or (at your option) any later version.
  7.    
  8.    This library 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 GNU
  11.    Library General Public License for more details.
  12.    
  13.    You should have received a copy of the GNU Library General Public
  14.    License along with this library; if not, write to the Free
  15.    Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
  16.    MA 02111-1307, USA */
  17.  
  18. #include "mysys_priv.h"
  19. #include "mysys_err.h"
  20. #include <errno.h>
  21. #undef MY_HOW_OFTEN_TO_ALARM
  22. #define MY_HOW_OFTEN_TO_ALARM ((int) my_time_to_wait_for_lock)
  23. #ifdef NO_ALARM_LOOP
  24. #undef NO_ALARM_LOOP
  25. #endif
  26. #include <my_alarm.h>
  27. #ifdef __WIN__
  28. #include <sys/locking.h>
  29. #endif
  30. #ifdef __EMX__
  31. #define INCL_BASE
  32. #define INCL_NOPMAPI
  33. #include <os2emx.h>
  34. #endif
  35.  
  36. #ifdef HAVE_FCNTL
  37. static struct flock lock;        /* Must be static for sun-sparc */
  38. #endif
  39.  
  40.     /* Lock a part of a file */
  41.  
  42. int my_lock(File fd, int locktype, my_off_t start, my_off_t length,
  43.         myf MyFlags)
  44. {
  45. #ifdef __EMX__
  46.   FILELOCK LockArea = {0,0}, UnlockArea = {0,0};
  47.   APIRET rc = 0;
  48.   fpos_t oldpos;
  49.   int lockflags = 0;
  50. #endif
  51. #ifdef HAVE_FCNTL
  52.   int value;
  53.   ALARM_VARIABLES;
  54. #endif
  55.   DBUG_ENTER("my_lock");
  56.   DBUG_PRINT("my",("Fd: %d  Op: %d  start: %ld  Length: %ld  MyFlags: %d",
  57.            fd,locktype,(long) start,(long) length,MyFlags));
  58. #ifdef VMS
  59.   DBUG_RETURN(0);
  60. #else
  61.   if (my_disable_locking)
  62.     DBUG_RETURN(0);
  63. #if defined(__EMX__)
  64.   if (locktype == F_UNLCK) {
  65.     UnlockArea.lOffset = start;
  66.     if (length)
  67.       UnlockArea.lRange = length;
  68.     else
  69.       UnlockArea.lRange = 0x7FFFFFFFL;
  70.   } else
  71.   if (locktype == F_RDLCK || locktype == F_WRLCK) {
  72.     if (locktype == F_RDLCK) lockflags |= 1;
  73.     LockArea.lOffset = start;
  74.     if (length)
  75.       LockArea.lRange = length;
  76.     else
  77.       LockArea.lRange = 0x7FFFFFFFL;
  78.   } else {
  79.     my_errno = EINVAL;
  80.     DBUG_RETURN(-1);
  81.   }
  82.   if (!LockArea.lRange && !UnlockArea.lRange)
  83.     DBUG_RETURN(0);
  84.   if (MyFlags & MY_DONT_WAIT) {
  85.     if (!(rc = DosSetFileLocks(fd,&UnlockArea,&LockArea,0,lockflags)))
  86.       DBUG_RETURN(0);        /* Lock was OK */
  87.     if (rc == 175 && locktype == F_RDLCK) {
  88.       lockflags &= ~1;
  89.       rc = DosSetFileLocks(fd,&UnlockArea,&LockArea,0,lockflags);
  90.     }
  91.     if (rc == 33) {  /* Lock Violation */
  92.       DBUG_PRINT("info",("Was locked, trying with timeout"));
  93.       rc = DosSetFileLocks(fd,&UnlockArea,&LockArea,MY_HOW_OFTEN_TO_ALARM * 1000,lockflags);
  94.     }
  95.     if (!rc) DBUG_RETURN(0);
  96.     if (rc == 33) errno = EAGAIN;
  97.     else {
  98.       errno = EINVAL;
  99.       printf("Error: DosSetFileLocks() == %d\n",rc);
  100.     }
  101.   } else {
  102.     while (rc = DosSetFileLocks(fd,&UnlockArea,&LockArea,
  103.     MY_HOW_OFTEN_TO_ALARM * 1000,lockflags) && (rc == 33 || rc == 175)) {
  104.       printf(".");
  105.       if (rc == 175) lockflags &= ~1;
  106.     }
  107.     if (!rc) DBUG_RETURN(0);
  108.     errno = EINVAL;
  109.     printf("Error: DosSetFileLocks() == %d\n",rc);
  110.   }
  111. #elif defined(HAVE_LOCKING)
  112.   /* Windows */
  113.   {
  114.     my_bool error;
  115.     pthread_mutex_lock(&my_file_info[fd].mutex);
  116.     if (MyFlags & MY_SEEK_NOT_DONE)
  117.       VOID(my_seek(fd,start,MY_SEEK_SET,MYF(MyFlags & ~MY_SEEK_NOT_DONE)));
  118.     error= locking(fd,locktype,(ulong) length) && errno != EINVAL;
  119.     pthread_mutex_unlock(&my_file_info[fd].mutex);
  120.     if (!error)
  121.       DBUG_RETURN(0);
  122.   }
  123. #else
  124. #if defined(HAVE_FCNTL)
  125.   lock.l_type= (short) locktype;
  126.   lock.l_whence=0L;
  127.   lock.l_start=(long) start;
  128.   lock.l_len=(long) length;
  129.   if (MyFlags & MY_DONT_WAIT)
  130.   {
  131.     if (fcntl(fd,F_SETLK,&lock) != -1)    /* Check if we can lock */
  132.       DBUG_RETURN(0);            /* Ok, file locked */
  133.     DBUG_PRINT("info",("Was locked, trying with alarm"));
  134.     ALARM_INIT;
  135.     while ((value=fcntl(fd,F_SETLKW,&lock)) && ! ALARM_TEST &&
  136.        errno == EINTR)
  137.     {            /* Setup again so we don`t miss it */
  138.       ALARM_REINIT;
  139.     }
  140.     ALARM_END;
  141.     if (value != -1)
  142.       DBUG_RETURN(0);
  143.     if (errno == EINTR)
  144.       errno=EAGAIN;
  145.   }
  146.   else if (fcntl(fd,F_SETLKW,&lock) != -1) /* Wait until a lock */
  147.     DBUG_RETURN(0);
  148. #else
  149.   if (MyFlags & MY_SEEK_NOT_DONE)
  150.     VOID(my_seek(fd,start,MY_SEEK_SET,MYF(MyFlags & ~MY_SEEK_NOT_DONE)));
  151.   if (lockf(fd,locktype,length) != -1)
  152.     DBUG_RETURN(0);
  153. #endif /* HAVE_FCNTL */
  154. #endif /* HAVE_LOCKING */
  155.  
  156.     /* We got an error. We don't want EACCES errors */
  157.   my_errno=(errno == EACCES) ? EAGAIN : errno ? errno : -1;
  158.   if (MyFlags & MY_WME)
  159.   {
  160.     if (locktype == F_UNLCK)
  161.       my_error(EE_CANTUNLOCK,MYF(ME_BELL+ME_WAITTANG),my_errno);
  162.     else
  163.       my_error(EE_CANTLOCK,MYF(ME_BELL+ME_WAITTANG),my_errno);
  164.   }
  165.   DBUG_PRINT("error",("my_errno: %d (%d)",my_errno,errno));
  166.   DBUG_RETURN(-1);
  167. #endif    /* ! VMS */
  168. } /* my_lock */
  169.