semaphore_posix.cpp 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. /*************************************************************************/
  2. /* semaphore_posix.cpp */
  3. /*************************************************************************/
  4. /* This file is part of: */
  5. /* GODOT ENGINE */
  6. /* http://www.godotengine.org */
  7. /*************************************************************************/
  8. /* Copyright (c) 2007-2015 Juan Linietsky, Ariel Manzur. */
  9. /* */
  10. /* Permission is hereby granted, free of charge, to any person obtaining */
  11. /* a copy of this software and associated documentation files (the */
  12. /* "Software"), to deal in the Software without restriction, including */
  13. /* without limitation the rights to use, copy, modify, merge, publish, */
  14. /* distribute, sublicense, and/or sell copies of the Software, and to */
  15. /* permit persons to whom the Software is furnished to do so, subject to */
  16. /* the following conditions: */
  17. /* */
  18. /* The above copyright notice and this permission notice shall be */
  19. /* included in all copies or substantial portions of the Software. */
  20. /* */
  21. /* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, */
  22. /* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF */
  23. /* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.*/
  24. /* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY */
  25. /* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, */
  26. /* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */
  27. /* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */
  28. /*************************************************************************/
  29. #include "semaphore_posix.h"
  30. #if defined(UNIX_ENABLED) || defined(PTHREAD_ENABLED)
  31. #include "os/memory.h"
  32. #include <errno.h>
  33. #include <stdio.h>
  34. Error SemaphorePosix::wait() {
  35. while(sem_wait(&sem)) {
  36. if (errno==EINTR) {
  37. errno=0;
  38. continue;
  39. } else {
  40. perror("sem waiting");
  41. return ERR_BUSY;
  42. }
  43. }
  44. return OK;
  45. }
  46. Error SemaphorePosix::post() {
  47. return (sem_post(&sem)==0)?OK:ERR_BUSY;
  48. }
  49. int SemaphorePosix::get() const {
  50. int val;
  51. sem_getvalue(&sem, &val);
  52. return val;
  53. }
  54. Semaphore *SemaphorePosix::create_semaphore_posix() {
  55. return memnew( SemaphorePosix );
  56. }
  57. void SemaphorePosix::make_default() {
  58. create_func=create_semaphore_posix;
  59. }
  60. SemaphorePosix::SemaphorePosix() {
  61. int r = sem_init(&sem,0,0);
  62. if (r != 0)
  63. perror("sem creating");
  64. }
  65. SemaphorePosix::~SemaphorePosix() {
  66. sem_destroy(&sem);
  67. }
  68. #endif