/* $Id: sched-win32.cpp 2981 2007-06-01 16:01:28Z vboxsync $ */ /** @file * innotek Portable Runtime - Scheduling, Win32. */ /* * Copyright (C) 2006-2007 innotek GmbH * * This file is part of VirtualBox Open Source Edition (OSE), as * available from http://www.virtualbox.org. This file is free software; * you can redistribute it and/or modify it under the terms of the GNU * General Public License as published by the Free Software Foundation, * in version 2 as it comes in the "COPYING" file of the VirtualBox OSE * distribution. VirtualBox OSE is distributed in the hope that it will * be useful, but WITHOUT ANY WARRANTY of any kind. * * If you received this file as part of a commercial VirtualBox * distribution, then only the terms of your commercial VirtualBox * license agreement apply instead of the previous paragraph. */ /** @def WIN32_SCHED_ENABLED * Enables the priority scheme. */ #define WIN32_SCHED_ENABLED /******************************************************************************* * Header Files * *******************************************************************************/ #define LOG_GROUP RTLOGGROUP_THREAD #include #include #include #include #include #include "internal/sched.h" #include "internal/thread.h" /******************************************************************************* * Structures and Typedefs * *******************************************************************************/ /** * Configuration of one priority. */ typedef struct { /** The priority. */ RTPROCPRIORITY enmPriority; /** The name of this priority. */ const char *pszName; /** The Win32 process priority class. If ANY_PROCESS_PRIORITY_CLASS the * process priority class is left unchanged. */ DWORD dwProcessPriorityClass; /** Array scheduler attributes corresponding to each of the thread types. */ struct { /** For sanity include the array index. */ RTTHREADTYPE enmType; /** The Win32 thread priority. */ DWORD dwThreadPriority; } aTypes[RTTHREADTYPE_END]; } PROCPRIORITY; /** Matches any process priority class. */ #define ANY_PROCESS_PRIORITY_CLASS (~0U) /******************************************************************************* * Global Variables * *******************************************************************************/ /** * Array of static priority configurations. */ static const PROCPRIORITY g_aPriorities[] = { { RTPROCPRIORITY_FLAT, "Flat", ANY_PROCESS_PRIORITY_CLASS, { { RTTHREADTYPE_INVALID, ~0 }, { RTTHREADTYPE_INFREQUENT_POLLER, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_MAIN_HEAVY_WORKER, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_EMULATION, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_DEFAULT, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_GUI, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_MAIN_WORKER, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_VRDP_IO, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_DEBUGGER, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_MSG_PUMP, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_IO, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_TIMER, THREAD_PRIORITY_NORMAL } } }, { RTPROCPRIORITY_LOW, "Low - Below Normal", BELOW_NORMAL_PRIORITY_CLASS, { { RTTHREADTYPE_INVALID, ~0 }, { RTTHREADTYPE_INFREQUENT_POLLER, THREAD_PRIORITY_LOWEST }, { RTTHREADTYPE_MAIN_HEAVY_WORKER, THREAD_PRIORITY_BELOW_NORMAL }, { RTTHREADTYPE_EMULATION, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_DEFAULT, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_GUI, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_MAIN_WORKER, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_VRDP_IO, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_DEBUGGER, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_MSG_PUMP, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_IO, THREAD_PRIORITY_HIGHEST }, { RTTHREADTYPE_TIMER, THREAD_PRIORITY_HIGHEST } } }, { RTPROCPRIORITY_LOW, "Low", ANY_PROCESS_PRIORITY_CLASS, { { RTTHREADTYPE_INVALID, ~0 }, { RTTHREADTYPE_INFREQUENT_POLLER, THREAD_PRIORITY_LOWEST }, { RTTHREADTYPE_MAIN_HEAVY_WORKER, THREAD_PRIORITY_LOWEST }, { RTTHREADTYPE_EMULATION, THREAD_PRIORITY_LOWEST }, { RTTHREADTYPE_DEFAULT, THREAD_PRIORITY_BELOW_NORMAL }, { RTTHREADTYPE_GUI, THREAD_PRIORITY_BELOW_NORMAL }, { RTTHREADTYPE_MAIN_WORKER, THREAD_PRIORITY_BELOW_NORMAL }, { RTTHREADTYPE_VRDP_IO, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_DEBUGGER, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_MSG_PUMP, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_IO, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_TIMER, THREAD_PRIORITY_NORMAL } } }, { RTPROCPRIORITY_NORMAL, "Normal - Normal", NORMAL_PRIORITY_CLASS, { { RTTHREADTYPE_INVALID, ~0 }, { RTTHREADTYPE_INFREQUENT_POLLER, THREAD_PRIORITY_LOWEST }, { RTTHREADTYPE_MAIN_HEAVY_WORKER, THREAD_PRIORITY_LOWEST }, { RTTHREADTYPE_EMULATION, THREAD_PRIORITY_BELOW_NORMAL }, { RTTHREADTYPE_DEFAULT, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_GUI, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_MAIN_WORKER, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_VRDP_IO, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_DEBUGGER, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_MSG_PUMP, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_IO, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_TIMER, THREAD_PRIORITY_HIGHEST } } }, { RTPROCPRIORITY_NORMAL, "Normal", ANY_PROCESS_PRIORITY_CLASS, { { RTTHREADTYPE_INVALID, ~0 }, { RTTHREADTYPE_INFREQUENT_POLLER, THREAD_PRIORITY_LOWEST }, { RTTHREADTYPE_MAIN_HEAVY_WORKER, THREAD_PRIORITY_LOWEST }, { RTTHREADTYPE_EMULATION, THREAD_PRIORITY_BELOW_NORMAL }, { RTTHREADTYPE_DEFAULT, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_GUI, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_MAIN_WORKER, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_VRDP_IO, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_DEBUGGER, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_MSG_PUMP, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_IO, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_TIMER, THREAD_PRIORITY_HIGHEST } } }, { RTPROCPRIORITY_HIGH, "High - High", HIGH_PRIORITY_CLASS, { { RTTHREADTYPE_INVALID, ~0 }, { RTTHREADTYPE_INFREQUENT_POLLER, THREAD_PRIORITY_LOWEST }, { RTTHREADTYPE_MAIN_HEAVY_WORKER, THREAD_PRIORITY_LOWEST }, { RTTHREADTYPE_EMULATION, THREAD_PRIORITY_BELOW_NORMAL }, { RTTHREADTYPE_DEFAULT, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_GUI, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_MAIN_WORKER, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_VRDP_IO, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_DEBUGGER, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_MSG_PUMP, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_IO, THREAD_PRIORITY_HIGHEST }, { RTTHREADTYPE_TIMER, THREAD_PRIORITY_HIGHEST } } }, { RTPROCPRIORITY_HIGH, "High - Above Normal", ABOVE_NORMAL_PRIORITY_CLASS, { { RTTHREADTYPE_INVALID, ~0 }, { RTTHREADTYPE_INFREQUENT_POLLER, THREAD_PRIORITY_LOWEST }, { RTTHREADTYPE_MAIN_HEAVY_WORKER, THREAD_PRIORITY_LOWEST }, { RTTHREADTYPE_EMULATION, THREAD_PRIORITY_BELOW_NORMAL }, { RTTHREADTYPE_DEFAULT, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_GUI, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_MAIN_WORKER, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_VRDP_IO, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_DEBUGGER, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_MSG_PUMP, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_IO, THREAD_PRIORITY_HIGHEST }, { RTTHREADTYPE_TIMER, THREAD_PRIORITY_HIGHEST } } }, { RTPROCPRIORITY_HIGH, "High", ANY_PROCESS_PRIORITY_CLASS, { { RTTHREADTYPE_INVALID, ~0 }, { RTTHREADTYPE_INFREQUENT_POLLER, THREAD_PRIORITY_BELOW_NORMAL }, { RTTHREADTYPE_MAIN_HEAVY_WORKER, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_EMULATION, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_DEFAULT, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_GUI, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_MAIN_WORKER, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_VRDP_IO, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_DEBUGGER, THREAD_PRIORITY_HIGHEST }, { RTTHREADTYPE_MSG_PUMP, THREAD_PRIORITY_HIGHEST }, { RTTHREADTYPE_IO, THREAD_PRIORITY_HIGHEST }, { RTTHREADTYPE_TIMER, THREAD_PRIORITY_HIGHEST } } } }; /** * The dynamic default priority configuration. * * This can be recalulated at runtime depending on what the * system allow us to do. Presently we don't do this as it's * generally not a bit issue on Win32 hosts. */ static PROCPRIORITY g_aDefaultPriority = { RTPROCPRIORITY_LOW, "Default", ANY_PROCESS_PRIORITY_CLASS, { { RTTHREADTYPE_INVALID, ~0 }, { RTTHREADTYPE_INFREQUENT_POLLER, THREAD_PRIORITY_LOWEST }, { RTTHREADTYPE_MAIN_HEAVY_WORKER, THREAD_PRIORITY_BELOW_NORMAL }, { RTTHREADTYPE_EMULATION, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_DEFAULT, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_GUI, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_MAIN_WORKER, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_VRDP_IO, THREAD_PRIORITY_NORMAL }, { RTTHREADTYPE_DEBUGGER, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_MSG_PUMP, THREAD_PRIORITY_ABOVE_NORMAL }, { RTTHREADTYPE_IO, THREAD_PRIORITY_HIGHEST }, { RTTHREADTYPE_TIMER, THREAD_PRIORITY_HIGHEST } } }; /** Pointer to the current priority configuration. */ static const PROCPRIORITY *g_pProcessPriority = &g_aDefaultPriority; /** * Calculate the scheduling properties for all the threads in the default * process priority, assuming the current thread have the type enmType. * * @returns iprt status code. * @param enmType The thread type to be assumed for the current thread. */ int rtSchedNativeCalcDefaultPriority(RTTHREADTYPE enmType) { Assert(enmType > RTTHREADTYPE_INVALID && enmType < RTTHREADTYPE_END); return VINF_SUCCESS; } /** * Validates and sets the process priority. * This will check that all rtThreadNativeSetPriority() will success for all the * thread types when applied to the current thread. * * @returns iprt status code. * @param enmPriority The priority to validate and set. * @remark Located in sched. */ int rtProcNativeSetPriority(RTPROCPRIORITY enmPriority) { Assert(enmPriority > RTPROCPRIORITY_INVALID && enmPriority < RTPROCPRIORITY_LAST); return VINF_SUCCESS; } /** * Gets the win32 thread handle. * * @returns Valid win32 handle for the specified thread. * @param pThread The thread. */ inline HANDLE rtThreadNativeGetHandle(PRTTHREADINT pThread) { if ((uintptr_t)pThread->Core.Key == GetCurrentThreadId()) return GetCurrentThread(); return (HANDLE)pThread->hThread; } /** * Sets the priority of the thread according to the thread type * and current process priority. * * The RTTHREADINT::enmType member has not yet been updated and will be updated by * the caller on a successful return. * * @returns iprt status code. * @param pThread The thread in question. * @param enmType The thread type. * @remark Located in sched. */ int rtThreadNativeSetPriority(PRTTHREADINT pThread, RTTHREADTYPE enmType) { Assert(enmType > RTTHREADTYPE_INVALID && enmType < RTTHREADTYPE_END); AssertMsg(g_pProcessPriority && g_pProcessPriority->aTypes[enmType].enmType == enmType, ("enmType=%d entry=%d\n", enmType, g_pProcessPriority->aTypes[enmType].enmType)); #ifdef WIN32_SCHED_ENABLED if (SetThreadPriority(rtThreadNativeGetHandle(pThread), g_pProcessPriority->aTypes[enmType].dwThreadPriority)) return VINF_SUCCESS; DWORD dwLastError = GetLastError(); int rc = RTErrConvertFromWin32(dwLastError); AssertMsgFailed(("SetThreadPriority(%p, %d) failed, dwLastError=%d rc=%Vrc\n", rtThreadNativeGetHandle(pThread), g_pProcessPriority->aTypes[enmType].dwThreadPriority, dwLastError, rc)); return rc; #else return VINF_SUCCESS; #endif }