IlmThreadSemaphorePosix.cpp 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
  1. ///////////////////////////////////////////////////////////////////////////
  2. //
  3. // Copyright (c) 2005-2012, Industrial Light & Magic, a division of Lucas
  4. // Digital Ltd. LLC
  5. //
  6. // All rights reserved.
  7. //
  8. // Redistribution and use in source and binary forms, with or without
  9. // modification, are permitted provided that the following conditions are
  10. // met:
  11. // * Redistributions of source code must retain the above copyright
  12. // notice, this list of conditions and the following disclaimer.
  13. // * Redistributions in binary form must reproduce the above
  14. // copyright notice, this list of conditions and the following disclaimer
  15. // in the documentation and/or other materials provided with the
  16. // distribution.
  17. // * Neither the name of Industrial Light & Magic nor the names of
  18. // its contributors may be used to endorse or promote products derived
  19. // from this software without specific prior written permission.
  20. //
  21. // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  22. // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  23. // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  24. // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  25. // OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  26. // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  27. // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  28. // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  29. // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  30. // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  31. // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  32. //
  33. ///////////////////////////////////////////////////////////////////////////
  34. //-----------------------------------------------------------------------------
  35. //
  36. // class Semaphore -- implementation for platforms
  37. // that support Posix threads and Posix semaphores
  38. //
  39. //-----------------------------------------------------------------------------
  40. #include "IlmBaseConfig.h"
  41. #if HAVE_PTHREAD && HAVE_POSIX_SEMAPHORES
  42. #include "IlmThreadSemaphore.h"
  43. #include "Iex.h"
  44. #include <assert.h>
  45. #include <errno.h>
  46. ILMTHREAD_INTERNAL_NAMESPACE_SOURCE_ENTER
  47. Semaphore::Semaphore (unsigned int value)
  48. {
  49. if (::sem_init (&_semaphore, 0, value))
  50. IEX_NAMESPACE::throwErrnoExc ("Cannot initialize semaphore (%T).");
  51. }
  52. Semaphore::~Semaphore ()
  53. {
  54. int error = ::sem_destroy (&_semaphore);
  55. assert (error == 0);
  56. }
  57. void
  58. Semaphore::wait ()
  59. {
  60. while( ::sem_wait( &_semaphore ) == -1 && errno == EINTR )
  61. {
  62. }
  63. }
  64. bool
  65. Semaphore::tryWait ()
  66. {
  67. return sem_trywait (&_semaphore) == 0;
  68. }
  69. void
  70. Semaphore::post ()
  71. {
  72. if (::sem_post (&_semaphore))
  73. IEX_NAMESPACE::throwErrnoExc ("Post operation on semaphore failed (%T).");
  74. }
  75. int
  76. Semaphore::value () const
  77. {
  78. int value;
  79. if (::sem_getvalue (&_semaphore, &value))
  80. IEX_NAMESPACE::throwErrnoExc ("Cannot read semaphore value (%T).");
  81. return value;
  82. }
  83. ILMTHREAD_INTERNAL_NAMESPACE_SOURCE_EXIT
  84. #endif