1062c5bc4SJason Schmidlapp /*
2062c5bc4SJason Schmidlapp * pthreads_delay_np.c
3062c5bc4SJason Schmidlapp *
4062c5bc4SJason Schmidlapp * Description:
5062c5bc4SJason Schmidlapp * This translation unit implements non-portable thread functions.
6062c5bc4SJason Schmidlapp *
7062c5bc4SJason Schmidlapp * --------------------------------------------------------------------------
8062c5bc4SJason Schmidlapp *
9062c5bc4SJason Schmidlapp * Pthreads-embedded (PTE) - POSIX Threads Library for embedded systems
10062c5bc4SJason Schmidlapp * Copyright(C) 2008 Jason Schmidlapp
11062c5bc4SJason Schmidlapp *
12062c5bc4SJason Schmidlapp * Contact Email: jschmidlapp@users.sourceforge.net
13062c5bc4SJason Schmidlapp *
14062c5bc4SJason Schmidlapp *
15062c5bc4SJason Schmidlapp * Based upon Pthreads-win32 - POSIX Threads Library for Win32
16062c5bc4SJason Schmidlapp * Copyright(C) 1998 John E. Bossom
17062c5bc4SJason Schmidlapp * Copyright(C) 1999,2005 Pthreads-win32 contributors
18062c5bc4SJason Schmidlapp *
19062c5bc4SJason Schmidlapp * Contact Email: rpj@callisto.canberra.edu.au
20062c5bc4SJason Schmidlapp *
21062c5bc4SJason Schmidlapp * The original list of contributors to the Pthreads-win32 project
22062c5bc4SJason Schmidlapp * is contained in the file CONTRIBUTORS.ptw32 included with the
23062c5bc4SJason Schmidlapp * source code distribution. The list can also be seen at the
24062c5bc4SJason Schmidlapp * following World Wide Web location:
25062c5bc4SJason Schmidlapp * http://sources.redhat.com/pthreads-win32/contributors.html
26062c5bc4SJason Schmidlapp *
27062c5bc4SJason Schmidlapp * This library is free software; you can redistribute it and/or
28062c5bc4SJason Schmidlapp * modify it under the terms of the GNU Lesser General Public
29062c5bc4SJason Schmidlapp * License as published by the Free Software Foundation; either
30062c5bc4SJason Schmidlapp * version 2 of the License, or (at your option) any later version.
31062c5bc4SJason Schmidlapp *
32062c5bc4SJason Schmidlapp * This library is distributed in the hope that it will be useful,
33062c5bc4SJason Schmidlapp * but WITHOUT ANY WARRANTY; without even the implied warranty of
34062c5bc4SJason Schmidlapp * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
35062c5bc4SJason Schmidlapp * Lesser General Public License for more details.
36062c5bc4SJason Schmidlapp *
37062c5bc4SJason Schmidlapp * You should have received a copy of the GNU Lesser General Public
38062c5bc4SJason Schmidlapp * License along with this library in the file COPYING.LIB;
39062c5bc4SJason Schmidlapp * if not, write to the Free Software Foundation, Inc.,
40062c5bc4SJason Schmidlapp * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA
41062c5bc4SJason Schmidlapp */
42062c5bc4SJason Schmidlapp
43062c5bc4SJason Schmidlapp #include <stdio.h>
44062c5bc4SJason Schmidlapp
45062c5bc4SJason Schmidlapp #include "pthread.h"
46062c5bc4SJason Schmidlapp #include "implement.h"
47062c5bc4SJason Schmidlapp
48062c5bc4SJason Schmidlapp
49062c5bc4SJason Schmidlapp /*
50062c5bc4SJason Schmidlapp * pthread_delay_np
51062c5bc4SJason Schmidlapp *
52062c5bc4SJason Schmidlapp * DESCRIPTION
53062c5bc4SJason Schmidlapp *
54062c5bc4SJason Schmidlapp * This routine causes a thread to delay execution for a specific period of time.
55062c5bc4SJason Schmidlapp * This period ends at the current time plus the specified interval. The routine
56062c5bc4SJason Schmidlapp * will not return before the end of the period is reached, but may return an
57062c5bc4SJason Schmidlapp * arbitrary amount of time after the period has gone by. This can be due to
58062c5bc4SJason Schmidlapp * system load, thread priorities, and system timer granularity.
59062c5bc4SJason Schmidlapp *
60062c5bc4SJason Schmidlapp * Specifying an interval of zero (0) seconds and zero (0) nanoseconds is
61062c5bc4SJason Schmidlapp * allowed and can be used to force the thread to give up the processor or to
62062c5bc4SJason Schmidlapp * deliver a pending cancelation request.
63062c5bc4SJason Schmidlapp *
64062c5bc4SJason Schmidlapp * The timespec structure contains the following two fields:
65062c5bc4SJason Schmidlapp *
66062c5bc4SJason Schmidlapp * tv_sec is an integer number of seconds.
67062c5bc4SJason Schmidlapp * tv_nsec is an integer number of nanoseconds.
68062c5bc4SJason Schmidlapp *
69062c5bc4SJason Schmidlapp * Return Values
70062c5bc4SJason Schmidlapp *
71062c5bc4SJason Schmidlapp * If an error condition occurs, this routine returns an integer value indicating
72062c5bc4SJason Schmidlapp * the type of error. Possible return values are as follows:
73062c5bc4SJason Schmidlapp *
74062c5bc4SJason Schmidlapp * 0
75062c5bc4SJason Schmidlapp * Successful completion.
76062c5bc4SJason Schmidlapp * [EINVAL]
77062c5bc4SJason Schmidlapp * The value specified by interval is invalid.
78062c5bc4SJason Schmidlapp *
79062c5bc4SJason Schmidlapp * Example
80062c5bc4SJason Schmidlapp *
81062c5bc4SJason Schmidlapp * The following code segment would wait for 5 and 1/2 seconds
82062c5bc4SJason Schmidlapp *
83062c5bc4SJason Schmidlapp * struct timespec tsWait;
84062c5bc4SJason Schmidlapp * int intRC;
85062c5bc4SJason Schmidlapp *
86062c5bc4SJason Schmidlapp * tsWait.tv_sec = 5;
87062c5bc4SJason Schmidlapp * tsWait.tv_nsec = 500000000L;
88062c5bc4SJason Schmidlapp * intRC = pthread_delay_np(&tsWait);
89062c5bc4SJason Schmidlapp */
90062c5bc4SJason Schmidlapp int
pthread_delay_np(struct timespec * interval)91062c5bc4SJason Schmidlapp pthread_delay_np (struct timespec *interval)
92062c5bc4SJason Schmidlapp {
93062c5bc4SJason Schmidlapp unsigned int wait_time;
94062c5bc4SJason Schmidlapp unsigned int secs_in_millisecs;
95062c5bc4SJason Schmidlapp unsigned int millisecs;
96062c5bc4SJason Schmidlapp pthread_t self;
97062c5bc4SJason Schmidlapp pte_thread_t * sp;
98062c5bc4SJason Schmidlapp
99062c5bc4SJason Schmidlapp if (interval == NULL)
100062c5bc4SJason Schmidlapp {
101062c5bc4SJason Schmidlapp return EINVAL;
102062c5bc4SJason Schmidlapp }
103062c5bc4SJason Schmidlapp
104062c5bc4SJason Schmidlapp if (interval->tv_sec == 0L && interval->tv_nsec == 0L)
105062c5bc4SJason Schmidlapp {
106062c5bc4SJason Schmidlapp pthread_testcancel ();
107062c5bc4SJason Schmidlapp pte_osThreadSleep (1);
108062c5bc4SJason Schmidlapp pthread_testcancel ();
109062c5bc4SJason Schmidlapp return (0);
110062c5bc4SJason Schmidlapp }
111062c5bc4SJason Schmidlapp
112062c5bc4SJason Schmidlapp /* convert secs to millisecs */
113062c5bc4SJason Schmidlapp secs_in_millisecs = interval->tv_sec * 1000L;
114062c5bc4SJason Schmidlapp
115062c5bc4SJason Schmidlapp /* convert nanosecs to millisecs (rounding up) */
116062c5bc4SJason Schmidlapp millisecs = (interval->tv_nsec + 999999L) / 1000000L;
117062c5bc4SJason Schmidlapp
118062c5bc4SJason Schmidlapp wait_time = secs_in_millisecs + millisecs;
119062c5bc4SJason Schmidlapp
120*a12978ccSJeremy Soller if (NULL == (self = pthread_self ()))
121062c5bc4SJason Schmidlapp {
122062c5bc4SJason Schmidlapp return ENOMEM;
123062c5bc4SJason Schmidlapp }
124062c5bc4SJason Schmidlapp
125*a12978ccSJeremy Soller sp = (pte_thread_t *) self;
126062c5bc4SJason Schmidlapp
127062c5bc4SJason Schmidlapp if (sp->cancelState == PTHREAD_CANCEL_ENABLE)
128062c5bc4SJason Schmidlapp {
129062c5bc4SJason Schmidlapp pte_osResult cancelStatus;
130062c5bc4SJason Schmidlapp /*
131062c5bc4SJason Schmidlapp * Async cancelation won't catch us until wait_time is up.
132062c5bc4SJason Schmidlapp * Deferred cancelation will cancel us immediately.
133062c5bc4SJason Schmidlapp */
134062c5bc4SJason Schmidlapp cancelStatus = pte_osThreadCheckCancel(sp->threadId);
135062c5bc4SJason Schmidlapp
136062c5bc4SJason Schmidlapp if (cancelStatus == PTE_OS_INTERRUPTED)
137062c5bc4SJason Schmidlapp {
138062c5bc4SJason Schmidlapp /*
139062c5bc4SJason Schmidlapp * Canceling!
140062c5bc4SJason Schmidlapp */
141062c5bc4SJason Schmidlapp (void) pthread_mutex_lock (&sp->cancelLock);
142062c5bc4SJason Schmidlapp if (sp->state < PThreadStateCanceling)
143062c5bc4SJason Schmidlapp {
144062c5bc4SJason Schmidlapp sp->state = PThreadStateCanceling;
145062c5bc4SJason Schmidlapp sp->cancelState = PTHREAD_CANCEL_DISABLE;
146062c5bc4SJason Schmidlapp (void) pthread_mutex_unlock (&sp->cancelLock);
147062c5bc4SJason Schmidlapp
148062c5bc4SJason Schmidlapp pte_throw (PTE_EPS_CANCEL);
149062c5bc4SJason Schmidlapp }
150062c5bc4SJason Schmidlapp
151062c5bc4SJason Schmidlapp (void) pthread_mutex_unlock (&sp->cancelLock);
152062c5bc4SJason Schmidlapp return ESRCH;
153062c5bc4SJason Schmidlapp }
154062c5bc4SJason Schmidlapp else if (cancelStatus != PTE_OS_OK)
155062c5bc4SJason Schmidlapp {
156062c5bc4SJason Schmidlapp return EINVAL;
157062c5bc4SJason Schmidlapp }
158062c5bc4SJason Schmidlapp }
159062c5bc4SJason Schmidlapp else
160062c5bc4SJason Schmidlapp
161062c5bc4SJason Schmidlapp {
162062c5bc4SJason Schmidlapp pte_osThreadSleep (wait_time);
163062c5bc4SJason Schmidlapp }
164062c5bc4SJason Schmidlapp
165062c5bc4SJason Schmidlapp return (0);
166062c5bc4SJason Schmidlapp }
167