Subversion Repositories HelenOS

Rev

Rev 2568 | Rev 3565 | Go to most recent revision | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 2568 Rev 2586
1
/*
1
/*
2
 * Copyright (c) 2006 Jakub Jermar
2
 * Copyright (c) 2006 Jakub Jermar
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 <thread.h>
35
#include <thread.h>
36
#include <libc.h>
36
#include <libc.h>
37
#include <stdlib.h>
37
#include <stdlib.h>
38
#include <libarch/faddr.h>
38
#include <libarch/faddr.h>
39
#include <kernel/proc/uarg.h>
39
#include <kernel/proc/uarg.h>
40
#include <fibril.h>
40
#include <fibril.h>
41
#include <string.h>
41
#include <string.h>
42
#include <async.h>
42
#include <async.h>
43
 
43
 
44
#include <stdio.h>
-
 
45
 
-
 
46
 
-
 
47
#ifndef THREAD_INITIAL_STACK_PAGES_NO
44
#ifndef THREAD_INITIAL_STACK_PAGES_NO
48
#define THREAD_INITIAL_STACK_PAGES_NO 1
45
#define THREAD_INITIAL_STACK_PAGES_NO 1
49
#endif
46
#endif
50
 
47
 
51
static LIST_INITIALIZE(thread_garbage);
-
 
52
 
-
 
53
extern char _tdata_start;
-
 
54
extern char _tdata_end;
-
 
55
extern char _tbss_start;
-
 
56
extern char _tbss_end;
-
 
57
 
-
 
58
/** Create TLS (Thread Local Storage) data structures.
-
 
59
 *
-
 
60
 * The code requires, that sections .tdata and .tbss are adjacent. It may be
-
 
61
 * changed in the future.
-
 
62
 *
-
 
63
 * @return Pointer to TCB.
-
 
64
 */
-
 
65
tcb_t *__make_tls(void)
-
 
66
{
-
 
67
    void *data;
-
 
68
    tcb_t *tcb;
-
 
69
    size_t tls_size = &_tbss_end - &_tdata_start;
-
 
70
   
-
 
71
    tcb = __alloc_tls(&data, tls_size);
-
 
72
   
-
 
73
    /*
-
 
74
     * Copy thread local data from the initialization image.
-
 
75
     */
-
 
76
    memcpy(data, &_tdata_start, &_tdata_end - &_tdata_start);
-
 
77
    /*
-
 
78
     * Zero out the thread local uninitialized data.
-
 
79
     */
-
 
80
    memset(data + (&_tbss_start - &_tdata_start), 0,
-
 
81
        &_tbss_end - &_tbss_start);
-
 
82
 
-
 
83
    return tcb;
-
 
84
}
-
 
85
 
-
 
86
void __free_tls(tcb_t *tcb)
-
 
87
{
-
 
88
    size_t tls_size = &_tbss_end - &_tdata_start;
-
 
89
    __free_tls_arch(tcb, tls_size);
-
 
90
}
-
 
91
 
-
 
92
/** Main thread function.
48
/** Main thread function.
93
 *
49
 *
94
 * This function is called from __thread_entry() and is used
50
 * This function is called from __thread_entry() and is used
95
 * to call the thread's implementing function and perform cleanup
51
 * to call the thread's implementing function and perform cleanup
96
 * and exit when thread returns back. Do not call this function
52
 * and exit when thread returns back. Do not call this function
97
 * directly.
53
 * directly.
98
 *
54
 *
99
 * @param uarg Pointer to userspace argument structure.
55
 * @param uarg Pointer to userspace argument structure.
100
 */
56
 */
101
void __thread_main(uspace_arg_t *uarg)
57
void __thread_main(uspace_arg_t *uarg)
102
{
58
{
103
    fibril_t *f;
59
    fibril_t *f;
104
 
60
 
105
    f = fibril_setup();
61
    f = fibril_setup();
106
    __tcb_set(f->tcb);
62
    __tcb_set(f->tcb);
107
 
63
 
108
    uarg->uspace_thread_function(uarg->uspace_thread_arg);
64
    uarg->uspace_thread_function(uarg->uspace_thread_arg);
109
    /* XXX: we cannot free the userspace stack while running on it */
65
    /* XXX: we cannot free the userspace stack while running on it */
110
//  free(uarg->uspace_stack);
66
//  free(uarg->uspace_stack);
111
//  free(uarg);
67
//  free(uarg);
112
 
68
 
113
    /* If there is a manager, destroy it */
69
    /* If there is a manager, destroy it */
114
    async_destroy_manager();
70
    async_destroy_manager();
115
    fibril_teardown(f);
71
    fibril_teardown(f);
116
 
72
 
117
    thread_exit(0);
73
    thread_exit(0);
118
}
74
}
119
 
75
 
120
/** Create userspace thread.
76
/** Create userspace thread.
121
 *
77
 *
122
 * This function creates new userspace thread and allocates userspace
78
 * This function creates new userspace thread and allocates userspace
123
 * stack and userspace argument structure for it.
79
 * stack and userspace argument structure for it.
124
 *
80
 *
125
 * @param function Function implementing the thread.
81
 * @param function Function implementing the thread.
126
 * @param arg Argument to be passed to thread.
82
 * @param arg Argument to be passed to thread.
127
 * @param name Symbolic name of the thread.
83
 * @param name Symbolic name of the thread.
128
 * @param tid Thread ID of the newly created thread.
84
 * @param tid Thread ID of the newly created thread.
129
 *
85
 *
130
 * @return Zero on success or a code from @ref errno.h on failure.
86
 * @return Zero on success or a code from @ref errno.h on failure.
131
 */
