thread.c File Reference

#include <k32.h>
#include <debug.h>

Include dependency graph for thread.c:

Go to the source code of this file.

Macros
#define	NDEBUG
#define	SXS_SUPPORT_FIXME
#define	THEONLYGROUP   0

Typedefs
typedef NTSTATUS(NTAPI *	PCSR_CREATE_REMOTE_THREAD) (IN HANDLE ThreadHandle, IN PCLIENT_ID ClientId)

Functions
NTSTATUS WINAPI	BasepNotifyCsrOfThread (IN HANDLE ThreadHandle, IN PCLIENT_ID ClientId)
DECLSPEC_NORETURN VOID WINAPI	BaseThreadStartup (_In_ LPTHREAD_START_ROUTINE lpStartAddress, _In_ LPVOID lpParameter)
VOID NTAPI	BaseDispatchApc (IN PAPCFUNC ApcRoutine, IN PVOID Data, IN PACTIVATION_CONTEXT ActivationContext)
HANDLE WINAPI DECLSPEC_HOTPATCH	CreateThread (IN LPSECURITY_ATTRIBUTES lpThreadAttributes, IN DWORD dwStackSize, IN LPTHREAD_START_ROUTINE lpStartAddress, IN LPVOID lpParameter, IN DWORD dwCreationFlags, OUT LPDWORD lpThreadId)
HANDLE WINAPI	CreateRemoteThread (IN HANDLE hProcess, IN LPSECURITY_ATTRIBUTES lpThreadAttributes, IN DWORD dwStackSize, IN LPTHREAD_START_ROUTINE lpStartAddress, IN LPVOID lpParameter, IN DWORD dwCreationFlags, OUT LPDWORD lpThreadId)
VOID WINAPI	ExitThread (IN DWORD uExitCode)
HANDLE WINAPI	OpenThread (IN DWORD dwDesiredAccess, IN BOOL bInheritHandle, IN DWORD dwThreadId)
PTEB	GetTeb (VOID)
BOOL WINAPI	SwitchToThread (VOID)
DWORD WINAPI	GetCurrentThreadId (VOID)
BOOL NTAPI	GetThreadTimes (IN HANDLE hThread, OUT LPFILETIME lpCreationTime, OUT LPFILETIME lpExitTime, OUT LPFILETIME lpKernelTime, OUT LPFILETIME lpUserTime)
BOOL WINAPI	GetThreadContext (IN HANDLE hThread, OUT LPCONTEXT lpContext)
BOOL WINAPI	SetThreadContext (IN HANDLE hThread, IN CONST CONTEXT *lpContext)
BOOL WINAPI	GetExitCodeThread (IN HANDLE hThread, OUT LPDWORD lpExitCode)
DWORD WINAPI	ResumeThread (IN HANDLE hThread)
BOOL WINAPI	TerminateThread (IN HANDLE hThread, IN DWORD dwExitCode)
DWORD WINAPI	SuspendThread (IN HANDLE hThread)
DWORD_PTR WINAPI	SetThreadAffinityMask (IN HANDLE hThread, IN DWORD_PTR dwThreadAffinityMask)
BOOL WINAPI	GetThreadGroupAffinity (IN HANDLE hThread, OUT PGROUP_AFFINITY GroupAffinity)
BOOL WINAPI	SetThreadGroupAffinity (IN HANDLE hThread, IN const GROUP_AFFINITY *GroupAffinity, OUT OPTIONAL PGROUP_AFFINITY PreviousGroupAffinity)
BOOL WINAPI	SetThreadPriority (IN HANDLE hThread, IN int nPriority)
int WINAPI	GetThreadPriority (IN HANDLE hThread)
BOOL WINAPI	GetThreadPriorityBoost (IN HANDLE hThread, OUT PBOOL pDisablePriorityBoost)
BOOL NTAPI	SetThreadPriorityBoost (IN HANDLE hThread, IN BOOL bDisablePriorityBoost)
BOOL WINAPI	GetThreadSelectorEntry (IN HANDLE hThread, IN DWORD dwSelector, OUT LPLDT_ENTRY lpSelectorEntry)
DWORD WINAPI	SetThreadIdealProcessor (IN HANDLE hThread, IN DWORD dwIdealProcessor)
DWORD WINAPI	GetProcessIdOfThread (IN HANDLE Thread)
DWORD WINAPI	GetThreadId (IN HANDLE Thread)
LANGID WINAPI	SetThreadUILanguage (IN LANGID LangId)
DWORD WINAPI	QueueUserAPC (IN PAPCFUNC pfnAPC, IN HANDLE hThread, IN ULONG_PTR dwData)
BOOL WINAPI	SetThreadStackGuarantee (IN OUT PULONG StackSizeInBytes)
BOOL WINAPI	GetThreadIOPendingFlag (IN HANDLE hThread, OUT PBOOL lpIOIsPending)
BOOL WINAPI	QueueUserWorkItem (IN LPTHREAD_START_ROUTINE Function, IN PVOID Context, IN ULONG Flags)
DWORD WINAPI	TlsAlloc (VOID)
BOOL WINAPI	TlsFree (IN DWORD Index)
LPVOID WINAPI	TlsGetValue (IN DWORD Index)
BOOL WINAPI	TlsSetValue (IN DWORD Index, IN LPVOID Value)

Macro Definition Documentation

NDEBUG

#define NDEBUG

Definition at line 14 of file thread.c.

SXS_SUPPORT_FIXME

#define SXS_SUPPORT_FIXME

Definition at line 17 of file thread.c.

THEONLYGROUP

#define THEONLYGROUP   0

Definition at line 695 of file thread.c.

Typedef Documentation

PCSR_CREATE_REMOTE_THREAD

typedef NTSTATUS(NTAPI * PCSR_CREATE_REMOTE_THREAD) (IN HANDLE ThreadHandle, IN PCLIENT_ID ClientId)

Definition at line 19 of file thread.c.

Function Documentation

BaseDispatchApc()

VOID NTAPI BaseDispatchApc	(	IN PAPCFUNC	ApcRoutine,
		IN PVOID	Data,
		IN PACTIVATION_CONTEXT	ActivationContext
	)

Definition at line 92 of file thread.c.

{
    RTL_CALLER_ALLOCATED_ACTIVATION_CONTEXT_STACK_FRAME ActivationFrame;
 
    /* Setup the activation context */
    ActivationFrame.Size = sizeof(ActivationFrame);
    ActivationFrame.Format = RTL_CALLER_ALLOCATED_ACTIVATION_CONTEXT_STACK_FRAME_FORMAT_WHISTLER;
 
    /* Check if caller wanted one */
    if (ActivationContext == INVALID_ACTIVATION_CONTEXT)
    {
        /* Do the APC directly */
        ApcRoutine((ULONG_PTR)Data);
        return;
    }
 
    /* Then activate it */
    RtlActivateActivationContextUnsafeFast(&ActivationFrame, ActivationContext);
 
    /* Call the routine under SEH */
    _SEH2_TRY
    {
        ApcRoutine((ULONG_PTR)Data);
    }
    _SEH2_EXCEPT(EXCEPTION_EXECUTE_HANDLER)
    {
 
    }
    _SEH2_END;
 
    /* Now de-activate and release the activation context */
    RtlDeactivateActivationContextUnsafeFast(&ActivationFrame);
    RtlReleaseActivationContext(ActivationContext);
}

Referenced by QueueUserAPC().

BasepNotifyCsrOfThread()

NTSTATUS WINAPI BasepNotifyCsrOfThread	(	IN HANDLE	ThreadHandle,
		IN PCLIENT_ID	ClientId
	)

Definition at line 25 of file thread.c.

{
    BASE_API_MESSAGE ApiMessage;
    PBASE_CREATE_THREAD CreateThreadRequest = &ApiMessage.Data.CreateThreadRequest;
 
    DPRINT("BasepNotifyCsrOfThread: Thread: %p, Handle %p\n",
            ClientId->UniqueThread, ThreadHandle);
 
    /* Fill out the request */
    CreateThreadRequest->ClientId = *ClientId;
    CreateThreadRequest->ThreadHandle = ThreadHandle;
 
    /* Call CSR */
    CsrClientCallServer((PCSR_API_MESSAGE)&ApiMessage,
                        NULL,
                        CSR_CREATE_API_NUMBER(BASESRV_SERVERDLL_INDEX, BasepCreateThread),
                        sizeof(*CreateThreadRequest));
    if (!NT_SUCCESS(ApiMessage.Status))
    {
        DPRINT1("Failed to tell CSRSS about new thread: %lx\n", ApiMessage.Status);
        return ApiMessage.Status;
    }
 
    /* Return Success */
    return STATUS_SUCCESS;
}

Referenced by CreateRemoteThread().

BaseThreadStartup()

DECLSPEC_NORETURN VOID WINAPI BaseThreadStartup	(	_In_ LPTHREAD_START_ROUTINE	lpStartAddress,
		_In_ LPVOID	lpParameter
	)

Definition at line 56 of file thread.c.

