pthread_setcancelstate.c 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129
  1. /*
  2. * pthread_setcancelstate.c
  3. *
  4. * Description:
  5. * POSIX thread functions related to thread cancellation.
  6. *
  7. * --------------------------------------------------------------------------
  8. *
  9. * Pthreads-embedded (PTE) - POSIX Threads Library for embedded systems
  10. * Copyright(C) 2008 Jason Schmidlapp
  11. *
  12. * Contact Email: [email protected]
  13. *
  14. *
  15. * Based upon Pthreads-win32 - POSIX Threads Library for Win32
  16. * Copyright(C) 1998 John E. Bossom
  17. * Copyright(C) 1999,2005 Pthreads-win32 contributors
  18. *
  19. * Contact Email: [email protected]
  20. *
  21. * The original list of contributors to the Pthreads-win32 project
  22. * is contained in the file CONTRIBUTORS.ptw32 included with the
  23. * source code distribution. The list can also be seen at the
  24. * following World Wide Web location:
  25. * http://sources.redhat.com/pthreads-win32/contributors.html
  26. *
  27. * This library is free software; you can redistribute it and/or
  28. * modify it under the terms of the GNU Lesser General Public
  29. * License as published by the Free Software Foundation; either
  30. * version 2 of the License, or (at your option) any later version.
  31. *
  32. * This library is distributed in the hope that it will be useful,
  33. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  34. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  35. * Lesser General Public License for more details.
  36. *
  37. * You should have received a copy of the GNU Lesser General Public
  38. * License along with this library in the file COPYING.LIB;
  39. * if not, write to the Free Software Foundation, Inc.,
  40. * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA
  41. */
  42. #include "pthread.h"
  43. #include "implement.h"
  44. int
  45. pthread_setcancelstate (int state, int *oldstate)
  46. /*
  47. * ------------------------------------------------------
  48. * DOCPUBLIC
  49. * This function atomically sets the calling thread's
  50. * cancelability state to 'state' and returns the previous
  51. * cancelability state at the location referenced by
  52. * 'oldstate'
  53. *
  54. * PARAMETERS
  55. * state,
  56. * oldstate
  57. * PTHREAD_CANCEL_ENABLE
  58. * cancellation is enabled,
  59. *
  60. * PTHREAD_CANCEL_DISABLE
  61. * cancellation is disabled
  62. *
  63. *
  64. * DESCRIPTION
  65. * This function atomically sets the calling thread's
  66. * cancelability state to 'state' and returns the previous
  67. * cancelability state at the location referenced by
  68. * 'oldstate'.
  69. *
  70. * NOTES:
  71. * 1) Use to disable cancellation around 'atomic' code that
  72. * includes cancellation points
  73. *
  74. * COMPATIBILITY ADDITIONS
  75. * If 'oldstate' is NULL then the previous state is not returned
  76. * but the function still succeeds. (Solaris)
  77. *
  78. * RESULTS
  79. * 0 successfully set cancelability type,
  80. * EINVAL 'state' is invalid
  81. *
  82. * ------------------------------------------------------
  83. */
  84. {
  85. int result = 0;
  86. pthread_t self = pthread_self ();
  87. pte_thread_t * sp = (pte_thread_t *) self;
  88. if (sp == NULL
  89. || (state != PTHREAD_CANCEL_ENABLE && state != PTHREAD_CANCEL_DISABLE))
  90. {
  91. return EINVAL;
  92. }
  93. /*
  94. * Lock for async-cancel safety.
  95. */
  96. (void) pthread_mutex_lock (&sp->cancelLock);
  97. if (oldstate != NULL)
  98. {
  99. *oldstate = sp->cancelState;
  100. }
  101. sp->cancelState = state;
  102. /*
  103. * Check if there is a pending asynchronous cancel
  104. */
  105. if (state == PTHREAD_CANCEL_ENABLE
  106. && (sp->cancelType == PTHREAD_CANCEL_ASYNCHRONOUS)
  107. && (pte_osThreadCheckCancel(sp->threadId) == PTE_OS_INTERRUPTED) )
  108. {
  109. sp->state = PThreadStateCanceling;
  110. sp->cancelState = PTHREAD_CANCEL_DISABLE;
  111. (void) pthread_mutex_unlock (&sp->cancelLock);
  112. pte_throw (PTE_EPS_CANCEL);
  113. /* Never reached */
  114. }
  115. (void) pthread_mutex_unlock (&sp->cancelLock);
  116. return (result);
  117. } /* pthread_setcancelstate */