Intravision/reactos
1
0
Fork 0
mirror of https://github.com/reactos/reactos.git synced 2025-02-24 09:25:10 +00:00
Code Issues Projects Releases Packages Wiki Activity

Create named pipe for SCM

Browse source 
svn path=/trunk/; revision=2312
This commit is contained in:
Casper Hornstrup 2001-10-21 19:09:06 +00:00
parent 7cb3efcca8
commit f238a86a0b
1 changed files with 140 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -1,4 +1,4 @@
/* $Id: services.c,v 1.3 2001/03/26 20:46:52 dwelch Exp $
/* $Id: services.c,v 1.4 2001/10/21 19:09:06 chorns Exp $
*
* service control manager
*
@ -31,12 +31,16 @@
#define NTOS_MODE_USER
#include <ntos.h>
#include <windows.h>
#include <services/services.h>
#define NDEBUG
#include <debug.h>
/* GLOBALS ******************************************************************/
#define PIPE_BUFSIZE 1024
#define PIPE_TIMEOUT 1000
/* FUNCTIONS *****************************************************************/
@ -50,7 +54,7 @@ void PrintString (char* fmt,...)
vsprintf(buffer, fmt, ap);
va_end(ap);
OutputDebugString(buffer);
OutputDebugStringA(buffer);
}
@ -86,6 +90,131 @@ BOOL ScmCreateStartEvent(PHANDLE StartEvent)
}
BOOL
ScmNamedPipeHandleRequest(
PVOID Request,
DWORD RequestSize,
PVOID Reply,
LPDWORD ReplySize)
{
DbgPrint("SCM READ: %s\n", Request);
*ReplySize = 0;
return FALSE;
}
DWORD
WINAPI
ScmNamedPipeThread(
LPVOID Context)
{
CHAR chRequest[PIPE_BUFSIZE];
CHAR chReply[PIPE_BUFSIZE];
DWORD cbReplyBytes;
DWORD cbBytesRead;
DWORD cbWritten;
BOOL fSuccess;
HANDLE hPipe;
DPRINT("Accepting SCM commands through named pipe\n");
hPipe = (HANDLE)Context;
for (;;)
{
fSuccess = ReadFile(
hPipe,
&chRequest,
PIPE_BUFSIZE,
&cbBytesRead,
NULL);
if (!fSuccess || cbBytesRead == 0)
{
break;
}
if (ScmNamedPipeHandleRequest(&chRequest, cbBytesRead, &chReply, &cbReplyBytes))
{
fSuccess = WriteFile(
hPipe,
&chReply,
cbReplyBytes,
&cbWritten,
NULL);
if (!fSuccess || cbReplyBytes != cbWritten)
{
break;
}
}
}
FlushFileBuffers(hPipe);
DisconnectNamedPipe(hPipe);
CloseHandle(hPipe);
return ERROR_SUCCESS;
}
BOOL ScmCreateNamedPipe(VOID)
{
DWORD dwThreadId;
BOOL fConnected;
HANDLE hThread;
HANDLE hPipe;
hPipe = CreateNamedPipe(
"\\\\.\\pipe\\Ntsvcs",
PIPE_ACCESS_DUPLEX,
PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
PIPE_UNLIMITED_INSTANCES,
PIPE_BUFSIZE,
PIPE_BUFSIZE,
PIPE_TIMEOUT,
NULL);
if (hPipe == INVALID_HANDLE_VALUE)
{
DPRINT("CreateNamedPipe() failed (%d)\n", GetLastError());
return FALSE;
}
fConnected = ConnectNamedPipe(
hPipe,
NULL) ? TRUE : (GetLastError() == ERROR_PIPE_CONNECTED);
if (fConnected)
{
DPRINT("Pipe connected\n");
hThread = CreateThread(
NULL,
0,
ScmNamedPipeThread,
(LPVOID)hPipe,
0,
&dwThreadId);
if (!hThread)
{
DPRINT("Could not create thread (%d)\n", GetLastError());
DisconnectNamedPipe(hPipe);
CloseHandle(hPipe);
return FALSE;
}
}
else
{
DPRINT("Pipe not connected\n");
CloseHandle(hPipe);
return FALSE;
}
return TRUE;
}
int STDCALL
WinMain(HINSTANCE hInstance,
HINSTANCE hPrevInstance,
@ -114,9 +243,14 @@ WinMain(HINSTANCE hInstance,
/* FIXME: update service database */
// ScmGetBootAndSystemDriverState();
/* FIXME: create pipe "\Pipe\Ntsvcs" */
#if 0
/* Create named pipe */
if (!ScmCreateNamedPipe())
{
PrintString("SERVICES: Failed to create named pipe\n");
ExitThread(0);
}
#endif
/* FIXME: create listener thread for pipe */
/* FIXME: register process as service process */