{
    /* Attempt to call the Thread Start Address */
    _SEH2_TRY
    {
        /* Legacy check which is still used today for Win32 threads */
        if (NtCurrentTeb()->NtTib.Version == (30 << 8)) // OS/2 V3.0 ("Cruiser")
        {
            /* This registers the termination port with CSRSS */
            if (!BaseRunningInServerProcess) CsrNewThread();
        }
 
        /* Get the exit code from the Thread Start */
        ExitThread(lpStartAddress(lpParameter));
    }
    _SEH2_EXCEPT(UnhandledExceptionFilter(_SEH2_GetExceptionInformation()))
    {
        /* Get the Exit code from the SEH Handler */
        if (!BaseRunningInServerProcess)
        {
            /* Kill the whole process, usually */
            ExitProcess(_SEH2_GetExceptionCode());
        }
        else
        {
            /* If running inside CSRSS, kill just this thread */
            ExitThread(_SEH2_GetExceptionCode());
        }
    }
    _SEH2_END;
}

Referenced by BaseInitializeContext().

CreateRemoteThread()

HANDLE WINAPI CreateRemoteThread	(	IN HANDLE	hProcess,
		IN LPSECURITY_ATTRIBUTES	lpThreadAttributes,
		IN DWORD	dwStackSize,
		IN LPTHREAD_START_ROUTINE	lpStartAddress,
		IN LPVOID	lpParameter,
		IN DWORD	dwCreationFlags,
		OUT LPDWORD	lpThreadId
	)

Definition at line 159 of file thread.c.

{
    NTSTATUS Status;
    INITIAL_TEB InitialTeb;
    CONTEXT Context;
    CLIENT_ID ClientId;
    OBJECT_ATTRIBUTES LocalObjectAttributes;
    POBJECT_ATTRIBUTES ObjectAttributes;
    HANDLE hThread;
    ULONG Dummy;
    PTEB Teb;
    THREAD_BASIC_INFORMATION ThreadBasicInfo;
    PACTIVATION_CONTEXT_STACK ActivationContextStack = NULL;
    ACTIVATION_CONTEXT_BASIC_INFORMATION ActCtxInfo;
    ULONG_PTR Cookie;
    ULONG ReturnLength;
    SIZE_T ReturnSize;
 
    DPRINT("CreateRemoteThread: hProcess: %p dwStackSize: %lu lpStartAddress"
           ": %p lpParameter: %p, dwCreationFlags: %lx\n", hProcess,
           dwStackSize, lpStartAddress, lpParameter, dwCreationFlags);
 
    /* Clear the Context */
    RtlZeroMemory(&Context, sizeof(Context));
 
    /* Write PID */
    ClientId.UniqueProcess = hProcess;
 
    /* Create the Stack */
    Status = BaseCreateStack(hProcess,
                             (dwCreationFlags & STACK_SIZE_PARAM_IS_A_RESERVATION) ?
                                0 : dwStackSize,
                             (dwCreationFlags & STACK_SIZE_PARAM_IS_A_RESERVATION) ?
                                dwStackSize : 0,
                             &InitialTeb);
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return NULL;
    }
 
    /* Create the Initial Context */
    BaseInitializeContext(&Context,
                          lpParameter,
                          lpStartAddress,
                          InitialTeb.StackBase,
                          1);
 
    /* Initialize the attributes for the thread object */
    ObjectAttributes = BaseFormatObjectAttributes(&LocalObjectAttributes,
                                                  lpThreadAttributes,
                                                  NULL);
 
    /* Create the Kernel Thread Object */
    Status = NtCreateThread(&hThread,
                            THREAD_ALL_ACCESS,
                            ObjectAttributes,
                            hProcess,
                            &ClientId,
                            &Context,
                            &InitialTeb,
                            TRUE);
    if (!NT_SUCCESS(Status))
    {
        /* Fail the kernel create */
        BaseFreeThreadStack(hProcess, &InitialTeb);
        BaseSetLastNTError(Status);
        return NULL;
    }
 
    /* Are we in the same process? */
    if (hProcess == NtCurrentProcess())
    {
        /* Get the TEB */
        Status = NtQueryInformationThread(hThread,
                                          ThreadBasicInformation,
                                          &ThreadBasicInfo,
                                          sizeof(ThreadBasicInfo),
                                          &ReturnLength);
        if (!NT_SUCCESS(Status))
        {
            /* Fail */
            DPRINT1("SXS: %s - Failing thread create because "
                    "NtQueryInformationThread() failed with status %08lx\n",
                    __FUNCTION__, Status);
            goto Quit;
        }
 
        /* Allocate the Activation Context Stack */
        Status = RtlAllocateActivationContextStack(&ActivationContextStack);
        if (!NT_SUCCESS(Status))
        {
            /* Fail */
            DPRINT1("SXS: %s - Failing thread create because "
                    "RtlAllocateActivationContextStack() failed with status %08lx\n",
                    __FUNCTION__, Status);
            goto Quit;
        }
 
        /* Save it */
        Teb = ThreadBasicInfo.TebBaseAddress;
        Teb->ActivationContextStackPointer = ActivationContextStack;
 
        /* Query the Context */
        Status = RtlQueryInformationActivationContext(RTL_QUERY_ACTIVATION_CONTEXT_FLAG_USE_ACTIVE_ACTIVATION_CONTEXT,
                                                      NULL,
                                                      0,
                                                      ActivationContextBasicInformation,
                                                      &ActCtxInfo,
                                                      sizeof(ActCtxInfo),
                                                      &ReturnSize);
        if (!NT_SUCCESS(Status))
        {
            /* Fail */
            DPRINT1("SXS: %s - Failing thread create because "
                    "RtlQueryInformationActivationContext() failed with status %08lx\n",
                    __FUNCTION__, Status);
            goto Quit;
        }
 
        /* Does it need to be activated? */
        if ((ActCtxInfo.hActCtx) && !(ActCtxInfo.dwFlags & 1))
        {
            /* Activate it */
            Status = RtlActivateActivationContextEx(RTL_ACTIVATE_ACTIVATION_CONTEXT_EX_FLAG_RELEASE_ON_STACK_DEALLOCATION,
                                                    Teb,
                                                    ActCtxInfo.hActCtx,
                                                    &Cookie);
            if (!NT_SUCCESS(Status))
            {
                /* Fail */
                DPRINT1("SXS: %s - Failing thread create because "
                        "RtlActivateActivationContextEx() failed with status %08lx\n",
                        __FUNCTION__, Status);
                goto Quit;
            }
        }
 
        /* Sync the service tag with the parent thread's one */
        Teb->SubProcessTag = NtCurrentTeb()->SubProcessTag;
    }
 
    /* Notify CSR */
    if (!BaseRunningInServerProcess)
    {
        Status = BasepNotifyCsrOfThread(hThread, &ClientId);
    }
    else
    {
        if (hProcess != NtCurrentProcess())
        {
            PCSR_CREATE_REMOTE_THREAD CsrCreateRemoteThread;
 
            /* Get the direct CSRSRV export */
            CsrCreateRemoteThread = (PCSR_CREATE_REMOTE_THREAD)
                                    GetProcAddress(GetModuleHandleA("csrsrv"),
                                                   "CsrCreateRemoteThread");
            if (CsrCreateRemoteThread)
            {
                /* Call it instead of going through LPC */
                Status = CsrCreateRemoteThread(hThread, &ClientId);
            }
        }
    }
 
Quit:
    if (!NT_SUCCESS(Status))
    {
        /* Failed to create the thread */
 
        /* Free the activation context stack */
        if (ActivationContextStack)
            RtlFreeActivationContextStack(ActivationContextStack);
 
        NtTerminateThread(hThread, Status);
        // FIXME: Wait for the thread to terminate?
        BaseFreeThreadStack(hProcess, &InitialTeb);
        NtClose(hThread);
 
        BaseSetLastNTError(Status);
        return NULL;
    }
 
    /* Success */
    if (lpThreadId)
        *lpThreadId = HandleToUlong(ClientId.UniqueThread);
 
    /* Resume the thread if asked */
    if (!(dwCreationFlags & CREATE_SUSPENDED))
        NtResumeThread(hThread, &Dummy);
 
    /* Return handle to thread */
    return hThread;
}

Referenced by _DoDLLInjection(), BaseCreateThreadPoolThread(), ConSrvConsoleCtrlEventTimeout(), CreateThread(), dll_entry_point(), GuiConsoleShowConsoleProperties(), test_CreateRemoteThread(), test_debugger(), test_ExitProcess(), test_TerminateProcess(), and test_thread_actctx().

CreateThread()

HANDLE WINAPI DECLSPEC_HOTPATCH CreateThread	(	IN LPSECURITY_ATTRIBUTES	lpThreadAttributes,
		IN DWORD	dwStackSize,
		IN LPTHREAD_START_ROUTINE	lpStartAddress,
		IN LPVOID	lpParameter,
		IN DWORD	dwCreationFlags,
		OUT LPDWORD	lpThreadId
	)

Definition at line 137 of file thread.c.

{
    /* Act as if we're going to create a remote thread in ourselves */
    return CreateRemoteThread(NtCurrentProcess(),
                              lpThreadAttributes,
                              dwStackSize,
                              lpStartAddress,
                              lpParameter,
                              dwCreationFlags,
                              lpThreadId);
}

