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

atomically increment the pipe id to be thread-safe. Thanks to Mark Grosberg for reporting it.

Browse source 
svn path=/trunk/; revision=11240
This commit is contained in:
Thomas Bluemel 2004-10-08 21:48:46 +00:00
parent d02f400b31
commit 6961ff9728
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
reactos/lib/kernel32/file/pipe.c
View file

@ -1,4 +1,4 @@
/* $Id: pipe.c,v 1.10 2004/01/23 21:16:03 ekohl Exp $ /* $Id: pipe.c,v 1.11 2004/10/08 21:48:46 weiden Exp $
* *
* COPYRIGHT: See COPYING in the top level directory * COPYRIGHT: See COPYING in the top level directory
* PROJECT: ReactOS system libraries * PROJECT: ReactOS system libraries
@ -37,15 +37,16 @@ BOOL STDCALL CreatePipe(PHANDLE hReadPipe,
NTSTATUS Status; NTSTATUS Status;
HANDLE ReadPipeHandle; HANDLE ReadPipeHandle;
HANDLE WritePipeHandle; HANDLE WritePipeHandle;
ULONG PipeId;
PSECURITY_DESCRIPTOR SecurityDescriptor = NULL; PSECURITY_DESCRIPTOR SecurityDescriptor = NULL;
DefaultTimeout.QuadPart = 300000000; /* 30 seconds */ DefaultTimeout.QuadPart = 300000000; /* 30 seconds */
ProcessPipeId++; PipeId = (ULONG)InterlockedIncrement((LONG*)&ProcessPipeId);
swprintf(Buffer, swprintf(Buffer,
L"\\Device\\NamedPipe\\Win32Pipes.%08x.%08x", L"\\Device\\NamedPipe\\Win32Pipes.%08x.%08x",
NtCurrentTeb()->Cid.UniqueProcess, NtCurrentTeb()->Cid.UniqueProcess,
ProcessPipeId); PipeId);
RtlInitUnicodeString (&PipeName, RtlInitUnicodeString (&PipeName,
Buffer); Buffer);