Intravision/reactos
1
0
Fork 0
mirror of https://github.com/reactos/reactos.git synced 2025-08-05 14:53:40 +00:00
Code Issues Projects Releases Packages Wiki Activity

First draft of a ScmNamedPipeListenerThread implementation.

Browse source 
Some debug noise from winlogon and as always edited an ignore file.

svn path=/trunk/; revision=3898
This commit is contained in:
Robert Dickenson 2002-12-27 13:54:28 +00:00
parent e464b1cd43
commit 70544cdae0
3 changed files with 298 additions and 244 deletions
Download patch file Download diff file Expand all files Collapse all files

153
reactos/subsys/system/services/services.c
View file

@ -1,4 +1,4 @@
/* $Id: services.c,v 1.9 2002/10/20 14:54:34 ekohl Exp $ /* $Id: services.c,v 1.10 2002/12/27 13:54:28 robd Exp $
* *
* service control manager * service control manager
* *
@ -74,27 +74,20 @@ ScmCreateStartEvent(PHANDLE StartEvent)
TRUE, TRUE,
FALSE, FALSE,
_T("SvcctrlStartEvent_A3725DX")); _T("SvcctrlStartEvent_A3725DX"));
if (hEvent == NULL) if (hEvent == NULL) {
{ if (GetLastError() == ERROR_ALREADY_EXISTS) {
if (GetLastError() == ERROR_ALREADY_EXISTS)
{
hEvent = OpenEvent(EVENT_ALL_ACCESS, hEvent = OpenEvent(EVENT_ALL_ACCESS,
FALSE, FALSE,
_T("SvcctrlStartEvent_A3725DX")); _T("SvcctrlStartEvent_A3725DX"));
if (hEvent == NULL) if (hEvent == NULL) {
{ return FALSE;
return(FALSE); }
} else {
return FALSE;
} }
} }
else
{
return(FALSE);
}
}
*StartEvent = hEvent; *StartEvent = hEvent;
return TRUE;
return(TRUE);
} }
@ -108,15 +101,13 @@ ScmNamedPipeHandleRequest(
DbgPrint("SCM READ: %s\n", Request); DbgPrint("SCM READ: %s\n", Request);
*ReplySize = 0; *ReplySize = 0;
return FALSE; return FALSE;
} }
DWORD DWORD
WINAPI WINAPI
ScmNamedPipeThread( ScmNamedPipeThread(LPVOID Context)
LPVOID Context)
{ {
CHAR chRequest[PIPE_BUFSIZE]; CHAR chRequest[PIPE_BUFSIZE];
CHAR chReply[PIPE_BUFSIZE]; CHAR chReply[PIPE_BUFSIZE];
@ -126,46 +117,38 @@ ScmNamedPipeThread(
BOOL fSuccess; BOOL fSuccess;
HANDLE hPipe; HANDLE hPipe;
DPRINT("Accepting SCM commands through named pipe\n");
hPipe = (HANDLE)Context; hPipe = (HANDLE)Context;
for (;;) DPRINT("ScmNamedPipeThread(%x) - Accepting SCM commands through named pipe\n", hPipe);
{
fSuccess = ReadFile( for (;;) {
hPipe, fSuccess = ReadFile(hPipe,
&chRequest, &chRequest,
PIPE_BUFSIZE, PIPE_BUFSIZE,
&cbBytesRead, &cbBytesRead,
NULL); NULL);
if (!fSuccess || cbBytesRead == 0) if (!fSuccess || cbBytesRead == 0) {
{
break; break;
} }
if (ScmNamedPipeHandleRequest(&chRequest, cbBytesRead, &chReply, &cbReplyBytes)) {
if (ScmNamedPipeHandleRequest(&chRequest, cbBytesRead, &chReply, &cbReplyBytes)) fSuccess = WriteFile(hPipe,
{
fSuccess = WriteFile(
hPipe,
&chReply, &chReply,
cbReplyBytes, cbReplyBytes,
&cbWritten, &cbWritten,
NULL); NULL);
if (!fSuccess || cbReplyBytes != cbWritten) if (!fSuccess || cbReplyBytes != cbWritten) {
{
break; break;
} }
} }
} }
DPRINT("ScmNamedPipeThread(%x) - Disconnecting named pipe connection\n", hPipe);
FlushFileBuffers(hPipe); FlushFileBuffers(hPipe);
DisconnectNamedPipe(hPipe); DisconnectNamedPipe(hPipe);
CloseHandle(hPipe); CloseHandle(hPipe);
DPRINT("ScmNamedPipeThread(%x) - Done.\n", hPipe);
return ERROR_SUCCESS; return ERROR_SUCCESS;
} }
BOOL ScmCreateNamedPipe(VOID) BOOL ScmCreateNamedPipe(VOID)
{ {
DWORD dwThreadId; DWORD dwThreadId;
@ -173,6 +156,8 @@ BOOL ScmCreateNamedPipe(VOID)
HANDLE hThread; HANDLE hThread;
HANDLE hPipe; HANDLE hPipe;
DPRINT("ScmCreateNamedPipe() - CreateNamedPipe(\"\\\\.\\pipe\\Ntsvcs\")\n");
hPipe = CreateNamedPipe("\\\\.\\pipe\\Ntsvcs", hPipe = CreateNamedPipe("\\\\.\\pipe\\Ntsvcs",
PIPE_ACCESS_DUPLEX, PIPE_ACCESS_DUPLEX,
PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT, PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
@ -181,44 +166,82 @@ BOOL ScmCreateNamedPipe(VOID)
PIPE_BUFSIZE, PIPE_BUFSIZE,
PIPE_TIMEOUT, PIPE_TIMEOUT,
NULL); NULL);
if (hPipe == INVALID_HANDLE_VALUE) if (hPipe == INVALID_HANDLE_VALUE) {
{
DPRINT("CreateNamedPipe() failed (%d)\n", GetLastError()); DPRINT("CreateNamedPipe() failed (%d)\n", GetLastError());
return(FALSE); return FALSE;
} }
DPRINT("CreateNamedPipe() - calling ConnectNamedPipe(%x)\n", hPipe);
fConnected = ConnectNamedPipe(hPipe, fConnected = ConnectNamedPipe(hPipe,
NULL) ? TRUE : (GetLastError() == ERROR_PIPE_CONNECTED); NULL) ? TRUE : (GetLastError() == ERROR_PIPE_CONNECTED);
if (fConnected) DPRINT("CreateNamedPipe() - ConnectNamedPipe() returned %d\n", fConnected);
{
DPRINT("Pipe connected\n");
if (fConnected) {
DPRINT("Pipe connected\n");
hThread = CreateThread(NULL, hThread = CreateThread(NULL,
0, 0,
ScmNamedPipeThread, ScmNamedPipeThread,
(LPVOID)hPipe, (LPVOID)hPipe,
0, 0,
&dwThreadId); &dwThreadId);
if (!hThread) if (!hThread) {
{
DPRINT("Could not create thread (%d)\n", GetLastError()); DPRINT("Could not create thread (%d)\n", GetLastError());
DisconnectNamedPipe(hPipe); DisconnectNamedPipe(hPipe);
CloseHandle(hPipe); CloseHandle(hPipe);
return(FALSE); DPRINT("CreateNamedPipe() - returning FALSE\n");
}
}
else
{
DPRINT("Pipe not connected\n");
CloseHandle(hPipe);
return FALSE; return FALSE;
} }
} else {
DPRINT("Pipe not connected\n");
CloseHandle(hPipe);
DPRINT("CreateNamedPipe() - returning FALSE\n");
return FALSE;
}
DPRINT("CreateNamedPipe() - returning TRUE\n");
return TRUE; return TRUE;
} }
DWORD
WINAPI
ScmNamedPipeListenerThread(LPVOID Context)
{
// HANDLE hPipe;
DPRINT("ScmNamedPipeListenerThread(%x) - aka SCM.\n", Context);
// hPipe = (HANDLE)Context;
for (;;) {
PrintString("SCM: Waiting for connection on named pipe...\n");
/* Create named pipe */
if (!ScmCreateNamedPipe()) {
PrintString("\nSCM: Failed to create named pipe\n");
break;
//ExitThread(0);
}
PrintString("\nSCM: named pipe session created.\n");
Sleep(10);
}
DPRINT("\n\nWARNING: ScmNamedPipeListenerThread(%x) - Aborted.\n\n", Context);
return ERROR_SUCCESS;
}
BOOL StartScmNamedPipeThreadListener(void)
{
DWORD dwThreadId;
HANDLE hThread;
hThread = CreateThread(NULL,
0,
ScmNamedPipeListenerThread,
NULL, /*(LPVOID)hPipe,*/
0,
&dwThreadId);
if (!hThread) {
PrintString("SERVICES: Could not create thread (Status %lx)\n", GetLastError());
return FALSE;
}
return TRUE;
}
int STDCALL int STDCALL
WinMain(HINSTANCE hInstance, WinMain(HINSTANCE hInstance,
@ -230,7 +253,7 @@ WinMain(HINSTANCE hInstance,
HANDLE hEvent; HANDLE hEvent;
NTSTATUS Status; NTSTATUS Status;
PrintString("Service Control Manager\n"); PrintString("SERVICES: Service Control Manager\n");
/* Create start event */ /* Create start event */
if (!ScmCreateStartEvent(&hScmStartEvent)) if (!ScmCreateStartEvent(&hScmStartEvent))
@ -239,6 +262,7 @@ WinMain(HINSTANCE hInstance,
ExitThread(0); ExitThread(0);
} }
PrintString("SERVICES: created start event with handle %x.\n", hScmStartEvent);
/* FIXME: more initialization */ /* FIXME: more initialization */
@ -247,7 +271,7 @@ WinMain(HINSTANCE hInstance,
Status = ScmCreateServiceDataBase(); Status = ScmCreateServiceDataBase();
if (!NT_SUCCESS(Status)) if (!NT_SUCCESS(Status))
{ {
PrintString("ScmCreateServiceDataBase() failed (Status %lx)\n", Status); PrintString("SERVICES: failed to create SCM database (Status %lx)\n", Status);
ExitThread(0); ExitThread(0);
} }
@ -255,12 +279,20 @@ WinMain(HINSTANCE hInstance,
ScmGetBootAndSystemDriverState(); ScmGetBootAndSystemDriverState();
#if 0 #if 0
PrintString("SERVICES: Attempting to create named pipe...\n");
/* Create named pipe */ /* Create named pipe */
if (!ScmCreateNamedPipe()) if (!ScmCreateNamedPipe()) {
{
PrintString("SERVICES: Failed to create named pipe\n"); PrintString("SERVICES: Failed to create named pipe\n");
ExitThread(0); ExitThread(0);
} }
PrintString("SERVICES: named pipe created successfully.\n");
#else
PrintString("SERVICES: Attempting to create named pipe listener...\n");
if (!StartScmNamedPipeThreadListener()) {
PrintString("SERVICES: Failed to create named pipe listener thread.\n");
ExitThread(0);
}
PrintString("SERVICES: named pipe listener thread created.\n");
#endif #endif
/* FIXME: create listener thread for pipe */ /* FIXME: create listener thread for pipe */
@ -285,9 +317,10 @@ WinMain(HINSTANCE hInstance,
PrintString("SERVICES: Running.\n"); PrintString("SERVICES: Running.\n");
#if 1
hEvent = CreateEvent(NULL, TRUE, FALSE, NULL); hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
WaitForSingleObject(hEvent, INFINITE); WaitForSingleObject(hEvent, INFINITE);
#if 0 #else
for (;;) for (;;)
{ {
NtYieldExecution(); NtYieldExecution();

34
reactos/subsys/system/winlogon/winlogon.c
View file

@ -1,4 +1,4 @@
/* $Id: winlogon.c,v 1.12 2002/09/08 10:23:48 chorns Exp $ /* $Id: winlogon.c,v 1.13 2002/12/27 13:54:28 robd Exp $
* *
* COPYRIGHT: See COPYING in the top level directory * COPYRIGHT: See COPYING in the top level directory
* PROJECT: ReactOS kernel * PROJECT: ReactOS kernel
@ -18,7 +18,7 @@
#include <wchar.h> #include <wchar.h>
#define NDEBUG #define DBG
#include <debug.h> #include <debug.h>
/* GLOBALS ******************************************************************/ /* GLOBALS ******************************************************************/
@ -64,6 +64,8 @@ BOOLEAN StartServices(VOID)
StartupInfo.cbReserved2 = 0; StartupInfo.cbReserved2 = 0;
StartupInfo.lpReserved2 = 0; StartupInfo.lpReserved2 = 0;
PrintString("WL: Creating new process - \"services.exe\".\n");
Result = CreateProcess(CommandLine, Result = CreateProcess(CommandLine,
NULL, NULL,
NULL, NULL,
@ -85,6 +87,7 @@ BOOLEAN StartServices(VOID)
{ {
Sleep(1000); Sleep(1000);
//DbgPrint("WL: Attempting to open event \"SvcctrlStartEvent_A3725DX\"\n");
ServicesInitEvent = OpenEvent(EVENT_ALL_ACCESS, //SYNCHRONIZE, ServicesInitEvent = OpenEvent(EVENT_ALL_ACCESS, //SYNCHRONIZE,
FALSE, FALSE,
"SvcctrlStartEvent_A3725DX"); "SvcctrlStartEvent_A3725DX");
@ -94,9 +97,18 @@ BOOLEAN StartServices(VOID)
} }
} }
if (ServicesInitEvent == NULL)
{
DbgPrint("WL: Failed to open event \"SvcctrlStartEvent_A3725DX\"\n");
return FALSE;
}
/* wait for event signalization */ /* wait for event signalization */
//DbgPrint("WL: Waiting forever on event handle: %x\n", ServicesInitEvent);
WaitForSingleObject(ServicesInitEvent, INFINITE); WaitForSingleObject(ServicesInitEvent, INFINITE);
//DbgPrint("WL: Closing event object \"SvcctrlStartEvent_A3725DX\"\n");
CloseHandle(ServicesInitEvent); CloseHandle(ServicesInitEvent);
DbgPrint("WL: StartServices() Done.\n");
return TRUE; return TRUE;
} }
@ -116,7 +128,7 @@ BOOLEAN StartLsass(VOID)
if (LsassInitEvent == NULL) if (LsassInitEvent == NULL)
{ {
DbgPrint("Failed to create lsass notification event\n"); DbgPrint("WL: Failed to create lsass notification event\n");
return(FALSE); return(FALSE);
} }
@ -230,7 +242,7 @@ WinMain(HINSTANCE hInstance,
CreateWindowStationW(L"WinSta0", 0, GENERIC_ALL, NULL); CreateWindowStationW(L"WinSta0", 0, GENERIC_ALL, NULL);
if (InteractiveWindowStation == NULL) if (InteractiveWindowStation == NULL)
{ {
DbgPrint("Failed to create window station (0x%X)\n", GetLastError()); DbgPrint("WL: Failed to create window station (0x%X)\n", GetLastError());
NtRaiseHardError(STATUS_SYSTEM_PROCESS_TERMINATED, 0, 0, 0, 0, 0); NtRaiseHardError(STATUS_SYSTEM_PROCESS_TERMINATED, 0, 0, 0, 0, 0);
ExitProcess(1); ExitProcess(1);
} }
@ -287,15 +299,23 @@ WinMain(HINSTANCE hInstance,
Success = SwitchDesktop(ApplicationDesktop); Success = SwitchDesktop(ApplicationDesktop);
if (!Success) if (!Success)
{ {
DbgPrint("Cannot switch to Winlogon desktop (0x%X)\n", GetLastError()); DbgPrint("WL: Cannot switch to Winlogon desktop (0x%X)\n", GetLastError());
} }
AllocConsole(); AllocConsole();
SetConsoleTitle( "Winlogon" ); SetConsoleTitle( "Winlogon" );
/* start system processes (services.exe & lsass.exe) */ /* start system processes (services.exe & lsass.exe) */
StartServices(); Success = StartServices();
if (!Success)
{
DbgPrint("WL: Failed to Start Services (0x%X)\n", GetLastError());
}
#if 0 #if 0
StartLsass(); Success = StartLsass();
if (!Success)
{
DbgPrint("WL: Failed to Start Security System (0x%X)\n", GetLastError());
}
#endif #endif
/* FIXME: What name does the real WinLogon use? */ /* FIXME: What name does the real WinLogon use? */

5
reactos/subsys/win32k/.cvsignore
View file

@ -1,8 +1,9 @@
base.tmp base.tmp
junk.tmp junk.tmp
temp.exp temp.exp
win32k.coff
win32k.sys win32k.sys
win32k.nostrip.sys
win32k.coff
win32k.sym
*.d *.d
*.o *.o
*.sym