Referenced by _beginthread(), _beginthreadex(), _ServiceMain(), _test_flush_async(), _tWinMain(), AcceptConnections(), ANIMATE_Play(), apartment_hostobject_in_hostapt(), ApplicationPageWndProc(), async_wait_pipe(), AVISplitter_first_request(), check_hook_thread(), check_interface_marshal_proxy_creation_(), check_thread_apartment_(), check_thread_instance(), child_process(), clipboard_wnd_proc(), CommonInstall(), create_child_thread(), CreateClientProcess(), CreateLobbyMessageReceptionThread(), CreateRenderingSubsystem(), CreateRenderingWindow(), CreateServers(), CreateServiceThread(), CreateSidCacheMgr(), CreateSoundThread(), CSysTray::CreateSysTrayThread(), CreateTestThread(), CtfImmSetLangBand(), CThread::CThread(), custom_action_server(), DbgkCreateThread(), DbgkpPostFakeThreadMessages(), DbgUiConvertStateChangeStructure(), DECLARE_INTERFACE_(), DIALOG_Printing_DialogProc(), CTrayWindow::DisplayProperties(), CTrayWindow::DisplayRunFileDlg(), dll_entry_point(), do_msidbCustomActionTypeDll(), do_msidbCustomActionTypeScript(), do_wait_idle_child(), DosStartProcess32(), EmulatorInitialize(), ensurePlayerThread(), ExitWindowsWorker(), fiber_actctx_func(), fls_exit_deadlock_child(), get_id_thread(), get_thread_fpu_cw(), GUIDisplayStatusMessage(), HandleLogoff(), http_release_netconn(), IDirectPlay4Impl_EnumSessions(), IDirectSoundCaptureBufferImpl_Start(), SEALED_::IMsTscAx::Connect(), init(), InitDialog(), CDesktopThread::Initialize(), BtrfsPropSheet::Initialize(), COutputPin::InitializeIOThread(), InitializeScreenSaver(), InitiateSoundStreaming(), InitRpc(), InstallDrvDlgProc(), installer_proc(), InstallReactOS(), CZipFolder::InvokeCommand(), JustDoIt(), KmtRunKernelTest(), LocalScheduleJob(), LS_ThreadProc(), LsapRmInitializeServer(), MailSlotReader(), main(), MainDialogProc(), MainWndProc(), MCI_SendCommandAsync(), MCIAVI_mciPlay_async(), MCICDA_Play(), MCIQTZ_mciPlay(), midiStreamOpen(), MMDevEnum_RegisterEndpointNotificationCallback(), mmTaskCreate(), StringTest::mt(), Netbios(), NetworkInitPageDlgProc(), NotifyTopLevelWindow(), Window::OnCommand(), OnCreate(), OnInitDialog(), OnUpdate(), CZipExtract::CExtractSettingsPage::OnWizardNext(), Telnet::Open(), audio_wavein::open(), audio_waveout::open(), OpenDevice(), OSK_Create(), OutputQueue_Construct(), CKsClockForwarder::Pause(), PdhCollectQueryDataEx(), PerformancePageWndProc(), PlayLogonSound(), PowerMeterDlgProc(), proc_PlaySoundAsync(), ProcessDlgProc(), ProcessPageWndProc(), Protocol_Start(), protocol_start(), PullPin_InitProcessing(), rawinput_test_thread(), BtrfsRecv::RecvProgressDlgProc(), ReferenceClock_AdvisePeriodic(), ReferenceClock_AdviseTime(), RegisterGPNotification(), report(), RpcReadFile(), rpcrt4_ncacn_http_open(), RPCRT4_new_client(), RPCRT4_start_listen_protseq(), RSetServiceStatus(), run_background_thread(), run_in_temp_desktop_(), run_LS_tests(), run_thread(), RunItemCompletionThread(), RunLogoffShutdownThread(), RunSelectedTest(), RunSetup(), RunShell(), RunTest(), s_test_I_RpcBindingInqLocalClientPID(), schedule_timeout(), ScStartService(), SearchDrvDlgProc(), ServiceInit(), ServiceMain(), BtrfsPropSheet::set_cmdline(), SHCreateThread(), SHOpenFolderWindow(), SockCreateOrReferenceAsyncThread(), start_dummy_thread(), start_host_object2(), start_installation(), START_TEST(), StartAdapterDiscovery(), StartAuthenticationPort(), StartClients(), StartNotificationThread(), StartPortThread(), CProgressDialog::StartProgressDialog(), BtrfsSend::StartSend(), StartServer(), StartServiceThread(), StartStopEnumEventsThread(), StartSystemShutdown(), CAsyncLoadIcon::StartTasks(), StartTestCORE10188(), StartTestCORE17376(), CUTBLangBarDlg::StartThread(), CHardErrorThread::StartThread(), subtest_fiber_actctx_preservation(), suspend_process_proc(), SystemClockPostMessageToAdviseThread(), test(), test_AbortWaitCts(), Test_Acquire(), test_activateapp(), test_ActivateKeyboardLayout(), test_alertable(), test_alertable_wait(), test_apc_deadlock(), test_attach_input(), Test_AVX(), Test_AVX512(), test_BCryptEncrypt(), test_blocking(), test_bsc_marshaling(), test_CancelSynchronousIo(), test_cancelsynchronousio(), test_ClipCursor_process(), Test_CloseWhileSelectDuplicatedSocket(), Test_CloseWhileSelectSameSocket(), test_CoFreeUnusedLibraries(), test_CoGetCurrentProcess(), test_completion_port_scheduling(), test_condvars_base(), test_condvars_consumer_producer(), test_CoRegisterPSClsid(), test_CoWaitForMultipleHandles(), test_CoWaitForMultipleHandles_thread(), test_crash_couninitialize(), test_CreateThread_basic(), test_CreateThread_stack(), test_CreateThread_suspended(), test_CUIAutomation_event_handlers(), test_dde_default_app(), test_default_client_accessible_object(), test_default_ime_window_creation(), test_defwinproc(), test_deletecontext(), test_destroy_quit(), test_DragQueryFile(), test_duplicate_handle_access(), test_edit_messages(), test_EnableWindow(), test_enum_thread_windows(), test_events(), test_ffcn_directory_overlap(), test_ffcnMultipleThreads(), test_FiberLocalStorage(), test_foregroundwindow(), test_get_next_thread(), test_GetKeyState(), test_GetPointerInfo(), test_gettext(), test_GetThreadExitCode(), test_GetThreadTimes(), test_globalinterfacetable(), test_handles(), test_HeapCreate(), test_HideFromDebugger(), test_hook_cleanup(), test_http_connection(), test_icons(), test_IInitializeSpy(), test_ImmDefaultHwnd(), test_ImmThreads(), test_ImpersonateNamedPipeClient(), test_implicit_mta(), test_import_resolution(), test_InSendMessage(), test_interthread_messages(), test_iosb(), test_IUIAutomationEventHandler(), test_kernel32_tp_io(), test_keyed_events(), test_kill_on_exit(), test_layered_window(), test_main_thread(), test_menu_input(), test_messages(), test_mta_creation_thread_change_apartment(), test_MultiThreadApartment(), test_multithreaded_clipboard(), test_mutant(), test_NamedPipe_2(), test_no_couninitialize_client(), test_no_couninitialize_server(), test_nonalertable(), test_NtAtom(), test_oletlsdata(), test_overlapped(), test_PeekMessage(), test_proxy_used_in_wrong_thread(), test_pseudo_console(), test_QueueUserAPC(), test_rawinput(), test_reader_info(), test_reconnect(), test_registered_object_thread_affinity(), test_RegNotifyChangeKeyValue(), test_render_with_multithread(), test_resource(), test_RoGetAgileReference(), test_RtlCreateUserStack(), test_RtlIsCriticalSectionLocked(), test_runner(), test_select(), test_SendInput_mouse_messages(), test_SendMessage_other_thread(), test_SendMessageTimeout(), test_set_clipboard_DRAWCLIPBOARD(), test_SetCursor(), test_SetFocus(), test_SetForegroundWindow(), test_setparent_status(), test_shell_window(), test_ShowCursor(), test_smresult(), test_srwlock_base(), test_srwlock_example(), Test_SSE(), test_stop_wait_for_call(), test_suspend_thread(), test_SuspendThread(), test_tableweak_and_normal_marshal_and_releasedata(), test_tableweak_and_normal_marshal_and_unmarshal(), test_TerminateThread(), test_thread_actctx(), test_thread_exit_destroy(), test_thread_objects(), test_thread_security(), test_thread_start_address(), test_ThreadIsTerminated(), test_threads(), test_tid_alert(), test_timeouts(), test_timers(), test_tls_links(), test_tp_io(), TEST_Tracking(), test_two_tableweak_marshal_and_releasedata(), test_uia_event_ProxyProviderWinEventHandler(), test_uia_node_from_prov_com_threading(), test_uia_reserved_value_ifaces(), test_UiaAddEvent(), test_UiaNodeFromHandle(), test_WaitBreak(), test_WaitCts(), test_WaitDcd(), test_WaitDsr(), test_WaitForInputIdle(), test_WaitRing(), test_winevents(), test_write_watch(), Test_WS_FORCEMINIMIZE_Sub(), TestMessages(), TestMultipleUserAPCs(), TestRecursiveInterThreadMessages(), thread(), TIME_MMTimeStart(), uia_start_client_thread(), uia_start_event_thread(), uia_start_provider_thread(), UserLogin(), WahOpenHandleHelper(), wave_out_test_deviceOut(), WdmAudSetMixerDeviceFormatByLegacy(), wined3d_cs_create(), WinMain(), wmain(), WriterThread::WriterThread(), WsAsyncCheckAndInitThread(), WshShell3_Popup(), and wWinMain().

