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
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
|
// pipes.hpp --------------------------------------------------------------//
// Copyright 2016 Klemens D. Morgenstern
// Copyright 2016 Andrey Semashev
// Distributed under the Boost Software License, Version 1.0.
// See http://www.boost.org/LICENSE_1_0.txt
#ifndef BOOST_DETAIL_WINAPI_PIPES_HPP_
#define BOOST_DETAIL_WINAPI_PIPES_HPP_
#include <boost/detail/winapi/basic_types.hpp>
#include <boost/detail/winapi/config.hpp>
#include <boost/detail/winapi/overlapped.hpp>
#include <boost/predef/platform.h>
#ifdef BOOST_HAS_PRAGMA_ONCE
#pragma once
#endif
#if BOOST_PLAT_WINDOWS_DESKTOP
#if !defined( BOOST_USE_WINDOWS_H )
extern "C" {
BOOST_SYMBOL_IMPORT boost::detail::winapi::BOOL_ WINAPI ImpersonateNamedPipeClient(
boost::detail::winapi::HANDLE_ hNamedPipe);
BOOST_SYMBOL_IMPORT boost::detail::winapi::BOOL_ WINAPI CreatePipe(
boost::detail::winapi::PHANDLE_ hReadPipe,
boost::detail::winapi::PHANDLE_ hWritePipe,
_SECURITY_ATTRIBUTES* lpPipeAttributes,
boost::detail::winapi::DWORD_ nSize);
BOOST_SYMBOL_IMPORT boost::detail::winapi::BOOL_ WINAPI ConnectNamedPipe(
boost::detail::winapi::HANDLE_ hNamedPipe,
_OVERLAPPED* lpOverlapped);
BOOST_SYMBOL_IMPORT boost::detail::winapi::BOOL_ WINAPI DisconnectNamedPipe(
boost::detail::winapi::HANDLE_ hNamedPipe);
BOOST_SYMBOL_IMPORT boost::detail::winapi::BOOL_ WINAPI SetNamedPipeHandleState(
boost::detail::winapi::HANDLE_ hNamedPipe,
boost::detail::winapi::LPDWORD_ lpMode,
boost::detail::winapi::LPDWORD_ lpMaxCollectionCount,
boost::detail::winapi::LPDWORD_ lpCollectDataTimeout);
BOOST_SYMBOL_IMPORT boost::detail::winapi::BOOL_ WINAPI PeekNamedPipe(
boost::detail::winapi::HANDLE_ hNamedPipe,
boost::detail::winapi::LPVOID_ lpBuffer,
boost::detail::winapi::DWORD_ nBufferSize,
boost::detail::winapi::LPDWORD_ lpBytesRead,
boost::detail::winapi::LPDWORD_ lpTotalBytesAvail,
boost::detail::winapi::LPDWORD_ lpBytesLeftThisMessage);
BOOST_SYMBOL_IMPORT boost::detail::winapi::BOOL_ WINAPI TransactNamedPipe(
boost::detail::winapi::HANDLE_ hNamedPipe,
boost::detail::winapi::LPVOID_ lpInBuffer,
boost::detail::winapi::DWORD_ nInBufferSize,
boost::detail::winapi::LPVOID_ lpOutBuffer,
boost::detail::winapi::DWORD_ nOutBufferSize,
boost::detail::winapi::LPDWORD_ lpBytesRead,
_OVERLAPPED* lpOverlapped);
#if !defined( BOOST_NO_ANSI_APIS )
BOOST_SYMBOL_IMPORT boost::detail::winapi::HANDLE_ WINAPI CreateNamedPipeA(
boost::detail::winapi::LPCSTR_ lpName,
boost::detail::winapi::DWORD_ dwOpenMode,
boost::detail::winapi::DWORD_ dwPipeMode,
boost::detail::winapi::DWORD_ nMaxInstances,
boost::detail::winapi::DWORD_ nOutBufferSize,
boost::detail::winapi::DWORD_ nInBufferSize,
boost::detail::winapi::DWORD_ nDefaultTimeOut,
_SECURITY_ATTRIBUTES *lpSecurityAttributes);
BOOST_SYMBOL_IMPORT boost::detail::winapi::BOOL_ WINAPI WaitNamedPipeA(
boost::detail::winapi::LPCSTR_ lpNamedPipeName,
boost::detail::winapi::DWORD_ nTimeOut);
#endif // !defined( BOOST_NO_ANSI_APIS )
BOOST_SYMBOL_IMPORT boost::detail::winapi::HANDLE_ WINAPI CreateNamedPipeW(
boost::detail::winapi::LPCWSTR_ lpName,
boost::detail::winapi::DWORD_ dwOpenMode,
boost::detail::winapi::DWORD_ dwPipeMode,
boost::detail::winapi::DWORD_ nMaxInstances,
boost::detail::winapi::DWORD_ nOutBufferSize,
boost::detail::winapi::DWORD_ nInBufferSize,
boost::detail::winapi::DWORD_ nDefaultTimeOut,
_SECURITY_ATTRIBUTES* lpSecurityAttributes);
BOOST_SYMBOL_IMPORT boost::detail::winapi::BOOL_ WINAPI WaitNamedPipeW(
boost::detail::winapi::LPCWSTR_ lpNamedPipeName,
boost::detail::winapi::DWORD_ nTimeOut);
#if BOOST_USE_WINAPI_VERSION >= BOOST_WINAPI_VERSION_WIN6
#if !defined( BOOST_NO_ANSI_APIS )
BOOST_SYMBOL_IMPORT boost::detail::winapi::BOOL_ WINAPI GetNamedPipeClientComputerNameA(
boost::detail::winapi::HANDLE_ Pipe,
boost::detail::winapi::LPSTR_ ClientComputerName,
boost::detail::winapi::ULONG_ ClientComputerNameLength);
#endif // !defined( BOOST_NO_ANSI_APIS )
BOOST_SYMBOL_IMPORT boost::detail::winapi::BOOL_ WINAPI GetNamedPipeClientComputerNameW(
boost::detail::winapi::HANDLE_ Pipe,
boost::detail::winapi::LPWSTR_ ClientComputerName,
boost::detail::winapi::ULONG_ ClientComputerNameLength);
#endif
} // extern "C"
#endif // !defined( BOOST_USE_WINDOWS_H )
namespace boost {
namespace detail {
namespace winapi {
#if defined( BOOST_USE_WINDOWS_H )
const DWORD_ PIPE_ACCESS_DUPLEX_ = PIPE_ACCESS_DUPLEX;
const DWORD_ PIPE_ACCESS_INBOUND_ = PIPE_ACCESS_INBOUND;
const DWORD_ PIPE_ACCESS_OUTBOUND_ = PIPE_ACCESS_OUTBOUND;
const DWORD_ PIPE_TYPE_BYTE_ = PIPE_TYPE_BYTE;
const DWORD_ PIPE_TYPE_MESSAGE_ = PIPE_TYPE_MESSAGE;
const DWORD_ PIPE_READMODE_BYTE_ = PIPE_READMODE_BYTE;
const DWORD_ PIPE_READMODE_MESSAGE_ = PIPE_READMODE_MESSAGE;
const DWORD_ PIPE_WAIT_ = PIPE_WAIT;
const DWORD_ PIPE_NOWAIT_ = PIPE_NOWAIT;
const DWORD_ PIPE_UNLIMITED_INSTANCES_ = PIPE_UNLIMITED_INSTANCES;
const DWORD_ NMPWAIT_USE_DEFAULT_WAIT_ = NMPWAIT_USE_DEFAULT_WAIT;
const DWORD_ NMPWAIT_NOWAIT_ = NMPWAIT_NOWAIT;
const DWORD_ NMPWAIT_WAIT_FOREVER_ = NMPWAIT_WAIT_FOREVER;
#else // defined( BOOST_USE_WINDOWS_H )
const DWORD_ PIPE_ACCESS_DUPLEX_ = 0x00000003;
const DWORD_ PIPE_ACCESS_INBOUND_ = 0x00000001;
const DWORD_ PIPE_ACCESS_OUTBOUND_ = 0x00000002;
const DWORD_ PIPE_TYPE_BYTE_ = 0x00000000;
const DWORD_ PIPE_TYPE_MESSAGE_ = 0x00000004;
const DWORD_ PIPE_READMODE_BYTE_ = 0x00000000;
const DWORD_ PIPE_READMODE_MESSAGE_ = 0x00000002;
const DWORD_ PIPE_WAIT_ = 0x00000000;
const DWORD_ PIPE_NOWAIT_ = 0x00000001;
const DWORD_ PIPE_UNLIMITED_INSTANCES_ = 255u;
const DWORD_ NMPWAIT_USE_DEFAULT_WAIT_ = 0x00000000;
const DWORD_ NMPWAIT_NOWAIT_ = 0x00000001;
const DWORD_ NMPWAIT_WAIT_FOREVER_ = 0xFFFFFFFF;
#endif // defined( BOOST_USE_WINDOWS_H )
// These constants are not defined in Windows SDK prior to 7.0A
const DWORD_ PIPE_ACCEPT_REMOTE_CLIENTS_ = 0x00000000;
const DWORD_ PIPE_REJECT_REMOTE_CLIENTS_ = 0x00000008;
using ::ImpersonateNamedPipeClient;
using ::DisconnectNamedPipe;
using ::SetNamedPipeHandleState;
using ::PeekNamedPipe;
#if !defined( BOOST_NO_ANSI_APIS )
using ::WaitNamedPipeA;
#endif
using ::WaitNamedPipeW;
#if BOOST_USE_WINAPI_VERSION >= BOOST_WINAPI_VERSION_WIN6
#if !defined( BOOST_NO_ANSI_APIS )
using ::GetNamedPipeClientComputerNameA;
#endif // !defined( BOOST_NO_ANSI_APIS )
using ::GetNamedPipeClientComputerNameW;
#endif // BOOST_USE_WINAPI_VERSION >= BOOST_WINAPI_VERSION_WIN6
BOOST_FORCEINLINE BOOL_ CreatePipe(PHANDLE_ hReadPipe, PHANDLE_ hWritePipe, LPSECURITY_ATTRIBUTES_ lpPipeAttributes, DWORD_ nSize)
{
return ::CreatePipe(hReadPipe, hWritePipe, reinterpret_cast< ::_SECURITY_ATTRIBUTES* >(lpPipeAttributes), nSize);
}
BOOST_FORCEINLINE BOOL_ ConnectNamedPipe(HANDLE_ hNamedPipe, LPOVERLAPPED_ lpOverlapped)
{
return ::ConnectNamedPipe(hNamedPipe, reinterpret_cast< ::_OVERLAPPED* >(lpOverlapped));
}
BOOST_FORCEINLINE BOOL_ TransactNamedPipe(HANDLE_ hNamedPipe, LPVOID_ lpInBuffer, DWORD_ nInBufferSize, LPVOID_ lpOutBuffer, DWORD_ nOutBufferSize, LPDWORD_ lpBytesRead, LPOVERLAPPED_ lpOverlapped)
{
return ::TransactNamedPipe(hNamedPipe, lpInBuffer, nInBufferSize, lpOutBuffer, nOutBufferSize, lpBytesRead, reinterpret_cast< ::_OVERLAPPED* >(lpOverlapped));
}
#if !defined( BOOST_NO_ANSI_APIS )
BOOST_FORCEINLINE HANDLE_ CreateNamedPipeA(
LPCSTR_ lpName,
DWORD_ dwOpenMode,
DWORD_ dwPipeMode,
DWORD_ nMaxInstances,
DWORD_ nOutBufferSize,
DWORD_ nInBufferSize,
DWORD_ nDefaultTimeOut,
LPSECURITY_ATTRIBUTES_ lpSecurityAttributes)
{
return ::CreateNamedPipeA(
lpName,
dwOpenMode,
dwPipeMode,
nMaxInstances,
nOutBufferSize,
nInBufferSize,
nDefaultTimeOut,
reinterpret_cast< ::_SECURITY_ATTRIBUTES* >(lpSecurityAttributes));
}
BOOST_FORCEINLINE HANDLE_ create_named_pipe(
LPCSTR_ lpName,
DWORD_ dwOpenMode,
DWORD_ dwPipeMode,
DWORD_ nMaxInstances,
DWORD_ nOutBufferSize,
DWORD_ nInBufferSize,
DWORD_ nDefaultTimeOut,
LPSECURITY_ATTRIBUTES_ lpSecurityAttributes)
{
return ::CreateNamedPipeA(
lpName,
dwOpenMode,
dwPipeMode,
nMaxInstances,
nOutBufferSize,
nInBufferSize,
nDefaultTimeOut,
reinterpret_cast< ::_SECURITY_ATTRIBUTES* >(lpSecurityAttributes));
}
#endif // !defined( BOOST_NO_ANSI_APIS )
BOOST_FORCEINLINE HANDLE_ CreateNamedPipeW(
LPCWSTR_ lpName,
DWORD_ dwOpenMode,
DWORD_ dwPipeMode,
DWORD_ nMaxInstances,
DWORD_ nOutBufferSize,
DWORD_ nInBufferSize,
DWORD_ nDefaultTimeOut,
LPSECURITY_ATTRIBUTES_ lpSecurityAttributes)
{
return ::CreateNamedPipeW(
lpName,
dwOpenMode,
dwPipeMode,
nMaxInstances,
nOutBufferSize,
nInBufferSize,
nDefaultTimeOut,
reinterpret_cast< ::_SECURITY_ATTRIBUTES* >(lpSecurityAttributes));
}
BOOST_FORCEINLINE HANDLE_ create_named_pipe(
LPCWSTR_ lpName,
DWORD_ dwOpenMode,
DWORD_ dwPipeMode,
DWORD_ nMaxInstances,
DWORD_ nOutBufferSize,
DWORD_ nInBufferSize,
DWORD_ nDefaultTimeOut,
LPSECURITY_ATTRIBUTES_ lpSecurityAttributes)
{
return ::CreateNamedPipeW(
lpName,
dwOpenMode,
dwPipeMode,
nMaxInstances,
nOutBufferSize,
nInBufferSize,
nDefaultTimeOut,
reinterpret_cast< ::_SECURITY_ATTRIBUTES* >(lpSecurityAttributes));
}
#if !defined( BOOST_NO_ANSI_APIS )
BOOST_FORCEINLINE BOOL_ wait_named_pipe(LPCSTR_ lpNamedPipeName, DWORD_ nTimeOut)
{
return ::WaitNamedPipeA(lpNamedPipeName, nTimeOut);
}
#endif //BOOST_NO_ANSI_APIS
BOOST_FORCEINLINE BOOL_ wait_named_pipe(LPCWSTR_ lpNamedPipeName, DWORD_ nTimeOut)
{
return ::WaitNamedPipeW(lpNamedPipeName, nTimeOut);
}
#if BOOST_USE_WINAPI_VERSION >= BOOST_WINAPI_VERSION_WIN6
#if !defined( BOOST_NO_ANSI_APIS )
BOOST_FORCEINLINE BOOL_ get_named_pipe_client_computer_name(HANDLE_ Pipe, LPSTR_ ClientComputerName, ULONG_ ClientComputerNameLength)
{
return ::GetNamedPipeClientComputerNameA(Pipe, ClientComputerName, ClientComputerNameLength);
}
#endif // !defined( BOOST_NO_ANSI_APIS )
BOOST_FORCEINLINE BOOL_ get_named_pipe_client_computer_name(HANDLE_ Pipe, LPWSTR_ ClientComputerName, ULONG_ ClientComputerNameLength)
{
return ::GetNamedPipeClientComputerNameW(Pipe, ClientComputerName, ClientComputerNameLength);
}
#endif // BOOST_USE_WINAPI_VERSION >= BOOST_WINAPI_VERSION_WIN6
}
}
}
#endif // BOOST_PLAT_WINDOWS_DESKTOP
#endif // BOOST_DETAIL_WINAPI_PIPES_HPP_
|
