1062c5bc4SJason Schmidlapp /*
2062c5bc4SJason Schmidlapp * create.c
3062c5bc4SJason Schmidlapp *
4062c5bc4SJason Schmidlapp * Description:
5062c5bc4SJason Schmidlapp * This translation unit implements routines associated with spawning a new
6062c5bc4SJason Schmidlapp * thread.
7062c5bc4SJason Schmidlapp *
8062c5bc4SJason Schmidlapp * --------------------------------------------------------------------------
9062c5bc4SJason Schmidlapp *
10062c5bc4SJason Schmidlapp * Pthreads-embedded (PTE) - POSIX Threads Library for embedded systems
11062c5bc4SJason Schmidlapp * Copyright(C) 2008 Jason Schmidlapp
12062c5bc4SJason Schmidlapp *
13062c5bc4SJason Schmidlapp * Contact Email: jschmidlapp@users.sourceforge.net
14062c5bc4SJason Schmidlapp *
15062c5bc4SJason Schmidlapp *
16062c5bc4SJason Schmidlapp * Based upon Pthreads-win32 - POSIX Threads Library for Win32
17062c5bc4SJason Schmidlapp * Copyright(C) 1998 John E. Bossom
18062c5bc4SJason Schmidlapp * Copyright(C) 1999,2005 Pthreads-win32 contributors
19062c5bc4SJason Schmidlapp *
20062c5bc4SJason Schmidlapp * Contact Email: rpj@callisto.canberra.edu.au
21062c5bc4SJason Schmidlapp *
22062c5bc4SJason Schmidlapp * The original list of contributors to the Pthreads-win32 project
23062c5bc4SJason Schmidlapp * is contained in the file CONTRIBUTORS.ptw32 included with the
24062c5bc4SJason Schmidlapp * source code distribution. The list can also be seen at the
25062c5bc4SJason Schmidlapp * following World Wide Web location:
26062c5bc4SJason Schmidlapp * http://sources.redhat.com/pthreads-win32/contributors.html
27062c5bc4SJason Schmidlapp *
28062c5bc4SJason Schmidlapp * This library is free software; you can redistribute it and/or
29062c5bc4SJason Schmidlapp * modify it under the terms of the GNU Lesser General Public
30062c5bc4SJason Schmidlapp * License as published by the Free Software Foundation; either
31062c5bc4SJason Schmidlapp * version 2 of the License, or (at your option) any later version.
32062c5bc4SJason Schmidlapp *
33062c5bc4SJason Schmidlapp * This library is distributed in the hope that it will be useful,
34062c5bc4SJason Schmidlapp * but WITHOUT ANY WARRANTY; without even the implied warranty of
35062c5bc4SJason Schmidlapp * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
36062c5bc4SJason Schmidlapp * Lesser General Public License for more details.
37062c5bc4SJason Schmidlapp *
38062c5bc4SJason Schmidlapp * You should have received a copy of the GNU Lesser General Public
39062c5bc4SJason Schmidlapp * License along with this library in the file COPYING.LIB;
40062c5bc4SJason Schmidlapp * if not, write to the Free Software Foundation, Inc.,
41062c5bc4SJason Schmidlapp * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA
42062c5bc4SJason Schmidlapp */
43062c5bc4SJason Schmidlapp
44062c5bc4SJason Schmidlapp #include "pte_osal.h"
45062c5bc4SJason Schmidlapp #include <stdio.h>
46062c5bc4SJason Schmidlapp #include <stdlib.h>
47062c5bc4SJason Schmidlapp
48062c5bc4SJason Schmidlapp #include "pthread.h"
49062c5bc4SJason Schmidlapp #include "implement.h"
50062c5bc4SJason Schmidlapp
51062c5bc4SJason Schmidlapp int
pthread_create(pthread_t * tid,const pthread_attr_t * attr,void * (* start)(void *),void * arg)52062c5bc4SJason Schmidlapp pthread_create (pthread_t * tid,
53062c5bc4SJason Schmidlapp const pthread_attr_t * attr,
54062c5bc4SJason Schmidlapp void *(*start) (void *), void *arg)
55062c5bc4SJason Schmidlapp /*
56062c5bc4SJason Schmidlapp * ------------------------------------------------------
57062c5bc4SJason Schmidlapp * DOCPUBLIC
58062c5bc4SJason Schmidlapp * This function creates a thread running the start function,
59062c5bc4SJason Schmidlapp * passing it the parameter value, 'arg'. The 'attr'
60062c5bc4SJason Schmidlapp * argument specifies optional creation attributes.
61062c5bc4SJason Schmidlapp * The identity of the new thread is returned
62062c5bc4SJason Schmidlapp * via 'tid', which should not be NULL.
63062c5bc4SJason Schmidlapp *
64062c5bc4SJason Schmidlapp * PARAMETERS
65062c5bc4SJason Schmidlapp * tid
66062c5bc4SJason Schmidlapp * pointer to an instance of pthread_t
67062c5bc4SJason Schmidlapp *
68062c5bc4SJason Schmidlapp * attr
69062c5bc4SJason Schmidlapp * optional pointer to an instance of pthread_attr_t
70062c5bc4SJason Schmidlapp *
71062c5bc4SJason Schmidlapp * start
72062c5bc4SJason Schmidlapp * pointer to the starting routine for the new thread
73062c5bc4SJason Schmidlapp *
74062c5bc4SJason Schmidlapp * arg
75062c5bc4SJason Schmidlapp * optional parameter passed to 'start'
76062c5bc4SJason Schmidlapp *
77062c5bc4SJason Schmidlapp *
78062c5bc4SJason Schmidlapp * DESCRIPTION
79062c5bc4SJason Schmidlapp * This function creates a thread running the start function,
80062c5bc4SJason Schmidlapp * passing it the parameter value, 'arg'. The 'attr'
81062c5bc4SJason Schmidlapp * argument specifies optional creation attributes.
82062c5bc4SJason Schmidlapp * The identity of the new thread is returned
83062c5bc4SJason Schmidlapp * via 'tid', which should not be the NULL pointer.
84062c5bc4SJason Schmidlapp *
85062c5bc4SJason Schmidlapp * RESULTS
86062c5bc4SJason Schmidlapp * 0 successfully created thread,
87062c5bc4SJason Schmidlapp * EINVAL attr invalid,
88062c5bc4SJason Schmidlapp * EAGAIN insufficient resources.
89062c5bc4SJason Schmidlapp *
90062c5bc4SJason Schmidlapp * ------------------------------------------------------
91062c5bc4SJason Schmidlapp */
92062c5bc4SJason Schmidlapp {
93062c5bc4SJason Schmidlapp pthread_t thread;
94062c5bc4SJason Schmidlapp pte_thread_t * tp;
95062c5bc4SJason Schmidlapp register pthread_attr_t a;
96062c5bc4SJason Schmidlapp int result = EAGAIN;
97062c5bc4SJason Schmidlapp int run = PTE_TRUE;
98062c5bc4SJason Schmidlapp ThreadParms *parms = NULL;
99062c5bc4SJason Schmidlapp long stackSize;
100062c5bc4SJason Schmidlapp int priority = 0;
101062c5bc4SJason Schmidlapp pthread_t self;
102062c5bc4SJason Schmidlapp pte_osResult osResult;
103062c5bc4SJason Schmidlapp
104062c5bc4SJason Schmidlapp if (attr != NULL)
105062c5bc4SJason Schmidlapp {
106062c5bc4SJason Schmidlapp a = *attr;
107062c5bc4SJason Schmidlapp }
108062c5bc4SJason Schmidlapp else
109062c5bc4SJason Schmidlapp {
110062c5bc4SJason Schmidlapp a = NULL;
111062c5bc4SJason Schmidlapp }
112062c5bc4SJason Schmidlapp
113*a12978ccSJeremy Soller if ((thread = pte_new ()) == NULL)
114062c5bc4SJason Schmidlapp {
115062c5bc4SJason Schmidlapp goto FAIL0;
116062c5bc4SJason Schmidlapp }
117062c5bc4SJason Schmidlapp
118*a12978ccSJeremy Soller tp = (pte_thread_t *) thread;
119062c5bc4SJason Schmidlapp
120062c5bc4SJason Schmidlapp priority = tp->sched_priority;
121062c5bc4SJason Schmidlapp
122062c5bc4SJason Schmidlapp if ((parms = (ThreadParms *) malloc (sizeof (*parms))) == NULL)
123062c5bc4SJason Schmidlapp {
124062c5bc4SJason Schmidlapp goto FAIL0;
125062c5bc4SJason Schmidlapp }
126062c5bc4SJason Schmidlapp
127062c5bc4SJason Schmidlapp parms->tid = thread;
128062c5bc4SJason Schmidlapp parms->start = start;
129062c5bc4SJason Schmidlapp parms->arg = arg;
130062c5bc4SJason Schmidlapp
131062c5bc4SJason Schmidlapp if (a != NULL)
132062c5bc4SJason Schmidlapp {
133062c5bc4SJason Schmidlapp stackSize = a->stacksize;
134062c5bc4SJason Schmidlapp tp->detachState = a->detachstate;
135062c5bc4SJason Schmidlapp priority = a->param.sched_priority;
136062c5bc4SJason Schmidlapp
137062c5bc4SJason Schmidlapp if ( (priority > pte_osThreadGetMaxPriority()) ||
138062c5bc4SJason Schmidlapp (priority < pte_osThreadGetMinPriority()) )
139062c5bc4SJason Schmidlapp {
140062c5bc4SJason Schmidlapp result = EINVAL;
141062c5bc4SJason Schmidlapp goto FAIL0;
142062c5bc4SJason Schmidlapp }
143062c5bc4SJason Schmidlapp
144062c5bc4SJason Schmidlapp /* Everything else */
145062c5bc4SJason Schmidlapp
146062c5bc4SJason Schmidlapp /*
147062c5bc4SJason Schmidlapp * Thread priority must be set to a valid system level
148062c5bc4SJason Schmidlapp * without altering the value set by pthread_attr_setschedparam().
149062c5bc4SJason Schmidlapp */
150062c5bc4SJason Schmidlapp
151062c5bc4SJason Schmidlapp if (PTHREAD_INHERIT_SCHED == a->inheritsched)
152062c5bc4SJason Schmidlapp {
153062c5bc4SJason Schmidlapp /*
154062c5bc4SJason Schmidlapp * If the thread that called pthread_create() is an OS thread
155062c5bc4SJason Schmidlapp * then the inherited priority could be the result of a temporary
156062c5bc4SJason Schmidlapp * system adjustment. This is not the case for POSIX threads.
157062c5bc4SJason Schmidlapp */
158062c5bc4SJason Schmidlapp self = pthread_self ();
159*a12978ccSJeremy Soller priority = ((pte_thread_t *) self)->sched_priority;
160062c5bc4SJason Schmidlapp }
161062c5bc4SJason Schmidlapp
162062c5bc4SJason Schmidlapp
163062c5bc4SJason Schmidlapp }
164062c5bc4SJason Schmidlapp else
165062c5bc4SJason Schmidlapp {
166062c5bc4SJason Schmidlapp /*
167062c5bc4SJason Schmidlapp * Default stackSize
168062c5bc4SJason Schmidlapp */
169062c5bc4SJason Schmidlapp stackSize = PTHREAD_STACK_MIN;
170062c5bc4SJason Schmidlapp
171062c5bc4SJason Schmidlapp }
172062c5bc4SJason Schmidlapp
173062c5bc4SJason Schmidlapp tp->state = run ? PThreadStateInitial : PThreadStateSuspended;
174062c5bc4SJason Schmidlapp
175062c5bc4SJason Schmidlapp tp->keys = NULL;
176062c5bc4SJason Schmidlapp
177062c5bc4SJason Schmidlapp /*
178062c5bc4SJason Schmidlapp * Threads must be started in suspended mode and resumed if necessary
179062c5bc4SJason Schmidlapp * after _beginthreadex returns us the handle. Otherwise we set up a
180062c5bc4SJason Schmidlapp * race condition between the creating and the created threads.
181062c5bc4SJason Schmidlapp * Note that we also retain a local copy of the handle for use
182062c5bc4SJason Schmidlapp * by us in case thread.p->threadH gets NULLed later but before we've
183062c5bc4SJason Schmidlapp * finished with it here.
184062c5bc4SJason Schmidlapp */
185062c5bc4SJason Schmidlapp result = pthread_mutex_lock (&tp->threadLock);
186062c5bc4SJason Schmidlapp
187062c5bc4SJason Schmidlapp if (0 == result)
188062c5bc4SJason Schmidlapp {
189062c5bc4SJason Schmidlapp /*
190062c5bc4SJason Schmidlapp * Must record the thread's sched_priority as given,
191062c5bc4SJason Schmidlapp * not as finally adjusted.
192062c5bc4SJason Schmidlapp */
193062c5bc4SJason Schmidlapp tp->sched_priority = priority;
194062c5bc4SJason Schmidlapp
195062c5bc4SJason Schmidlapp (void) pthread_mutex_unlock (&tp->threadLock);
196062c5bc4SJason Schmidlapp }
197062c5bc4SJason Schmidlapp
198062c5bc4SJason Schmidlapp osResult = pte_osThreadCreate(pte_threadStart,
199062c5bc4SJason Schmidlapp stackSize,
200062c5bc4SJason Schmidlapp priority,
201062c5bc4SJason Schmidlapp parms,
202062c5bc4SJason Schmidlapp &(tp->threadId));
203062c5bc4SJason Schmidlapp
204062c5bc4SJason Schmidlapp if (osResult == PTE_OS_OK)
205062c5bc4SJason Schmidlapp {
206062c5bc4SJason Schmidlapp pte_osThreadStart(tp->threadId);
207062c5bc4SJason Schmidlapp result = 0;
208062c5bc4SJason Schmidlapp }
209062c5bc4SJason Schmidlapp else
210062c5bc4SJason Schmidlapp {
211062c5bc4SJason Schmidlapp tp->threadId = 0;
212062c5bc4SJason Schmidlapp result = EAGAIN;
213062c5bc4SJason Schmidlapp goto FAIL0;
214062c5bc4SJason Schmidlapp }
215062c5bc4SJason Schmidlapp
216062c5bc4SJason Schmidlapp /*
217062c5bc4SJason Schmidlapp * Fall Through Intentionally
218062c5bc4SJason Schmidlapp */
219062c5bc4SJason Schmidlapp
220062c5bc4SJason Schmidlapp /*
221062c5bc4SJason Schmidlapp * ------------
222062c5bc4SJason Schmidlapp * Failure Code
223062c5bc4SJason Schmidlapp * ------------
224062c5bc4SJason Schmidlapp */
225062c5bc4SJason Schmidlapp
226062c5bc4SJason Schmidlapp FAIL0:
227062c5bc4SJason Schmidlapp if (result != 0)
228062c5bc4SJason Schmidlapp {
229062c5bc4SJason Schmidlapp
230062c5bc4SJason Schmidlapp pte_threadDestroy (thread);
231062c5bc4SJason Schmidlapp tp = NULL;
232062c5bc4SJason Schmidlapp
233062c5bc4SJason Schmidlapp if (parms != NULL)
234062c5bc4SJason Schmidlapp {
235062c5bc4SJason Schmidlapp free (parms);
236062c5bc4SJason Schmidlapp }
237062c5bc4SJason Schmidlapp }
238062c5bc4SJason Schmidlapp else
239062c5bc4SJason Schmidlapp {
240062c5bc4SJason Schmidlapp if (tid != NULL)
241062c5bc4SJason Schmidlapp {
242062c5bc4SJason Schmidlapp *tid = thread;
243062c5bc4SJason Schmidlapp }
244062c5bc4SJason Schmidlapp }
245062c5bc4SJason Schmidlapp
246062c5bc4SJason Schmidlapp return (result);
247062c5bc4SJason Schmidlapp
248062c5bc4SJason Schmidlapp } /* pthread_create */
249