ExitThread()

VOID WINAPI ExitThread

(

IN DWORD

uExitCode

)

Definition at line 365 of file thread.c.

{
    NTSTATUS Status;
    ULONG LastThread;
    PRTL_CRITICAL_SECTION LoaderLock;
 
    /* Make sure loader lock isn't held */
    LoaderLock = NtCurrentPeb()->LoaderLock;
    if (LoaderLock) ASSERT(NtCurrentTeb()->ClientId.UniqueThread != LoaderLock->OwningThread);
 
    /*
     * Terminate process if this is the last thread
     * of the current process
     */
    Status = NtQueryInformationThread(NtCurrentThread(),
                                      ThreadAmILastThread,
                                      &LastThread,
                                      sizeof(LastThread),
                                      NULL);
    if ((NT_SUCCESS(Status)) && (LastThread)) ExitProcess(uExitCode);
 
    /* Notify DLLs and TLS Callbacks of termination */
    LdrShutdownThread();
 
    /* Tell the Kernel to free the Stack */
    NtCurrentTeb()->FreeStackOnTermination = TRUE;
    NtTerminateThread(NULL, uExitCode);
 
    /* We should never reach this place */
    ERROR_FATAL("It should not happen\n");
    while (TRUE); /* 'noreturn' function */
}

Referenced by _endthreadex(), BaseExitThreadPoolThread(), BaseProcessStartup(), BaseThreadStartup(), ChargenHandler(), client_stop(), collect_query_thread(), common_end_thread(), ConsoleControlDispatcher(), create_debug_port(), CreateSystemThreads(), DaytimeHandler(), DbgkExitThread(), ddeThread(), debug_and_exit(), debug_and_wait(), DECLARE_INTERFACE_(), DeleteFiber(), DiscardHandler(), EchoHandler(), exit_thread_fiber_func(), ExitWindowsThread(), FreeLibraryAndExitThread(), MMSYSTEM_MidiStream_Player(), NotificationThread(), PullPin_Thread_Stop(), QotdHandler(), server_stop(), StartServer(), test_stack_growth_thread(), test_thread_func(), thread_proc(), thread_start(), WaveActivateSoundStreaming(), wmain(), and wWinMain().

GetCurrentThreadId()

DWORD WINAPI GetCurrentThreadId

(

VOID

)

Definition at line 459 of file thread.c.

{
    return HandleToUlong(NtCurrentTeb()->ClientId.UniqueThread);
}

Referenced by __security_init_cookie(), __threadid(), CTipbarThread::_UninitItemList(), alloc_msi_remote_handle(), alloc_msihandle(), ANIMATE_DoStop(), AnotherThreadFunc(), apartment_construct(), AtlModuleAddCreateWndData(), AtlModuleExtractCreateWndData(), ATL::AtlWinModuleAddCreateWndData(), ATL::AtlWinModuleExtractCreateWndData(), CTipbarWnd::AttachFocusThread(), callback(), callback_func(), cbt_global_hook_proc(), cbt_hook_proc(), check_active_state_(), check_dinput_hooks(), check_notification(), check_window_style(), check_wnd_state_(), clipboard_thread(), clnt_cb_thread(), clnt_vc_create(), clnt_vc_destroy(), CMenuFocusManager::CMenuFocusManager(), ConIme_InitInstance(), ConIme_OnEnd(), context_create(), context_destroy(), context_reacquire(), CoRegisterInitializeSpy(), CoRevokeInitializeSpy(), create_binding_protocol(), create_test_windows(), CreateD3D9(), CreatePseudoConsole(), CtfImmGenerateMessage(), CtfImmTIMCreateInputContext(), DECLARE_INTERFACE_(), dialog_proc(), dialog_register_class(), dialog_run_message_loop(), DlgMainProc(), DllMain(), do_InitialDesktop_child(), do_wait_idle_child(), dprintf(), DumpNotificationState(), enum_thread(), EnumThreadWindows(), eprintf(), event_client(), fetch_thread_info(), FileOpenDlgProc95(), format_exception_msg(), get_ime_window(), get_or_create_threaddata(), get_thread_data(), GetActiveWindow(), GetCapture(), GetFocus(), GetMessageRedrawWindowTest(), GetSystemUserInfo(), GetThreadFromCurrentProcess(), group_cancel_cleanup_increment_cb(), group_cancel_cleanup_release2_cb(), group_cancel_cleanup_release_cb(), HttpNegotiate_BeginningTransaction(), HttpNegotiate_GetRootSecurityId(), HttpNegotiate_OnResponse(), IDirectSoundBufferImpl_GetStatus(), IDirectSoundCaptureBufferImpl_GetStatus(), Imm32InternalLockIMC(), Imm32IsCrossThreadAccess(), ImmSetCompositionStringAW(), init_tests(), InitChildWindow(), InitD3D9BaseDevice(), InitThreads(), InitUniqueString(), is_apartment_thread(), JScript_AddNamedItem(), JScript_Close(), JScript_GetScriptDispatch(), JScript_GetScriptState(), JScript_SetScriptState(), JScriptParse_ParseScriptText(), JScriptParseProcedure_ParseProcedureText(), load_gecko(), log_debug(), log_hexdump(), MainDialogProc(), MainWndProc(), MCI_Close(), MCI_LoadMciDriver(), MCI_SendCommandFrom32(), mmGetCurrentTask(), msg_spy_init(), msi_dialog_check_messages(), msi_dialog_destroy(), MsiCloseAllHandles(), msvcrt_get_thread_data(), mutex_thread_proc(), new_stub_manager(), nfs41_open(), noop_thread_proc(), notification_callback(), OLEMenu_CallWndProc(), OLEMenu_GetMsgProc(), OLEMenu_InstallHooks(), OleSetMenuDescriptor(), OnInitDialog(), CAutoComplete::OnShowWindow(), oob_client(), oob_server(), PersistMoniker_Load(), print_sr_status_flags(), Protocol_Continue(), ProviderAdviseEvents_AdviseEventAdded(), ProviderAdviseEvents_AdviseEventRemoved(), ProviderFragment_get_BoundingRectangle(), ProviderFragment_get_FragmentRoot(), ProviderFragment_GetEmbeddedFragmentRoots(), ProviderFragment_GetRuntimeId(), ProviderFragment_Navigate(), ProviderFragmentRoot_GetFocus(), ProviderSimple_get_HostRawElementProvider(), ProviderSimple_get_ProviderOptions(), ProviderSimple_GetPatternProvider(), ProviderSimple_GetPropertyValue(), ProviderWinEventHandler_RespondToWinEvent(), CAsyncLoadIcon::Queue(), RegisterConsoleIME(), Rs232Thread(), rtl_wait_cb(), run_in_temp_desktop_thread_func(), ScriptThread(), select_server(), semaphore_thread_proc(), server_stop(), set_cursor_thread(), CTipbarWnd::SetFocusThread(), setup_test(), CThreadMgr::SetupWindowsHook(), show_cursor_thread(), simple_client(), simple_mixed_client(), simple_server(), SPY_EnterMessage(), start_debugger(), START_TEST(), CTipbarWnd::StartModalInput(), statusclb_GetBindInfo(), statusclb_OnDataAvailable(), statusclb_OnProgress(), statusclb_OnStartBinding(), statusclb_OnStopBinding(), statusclb_QueryInterface(), CTipbarWnd::StopModalInput(), Stream_Read(), sw_SetContext(), swapchain_create_context(), swapchain_get_context(), Test_Acquire(), test_alertable(), test_async(), test_async_HttpSendRequestEx(), test_attach_input(), test_capture_4_proc(), test_CoGetCurrentProcess(), test_com_event_data_(), test_CoWaitForMultipleHandles_thread(), test_CreateThread_basic(), test_crypt_ui_wiz_import(), test_dbcs_wm_char(), test_dde_default_app(), test_default_ime_disabled_cb(), Test_DesktopAccess(), test_destroy_quit(), test_EnumDisplayMonitors(), test_foregroundwindow(), test_fragmentsize(), test_get_next_thread(), test_get_security(), test_handles(), test_hook_changing_window_proc(), test_hook_cleanup(), test_hook_cleanup_hook_proc(), test_hook_cleanup_thread_proc(), test_IInitializeSpy(), test_inputdesktop(), test_inputdesktop2(), test_invisible_winstation_child(), test_IsDialogMessage(), test_keyboard_input(), test_message_conversion(), test_MessageBox(), test_notification_cb(), test_notify_message(), test_ole_initialization(), Test_OpenInputDesktop(), test_peb_teb(), test_PeekMessage(), test_process(), test_process_security_child(), test_query_object(), test_query_process(), test_quit_message(), test_recursion(), test_recursion_callback(), test_recursive_hook(), Test_References(), test_RtlLeaveCriticalSection(), test_RtlQueryProcessDebugInformation(), test_RtlRegisterWait(), test_SendInput_mouse_messages(), test_set_hook(), test_SetCursor(), Test_SetCursorPos(), test_SetFocus(), test_ShowCursor(), test_thread_description(), test_thread_info(), test_thread_lookup(), test_thread_priority(), test_tid_alert(), test_tp_group_cancel(), test_uia_node_from_prov_com_threading(), test_UiaAddEvent(), test_UiaNodeFromHandle(), test_window_security(), test_winmodule(), test_wiznavigation(), test_zero_access(), TestGetUserObjectInfoA(), TestGetUserObjectInfoW(), thread(), thread_proc(), threadFunc1(), ThreadShutdownNotify(), throw(), TIME_TriggerCallBack(), tp_object_execute(), TpCallbackMayRunLong(), TpDisassociateCallback(), MxLockNoDynam::TryToAcquire(), uia_add_event_test_thread(), uia_com_event_handler_test_thread(), uia_get_provider_from_hwnd(), uia_node_from_handle_test_thread(), uia_node_from_provider_test_com_thread(), UnregisterConsoleIME(), VBScript_AddNamedItem(), VBScript_Close(), VBScript_GetScriptDispatch(), VBScript_GetScriptState(), VBScript_SetScriptSite(), VBScript_SetScriptState(), VBScriptParse_ParseScriptText(), VBScriptParseProcedure_ParseProcedureText(), wave_out_test_deviceOut(), WDML_GetConv(), WDML_GetInstance(), WDML_Initialize(), WDML_NotifyThreadDetach(), WDML_ServerNameProc(), WDML_SetAllLastError(), wglDeleteContext(), wglMakeCurrent(), win_event_global_hook_proc(), WindowThreadProc(), wined3d_cs_mt_finish(), wined3d_cs_mt_require_space(), wined3d_cs_mt_submit(), wined3d_cs_run(), wined3d_from_cs(), wined3d_not_from_cs(), wined3d_resource_wait_idle(), WndProc(), wWinMain(), xmlGetThreadId(), xmlInitGlobalsInternal(), and xmlIsMainThreadInternal().

