Intravision/reactos
1
0
Fork 0
mirror of https://github.com/reactos/reactos.git synced 2025-04-21 12:40:33 +00:00
Code Issues Projects Releases Packages Wiki Activity

- Added CsrCreateProcessData.

Browse source 
- Added CsrDuplicateHandle.

svn path=/trunk/; revision=4277
This commit is contained in:
Hartmut Birr 2003-03-09 21:41:35 +00:00
parent 718da6238e
commit 035e6fa830
1 changed files with 82 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

87
reactos/subsys/csrss/api/process.c
View file

@ -1,4 +1,4 @@
/* $Id: process.c,v 1.25 2003/03/05 22:50:24 ekohl Exp $ /* $Id: process.c,v 1.26 2003/03/09 21:41:35 hbirr Exp $
* *
* reactos/subsys/csrss/api/process.c * reactos/subsys/csrss/api/process.c
* *
@ -15,6 +15,9 @@
#include <ntdll/rtl.h> #include <ntdll/rtl.h>
#include "api.h" #include "api.h"
#define NDEBUG
#include <debug.h>
BOOL STDCALL W32kCleanupForProcess( INT Process ); BOOL STDCALL W32kCleanupForProcess( INT Process );
#define LOCK RtlEnterCriticalSection(&ProcessDataLock) #define LOCK RtlEnterCriticalSection(&ProcessDataLock)
@ -48,6 +51,26 @@ PCSRSS_PROCESS_DATA STDCALL CsrGetProcessData(ULONG ProcessId)
pProcessData = ProcessData[hash]; pProcessData = ProcessData[hash];
while (pProcessData && pProcessData->ProcessId != ProcessId)
{
pProcessData = pProcessData->next;
}
UNLOCK;
return pProcessData;
}
PCSRSS_PROCESS_DATA STDCALL CsrCreateProcessData(ULONG ProcessId)
{
ULONG i;
ULONG hash;
PCSRSS_PROCESS_DATA pProcessData;
hash = ProcessId % (sizeof(ProcessData) / sizeof(*ProcessData));
LOCK;
pProcessData = ProcessData[hash];
while (pProcessData && pProcessData->ProcessId != ProcessId) while (pProcessData && pProcessData->ProcessId != ProcessId)
{ {
pProcessData = pProcessData->next; pProcessData = pProcessData->next;
@ -64,6 +87,10 @@ PCSRSS_PROCESS_DATA STDCALL CsrGetProcessData(ULONG ProcessId)
ProcessData[hash] = pProcessData; ProcessData[hash] = pProcessData;
} }
} }
else
{
DPRINT("Process data for pid %d already exist\n", ProcessId);
}
UNLOCK; UNLOCK;
if (pProcessData == NULL) if (pProcessData == NULL)
{ {
@ -148,7 +175,7 @@ CSR_API(CsrCreateProcess)
sizeof(LPC_MESSAGE); sizeof(LPC_MESSAGE);
Reply->Header.MessageSize = sizeof(CSRSS_API_REPLY); Reply->Header.MessageSize = sizeof(CSRSS_API_REPLY);
NewProcessData = CsrGetProcessData(Request->Data.CreateProcessRequest.NewProcessId); NewProcessData = CsrCreateProcessData(Request->Data.CreateProcessRequest.NewProcessId);
if (NewProcessData == NULL) if (NewProcessData == NULL)
{ {
Reply->Status = STATUS_NO_MEMORY; Reply->Status = STATUS_NO_MEMORY;
@ -234,6 +261,11 @@ CSR_API(CsrTerminateProcess)
- sizeof(LPC_MESSAGE); - sizeof(LPC_MESSAGE);
Reply->Header.DataSize = sizeof(CSRSS_API_REPLY); Reply->Header.DataSize = sizeof(CSRSS_API_REPLY);
if (ProcessData == NULL)
{
return(Reply->Status = STATUS_INVALID_PARAMETER);
}
Status = CsrFreeProcessData(ProcessData->ProcessId); Status = CsrFreeProcessData(ProcessData->ProcessId);
Reply->Status = Status; Reply->Status = Status;
@ -257,6 +289,11 @@ CSR_API(CsrGetShutdownParameters)
Reply->Header.DataSize = sizeof(CSRSS_API_REPLY) - Reply->Header.DataSize = sizeof(CSRSS_API_REPLY) -
sizeof(LPC_MESSAGE); sizeof(LPC_MESSAGE);
if (ProcessData == NULL)
{
return(Reply->Status = STATUS_INVALID_PARAMETER);
}
Reply->Data.GetShutdownParametersReply.Level = ProcessData->ShutdownLevel; Reply->Data.GetShutdownParametersReply.Level = ProcessData->ShutdownLevel;
Reply->Data.GetShutdownParametersReply.Flags = ProcessData->ShutdownFlags; Reply->Data.GetShutdownParametersReply.Flags = ProcessData->ShutdownFlags;
@ -271,6 +308,11 @@ CSR_API(CsrSetShutdownParameters)
Reply->Header.DataSize = sizeof(CSRSS_API_REPLY) - Reply->Header.DataSize = sizeof(CSRSS_API_REPLY) -
sizeof(LPC_MESSAGE); sizeof(LPC_MESSAGE);
if (ProcessData == NULL)
{
return(Reply->Status = STATUS_INVALID_PARAMETER);
}
ProcessData->ShutdownLevel = Request->Data.SetShutdownParametersRequest.Level; ProcessData->ShutdownLevel = Request->Data.SetShutdownParametersRequest.Level;
ProcessData->ShutdownFlags = Request->Data.SetShutdownParametersRequest.Flags; ProcessData->ShutdownFlags = Request->Data.SetShutdownParametersRequest.Flags;
@ -352,13 +394,48 @@ CSR_API(CsrVerifyHandle)
Reply->Header.MessageSize = sizeof(CSRSS_API_REPLY); Reply->Header.MessageSize = sizeof(CSRSS_API_REPLY);
Reply->Header.DataSize = sizeof(CSRSS_API_REPLY) - sizeof(LPC_MESSAGE); Reply->Header.DataSize = sizeof(CSRSS_API_REPLY) - sizeof(LPC_MESSAGE);
if (ProcessData == NULL) Reply->Status = CsrVerifyObject(ProcessData, Request->Data.VerifyHandleRequest.Handle);
if (!NT_SUCCESS(Reply->Status))
{ {
Reply->Status = STATUS_INVALID_PARAMETER; DPRINT("CsrVerifyObject failed, status=%x\n", Reply->Status);
}
return Reply->Status;
}
CSR_API(CsrDuplicateHandle)
{
Object_t *Object;
Reply->Header.MessageSize = sizeof(CSRSS_API_REPLY);
Reply->Header.DataSize = sizeof(CSRSS_API_REPLY) - sizeof(LPC_MESSAGE);
ProcessData = CsrGetProcessData(Request->Data.DuplicateHandleRequest.ProcessId);
Reply->Status = CsrGetObject(ProcessData, Request->Data.DuplicateHandleRequest.Handle, &Object);
if (!NT_SUCCESS(Reply->Status))
{
DPRINT("CsrGetObject failed, status=%x\n", Reply->Status);
} }
else else
{ {
Reply->Status = CsrVerifyObject(ProcessData, Request->Data.VerifyHandleRequest.Handle); if (Object->Type == CSRSS_CONSOLE_MAGIC)
{
Reply->Status = CsrInsertObject(ProcessData,
&Reply->Data.DuplicateHandleReply.Handle,
(Object_t *)ProcessData->Console);
}
else if (Object->Type == CSRSS_SCREEN_BUFFER_MAGIC)
{
RtlEnterCriticalSection( &ActiveConsoleLock );
Reply->Status = CsrInsertObject(ProcessData,
&Reply->Data.DuplicateHandleReply.Handle,
&(ProcessData->Console->ActiveBuffer->Header));
RtlLeaveCriticalSection( &ActiveConsoleLock );
}
else
{
Reply->Status = STATUS_INVALID_PARAMETER;
}
} }
return Reply->Status; return Reply->Status;
} }