SDL_sysmutex.c
上传用户:sun1608
上传日期:2007-02-02
资源大小:6116k
文件大小:4k
源码类别:

流媒体/Mpeg4/MP4

开发平台:

Visual C++

  1. /*
  2.     SDL - Simple DirectMedia Layer
  3.     Copyright (C) 1997, 1998, 1999, 2000, 2001, 2002  Sam Lantinga
  4.     This library is free software; you can redistribute it and/or
  5.     modify it under the terms of the GNU Library General Public
  6.     License as published by the Free Software Foundation; either
  7.     version 2 of the License, or (at your option) any later version.
  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.     You should have received a copy of the GNU Library General Public
  13.     License along with this library; if not, write to the Free
  14.     Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  15.     Sam Lantinga
  16.     slouken@libsdl.org
  17. */
  18. #ifdef SAVE_RCSID
  19. static char rcsid =
  20.  "@(#) $Id: SDL_sysmutex.c,v 1.4 2002/04/22 21:38:03 wmay Exp $";
  21. #endif
  22. #ifdef linux
  23. /* Look to see if glibc is available, and if so, what version */
  24. #include <features.h>
  25. #if (__GLIBC__ == 2) && (__GLIBC_MINOR__ == 0)
  26. #warning Working around a bug in glibc 2.0 pthreads
  27. #undef SDL_USE_PTHREADS
  28. /* The bug is actually a problem where threads are suspended, but don't
  29.    wake up when the thread manager sends them a signal.  This is a problem
  30.    with thread creation too, but it happens less often. :-/
  31.    We avoid this by using System V IPC for mutexes.
  32.  */
  33. #endif /* glibc 2.0 */
  34. #endif /* linux */
  35. #ifdef SDL_USE_PTHREADS
  36. #include <stdlib.h>
  37. #include <stdio.h>
  38. #include <pthread.h>
  39. #include "SDL_error.h"
  40. #include "SDL_thread.h"
  41. struct SDL_mutex {
  42. pthread_mutex_t id;
  43. #ifdef PTHREAD_NO_RECURSIVE_MUTEX
  44. int recursive;
  45. pthread_t owner;
  46. #endif
  47. };
  48. SDL_mutex *SDL_CreateMutex (void)
  49. {
  50. SDL_mutex *mutex;
  51. pthread_mutexattr_t attr;
  52. /* Allocate the structure */
  53. mutex = (SDL_mutex *)calloc(1, sizeof(*mutex));
  54. if ( mutex ) {
  55. pthread_mutexattr_init(&attr);
  56. #ifdef PTHREAD_NO_RECURSIVE_MUTEX
  57. /* No extra attributes necessary */
  58. #else
  59. #ifdef linux
  60. pthread_mutexattr_setkind_np(&attr, PTHREAD_MUTEX_RECURSIVE_NP);
  61. #else
  62. pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE);
  63. #endif
  64. #endif /* PTHREAD_NO_RECURSIVE_MUTEX */
  65. if ( pthread_mutex_init(&mutex->id, &attr) != 0 ) {
  66. SDL_SetError("pthread_mutex_init() failed");
  67. free(mutex);
  68. mutex = NULL;
  69. }
  70. } else {
  71. SDL_OutOfMemory();
  72. }
  73. return(mutex);
  74. }
  75. void SDL_DestroyMutex(SDL_mutex *mutex)
  76. {
  77. if ( mutex ) {
  78. pthread_mutex_destroy(&mutex->id);
  79. free(mutex);
  80. }
  81. }
  82. /* Lock the mutex */
  83. int SDL_mutexP(SDL_mutex *mutex)
  84. {
  85. int retval;
  86. #ifdef PTHREAD_NO_RECURSIVE_MUTEX
  87. pthread_t this_thread;
  88. #endif
  89. if ( mutex == NULL ) {
  90. SDL_SetError("Passed a NULL mutex");
  91. return -1;
  92. }
  93. retval = 0;
  94. #ifdef PTHREAD_NO_RECURSIVE_MUTEX
  95. this_thread = pthread_self();
  96. if ( mutex->owner == this_thread ) {
  97. ++mutex->recursive;
  98. } else {
  99. /* The order of operations is important.
  100.    We set the locking thread id after we obtain the lock
  101.    so unlocks from other threads will fail.
  102. */
  103. if ( pthread_mutex_lock(&mutex->id) == 0 ) {
  104. mutex->owner = this_thread;
  105. mutex->recursive = 0;
  106. } else {
  107. SDL_SetError("pthread_mutex_lock() failed");
  108. retval = -1;
  109. }
  110. }
  111. #else
  112. if ( pthread_mutex_lock(&mutex->id) < 0 ) {
  113. SDL_SetError("pthread_mutex_lock() failed");
  114. retval = -1;
  115. }
  116. #endif
  117. return retval;
  118. }
  119. int SDL_mutexV(SDL_mutex *mutex)
  120. {
  121. int retval;
  122. if ( mutex == NULL ) {
  123. SDL_SetError("Passed a NULL mutex");
  124. return -1;
  125. }
  126. retval = 0;
  127. #ifdef PTHREAD_NO_RECURSIVE_MUTEX
  128. /* We can only unlock the mutex if we own it */
  129. if ( pthread_self() == mutex->owner ) {
  130. if ( mutex->recursive ) {
  131. --mutex->recursive;
  132. } else {
  133. /* The order of operations is important.
  134.    First reset the owner so another thread doesn't lock
  135.    the mutex and set the ownership before we reset it,
  136.    then release the lock semaphore.
  137.  */
  138. mutex->owner = 0;
  139. pthread_mutex_unlock(&mutex->id);
  140. }
  141. } else {
  142. SDL_SetError("mutex not owned by this thread");
  143. retval = -1;
  144. }
  145. #else
  146. if ( pthread_mutex_unlock(&mutex->id) < 0 ) {
  147. SDL_SetError("pthread_mutex_unlock() failed");
  148. retval = -1;
  149. }
  150. #endif /* PTHREAD_NO_RECURSIVE_MUTEX */
  151. return retval;
  152. }
  153. #else /* Use semaphore implementation */
  154. #include "generic/SDL_sysmutex.c"
  155. #endif /* SDL_USE_PTHREADS */