GetExitCodeThread()

BOOL WINAPI GetExitCodeThread	(	IN HANDLE	hThread,
		OUT LPDWORD	lpExitCode
	)

Definition at line 541 of file thread.c.

{
    THREAD_BASIC_INFORMATION ThreadBasic;
    NTSTATUS Status;
 
    Status = NtQueryInformationThread(hThread,
                                      ThreadBasicInformation,
                                      &ThreadBasic,
                                      sizeof(THREAD_BASIC_INFORMATION),
                                      NULL);
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return FALSE;
    }
 
    *lpExitCode = ThreadBasic.ExitStatus;
    return TRUE;
}

Referenced by child_process(), custom_client_thread(), custom_get_thread_return(), dll_entry_point(), DosStartProcess32(), EndLocalThread(), ExitWindowsWorker(), FinishNotificationThread(), init(), MIDI_mciPlay(), NotifyTopLevelWindow(), pattern_fork(), ProcessDlgProc(), RunLogoffShutdownThread(), test_CreateRemoteThread(), test_CreateThread_basic(), test_ExitProcess(), test_ffcnMultipleThreads(), test_GetThreadExitCode(), test_main_thread(), test_MultiThreadApartment(), test_registered_object_thread_affinity(), test_SetCursor(), test_ShowCursor(), test_SuspendFlag(), test_SuspendThread(), test_TerminateThread(), test_thread_priority(), and TestRecursiveInterThreadMessages().

GetProcessIdOfThread()

DWORD WINAPI GetProcessIdOfThread

(

IN HANDLE

Thread

)

Definition at line 947 of file thread.c.

{
    THREAD_BASIC_INFORMATION ThreadBasic;
    NTSTATUS Status;
 
    Status = NtQueryInformationThread(Thread,
                                      ThreadBasicInformation,
                                      &ThreadBasic,
                                      sizeof(THREAD_BASIC_INFORMATION),
                                      NULL);
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return 0;
    }
 
    return HandleToUlong(ThreadBasic.ClientId.UniqueProcess);
}

GetTeb()

PTEB GetTeb

(

VOID

)

Definition at line 438 of file thread.c.

{
    return NtCurrentTeb();
}

GetThreadContext()

BOOL WINAPI GetThreadContext	(	IN HANDLE	hThread,
		OUT LPCONTEXT	lpContext
	)

Definition at line 501 of file thread.c.

{
    NTSTATUS Status;
 
    Status = NtGetContextThread(hThread, lpContext);
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return FALSE;
    }
 
    return TRUE;
}

Referenced by DECLARE_INTERFACE_(), fetch_thread_context_(), fetch_thread_info(), main(), START_TEST(), test_ExitProcess(), test_selectors(), test_thread_info(), TestThreadProc(), and ThreadData::Update().

GetThreadGroupAffinity()

BOOL WINAPI GetThreadGroupAffinity	(	IN HANDLE	hThread,
		OUT PGROUP_AFFINITY	GroupAffinity
	)

Definition at line 702 of file thread.c.

{
    NTSTATUS Status;
    THREAD_BASIC_INFORMATION ThreadBasic;
 
    STUB; // FIXME: Real group support
    Status = NtQueryInformationThread(hThread,
                                      ThreadBasicInformation,
                                      &ThreadBasic,
                                      sizeof(ThreadBasic),
                                      NULL);
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return FALSE;
    }
    ZeroMemory(GroupAffinity, sizeof(*GroupAffinity)); // For Reserved
    GroupAffinity->Mask = ThreadBasic.AffinityMask;
    GroupAffinity->Group = THEONLYGROUP;
    return TRUE;
}

Referenced by init_funcs(), and SetThreadGroupAffinity().

GetThreadId()

DWORD WINAPI GetThreadId

(

IN HANDLE

Thread

)

Definition at line 971 of file thread.c.

{
    THREAD_BASIC_INFORMATION ThreadBasic;
    NTSTATUS Status;
 
    Status = NtQueryInformationThread(Thread,
                                      ThreadBasicInformation,
                                      &ThreadBasic,
                                      sizeof(THREAD_BASIC_INFORMATION),
                                      NULL);
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return 0;
    }
 
    return HandleToUlong(ThreadBasic.ClientId.UniqueThread);
}

Referenced by RpcCancelThreadEx(), RpcMgmtWaitServerListen(), and test_get_next_thread().

GetThreadIOPendingFlag()

BOOL WINAPI GetThreadIOPendingFlag	(	IN HANDLE	hThread,
		OUT PBOOL	lpIOIsPending
	)

Definition at line 1105 of file thread.c.

{
    ULONG IoPending;
    NTSTATUS Status;
 
    /* Query the flag */
    Status = NtQueryInformationThread(hThread,
                                      ThreadIsIoPending,
                                      &IoPending,
                                      sizeof(IoPending),
                                      NULL);
    if (NT_SUCCESS(Status))
    {
        /* Return the flag */
        *lpIOIsPending = IoPending ? TRUE : FALSE;
        return TRUE;
    }
 
    /* Fail */
    BaseSetLastNTError(Status);
    return FALSE;
}

GetThreadPriority()

int WINAPI GetThreadPriority

(

IN HANDLE

hThread

)

Definition at line 797 of file thread.c.

{
    THREAD_BASIC_INFORMATION ThreadBasic;
    NTSTATUS Status;
 
    /* Query the Base Priority Increment */
    Status = NtQueryInformationThread(hThread,
                                      ThreadBasicInformation,
                                      &ThreadBasic,
                                      sizeof(THREAD_BASIC_INFORMATION),
                                      NULL);
    if (!NT_SUCCESS(Status))
    {
        /* Failure */
        BaseSetLastNTError(Status);
        return THREAD_PRIORITY_ERROR_RETURN;
    }
 
    /* Do some conversions for saturation values */
    if (ThreadBasic.BasePriority == ((HIGH_PRIORITY + 1) / 2))
    {
        /* Win32 calls this "time critical" */
        ThreadBasic.BasePriority = THREAD_PRIORITY_TIME_CRITICAL;
    }
    else if (ThreadBasic.BasePriority == -((HIGH_PRIORITY + 1) / 2))
    {
        /* Win32 calls this "idle" */
        ThreadBasic.BasePriority = THREAD_PRIORITY_IDLE;
    }
 
    /* Return the final result */
    return ThreadBasic.BasePriority;
}

Referenced by priorityTimeProc(), SlideWindow(), and test_thread_priority().

GetThreadPriorityBoost()

BOOL WINAPI GetThreadPriorityBoost	(	IN HANDLE	hThread,
		OUT PBOOL	pDisablePriorityBoost
	)

Definition at line 836 of file thread.c.

{
    ULONG PriorityBoost;
    NTSTATUS Status;
 
    Status = NtQueryInformationThread(hThread,
                                      ThreadPriorityBoost,
                                      &PriorityBoost,
                                      sizeof(ULONG),
                                      NULL);
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return FALSE;
    }
 
    *pDisablePriorityBoost = PriorityBoost;
    return TRUE;
}

Referenced by init_funcs().

GetThreadSelectorEntry()

BOOL WINAPI GetThreadSelectorEntry	(	IN HANDLE	hThread,
		IN DWORD	dwSelector,
		OUT LPLDT_ENTRY	lpSelectorEntry
	)

Definition at line 888 of file thread.c.

