WebSVN – HelenOS-historic – Diff – /uspace/trunk/libc/generic/psthread.c


/*
 * Copyright (C) 2006 Ondrej Palkovsky
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * - Redistributions of source code must retain the above copyright
 *   notice, this list of conditions and the following disclaimer.
 * - Redistributions in binary form must reproduce the above copyright
 *   notice, this list of conditions and the following disclaimer in the
 *   documentation and/or other materials provided with the distribution.
 * - The name of the author may not be used to endorse or promote products
 *   derived from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */
 
/** @addtogroup libc
 * @{
 */
/** @file
 */
 
#include <libadt/list.h>
#include <psthread.h>
#include <malloc.h>
#include <unistd.h>
#include <thread.h>
#include <stdio.h>
#include <libarch/faddr.h>
#include <futex.h>
#include <assert.h>
#include <async.h>
 
#ifndef PSTHREAD_INITIAL_STACK_PAGES_NO
#define PSTHREAD_INITIAL_STACK_PAGES_NO 1
#endif
 
static LIST_INITIALIZE(ready_list);
static LIST_INITIALIZE(serialized_list);
static LIST_INITIALIZE(manager_list);
 
static void psthread_main(void);
 
static atomic_t psthread_futex = FUTEX_INITIALIZER;
/** Count of real threads that are in async_serialized mode */
static int serialized_threads; /* Protected by async_futex */
/** Thread-local count of serialization. If >0, we must not preempt */
static __thread int serialization_count;
/** Counter of threads residing in async_manager */
static int threads_in_manager;
 
/** Setup PSthread information into TCB structure */
psthread_data_t * psthread_setup()
{
    psthread_data_t *pt;
    tcb_t *tcb;
 
    tcb = __make_tls();
    if (!tcb)
        return NULL;
 
    pt = malloc(sizeof(*pt));
    if (!pt) {
        __free_tls(tcb);
        return NULL;
    }
 
    tcb->pst_data = pt;
    pt->tcb = tcb;
 
    return pt;
}
 
void psthread_teardown(psthread_data_t *pt)
{
    __free_tls(pt->tcb);
    free(pt);
}
 
/** Function that is called on entry to new uspace thread */
void psthread_main(void)
{
    psthread_data_t *pt = __tcb_get()->pst_data;
 
    pt->retval = pt->func(pt->arg);
 
    pt->finished = 1;
    if (pt->waiter)
        list_append(&pt->waiter->link, &ready_list);
 
    psthread_schedule_next_adv(PS_FROM_DEAD);
}
 
/** Schedule next userspace pseudo thread.
 *
 * If calling with PS_TO_MANAGER parameter, the async_futex should be
 * held.
 *
 * @param ctype Type of switch.
 * @return 0 if there is no ready pseudo thread, 1 otherwise.
 */
