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
|
/*
* Copyright (c) 2007 Wayne Meissner. All rights reserved.
*
* For licensing, see LICENSE.SPECS
*/
#ifdef _WIN32
#include <windows.h>
#include <stdio.h>
#include "PipeHelper.h"
int pipeHelperCreatePipe(FD_TYPE pipefd[2])
{
char name[ MAX_PATH ];
static int pipe_idx = 0;
sprintf( name, "\\\\.\\Pipe\\pipeHelper-%u-%i",
(unsigned int)GetCurrentProcessId(), pipe_idx++ );
pipefd[0] = CreateNamedPipeA( name, PIPE_ACCESS_INBOUND | FILE_FLAG_OVERLAPPED,
PIPE_TYPE_BYTE | PIPE_WAIT,
1, // Number of pipes
5, // Out buffer size
5, // In buffer size
60 * 1000, // Timeout in ms
NULL );
if(pipefd[0] == INVALID_HANDLE_VALUE)
return -1;
pipefd[1] = CreateFileA( name, GENERIC_WRITE, 0, NULL,
OPEN_EXISTING,
FILE_ATTRIBUTE_NORMAL,
NULL);
if(pipefd[1] == INVALID_HANDLE_VALUE) {
CloseHandle( pipefd[0] );
return -1;
}
return 0;
}
char pipeHelperReadChar(FD_TYPE fd, int timeout)
{
char d;
OVERLAPPED ovl;
ZeroMemory(&ovl, sizeof(ovl));
ovl.hEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
if( ReadFile(fd, &d, 1, NULL, &ovl) == 0) {
DWORD recvd = 0;;
DWORD res = WaitForSingleObject(ovl.hEvent, timeout * 1000);
if( res != WAIT_OBJECT_0 ) {
CloseHandle(ovl.hEvent);
return 0;
}
if( GetOverlappedResult(fd, &ovl, &recvd, FALSE) == 0 ) {
CloseHandle(ovl.hEvent);
return 0;
}
}
CloseHandle(ovl.hEvent);
return d;
}
int pipeHelperWriteChar(FD_TYPE fd, char c)
{
DWORD written;
return WriteFile(fd, &c, 1, &written, NULL) == 0 ? 0 : 1;
}
void pipeHelperClosePipe(FD_TYPE fd) {
CloseHandle(fd);
}
#endif
|
