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
31 #include "wine/winbase16.h"
36 #include "selectors.h"
38 #include "wine/server.h"
39 #include "stackframe.h"
40 #include "wine/debug.h"
43 WINE_DEFAULT_DEBUG_CHANNEL(thread);
44 WINE_DECLARE_DEBUG_CHANNEL(relay);
46 /* TEB of the initial thread */
47 static TEB initial_teb;
49 extern struct _PDB current_process;
51 /***********************************************************************
54 * Convert a thread id to a TEB, making sure it is valid.
56 TEB *THREAD_IdToTEB( DWORD id )
60 if (!id || id == GetCurrentThreadId()) return NtCurrentTeb();
62 SERVER_START_REQ( get_thread_info )
65 req->tid_in = (void *)id;
66 if (!wine_server_call( req )) ret = reply->teb;
72 /* Allow task handles to be used; convert to main thread */
75 TDB *pTask = TASK_GetPtr( id );
76 if (pTask) return pTask->teb;
78 SetLastError( ERROR_INVALID_PARAMETER );
84 /***********************************************************************
87 * Initialization of a newly created TEB.
89 static BOOL THREAD_InitTEB( TEB *teb )
91 teb->except = (void *)~0UL;
93 teb->tibflags = TEBF_WIN32;
94 teb->tls_ptr = teb->tls_array;
95 teb->exit_code = STILL_ACTIVE;
100 teb->stack_top = (void *)~0UL;
101 teb->StaticUnicodeString.MaximumLength = sizeof(teb->StaticUnicodeBuffer);
102 teb->StaticUnicodeString.Buffer = (PWSTR)teb->StaticUnicodeBuffer;
103 teb->teb_sel = SELECTOR_AllocBlock( teb, 0x1000, WINE_LDT_FLAGS_DATA|WINE_LDT_FLAGS_32BIT );
104 return (teb->teb_sel != 0);
108 /***********************************************************************
111 * Free data structures associated with a thread.
112 * Must be called from the context of another thread.
114 static void THREAD_FreeTEB( TEB *teb )
116 TRACE("(%p) called\n", teb );
117 /* Free the associated memory */
118 FreeSelector16( teb->stack_sel );
119 FreeSelector16( teb->teb_sel );
120 VirtualFree( teb->stack_base, 0, MEM_RELEASE );
124 /***********************************************************************
127 * Allocate the stack of a thread.
129 TEB *THREAD_InitStack( TEB *teb, DWORD stack_size )
131 DWORD old_prot, total_size;
132 DWORD page_size = getpagesize();
135 /* Allocate the stack */
137 if (stack_size >= 16*1024*1024)
138 WARN("Thread stack size is %ld MB.\n",stack_size/1024/1024);
140 /* if size is smaller than default, get stack size from parent */
141 if (stack_size < 1024 * 1024)
144 stack_size = 1024 * 1024; /* no parent */
146 stack_size = ((char *)NtCurrentTeb()->stack_top - (char *)NtCurrentTeb()->stack_base
147 - SIGNAL_STACK_SIZE - 3 * page_size);
150 /* FIXME: some Wine functions use a lot of stack, so we add 64Kb here */
151 stack_size += 64 * 1024;
153 /* Memory layout in allocated block:
156 * 1 page NOACCESS guard page
157 * SIGNAL_STACK_SIZE signal stack
158 * 1 page NOACCESS guard page
159 * 1 page PAGE_GUARD guard page
160 * stack_size normal stack
161 * 64Kb 16-bit stack (optional)
162 * 1 page TEB (except for initial thread)
163 * 1 page debug info (except for initial thread)
166 stack_size = (stack_size + (page_size - 1)) & ~(page_size - 1);
167 total_size = stack_size + SIGNAL_STACK_SIZE + 3 * page_size;
168 total_size += 0x10000; /* 16-bit stack */
169 if (!teb) total_size += 2 * page_size;
171 if (!(base = VirtualAlloc( NULL, total_size, MEM_COMMIT, PAGE_EXECUTE_READWRITE )))
176 teb = (TEB *)((char *)base + total_size - 2 * page_size);
177 if (!THREAD_InitTEB( teb )) goto error;
178 teb->debug_info = (char *)teb + page_size;
181 teb->stack_low = base;
182 teb->stack_base = base;
183 teb->signal_stack = (char *)base + page_size;
184 teb->stack_top = (char *)base + 3 * page_size + SIGNAL_STACK_SIZE + stack_size;
186 /* Setup guard pages */
188 VirtualProtect( base, 1, PAGE_NOACCESS, &old_prot );
189 VirtualProtect( (char *)teb->signal_stack + SIGNAL_STACK_SIZE, 1, PAGE_NOACCESS, &old_prot );
190 VirtualProtect( (char *)teb->signal_stack + SIGNAL_STACK_SIZE + page_size, 1,
191 PAGE_EXECUTE_READWRITE | PAGE_GUARD, &old_prot );
193 /* Allocate the 16-bit stack selector */
195 teb->stack_sel = SELECTOR_AllocBlock( teb->stack_top, 0x10000, WINE_LDT_FLAGS_DATA );
196 if (!teb->stack_sel) goto error;
197 teb->cur_stack = MAKESEGPTR( teb->stack_sel, 0x10000 - sizeof(STACK16FRAME) );
202 FreeSelector16( teb->teb_sel );
203 VirtualFree( base, 0, MEM_RELEASE );
208 /***********************************************************************
209 * thread_errno_location
211 * Get the per-thread errno location.
213 static int *thread_errno_location(void)
215 return &NtCurrentTeb()->thread_errno;
218 /***********************************************************************
219 * thread_h_errno_location
221 * Get the per-thread h_errno location.
223 static int *thread_h_errno_location(void)
225 return &NtCurrentTeb()->thread_h_errno;
228 /***********************************************************************
231 * Setup the initial thread.
233 * NOTES: The first allocated TEB on NT is at 0x7ffde000.
235 void THREAD_Init(void)
237 if (!initial_teb.self) /* do it only once */
239 THREAD_InitTEB( &initial_teb );
240 assert( initial_teb.teb_sel );
241 initial_teb.process = ¤t_process;
242 SYSDEPS_SetCurThread( &initial_teb );
243 wine_errno_location = thread_errno_location;
244 wine_h_errno_location = thread_h_errno_location;
248 DECL_GLOBAL_CONSTRUCTOR(thread_init) { THREAD_Init(); }
251 /***********************************************************************
254 * Start execution of a newly created thread. Does not return.
256 static void THREAD_Start(void)
258 LPTHREAD_START_ROUTINE func = (LPTHREAD_START_ROUTINE)NtCurrentTeb()->entry_point;
261 DPRINTF("%08lx:Starting thread (entryproc=%p)\n", GetCurrentThreadId(), func );
263 PROCESS_CallUserSignalProc( USIG_THREAD_INIT, 0 );
264 MODULE_DllThreadAttach( NULL );
265 ExitThread( func( NtCurrentTeb()->entry_arg ) );
269 /***********************************************************************
270 * CreateThread (KERNEL32.@)
272 HANDLE WINAPI CreateThread( SECURITY_ATTRIBUTES *sa, DWORD stack,
273 LPTHREAD_START_ROUTINE start, LPVOID param,
274 DWORD flags, LPDWORD id )
281 if (pipe( request_pipe ) == -1)
283 SetLastError( ERROR_TOO_MANY_OPEN_FILES );
286 fcntl( request_pipe[1], F_SETFD, 1 ); /* set close on exec flag */
287 wine_server_send_fd( request_pipe[0] );
289 SERVER_START_REQ( new_thread )
291 req->suspend = ((flags & CREATE_SUSPENDED) != 0);
292 req->inherit = (sa && (sa->nLength>=sizeof(*sa)) && sa->bInheritHandle);
293 req->request_fd = request_pipe[0];
294 if (!wine_server_call_err( req ))
296 handle = reply->handle;
299 close( request_pipe[0] );
303 if (!handle || !(teb = THREAD_InitStack( NULL, stack )))
305 close( request_pipe[1] );
309 teb->process = NtCurrentTeb()->process;
311 teb->request_fd = request_pipe[1];
312 teb->entry_point = start;
313 teb->entry_arg = param;
314 teb->startup = THREAD_Start;
315 teb->htask16 = GetCurrentTask();
317 if (id) *id = (DWORD)tid;
318 if (SYSDEPS_SpawnThread( teb ) == -1)
320 CloseHandle( handle );
321 close( request_pipe[1] );
322 THREAD_FreeTEB( teb );
328 /***********************************************************************
329 * CreateThread16 (KERNEL.441)
331 static DWORD CALLBACK THREAD_StartThread16( LPVOID threadArgs )
333 FARPROC16 start = ((FARPROC16 *)threadArgs)[0];
334 DWORD param = ((DWORD *)threadArgs)[1];
335 HeapFree( GetProcessHeap(), 0, threadArgs );
337 ((LPDWORD)CURRENT_STACK16)[-1] = param;
338 return wine_call_to_16_long( start, sizeof(DWORD) );
340 HANDLE WINAPI CreateThread16( SECURITY_ATTRIBUTES *sa, DWORD stack,
341 FARPROC16 start, SEGPTR param,
342 DWORD flags, LPDWORD id )
344 DWORD *threadArgs = HeapAlloc( GetProcessHeap(), 0, 2*sizeof(DWORD) );
345 if (!threadArgs) return INVALID_HANDLE_VALUE;
346 threadArgs[0] = (DWORD)start;
347 threadArgs[1] = (DWORD)param;
349 return CreateThread( sa, stack, THREAD_StartThread16, threadArgs, flags, id );
353 /***********************************************************************
354 * ExitThread [KERNEL32.@] Ends a thread
359 void WINAPI ExitThread( DWORD code ) /* [in] Exit code for this thread */
362 SERVER_START_REQ( terminate_thread )
364 /* send the exit code to the server */
365 req->handle = GetCurrentThread();
366 req->exit_code = code;
367 wine_server_call( req );
374 MODULE_DllProcessDetach( TRUE, (LPVOID)1 );
379 MODULE_DllThreadDetach( NULL );
380 if (!(NtCurrentTeb()->tibflags & TEBF_WIN32)) TASK_ExitTask();
381 SYSDEPS_ExitThread( code );
385 /***********************************************************************
386 * OpenThread Retrieves a handle to a thread from its thread id
391 HANDLE WINAPI OpenThread( DWORD dwDesiredAccess, BOOL bInheritHandle, DWORD dwThreadId )
394 SERVER_START_REQ( open_thread )
396 req->tid = (void *)dwThreadId;
397 req->access = dwDesiredAccess;
398 req->inherit = bInheritHandle;
399 if (!wine_server_call_err( req )) ret = reply->handle;
405 /***********************************************************************
406 * SetThreadContext [KERNEL32.@] Sets context of thread.
412 BOOL WINAPI SetThreadContext( HANDLE handle, /* [in] Handle to thread with context */
413 const CONTEXT *context ) /* [in] Address of context structure */
416 SERVER_START_REQ( set_thread_context )
418 req->handle = handle;
419 req->flags = context->ContextFlags;
420 wine_server_add_data( req, context, sizeof(*context) );
421 ret = !wine_server_call_err( req );
428 /***********************************************************************
429 * GetThreadContext [KERNEL32.@] Retrieves context of thread.
435 BOOL WINAPI GetThreadContext( HANDLE handle, /* [in] Handle to thread with context */
436 CONTEXT *context ) /* [out] Address of context structure */
439 SERVER_START_REQ( get_thread_context )
441 req->handle = handle;
442 req->flags = context->ContextFlags;
443 wine_server_add_data( req, context, sizeof(*context) );
444 wine_server_set_reply( req, context, sizeof(*context) );
445 ret = !wine_server_call_err( req );
452 /**********************************************************************
453 * GetThreadPriority [KERNEL32.@] Returns priority for thread.
456 * Success: Thread's priority level.
457 * Failure: THREAD_PRIORITY_ERROR_RETURN
459 INT WINAPI GetThreadPriority(
460 HANDLE hthread) /* [in] Handle to thread */
462 INT ret = THREAD_PRIORITY_ERROR_RETURN;
463 SERVER_START_REQ( get_thread_info )
465 req->handle = hthread;
467 if (!wine_server_call_err( req )) ret = reply->priority;
474 /**********************************************************************
475 * SetThreadPriority [KERNEL32.@] Sets priority for thread.
481 BOOL WINAPI SetThreadPriority(
482 HANDLE hthread, /* [in] Handle to thread */
483 INT priority) /* [in] Thread priority level */
486 SERVER_START_REQ( set_thread_info )
488 req->handle = hthread;
489 req->priority = priority;
490 req->mask = SET_THREAD_INFO_PRIORITY;
491 ret = !wine_server_call_err( req );
498 /**********************************************************************
499 * GetThreadPriorityBoost [KERNEL32.@] Returns priority boost for thread.
501 * Always reports that priority boost is disabled.
507 BOOL WINAPI GetThreadPriorityBoost(
508 HANDLE hthread, /* [in] Handle to thread */
509 PBOOL pstate) /* [out] pointer to var that receives the boost state */
511 if (pstate) *pstate = FALSE;
516 /**********************************************************************
517 * SetThreadPriorityBoost [KERNEL32.@] Sets priority boost for thread.
519 * Priority boost is not implemented. Thsi function always returns
520 * FALSE and sets last error to ERROR_CALL_NOT_IMPLEMENTED
523 * Always returns FALSE to indicate a failure
525 BOOL WINAPI SetThreadPriorityBoost(
526 HANDLE hthread, /* [in] Handle to thread */
527 BOOL disable) /* [in] TRUE to disable priority boost */
529 SetLastError(ERROR_CALL_NOT_IMPLEMENTED);
534 /**********************************************************************
535 * SetThreadAffinityMask (KERNEL32.@)
537 DWORD WINAPI SetThreadAffinityMask( HANDLE hThread, DWORD dwThreadAffinityMask )
540 SERVER_START_REQ( set_thread_info )
542 req->handle = hThread;
543 req->affinity = dwThreadAffinityMask;
544 req->mask = SET_THREAD_INFO_AFFINITY;
545 ret = !wine_server_call_err( req );
546 /* FIXME: should return previous value */
552 /**********************************************************************
553 * SetThreadIdealProcessor [KERNEL32.@] Obtains timing information.
556 * Success: Value of last call to SetThreadIdealProcessor
559 DWORD WINAPI SetThreadIdealProcessor(
560 HANDLE hThread, /* [in] Specifies the thread of interest */
561 DWORD dwIdealProcessor) /* [in] Specifies the new preferred processor */
563 FIXME("(0x%08x): stub\n",hThread);
564 SetLastError(ERROR_CALL_NOT_IMPLEMENTED);
568 /**********************************************************************
569 * TerminateThread [KERNEL32.@] Terminates a thread
575 BOOL WINAPI TerminateThread( HANDLE handle, /* [in] Handle to thread */
576 DWORD exit_code) /* [in] Exit code for thread */
578 NTSTATUS status = NtTerminateThread( handle, exit_code );
579 if (status) SetLastError( RtlNtStatusToDosError(status) );
584 /**********************************************************************
585 * GetExitCodeThread (KERNEL32.@)
587 * Gets termination status of thread.
593 BOOL WINAPI GetExitCodeThread(
594 HANDLE hthread, /* [in] Handle to thread */
595 LPDWORD exitcode) /* [out] Address to receive termination status */
598 SERVER_START_REQ( get_thread_info )
600 req->handle = hthread;
602 ret = !wine_server_call_err( req );
603 if (ret && exitcode) *exitcode = reply->exit_code;
610 /**********************************************************************
611 * ResumeThread [KERNEL32.@] Resumes a thread.
613 * Decrements a thread's suspend count. When count is zero, the
614 * execution of the thread is resumed.
617 * Success: Previous suspend count
618 * Failure: 0xFFFFFFFF
621 DWORD WINAPI ResumeThread(
622 HANDLE hthread) /* [in] Identifies thread to restart */
624 DWORD ret = 0xffffffff;
625 SERVER_START_REQ( resume_thread )
627 req->handle = hthread;
628 if (!wine_server_call_err( req )) ret = reply->count;
635 /**********************************************************************
636 * SuspendThread [KERNEL32.@] Suspends a thread.
639 * Success: Previous suspend count
640 * Failure: 0xFFFFFFFF
642 DWORD WINAPI SuspendThread(
643 HANDLE hthread) /* [in] Handle to the thread */
645 DWORD ret = 0xffffffff;
646 SERVER_START_REQ( suspend_thread )
648 req->handle = hthread;
649 if (!wine_server_call_err( req )) ret = reply->count;
656 /***********************************************************************
657 * QueueUserAPC (KERNEL32.@)
659 DWORD WINAPI QueueUserAPC( PAPCFUNC func, HANDLE hthread, ULONG_PTR data )
662 SERVER_START_REQ( queue_apc )
664 req->handle = hthread;
667 req->param = (void *)data;
668 ret = !wine_server_call_err( req );
675 /**********************************************************************
676 * GetThreadTimes [KERNEL32.@] Obtains timing information.
679 * What are the fields where these values are stored?
685 BOOL WINAPI GetThreadTimes(
686 HANDLE thread, /* [in] Specifies the thread of interest */
687 LPFILETIME creationtime, /* [out] When the thread was created */
688 LPFILETIME exittime, /* [out] When the thread was destroyed */
689 LPFILETIME kerneltime, /* [out] Time thread spent in kernel mode */
690 LPFILETIME usertime) /* [out] Time thread spent in user mode */
692 FIXME("(0x%08x): stub\n",thread);
693 SetLastError(ERROR_CALL_NOT_IMPLEMENTED);
698 /**********************************************************************
699 * VWin32_BoostThreadGroup [KERNEL.535]
701 VOID WINAPI VWin32_BoostThreadGroup( DWORD threadId, INT boost )
703 FIXME("(0x%08lx,%d): stub\n", threadId, boost);
706 /**********************************************************************
707 * VWin32_BoostThreadStatic [KERNEL.536]
709 VOID WINAPI VWin32_BoostThreadStatic( DWORD threadId, INT boost )
711 FIXME("(0x%08lx,%d): stub\n", threadId, boost);
715 /***********************************************************************
716 * GetThreadLocale (KERNEL32.@)
718 LCID WINAPI GetThreadLocale(void)
720 LCID ret = NtCurrentTeb()->CurrentLocale;
721 if (!ret) NtCurrentTeb()->CurrentLocale = ret = GetUserDefaultLCID();
726 /**********************************************************************
727 * SetThreadLocale [KERNEL32.@] Sets the calling threads current locale.
734 * check if lcid is a valid cp
736 BOOL WINAPI SetThreadLocale(
737 LCID lcid) /* [in] Locale identifier */
741 case LOCALE_SYSTEM_DEFAULT:
742 lcid = GetSystemDefaultLCID();
744 case LOCALE_USER_DEFAULT:
746 lcid = GetUserDefaultLCID();
749 NtCurrentTeb()->CurrentLocale = lcid;
754 /***********************************************************************
755 * GetCurrentThread [KERNEL32.@] Gets pseudohandle for current thread
758 * Pseudohandle for the current thread
760 #undef GetCurrentThread
761 HANDLE WINAPI GetCurrentThread(void)
767 /***********************************************************************
768 * ProcessIdToSessionId (KERNEL32.@)
769 * This function is available on Terminal Server 4SP4 and Windows 2000
771 BOOL WINAPI ProcessIdToSessionId( DWORD procid, DWORD *sessionid_ptr )
773 /* According to MSDN, if the calling process is not in a terminal
774 * services environment, then the sessionid returned is zero.
780 /***********************************************************************
781 * SetThreadExecutionState (KERNEL32.@)
783 * Informs the system that activity is taking place for
784 * power management purposes.
786 EXECUTION_STATE WINAPI SetThreadExecutionState(EXECUTION_STATE flags)
788 static EXECUTION_STATE current =
789 ES_SYSTEM_REQUIRED|ES_DISPLAY_REQUIRED|ES_USER_PRESENT;
790 EXECUTION_STATE old = current;
792 if (!(current & ES_CONTINUOUS) || (flags & ES_CONTINUOUS))
794 FIXME("(0x%lx): stub, harmless (power management).\n", flags);
801 /***********************************************************************
802 * SetLastError (KERNEL.147)
803 * SetLastError (KERNEL32.@)
805 /* void WINAPI SetLastError( DWORD error ); */
806 __ASM_GLOBAL_FUNC( SetLastError,
807 "movl 4(%esp),%eax\n\t"
812 /***********************************************************************
813 * GetLastError (KERNEL.148)
814 * GetLastError (KERNEL32.@)
816 /* DWORD WINAPI GetLastError(void); */
817 __ASM_GLOBAL_FUNC( GetLastError, ".byte 0x64\n\tmovl 0x60,%eax\n\tret" );
819 /***********************************************************************
820 * GetCurrentProcessId (KERNEL.471)
821 * GetCurrentProcessId (KERNEL32.@)
823 /* DWORD WINAPI GetCurrentProcessId(void) */
824 __ASM_GLOBAL_FUNC( GetCurrentProcessId, ".byte 0x64\n\tmovl 0x20,%eax\n\tret" );
826 /***********************************************************************
827 * GetCurrentThreadId (KERNEL.462)
828 * GetCurrentThreadId (KERNEL32.@)
830 /* DWORD WINAPI GetCurrentThreadId(void) */
831 __ASM_GLOBAL_FUNC( GetCurrentThreadId, ".byte 0x64\n\tmovl 0x24,%eax\n\tret" );
835 /**********************************************************************
836 * SetLastError (KERNEL.147)
837 * SetLastError (KERNEL32.@)
839 * Sets the last-error code.
841 void WINAPI SetLastError( DWORD error ) /* [in] Per-thread error code */
843 NtCurrentTeb()->last_error = error;
846 /**********************************************************************
847 * GetLastError (KERNEL.148)
848 * GetLastError (KERNEL32.@)
850 * Returns last-error code.
852 DWORD WINAPI GetLastError(void)
854 return NtCurrentTeb()->last_error;
857 /***********************************************************************
858 * GetCurrentProcessId (KERNEL.471)
859 * GetCurrentProcessId (KERNEL32.@)
861 * Returns process identifier.
863 DWORD WINAPI GetCurrentProcessId(void)
865 return (DWORD)NtCurrentTeb()->pid;
868 /***********************************************************************
869 * GetCurrentThreadId (KERNEL.462)
870 * GetCurrentThreadId (KERNEL32.@)
872 * Returns thread identifier.
874 DWORD WINAPI GetCurrentThreadId(void)
876 return (DWORD)NtCurrentTeb()->tid;
879 #endif /* __i386__ */