Leaked source code of windows server 2003
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 
 
 
 

576 lines
16 KiB

#include "cplusinc.h"
#include "windows.h"
#include "stdlib.h"
#include "stdio.h"
#include "coredbg.h"
#include <sddl.h>
#define DEBUGBUFLEN 1024
// don't log at all
#define COREDBG_DONT_LOG (COREDBG_DONT_LOG_TO_FILE | COREDBG_DONT_LOG_TO_DEBUGGER)
// if we fail to acquire mutex within this time, shutdown tracing
#define COREDBG_DEBUG_TIMEOUT 10000L
// globals
DWORD g_dwDebugFlags = COREDBG_DEFAULT_FLAGS;
HANDLE g_hDebugFile = INVALID_HANDLE_VALUE;
DWORD g_dwDebugFileSizeLimit = COREDBG_FILE_SIZE_LIMIT;
BOOL g_bDebugInited = FALSE;
static CHAR g_szDebugFileName[MAX_PATH] = { 0 };
static CHAR g_szModuleName[MAX_PATH] = { 0 };
static HANDLE g_hDebugFileMutex = NULL;
static BOOL g_bInited = FALSE;
static BOOL g_bBannerPrinted = FALSE;
#undef TRACE
#ifdef DEBUG
#define TRACE(x) InternalTrace x
#else
#define TRACE(x)
#endif
////////////////////////////////////////////////
// InternalTrace
//
// Internal tracing for problems in CoreDbgWrite
//
static void InternalTrace(LPCSTR fmt, ...)
{
char buffer[DEBUGBUFLEN];
size_t len = 0;
va_list marker;
va_start(marker, fmt);
_vsnprintf(buffer, DEBUGBUFLEN-3, fmt, marker);
buffer[DEBUGBUFLEN - 3] = 0;
len = strlen(buffer);
if(len > 0)
{
// make sure the line has terminating "\n"
if(buffer[len - 1] != '\n') {
buffer[len++] = '\n';
buffer[len] = '\0';
}
OutputDebugStringA(buffer);
}
va_end(marker);
}
//
// Creates our mutex with appropriate security descriptor
//
BOOL CoreDbgCreateDebugMutex(void)
{
#undef CHECK
#define CHECK(x) if(!(x)) { \
TRACE(("%s(%d): %s failed (%d)", __FILE__, __LINE__, #x, GetLastError())); \
goto Cleanup; }
#undef CHECK2
#define CHECK2(x, y) if(!(x)) { \
TRACE(("%s(%d): %s failed (%d)", __FILE__, __LINE__, #x, GetLastError())); \
TRACE(y); goto Cleanup; }
const TCHAR *COREDBG_OBJECT_DACLS= TEXT("D:(A;OICI;GA;;;BA)") // Admin
TEXT( "(A;OICI;GA;;;LS)") // Local Service
TEXT( "(A;OICI;GA;;;AU)"); // Authenticated Users.
SECURITY_ATTRIBUTES SA = {0};
BOOL bSuccess = FALSE;
SA.nLength = sizeof(SECURITY_ATTRIBUTES);
SA.bInheritHandle = FALSE;
SA.lpSecurityDescriptor = NULL;
if (ConvertStringSecurityDescriptorToSecurityDescriptor(
COREDBG_OBJECT_DACLS,
SDDL_REVISION_1,
&(SA.lpSecurityDescriptor),
NULL))
{
CHECK((g_hDebugFileMutex = CreateMutexA(&SA, FALSE, "Global\\WiaDebugFileMut")) != NULL);
bSuccess = TRUE;
}
Cleanup:
if (SA.lpSecurityDescriptor)
{
LocalFree(SA.lpSecurityDescriptor);
}
return bSuccess;
}
////////////////////////////////////////////////
// CoreDbgWrite
//
// Writes specified number of bytes to a debug
// file, creating it if needed. Thread-safe.
// Registers any failure and from that point returns
// immediately.
//
static void
CoreDbgWrite(LPCSTR buffer, DWORD n)
{
#undef CHECK
#define CHECK(x) if(!(x)) { \
TRACE(("%s(%d): %s failed (%d)", __FILE__, __LINE__, #x, GetLastError())); \
bCatastrophicFailure = TRUE; goto Cleanup; }
#undef CHECK2
#define CHECK2(x, y) if(!(x)) { \
TRACE(("%s(%d): %s failed (%d)", __FILE__, __LINE__, #x, GetLastError())); \
TRACE(y); bCatastrophicFailure = TRUE; goto Cleanup; }
DWORD cbWritten;
DWORD dwWaitResult;
LARGE_INTEGER newPos = { 0, 0 };
static BOOL bCatastrophicFailure = FALSE;
BOOL bMutexAcquired = FALSE;
// if something is broken, return immediately
if(bCatastrophicFailure) return;
// make sure we have file mutex
if(!g_hDebugFileMutex)
{
CHECK(CoreDbgCreateDebugMutex());
}
// acquire mutex
dwWaitResult = WaitForSingleObject(g_hDebugFileMutex, COREDBG_DEBUG_TIMEOUT);
// if we failed to acquire mutex within the specified timeout,
// shutdown tracing (on free builds users will not know this)
CHECK(dwWaitResult == WAIT_OBJECT_0 || dwWaitResult == WAIT_ABANDONED);
bMutexAcquired = TRUE;
// make sure we have open file
if(g_hDebugFile == INVALID_HANDLE_VALUE)
{
// attempt to open file
CHECK(ExpandEnvironmentStringsA(COREDBG_FILE_NAME, g_szDebugFileName, MAX_PATH));
g_hDebugFile = CreateFileA(g_szDebugFileName, GENERIC_WRITE,
FILE_SHARE_READ | FILE_SHARE_WRITE, NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
CHECK2(g_hDebugFile != INVALID_HANDLE_VALUE,
("g_szDebugFileName = '%s'", g_szDebugFileName));
}
// seek to the end of file
#ifdef UNICODE
CHECK(SetFilePointerEx(g_hDebugFile, newPos, &newPos, SEEK_END));
#else
CHECK(SetFilePointer(g_hDebugFile, newPos.LowPart, (PLONG)&newPos.LowPart, SEEK_END));
#endif
// check the file size
if(newPos.HighPart != 0 || newPos.LowPart > g_dwDebugFileSizeLimit)
{
static CHAR LogFullMessage[128];
TRACE(("Reached log file maximum size of %d", g_dwDebugFileSizeLimit));
_snprintf(LogFullMessage,
sizeof(LogFullMessage) / sizeof(LogFullMessage[0]) - 1,
"Log file reached maximum size of %d, logging stopped.",
g_dwDebugFileSizeLimit);
LogFullMessage[sizeof(LogFullMessage) / sizeof(LogFullMessage[0]) - 1] = '\0';
CHECK2(WriteFile(g_hDebugFile, LogFullMessage, strlen(LogFullMessage), &cbWritten, NULL), ("%d", cbWritten));
bCatastrophicFailure = TRUE;
}
// write data
CHECK2(WriteFile(g_hDebugFile, buffer, n, &cbWritten, NULL),
("%d %d", cbWritten, n));
// make sure we write to the disk now.
FlushFileBuffers(g_hDebugFile);
CHECK2(cbWritten == n, ("%d %d", n, cbWritten))
Cleanup:
if(bMutexAcquired) ReleaseMutex(g_hDebugFileMutex);
return;
}
////////////////////////////////////////////////
// PrintBanner
//
// Since we append to the log file, we need a
// seperator of some sort so we know when a
// new execution has started.
//
void PrintBanner(void)
{
char buffer[1024] = {0};
size_t len = 0;
SYSTEMTIME SysTime;
GetLocalTime(&SysTime);
if (g_dwDebugFlags)
{
_snprintf(buffer,
sizeof(buffer) / sizeof(buffer[0]) - 1,
"====================Start '%s' Debug - Time: %d/%02d/%02d %02d:%02d:%02d:%02d====================\r\n",
g_szModuleName,
SysTime.wYear,
SysTime.wMonth,
SysTime.wDay,
SysTime.wHour,
SysTime.wMinute,
SysTime.wSecond,
SysTime.wMilliseconds);
buffer[sizeof(buffer) / sizeof(buffer[0]) - 1] = '\0';
}
len = strlen(buffer);
if (len > 0)
{
if(!(g_dwDebugFlags & COREDBG_DONT_LOG_TO_FILE))
{
CoreDbgWrite(buffer, len);
}
#ifdef DEBUG
if(!(g_dwDebugFlags & COREDBG_DONT_LOG_TO_DEBUGGER))
{
OutputDebugStringA(buffer);
}
#endif
}
return;
}
////////////////////////////////////////////////
// CoreDbgGenericTrace
//
// Formats message and writes it into log file
// and/or debugger;
//
void CoreDbgGenericTrace(LPCSTR fmt,
va_list marker,
BOOL bIndent)
{
char buffer[DEBUGBUFLEN];
size_t len = 0;
//
// The first time we ever print a debug statement, lets
// output a seperator line since when we output to file
// we append, this way we can seperate different execution
// sessions.
//
if (!g_bBannerPrinted)
{
PrintBanner();
g_bBannerPrinted = TRUE;
}
if (bIndent)
{
buffer[0] = '\t';
_vsnprintf(&buffer[1], DEBUGBUFLEN - 3, fmt, marker);
}
else
{
_vsnprintf(buffer, DEBUGBUFLEN - 3, fmt, marker);
}
buffer[DEBUGBUFLEN - 3] = 0;
len = strlen(buffer);
if(len > 0)
{
// make sure the line has terminating "\n"
if(buffer[len - 1] != '\n')
{
buffer[len++] = '\r';
buffer[len++] = '\n';
buffer[len] = '\0';
}
if(!(g_dwDebugFlags & COREDBG_DONT_LOG_TO_FILE))
{
CoreDbgWrite(buffer, len);
}
#ifdef DEBUG
if(!(g_dwDebugFlags & COREDBG_DONT_LOG_TO_DEBUGGER))
{
OutputDebugStringA(buffer);
}
#endif
}
}
////////////////////////////////////////////////
// CoreDbgTrace
//
// Formats message and writes it into log file
// and/or debugger;
//
void CoreDbgTrace(LPCSTR fmt, ...)
{
va_list marker;
// get out if we don't have to log
#ifdef DEBUG
if((g_dwDebugFlags & COREDBG_DONT_LOG) == COREDBG_DONT_LOG)
#else
if(g_dwDebugFlags & COREDBG_DONT_LOG_TO_FILE)
#endif
{
return;
}
va_start(marker, fmt);
CoreDbgGenericTrace(fmt, marker, FALSE);
va_end(marker);
}
////////////////////////////////////////////////
// CoreDbgTraceWithTab
//
// Formats message and writes it into log file
// and/or debugger;
//
void CoreDbgTraceWithTab(LPCSTR fmt, ...)
{
va_list marker;
// get out if we don't have to log
#ifdef DEBUG
if((g_dwDebugFlags & COREDBG_DONT_LOG) == COREDBG_DONT_LOG)
#else
if(g_dwDebugFlags & COREDBG_DONT_LOG_TO_FILE)
#endif
{
return;
}
va_start(marker, fmt);
CoreDbgGenericTrace(fmt, marker, TRUE);
va_end(marker);
}
////////////////////////////////////////////////
// GetRegDWORD
//
// Attempts to get a DWORD from the specified
// location. If bSetIfNotExist is set, it
// writes the registry setting to the current
// value in pdwValue.
//
LRESULT GetRegDWORD(HKEY hKey,
const CHAR *pszRegValName,
DWORD *pdwValue,
BOOL bSetIfNotExist)
{
LRESULT lResult = ERROR_SUCCESS;
DWORD dwSize = 0;
DWORD dwType = REG_DWORD;
if ((hKey == NULL) ||
(pszRegValName == NULL) ||
(pdwValue == NULL))
{
return ERROR_INVALID_HANDLE;
}
dwSize = sizeof(DWORD);
lResult = RegQueryValueExA(hKey,
pszRegValName,
NULL,
&dwType,
(BYTE*) pdwValue,
&dwSize);
// if we didn't find the key, create it.
if (bSetIfNotExist)
{
if ((lResult != ERROR_SUCCESS) ||
(dwType != REG_DWORD))
{
lResult = RegSetValueExA(hKey,
pszRegValName,
0,
REG_DWORD,
(BYTE*) pdwValue,
dwSize);
}
}
return lResult;
}
////////////////////////////////////////////////
// CoreDbgInit
//
// Overwrite g_dwDebugFlags and g_dwDebugFileSizeLimit
// from registry
//
void CoreDbgInit(HINSTANCE hInstance)
{
HKEY hKey = NULL;
DWORD dwDispositon = 0;
DWORD dwData;
SYSTEMTIME SysTime;
DWORD dwDisposition = 0;
CHAR szModulePath[MAX_PATH + 1] = {0};
CHAR szDebugKey[1023 + 1] = {0};
CHAR *pszFileName = NULL;
GetModuleFileNameA(hInstance, szModulePath, sizeof(szModulePath));
szModulePath[sizeof(szModulePath) - 1] = '\0';
pszFileName = strrchr(szModulePath, '\\');
if (pszFileName == NULL)
{
pszFileName = szModulePath;
}
else
{
pszFileName++;
}
//
// build the registry key.
//
_snprintf(szDebugKey,
sizeof(szDebugKey) / sizeof(szDebugKey[0]) - 1,
"%s\\%s",
COREDBG_FLAGS_REGKEY,
pszFileName);
szDebugKey[sizeof(szDebugKey) / sizeof(szDebugKey[0]) - 1] = '\0';
lstrcpynA(g_szModuleName, pszFileName, sizeof(g_szModuleName));
//
// get/set the debug subkey. The DebugValues value is stored on a per module
// basis
//
if (RegCreateKeyExA(HKEY_LOCAL_MACHINE,
szDebugKey,
0,
NULL,
0,
KEY_READ | KEY_WRITE,
NULL,
&hKey,
&dwDisposition) == ERROR_SUCCESS ||
RegCreateKeyExA(HKEY_LOCAL_MACHINE,
szDebugKey,
0,
NULL,
0,
KEY_READ,
NULL,
&hKey,
&dwDisposition) == ERROR_SUCCESS)
{
dwData = g_dwDebugFlags;
if (GetRegDWORD(hKey, COREDBG_FLAGS_REGVAL, &dwData, TRUE) == ERROR_SUCCESS)
{
g_dwDebugFlags = dwData;
}
RegCloseKey(hKey);
hKey = NULL;
}
//
// get/set the Max File Size value. This is global to all debug modules since
// the all write to the same file.
//
if (RegCreateKeyExA(HKEY_LOCAL_MACHINE,
COREDBG_FLAGS_REGKEY,
0,
NULL,
0,
KEY_READ | KEY_WRITE,
NULL,
&hKey,
&dwDisposition) == ERROR_SUCCESS ||
RegCreateKeyExA(HKEY_LOCAL_MACHINE,
COREDBG_FLAGS_REGKEY,
0,
NULL,
0,
KEY_READ,
NULL,
&hKey,
&dwDisposition) == ERROR_SUCCESS)
{
dwData = g_dwDebugFileSizeLimit;
if (GetRegDWORD(hKey, COREDBG_REGVAL_FILE_SIZE_LIMIT, &dwData, TRUE) == ERROR_SUCCESS)
{
g_dwDebugFileSizeLimit = dwData;
}
RegCloseKey(hKey);
hKey = NULL;
}
g_bDebugInited = TRUE;
return;
}
////////////////////////////////////////////////
// CoreDbgTerm
//
// Clean up resources.
//
void CoreDbgTerm()
{
//
// This is FAR from perfect. The expectation is that
// this function is called in the DllMain of the
// application that is shutting down. Thus, we shouldn't
// really have any synchronization in here. However,
// this then doesn't address the problem of a thread
// calling into CoreDbgWrite above and recreating these
// objects, since we closed them (CoreDbgWrite will re-create
// objects that are closed automatically)
// Even worse, the WaitForSingleObject function's behavior is
// undefined if the handle is closed while it is in a wait
// state.
//
//
if (g_hDebugFile != INVALID_HANDLE_VALUE)
{
CloseHandle(g_hDebugFile);
g_hDebugFile = INVALID_HANDLE_VALUE;
}
if (g_hDebugFileMutex)
{
CloseHandle(g_hDebugFileMutex);
g_hDebugFileMutex = INVALID_HANDLE_VALUE;
}
}