1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
/********************************************************/
/* ntapi: Native API core library */
/* Copyright (C) 2013--2021 SysDeer Technologies, LLC */
/* Released under GPLv2 and GPLv3; see COPYING.NTAPI. */
/********************************************************/
#include <psxtypes/psxtypes.h>
#include <ntapi/nt_file.h>
#include <ntapi/nt_string.h>
#include <ntapi/nt_tty.h>
#include <ntapi/ntapi.h>
#include "ntapi_impl.h"
int32_t __stdcall __ntapi_ipc_create_pipe_v2(
__out void ** hpipe_read,
__out void ** hpipe_write,
__in uint32_t advisory_buffer_size)
{
int32_t status;
void * hdevpipes;
void * hwrite;
void * hread;
nt_object_attributes oa;
nt_io_status_block iosb;
nt_sqos sqos;
nt_unicode_string nt_name;
nt_timeout timeout;
const wchar16_t pipe_dir[] = {
'\\','D','e','v','i','c','e',
'\\','N','a','m','e','d','P','i','p','e','\\',0
};
/* nt_name: pipe device directory */
nt_name.strlen = (uint16_t)(sizeof(pipe_dir) - sizeof(wchar16_t));
nt_name.maxlen = 0;
nt_name.buffer = (uint16_t *)pipe_dir;
/* init security structure */
sqos.length = sizeof(sqos);
sqos.impersonation_level = NT_SECURITY_ANONYMOUS;
sqos.context_tracking_mode = NT_SECURITY_TRACKING_STATIC;
sqos.effective_only = 1;
/* oa */
oa.len = sizeof(oa);
oa.root_dir = (void *)0;
oa.obj_name = &nt_name;
oa.obj_attr = NT_OBJ_CASE_INSENSITIVE | NT_OBJ_INHERIT;
oa.sec_desc = (nt_security_descriptor *)0;
oa.sec_qos = &sqos;
if ((status = __ntapi->zw_open_file(
&hdevpipes,
NT_GENERIC_READ | NT_SEC_SYNCHRONIZE,
&oa,
&iosb,
NT_FILE_SHARE_READ | NT_FILE_SHARE_WRITE,
NT_FILE_DIRECTORY_FILE)))
return status;
timeout.ihigh = 0xffffffff;
timeout.ulow = 0x0;
oa.root_dir = hdevpipes;
nt_name.strlen = 0;
nt_name.buffer = 0;
status = __ntapi->zw_create_named_pipe_file(
&hread,
NT_GENERIC_READ | NT_SEC_SYNCHRONIZE | NT_FILE_WRITE_ATTRIBUTES,
&oa,
&iosb,
NT_FILE_SHARE_READ | NT_FILE_SHARE_WRITE,
NT_FILE_CREATE,
NT_FILE_ASYNCHRONOUS_IO,
NT_FILE_PIPE_BYTE_STREAM_TYPE,
NT_FILE_PIPE_BYTE_STREAM_MODE,
NT_FILE_PIPE_QUEUE_OPERATION,
1,
advisory_buffer_size,
advisory_buffer_size,
&timeout);
__ntapi->zw_close(
hdevpipes);
if (status)
return status;
/* the pipe is now our root directory */
oa.root_dir = hread;
status = __ntapi->zw_open_file(
&hwrite,
NT_GENERIC_WRITE | NT_SEC_SYNCHRONIZE | NT_FILE_READ_ATTRIBUTES,
&oa,
&iosb,
NT_FILE_SHARE_READ | NT_FILE_SHARE_WRITE,
NT_FILE_WRITE_THROUGH | NT_FILE_SYNCHRONOUS_IO_ALERT | NT_FILE_NON_DIRECTORY_FILE);
if (status) {
__ntapi->zw_close(hread);
return status;
}
*hpipe_read = hread;
*hpipe_write = hwrite;
return status;
}
|