{
#ifdef _M_IX86
    DESCRIPTOR_TABLE_ENTRY DescriptionTableEntry;
    NTSTATUS Status;
 
    /* Set the selector and do the query */
    DescriptionTableEntry.Selector = dwSelector;
    Status = NtQueryInformationThread(hThread,
                                      ThreadDescriptorTableEntry,
                                      &DescriptionTableEntry,
                                      sizeof(DESCRIPTOR_TABLE_ENTRY),
                                      NULL);
    if (!NT_SUCCESS(Status))
    {
        /* Fail */
        BaseSetLastNTError(Status);
        return FALSE;
    }
 
    /* Success, return the selector */
    *lpSelectorEntry = DescriptionTableEntry.Descriptor;
    return TRUE;
#else
    DPRINT1("Calling GetThreadSelectorEntry!\n");
    return FALSE;
#endif
}

Referenced by addr_to_linear(), and i386_stack_walk().

GetThreadTimes()

BOOL NTAPI GetThreadTimes	(	IN HANDLE	hThread,
		OUT LPFILETIME	lpCreationTime,
		OUT LPFILETIME	lpExitTime,
		OUT LPFILETIME	lpKernelTime,
		OUT LPFILETIME	lpUserTime
	)

Definition at line 469 of file thread.c.

{
    KERNEL_USER_TIMES KernelUserTimes;
    NTSTATUS Status;
 
    Status = NtQueryInformationThread(hThread,
                                      ThreadTimes,
                                      &KernelUserTimes,
                                      sizeof(KERNEL_USER_TIMES),
                                      NULL);
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return FALSE;
    }
 
    *lpCreationTime = *(LPFILETIME)&KernelUserTimes.CreateTime;
    *lpExitTime = *(LPFILETIME)&KernelUserTimes.ExitTime;
    *lpKernelTime = *(LPFILETIME)&KernelUserTimes.KernelTime;
    *lpUserTime = *(LPFILETIME)&KernelUserTimes.UserTime;
    return TRUE;
}

Referenced by test_GetThreadTimes().

OpenThread()

HANDLE WINAPI OpenThread	(	IN DWORD	dwDesiredAccess,
		IN BOOL	bInheritHandle,
		IN DWORD	dwThreadId
	)

Definition at line 403 of file thread.c.

{
    NTSTATUS Status;
    HANDLE ThreadHandle;
    OBJECT_ATTRIBUTES ObjectAttributes;
    CLIENT_ID ClientId;
 
    ClientId.UniqueProcess = 0;
    ClientId.UniqueThread = ULongToHandle(dwThreadId);
 
    InitializeObjectAttributes(&ObjectAttributes,
                               NULL,
                               (bInheritHandle ? OBJ_INHERIT : 0),
                               NULL,
                               NULL);
 
    Status = NtOpenThread(&ThreadHandle,
                          dwDesiredAccess,
                          &ObjectAttributes,
                          &ClientId);
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return NULL;
    }
 
    return ThreadHandle;
}

Referenced by fetch_thread_context_(), fetch_thread_info(), GetThreadFromCurrentProcess(), init_funcs(), test_debugger(), test_process_security_child(), test_RtlRegisterWait(), test_thread_description(), and test_Toolhelp().

QueueUserAPC()

DWORD WINAPI QueueUserAPC	(	IN PAPCFUNC	pfnAPC,
		IN HANDLE	hThread,
		IN ULONG_PTR	dwData
	)

Definition at line 1017 of file thread.c.

{
    NTSTATUS Status;
    ACTIVATION_CONTEXT_BASIC_INFORMATION ActCtxInfo;
 
    /* Zero the activation context and query information on it */
    RtlZeroMemory(&ActCtxInfo, sizeof(ActCtxInfo));
    Status = RtlQueryInformationActivationContext(RTL_QUERY_ACTIVATION_CONTEXT_FLAG_USE_ACTIVE_ACTIVATION_CONTEXT,
                                                  NULL,
                                                  0,
                                                  ActivationContextBasicInformation,
                                                  &ActCtxInfo,
                                                  sizeof(ActCtxInfo),
                                                  NULL);
    if (!NT_SUCCESS(Status))
    {
        /* Fail due to SxS */
        DbgPrint("SXS: %s failing because RtlQueryInformationActivationContext()"
                 "returned status %08lx\n", __FUNCTION__, Status);
        BaseSetLastNTError(Status);
        return FALSE;
    }
 
    /* Queue the APC */
    Status = NtQueueApcThread(hThread,
                              (PKNORMAL_ROUTINE)BaseDispatchApc,
                              pfnAPC,
                              (PVOID)dwData,
                              (ActCtxInfo.dwFlags & 1) ?
                              INVALID_ACTIVATION_CONTEXT : ActCtxInfo.hActCtx);
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return FALSE;
    }
 
    /* All good */
    return TRUE;
}

Referenced by async_notifier_proc(), JustDoIt(), process_work_items(), CDirectoryWatcher::RequestAddWatcher(), CDirectoryWatcher::RequestAllWatchersTermination(), CDirectoryWatcher::RequestTermination(), serverThreadMain2(), SEALED_::TerminateProtocolThread(), test_alertable_wait(), test_CoWaitForMultipleHandles(), test_CreatePipe(), test_GetOverlappedResultEx(), test_MsgWaitForMultipleObjects(), test_post_completion(), test_QueueUserAPC(), test_read_write(), test_RtlRegisterWait(), test_set_io_completion(), TestMultipleUserAPCs(), WahCloseHandleHelper(), and WahQueueUserApc().

QueueUserWorkItem()

BOOL WINAPI QueueUserWorkItem	(	IN LPTHREAD_START_ROUTINE	Function,
		IN PVOID	Context,
		IN ULONG	Flags
	)

Definition at line 1134 of file thread.c.

{
    NTSTATUS Status;
 
    /* NOTE: Rtl needs to safely call the function using a trampoline */
    Status = RtlQueueWorkItem((WORKERCALLBACKFUNC)Function, Context, Flags);
    if (!NT_SUCCESS(Status))
    {
        /* Failed */
        BaseSetLastNTError(Status);
        return FALSE;
    }
 
    /* All good */
    return TRUE;
}

Referenced by ClientRpcChannelBuffer_SendReceive(), handle_full_cache(), I_RpcSend(), init_funcs(), INTERNET_AsyncCall(), queue_async(), RPCRT4_io_thread(), and SHQueueUserWorkItem().

ResumeThread()

DWORD WINAPI ResumeThread

(

IN HANDLE

hThread

)

Definition at line 567 of file thread.c.

{
    ULONG PreviousResumeCount;
    NTSTATUS Status;
 
    Status = NtResumeThread(hThread, &PreviousResumeCount);
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return -1;
    }
 
    return PreviousResumeCount;
}

Referenced by _beginthread(), _check_thread_suspend_count(), cmd_start(), CommandThreadProc(), cordebugprocess_Continue(), CreateProcessAsUserCommon(), CreateSoundThread(), fetch_thread_info(), IDirectPlayLobby3AImpl_RunApplication(), main(), midiStreamRestart(), Netbios(), ScmStartUserModeService(), StartStopEnumEventsThread(), test_apc_deadlock(), test_CreateRemoteThread(), test_CreateThread_suspended(), test_debugger(), test_GetThreadTimes(), test_peb_teb(), test_process_token(), test_query_process_debug_flags(), test_SuspendFlag(), test_SuspendThread(), test_thread_suspended(), test_tls_links(), test_Toolhelp(), TestMultipleUserAPCs(), TestRecursiveInterThreadMessages(), Thread1(), and WahOpenHandleHelper().

SetThreadAffinityMask()

DWORD_PTR WINAPI SetThreadAffinityMask	(	IN HANDLE	hThread,
		IN DWORD_PTR	dwThreadAffinityMask
	)

Definition at line 662 of file thread.c.

{
    THREAD_BASIC_INFORMATION ThreadBasic;
    KAFFINITY AffinityMask;
    NTSTATUS Status;
 
    AffinityMask = (KAFFINITY)dwThreadAffinityMask;
 
    Status = NtQueryInformationThread(hThread,
                                      ThreadBasicInformation,
                                      &ThreadBasic,
                                      sizeof(THREAD_BASIC_INFORMATION),
                                      NULL);
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return 0;
    }
 
    Status = NtSetInformationThread(hThread,
                                    ThreadAffinityMask,
                                    &AffinityMask,
                                    sizeof(KAFFINITY));
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        ThreadBasic.AffinityMask = 0;
    }
 
    return ThreadBasic.AffinityMask;
}

Referenced by AdjustAffinity(), SetThreadGroupAffinity(), Test_SyscallPerformance(), test_thread_processor(), and wmain().

SetThreadContext()

BOOL WINAPI SetThreadContext	(	IN HANDLE	hThread,
		IN CONST CONTEXT *	lpContext
	)

Definition at line 521 of file thread.c.

{
    NTSTATUS Status;
 
    Status = NtSetContextThread(hThread, (PCONTEXT)lpContext);
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return FALSE;
    }
 
    return TRUE;
}

Referenced by DECLARE_INTERFACE_(), set_thread_context_(), and test_ExitProcess().

SetThreadGroupAffinity()

