开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
my_os2file64.c
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：12k
源码类别：

MySQL数据库

开发平台：

Visual C++

my_os2file64.c：源码内容
  1. /* Copyright (C) Yuri Dario & 2000 MySQL AB
  2.    All the above parties has a full, independent copyright to
  3.    the following code, including the right to use the code in
  4.    any manner without any demands from the other parties.
  6.    This library is free software; you can redistribute it and/or
  7.    modify it under the terms of the GNU Library General Public
  8.    License as published by the Free Software Foundation; either
  9.    version 2 of the License, or (at your option) any later version.
  11.    This library is distributed in the hope that it will be useful,
  12.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  14.    Library General Public License for more details.
  16.    You should have received a copy of the GNU Library General Public
  17.    License along with this library; if not, write to the Free
  18.    Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
  19.    MA 02111-1307, USA */
  21. void     _OS2errno( APIRET rc);
  22. longlong    _lseek64( int fd, longlong offset, int seektype);
  23. int     _lock64( int fd, int locktype, my_off_t start,
  24.      my_off_t length, myf MyFlags);
  25. int     _sopen64( const char *name, int oflag, int shflag, int mask);
  27. /*
  28.   This class is used to define a global c++ variable, that
  29.   is initialized before main() gets called.
  30. */
  32. class File64bit
  33. {
  34.    public:
  35.       File64bit();  /* default constructor */
  36. } initFile64bit;
  38. static APIRET (* APIENTRY _DosOpenL)(PCSZ  pszFileName,
  39.     PHFILE phf,
  40.     PULONG pulAction,
  41.     LONGLONG cbFile,
  42.     ULONG ulAttribute,
  43.     ULONG fsOpenFlags,
  44.     ULONG fsOpenMode,
  45.     PEAOP2 peaop2);
  46. static APIRET (* APIENTRY _DosSetFilePtrL)(HFILE hFile,
  47.    LONGLONG ib,
  48.    ULONG method,
  49.    PLONGLONG ibActual);
  50. static APIRET (* APIENTRY _DosSetFileLocksL)(HFILE hFile,
  51.     PFILELOCKL pflUnlock,
  52.     PFILELOCKL pflLock,
  53.     ULONG timeout,
  54.     ULONG flags);
  56. #define  EIO   EINVAL
  57. #define  ESPIPE   EBADSEEK
  60. static unsigned char const errno_tab[] =
  61. {
  62.   0 , EINVAL, ENOENT, ENOENT, EMFILE,  /* 0..4 */
  63.   EACCES, EBADF,  EIO,   ENOMEM, EIO,    /* 5..9 */
  64.   EINVAL, ENOEXEC,EINVAL, EINVAL, EINVAL,  /* 10..14 */
  65.   ENOENT, EBUSY,  EXDEV,  ENOENT, EROFS,   /* 15..19 */
  66.   EIO,   EIO,   EIO,   EIO,   EIO,    /* 20..24 */
  67.   EIO,   EIO,   EIO,   ENOSPC, EIO,    /* 25..29 */
  68.   EIO,   EIO,   EACCES, EACCES, EIO,    /* 30..34 */
  69.   EIO,   EIO,   EIO,   EIO,   ENOSPC,  /* 35..39 */
  70.   EIO,   EIO,   EIO,   EIO,   EIO,    /* 40..44 */
  71.   EIO,   EIO,   EIO,   EIO,   EIO,    /* 45..49 */
  72.   EIO,   EIO,   EIO,   EIO,   EBUSY,   /* 50..54 */
  73.   EIO,   EIO,   EIO,   EIO,   EIO,    /* 55..59 */
  74.   EIO,   ENOSPC, ENOSPC, EIO,   EIO,    /* 60..64 */
  75.   EACCES, EIO,   EIO,   EIO,   EIO,    /* 65..69 */
  76.   EIO,   EIO,   EIO,   EROFS,  EIO,    /* 70..74 */
  77.   EIO,   EIO,   EIO,   EIO,   EIO,    /* 75..79 */
  78.   EEXIST, EIO,   ENOENT, EIO,   EIO,    /* 80..84 */
  79.   EIO,   EIO,   EINVAL, EIO,   EAGAIN,  /* 85..89 */
  80.   EIO,   EIO,   EIO,   EIO,   EIO,    /* 90..94 */
  81.   EINTR,  EIO,   EIO,   EIO,   EACCES,  /* 95..99 */
  82.   ENOMEM, EINVAL, EINVAL, ENOMEM, EINVAL,  /* 100..104 */
  83.   EINVAL, ENOMEM, EIO,   EACCES, EPIPE,   /* 105..109 */
  84.   ENOENT, E2BIG,  ENOSPC, ENOMEM, EBADF,   /* 110..114 */
  85.   EINVAL, EINVAL, EINVAL, EINVAL, EINVAL,  /* 115..119 */
  86.   EINVAL, EINVAL, EINVAL, ENOENT, EINVAL,  /* 120..124 */
  87.   ENOENT, ENOENT, ENOENT, ECHILD, ECHILD,  /* 125..129 */
  88.   EACCES, EINVAL, ESPIPE, EINVAL, EINVAL,  /* 130..134 */
  89.   EINVAL, EINVAL, EINVAL, EINVAL, EINVAL,  /* 135..139 */
  90.   EINVAL, EINVAL, EBUSY,  EINVAL, EINVAL,  /* 140..144 */
  91.   EINVAL, EINVAL, EINVAL, EBUSY,  EINVAL,  /* 145..149 */
  92.   EINVAL, EINVAL, ENOMEM, EINVAL, EINVAL,  /* 150..154 */
  93.   EINVAL, EINVAL, EINVAL, EINVAL, EINVAL,  /* 155..159 */
  94.   EINVAL, EINVAL, EINVAL, EINVAL, EAGAIN,  /* 160..164 */
  95.   EINVAL, EINVAL, EACCES, EINVAL, EINVAL,  /* 165..169 */
  96.   EBUSY,  EINVAL, EINVAL, EINVAL, EINVAL,  /* 170..174 */
  97.   EINVAL, EINVAL, EINVAL, EINVAL, EINVAL,  /* 175..179 */
  98.   EINVAL, EINVAL, EINVAL, EINVAL, ECHILD,  /* 180..184 */
  99.   EINVAL, EINVAL, ENOENT, EINVAL, EINVAL,  /* 185..189 */
  100.   ENOEXEC,ENOEXEC,ENOEXEC,ENOEXEC,ENOEXEC, /* 190..194 */
  101.   ENOEXEC,ENOEXEC,ENOEXEC,ENOEXEC,ENOEXEC, /* 195..199 */
  102.   ENOEXEC,ENOEXEC,ENOEXEC,ENOENT, EINVAL,  /* 200..204 */
  103.   EINVAL, ENAMETOOLONG, EINVAL, EINVAL, EINVAL,  /* 205..209 */
  104.   EINVAL, EINVAL, EACCES, ENOEXEC,ENOEXEC, /* 210..214 */
  105.   EINVAL, EINVAL, EINVAL, EINVAL, EINVAL,  /* 215..219 */
  106.   EINVAL, EINVAL, EINVAL, EINVAL, EINVAL,  /* 220..224 */
  107.   EINVAL, EINVAL, EINVAL, ECHILD, EINVAL,  /* 225..229 */
  108.   EINVAL, EBUSY,  EAGAIN, ENOTCONN, EINVAL, /* 230..234 */
  109.   EINVAL, EINVAL, EINVAL, EINVAL, EINVAL,  /* 235..239 */
  110.   EINVAL, EINVAL, EINVAL, EINVAL, EINVAL,  /* 240..244 */
  111.   EINVAL, EINVAL, EINVAL, EINVAL, EINVAL,  /* 245..249 */
  112.   EACCES, EACCES, EINVAL, ENOENT, EINVAL,  /* 250..254 */
  113.   EINVAL, EINVAL, EINVAL, EINVAL, EINVAL,  /* 255..259 */
  114.   EINVAL, EINVAL, EINVAL, EINVAL, EINVAL,  /* 260..264 */
  115.   EINVAL, EINVAL, EINVAL, EINVAL, EINVAL,  /* 265..269 */
  116.   EINVAL, EINVAL, EINVAL, EINVAL, EINVAL,  /* 270..274 */
  117.   EINVAL, EINVAL, EINVAL, EINVAL, EINVAL,  /* 275..279 */
  118.   EINVAL, EINVAL, EINVAL, EINVAL, EEXIST,  /* 280..284 */
  119.   EEXIST, EINVAL, EINVAL, EINVAL, EINVAL,  /* 285..289 */
  120.   ENOMEM, EMFILE, EINVAL, EINVAL, EINVAL,  /* 290..294 */
  121.   EINVAL, EINVAL, EINVAL, EINVAL, EINVAL,  /* 295..299 */
  122.   EINVAL, EBUSY,  EINVAL, ESRCH,  EINVAL,  /* 300..304 */
  123.   ESRCH,  EINVAL, EINVAL, EINVAL, ESRCH,   /* 305..309 */
  124.   EINVAL, ENOMEM, EINVAL, EINVAL, EINVAL,  /* 310..314 */
  125.   EINVAL, E2BIG,  ENOENT, EIO,   EIO,    /* 315..319 */
  126.   EINVAL, EINVAL, EINVAL, EINVAL, EAGAIN,  /* 320..324 */
  127.   EINVAL, EINVAL, EINVAL, EIO,   ENOENT,  /* 325..329 */
  128.   EACCES, EACCES, EACCES, ENOENT, ENOMEM   /* 330..334 */
  129. };
  131. /*
  132.  * Initialize 64bit file access: dynamic load of WSeB API
  133. */
  134.     File64bit :: File64bit()
  135. {
  136.    HMODULE hDoscalls;
  138.    if (DosQueryModuleHandle("DOSCALLS", &hDoscalls) != NO_ERROR)
  139.       return;
  141.    if (DosQueryProcAddr(hDoscalls, 981, NULL, (PFN *)&_DosOpenL) != NO_ERROR)
  142.       return;
  144.    if (DosQueryProcAddr(hDoscalls, 988, NULL, (PFN *)&_DosSetFilePtrL) != NO_ERROR) {
  145.       _DosOpenL = NULL;
  146.       return;
  147.    }
  149.    if (DosQueryProcAddr(hDoscalls, 986, NULL, (PFN *)&_DosSetFileLocksL) != NO_ERROR) {
  150.       _DosOpenL = NULL;
  151.       _DosSetFilePtrL = NULL;
  152.       return;
  153.    }
  154.    /* notify success */
  155. #ifdef MYSQL_SERVER
  156.    printf( "WSeB 64bit file API loaded.n");
  157. #endif
  158. }
  160. void     _OS2errno( APIRET rc)
  161. {
  162.   if (rc >= sizeof (errno_tab))
  163.     errno = EINVAL;
  164.   else
  165.     errno = errno_tab[rc];
  166. }
  169. longlong _lseek64( int fd, longlong offset, int seektype)
  170. {
  171.   APIRET   rc;
  172.   longlong actual;
  174.   if (_DosSetFilePtrL)
  175.     rc = _DosSetFilePtrL( fd, offset, seektype, &actual);
  176.   else
  177.   {
  178.     ULONG ulActual;
  179.     rc = DosSetFilePtr( fd, (long) offset, seektype, &ulActual);
  180.     actual = ulActual;
  181.   }
  183.   if (!rc)
  184.     return( actual); /* NO_ERROR */
  186.   _OS2errno( rc); /* set errno */
  187.   return(-1); /* seek failed */
  188. }
  191. inline APIRET _SetFileLocksL(HFILE hFile,
  192.      PFILELOCKL pflUnlock,
  193.      PFILELOCKL pflLock,
  194.      ULONG timeout,
  195.      ULONG flags)
  196. {
  197.   if (_DosSetFileLocksL)
  198.   {
  199.     APIRET rc;
  200.     rc = _DosSetFileLocksL( hFile, pflUnlock, pflLock, timeout, flags);
  202.     /*
  203.       on FAT/HPFS/LAN a INVALID_PARAMETER is returned, seems that
  204.       only JFS can handle >2GB ranges.
  205.     */
  206.     if (rc != 87)
  207.       return rc;
  208.     /* got INVALID_PARAMETER, fallback to standard call */
  209.   }
  211.   FILELOCK flUnlock = { pflUnlock->lOffset, pflUnlock->lRange };
  212.   FILELOCK flLock = { pflLock->lOffset, pflLock->lRange };
  213.   return DosSetFileLocks( hFile, &flUnlock, &flLock, timeout, flags);
  214. }
  217. int  _lock64( int fd, int locktype, my_off_t start,
  218.       my_off_t length, myf MyFlags)
  219. {
  220.   FILELOCKL LockArea = {0,0}, UnlockArea = {0,0};
  221.   ULONG     readonly = 0;
  222.   APIRET    rc = -1;
  224.   switch (locktype) {
  225.   case F_UNLCK:
  226.     UnlockArea.lOffset = start;
  227.     UnlockArea.lRange = length ? length : LONGLONG_MAX;
  228.     break;
  230.   case F_RDLCK:
  231.   case F_WRLCK:
  232.     LockArea.lOffset = start;
  233.     LockArea.lRange = length ? length : LONGLONG_MAX;
  234.     readonly = (locktype == F_RDLCK ? 1 : 0);
  235.     break;
  237.   default:
  238.     errno = EINVAL;
  239.     rc = -1;
  240.     break;
  241.   }
  243.   if (MyFlags & MY_DONT_WAIT)
  244.   {
  245.     rc = _SetFileLocksL( fd, &UnlockArea, &LockArea, 0, readonly);
  246.     /* printf("fd %d, locktype %d, rc %d (dont_wait)n", fd, locktype, rc); */
  247.     if (rc == 33) {  /* Lock Violation */
  249.       DBUG_PRINT("info",("Was locked, trying with timeout"));
  250.       rc = _SetFileLocksL( fd, &UnlockArea, &LockArea, 1 * 1000, readonly);
  251.       /* printf( "fd %d, locktype %d, rc %d (dont_wait with timeout)n", fd, locktype, rc); */
  252.     }
  253.   }
  254.   else
  255.   {
  256.     while (rc = _SetFileLocksL( fd, &UnlockArea, &LockArea, 0, readonly) &&
  257.    (rc == 33))
  258.     {
  259.       printf(".");
  260.       DosSleep(1 * 1000);
  261.     }
  262.     /* printf( "fd %d, locktype %d, rc %d (wait2)n", fd, locktype, rc); */
  263.   }
  264.   if (!rc)
  265.     return(0); /* NO_ERROR */
  266.   _OS2errno( rc); /* set errno */
  267.   return(-1); /* lock failed */
  268. }
  271. int sopen(const char *name, int oflag, int shflag, int mask)
  272. {
  273.   int     fail_errno;
  274.   APIRET   rc = 0;
  275.   HFILE    hf = 0;
  276.   ULONG    ulAction = 0;
  277.   LONGLONG cbFile = 0;
  278.   ULONG    ulAttribute = FILE_NORMAL;
  279.   ULONG    fsOpenFlags = 0;
  280.   ULONG    fsOpenMode = 0;
  282.   /* Extract the access mode and sharing mode bits. */
  283.   fsOpenMode = (shflag & 0xFF) | (oflag & 0x03);
  285.   /*
  286.     Translate ERROR_OPEN_FAILED to ENOENT unless O_EXCL is set (see
  287.     below).
  288.   */
  289.   fail_errno = ENOENT;
  291.   /*
  292.     Compute `open_flag' depending on `flags'.  Note that _SO_CREAT is
  293.     set for O_CREAT.
  294.   */
  296.   if (oflag & O_CREAT)
  297.   {
  298.     if (oflag & O_EXCL)
  299.     {
  300.       fsOpenFlags = OPEN_ACTION_FAIL_IF_EXISTS | OPEN_ACTION_CREATE_IF_NEW;
  301.       fail_errno = EEXIST;
  302.     }
  303.     else if (oflag & O_TRUNC)
  304.       fsOpenFlags = OPEN_ACTION_REPLACE_IF_EXISTS | OPEN_ACTION_CREATE_IF_NEW;
  305.     else
  306.       fsOpenFlags = OPEN_ACTION_OPEN_IF_EXISTS | OPEN_ACTION_CREATE_IF_NEW;
  308.     if (mask & S_IWRITE)
  309.       ulAttribute = FILE_NORMAL;
  310.     else
  311.       ulAttribute = FILE_READONLY;
  313.   }
  314.   else if (oflag & O_TRUNC)
  315.     fsOpenFlags = OPEN_ACTION_REPLACE_IF_EXISTS | OPEN_ACTION_FAIL_IF_NEW;
  316.   else
  317.     fsOpenFlags = OPEN_ACTION_OPEN_IF_EXISTS | OPEN_ACTION_FAIL_IF_NEW;
  319.   /* Try to open the file and handle errors. */
  320.   if (_DosOpenL)
  321.     rc = _DosOpenL( name, &hf, &ulAction, cbFile,
  322.     ulAttribute, fsOpenFlags, fsOpenMode, NULL);
  323.   else
  324.     rc = DosOpen( name, &hf, &ulAction, (LONG) cbFile,
  325.   ulAttribute, fsOpenFlags, fsOpenMode, NULL);
  327.   if (rc == ERROR_OPEN_FAILED)
  328.   {
  329.     errno = fail_errno;
  330.     return -1;
  331.   }
  332.   if (rc != 0)
  333.   {
  334.     _OS2errno( rc);      /* set errno */
  335.     return -1;
  336.   }
  337.   if (oflag & O_APPEND)
  338.     _lseek64( hf, 0L, SEEK_END);
  339.   return hf;
  340. }
  343. int read(int fd, void *buffer, unsigned int count)
  344. {
  345.   APIRET   rc;
  346.   ULONG    actual;
  348.   rc= DosRead( fd, (PVOID) buffer, count, &actual);
  350.   if (!rc)
  351.     return( actual); /* NO_ERROR */
  352.   _OS2errno( rc); /* set errno */
  353.   return(-1); /* read failed */
  354. }
  357. int write(int fd, const void *buffer, unsigned int count)
  358. {
  359.   APIRET   rc;
  360.   ULONG    actual;
  362.   rc = DosWrite( fd, (PVOID) buffer, count, &actual);
  364.   if (!rc)
  365.     return( actual); /* NO_ERROR */
  366.   _OS2errno( rc); /* set errno */
  367.   return(-1); /* write failed */
  368. }
  371. int close( int fd)
  372. {
  373.   APIRET   rc;
  374.   ULONG    actual;
  376.   rc = DosClose( fd);
  378.   if (!rc)
  379.     return( 0); /* NO_ERROR */
  380.   _OS2errno( rc); /* set errno */
  381.   return(-1); /* close failed */
  382. }
  385. int open( const char *name, int oflag)
  386. {
  387.    return sopen( name, oflag, OPEN_SHARE_DENYNONE, S_IREAD | S_IWRITE);
  388. }
  391. int open( const char *name, int oflag, int mask)
  392. {
  393.    return sopen( name, oflag, OPEN_SHARE_DENYNONE, mask);
  394. }