int psthread_schedule_next_adv(pschange_type ctype)
{
    psthread_data_t *srcpt, *dstpt;
    int retval = 0;
   
    futex_down(&psthread_futex);
 
    if (ctype == PS_PREEMPT && list_empty(&ready_list))
        goto ret_0;
 
    if (ctype == PS_FROM_MANAGER) {
        if (list_empty(&ready_list) && list_empty(&serialized_list))
            goto ret_0;
        /* Do not preempt if there is not sufficient count of thread managers */
        if (list_empty(&serialized_list) && threads_in_manager <= serialized_threads) {
            goto ret_0;
        }
    }
    /* If we are going to manager and none exists, create it */
    if (ctype == PS_TO_MANAGER || ctype == PS_FROM_DEAD) {
        while (list_empty(&manager_list)) {
            futex_up(&psthread_futex);
            async_create_manager();
            futex_down(&psthread_futex);
        }
    }
   
    if (ctype != PS_FROM_DEAD) {
        /* Save current state */
        srcpt = __tcb_get()->pst_data;
        if (!context_save(&srcpt->ctx)) {
            if (serialization_count)
                srcpt->flags &= ~PSTHREAD_SERIALIZED;
            return 1; // futex_up already done here
        }
 
        /* Save myself to correct run list */
        if (ctype == PS_PREEMPT)
            list_append(&srcpt->link, &ready_list);
        else if (ctype == PS_FROM_MANAGER) {
            list_append(&srcpt->link, &manager_list);
            threads_in_manager--;
        } /* If ctype == PS_TO_MANAGER, don't save ourselves to any list, we should
           * already be somewhere, or we will be lost */
    } else
        srcpt = NULL; /* Avoid GCC warning, if ctype == PS_FROM_DEAD, srcpt is not used */
 
    /* Choose new thread to run */
    if (ctype == PS_TO_MANAGER || ctype == PS_FROM_DEAD) {
        dstpt = list_get_instance(manager_list.next,psthread_data_t, link);
        if (serialization_count && ctype == PS_TO_MANAGER) {
            serialized_threads++;
            srcpt->flags |= PSTHREAD_SERIALIZED;
        }
        threads_in_manager++;
    } else {
        if (!list_empty(&serialized_list)) {
            dstpt = list_get_instance(serialized_list.next, psthread_data_t, link);
            serialized_threads--;
        } else
            dstpt = list_get_instance(ready_list.next, psthread_data_t, link);
    }
    list_remove(&dstpt->link);
 
    futex_up(&psthread_futex);
    context_restore(&dstpt->ctx);
 
ret_0:
    futex_up(&psthread_futex);
    return retval;
}
 
/** Wait for uspace pseudo thread to finish.
 *
 * @param psthrid Pseudo thread to wait for.
 *
 * @return Value returned by the finished thread.
 */
int psthread_join(pstid_t psthrid)
{
    volatile psthread_data_t *pt;
    volatile int retval;
 
    /* Handle psthrid = Kernel address -> it is wait for call */
    pt = (psthread_data_t *) psthrid;
 
    /* TODO */
    printf("join unsupported\n");
    _exit(1);
 
    retval = pt->retval;
 
    free(pt->stack);
    psthread_teardown((void *)pt);
 
    return retval;
}
 
/**
 * Create a userspace thread
 *
 * @param func Pseudo thread function.
 * @param arg Argument to pass to func.
 *
 * @return 0 on failure, TLS of the new pseudo thread.
 */
pstid_t psthread_create(int (*func)(void *), void *arg)
{
    psthread_data_t *pt;
 
    pt = psthread_setup();
    if (!pt)
        return 0;
    pt->stack = (char *) malloc(PSTHREAD_INITIAL_STACK_PAGES_NO*getpagesize());
 
    if (!pt->stack) {
        psthread_teardown(pt);
        return 0;
    }
 
    pt->arg= arg;
    pt->func = func;
    pt->finished = 0;
    pt->waiter = NULL;
    pt->flags = 0;
 
    context_save(&pt->ctx);
    context_set(&pt->ctx, FADDR(psthread_main), pt->stack, PSTHREAD_INITIAL_STACK_PAGES_NO*getpagesize(), pt->tcb);
 
    return (pstid_t )pt;
}
 
/** Add a thread to ready list */
void psthread_add_ready(pstid_t psthrid)
{
    psthread_data_t *pt;
 
    pt = (psthread_data_t *) psthrid;
    futex_down(&psthread_futex);
    if ((pt->flags & PSTHREAD_SERIALIZED))
        list_append(&pt->link, &serialized_list);
    else
        list_append(&pt->link, &ready_list);
    futex_up(&psthread_futex);
}
 
/** Add a thread to manager list */
void psthread_add_manager(pstid_t psthrid)
{
    psthread_data_t *pt;
 
    pt = (psthread_data_t *) psthrid;
 
    futex_down(&psthread_futex);
    list_append(&pt->link, &manager_list);
    futex_up(&psthread_futex);
}
 
/** Remove one manager from manager list */
void psthread_remove_manager()
{
    futex_down(&psthread_futex);
    if (list_empty(&manager_list)) {
        futex_up(&psthread_futex);
        return;
    }
    list_remove(manager_list.next);
    futex_up(&psthread_futex);
}
 