BOOL WINAPI SetThreadGroupAffinity	(	IN HANDLE	hThread,
		IN const GROUP_AFFINITY *	GroupAffinity,
		OUT OPTIONAL PGROUP_AFFINITY	PreviousGroupAffinity
	)

Definition at line 730 of file thread.c.

{
    DWORD_PTR OldMask;
 
    STUB; // FIXME: Real group support
    if (!GroupAffinity || GroupAffinity->Group != THEONLYGROUP)
    {
        SetLastError(ERROR_INVALID_PARAMETER);
        return FALSE;
    }
 
    OldMask = SetThreadAffinityMask(hThread, GroupAffinity->Mask);
    if (OldMask && PreviousGroupAffinity)
    {
        ZeroMemory(PreviousGroupAffinity, sizeof(*PreviousGroupAffinity)); // For Reserved
        PreviousGroupAffinity->Mask = OldMask;
        PreviousGroupAffinity->Group = THEONLYGROUP;
    }
    return OldMask != 0;
}

Referenced by init_funcs().

SetThreadIdealProcessor()

DWORD WINAPI SetThreadIdealProcessor	(	IN HANDLE	hThread,
		IN DWORD	dwIdealProcessor
	)

Definition at line 924 of file thread.c.

{
    NTSTATUS Status;
 
    Status = NtSetInformationThread(hThread,
                                    ThreadIdealProcessor,
                                    &dwIdealProcessor,
                                    sizeof(ULONG));
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return -1;
    }
 
    return (DWORD)Status;
}

Referenced by test_thread_processor().

SetThreadPriority()

BOOL WINAPI SetThreadPriority	(	IN HANDLE	hThread,
		IN int	nPriority
	)

Definition at line 758 of file thread.c.

{
    LONG Prio = nPriority;
    NTSTATUS Status;
 
    /* Check if values forcing saturation should be used */
    if (Prio == THREAD_PRIORITY_TIME_CRITICAL)
    {
        /* This is 16 */
        Prio = (HIGH_PRIORITY + 1) / 2;
    }
    else if (Prio == THREAD_PRIORITY_IDLE)
    {
        /* This is -16 */
        Prio = -((HIGH_PRIORITY + 1) / 2);
    }
 
    /* Set the Base Priority */
    Status = NtSetInformationThread(hThread,
                                    ThreadBasePriority,
                                    &Prio,
                                    sizeof(LONG));
    if (!NT_SUCCESS(Status))
    {
        /* Failure */
        BaseSetLastNTError(Status);
        return FALSE;
    }
 
    /* Return */
    return TRUE;
}

Referenced by ConsoleControlDispatcher(), ensurePlayerThread(), ImageView_Main(), main(), MCI_SendCommandAsync(), MCIAVI_mciPlay_async(), midiStreamOpen(), mmTaskCreate(), Telnet::Open(), OutputQueue_Construct(), proc_PlaySoundAsync(), CFindFolder::SearchThreadProc(), SlideWindow(), SockAsyncThread(), SystemClockPostMessageToAdviseThread(), test_ExitProcess(), test_thread_priority(), TIME_MMTimeStart(), WaveThread(), WriterThread::WriterThread(), and wWinMain().

SetThreadPriorityBoost()

BOOL NTAPI SetThreadPriorityBoost	(	IN HANDLE	hThread,
		IN BOOL	bDisablePriorityBoost
	)

Definition at line 862 of file thread.c.

{
    ULONG PriorityBoost;
    NTSTATUS Status;
 
    PriorityBoost = bDisablePriorityBoost != FALSE;
 
    Status = NtSetInformationThread(hThread,
                                    ThreadPriorityBoost,
                                    &PriorityBoost,
                                    sizeof(ULONG));
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return FALSE;
    }
 
    return TRUE;
}

Referenced by init_funcs().

SetThreadStackGuarantee()

BOOL WINAPI SetThreadStackGuarantee

(

IN OUT PULONG

StackSizeInBytes

)

Definition at line 1064 of file thread.c.

{
    PTEB Teb = NtCurrentTeb();
    ULONG GuaranteedStackBytes;
    ULONG AllocationSize;
 
    if (!StackSizeInBytes)
    {
        SetLastError(ERROR_INVALID_PARAMETER);
        return FALSE;
    }
 
    AllocationSize = *StackSizeInBytes;
 
    /* Retrieve the current stack size */
    GuaranteedStackBytes = Teb->GuaranteedStackBytes;
 
    /* Return the size of the previous stack */
    *StackSizeInBytes = GuaranteedStackBytes;
 
    /*
     * If the new stack size is either zero or is less than the current size,
     * the previous stack size is returned and we return success.
     */
    if ((AllocationSize == 0) || (AllocationSize < GuaranteedStackBytes))
    {
        return TRUE;
    }
 
    // FIXME: Unimplemented!
    UNIMPLEMENTED_ONCE;
 
    // Temporary HACK for supporting applications!
    return TRUE; // FALSE;
}

Referenced by init_funcs().

SetThreadUILanguage()

LANGID WINAPI SetThreadUILanguage

(

IN LANGID

LangId

)

Definition at line 995 of file thread.c.

{
#if (NTDDI_VERSION < NTDDI_LONGHORN)
    /* We only support LangId == 0, for selecting a language
     * identifier that best supports the NT Console. */
    if (LangId != 0)
    {
        BaseSetLastNTError(STATUS_NOT_SUPPORTED);
        return 0;
    }
#endif
 
    UNIMPLEMENTED;
 
    return LANGIDFROMLCID(NtCurrentTeb()->CurrentLocale);
}

Referenced by SetLocale().

SuspendThread()

DWORD WINAPI SuspendThread

(

IN HANDLE

hThread

)

Definition at line 642 of file thread.c.

{
    ULONG PreviousSuspendCount;
    NTSTATUS Status;
 
    Status = NtSuspendThread(hThread, &PreviousSuspendCount);
    if (!NT_SUCCESS(Status))
    {
        BaseSetLastNTError(Status);
        return -1;
    }
 
    return PreviousSuspendCount;
}

Referenced by _check_thread_suspend_count(), fetch_thread_info(), main(), midiStreamPause(), MMSYSTEM_MidiStream_Player(), test_apc_deadlock(), test_CreateRemoteThread(), test_CreateThread_suspended(), test_debugger(), test_query_process_debug_flags(), test_SuspendThread(), and threadFunc3().

SwitchToThread()

BOOL WINAPI SwitchToThread

(

VOID

)

Definition at line 448 of file thread.c.

{
    return NtYieldExecution() != STATUS_NO_YIELD_PERFORMED;
}

TerminateThread()

BOOL WINAPI TerminateThread	(	IN HANDLE	hThread,
		IN DWORD	dwExitCode
	)

Definition at line 587 of file thread.c.

{
    NTSTATUS Status;
#if DBG
    PRTL_CRITICAL_SECTION LoaderLock;
    THREAD_BASIC_INFORMATION ThreadInfo;
#endif /* DBG */
 
    /* Check for invalid thread handle */
    if (!hThread)
    {
        /* Fail if one was passed */
        SetLastError(ERROR_INVALID_HANDLE);
        return FALSE;
    }
 
#if DBG
    /* Get the loader lock */
    LoaderLock = NtCurrentPeb()->LoaderLock;
    if (LoaderLock)
    {
        /* Get our TID */
        Status = NtQueryInformationThread(hThread,
                                          ThreadBasicInformation,
                                          &ThreadInfo,
                                          sizeof(ThreadInfo),
                                          NULL);
        if (NT_SUCCESS(Status))
        {
            /* If terminating the current thread, we must not hold the loader lock */
            if (NtCurrentTeb()->ClientId.UniqueThread == ThreadInfo.ClientId.UniqueThread)
                ASSERT(NtCurrentTeb()->ClientId.UniqueThread != LoaderLock->OwningThread);
        }
    }
#endif /* DBG */
 
    /* Now terminate the thread */
    Status = NtTerminateThread(hThread, dwExitCode);
    if (!NT_SUCCESS(Status))
    {
        /* Fail */
        BaseSetLastNTError(Status);
        return FALSE;
    }
 
    /* All done */
    return TRUE;
}

Referenced by do_test(), DP_DestroyDirectPlay2(), main(), nfs41_session_free(), NotifyTopLevelWindow(), NotifyUserProcessForShutdown(), RunTest(), BtrfsSend::SendDlgProc(), start_fiber(), test_bsc_marshaling(), test_CreateThread_basic(), test_CreateThread_suspended(), test_ExitProcess(), test_kill_on_exit(), test_QueueUserAPC(), test_runner(), Test_SimpleParameters(), test_SuspendThread(), test_TerminateProcess(), test_TerminateThread(), test_thread_security(), ThreadShutdownNotify(), WndProc(), and CHardErrorThread::~CHardErrorThread().

TlsAlloc()

DWORD WINAPI TlsAlloc

(

VOID

)

Definition at line 1158 of file thread.c.

