file.c
上传用户:tsgydb
上传日期:2007-04-14
资源大小:10674k
文件大小:4k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /* ==== file.c ============================================================
  2.  * Copyright (c) 1993, 1994 by Chris Provenzano, proven@mit.edu
  3.  * All rights reserved.
  4.  *
  5.  * Redistribution and use in source and binary forms, with or without
  6.  * modification, are permitted provided that the following conditions
  7.  * are met:
  8.  * 1. Redistributions of source code must retain the above copyright
  9.  *    notice, this list of conditions and the following disclaimer.
  10.  * 2. Redistributions in binary form must reproduce the above copyright
  11.  *    notice, this list of conditions and the following disclaimer in the
  12.  *    documentation and/or other materials provided with the distribution.
  13.  * 3. All advertising materials mentioning features or use of this software
  14.  *    must display the following acknowledgement:
  15.  *  This product includes software developed by Chris Provenzano.
  16.  * 4. The name of Chris Provenzano may not be used to endorse or promote 
  17.  *   products derived from this software without specific prior written
  18.  *   permission.
  19.  *
  20.  * THIS SOFTWARE IS PROVIDED BY CHRIS PROVENZANO ``AS IS'' AND
  21.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  22.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  23.  * ARE DISCLAIMED.  IN NO EVENT SHALL CHRIS PROVENZANO BE LIABLE FOR ANY 
  24.  * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
  25.  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR 
  26.  * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
  27.  * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 
  28.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  29.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 
  30.  * SUCH DAMAGE.
  31.  *
  32.  * Description : The locking functions for stdio.
  33.  *
  34.  *  1.00 93/09/04 proven
  35.  *      -Started coding this file.
  36.  */
  37. #ifndef lint
  38. static const char rcsid[] = "$Id$";
  39. #endif
  40. #include <pthread.h>
  41. #include <stdio.h>
  42. /* ==========================================================================
  43.  * flockfile()
  44.  */
  45. void flockfile(FILE *fp)
  46. {
  47. pthread_mutex_t *mutex;
  48. int fd, flags;
  49. if ((fd = fileno(fp)) >= 0) {
  50. pthread_mutex_lock(mutex = &(fd_table[fd]->mutex));
  51. if (fp->_flags & __SRW) {
  52. flags = FD_READ | FD_WRITE;
  53. } else {
  54. if (fp->_flags & __SWR) {
  55. flags = FD_WRITE;
  56. } else {
  57. flags = FD_READ;
  58. }
  59. }
  60. /* This might fail but POSIX doesn't give a damn. */
  61. fd_basic_lock(fd, flags, mutex, NULL);
  62. pthread_mutex_unlock(mutex);
  63. }
  64. }
  65. /* ==========================================================================
  66.  * ftrylockfile()
  67.  */
  68. int ftrylockfile(FILE *fp)
  69. {
  70. pthread_mutex_t *mutex;
  71. int fd, flags;
  72. if ((fd = fileno(fp)) >= 0) {
  73. pthread_mutex_lock(mutex = &(fd_table[fd]->mutex));
  74. if (fp->_flags & __SRW) {
  75. flags = FD_READ | FD_WRITE;
  76. } else {
  77. if (fp->_flags & __SWR) {
  78. flags = FD_WRITE;
  79. } else {
  80. flags = FD_READ;
  81. }
  82. }
  83. if (!(fd_table[fd]->r_owner && fd_table[fd]->w_owner)) {
  84. fd_basic_lock(fd, flags, mutex, NULL);
  85. fd = OK;
  86. } else {
  87. fd = NOTOK;
  88. }
  89. pthread_mutex_unlock(mutex);
  90. } else {
  91. fd = OK;
  92. }
  93. return(fd);
  94. }
  95. /* ==========================================================================
  96.  * funlockfile()
  97.  */
  98. void funlockfile(FILE *fp)
  99. {
  100. pthread_mutex_t *mutex;
  101. int fd, flags;
  102. if ((fd = fileno(fp)) >= 0) {
  103. pthread_mutex_lock(mutex = &(fd_table[fd]->mutex));
  104. if (fp->_flags & __SRW) {
  105. flags = FD_READ | FD_WRITE;
  106. } else {
  107. if (fp->_flags & __SWR) {
  108. flags = FD_WRITE;
  109. } else {
  110. flags = FD_READ;
  111. }
  112. }
  113. fd_basic_unlock(fd, flags);
  114. pthread_mutex_unlock(mutex);
  115. }
  116. }