87
 */
132
int thread_create(void (* function)(void *), void *arg, char *name,
88
int thread_create(void (* function)(void *), void *arg, char *name,
133
    thread_id_t *tid)
89
    thread_id_t *tid)
134
{
90
{
135
    char *stack;
91
    char *stack;
136
    uspace_arg_t *uarg;
92
    uspace_arg_t *uarg;
137
    int rc;
93
    int rc;
138
 
94
 
139
    stack = (char *) malloc(getpagesize() * THREAD_INITIAL_STACK_PAGES_NO);
95
    stack = (char *) malloc(getpagesize() * THREAD_INITIAL_STACK_PAGES_NO);
140
    if (!stack)
96
    if (!stack)
141
        return -1;
97
        return -1;
142
       
98
       
143
    uarg = (uspace_arg_t *) malloc(sizeof(uspace_arg_t));
99
    uarg = (uspace_arg_t *) malloc(sizeof(uspace_arg_t));
144
    if (!uarg) {
100
    if (!uarg) {
145
        free(stack);
101
        free(stack);
146
        return -1;
102
        return -1;
147
    }
103
    }
148
   
104
   
149
    uarg->uspace_entry = (void *) FADDR(__thread_entry);
105
    uarg->uspace_entry = (void *) FADDR(__thread_entry);
150
    uarg->uspace_stack = (void *) stack;
106
    uarg->uspace_stack = (void *) stack;
151
    uarg->uspace_thread_function = function;
107
    uarg->uspace_thread_function = function;
152
    uarg->uspace_thread_arg = arg;
108
    uarg->uspace_thread_arg = arg;
153
    uarg->uspace_uarg = uarg;
109
    uarg->uspace_uarg = uarg;
154
   
110
   
155
    rc = __SYSCALL3(SYS_THREAD_CREATE, (sysarg_t) uarg, (sysarg_t) name,
111
    rc = __SYSCALL3(SYS_THREAD_CREATE, (sysarg_t) uarg, (sysarg_t) name,
156
        (sysarg_t) tid);
112
        (sysarg_t) tid);
157
   
113
   
158
    if (rc) {
114
    if (rc) {
159
        /*
115
        /*
160
         * Failed to create a new thread.
116
         * Failed to create a new thread.
161
         * Free up the allocated structures.
117
         * Free up the allocated structures.
162
         */
118
         */
163
        free(uarg);
119
        free(uarg);
164
        free(stack);
120
        free(stack);
165
    }
121
    }
166
 
122
 
167
    return rc;
123
    return rc;
168
}
124
}
169
 
125
 
170
/** Terminate current thread.
126
/** Terminate current thread.
171
 *
127
 *
172
 * @param status Exit status. Currently not used.
128
 * @param status Exit status. Currently not used.
173
 */
129
 */
174
void thread_exit(int status)
130
void thread_exit(int status)
175
{
131
{
176
    __SYSCALL1(SYS_THREAD_EXIT, (sysarg_t) status);
132
    __SYSCALL1(SYS_THREAD_EXIT, (sysarg_t) status);
177
}
133
}
178
 
134
 
179
/** Detach thread.
135
/** Detach thread.
180
 *
136
 *
181
 * Currently not implemented.
137
 * Currently not implemented.
182
 *
138
 *
183
 * @param thread TID.
139
 * @param thread TID.
184
 */
140
 */
185
void thread_detach(thread_id_t thread)
141
void thread_detach(thread_id_t thread)
186
{
142
{
187
}
143
}
188
 
144
 
189
/** Join thread.
145
/** Join thread.
190
 *
146
 *
191
 * Currently not implemented.
147
 * Currently not implemented.
192
 *
148
 *
193
 * @param thread TID.
149
 * @param thread TID.
194
 *
150
 *
195
 * @return Thread exit status.
151
 * @return Thread exit status.
196
 */
152
 */
197
int thread_join(thread_id_t thread)
153
int thread_join(thread_id_t thread)
198
{
154
{
199
}
155
}
200
 
156
 
201
/** Get current thread ID.
157
/** Get current thread ID.
202
 *
158
 *
203
 * @return Current thread ID.
159
 * @return Current thread ID.
204
 */
160
 */
205
thread_id_t thread_get_id(void)
161
thread_id_t thread_get_id(void)
206
{
162
{
207
    thread_id_t thread_id;
163
    thread_id_t thread_id;
208
 
164
 
209
    (void) __SYSCALL1(SYS_THREAD_GET_ID, (sysarg_t) &thread_id);
165
    (void) __SYSCALL1(SYS_THREAD_GET_ID, (sysarg_t) &thread_id);
210
 
166
 
211
    return thread_id;
167
    return thread_id;
212
}
168
}
213
 
169
 
214
/** @}
170
/** @}
215
 */
171
 */
216
 
172