2 * System-dependent scheduler support
4 * Copyright 1998 Alexandre Julliard
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation; either
9 * version 2.1 of the License, or (at your option) any later version.
11 * This library is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
16 * You should have received a copy of the GNU Lesser General Public
17 * License along with this library; if not, write to the Free Software
18 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
22 #include "wine/port.h"
29 #ifdef HAVE_SYS_TIME_H
30 # include <sys/time.h>
32 #ifdef HAVE_SYS_SYSCALL_H
33 # include <sys/syscall.h>
38 #ifdef HAVE_UCONTEXT_H
39 # include <ucontext.h>
41 #ifdef HAVE_SYS_MMAN_H
49 #include "wine/server.h"
51 #include "wine/winbase16.h"
52 #include "wine/exception.h"
53 #include "wine/library.h"
54 #include "wine/debug.h"
56 WINE_DEFAULT_DEBUG_CHANNEL(thread
);
58 struct thread_cleanup_info
65 /* temporary stacks used on thread exit */
66 #define TEMP_STACK_SIZE 1024
67 #define NB_TEMP_STACKS 8
68 static char temp_stacks
[NB_TEMP_STACKS
][TEMP_STACK_SIZE
];
69 static LONG next_temp_stack
; /* next temp stack to use */
71 /***********************************************************************
72 * SYSDEPS_SetCurThread
74 * Make 'thread' the current thread.
76 void SYSDEPS_SetCurThread( TEB
*teb
)
79 /* On the i386, the current thread is in the %fs register */
82 wine_ldt_set_base( &fs_entry
, teb
);
83 wine_ldt_set_limit( &fs_entry
, 0xfff );
84 wine_ldt_set_flags( &fs_entry
, WINE_LDT_FLAGS_DATA
|WINE_LDT_FLAGS_32BIT
);
85 wine_ldt_init_fs( teb
->teb_sel
, &fs_entry
);
86 #elif defined(__powerpc__)
87 /* On PowerPC, the current TEB is in the gpr13 register */
88 __asm__
__volatile__("mr 2, %0" : : "r" (teb
));
89 #elif defined(HAVE__LWP_CREATE)
90 /* On non-i386 Solaris, we use the LWP private pointer */
91 _lwp_setprivate( teb
);
96 /***********************************************************************
97 * call_on_thread_stack
99 * Call a function once we switched to the thread stack.
101 static void call_on_thread_stack( void *func
)
105 void (*funcptr
)(void) = func
;
108 __EXCEPT(UnhandledExceptionFilter
)
110 TerminateThread( GetCurrentThread(), GetExceptionCode() );
113 SYSDEPS_ExitThread(0); /* should never get here */
117 /***********************************************************************
120 * Get a temporary stack address to run the thread exit code on.
122 inline static char *get_temp_stack(void)
124 unsigned int next
= InterlockedExchangeAdd( &next_temp_stack
, 1 );
125 return temp_stacks
[next
% NB_TEMP_STACKS
];
129 /***********************************************************************
132 * Cleanup the remains of a thread. Runs on a temporary stack.
134 static void cleanup_thread( void *ptr
)
136 /* copy the info structure since it is on the stack we will free */
137 struct thread_cleanup_info info
= *(struct thread_cleanup_info
*)ptr
;
138 munmap( info
.stack_base
, info
.stack_size
);
139 wine_ldt_free_fs( wine_get_fs() );
140 #ifdef HAVE__LWP_CREATE
143 _exit( info
.status
);
147 /***********************************************************************
148 * SYSDEPS_StartThread
150 * Startup routine for a new thread.
152 static void SYSDEPS_StartThread( TEB
*teb
)
154 SYSDEPS_SetCurThread( teb
);
161 __EXCEPT(UnhandledExceptionFilter
)
163 TerminateThread( GetCurrentThread(), GetExceptionCode() );
166 SYSDEPS_ExitThread(0); /* should never get here */
170 /***********************************************************************
171 * SYSDEPS_SpawnThread
173 * Start running a new thread.
174 * Return -1 on error, 0 if OK.
176 int SYSDEPS_SpawnThread( TEB
*teb
)
179 if (clone( (int (*)(void *))SYSDEPS_StartThread
, teb
->stack_top
,
180 CLONE_VM
| CLONE_FS
| CLONE_FILES
, teb
) < 0)
183 #elif defined(HAVE_RFORK)
184 void **sp
= (void **)teb
->stack_top
;
187 *--sp
= SYSDEPS_StartThread
;
188 __asm__
__volatile__(
189 "pushl %2;\n\t" /* flags */
190 "pushl $0;\n\t" /* 0 ? */
191 "movl %1,%%eax;\n\t" /* SYS_rfork */
192 ".byte 0x9a; .long 0; .word 7;\n\t" /* lcall 7:0... FreeBSD syscall */
193 "cmpl $0, %%edx;\n\t"
195 "movl %0,%%esp;\n\t" /* child -> new thread */
197 "1:\n\t" /* parent -> caller thread */
199 : "r" (sp
), "g" (SYS_rfork
), "g" (RFPROC
| RFMEM
)
202 #elif defined(HAVE__LWP_CREATE)
204 _lwp_makecontext( &context
, (void(*)(void *))SYSDEPS_StartThread
, teb
,
205 NULL
, teb
->stack_base
, (char *)teb
->stack_top
- (char *)teb
->stack_base
);
206 if ( _lwp_create( &context
, 0, NULL
) )
211 FIXME("CreateThread: stub\n" );
216 /***********************************************************************
217 * SYSDEPS_CallOnStack
219 void DECLSPEC_NORETURN
SYSDEPS_CallOnStack( void (*func
)(LPVOID
), LPVOID arg
);
222 __ASM_GLOBAL_FUNC( SYSDEPS_CallOnStack
,
223 "movl 4(%esp),%ecx\n\t" /* func */
224 "movl 8(%esp),%edx\n\t" /* arg */
225 ".byte 0x64\n\tmovl 0x04,%esp\n\t" /* teb->stack_top */
229 "int $3" /* we never return here */ );
230 # elif defined(_MSC_VER)
231 __declspec(naked
) void SYSDEPS_CallOnStack( void (*func
)(LPVOID
), LPVOID arg
)
233 __asm mov ecx
, 4[esp
];
234 __asm mov edx
, 8[esp
];
235 __asm mov fs
:[0x04], esp
;
241 # endif /* defined(__GNUC__) || defined(_MSC_VER) */
242 #elif defined(__sparc__) && defined(__GNUC__)
243 __ASM_GLOBAL_FUNC( SYSDEPS_CallOnStack
,
244 "mov %o0, %l0\n\t" /* store first argument */
245 "call " __ASM_NAME("NtCurrentTeb") ", 0\n\t"
246 "mov %o1, %l1\n\t" /* delay slot: store second argument */
247 "ld [%o0+4], %sp\n\t" /* teb->stack_top */
248 "call %l0, 0\n\t" /* call func */
249 "mov %l1, %o0\n\t" /* delay slot: arg for func */
250 "ta 0x01\n\t"); /* breakpoint - we never get here */
251 #else /* !sparc, !i386 */
252 void SYSDEPS_CallOnStack( void (*func
)(LPVOID
), LPVOID arg
)
255 while(1); /* avoid warning */
257 #endif /* !defined(__i386__) && !defined(__sparc__) */
260 /***********************************************************************
261 * SYSDEPS_SwitchToThreadStack
263 void SYSDEPS_SwitchToThreadStack( void (*func
)(void) )
265 SYSDEPS_CallOnStack( call_on_thread_stack
, func
);
269 /***********************************************************************
272 * Exit a running thread; must not return.
274 void SYSDEPS_ExitThread( int status
)
276 TEB
*teb
= NtCurrentTeb();
277 struct thread_cleanup_info info
;
278 MEMORY_BASIC_INFORMATION meminfo
;
280 wine_ldt_free_entries( teb
->stack_sel
, 1 );
281 VirtualQuery( teb
->stack_top
, &meminfo
, sizeof(meminfo
) );
282 info
.stack_base
= meminfo
.AllocationBase
;
283 info
.stack_size
= meminfo
.RegionSize
+ ((char *)teb
->stack_top
- (char *)meminfo
.AllocationBase
);
284 info
.status
= status
;
289 VirtualFree( teb
->stack_base
, 0, MEM_RELEASE
| MEM_SYSTEM
);
290 close( teb
->wait_fd
[0] );
291 close( teb
->wait_fd
[1] );
292 close( teb
->reply_fd
);
293 close( teb
->request_fd
);
294 teb
->stack_low
= get_temp_stack();
295 teb
->stack_top
= (char *) teb
->stack_low
+ TEMP_STACK_SIZE
;
296 SYSDEPS_CallOnStack( cleanup_thread
, &info
);
300 /***********************************************************************
301 * SYSDEPS_AbortThread
303 * Same as SYSDEPS_ExitThread, but must not do anything that requires a server call.
305 void SYSDEPS_AbortThread( int status
)
309 close( NtCurrentTeb()->wait_fd
[0] );
310 close( NtCurrentTeb()->wait_fd
[1] );
311 close( NtCurrentTeb()->reply_fd
);
312 close( NtCurrentTeb()->request_fd
);
313 #ifdef HAVE__LWP_CREATE
316 for (;;) /* avoid warning */
321 /* default errno before threading is initialized */
322 static int *default_errno_location(void)
328 /* default h_errno before threading is initialized */
329 static int *default_h_errno_location(void)
335 /* errno once threading is working */
336 static int *thread_errno_location(void)
338 return &NtCurrentTeb()->thread_errno
;
341 /* h_errno once threading is working */
342 static int *thread_h_errno_location(void)
344 return &NtCurrentTeb()->thread_h_errno
;
347 static int* (*errno_location_ptr
)(void) = default_errno_location
;
348 static int* (*h_errno_location_ptr
)(void) = default_h_errno_location
;
350 /***********************************************************************
351 * __errno_location/__error/___errno
353 * Get the per-thread errno location.
355 #ifdef ERRNO_LOCATION
356 int *ERRNO_LOCATION(void)
358 return errno_location_ptr();
360 #endif /* ERRNO_LOCATION */
362 /***********************************************************************
365 * Get the per-thread h_errno location.
367 int *__h_errno_location(void)
369 return h_errno_location_ptr();
373 /***********************************************************************
376 * Initialize errno handling.
378 void SYSDEPS_InitErrno(void)
380 errno_location_ptr
= thread_errno_location
;
381 h_errno_location_ptr
= thread_h_errno_location
;
385 /**********************************************************************
386 * NtCurrentTeb (NTDLL.@)
388 * This will crash and burn if called before threading is initialized
390 #if defined(__i386__) && defined(__GNUC__)
391 __ASM_GLOBAL_FUNC( NtCurrentTeb
, ".byte 0x64\n\tmovl 0x18,%eax\n\tret" );
392 #elif defined(__i386__) && defined(_MSC_VER)
393 /* Nothing needs to be done. MS C "magically" exports the inline version from winnt.h */
394 #elif defined(HAVE__LWP_CREATE)
395 /***********************************************************************
396 * NtCurrentTeb (NTDLL.@)
398 struct _TEB
* WINAPI
NtCurrentTeb(void)
400 extern void *_lwp_getprivate(void);
401 return (struct _TEB
*)_lwp_getprivate();
403 #elif defined(__powerpc__)
404 __ASM_GLOBAL_FUNC( NtCurrentTeb
, "\n\tmr 3,2\n\tblr" );
406 # error NtCurrentTeb not defined for this architecture
407 #endif /* __i386__ */