{
    ULONG Index;
    PTEB Teb;
    PPEB Peb;
 
    /* Get the PEB and TEB, lock the PEB */
    Teb = NtCurrentTeb();
    Peb = Teb->ProcessEnvironmentBlock;
    RtlAcquirePebLock();
 
    /* Try to get regular TEB slot */
    Index = RtlFindClearBitsAndSet(Peb->TlsBitmap, 1, 0);
    if (Index != 0xFFFFFFFF)
    {
        /* Clear the value. */
        Teb->TlsSlots[Index] = 0;
        RtlReleasePebLock();
        return Index;
    }
 
    /* If it fails, try to find expansion TEB slot. */
    Index = RtlFindClearBitsAndSet(Peb->TlsExpansionBitmap, 1, 0);
    if (Index != 0xFFFFFFFF)
    {
        /* Is there no expansion slot yet? */
        if (!Teb->TlsExpansionSlots)
        {
            /* Allocate an array */
            Teb->TlsExpansionSlots = RtlAllocateHeap(RtlGetProcessHeap(),
                                                     HEAP_ZERO_MEMORY,
                                                     TLS_EXPANSION_SLOTS *
                                                     sizeof(PVOID));
        }
 
        /* Did we get an array? */
        if (!Teb->TlsExpansionSlots)
        {
            /* Fail */
            RtlClearBits(Peb->TlsExpansionBitmap, Index, 1);
            Index = 0xFFFFFFFF;
            BaseSetLastNTError(STATUS_NO_MEMORY);
        }
        else
        {
            /* Clear the value. */
            Teb->TlsExpansionSlots[Index] = 0;
            Index += TLS_MINIMUM_AVAILABLE;
        }
    }
    else
    {
        /* Fail */
        BaseSetLastNTError(STATUS_NO_MEMORY);
    }
 
    /* Release the lock and return */
    RtlReleasePebLock();
    return Index;
}

TlsFree()

BOOL WINAPI TlsFree

(

IN DWORD

Index

)

Definition at line 1224 of file thread.c.

{
    BOOL BitSet;
    PPEB Peb;
    ULONG TlsIndex;
    PVOID TlsBitmap;
    NTSTATUS Status;
 
    /* Acquire the PEB lock and grab the PEB */
    Peb = NtCurrentPeb();
    RtlAcquirePebLock();
 
    /* Check if the index is too high */
    if (Index >= TLS_MINIMUM_AVAILABLE)
    {
        /* Check if it can fit in the expansion slots */
        TlsIndex = Index - TLS_MINIMUM_AVAILABLE;
        if (TlsIndex >= TLS_EXPANSION_SLOTS)
        {
            /* It's invalid */
            BaseSetLastNTError(STATUS_INVALID_PARAMETER);
            RtlReleasePebLock();
            return FALSE;
        }
        else
        {
            /* Use the expansion bitmap */
            TlsBitmap = Peb->TlsExpansionBitmap;
            Index = TlsIndex;
        }
    }
    else
    {
        /* Use the normal bitmap */
        TlsBitmap = Peb->TlsBitmap;
    }
 
    /* Check if the index was set */
    BitSet = RtlAreBitsSet(TlsBitmap, Index, 1);
    if (BitSet)
    {
        /* Tell the kernel to free the TLS cells */
        Status = NtSetInformationThread(NtCurrentThread(),
                                        ThreadZeroTlsCell,
                                        &Index,
                                        sizeof(DWORD));
        if (!NT_SUCCESS(Status))
        {
            BaseSetLastNTError(STATUS_INVALID_PARAMETER);
            RtlReleasePebLock();
            return FALSE;
        }
 
        /* Clear the bit */
        RtlClearBits(TlsBitmap, Index, 1);
    }
    else
    {
        /* Fail */
        BaseSetLastNTError(STATUS_INVALID_PARAMETER);
        RtlReleasePebLock();
        return FALSE;
    }
 
    /* Done! */
    RtlReleasePebLock();
    return TRUE;
}

Referenced by __acrt_FlsFree(), Cleanup(), ClientThreadSetupHelper(), DllMain(), Exit(), free_tls_list(), get_thread_data(), get_tls_data(), I_CryptFreeTls(), msvcrt_free_tls(), process_detach(), ProcessDetach(), spy_init(), test_CreateThread_basic(), test_reserved_tls(), test_TLS(), TLS::Uninitialize(), UXTHEME_UnInitSystem(), wined3d_dll_destroy(), wined3d_dll_init(), and xmlCleanupGlobalsInternal().

TlsGetValue()

LPVOID WINAPI TlsGetValue

(

IN DWORD

Index

)

Definition at line 1298 of file thread.c.

{
    PTEB Teb;
 
    /* Get the TEB and clear the last error */
    Teb = NtCurrentTeb();
    Teb->LastErrorValue = 0;
 
    /* Check for simple TLS index */
    if (Index < TLS_MINIMUM_AVAILABLE)
    {
        /* Return it */
        return Teb->TlsSlots[Index];
    }
 
    /* Check for valid index */
    if (Index >= TLS_EXPANSION_SLOTS + TLS_MINIMUM_AVAILABLE)
    {
        /* Fail */
        BaseSetLastNTError(STATUS_INVALID_PARAMETER);
        return NULL;
    }
 
    /* The expansion slots are allocated on demand, so check for it. */
    Teb->LastErrorValue = 0;
    if (!Teb->TlsExpansionSlots) return NULL;
 
    /* Return the value from the expansion slots */
    return Teb->TlsExpansionSlots[Index - TLS_MINIMUM_AVAILABLE];
}

Referenced by __acrt_FlsGetValue(), __mingwthr_run_key_dtors(), _endthread(), _endthreadex(), add_active_textservice(), client_stop(), CommDlgExtendedError(), context_get_current(), CThreadMgr::CreateInstance(), detach_thread(), DllMain(), event_client(), get_indent_level(), get_thread_data(), get_tls_data(), CMenuFocusManager::GetManager(), I_CryptDetachTls(), I_CryptGetTls(), Imm32AllocateTLS(), Imm32GetTLS(), INTERNET_GetLastError(), INTERNET_GetResponseBuffer(), INTERNET_SetLastError(), INTERNET_WorkerThreadFunc(), InternetGetLastResponseInfoA(), InternetGetLastResponseInfoW(), mono_print_handler_fn(), msvcrt_free_tls_mem(), msvcrt_get_thread_data(), oob_client(), oob_server(), TLS::PeekTLS(), select_server(), server_stop(), SHGetThreadRef(), simple_client(), simple_mixed_client(), simple_server(), test_errno(), test_reserved_tls(), test_TLS(), TF_GetThreadMgr(), CThreadMgr::ThreadFocusHookProc(), threadFunc1(), UXTHEME_GetParseErrorInfo(), VirtualChannelInit(), WsSockInitialize(), WsThreadBlockingCallback(), WsThreadDestroyCurrentThread(), WsThreadGetCurrentThread(), and WsThreadGetThreadId().

TlsSetValue()

BOOL WINAPI TlsSetValue	(	IN DWORD	Index,
		IN LPVOID	Value
	)

Definition at line 1334 of file thread.c.

{
    DWORD TlsIndex;
    PTEB Teb = NtCurrentTeb();
 
    /* Check for simple TLS index */
    if (Index < TLS_MINIMUM_AVAILABLE)
    {
        /* Return it */
        Teb->TlsSlots[Index] = Value;
        return TRUE;
    }
 
    /* Check if this is an expansion slot */
    TlsIndex = Index - TLS_MINIMUM_AVAILABLE;
    if (TlsIndex >= TLS_EXPANSION_SLOTS)
    {
        /* Fail */
        BaseSetLastNTError(STATUS_INVALID_PARAMETER);
        return FALSE;
    }
 
    /* Do we not have expansion slots? */
    if (!Teb->TlsExpansionSlots)
    {
        /* Get the PEB lock to see if we still need them */
        RtlAcquirePebLock();
        if (!Teb->TlsExpansionSlots)
        {
            /* Allocate them */
            Teb->TlsExpansionSlots = RtlAllocateHeap(RtlGetProcessHeap(),
                                                     HEAP_ZERO_MEMORY,
                                                     TLS_EXPANSION_SLOTS *
                                                     sizeof(PVOID));
            if (!Teb->TlsExpansionSlots)
            {
                /* Fail */
                RtlReleasePebLock();
                BaseSetLastNTError(STATUS_NO_MEMORY);
                return FALSE;
            }
        }
 
        /* Release the lock */
        RtlReleasePebLock();
    }
 
    /* Write the value */
    Teb->TlsExpansionSlots[TlsIndex] = Value;
 
    /* Success */
    return TRUE;
}

Referenced by __acrt_FlsSetValue(), CMenuFocusManager::AcquireManager(), client_start(), COMDLG32_SetCommDlgExtendedError(), context_destroy(), context_set_current(), CThreadMgr::CreateInstance(), DllMain(), get_thread_data(), get_tls_data(), I_CryptDetachTls(), I_CryptSetTls(), Imm32AllocateTLS(), TLS::InternalAllocateTLS(), TLS::InternalDestroyTLS(), INTERNET_AllocThreadError(), INTERNET_WorkerThreadFunc(), mono_print_handler_fn(), msvcrt_get_thread_data(), release_thread_data(), CMenuFocusManager::ReleaseManager(), server_start(), set_indent_level(), SHSetThreadRef(), test_reserved_tls(), test_TLS(), threadFunc1(), UXTHEME_DeleteParseErrorInfo(), UXTHEME_GetParseErrorInfo(), WsThreadCreate(), WsThreadDelete(), WsThreadDestroyCurrentThread(), and CThreadMgr::~CThreadMgr().