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

MySQL数据库

开发平台:

Visual C++

  1. /*-
  2.  * See the file LICENSE for redistribution information.
  3.  *
  4.  * Copyright (c) 1998-2002
  5.  * Sleepycat Software.  All rights reserved.
  6.  */
  7. #include "db_config.h"
  8. #ifndef lint
  9. static const char revid[] = "$Id: os_handle.c,v 11.30 2002/07/12 18:56:54 bostic Exp $";
  10. #endif /* not lint */
  11. #ifndef NO_SYSTEM_INCLUDES
  12. #include <sys/types.h>
  13. #include <fcntl.h>
  14. #include <string.h>
  15. #include <unistd.h>
  16. #endif
  17. #include "db_int.h"
  18. /*
  19.  * __os_openhandle --
  20.  * Open a file, using POSIX 1003.1 open flags.
  21.  *
  22.  * PUBLIC: int __os_openhandle __P((DB_ENV *, const char *, int, int, DB_FH *));
  23.  */
  24. int
  25. __os_openhandle(dbenv, name, flags, mode, fhp)
  26. DB_ENV *dbenv;
  27. const char *name;
  28. int flags, mode;
  29. DB_FH *fhp;
  30. {
  31. int ret, nrepeat;
  32. memset(fhp, 0, sizeof(*fhp));
  33. fhp->handle = INVALID_HANDLE_VALUE;
  34. /* If the application specified an interface, use it. */
  35. if (DB_GLOBAL(j_open) != NULL) {
  36. if ((fhp->fd = DB_GLOBAL(j_open)(name, flags, mode)) == -1)
  37. return (__os_get_errno());
  38. F_SET(fhp, DB_FH_VALID);
  39. return (0);
  40. }
  41. for (nrepeat = 1; nrepeat < 4; ++nrepeat) {
  42. ret = 0;
  43. fhp->fd = open(name, flags, mode);
  44. if (fhp->fd == -1) {
  45. /*
  46.  * If it's a "temporary" error, we retry up to 3 times,
  47.  * waiting up to 12 seconds.  While it's not a problem
  48.  * if we can't open a database, an inability to open a
  49.  * log file is cause for serious dismay.
  50.  */
  51. ret = __os_get_errno();
  52. if (ret == ENFILE || ret == EMFILE || ret == ENOSPC) {
  53. (void)__os_sleep(dbenv, nrepeat * 2, 0);
  54. continue;
  55. }
  56. /*
  57.  * If it was an EINTR it's reasonable to retry
  58.  * immediately, and arbitrarily often.
  59.  */
  60. if (ret == EINTR) {
  61. --nrepeat;
  62. continue;
  63. }
  64. } else {
  65. F_SET(fhp, DB_FH_VALID);
  66. }
  67. break;
  68. }
  69. return (ret);
  70. }
  71. /*
  72.  * __os_closehandle --
  73.  * Close a file.
  74.  *
  75.  * PUBLIC: int __os_closehandle __P((DB_ENV *, DB_FH *));
  76.  */
  77. int
  78. __os_closehandle(dbenv, fhp)
  79. DB_ENV *dbenv;
  80. DB_FH *fhp;
  81. {
  82. BOOL success;
  83. int ret;
  84. COMPQUIET(dbenv, NULL);
  85. /* Don't close file descriptors that were never opened. */
  86. DB_ASSERT(F_ISSET(fhp, DB_FH_VALID) &&
  87.     ((fhp->fd != -1) || (fhp->handle != INVALID_HANDLE_VALUE)));
  88. ret = 0;
  89. do {
  90. if (DB_GLOBAL(j_close) != NULL)
  91. success = (DB_GLOBAL(j_close)(fhp->fd) == 0);
  92. else if (fhp->handle != INVALID_HANDLE_VALUE) {
  93. success = CloseHandle(fhp->handle);
  94. if (!success)
  95. __os_set_errno(__os_win32_errno());
  96. }
  97. else
  98. success = (close(fhp->fd) == 0);
  99. } while (!success && (ret = __os_get_errno()) == EINTR);
  100. /*
  101.  * Smash the POSIX file descriptor -- it's never tested, but we want
  102.  * to catch any mistakes.
  103.  */
  104. fhp->fd = -1;
  105. fhp->handle = INVALID_HANDLE_VALUE;
  106. F_CLR(fhp, DB_FH_VALID);
  107. return (ret);
  108. }