server.c File Reference

#include "precomp.h"
#include "dbt.h"
#include "ntdddisk.h"
#include "ntuser.h"
#include <regstr.h>

Go to the source code of this file.

Defines
#define	ID_NLS   0
#define	ID_POWER   1
#define	ID_MEDIACHANGE   2
#define	ID_NETDEVCHANGE   3
#define	ID_NUM_EVENTS   4
#define	SC_BSM_EVENT_NAME   L"ScNetDrvMsg"
Typedefs
typedef BOOL(*	PFNPROCESSCREATE )(DWORD, DWORD, ULONG_PTR, DWORD)
Functions
HANDLE	CsrQueryApiPort (VOID)
ULONG	SrvExitWindowsEx (IN OUT PCSR_API_MSG m, IN OUT PCSR_REPLY_STATUS ReplyStatus)
ULONG	SrvEndTask (IN OUT PCSR_API_MSG m, IN OUT PCSR_REPLY_STATUS ReplyStatus)
ULONG	SrvLogon (IN OUT PCSR_API_MSG m, IN OUT PCSR_REPLY_STATUS ReplyStatus)
ULONG	SrvRegisterServicesProcess (IN OUT PCSR_API_MSG m, IN OUT PCSR_REPLY_STATUS ReplyStatus)
ULONG	SrvActivateDebugger (IN OUT PCSR_API_MSG m, IN OUT PCSR_REPLY_STATUS ReplyStatus)
ULONG	SrvGetThreadConsoleDesktop (IN OUT PCSR_API_MSG m, IN OUT PCSR_REPLY_STATUS ReplyStatus)
ULONG	SrvDeviceEvent (IN OUT PCSR_API_MSG m, IN OUT PCSR_REPLY_STATUS ReplyStatus)
ULONG	SrvRegisterLogonProcess (IN OUT PCSR_API_MSG m, IN OUT PCSR_REPLY_STATUS ReplyStatus)
ULONG	SrvWin32HeapFail (IN OUT PCSR_API_MSG m, IN OUT PCSR_REPLY_STATUS ReplyStatus)
ULONG	SrvWin32HeapStat (IN OUT PCSR_API_MSG m, IN OUT PCSR_REPLY_STATUS ReplyStatus)
NTSTATUS	UserServerDllInitialization (PCSR_SERVER_DLL psrvdll)
NTSTATUS	UserClientConnect (PCSR_PROCESS Process, PVOID ConnectionInformation, PULONG pulConnectionLen)
VOID	UserHardError (PCSR_THREAD pcsrt, PHARDERROR_MSG pmsg)
NTSTATUS	UserClientShutdown (PCSR_PROCESS Process, ULONG dwFlags, BOOLEAN fFirstPass)
VOID	GetTimeouts (VOID)
VOID	StartRegReadRead (VOID)
VOID	RegReadApcProcedure (PVOID RegReadApcContext, PIO_STATUS_BLOCK IoStatus)
VOID	NotificationThread (PVOID)
VOID	InitializeConsoleAttributes (VOID)
NTSTATUS	GetThreadConsoleDesktop (DWORD dwThreadId, HDESK *phdesk)
NTSTATUS	MyRegOpenKey (IN HANDLE hKey, IN LPWSTR lpSubKey, OUT PHANDLE phResult)
BOOL	BaseSetProcessCreateNotify (PFNPROCESSCREATE pfn)
VOID	BaseSrvNlsUpdateRegistryCache (PVOID ApcContext, PIO_STATUS_BLOCK pIoStatusBlock)
NTSTATUS	BaseSrvNlsLogon (BOOL)
NTSTATUS	WinStationAPIInit (VOID)
VOID	HandleMediaChangeEvent (VOID)
DWORD	GetNetworkDrives ()
VOID	HandleRemoteNetDeviceChangeEvent ()
BOOL	CreateBSMEventSD (PSECURITY_DESCRIPTOR *SecurityDescriptor)
UINT	GetRegIntFromID (HKEY hKey, int KeyID, UINT nDefault)
BOOL CALLBACK	FindWindowFromThread (HWND hwnd, LPARAM lParam)
DWORD	GetRipComponent (VOID)
DWORD	GetDbgTagFlags (int tag)
DWORD	GetRipPID (VOID)
DWORD	GetRipFlags (VOID)
VOID	SetRipFlags (DWORD dwRipFlags, DWORD dwRipPID)
VOID	SetDbgTag (int tag, DWORD dwBitFlags)
VOID	UserRtlRaiseStatus (NTSTATUS Status)
Variables
HANDLE	hThreadNotification
HANDLE	hKeyPriority
UNICODE_STRING	PriorityValueName
IO_STATUS_BLOCK	IoStatusRegChange
ULONG	RegChangeBuffer
HANDLE	ghNlsEvent
BOOL	gfLogon
FARPROC	gpfnAttachRoutine
HANDLE	ghPowerRequestEvent
HANDLE	ghMediaRequestEvent
DWORD	LastNetDrives
HANDLE	CsrApiPort
PCSR_API_ROUTINE	UserServerApiDispatchTable [UserpMaxApiNumber-UserpExitWindowsEx]
BOOLEAN	UserServerApiServerValidTable [UserpMaxApiNumber-UserpExitWindowsEx]
WORD	gDispatchTableValues
CONST ALWAYSZERO	gZero

---

Define Documentation

#define ID_MEDIACHANGE   2

Definition at line 38 of file server/server.c. Referenced by NotificationThread().

#define ID_NETDEVCHANGE   3

Definition at line 39 of file server/server.c. Referenced by NotificationThread().

#define ID_NLS   0

Definition at line 36 of file server/server.c. Referenced by NotificationThread().

#define ID_NUM_EVENTS   4

Definition at line 41 of file server/server.c. Referenced by NotificationThread().

#define ID_POWER   1

Definition at line 37 of file server/server.c. Referenced by NotificationThread().

#define SC_BSM_EVENT_NAME   L"ScNetDrvMsg"

Definition at line 46 of file server/server.c. Referenced by NotificationThread().

---

Typedef Documentation

typedef BOOL(* PFNPROCESSCREATE)(DWORD, DWORD, ULONG_PTR, DWORD)

Definition at line 162 of file server/server.c.

---

Function Documentation

BOOL BaseSetProcessCreateNotify (  PFNPROCESSCREATE  pfn  )

Referenced by UserServerDllInitialization().

NTSTATUS BaseSrvNlsLogon (  BOOL   )

Referenced by SrvLogon().

VOID BaseSrvNlsUpdateRegistryCache (  PVOID  ApcContext, PIO_STATUS_BLOCK  pIoStatusBlock )

Referenced by NotificationThread().

BOOL CreateBSMEventSD (  PSECURITY_DESCRIPTOR *  SecurityDescriptor  )

