- register the checklist window class when attached to a process
[reactos.git] / reactos / lib / kernel32 / file / pipe.c
1 /* $Id$
2 *
3 * COPYRIGHT: See COPYING in the top level directory
4 * PROJECT: ReactOS system libraries
5 * FILE: lib/kernel32/file/create.c
6 * PURPOSE: Directory functions
7 * PROGRAMMER: Ariadne ( ariadne@xs4all.nl)
8 * UPDATE HISTORY:
9 */
10
11 /* INCLUDES *****************************************************************/
12
13 #include <k32.h>
14
15 #define NDEBUG
16 #include "../include/debug.h"
17
18 /* GLOBALS ******************************************************************/
19
20 ULONG ProcessPipeId = 0;
21
22 /* FUNCTIONS ****************************************************************/
23
24 /*
25 * @implemented
26 */
27 BOOL STDCALL CreatePipe(PHANDLE hReadPipe,
28 PHANDLE hWritePipe,
29 LPSECURITY_ATTRIBUTES lpPipeAttributes,
30 DWORD nSize)
31 {
32 WCHAR Buffer[64];
33 UNICODE_STRING PipeName;
34 OBJECT_ATTRIBUTES ObjectAttributes;
35 IO_STATUS_BLOCK StatusBlock;
36 LARGE_INTEGER DefaultTimeout;
37 NTSTATUS Status;
38 HANDLE ReadPipeHandle;
39 HANDLE WritePipeHandle;
40 ULONG PipeId;
41 ULONG Attributes;
42 PSECURITY_DESCRIPTOR SecurityDescriptor = NULL;
43
44 DefaultTimeout.QuadPart = 300000000; /* 30 seconds */
45
46 PipeId = (ULONG)InterlockedIncrement((LONG*)&ProcessPipeId);
47 swprintf(Buffer,
48 L"\\Device\\NamedPipe\\Win32Pipes.%08x.%08x",
49 NtCurrentTeb()->Cid.UniqueProcess,
50 PipeId);
51 RtlInitUnicodeString (&PipeName,
52 Buffer);
53
54 Attributes = OBJ_CASE_INSENSITIVE;
55 if (lpPipeAttributes)
56 {
57 SecurityDescriptor = lpPipeAttributes->lpSecurityDescriptor;
58 if (lpPipeAttributes->bInheritHandle)
59 Attributes |= OBJ_INHERIT;
60 }
61
62 /* use default buffer size if desired */
63 if (nSize == 0) nSize = 0x1000;
64
65 InitializeObjectAttributes(&ObjectAttributes,
66 &PipeName,
67 Attributes,
68 NULL,
69 SecurityDescriptor);
70
71 Status = NtCreateNamedPipeFile(&ReadPipeHandle,
72 FILE_GENERIC_READ | FILE_WRITE_ATTRIBUTES | SYNCHRONIZE,
73 &ObjectAttributes,
74 &StatusBlock,
75 FILE_SHARE_READ | FILE_SHARE_WRITE,
76 FILE_CREATE,
77 FILE_SYNCHRONOUS_IO_NONALERT,
78 FALSE,
79 FALSE,
80 FALSE,
81 1,
82 nSize,
83 nSize,
84 &DefaultTimeout);
85 if (!NT_SUCCESS(Status))
86 {
87 SetLastErrorByStatus(Status);
88 return FALSE;
89 }
90
91 Status = NtOpenFile(&WritePipeHandle,
92 FILE_GENERIC_WRITE | SYNCHRONIZE,
93 &ObjectAttributes,
94 &StatusBlock,
95 FILE_SHARE_READ | FILE_SHARE_WRITE,
96 FILE_SYNCHRONOUS_IO_NONALERT | FILE_NON_DIRECTORY_FILE);
97 if (!NT_SUCCESS(Status))
98 {
99 NtClose(ReadPipeHandle);
100 SetLastErrorByStatus(Status);
101 return FALSE;
102 }
103
104 *hReadPipe = ReadPipeHandle;
105 *hWritePipe = WritePipeHandle;
106
107 return TRUE;
108 }
109
110 /* EOF */