WebSVN – HelenOS – Diff – /tags/0.2.0.1/uspace/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 <kernel/arch/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_exit(void) __attribute__ ((noinline));
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 tomanager If true, we are switching to next ready manager thread
 *                  (if none is found, thread is exited)
 * @param frommanager If true, we are switching from manager thread
 * @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 */
    }
 
    /* 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, *mypt;
    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 1965	Rev 1968
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 <kernel/arch/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_exit(void) __attribute__ ((noinline));	54	static void psthread_exit(void) __attribute__ ((noinline));
55	static void psthread_main(void);	55	static void psthread_main(void);
56		56
57	static atomic_t psthread_futex = FUTEX_INITIALIZER;	57	static atomic_t psthread_futex = FUTEX_INITIALIZER;
58	/** Count of real threads that are in async_serialized mode */	58	/** Count of real threads that are in async_serialized mode */
59	static int serialized_threads; /* Protected by async_futex */	59	static int serialized_threads; /* Protected by async_futex */
60	/** Thread-local count of serialization. If >0, we must not preempt */	60	/** Thread-local count of serialization. If >0, we must not preempt */
61	static __thread int serialization_count;	61	static __thread int serialization_count;
62	/** Counter of threads residing in async_manager */	62	/** Counter of threads residing in async_manager */
63	static int threads_in_manager;	63	static int threads_in_manager;
64		64
65	/** Setup PSthread information into TCB structure */	65	/** Setup PSthread information into TCB structure */
66	psthread_data_t * psthread_setup()	66	psthread_data_t * psthread_setup()
67	{	67	{
68	psthread_data_t *pt;	68	psthread_data_t *pt;
69	tcb_t *tcb;	69	tcb_t *tcb;
70		70
71	tcb = __make_tls();	71	tcb = __make_tls();
72	if (!tcb)	72	if (!tcb)
73	return NULL;	73	return NULL;
74		74
75	pt = malloc(sizeof(*pt));	75	pt = malloc(sizeof(*pt));
76	if (!pt) {	76	if (!pt) {
77	__free_tls(tcb);	77	__free_tls(tcb);
78	return NULL;	78	return NULL;
79	}	79	}
80		80
81	tcb->pst_data = pt;	81	tcb->pst_data = pt;
82	pt->tcb = tcb;	82	pt->tcb = tcb;
83		83
84	return pt;	84	return pt;
85	}	85	}
86		86
87	void psthread_teardown(psthread_data_t *pt)	87	void psthread_teardown(psthread_data_t *pt)
88	{	88	{
89	__free_tls(pt->tcb);	89	__free_tls(pt->tcb);
90	free(pt);	90	free(pt);
91	}	91	}
92		92
93	/** Function that is called on entry to new uspace thread */	93	/** Function that is called on entry to new uspace thread */
94	void psthread_main(void)	94	void psthread_main(void)
95	{	95	{
96	psthread_data_t *pt = __tcb_get()->pst_data;	96	psthread_data_t *pt = __tcb_get()->pst_data;
97		97
98	pt->retval = pt->func(pt->arg);	98	pt->retval = pt->func(pt->arg);
99		99
100	pt->finished = 1;	100	pt->finished = 1;
101	if (pt->waiter)	101	if (pt->waiter)
102	list_append(&pt->waiter->link, &ready_list);	102	list_append(&pt->waiter->link, &ready_list);
103		103
104	psthread_schedule_next_adv(PS_FROM_DEAD);	104	psthread_schedule_next_adv(PS_FROM_DEAD);
105	}	105	}
106		106
107	/** Schedule next userspace pseudo thread.	107	/** Schedule next userspace pseudo thread.
108	*	108	*
109	* If calling with PS_TO_MANAGER parameter, the async_futex should be	109	* If calling with PS_TO_MANAGER parameter, the async_futex should be
110	* held.	110	* held.
111	*	111	*
112	* @param tomanager If true, we are switching to next ready manager thread	112	* @param tomanager If true, we are switching to next ready manager thread
113	* (if none is found, thread is exited)	113	* (if none is found, thread is exited)
114	* @param frommanager If true, we are switching from manager thread	114	* @param frommanager If true, we are switching from manager thread
115	* @return 0 if there is no ready pseudo thread, 1 otherwise.	115	* @return 0 if there is no ready pseudo thread, 1 otherwise.
116	*/	116	*/
117	int psthread_schedule_next_adv(pschange_type ctype)	117	int psthread_schedule_next_adv(pschange_type ctype)
118	{	118	{
119	psthread_data_t srcpt, dstpt;	119	psthread_data_t srcpt, dstpt;
120	int retval = 0;	120	int retval = 0;
121		121
122	futex_down(&psthread_futex);	122	futex_down(&psthread_futex);
123		123
124	if (ctype == PS_PREEMPT && list_empty(&ready_list))	124	if (ctype == PS_PREEMPT && list_empty(&ready_list))
125	goto ret_0;	125	goto ret_0;
126		126
127	if (ctype == PS_FROM_MANAGER) {	127	if (ctype == PS_FROM_MANAGER) {
128	if (list_empty(&ready_list) && list_empty(&serialized_list))	128	if (list_empty(&ready_list) && list_empty(&serialized_list))
129	goto ret_0;	129	goto ret_0;
130	/* Do not preempt if there is not sufficient count of thread managers */	130	/* Do not preempt if there is not sufficient count of thread managers */
131	if (list_empty(&serialized_list) && threads_in_manager <= serialized_threads) {	131	if (list_empty(&serialized_list) && threads_in_manager <= serialized_threads) {
132	goto ret_0;	132	goto ret_0;
133	}	133	}
134	}	134	}
135	/* If we are going to manager and none exists, create it */	135	/* If we are going to manager and none exists, create it */
136	if (ctype == PS_TO_MANAGER \|\| ctype == PS_FROM_DEAD) {	136	if (ctype == PS_TO_MANAGER \|\| ctype == PS_FROM_DEAD) {
137	while (list_empty(&manager_list)) {	137	while (list_empty(&manager_list)) {
138	futex_up(&psthread_futex);	138	futex_up(&psthread_futex);
139	async_create_manager();	139	async_create_manager();
140	futex_down(&psthread_futex);	140	futex_down(&psthread_futex);
141	}	141	}
142	}	142	}
143		143
144	if (ctype != PS_FROM_DEAD) {	144	if (ctype != PS_FROM_DEAD) {
145	/* Save current state */	145	/* Save current state */
146	srcpt = __tcb_get()->pst_data;	146	srcpt = __tcb_get()->pst_data;
147	if (!context_save(&srcpt->ctx)) {	147	if (!context_save(&srcpt->ctx)) {
148	if (serialization_count)	148	if (serialization_count)
149	srcpt->flags &= ~PSTHREAD_SERIALIZED;	149	srcpt->flags &= ~PSTHREAD_SERIALIZED;
150	return 1; // futex_up already done here	150	return 1; // futex_up already done here
151	}	151	}
152		152
153	/* Save myself to correct run list */	153	/* Save myself to correct run list */
154	if (ctype == PS_PREEMPT)	154	if (ctype == PS_PREEMPT)
155	list_append(&srcpt->link, &ready_list);	155	list_append(&srcpt->link, &ready_list);
156	else if (ctype == PS_FROM_MANAGER) {	156	else if (ctype == PS_FROM_MANAGER) {
157	list_append(&srcpt->link, &manager_list);	157	list_append(&srcpt->link, &manager_list);
158	threads_in_manager--;	158	threads_in_manager--;
159	} /* If ctype == PS_TO_MANAGER, don't save ourselves to any list, we should	159	} /* If ctype == PS_TO_MANAGER, don't save ourselves to any list, we should
160	* already be somewhere, or we will be lost */	160	* already be somewhere, or we will be lost */
161	}	161	}
162		162
163	/* Choose new thread to run */	163	/* Choose new thread to run */
164	if (ctype == PS_TO_MANAGER \|\| ctype == PS_FROM_DEAD) {	164	if (ctype == PS_TO_MANAGER \|\| ctype == PS_FROM_DEAD) {
165	dstpt = list_get_instance(manager_list.next,psthread_data_t, link);	165	dstpt = list_get_instance(manager_list.next,psthread_data_t, link);
166	if (serialization_count && ctype == PS_TO_MANAGER) {	166	if (serialization_count && ctype == PS_TO_MANAGER) {
167	serialized_threads++;	167	serialized_threads++;
168	srcpt->flags \|= PSTHREAD_SERIALIZED;	168	srcpt->flags \|= PSTHREAD_SERIALIZED;
169	}	169	}
170	threads_in_manager++;	170	threads_in_manager++;
171	} else {	171	} else {
172	if (!list_empty(&serialized_list)) {	172	if (!list_empty(&serialized_list)) {
173	dstpt = list_get_instance(serialized_list.next, psthread_data_t, link);	173	dstpt = list_get_instance(serialized_list.next, psthread_data_t, link);
174	serialized_threads--;	174	serialized_threads--;
175	} else	175	} else
176	dstpt = list_get_instance(ready_list.next, psthread_data_t, link);	176	dstpt = list_get_instance(ready_list.next, psthread_data_t, link);
177	}	177	}
178	list_remove(&dstpt->link);	178	list_remove(&dstpt->link);
179		179
180	futex_up(&psthread_futex);	180	futex_up(&psthread_futex);
181	context_restore(&dstpt->ctx);	181	context_restore(&dstpt->ctx);
182		182
183	ret_0:	183	ret_0:
184	futex_up(&psthread_futex);	184	futex_up(&psthread_futex);
185	return retval;	185	return retval;
186	}	186	}
187		187
188	/** Wait for uspace pseudo thread to finish.	188	/** Wait for uspace pseudo thread to finish.
189	*	189	*
190	* @param psthrid Pseudo thread to wait for.	190	* @param psthrid Pseudo thread to wait for.
191	*	191	*
192	* @return Value returned by the finished thread.	192	* @return Value returned by the finished thread.
193	*/	193	*/
194	int psthread_join(pstid_t psthrid)	194	int psthread_join(pstid_t psthrid)
195	{	195	{
196	volatile psthread_data_t pt, mypt;	196	volatile psthread_data_t pt, mypt;
197	volatile int retval;	197	volatile int retval;
198		198
199	/* Handle psthrid = Kernel address -> it is wait for call */	199	/* Handle psthrid = Kernel address -> it is wait for call */
200	pt = (psthread_data_t *) psthrid;	200	pt = (psthread_data_t *) psthrid;
201		201
202	/* TODO */	202	/* TODO */
203	printf("join unsupported\n");	203	printf("join unsupported\n");
204	_exit(1);	204	_exit(1);
205		205
206	retval = pt->retval;	206	retval = pt->retval;
207		207
208	free(pt->stack);	208	free(pt->stack);
209	psthread_teardown((void *)pt);	209	psthread_teardown((void *)pt);
210		210
211	return retval;	211	return retval;
212	}	212	}
213		213
214	/**	214	/**
215	* Create a userspace thread	215	* Create a userspace thread
216	*	216	*
217	* @param func Pseudo thread function.	217	* @param func Pseudo thread function.
218	* @param arg Argument to pass to func.	218	* @param arg Argument to pass to func.
219	*	219	*
220	* @return 0 on failure, TLS of the new pseudo thread.	220	* @return 0 on failure, TLS of the new pseudo thread.
221	*/	221	*/
222	pstid_t psthread_create(int (func)(void ), void *arg)	222	pstid_t psthread_create(int (func)(void ), void *arg)
223	{	223	{
224	psthread_data_t *pt;	224	psthread_data_t *pt;
225		225
226	pt = psthread_setup();	226	pt = psthread_setup();
227	if (!pt)	227	if (!pt)
228	return 0;	228	return 0;
229	pt->stack = (char ) malloc(PSTHREAD_INITIAL_STACK_PAGES_NOgetpagesize());	229	pt->stack = (char ) malloc(PSTHREAD_INITIAL_STACK_PAGES_NOgetpagesize());
230		230
231	if (!pt->stack) {	231	if (!pt->stack) {
232	psthread_teardown(pt);	232	psthread_teardown(pt);
233	return 0;	233	return 0;
234	}	234	}
235		235
236	pt->arg= arg;	236	pt->arg= arg;
237	pt->func = func;	237	pt->func = func;
238	pt->finished = 0;	238	pt->finished = 0;
239	pt->waiter = NULL;	239	pt->waiter = NULL;
240	pt->flags = 0;	240	pt->flags = 0;
241		241
242	context_save(&pt->ctx);	242	context_save(&pt->ctx);
243	context_set(&pt->ctx, FADDR(psthread_main), pt->stack, PSTHREAD_INITIAL_STACK_PAGES_NO*getpagesize(),	243	context_set(&pt->ctx, FADDR(psthread_main), pt->stack, PSTHREAD_INITIAL_STACK_PAGES_NO*getpagesize(),
244	pt->tcb);	244	pt->tcb);
245		245
246	return (pstid_t )pt;	246	return (pstid_t )pt;
247	}	247	}
248		248
249	/** Add a thread to ready list */	249	/** Add a thread to ready list */
250	void psthread_add_ready(pstid_t psthrid)	250	void psthread_add_ready(pstid_t psthrid)
251	{	251	{
252	psthread_data_t *pt;	252	psthread_data_t *pt;
253		253
254	pt = (psthread_data_t *) psthrid;	254	pt = (psthread_data_t *) psthrid;
255	futex_down(&psthread_futex);	255	futex_down(&psthread_futex);
256	if ((pt->flags & PSTHREAD_SERIALIZED))	256	if ((pt->flags & PSTHREAD_SERIALIZED))
257	list_append(&pt->link, &serialized_list);	257	list_append(&pt->link, &serialized_list);
258	else	258	else
259	list_append(&pt->link, &ready_list);	259	list_append(&pt->link, &ready_list);
260	futex_up(&psthread_futex);	260	futex_up(&psthread_futex);
261	}	261	}
262		262
263	/** Add a thread to manager list */	263	/** Add a thread to manager list */
264	void psthread_add_manager(pstid_t psthrid)	264	void psthread_add_manager(pstid_t psthrid)
265	{	265	{
266	psthread_data_t *pt;	266	psthread_data_t *pt;
267		267
268	pt = (psthread_data_t *) psthrid;	268	pt = (psthread_data_t *) psthrid;
269		269
270	futex_down(&psthread_futex);	270	futex_down(&psthread_futex);
271	list_append(&pt->link, &manager_list);	271	list_append(&pt->link, &manager_list);
272	futex_up(&psthread_futex);	272	futex_up(&psthread_futex);
273	}	273	}
274		274
275	/** Remove one manager from manager list */	275	/** Remove one manager from manager list */
276	void psthread_remove_manager()	276	void psthread_remove_manager()
277	{	277	{
278	futex_down(&psthread_futex);	278	futex_down(&psthread_futex);
279	if (list_empty(&manager_list)) {	279	if (list_empty(&manager_list)) {
280	futex_up(&psthread_futex);	280	futex_up(&psthread_futex);
281	return;	281	return;
282	}	282	}
283	list_remove(manager_list.next);	283	list_remove(manager_list.next);
284	futex_up(&psthread_futex);	284	futex_up(&psthread_futex);
285	}	285	}
286		286
287	/** Return thread id of current running thread */	287	/** Return thread id of current running thread */
288	pstid_t psthread_get_id(void)	288	pstid_t psthread_get_id(void)
289	{	289	{
290	return (pstid_t)__tcb_get()->pst_data;	290	return (pstid_t)__tcb_get()->pst_data;
291	}	291	}
292		292
293	/** Disable preemption	293	/** Disable preemption
294	*	294	*
295	* If the thread wants to send several message in row and does not want	295	* If the thread wants to send several message in row and does not want
296	* to be preempted, it should start async_serialize_start() in the beginning	296	* to be preempted, it should start async_serialize_start() in the beginning
297	* of communication and async_serialize_end() in the end. If it is a	297	* of communication and async_serialize_end() in the end. If it is a
298	* true multithreaded application, it should protect the communication channel	298	* true multithreaded application, it should protect the communication channel
299	* by a futex as well. Interrupt messages will can still be preempted.	299	* by a futex as well. Interrupt messages will can still be preempted.
300	*/	300	*/
301	void psthread_inc_sercount(void)	301	void psthread_inc_sercount(void)
302	{	302	{
303	serialization_count++;	303	serialization_count++;
304	}	304	}
305		305
306	void psthread_dec_sercount(void)	306	void psthread_dec_sercount(void)
307	{	307	{
308	serialization_count--;	308	serialization_count--;
309	}	309	}
310		310
311		311
312	/** @}	312	/** @}
313	*/	313	*/
314		314
315		315
316		316

Subversion Repositories HelenOS

(root)/tags/0.2.0.1/uspace/libc/generic/psthread.c – Rev 1965 → 1968