1062c5bc4SJason Schmidlapp /*
2062c5bc4SJason Schmidlapp * pte_cancellable_wait.c
3062c5bc4SJason Schmidlapp *
4062c5bc4SJason Schmidlapp * Description:
5062c5bc4SJason Schmidlapp *
6062c5bc4SJason Schmidlapp * --------------------------------------------------------------------------
7062c5bc4SJason Schmidlapp *
8062c5bc4SJason Schmidlapp * Pthreads-embedded (PTE) - POSIX Threads Library for embedded systems
9062c5bc4SJason Schmidlapp * Copyright(C) 2008 Jason Schmidlapp
10062c5bc4SJason Schmidlapp *
11062c5bc4SJason Schmidlapp * Contact Email: jschmidlapp@users.sourceforge.net
12062c5bc4SJason Schmidlapp *
13062c5bc4SJason Schmidlapp *
14062c5bc4SJason Schmidlapp * Based upon Pthreads-win32 - POSIX Threads Library for Win32
15062c5bc4SJason Schmidlapp * Copyright(C) 1998 John E. Bossom
16062c5bc4SJason Schmidlapp * Copyright(C) 1999,2005 Pthreads-win32 contributors
17062c5bc4SJason Schmidlapp *
18062c5bc4SJason Schmidlapp * Contact Email: rpj@callisto.canberra.edu.au
19062c5bc4SJason Schmidlapp *
20062c5bc4SJason Schmidlapp * The original list of contributors to the Pthreads-win32 project
21062c5bc4SJason Schmidlapp * is contained in the file CONTRIBUTORS.ptw32 included with the
22062c5bc4SJason Schmidlapp * source code distribution. The list can also be seen at the
23062c5bc4SJason Schmidlapp * following World Wide Web location:
24062c5bc4SJason Schmidlapp * http://sources.redhat.com/pthreads-win32/contributors.html
25062c5bc4SJason Schmidlapp *
26062c5bc4SJason Schmidlapp * This library is free software; you can redistribute it and/or
27062c5bc4SJason Schmidlapp * modify it under the terms of the GNU Lesser General Public
28062c5bc4SJason Schmidlapp * License as published by the Free Software Foundation; either
29062c5bc4SJason Schmidlapp * version 2 of the License, or (at your option) any later version.
30062c5bc4SJason Schmidlapp *
31062c5bc4SJason Schmidlapp * This library is distributed in the hope that it will be useful,
32062c5bc4SJason Schmidlapp * but WITHOUT ANY WARRANTY; without even the implied warranty of
33062c5bc4SJason Schmidlapp * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
34062c5bc4SJason Schmidlapp * Lesser General Public License for more details.
35062c5bc4SJason Schmidlapp *
36062c5bc4SJason Schmidlapp * You should have received a copy of the GNU Lesser General Public
37062c5bc4SJason Schmidlapp * License along with this library in the file COPYING.LIB;
38062c5bc4SJason Schmidlapp * if not, write to the Free Software Foundation, Inc.,
39062c5bc4SJason Schmidlapp * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA
40062c5bc4SJason Schmidlapp */
41062c5bc4SJason Schmidlapp
42062c5bc4SJason Schmidlapp #include <stdio.h>
43062c5bc4SJason Schmidlapp #include <stdlib.h>
44062c5bc4SJason Schmidlapp
45062c5bc4SJason Schmidlapp #include "pthread.h"
46062c5bc4SJason Schmidlapp #include "semaphore.h"
47062c5bc4SJason Schmidlapp #include "implement.h"
48062c5bc4SJason Schmidlapp
49062c5bc4SJason Schmidlapp
pte_cancellable_wait(pte_osSemaphoreHandle semHandle,unsigned int * timeout)50062c5bc4SJason Schmidlapp int pte_cancellable_wait (pte_osSemaphoreHandle semHandle, unsigned int* timeout)
51062c5bc4SJason Schmidlapp {
52062c5bc4SJason Schmidlapp int result = EINVAL;
53062c5bc4SJason Schmidlapp pte_osResult osResult;
54062c5bc4SJason Schmidlapp int cancelEnabled = 0;
55062c5bc4SJason Schmidlapp pthread_t self;
56062c5bc4SJason Schmidlapp pte_thread_t * sp;
57062c5bc4SJason Schmidlapp
58062c5bc4SJason Schmidlapp self = pthread_self();
59*a12978ccSJeremy Soller sp = (pte_thread_t *) self;
60062c5bc4SJason Schmidlapp
61062c5bc4SJason Schmidlapp if (sp != NULL)
62062c5bc4SJason Schmidlapp {
63062c5bc4SJason Schmidlapp /*
64062c5bc4SJason Schmidlapp * Get cancelEvent handle
65062c5bc4SJason Schmidlapp */
66062c5bc4SJason Schmidlapp if (sp->cancelState == PTHREAD_CANCEL_ENABLE)
67062c5bc4SJason Schmidlapp {
68062c5bc4SJason Schmidlapp cancelEnabled = 1;
69062c5bc4SJason Schmidlapp }
70062c5bc4SJason Schmidlapp }
71062c5bc4SJason Schmidlapp
72062c5bc4SJason Schmidlapp
73062c5bc4SJason Schmidlapp if (cancelEnabled)
74062c5bc4SJason Schmidlapp {
75062c5bc4SJason Schmidlapp osResult = pte_osSemaphoreCancellablePend(semHandle, timeout);
76062c5bc4SJason Schmidlapp }
77062c5bc4SJason Schmidlapp else
78062c5bc4SJason Schmidlapp {
79062c5bc4SJason Schmidlapp osResult = pte_osSemaphorePend(semHandle, timeout);
80062c5bc4SJason Schmidlapp }
81062c5bc4SJason Schmidlapp
82062c5bc4SJason Schmidlapp switch (osResult)
83062c5bc4SJason Schmidlapp {
84062c5bc4SJason Schmidlapp case PTE_OS_OK:
85062c5bc4SJason Schmidlapp {
86062c5bc4SJason Schmidlapp result = 0;
87062c5bc4SJason Schmidlapp break;
88062c5bc4SJason Schmidlapp }
89062c5bc4SJason Schmidlapp
90062c5bc4SJason Schmidlapp case PTE_OS_TIMEOUT:
91062c5bc4SJason Schmidlapp {
92062c5bc4SJason Schmidlapp result = ETIMEDOUT;
93062c5bc4SJason Schmidlapp break;
94062c5bc4SJason Schmidlapp }
95062c5bc4SJason Schmidlapp
96062c5bc4SJason Schmidlapp case PTE_OS_INTERRUPTED:
97062c5bc4SJason Schmidlapp {
98062c5bc4SJason Schmidlapp if (sp != NULL)
99062c5bc4SJason Schmidlapp {
100062c5bc4SJason Schmidlapp /*
101062c5bc4SJason Schmidlapp * Should handle POSIX and implicit POSIX threads..
102062c5bc4SJason Schmidlapp * Make sure we haven't been async-canceled in the meantime.
103062c5bc4SJason Schmidlapp */
104062c5bc4SJason Schmidlapp (void) pthread_mutex_lock (&sp->cancelLock);
105062c5bc4SJason Schmidlapp if (sp->state < PThreadStateCanceling)
106062c5bc4SJason Schmidlapp {
107062c5bc4SJason Schmidlapp sp->state = PThreadStateCanceling;
108062c5bc4SJason Schmidlapp sp->cancelState = PTHREAD_CANCEL_DISABLE;
109062c5bc4SJason Schmidlapp (void) pthread_mutex_unlock (&sp->cancelLock);
110062c5bc4SJason Schmidlapp pte_throw (PTE_EPS_CANCEL);
111062c5bc4SJason Schmidlapp
112062c5bc4SJason Schmidlapp /* Never reached */
113062c5bc4SJason Schmidlapp }
114062c5bc4SJason Schmidlapp (void) pthread_mutex_unlock (&sp->cancelLock);
115062c5bc4SJason Schmidlapp }
116062c5bc4SJason Schmidlapp break;
117062c5bc4SJason Schmidlapp }
118062c5bc4SJason Schmidlapp
119062c5bc4SJason Schmidlapp default:
120062c5bc4SJason Schmidlapp {
121062c5bc4SJason Schmidlapp result = EINVAL;
122062c5bc4SJason Schmidlapp }
123062c5bc4SJason Schmidlapp
124062c5bc4SJason Schmidlapp }
125062c5bc4SJason Schmidlapp
126062c5bc4SJason Schmidlapp
127062c5bc4SJason Schmidlapp return (result);
128062c5bc4SJason Schmidlapp
129062c5bc4SJason Schmidlapp } /* CancelableWait */
130