/** Return thread id of current running thread */
pstid_t psthread_get_id(void)
{
    return (pstid_t)__tcb_get()->pst_data;
}
 
/** Disable preemption
 *
 * If the thread wants to send several message in row and does not want
 * to be preempted, it should start async_serialize_start() in the beginning
 * of communication and async_serialize_end() in the end. If it is a
 * true multithreaded application, it should protect the communication channel
 * by a futex as well. Interrupt messages will can still be preempted.
 */
void psthread_inc_sercount(void)
{
    serialization_count++;
}
 
void psthread_dec_sercount(void)
{
    serialization_count--;
}
 
 
/** @}
 */
 

Rev 1720	Rev 1781
1	/*	1	/*
2	* Copyright (C) 2006 Ondrej Palkovsky	2	* Copyright (C) 2006 Ondrej Palkovsky
3	* All rights reserved.	3	* All rights reserved.
4	*	4	*
5	* Redistribution and use in source and binary forms, with or without	5	* Redistribution and use in source and binary forms, with or without
6	* modification, are permitted provided that the following conditions	6	* modification, are permitted provided that the following conditions
7	* are met:	7	* are met:
8	*	8	*
9	* - Redistributions of source code must retain the above copyright	9	* - Redistributions of source code must retain the above copyright
10	* notice, this list of conditions and the following disclaimer.	10	* notice, this list of conditions and the following disclaimer.
11	* - Redistributions in binary form must reproduce the above copyright	11	* - Redistributions in binary form must reproduce the above copyright
12	* notice, this list of conditions and the following disclaimer in the	12	* notice, this list of conditions and the following disclaimer in the
13	* documentation and/or other materials provided with the distribution.	13	* documentation and/or other materials provided with the distribution.
14	* - The name of the author may not be used to endorse or promote products	14	* - The name of the author may not be used to endorse or promote products
15	* derived from this software without specific prior written permission.	15	* derived from this software without specific prior written permission.
16	*	16	*
17	* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR	17	* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
18	* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES	18	* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
19	* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.	19	* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20	* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,	20	* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
21	* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT	21	* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
22	* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,	22	* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
23	* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY	23	* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
24	* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT	24	* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
25	* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF	25	* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
26	* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.	26	* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27	*/	27	*/
28		28
29	/** @addtogroup libc	29	/** @addtogroup libc
30	* @{	30	* @{
31	*/	31	*/
32	/** @file	32	/** @file
33	*/	33	*/
34		34
35	#include <libadt/list.h>	35	#include <libadt/list.h>
36	#include <psthread.h>	36	#include <psthread.h>
37	#include <malloc.h>	37	#include <malloc.h>
38	#include <unistd.h>	38	#include <unistd.h>
39	#include <thread.h>	39	#include <thread.h>
40	#include <stdio.h>	40	#include <stdio.h>
41	#include <kernel/arch/faddr.h>	41	#include <libarch/faddr.h>
42	#include <futex.h>	42	#include <futex.h>
43	#include <assert.h>	43	#include <assert.h>
44	#include <async.h>	44	#include <async.h>
45		45
46	#ifndef PSTHREAD_INITIAL_STACK_PAGES_NO	46	#ifndef PSTHREAD_INITIAL_STACK_PAGES_NO
47	#define PSTHREAD_INITIAL_STACK_PAGES_NO 1	47	#define PSTHREAD_INITIAL_STACK_PAGES_NO 1
48	#endif	48	#endif
49		49
50	static LIST_INITIALIZE(ready_list);	50	static LIST_INITIALIZE(ready_list);
51	static LIST_INITIALIZE(serialized_list);	51	static LIST_INITIALIZE(serialized_list);
52	static LIST_INITIALIZE(manager_list);	52	static LIST_INITIALIZE(manager_list);
53		53
54	static void psthread_main(void);	54	static void psthread_main(void);
55		55
56	static atomic_t psthread_futex = FUTEX_INITIALIZER;	56	static atomic_t psthread_futex = FUTEX_INITIALIZER;
57	/** Count of real threads that are in async_serialized mode */	57	/** Count of real threads that are in async_serialized mode */
58	static int serialized_threads; /* Protected by async_futex */	58	static int serialized_threads; /* Protected by async_futex */
59	/** Thread-local count of serialization. If >0, we must not preempt */	59	/** Thread-local count of serialization. If >0, we must not preempt */
60	static __thread int serialization_count;	60	static __thread int serialization_count;
61	/** Counter of threads residing in async_manager */	61	/** Counter of threads residing in async_manager */
62	static int threads_in_manager;	62	static int threads_in_manager;
63		63
64	/** Setup PSthread information into TCB structure */	64	/** Setup PSthread information into TCB structure */
65	psthread_data_t * psthread_setup()	65	psthread_data_t * psthread_setup()
66	{	66	{
67	psthread_data_t *pt;	67	psthread_data_t *pt;
68	tcb_t *tcb;	68	tcb_t *tcb;
69		69
70	tcb = __make_tls();	70	tcb = __make_tls();
71	if (!tcb)	71	if (!tcb)
72	return NULL;	72	return NULL;
73		73
74	pt = malloc(sizeof(*pt));	74	pt = malloc(sizeof(*pt));
75	if (!pt) {	75	if (!pt) {
76	__free_tls(tcb);	76	__free_tls(tcb);
77	return NULL;	77	return NULL;
78	}	78	}
79		79
80	tcb->pst_data = pt;	80	tcb->pst_data = pt;
81	pt->tcb = tcb;	81	pt->tcb = tcb;
82		82
83	return pt;	83	return pt;
84	}	84	}
85		85
86	void psthread_teardown(psthread_data_t *pt)	86	void psthread_teardown(psthread_data_t *pt)
87	{	87	{
88	__free_tls(pt->tcb);	88	__free_tls(pt->tcb);
89	free(pt);	89	free(pt);
90	}	90	}
91		91
92	/** Function that is called on entry to new uspace thread */	92	/** Function that is called on entry to new uspace thread */
93	void psthread_main(void)	93	void psthread_main(void)
94	{	94	{
95	psthread_data_t *pt = __tcb_get()->pst_data;	95	psthread_data_t *pt = __tcb_get()->pst_data;
96		96
97	pt->retval = pt->func(pt->arg);	97	pt->retval = pt->func(pt->arg);
98		98
99	pt->finished = 1;	99	pt->finished = 1;
100	if (pt->waiter)	100	if (pt->waiter)
101	list_append(&pt->waiter->link, &ready_list);	101	list_append(&pt->waiter->link, &ready_list);
102		102
103	psthread_schedule_next_adv(PS_FROM_DEAD);	103	psthread_schedule_next_adv(PS_FROM_DEAD);
104	}	104	}
105		105
106	/** Schedule next userspace pseudo thread.	106	/** Schedule next userspace pseudo thread.
107	*	107	*
108	* If calling with PS_TO_MANAGER parameter, the async_futex should be	108	* If calling with PS_TO_MANAGER parameter, the async_futex should be
109	* held.	109	* held.
110	*	110	*
111	* @param ctype Type of switch.	111	* @param ctype Type of switch.
112	* @return 0 if there is no ready pseudo thread, 1 otherwise.	112	* @return 0 if there is no ready pseudo thread, 1 otherwise.
113	*/	113	*/
114	int psthread_schedule_next_adv(pschange_type ctype)	114	int psthread_schedule_next_adv(pschange_type ctype)
115	{	115	{
116	psthread_data_t srcpt, dstpt;	116	psthread_data_t srcpt, dstpt;
117	int retval = 0;	117	int retval = 0;
118		118
119	futex_down(&psthread_futex);	119	futex_down(&psthread_futex);
120		120
121	if (ctype == PS_PREEMPT && list_empty(&ready_list))	121	if (ctype == PS_PREEMPT && list_empty(&ready_list))
122	goto ret_0;	122	goto ret_0;
123		123
124	if (ctype == PS_FROM_MANAGER) {	124	if (ctype == PS_FROM_MANAGER) {
125	if (list_empty(&ready_list) && list_empty(&serialized_list))	125	if (list_empty(&ready_list) && list_empty(&serialized_list))
126	goto ret_0;	126	goto ret_0;
127	/* Do not preempt if there is not sufficient count of thread managers */	127	/* Do not preempt if there is not sufficient count of thread managers */
128	if (list_empty(&serialized_list) && threads_in_manager <= serialized_threads) {	128	if (list_empty(&serialized_list) && threads_in_manager <= serialized_threads) {
129	goto ret_0;	129	goto ret_0;
130	}	130	}
131	}	131	}
132	/* If we are going to manager and none exists, create it */	132	/* If we are going to manager and none exists, create it */
133	if (ctype == PS_TO_MANAGER \|\| ctype == PS_FROM_DEAD) {	133	if (ctype == PS_TO_MANAGER \|\| ctype == PS_FROM_DEAD) {
134	while (list_empty(&manager_list)) {	134	while (list_empty(&manager_list)) {
135	futex_up(&psthread_futex);	135	futex_up(&psthread_futex);
136	async_create_manager();	136	async_create_manager();
137	futex_down(&psthread_futex);	137	futex_down(&psthread_futex);
138	}	138	}
139	}	139	}
140		140
141	if (ctype != PS_FROM_DEAD) {	141	if (ctype != PS_FROM_DEAD) {
142	/* Save current state */	142	/* Save current state */
143	srcpt = __tcb_get()->pst_data;	143	srcpt = __tcb_get()->pst_data;
144	if (!context_save(&srcpt->ctx)) {	144	if (!context_save(&srcpt->ctx)) {
145	if (serialization_count)	145	if (serialization_count)
146	srcpt->flags &= ~PSTHREAD_SERIALIZED;	146	srcpt->flags &= ~PSTHREAD_SERIALIZED;
147	return 1; // futex_up already done here	147	return 1; // futex_up already done here
148	}	148	}
149		149
150	/* Save myself to correct run list */	150	/* Save myself to correct run list */
151	if (ctype == PS_PREEMPT)	151	if (ctype == PS_PREEMPT)
152	list_append(&srcpt->link, &ready_list);	152	list_append(&srcpt->link, &ready_list);
153	else if (ctype == PS_FROM_MANAGER) {	153	else if (ctype == PS_FROM_MANAGER) {
154	list_append(&srcpt->link, &manager_list);	154	list_append(&srcpt->link, &manager_list);
155	threads_in_manager--;	155	threads_in_manager--;
156	} /* If ctype == PS_TO_MANAGER, don't save ourselves to any list, we should	156	} /* If ctype == PS_TO_MANAGER, don't save ourselves to any list, we should
157	* already be somewhere, or we will be lost */	157	* already be somewhere, or we will be lost */
158	} else	158	} else
159	srcpt = NULL; /* Avoid GCC warning, if ctype == PS_FROM_DEAD, srcpt is not used */	159	srcpt = NULL; /* Avoid GCC warning, if ctype == PS_FROM_DEAD, srcpt is not used */
160		160
161	/* Choose new thread to run */	161	/* Choose new thread to run */
162	if (ctype == PS_TO_MANAGER \|\| ctype == PS_FROM_DEAD) {	162	if (ctype == PS_TO_MANAGER \|\| ctype == PS_FROM_DEAD) {
163	dstpt = list_get_instance(manager_list.next,psthread_data_t, link);	163	dstpt = list_get_instance(manager_list.next,psthread_data_t, link);
164	if (serialization_count && ctype == PS_TO_MANAGER) {	164	if (serialization_count && ctype == PS_TO_MANAGER) {
165	serialized_threads++;	165	serialized_threads++;
166	srcpt->flags \|= PSTHREAD_SERIALIZED;	166	srcpt->flags \|= PSTHREAD_SERIALIZED;
167	}	167	}
168	threads_in_manager++;	168	threads_in_manager++;
169	} else {	169	} else {
170	if (!list_empty(&serialized_list)) {	170	if (!list_empty(&serialized_list)) {
171	dstpt = list_get_instance(serialized_list.next, psthread_data_t, link);	171	dstpt = list_get_instance(serialized_list.next, psthread_data_t, link);
172	serialized_threads--;	172	serialized_threads--;
173	} else	173	} else
174	dstpt = list_get_instance(ready_list.next, psthread_data_t, link);	174	dstpt = list_get_instance(ready_list.next, psthread_data_t, link);
175	}	175	}
176	list_remove(&dstpt->link);	176	list_remove(&dstpt->link);
177		177
178	futex_up(&psthread_futex);	178	futex_up(&psthread_futex);
179	context_restore(&dstpt->ctx);	179	context_restore(&dstpt->ctx);
180		180
181	ret_0:	181	ret_0:
182	futex_up(&psthread_futex);	182	futex_up(&psthread_futex);
183	return retval;	183	return retval;
184	}	184	}
185		185
186	/** Wait for uspace pseudo thread to finish.	186	/** Wait for uspace pseudo thread to finish.
187	*	187	*
188	* @param psthrid Pseudo thread to wait for.	188	* @param psthrid Pseudo thread to wait for.
189	*	189	*
190	* @return Value returned by the finished thread.	190	* @return Value returned by the finished thread.
191	*/	191	*/
192	int psthread_join(pstid_t psthrid)	192	int psthread_join(pstid_t psthrid)
193	{	193	{
194	volatile psthread_data_t *pt;	194	volatile psthread_data_t *pt;
195	volatile int retval;	195	volatile int retval;
196		196
197	/* Handle psthrid = Kernel address -> it is wait for call */	197	/* Handle psthrid = Kernel address -> it is wait for call */
198	pt = (psthread_data_t *) psthrid;	198	pt = (psthread_data_t *) psthrid;
199		199
200	/* TODO */	200	/* TODO */
201	printf("join unsupported\n");	201	printf("join unsupported\n");
202	_exit(1);	202	_exit(1);
203		203
204	retval = pt->retval;	204	retval = pt->retval;
205		205
206	free(pt->stack);	206	free(pt->stack);
207	psthread_teardown((void *)pt);	207	psthread_teardown((void *)pt);
208		208
209	return retval;	209	return retval;
210	}	210	}
211		211
212	/**	212	/**
213	* Create a userspace thread	213	* Create a userspace thread
214	*	214	*
215	* @param func Pseudo thread function.	215	* @param func Pseudo thread function.
216	* @param arg Argument to pass to func.	216	* @param arg Argument to pass to func.
217	*	217	*
218	* @return 0 on failure, TLS of the new pseudo thread.	218	* @return 0 on failure, TLS of the new pseudo thread.
219	*/	219	*/
220	pstid_t psthread_create(int (func)(void ), void *arg)	220	pstid_t psthread_create(int (func)(void ), void *arg)
221	{	221	{
222	psthread_data_t *pt;	222	psthread_data_t *pt;
223		223
224	pt = psthread_setup();	224	pt = psthread_setup();
225	if (!pt)	225	if (!pt)
226	return 0;	226	return 0;
227	pt->stack = (char ) malloc(PSTHREAD_INITIAL_STACK_PAGES_NOgetpagesize());	227	pt->stack = (char ) malloc(PSTHREAD_INITIAL_STACK_PAGES_NOgetpagesize());
228		228
229	if (!pt->stack) {	229	if (!pt->stack) {
230	psthread_teardown(pt);	230	psthread_teardown(pt);
231	return 0;	231	return 0;
232	}	232	}
233		233
234	pt->arg= arg;	234	pt->arg= arg;
235	pt->func = func;	235	pt->func = func;
236	pt->finished = 0;	236	pt->finished = 0;
237	pt->waiter = NULL;	237	pt->waiter = NULL;
238	pt->flags = 0;	238	pt->flags = 0;
239		239
240	context_save(&pt->ctx);	240	context_save(&pt->ctx);
241	context_set(&pt->ctx, FADDR(psthread_main), pt->stack, PSTHREAD_INITIAL_STACK_PAGES_NO*getpagesize(), pt->tcb);	241	context_set(&pt->ctx, FADDR(psthread_main), pt->stack, PSTHREAD_INITIAL_STACK_PAGES_NO*getpagesize(), pt->tcb);
242		242
243	return (pstid_t )pt;	243	return (pstid_t )pt;
244	}	244	}
245		245
246	/** Add a thread to ready list */	246	/** Add a thread to ready list */
247	void psthread_add_ready(pstid_t psthrid)	247	void psthread_add_ready(pstid_t psthrid)
248	{	248	{
249	psthread_data_t *pt;	249	psthread_data_t *pt;
250		250
251	pt = (psthread_data_t *) psthrid;	251	pt = (psthread_data_t *) psthrid;
252	futex_down(&psthread_futex);	252	futex_down(&psthread_futex);
253	if ((pt->flags & PSTHREAD_SERIALIZED))	253	if ((pt->flags & PSTHREAD_SERIALIZED))
254	list_append(&pt->link, &serialized_list);	254	list_append(&pt->link, &serialized_list);
255	else	255	else
256	list_append(&pt->link, &ready_list);	256	list_append(&pt->link, &ready_list);
257	futex_up(&psthread_futex);	257	futex_up(&psthread_futex);
258	}	258	}
259		259
260	/** Add a thread to manager list */	260	/** Add a thread to manager list */
261	void psthread_add_manager(pstid_t psthrid)	261	void psthread_add_manager(pstid_t psthrid)
262	{	262	{
263	psthread_data_t *pt;	263	psthread_data_t *pt;
264		264
265	pt = (psthread_data_t *) psthrid;	265	pt = (psthread_data_t *) psthrid;
266		266
267	futex_down(&psthread_futex);	267	futex_down(&psthread_futex);
268	list_append(&pt->link, &manager_list);	268	list_append(&pt->link, &manager_list);
269	futex_up(&psthread_futex);	269	futex_up(&psthread_futex);
270	}	270	}
271		271
272	/** Remove one manager from manager list */	272	/** Remove one manager from manager list */
273	void psthread_remove_manager()	273	void psthread_remove_manager()
274	{	274	{
275	futex_down(&psthread_futex);	275	futex_down(&psthread_futex);
276	if (list_empty(&manager_list)) {	276	if (list_empty(&manager_list)) {
277	futex_up(&psthread_futex);	277	futex_up(&psthread_futex);
278	return;	278	return;
279	}	279	}
280	list_remove(manager_list.next);	280	list_remove(manager_list.next);
281	futex_up(&psthread_futex);	281	futex_up(&psthread_futex);
282	}	282	}
283		283
284	/** Return thread id of current running thread */	284	/** Return thread id of current running thread */
285	pstid_t psthread_get_id(void)	285	pstid_t psthread_get_id(void)
286	{	286	{
287	return (pstid_t)__tcb_get()->pst_data;	287	return (pstid_t)__tcb_get()->pst_data;
288	}	288	}
289		289
290	/** Disable preemption	290	/** Disable preemption
291	*	291	*
292	* If the thread wants to send several message in row and does not want	292	* If the thread wants to send several message in row and does not want
293	* to be preempted, it should start async_serialize_start() in the beginning	293	* to be preempted, it should start async_serialize_start() in the beginning
294	* of communication and async_serialize_end() in the end. If it is a	294	* of communication and async_serialize_end() in the end. If it is a
295	* true multithreaded application, it should protect the communication channel	295	* true multithreaded application, it should protect the communication channel
296	* by a futex as well. Interrupt messages will can still be preempted.	296	* by a futex as well. Interrupt messages will can still be preempted.
297	*/	297	*/
298	void psthread_inc_sercount(void)	298	void psthread_inc_sercount(void)
299	{	299	{
300	serialization_count++;	300	serialization_count++;
301	}	301	}
302		302
303	void psthread_dec_sercount(void)	303	void psthread_dec_sercount(void)
304	{	304	{
305	serialization_count--;	305	serialization_count--;
306	}	306	}
307		307
308		308
309	/** @}	309	/** @}
310	*/	310	*/
311		311

Subversion Repositories HelenOS-historic

(root)/uspace/trunk/libc/generic/psthread.c – Rev 1720 → 1781