4 * Copyright 1996 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"
26 #include <sys/types.h>
27 #ifdef HAVE_SYS_MMAN_H
30 #ifdef HAVE_SYS_TIMES_H
31 #include <sys/times.h>
36 #include "wine/winbase16.h"
41 #include "selectors.h"
43 #include "wine/server.h"
44 #include "wine/debug.h"
47 WINE_DEFAULT_DEBUG_CHANNEL(thread
);
48 WINE_DECLARE_DEBUG_CHANNEL(relay
);
50 /* TEB of the initial thread */
51 static TEB initial_teb
;
53 extern struct _PDB current_process
;
55 /***********************************************************************
58 * Initialization of a newly created TEB.
60 static BOOL
THREAD_InitTEB( TEB
*teb
)
62 teb
->Tib
.ExceptionList
= (void *)~0UL;
63 teb
->Tib
.StackBase
= (void *)~0UL;
64 teb
->Tib
.Self
= &teb
->Tib
;
65 teb
->tibflags
= TEBF_WIN32
;
66 teb
->exit_code
= STILL_ACTIVE
;
71 teb
->StaticUnicodeString
.MaximumLength
= sizeof(teb
->StaticUnicodeBuffer
);
72 teb
->StaticUnicodeString
.Buffer
= (PWSTR
)teb
->StaticUnicodeBuffer
;
73 InitializeListHead(&teb
->TlsLinks
);
74 teb
->teb_sel
= wine_ldt_alloc_fs();
75 return (teb
->teb_sel
!= 0);
79 /***********************************************************************
82 * Free data structures associated with a thread.
83 * Must be called from the context of another thread.
85 static void THREAD_FreeTEB( TEB
*teb
)
87 TRACE("(%p) called\n", teb
);
88 /* Free the associated memory */
89 wine_ldt_free_fs( teb
->teb_sel
);
90 VirtualFree( teb
->DeallocationStack
, 0, MEM_RELEASE
);
94 /***********************************************************************
97 * Allocate the stack of a thread.
99 TEB
*THREAD_InitStack( TEB
*teb
, DWORD stack_size
)
101 DWORD old_prot
, total_size
;
102 DWORD page_size
= getpagesize();
105 /* Allocate the stack */
107 if (stack_size
>= 16*1024*1024)
108 WARN("Thread stack size is %ld MB.\n",stack_size
/1024/1024);
110 /* if size is smaller than default, get stack size from parent */
111 if (stack_size
< 1024 * 1024)
114 stack_size
= 1024 * 1024; /* no parent */
116 stack_size
= ((char *)NtCurrentTeb()->Tib
.StackBase
- (char *)NtCurrentTeb()->DeallocationStack
117 - SIGNAL_STACK_SIZE
- 3 * page_size
);
120 /* FIXME: some Wine functions use a lot of stack, so we add 64Kb here */
121 stack_size
+= 64 * 1024;
123 /* Memory layout in allocated block:
126 * 1 page NOACCESS guard page
127 * SIGNAL_STACK_SIZE signal stack
128 * 1 page NOACCESS guard page
129 * 1 page PAGE_GUARD guard page
130 * stack_size normal stack
131 * 1 page TEB (except for initial thread)
134 stack_size
= (stack_size
+ (page_size
- 1)) & ~(page_size
- 1);
135 total_size
= stack_size
+ SIGNAL_STACK_SIZE
+ 3 * page_size
;
136 if (!teb
) total_size
+= page_size
;
138 if (!(base
= VirtualAlloc( NULL
, total_size
, MEM_COMMIT
, PAGE_EXECUTE_READWRITE
)))
143 teb
= (TEB
*)((char *)base
+ total_size
- page_size
);
144 if (!THREAD_InitTEB( teb
))
146 VirtualFree( base
, 0, MEM_RELEASE
);
151 teb
->DeallocationStack
= base
;
152 teb
->signal_stack
= (char *)base
+ page_size
;
153 teb
->Tib
.StackBase
= (char *)base
+ 3 * page_size
+ SIGNAL_STACK_SIZE
+ stack_size
;
154 teb
->Tib
.StackLimit
= base
; /* note: limit is lower than base since the stack grows down */
156 /* Setup guard pages */
158 VirtualProtect( base
, 1, PAGE_NOACCESS
, &old_prot
);
159 VirtualProtect( (char *)teb
->signal_stack
+ SIGNAL_STACK_SIZE
, 1, PAGE_NOACCESS
, &old_prot
);
160 VirtualProtect( (char *)teb
->signal_stack
+ SIGNAL_STACK_SIZE
+ page_size
, 1,
161 PAGE_EXECUTE_READWRITE
| PAGE_GUARD
, &old_prot
);
166 /***********************************************************************
169 * Setup the initial thread.
171 * NOTES: The first allocated TEB on NT is at 0x7ffde000.
173 void THREAD_Init(void)
175 static struct debug_info info
; /* debug info for initial thread */
177 if (!initial_teb
.Tib
.Self
) /* do it only once */
179 THREAD_InitTEB( &initial_teb
);
180 assert( initial_teb
.teb_sel
);
181 info
.str_pos
= info
.strings
;
182 info
.out_pos
= info
.output
;
183 initial_teb
.debug_info
= &info
;
184 initial_teb
.Peb
= (PEB
*)¤t_process
; /* FIXME */
185 SYSDEPS_SetCurThread( &initial_teb
);
189 DECL_GLOBAL_CONSTRUCTOR(thread_init
) { THREAD_Init(); }
192 /***********************************************************************
195 * Start execution of a newly created thread. Does not return.
197 static void THREAD_Start( TEB
*teb
)
199 LPTHREAD_START_ROUTINE func
= (LPTHREAD_START_ROUTINE
)teb
->entry_point
;
200 struct debug_info info
;
202 info
.str_pos
= info
.strings
;
203 info
.out_pos
= info
.output
;
204 teb
->debug_info
= &info
;
206 SYSDEPS_SetCurThread( teb
);
211 DPRINTF("%04lx:Starting thread (entryproc=%p)\n", GetCurrentThreadId(), func
);
215 MODULE_DllThreadAttach( NULL
);
216 ExitThread( func( NtCurrentTeb()->entry_arg
) );
218 __EXCEPT(UnhandledExceptionFilter
)
220 TerminateThread( GetCurrentThread(), GetExceptionCode() );
226 /***********************************************************************
227 * CreateThread (KERNEL32.@)
229 HANDLE WINAPI
CreateThread( SECURITY_ATTRIBUTES
*sa
, SIZE_T stack
,
230 LPTHREAD_START_ROUTINE start
, LPVOID param
,
231 DWORD flags
, LPDWORD id
)
238 if (pipe( request_pipe
) == -1)
240 SetLastError( ERROR_TOO_MANY_OPEN_FILES
);
243 fcntl( request_pipe
[1], F_SETFD
, 1 ); /* set close on exec flag */
244 wine_server_send_fd( request_pipe
[0] );
246 SERVER_START_REQ( new_thread
)
248 req
->suspend
= ((flags
& CREATE_SUSPENDED
) != 0);
249 req
->inherit
= (sa
&& (sa
->nLength
>=sizeof(*sa
)) && sa
->bInheritHandle
);
250 req
->request_fd
= request_pipe
[0];
251 if (!wine_server_call_err( req
))
253 handle
= reply
->handle
;
256 close( request_pipe
[0] );
260 if (!handle
|| !(teb
= THREAD_InitStack( NULL
, stack
)))
262 close( request_pipe
[1] );
266 teb
->Peb
= NtCurrentTeb()->Peb
;
267 teb
->ClientId
.UniqueThread
= (HANDLE
)tid
;
268 teb
->request_fd
= request_pipe
[1];
269 teb
->entry_point
= start
;
270 teb
->entry_arg
= param
;
271 teb
->htask16
= GetCurrentTask();
273 InsertHeadList( &NtCurrentTeb()->TlsLinks
, &teb
->TlsLinks
);
277 if (SYSDEPS_SpawnThread( THREAD_Start
, teb
) == -1)
279 CloseHandle( handle
);
280 close( request_pipe
[1] );
282 RemoveEntryList( &teb
->TlsLinks
);
284 THREAD_FreeTEB( teb
);
290 /***********************************************************************
291 * ExitThread [KERNEL32.@] Ends a thread
296 void WINAPI
ExitThread( DWORD code
) /* [in] Exit code for this thread */
299 SERVER_START_REQ( terminate_thread
)
301 /* send the exit code to the server */
302 req
->handle
= GetCurrentThread();
303 req
->exit_code
= code
;
304 wine_server_call( req
);
311 LdrShutdownProcess();
318 RemoveEntryList( &NtCurrentTeb()->TlsLinks
);
320 SYSDEPS_ExitThread( code
);
324 /***********************************************************************
325 * OpenThread Retrieves a handle to a thread from its thread id
330 HANDLE WINAPI
OpenThread( DWORD dwDesiredAccess
, BOOL bInheritHandle
, DWORD dwThreadId
)
333 SERVER_START_REQ( open_thread
)
335 req
->tid
= dwThreadId
;
336 req
->access
= dwDesiredAccess
;
337 req
->inherit
= bInheritHandle
;
338 if (!wine_server_call_err( req
)) ret
= reply
->handle
;
344 /**********************************************************************
345 * TerminateThread [KERNEL32.@] Terminates a thread
351 BOOL WINAPI
TerminateThread( HANDLE handle
, /* [in] Handle to thread */
352 DWORD exit_code
) /* [in] Exit code for thread */
354 NTSTATUS status
= NtTerminateThread( handle
, exit_code
);
355 if (status
) SetLastError( RtlNtStatusToDosError(status
) );
360 /**********************************************************************
361 * GetExitCodeThread (KERNEL32.@)
363 * Gets termination status of thread.
369 BOOL WINAPI
GetExitCodeThread(
370 HANDLE hthread
, /* [in] Handle to thread */
371 LPDWORD exitcode
) /* [out] Address to receive termination status */
373 THREAD_BASIC_INFORMATION info
;
374 NTSTATUS status
= NtQueryInformationThread( hthread
, ThreadBasicInformation
,
375 &info
, sizeof(info
), NULL
);
379 SetLastError( RtlNtStatusToDosError(status
) );
382 if (exitcode
) *exitcode
= info
.ExitStatus
;
387 /* callback for QueueUserAPC */
388 static void CALLBACK
call_user_apc( ULONG_PTR arg1
, ULONG_PTR arg2
, ULONG_PTR arg3
)
390 PAPCFUNC func
= (PAPCFUNC
)arg1
;
394 /***********************************************************************
395 * QueueUserAPC (KERNEL32.@)
397 DWORD WINAPI
QueueUserAPC( PAPCFUNC func
, HANDLE hthread
, ULONG_PTR data
)
399 NTSTATUS status
= NtQueueApcThread( hthread
, call_user_apc
, (ULONG_PTR
)func
, data
, 0 );
401 if (status
) SetLastError( RtlNtStatusToDosError(status
) );
406 /***********************************************************************
407 * ProcessIdToSessionId (KERNEL32.@)
408 * This function is available on Terminal Server 4SP4 and Windows 2000
410 BOOL WINAPI
ProcessIdToSessionId( DWORD procid
, DWORD
*sessionid_ptr
)
412 /* According to MSDN, if the calling process is not in a terminal
413 * services environment, then the sessionid returned is zero.
422 /***********************************************************************
423 * SetLastError (KERNEL.147)
424 * SetLastError (KERNEL32.@)
426 /* void WINAPI SetLastError( DWORD error ); */
427 __ASM_GLOBAL_FUNC( SetLastError
,
428 "movl 4(%esp),%eax\n\t"
433 /***********************************************************************
434 * GetLastError (KERNEL.148)
435 * GetLastError (KERNEL32.@)
437 /* DWORD WINAPI GetLastError(void); */
438 __ASM_GLOBAL_FUNC( GetLastError
, ".byte 0x64\n\tmovl 0x60,%eax\n\tret" );
440 /***********************************************************************
441 * GetCurrentProcessId (KERNEL.471)
442 * GetCurrentProcessId (KERNEL32.@)
444 /* DWORD WINAPI GetCurrentProcessId(void) */
445 __ASM_GLOBAL_FUNC( GetCurrentProcessId
, ".byte 0x64\n\tmovl 0x20,%eax\n\tret" );
447 /***********************************************************************
448 * GetCurrentThreadId (KERNEL.462)
449 * GetCurrentThreadId (KERNEL32.@)
451 /* DWORD WINAPI GetCurrentThreadId(void) */
452 __ASM_GLOBAL_FUNC( GetCurrentThreadId
, ".byte 0x64\n\tmovl 0x24,%eax\n\tret" );
456 /**********************************************************************
457 * SetLastError (KERNEL.147)
458 * SetLastError (KERNEL32.@)
460 * Sets the last-error code.
462 void WINAPI
SetLastError( DWORD error
) /* [in] Per-thread error code */
464 NtCurrentTeb()->last_error
= error
;
467 /**********************************************************************
468 * GetLastError (KERNEL.148)
469 * GetLastError (KERNEL32.@)
471 * Returns last-error code.
473 DWORD WINAPI
GetLastError(void)
475 return NtCurrentTeb()->last_error
;
478 /***********************************************************************
479 * GetCurrentProcessId (KERNEL.471)
480 * GetCurrentProcessId (KERNEL32.@)
482 * Returns process identifier.
484 DWORD WINAPI
GetCurrentProcessId(void)
486 return (DWORD
)NtCurrentTeb()->ClientId
.UniqueProcess
;
489 /***********************************************************************
490 * GetCurrentThreadId (KERNEL.462)
491 * GetCurrentThreadId (KERNEL32.@)
493 * Returns thread identifier.
495 DWORD WINAPI
GetCurrentThreadId(void)
497 return (DWORD
)NtCurrentTeb()->ClientId
.UniqueThread
;
500 #endif /* __i386__ */