Definition at line 705 of file server/server.c. References BOOL, BYTE, FALSE, NT_SUCCESS, NTSTATUS(), NULL, RtlAddAccessAllowedAce(), RtlAllocateAndInitializeSid(), RtlCreateAcl(), RtlCreateSecurityDescriptor(), RtlFreeSid(), RtlLengthSid(), RtlSetDaclSecurityDescriptor(), Status, TRUE, and WorldSid. Referenced by NotificationThread(). : This function creates a security descriptor for the BSM request event. It grants EVENT_ALL_ACCESS to local system and EVENT_MODIFY_STATE access to the rest of the world. This prevents principals other than local system from waiting for the event. Arguments: SecurityDescriptor - Receives a pointer to the new security descriptor. Should be freed with LocalFree. Return Value: TRUE - success FALSE - failure, use GetLastError --*/ { NTSTATUS Status; ULONG AclLength; PACL EventDacl; PSID WorldSid = NULL; PSID SystemSid = NULL; SID_IDENTIFIER_AUTHORITY NtSidAuthority = SECURITY_NT_AUTHORITY; SID_IDENTIFIER_AUTHORITY WorldSidAuthority = SECURITY_WORLD_SID_AUTHORITY; BOOL retval = TRUE; *SecurityDescriptor = NULL; Status = RtlAllocateAndInitializeSid( &NtSidAuthority, 1, SECURITY_LOCAL_SYSTEM_RID, 0, 0, 0, 0, 0, 0, 0, &SystemSid ); if (!NT_SUCCESS(Status)) { retval = FALSE; goto Cleanup; } Status = RtlAllocateAndInitializeSid( &WorldSidAuthority, 1, SECURITY_WORLD_RID, 0, 0, 0, 0, 0, 0, 0, &WorldSid ); if (!NT_SUCCESS(Status)) { retval = FALSE; goto Cleanup; } // // Allocate a buffer to contain the SD followed by the DACL // Note, the well-known SIDs are expected to have been created // by this time // AclLength = (ULONG)sizeof(ACL) + (2*((ULONG)sizeof(ACCESS_ALLOWED_ACE))) + RtlLengthSid( SystemSid ) + RtlLengthSid( WorldSid ) + 8; // 8 is for good measure *SecurityDescriptor = (PSECURITY_DESCRIPTOR) LocalAlloc( 0, SECURITY_DESCRIPTOR_MIN_LENGTH + AclLength ); if (*SecurityDescriptor == NULL) { retval = FALSE; goto Cleanup; } EventDacl = (PACL) ((BYTE*)(*SecurityDescriptor) + SECURITY_DESCRIPTOR_MIN_LENGTH); // // Set up a default ACL // // Public: WORLD:EVENT_MODIFY_STATE, SYSTEM:all Status = RtlCreateAcl( EventDacl, AclLength, ACL_REVISION2); if (!NT_SUCCESS(Status)) { retval = FALSE; goto Cleanup; } // // WORLD access // Status = RtlAddAccessAllowedAce ( EventDacl, ACL_REVISION2, EVENT_MODIFY_STATE, WorldSid ); if (!NT_SUCCESS(Status)) { retval = FALSE; goto Cleanup; } // // SYSTEM access // Status = RtlAddAccessAllowedAce ( EventDacl, ACL_REVISION2, EVENT_ALL_ACCESS, SystemSid ); if (!NT_SUCCESS(Status)) { retval = FALSE; goto Cleanup; } // // Now initialize security descriptors // that export this protection // Status = RtlCreateSecurityDescriptor( *SecurityDescriptor, SECURITY_DESCRIPTOR_REVISION1 ); if (!NT_SUCCESS(Status)) { retval = FALSE; goto Cleanup; } Status = RtlSetDaclSecurityDescriptor( *SecurityDescriptor, TRUE, // DaclPresent EventDacl, FALSE // DaclDefaulted ); if (!NT_SUCCESS(Status)) { retval = FALSE; goto Cleanup; } Cleanup: if (WorldSid) { RtlFreeSid(WorldSid); } if (SystemSid) { RtlFreeSid(SystemSid); } if ((retval == FALSE) && (*SecurityDescriptor != NULL)) { LocalFree(*SecurityDescriptor); *SecurityDescriptor = NULL; } return retval; }

HANDLE CsrQueryApiPort (  VOID   )

BOOL CALLBACK FindWindowFromThread (  HWND  hwnd, LPARAM  lParam )

Definition at line 1255 of file server/server.c. References BOOL, GetWindow(), NULL, and TRUE. Referenced by BoostHardError(), GetHardErrorText(), and ThreadShutdownNotify(). { BOOL fTopLevelOwner; #ifdef FE_IME if ( IsImeWindow(hwnd) ) { return TRUE; } #endif fTopLevelOwner = (GetWindow(hwnd, GW_OWNER) == NULL); if ((*((HWND *)lParam) == NULL) || fTopLevelOwner) { *((HWND *)lParam) = hwnd; } return !fTopLevelOwner; }

DWORD GetDbgTagFlags (  int  tag  )

Definition at line 1273 of file server/server.c. References DWORD. { return 0; UNREFERENCED_PARAMETER(tag); }

DWORD GetNetworkDrives (   )

Definition at line 549 of file server/server.c. References DWORD, NT_SUCCESS, NtQueryInformationProcess(), and NULL. Referenced by HandleRemoteNetDeviceChangeEvent(). : Returns a drive bitmask similar to GetLogicalDrives, but including only the network drives. Arguments: Return Value: --*/ { DWORD Mask = 0; DWORD DriveNumber; PROCESS_DEVICEMAP_INFORMATION ProcessDeviceMapInfo; if (NT_SUCCESS(NtQueryInformationProcess( NtCurrentProcess(), ProcessDeviceMap, &ProcessDeviceMapInfo.Query, sizeof( ProcessDeviceMapInfo.Query ), NULL ))) { // For all the drives from C to Z for (DriveNumber = 2; DriveNumber < 26; DriveNumber++) { if (ProcessDeviceMapInfo.Query.DriveType[DriveNumber] == DOSDEVICE_DRIVE_REMOTE) { Mask |= (1 << DriveNumber); } } } return Mask; }

UINT GetRegIntFromID (  HKEY  hKey, int  KeyID, UINT  nDefault )

Definition at line 1029 of file server/server.c. References BOOL, BYTE, DWORD, FALSE, ghModuleWin, NT_SUCCESS, NtQueryValueKey(), NTSTATUS(), NULL, RtlInitUnicodeString(), RtlLoadStringOrError(), RtlUnicodeStringToInteger(), Status, and UINT. Referenced by GetTimeouts(). { LPWSTR lpszValue; BOOL fAllocated; UNICODE_STRING Value; DWORD cbSize; BYTE Buf[sizeof(KEY_VALUE_PARTIAL_INFORMATION) + 20 * sizeof(WCHAR)]; NTSTATUS Status; UINT ReturnValue; lpszValue = (LPWSTR)RtlLoadStringOrError(ghModuleWin, KeyID, NULL, &fAllocated, FALSE); RtlInitUnicodeString(&Value, lpszValue); Status = NtQueryValueKey(hKey, &Value, KeyValuePartialInformation, (PKEY_VALUE_PARTIAL_INFORMATION)Buf, sizeof(Buf), &cbSize); if (NT_SUCCESS(Status)) { /* * Convert string to int. */ RtlInitUnicodeString(&Value, (LPWSTR)((PKEY_VALUE_PARTIAL_INFORMATION)Buf)->Data); RtlUnicodeStringToInteger(&Value, 10, &ReturnValue); } else { ReturnValue = nDefault; } LocalFree(lpszValue); return(ReturnValue); }

DWORD GetRipComponent (  VOID   )

Definition at line 1271 of file server/server.c. References DWORD. { return RIP_USERSRV; }

DWORD GetRipFlags (  VOID   )

Definition at line 1280 of file server/server.c. References DWORD, and gdwRIPFlags. { return gdwRIPFlags; }

DWORD GetRipPID (  VOID   )

Definition at line 1279 of file server/server.c. References DWORD. { return 0; }

NTSTATUS GetThreadConsoleDesktop (  DWORD  dwThreadId, HDESK *  phdesk )

Definition at line 3139 of file server/private.c. References CONSOLE_FROMTHREADPERPROCESSDATA, _CONSOLE_PER_PROCESS_DATA::ConsoleHandle, _CONSOLE_INFORMATION::hDesk, NT_SUCCESS, NTSTATUS(), NULL, PCONSOLE_PER_PROCESS_DATA, RevalidateConsole(), Status, and UnlockConsole(). Referenced by SrvGetThreadConsoleDesktop(). { PCSR_THREAD pcsrt; PCONSOLE_PER_PROCESS_DATA ProcessData; PCONSOLE_INFORMATION Console; NTSTATUS Status; HANDLE ConsoleHandle = NULL; *phdeskConsole = NULL; Status = CsrLockThreadByClientId((HANDLE)dwThreadId, &pcsrt); if (NT_SUCCESS(Status)) { ProcessData = CONSOLE_FROMTHREADPERPROCESSDATA(pcsrt); ConsoleHandle = ProcessData->ConsoleHandle; CsrUnlockThread(pcsrt); } // // If this process is a console app, return the // handle to its desktop. Otherwise, return NULL. // if (ConsoleHandle != NULL) { Status = RevalidateConsole(ConsoleHandle, &Console); if (NT_SUCCESS(Status)) { *phdeskConsole = Console->hDesk; } UnlockConsole(Console); } return STATUS_SUCCESS; }

VOID GetTimeouts (  VOID   )

Definition at line 1068 of file server/server.c. References CMSHUNGAPPTIMEOUT, gCmsHungAppTimeout, gCmsWaitToKillTimeout, gdwHungToKillCount, gdwProcessTerminateTimeout, gdwServicesWaitToKillTimeout, GetRegIntFromID(), gfAutoEndTask, L, MyRegOpenKey(), NT_SUCCESS, NtClose(), NTSTATUS(), NULL, PROCESSTERMINATETIMEOUT, RtlOpenCurrentUser(), Status, and VOID(). Referenced by SrvLogon(). { HANDLE hCurrentUserKey; HANDLE hKey; NTSTATUS Status; Status = RtlOpenCurrentUser(MAXIMUM_ALLOWED, &hCurrentUserKey); if (NT_SUCCESS(Status)) { Status = MyRegOpenKey(hCurrentUserKey, L"Control Panel\\Desktop", &hKey); if (NT_SUCCESS(Status)) { gCmsHungAppTimeout = GetRegIntFromID( hKey, STR_CMSHUNGAPPTIMEOUT, gCmsHungAppTimeout); gCmsWaitToKillTimeout = GetRegIntFromID( hKey, STR_CMSWAITTOKILLTIMEOUT, gCmsWaitToKillTimeout); gdwHungToKillCount = gCmsWaitToKillTimeout / gCmsHungAppTimeout; gfAutoEndTask = GetRegIntFromID( hKey, STR_AUTOENDTASK, gfAutoEndTask); NtClose(hKey); } NtClose(hCurrentUserKey); } Status = MyRegOpenKey(NULL, L"\\Registry\\Machine\\System\\CurrentControlSet\\Control", &hKey); if (NT_SUCCESS(Status)) { gdwServicesWaitToKillTimeout = GetRegIntFromID( hKey, STR_WAITTOKILLSERVICETIMEOUT, gCmsWaitToKillTimeout); gdwProcessTerminateTimeout = GetRegIntFromID( hKey, STR_PROCESSTERMINATETIMEOUT, PROCESSTERMINATETIMEOUT); if (gdwProcessTerminateTimeout < CMSHUNGAPPTIMEOUT) { gdwProcessTerminateTimeout = CMSHUNGAPPTIMEOUT; } NtClose(hKey); } }

VOID HandleMediaChangeEvent (  VOID   )

Definition at line 479 of file server/server.c. References BOOL, BroadcastSystemMessage(), DWORD, NT_SUCCESS, NTSTATUS(), NtUserCallNoParam(), NtUserSetInformationThread(), NULL, Status, and VOID(). Referenced by NotificationThread(). { /* * Local variables */ DWORD dwRecipients; BOOL bResult; NTSTATUS Status; DEV_BROADCAST_VOLUME dbcvInfo; USERTHREAD_USEDESKTOPINFO utudi; ULONG cDrive; while (cDrive = (ULONG)NtUserCallNoParam(SFI_GETDEVICECHANGEINFO)) { /* * Determine if it's an arrival or removal */ bResult = (cDrive & 0x80000000); /* * Initialize the structures used for BroadcastSystemMessage */ dbcvInfo.dbcv_size = sizeof(dbcvInfo); dbcvInfo.dbcv_devicetype = DBT_DEVTYP_VOLUME; dbcvInfo.dbcv_reserved = 0; dbcvInfo.dbcv_flags = DBTF_MEDIA; dbcvInfo.dbcv_unitmask = cDrive; dwRecipients = BSM_ALLCOMPONENTS | BSM_ALLDESKTOPS; /* * Temporarily we must assign this thread to a desktop so we can * call USER's BroascastSystemMessage() routine. We call the * private SetThreadDesktopToDefault() to assign ourselves to the * desktop that is currently receiving input. */ utudi.hThread = NULL; utudi.drdRestore.pdeskRestore = NULL; Status = NtUserSetInformationThread(NtCurrentThread(), UserThreadUseActiveDesktop, &utudi, sizeof(utudi)); if (NT_SUCCESS(Status)) { /* * Broadcast the message */ BroadcastSystemMessage(BSF_FORCEIFHUNG | ((bResult) ? BSF_ALLOWSFW : 0), &dwRecipients, WM_DEVICECHANGE, // HACK: need to or 0x8000 in wParam // because this is a flag to let // BSM know that lParam is a pointer // to a data structure. 0x8000 | ((bResult) ? DBT_DEVICEARRIVAL : DBT_DEVICEREMOVECOMPLETE), (LPARAM)&dbcvInfo); /* * Set our thread's desktop back to NULL. This will decrement * the desktop's reference count. */ NtUserSetInformationThread(NtCurrentThread(), UserThreadUseDesktop, &utudi, sizeof(utudi)); } } }

VOID HandleRemoteNetDeviceChangeEvent (   )

Definition at line 589 of file server/server.c. References BroadcastSystemMessage(), DWORD, GetNetworkDrives(), LastNetDrives, NT_SUCCESS, NtUserSetInformationThread(), and NULL. Referenced by NotificationThread(). : Arguments: Return Value: --*/ { DWORD NetDrives; DEV_BROADCAST_VOLUME dbv; LONG status; USERTHREAD_USEDESKTOPINFO utudi; /* * Temporarily we must assign this thread to a desktop so we can * call USER's BroascastSystemMessage() routine. We call the * private SetThreadDesktopToDefault() to assign ourselves to the * desktop that is currently receiving input. */ utudi.hThread = NULL; utudi.drdRestore.pdeskRestore = NULL; status = NtUserSetInformationThread(NtCurrentThread(), UserThreadUseActiveDesktop, &utudi, sizeof(utudi)); if (!NT_SUCCESS(status)) { return; } // // Keep broadcasting until the set of net drives stops changing // for (;;) { // // Get the current net drive bitmask and compare against the net // drive bitmask when we last broadcast // NetDrives = GetNetworkDrives(); if (NetDrives == LastNetDrives) { break; } // // Broadcast about deleted volumes // dbv.dbcv_size = sizeof(dbv); dbv.dbcv_devicetype = DBT_DEVTYP_VOLUME; dbv.dbcv_reserved = 0; dbv.dbcv_unitmask = LastNetDrives & ~NetDrives; dbv.dbcv_flags = DBTF_NET; if (dbv.dbcv_unitmask != 0) { DWORD dwRec = BSM_APPLICATIONS | BSM_ALLDESKTOPS; status = BroadcastSystemMessage( BSF_FORCEIFHUNG | BSF_NOHANG | BSF_NOTIMEOUTIFNOTHUNG, &dwRec, WM_DEVICECHANGE, (WPARAM) DBT_DEVICEREMOVECOMPLETE, (LPARAM)(DEV_BROADCAST_HDR*)(&dbv) ); } // // Broadcast about added volumes // dbv.dbcv_unitmask = NetDrives & ~LastNetDrives; if (dbv.dbcv_unitmask != 0) { DWORD dwRec = BSM_APPLICATIONS | BSM_ALLDESKTOPS; status = BroadcastSystemMessage( BSF_FORCEIFHUNG | BSF_NOHANG | BSF_NOTIMEOUTIFNOTHUNG, &dwRec, WM_DEVICECHANGE, (WPARAM) DBT_DEVICEARRIVAL, (LPARAM)(DEV_BROADCAST_HDR*)(&dbv) ); } // // Remember the drive set that we last broadcast about // LastNetDrives = NetDrives; // // Go around the loop again to detect changes that may have occurred // while we were broadcasting // } /* * Set our thread's desktop back to NULL. This will decrement * the desktop's reference count. */ NtUserSetInformationThread(NtCurrentThread(), UserThreadUseDesktop, &utudi, sizeof(utudi)); return; }

VOID InitializeConsoleAttributes (  VOID   )

Definition at line 2132 of file srvinit.c. References _CONSOLE_REGISTRY_INFO::AutoPosition, _CONSOLE_REGISTRY_INFO::ColorTable, CURSOR_SMALL_SIZE, _CONSOLE_REGISTRY_INFO::CursorSize, DEFAULT_NUMBER_OF_BUFFERS, DEFAULT_NUMBER_OF_COMMANDS, DefaultRegInfo, _CONSOLE_REGISTRY_INFO::FaceName, FALSE, _CONSOLE_REGISTRY_INFO::FontFamily, _CONSOLE_REGISTRY_INFO::FontSize, _CONSOLE_REGISTRY_INFO::FontWeight, _CONSOLE_REGISTRY_INFO::FullScreen, _CONSOLE_REGISTRY_INFO::HistoryBufferSize, _CONSOLE_REGISTRY_INFO::HistoryNoDup, InitializeSystemMetrics(), _CONSOLE_REGISTRY_INFO::InsertMode, L, _CONSOLE_REGISTRY_INFO::LastWriteTime, _CONSOLE_REGISTRY_INFO::NumberOfHistoryBuffers, OEMCP, _CONSOLE_REGISTRY_INFO::PopupFill, _CONSOLE_REGISTRY_INFO::QuickEdit, _CONSOLE_REGISTRY_INFO::ScreenBufferSize, _CONSOLE_REGISTRY_INFO::ScreenFill, TRUE, _CONSOLE_REGISTRY_INFO::WindowOrigin, and _CONSOLE_REGISTRY_INFO::WindowSize. Referenced by SrvLogon(). : This routine initializes default attributes from the current user's registry values. It gets called during logon/logoff. Arguments: none Return Value: none --*/ { // // Store default values in structure and mark it // as invalid (by resetting LastWriteTime). // DefaultRegInfo.ScreenFill.Attributes = 0x07; // white on black DefaultRegInfo.ScreenFill.Char.UnicodeChar = (WCHAR)' '; DefaultRegInfo.PopupFill.Attributes = 0xf5; // purple on white DefaultRegInfo.PopupFill.Char.UnicodeChar = (WCHAR)' '; DefaultRegInfo.InsertMode = FALSE; DefaultRegInfo.QuickEdit = FALSE; DefaultRegInfo.AutoPosition = TRUE; DefaultRegInfo.FullScreen = FALSE; DefaultRegInfo.ScreenBufferSize.X = 80; DefaultRegInfo.ScreenBufferSize.Y = 25; DefaultRegInfo.WindowSize.X = 80; DefaultRegInfo.WindowSize.Y = 25; DefaultRegInfo.WindowOrigin.X = 0; DefaultRegInfo.WindowOrigin.Y = 0; DefaultRegInfo.FontSize.X = 0; DefaultRegInfo.FontSize.Y = 0; DefaultRegInfo.FontFamily = 0; DefaultRegInfo.FontWeight = 0; DefaultRegInfo.FaceName[0] = L'\0'; DefaultRegInfo.CursorSize = CURSOR_SMALL_SIZE; DefaultRegInfo.HistoryBufferSize = DEFAULT_NUMBER_OF_COMMANDS; DefaultRegInfo.NumberOfHistoryBuffers = DEFAULT_NUMBER_OF_BUFFERS; DefaultRegInfo.HistoryNoDup = FALSE; DefaultRegInfo.ColorTable[ 0] = RGB(0, 0, 0 ); DefaultRegInfo.ColorTable[ 1] = RGB(0, 0, 0x80); DefaultRegInfo.ColorTable[ 2] = RGB(0, 0x80,0 ); DefaultRegInfo.ColorTable[ 3] = RGB(0, 0x80,0x80); DefaultRegInfo.ColorTable[ 4] = RGB(0x80,0, 0 ); DefaultRegInfo.ColorTable[ 5] = RGB(0x80,0, 0x80); DefaultRegInfo.ColorTable[ 6] = RGB(0x80,0x80,0 ); DefaultRegInfo.ColorTable[ 7] = RGB(0xC0,0xC0,0xC0); DefaultRegInfo.ColorTable[ 8] = RGB(0x80,0x80,0x80); DefaultRegInfo.ColorTable[ 9] = RGB(0, 0, 0xFF); DefaultRegInfo.ColorTable[10] = RGB(0, 0xFF,0 ); DefaultRegInfo.ColorTable[11] = RGB(0, 0xFF,0xFF); DefaultRegInfo.ColorTable[12] = RGB(0xFF,0, 0 ); DefaultRegInfo.ColorTable[13] = RGB(0xFF,0, 0xFF); DefaultRegInfo.ColorTable[14] = RGB(0xFF,0xFF,0 ); DefaultRegInfo.ColorTable[15] = RGB(0xFF,0xFF,0xFF); #if defined(FE_SB) // scotthsu DefaultRegInfo.CodePage = OEMCP; #endif DefaultRegInfo.LastWriteTime = 0; // // Get system metrics for this user // InitializeSystemMetrics(); }

NTSTATUS MyRegOpenKey (  IN HANDLE  hKey, IN LPWSTR  lpSubKey, OUT PHANDLE  phResult )

Definition at line 1635 of file srvinit.c. References NtOpenKey(), NULL, and RtlInitUnicodeString(). Referenced by GetRegistryValues(), and GetTimeouts(). { OBJECT_ATTRIBUTES Obja; UNICODE_STRING SubKey; // // Convert the subkey to a counted Unicode string. // RtlInitUnicodeString( &SubKey, lpSubKey ); // // Initialize the OBJECT_ATTRIBUTES structure and open the key. // InitializeObjectAttributes( &Obja, &SubKey, OBJ_CASE_INSENSITIVE, hKey, NULL ); return NtOpenKey( phResult, KEY_READ, &Obja ); }

VOID NotificationThread (  PVOID   )

Definition at line 881 of file server/server.c. References BaseSrvNlsUpdateRegistryCache(), CreateBSMEventSD(), FALSE, gfLogon, ghMediaRequestEvent, ghNlsEvent, ghPowerRequestEvent, gSessionId, HandleMediaChangeEvent(), HandleRemoteNetDeviceChangeEvent(), hThreadNotification, ID_MEDIACHANGE, ID_NETDEVCHANGE, ID_NLS, ID_NUM_EVENTS, ID_POWER, L, MAX_SESSION_PATH, NT_SUCCESS, NtCreateEvent(), NtResetEvent(), NtSetInformationThread(), NTSTATUS(), NtUserCallNoParam(), NtWaitForMultipleObjects(), NULL, RtlInitUnicodeString(), SC_BSM_EVENT_NAME, SESSION_ROOT, StartRegReadRead(), Status, TRUE, and VOID(). Referenced by UserServerDllInitialization(). { KPRIORITY Priority; NTSTATUS Status; HANDLE hEvent[ID_NUM_EVENTS]; WCHAR szObjectStr[MAX_SESSION_PATH]; OBJECT_ATTRIBUTES Attributes; UNICODE_STRING UnicodeString; PSECURITY_DESCRIPTOR pSD = NULL; ULONG NumEvents = ID_NUM_EVENTS; UNREFERENCED_PARAMETER(pJunk); try { /* * Set the priority of the RIT to 3. */ Priority = LOW_PRIORITY + 3; NtSetInformationThread(hThreadNotification, ThreadPriority, &Priority, sizeof(KPRIORITY)); /* * Setup the NLS event */ NtCreateEvent(&ghNlsEvent, EVENT_ALL_ACCESS, NULL, SynchronizationEvent, FALSE); UserAssert( ghNlsEvent != NULL ); hEvent[ID_NLS] = ghNlsEvent; /* * Setup the power request event */ hEvent[ID_POWER] = ghPowerRequestEvent; /* * Setup the MediaChangeEvent */ hEvent[ID_MEDIACHANGE] = ghMediaRequestEvent; /* * Setup the NetDeviceChange Event */ if (gSessionId != 0) { // // Only on remote Session // swprintf(szObjectStr,L"%ws\\%ld\\BaseNamedObjects\\%ws", SESSION_ROOT,gSessionId,SC_BSM_EVENT_NAME); RtlInitUnicodeString(&UnicodeString, szObjectStr); if (CreateBSMEventSD(&pSD) ) { InitializeObjectAttributes(&Attributes, &UnicodeString, OBJ_CASE_INSENSITIVE | OBJ_OPENIF, NULL, pSD); if (!NT_SUCCESS(NtCreateEvent(&hEvent[ID_NETDEVCHANGE], EVENT_ALL_ACCESS, &Attributes, SynchronizationEvent, FALSE))) { NumEvents--; } LocalFree(pSD); } else { NumEvents--; } } else { // // On Console we don't wait for NetDeviceEvent // NumEvents--; } /* * Only want media change events on the console. */ if (gSessionId == 0) { } StartRegReadRead(); /* * Sit and wait forever. */ while (TRUE) { Status = NtWaitForMultipleObjects(NumEvents, hEvent, WaitAny, TRUE, NULL); if (Status == ID_NLS + WAIT_OBJECT_0) { /* * Handle the NLS event */ if (gfLogon) { gfLogon = FALSE; BaseSrvNlsUpdateRegistryCache(NULL, NULL); } } else if (Status == ID_POWER + WAIT_OBJECT_0) { /* * Handle the power request event */ NtUserCallNoParam(SFI_XXXUSERPOWERCALLOUTWORKER); } else if (Status == ID_MEDIACHANGE + WAIT_OBJECT_0) { /* * Handle the media change event */ HandleMediaChangeEvent(); NtResetEvent(hEvent[ID_MEDIACHANGE], NULL); } else if (Status == ID_NETDEVCHANGE + WAIT_OBJECT_0) { /* * Handle the NetDevice change event for remote sessions */ HandleRemoteNetDeviceChangeEvent(); } } // While (TRUE) } except (CsrUnhandledExceptionFilter(GetExceptionInformation())) { KdPrint(("Registry notification thread is dead, sorry.\n")); } }

VOID RegReadApcProcedure (  PVOID  RegReadApcContext, PIO_STATUS_BLOCK  IoStatus )

Definition at line 387 of file server/server.c. References BYTE, DWORD, FALSE, hKeyPriority, IoStatusRegChange, L, NT_SUCCESS, NtNotifyChangeKey(), NtQueryValueKey(), NtSetSystemInformation(), NULL, RegChangeBuffer, RegReadApcProcedure(), RtlInitUnicodeString(), Status, and TRUE. Referenced by RegReadApcProcedure(), and StartRegReadRead(). { UNICODE_STRING ValueString; LONG Status; BYTE Buf[sizeof(KEY_VALUE_PARTIAL_INFORMATION) + sizeof(DWORD)]; DWORD cbSize; ULONG l; UNREFERENCED_PARAMETER(RegReadApcContext); UNREFERENCED_PARAMETER(IoStatus); RtlInitUnicodeString(&ValueString, L"Win32PrioritySeparation"); Status = NtQueryValueKey(hKeyPriority, &ValueString, KeyValuePartialInformation, (PKEY_VALUE_PARTIAL_INFORMATION)Buf, sizeof(Buf), &cbSize); if (NT_SUCCESS(Status)) { l = *((PDWORD)((PKEY_VALUE_PARTIAL_INFORMATION)Buf)->Data); } else { l = PROCESS_PRIORITY_SEPARATION_MAX; // last resort default } NtSetSystemInformation(SystemPrioritySeperation,&l,sizeof(ULONG)); NtNotifyChangeKey( hKeyPriority, NULL, (PIO_APC_ROUTINE)RegReadApcProcedure, NULL, &IoStatusRegChange, REG_NOTIFY_CHANGE_LAST_SET, FALSE, &RegChangeBuffer, sizeof(RegChangeBuffer), TRUE ); }

VOID SetDbgTag (  int  tag, DWORD  dwBitFlags )

Definition at line 1290 of file server/server.c. References VOID(). { UNREFERENCED_PARAMETER(tag); UNREFERENCED_PARAMETER(dwBitFlags); }

VOID SetRipFlags (  DWORD  dwRipFlags, DWORD  dwRipPID )

Definition at line 1282 of file server/server.c. References DWORD, gdwRIPFlags, RIPF_VALIDUSERFLAGS, and VOID(). { if ((dwRipFlags != (DWORD)-1) && !(dwRipFlags & ~RIPF_VALIDUSERFLAGS)) { gdwRIPFlags = (WORD)((gdwRIPFlags & ~RIPF_VALIDUSERFLAGS) | dwRipFlags); } UNREFERENCED_PARAMETER(dwRipPID); }

ULONG SrvActivateDebugger (  IN OUT PCSR_API_MSG  m, IN OUT PCSR_REPLY_STATUS  ReplyStatus )

Definition at line 28 of file w32/ntuser/server/debug.c. References ASSERT, _ACTIVATEDEBUGGERMSG::ClientId, FALSE, gpfnAttachRoutine, NT_SUCCESS, NtAlertThread(), NTSTATUS(), NULL, RtlRemoteCall(), Status, and TRUE. { PACTIVATEDEBUGGERMSG a = (PACTIVATEDEBUGGERMSG)&m->u.ApiMessageData; PCSR_THREAD Thread; NTSTATUS Status; UNREFERENCED_PARAMETER(ReplyStatus); /* * If the process is CSR, break */ if (a->ClientId.UniqueProcess == NtCurrentTeb()->ClientId.UniqueProcess) { DbgBreakPoint(); return STATUS_SUCCESS; } /* * Impersonate the client if this is a user mode request. */ if (m->h.u2.s2.Type == LPC_REQUEST) { if (!CsrImpersonateClient(NULL)) { return STATUS_UNSUCCESSFUL; } } /* * Lock the client thread */ Status = CsrLockThreadByClientId(a->ClientId.UniqueThread, &Thread); if (NT_SUCCESS(Status)) { ASSERT(a->ClientId.UniqueProcess == Thread->ClientId.UniqueProcess); /* * Now that everything is set, rtlremote call to a debug breakpoint. * This causes the process to enter the debugger with a breakpoint. */ Status = RtlRemoteCall( Thread->Process->ProcessHandle, Thread->ThreadHandle, (PVOID)gpfnAttachRoutine, 0, NULL, TRUE, FALSE ); UserAssert(NT_SUCCESS(Status)); Status = NtAlertThread(Thread->ThreadHandle); UserAssert(NT_SUCCESS(Status)); CsrUnlockThread(Thread); } /* * Stop impersonating the client. */ if (m->h.u2.s2.Type == LPC_REQUEST) { CsrRevertToSelf(); } return Status; }

ULONG SrvDeviceEvent (  IN OUT PCSR_API_MSG  m, IN OUT PCSR_REPLY_STATUS  ReplyStatus )

Definition at line 37 of file instdev.c. References _DEVICEEVENTMSG::dwFlags, _DEVICEEVENTMSG::dwResult, EXCEPTION_EXECUTE_HANDLER, _DEVICEEVENTMSG::hWnd, IsWindow(), _DEVICEEVENTMSG::lParam, NT_SUCCESS, NTSTATUS(), NtUserSetInformationThread(), NULL, PostMessage(), SendMessageTimeout(), Status, and _DEVICEEVENTMSG::wParam. { NTSTATUS Status = STATUS_SUCCESS; PDEVICEEVENTMSG a = (PDEVICEEVENTMSG)&m->u.ApiMessageData; USERTHREAD_USEDESKTOPINFO utudi; UNREFERENCED_PARAMETER(ReplyStatus); try { // // Set the desktop to the active desktop before sending the // message. // utudi.hThread = NULL; utudi.drdRestore.pdeskRestore = NULL; Status = NtUserSetInformationThread(NtCurrentThread(), UserThreadUseActiveDesktop, &utudi, sizeof(utudi)); if (!NT_SUCCESS(Status)) { #if DBG KdPrint(("--> SrvDeviceEvent: NtUserSetInformationThread failed %d\n", Status)); #endif goto Clean1; } // // Verify the window handle is still valid, if not, let the caller know // so it can be purged from the notification window hand list that the // user-mode pnp manager keeps. // if ((a->hWnd != HWND_BROADCAST) && !IsWindow(a->hWnd)) { Status = STATUS_INVALID_HANDLE; goto Clean0; } if (a->dwFlags) { // // This is a query so we have to send the message but use // timeouts so an app can't stall us forever. // RIPMSG3(RIP_VERBOSE, "--> SrvDeviceEvent: Sending WM_DEVICECHANGE to 0x%x, w 0x%x, l 0x%x", (ULONG_PTR)a->hWnd, a->wParam, a->lParam); if (!SendMessageTimeout(a->hWnd, WM_DEVICECHANGE, a->wParam, a->lParam, SMTO_ABORTIFHUNG | SMTO_NORMAL, PNP_NOTIFY_TIMEOUT, &a->dwResult)) { Status = STATUS_UNSUCCESSFUL; } } else { // // It's not a query so just post it and return, we don't // care what the app returns. // RIPMSG3(RIP_VERBOSE, "--> SrvDeviceEvent: Posting WM_DEVICECHANGE to 0x%x, w 0x%x, l 0x%x", (ULONG_PTR)a->hWnd, a->wParam, a->lParam); if (!PostMessage(a->hWnd, WM_DEVICECHANGE, a->wParam, a->lParam)) { Status = STATUS_UNSUCCESSFUL; } } Clean0: // // Reset this thread's desktop back to NULL before returning. This // decrements the desktop's reference count. // NtUserSetInformationThread(NtCurrentThread(), UserThreadUseDesktop, &utudi, sizeof(utudi)); Clean1: ; } except (EXCEPTION_EXECUTE_HANDLER) { KdPrint(("SrvDeviceEvent generated an exception (%d)\n", GetExceptionCode())); Status = STATUS_UNSUCCESSFUL; } return Status; } // SrvDeviceEvent

ULONG SrvEndTask (  IN OUT PCSR_API_MSG  m, IN OUT PCSR_REPLY_STATUS  ReplyStatus )

Definition at line 1963 of file server/exitwin.c. References _EndTask(), _ENDTASKMSG::dwLastError, _ENDTASKMSG::fForce, _ENDTASKMSG::fShutdown, _ENDTASKMSG::fSuccess, _ENDTASKMSG::hwnd, NtReplyPort(), NULL, and TRUE. { PENDTASKMSG petm = (PENDTASKMSG)&m->u.ApiMessageData; PCSR_THREAD pcsrt; PTEB Teb = NtCurrentTeb(); Teb->LastErrorValue = 0; pcsrt = CSR_SERVER_QUERYCLIENTTHREAD(); /* * Don't block the client so it can respond to messages while we * process this request -- we might bring up the End Application * dialog or the hwnd being shutdown might request some user action. */ if (pcsrt->Process->ClientPort != NULL) { m->ReturnValue = STATUS_SUCCESS; petm->dwLastError = 0; petm->fSuccess = TRUE; NtReplyPort(pcsrt->Process->ClientPort, (PPORT_MESSAGE)m); *ReplyStatus = CsrServerReplied; } petm->fSuccess = _EndTask(petm->hwnd, petm->fShutdown, petm->fForce); petm->dwLastError = Teb->LastErrorValue; return STATUS_SUCCESS; }

ULONG SrvExitWindowsEx (  IN OUT PCSR_API_MSG  m, IN OUT PCSR_REPLY_STATUS  ReplyStatus )

Definition at line 1950 of file server/exitwin.c. References _ExitWindowsEx(), BEGIN_LPC_RECV, END_LPC_RECV, NT_SUCCESS, and Status. { BEGIN_LPC_RECV(EXITWINDOWSEX); Status = _ExitWindowsEx(pcsrt, a->uFlags, a->dwReserved); a->fSuccess = NT_SUCCESS(Status); END_LPC_RECV(); }

ULONG SrvGetThreadConsoleDesktop (  IN OUT PCSR_API_MSG  m, IN OUT PCSR_REPLY_STATUS  ReplyStatus )

Definition at line 1235 of file server/server.c. References _GETTHREADCONSOLEDESKTOPMSG::dwThreadId, GetThreadConsoleDesktop(), _GETTHREADCONSOLEDESKTOPMSG::hdeskConsole, and PGETTHREADCONSOLEDESKTOPMSG. { PGETTHREADCONSOLEDESKTOPMSG a = (PGETTHREADCONSOLEDESKTOPMSG)&m->u.ApiMessageData; UNREFERENCED_PARAMETER(ReplyStatus); return GetThreadConsoleDesktop(a->dwThreadId, &a->hdeskConsole); }

ULONG SrvLogon (  IN OUT PCSR_API_MSG  m, IN OUT PCSR_REPLY_STATUS  ReplyStatus )

Definition at line 1121 of file server/server.c. References ASSERT, BaseSrvNlsLogon(), FALSE, _LOGONMSG::fLogon, GetTimeouts(), gfLogon, ghNlsEvent, InitializeConsoleAttributes(), LdrFlushAlternateResourceModules(), NT_SUCCESS, NtSetEvent(), NTSTATUS(), NULL, PLOGONMSG, Status, and TRUE. { PLOGONMSG a = (PLOGONMSG)&m->u.ApiMessageData; NTSTATUS Status; UNREFERENCED_PARAMETER(ReplyStatus); if (!CsrImpersonateClient(NULL)) return (ULONG)STATUS_UNSUCCESSFUL; if (a->fLogon) { /* * Flush the MultiLingual UI (MUI) alternate * resource modules from within NTDLL, so that the * new user logging-on gets his chance to * load his own. */ LdrFlushAlternateResourceModules(); /* * Take care of NLS cache for LogON. */ BaseSrvNlsLogon(TRUE); /* * Set the cleanup event so that the RIT can handle the NLS * registry notification. */ gfLogon = TRUE; Status = NtSetEvent( ghNlsEvent, NULL ); ASSERT(NT_SUCCESS(Status)); } else { /* * Take care of NLS cache for LogOFF. */ BaseSrvNlsLogon(FALSE); } /* * Get timeout values from registry */ GetTimeouts(); CsrRevertToSelf(); /* * Initialize console attributes */ InitializeConsoleAttributes(); return (ULONG)STATUS_SUCCESS; }

ULONG SrvRegisterLogonProcess (  IN OUT PCSR_API_MSG  m, IN OUT PCSR_REPLY_STATUS  ReplyStatus )

Definition at line 1179 of file server/server.c. References DWORD, and gIdLogon. { /* * Fail if this is not the first call. */ if (gIdLogon != 0) { return (ULONG)STATUS_UNSUCCESSFUL; } gIdLogon = *(DWORD*)m->u.ApiMessageData; UNREFERENCED_PARAMETER(ReplyStatus); return (ULONG)STATUS_SUCCESS; }

ULONG SrvRegisterServicesProcess (  IN OUT PCSR_API_MSG  m, IN OUT PCSR_REPLY_STATUS  ReplyStatus )

Definition at line 2053 of file server/exitwin.c. References BEGIN_LPC_RECV, END_LPC_RECV, EnterCrit, FALSE, gdwServicesProcessId, IsPrivileged(), LeaveCrit, psTcb, and TRUE. { PRIVILEGE_SET psTcb = { 1, PRIVILEGE_SET_ALL_NECESSARY, { SE_TCB_PRIVILEGE, 0 } }; BEGIN_LPC_RECV(REGISTERSERVICESPROCESS); /* * Allow only one services process and then only if it has TCB * privilege. */ EnterCrit(); if ((gdwServicesProcessId != 0) || !IsPrivileged(&psTcb)) { SetLastError(ERROR_ACCESS_DENIED); a->fSuccess = FALSE; } else { gdwServicesProcessId = a->dwProcessId; a->fSuccess = TRUE; } LeaveCrit(); END_LPC_RECV(); }

ULONG SrvWin32HeapFail (  IN OUT PCSR_API_MSG  m, IN OUT PCSR_REPLY_STATUS  ReplyStatus )

Definition at line 1198 of file server/server.c. References _WIN32HEAPFAILMSG::bFail, and PWIN32HEAPFAILMSG. { #if DBG PWIN32HEAPFAILMSG a = (PWIN32HEAPFAILMSG)&m->u.ApiMessageData; Win32HeapFailAllocations(a->bFail); #endif return (ULONG)STATUS_SUCCESS; UNREFERENCED_PARAMETER(m); UNREFERENCED_PARAMETER(ReplyStatus); }

ULONG SrvWin32HeapStat (  IN OUT PCSR_API_MSG  m, IN OUT PCSR_REPLY_STATUS  ReplyStatus )

Definition at line 1214 of file server/server.c. References BOOL, BYTE, _WIN32HEAPSTATMSG::dwLen, _WIN32HEAPSTATMSG::dwMaxTag, DWORD, _WIN32HEAPSTATMSG::phs, PWIN32HEAPSTATMSG, and TRUE. { #if DBG extern DWORD Win32HeapStat(PDBGHEAPSTAT phs, DWORD dwLen, BOOL bNeedTagShift); PWIN32HEAPSTATMSG a = (PWIN32HEAPSTATMSG)&m->u.ApiMessageData; if (!CsrValidateMessageBuffer(m, &a->phs, a->dwLen, sizeof(BYTE))) { return STATUS_INVALID_PARAMETER; } a->dwMaxTag = Win32HeapStat(a->phs, a->dwLen, TRUE); #endif return (ULONG)STATUS_SUCCESS; UNREFERENCED_PARAMETER(m); UNREFERENCED_PARAMETER(ReplyStatus); }

VOID StartRegReadRead (  VOID   )

Definition at line 431 of file server/server.c. References FALSE, hKeyPriority, L, NT_SUCCESS, NtOpenKey(), NULL, RegReadApcProcedure(), and RtlInitUnicodeString(). Referenced by NotificationThread(). { UNICODE_STRING UnicodeString; OBJECT_ATTRIBUTES OA; RtlInitUnicodeString(&UnicodeString, L"\\Registry\\Machine\\System\\CurrentControlSet\\Control\\PriorityControl"); InitializeObjectAttributes(&OA, &UnicodeString, OBJ_CASE_INSENSITIVE, NULL, NULL); if (!NT_SUCCESS(NtOpenKey(&hKeyPriority, KEY_READ | KEY_NOTIFY, &OA))) UserAssert(FALSE); RegReadApcProcedure(NULL, NULL); }

NTSTATUS UserClientConnect (  PCSR_PROCESS  Process, PVOID  ConnectionInformation, PULONG  pulConnectionLen )

Definition at line 357 of file server/server.c. References CsrApiPort, CsrQueryApiPort(), gDispatchTableValues, NTSTATUS(), NtUserProcessConnect(), NtUserSetInformationThread(), NULL, and USERCONNECT. Referenced by UserServerDllInitialization(). { /* * Pass the api port to the kernel. Do this early so the kernel * can send a datagram to CSR to activate a debugger. */ if (CsrApiPort == NULL) { CsrApiPort = CsrQueryApiPort(); NtUserSetInformationThread( NtCurrentThread(), UserThreadCsrApiPort, &CsrApiPort, sizeof(HANDLE)); } UserAssert(*pulConnectionLen == sizeof(USERCONNECT)); if (*pulConnectionLen != sizeof(USERCONNECT)) { return STATUS_INVALID_PARAMETER; } ((PUSERCONNECT)ConnectionInformation)->dwDispatchCount = gDispatchTableValues; return NtUserProcessConnect(Process->ProcessHandle, (PUSERCONNECT)ConnectionInformation, *pulConnectionLen); }

NTSTATUS UserClientShutdown (  PCSR_PROCESS  Process, ULONG  dwFlags, BOOLEAN  fFirstPass )

VOID UserHardError (  PCSR_THREAD  pcsrt, PHARDERROR_MSG  pmsg )

Definition at line 1662 of file w32/ntuser/server/harderr.c. References NULL, UserHardErrorEx(), and VOID(). Referenced by UserServerDllInitialization(). { UserHardErrorEx(pt, pmsg, NULL); }

VOID UserRtlRaiseStatus (  NTSTATUS  Status  )

Definition at line 1296 of file server/server.c. References RtlRaiseStatus(), Status, and VOID(). { RtlRaiseStatus(Status); }

NTSTATUS UserServerDllInitialization (  PCSR_SERVER_DLL  psrvdll  )

Definition at line 192 of file server/server.c. References BaseSetProcessCreateNotify(), BOOL, EnterCrit, FALSE, gcsUserSrv, gdwRIPFlags, gheventCancel, gheventCancelled, ghMediaRequestEvent, ghModuleWin, ghPowerRequestEvent, gpfnAttachRoutine, gpwszaSUCCESS, gpwszaSYSTEM_ERROR, gpwszaSYSTEM_INFORMATION, gpwszaSYSTEM_WARNING, hThreadNotification, ISTS, LeaveCrit, NotificationThread(), NT_SUCCESS, NtCreateEvent(), NTSTATUS(), NtUserInitialize(), NtUserNotifyProcessCreate(), NULL, RIPF_DEFAULT, RtlCreateUserThread(), RtlGetNtGlobalFlags(), RtlInitializeCriticalSection(), RtlLoadStringOrError(), Status, TRUE, UserClientConnect(), UserClientShutdown(), USERCURRENTVERSION, UserHardError(), UserpMaxApiNumber, UserServerApiDispatchTable, UserServerApiServerValidTable, and WinStationAPIInit(). { CLIENT_ID ClientId; BOOL bAllocated; NTSTATUS Status; /* * Initialize the RIP flags to default */ gdwRIPFlags = RIPF_DEFAULT; #if DBG if (RtlGetNtGlobalFlags() & FLG_SHOW_LDR_SNAPS) { RIPMSG0(RIP_WARNING, "UserServerDllInitialization: entered"); } #endif /* * Initialize a critical section structure that will be used to protect * all of the User Server's critical sections (except a few special * cases like the RIT -- see below). */ Status = RtlInitializeCriticalSection(&gcsUserSrv); if (!NT_SUCCESS(Status)) { RIPMSG1(RIP_WARNING, "UserServerDllInitialization: InitializeCriticalSection failed with Status %x", Status); return Status; } EnterCrit(); /* * Remember WINSRV.DLL's hmodule so we can grab resources from it later. */ ghModuleWin = psrvdll->ModuleHandle; psrvdll->ApiNumberBase = USERSRV_FIRST_API_NUMBER; psrvdll->MaxApiNumber = UserpMaxApiNumber; psrvdll->ApiDispatchTable = UserServerApiDispatchTable; if (ISTS()) { UserServerApiServerValidTable[0] = TRUE; // for ExitWindowsEx } psrvdll->ApiServerValidTable = UserServerApiServerValidTable; #if DBG psrvdll->ApiNameTable = UserServerApiNameTable; #else psrvdll->ApiNameTable = NULL; #endif psrvdll->ConnectRoutine = UserClientConnect; psrvdll->HardErrorRoutine = UserHardError; psrvdll->ShutdownProcessRoutine = UserClientShutdown; /* * Create these events used by shutdown */ //BUGBUG we should test the return code of NtCreateEvent NtCreateEvent(&gheventCancel, EVENT_ALL_ACCESS, NULL, NotificationEvent, FALSE); NtCreateEvent(&gheventCancelled, EVENT_ALL_ACCESS, NULL, NotificationEvent, FALSE); /* * Create the event used by the power request code. */ NtCreateEvent(&ghPowerRequestEvent, EVENT_ALL_ACCESS, NULL, SynchronizationEvent, FALSE); /* * Create the event used by the media change code. */ NtCreateEvent(&ghMediaRequestEvent, EVENT_ALL_ACCESS, NULL, SynchronizationEvent, FALSE); /* * Tell the base what user address to call when it is creating a process * (but before the process starts running). */ BaseSetProcessCreateNotify(NtUserNotifyProcessCreate); /* * Load some strings. */ gpwszaSUCCESS = (PWSTR)RtlLoadStringOrError(ghModuleWin, STR_SUCCESS, NULL, &bAllocated, FALSE); gpwszaSYSTEM_INFORMATION = (PWSTR)RtlLoadStringOrError(ghModuleWin, STR_SYSTEM_INFORMATION, NULL, &bAllocated, FALSE); gpwszaSYSTEM_WARNING = (PWSTR)RtlLoadStringOrError(ghModuleWin, STR_SYSTEM_WARNING, NULL, &bAllocated, FALSE); gpwszaSYSTEM_ERROR = (PWSTR)RtlLoadStringOrError(ghModuleWin, STR_SYSTEM_ERROR, NULL, &bAllocated, FALSE); /* * Initialize USER */ { HANDLE hModBase; hModBase = GetModuleHandle(TEXT("kernel32")); UserAssert(hModBase); gpfnAttachRoutine = GetProcAddress(hModBase,"BaseAttachCompleteThunk"); UserAssert(gpfnAttachRoutine); Status = NtUserInitialize(USERCURRENTVERSION, ghPowerRequestEvent, ghMediaRequestEvent); if (!NT_SUCCESS(Status)) { RIPMSG1(RIP_WARNING, "UserServerDllInitialization: NtUserInitialize failed with Status %x", Status); goto ExitUserInit; } } if (ISTS()) { Status = WinStationAPIInit(); if (!NT_SUCCESS(Status)) { RIPMSG1(RIP_WARNING, "UserServerDllInitialization: WinStationAPIInit failed with Status %x", Status); goto ExitUserInit; } } /* * Start registry notification thread */ Status = RtlCreateUserThread(NtCurrentProcess(), NULL, FALSE, 0, 0, 4*0x1000, (PUSER_THREAD_START_ROUTINE)NotificationThread, NULL, &hThreadNotification, &ClientId); if (!NT_SUCCESS(Status)) { RIPMSG1(RIP_WARNING, "UserServerDllInitialization: RtlCreateUserThread failed with Status %x", Status); } CsrAddStaticServerThread(hThreadNotification, &ClientId, 0); ExitUserInit: LeaveCrit(); return Status; }

NTSTATUS WinStationAPIInit (  VOID   )

Definition at line 212 of file api.c. References BOOL, DBGHYD, FALSE, gSessionId, L, NT_SUCCESS, NtResumeThread(), NtSetInformationThread(), NTSTATUS(), NULL, RtlCreateUserThread(), Status, TerminalServerRequestThread(), ThreadHandle, and TRUE. Referenced by UserServerDllInitialization(). { NTSTATUS Status; CLIENT_ID ClientId; HANDLE ThreadHandle; KPRIORITY Priority; #if DBG static BOOL Inited = FALSE; #endif UserAssert(Inited == FALSE); gSessionId = NtCurrentPeb()->SessionId; #if DBG if (Inited) DBGHYD(("WinStationAPIInit called twice !!!\n")); Inited = TRUE; #endif Status = RtlCreateUserThread(NtCurrentProcess(), NULL, TRUE, 0L, 0L, 0L, TerminalServerRequestThread, NULL, &ThreadHandle, &ClientId); if (!NT_SUCCESS(Status)) { DBGHYD(("WinStationAPIInit: failed to create TerminalServerRequestThread\n")); goto Exit; } /* * Add thread to server thread pool */ CsrAddStaticServerThread(ThreadHandle, &ClientId, 0); /* * Boost priority of ICA SRV Request thread */ Priority = THREAD_BASE_PRIORITY_MAX; Status = NtSetInformationThread(ThreadHandle, ThreadBasePriority, &Priority, sizeof(Priority)); if (!NT_SUCCESS(Status)) { DBGHYD(("WinStationAPIInit: failed to set thread priority\n")); goto Exit; } /* * Resume the thread now that we've initialized things. */ NtResumeThread(ThreadHandle, NULL); Exit: return Status; }

---

Variable Documentation

HANDLE CsrApiPort

Definition at line 54 of file server/server.c.

WORD gDispatchTableValues

Definition at line 355 of file server/server.c.

BOOL gfLogon

Definition at line 31 of file server/server.c. Referenced by NotificationThread(), and SrvLogon().

HANDLE ghMediaRequestEvent

Definition at line 34 of file server/server.c. Referenced by NotificationThread(), and UserServerDllInitialization().

HANDLE ghNlsEvent

Definition at line 30 of file server/server.c. Referenced by NotificationThread(), and SrvLogon().

HANDLE ghPowerRequestEvent

Definition at line 33 of file server/server.c. Referenced by NotificationThread(), and UserServerDllInitialization().

FARPROC gpfnAttachRoutine

Definition at line 32 of file server/server.c. Referenced by SrvActivateDebugger(), and UserServerDllInitialization().

CONST ALWAYSZERO gZero

Definition at line 1310 of file server/server.c.

HANDLE hKeyPriority

Definition at line 26 of file server/server.c. Referenced by RegReadApcProcedure(), and StartRegReadRead().

HANDLE hThreadNotification

Definition at line 25 of file server/server.c. Referenced by NotificationThread(), and UserServerDllInitialization().

IO_STATUS_BLOCK IoStatusRegChange

Definition at line 28 of file server/server.c. Referenced by RegReadApcProcedure().

DWORD LastNetDrives

Definition at line 51 of file server/server.c. Referenced by HandleRemoteNetDeviceChangeEvent().

UNICODE_STRING PriorityValueName

Definition at line 27 of file server/server.c.

ULONG RegChangeBuffer

Definition at line 29 of file server/server.c. Referenced by RegReadApcProcedure().

PCSR_API_ROUTINE UserServerApiDispatchTable[UserpMaxApiNumber-UserpExitWindowsEx]

Initial value: { (PCSR_API_ROUTINE)SrvExitWindowsEx, (PCSR_API_ROUTINE)SrvEndTask, (PCSR_API_ROUTINE)SrvLogon, (PCSR_API_ROUTINE)SrvRegisterServicesProcess, (PCSR_API_ROUTINE)SrvActivateDebugger, (PCSR_API_ROUTINE)SrvGetThreadConsoleDesktop, (PCSR_API_ROUTINE)SrvDeviceEvent, (PCSR_API_ROUTINE)SrvRegisterLogonProcess, (PCSR_API_ROUTINE)SrvWin32HeapFail, (PCSR_API_ROUTINE)SrvWin32HeapStat, } Definition at line 107 of file server/server.c. Referenced by UserServerDllInitialization().

BOOLEAN UserServerApiServerValidTable[UserpMaxApiNumber-UserpExitWindowsEx]

Initial value: { FALSE, FALSE, FALSE, FALSE, FALSE, TRUE, FALSE, FALSE, FALSE, FALSE, } Definition at line 120 of file server/server.c. Referenced by UserServerDllInitialization().

---