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
|
/***
*pipe.c - create a pipe
*
* Copyright (c) 1989-1993, Microsoft Corporation. All rights reserved.
*
*Purpose:
* defines _pipe() - creates a pipe (i.e., an I/O channel for interprocess
* communication)
*
*Revision History:
* 06-20-89 PHG Module created, based on asm version
* 03-13-90 GJF Made calling type _CALLTYPE2 (for now), added #include
* <cruntime.h> and fixed copyright. Also, cleaned up the
* formatting a bit.
* 04-03-90 GJF Now _CALLTYPE1.
* 07-24-90 SBM Removed '32' from API names
* 08-14-90 SBM Compiles cleanly with -W3
* 10-01-90 GJF New-style function declarator.
* 12-04-90 SRW Changed to include <oscalls.h> instead of <doscalls.h>
* 12-06-90 SRW Added _CRUISER_ and _WIN32 conditionals.
* 01-18-91 GJF ANSI naming.
* 02-18-91 SRW Added _WIN32_ implementation [_WIN32_]
* 02-25-91 SRW Renamed _get_free_osfhnd to be _alloc_osfhnd [_WIN32_]
* 03-13-91 SRW Fixed _pipe so it works [_WIN32_]
* 03-18-91 SRW Fixed _pipe NtCreatePipe handles are inherited [_WIN32_]
* 04-06-92 SRW Pay attention to _O_NOINHERIT flag in oflag parameter
* 01-10-93 GJF Fixed bug in checking for _O_BINARY (inadvertently
* introduced by SRW's change above).
*
*******************************************************************************/
#include <cruntime.h>
#include <oscalls.h>
#include <os2dll.h>
#include <io.h>
#include <internal.h>
#include <stdlib.h>
#include <errno.h>
#include <msdos.h>
#include <fcntl.h>
/***
*int _pipe(phandles, psize, textmode) - open a pipe
*
*Purpose:
* Checks if the given handle is associated with a character device
* (terminal, console, printer, serial port)
*
* Multi-thread notes: No locking is performed or deemed necessary. The
* handles returned by DOSCREATEPIPE are newly opened and, therefore,
* should not be referenced by any thread until after the _pipe call is
* complete. The function is not protected from some thread of the caller
* doing, say, output to a previously invalid handle that becomes one of
* the pipe handles. However, any such program is doomed anyway and
* protecting the _pipe function such a case would be of little value.
*
*Entry:
* int phandle[2] - array to hold returned read (phandle[0]) and write
* (phandle[1]) handles
*
* unsigned psize - amount of memory, in bytes, to ask OS/2 to reserve
* for the pipe
*
* int textmode - _O_TEXT, _O_BINARY, _O_NOINHERIT, or 0 (use default)
*
*Exit:
* returns 0 if successful
* returns -1 if an error occurs in which case, errno is set to:
*
*Exceptions:
*
*******************************************************************************/
int _CRTAPI1 _pipe (
int phandles[2],
unsigned psize,
int textmode
)
{
ULONG dosretval; /* OS/2 return value */
#ifdef _CRUISER_
if (dosretval = DOSCREATEPIPE(&phandles[0], &phandles[1], psize)) {
/* OS/2 error */
_dosmaperr(dosretval);
return -1;
}
if ((unsigned)phandles[0] >= (unsigned)_nfile ||
(unsigned)phandles[1] >= (unsigned)_nfile)
{
/* one or both of the handles are too large -- close both */
DOSCLOSE(phandles[0]);
DOSCLOSE(phandles[1]);
errno = EMFILE; /* too many files */
_doserrno = 0; /* not an OS/2 error */
return -1;
}
/* now we must set the _osfile values */
if (textmode == _O_BINARY || (textmode == 0 && _fmode == _O_BINARY)) {
/* binary mode */
_osfile[phandles[0]] = _osfile[phandles[1]] = FOPEN | FPIPE;
}
else {
/* text mode */
_osfile[phandles[0]] = _osfile[phandles[1]] = FOPEN | FPIPE |
FTEXT;
}
#else /* ndef _CRUISER_ */
#ifdef _WIN32_
HANDLE ReadHandle, WriteHandle;
SECURITY_ATTRIBUTES SecurityAttributes;
SecurityAttributes.nLength = sizeof(SecurityAttributes);
SecurityAttributes.lpSecurityDescriptor = NULL;
if (textmode & _O_NOINHERIT) {
SecurityAttributes.bInheritHandle = FALSE;
}
else {
SecurityAttributes.bInheritHandle = TRUE;
}
if (!CreatePipe(&ReadHandle, &WriteHandle, &SecurityAttributes, psize)) {
/* OS/2 error */
dosretval = GetLastError();
_dosmaperr(dosretval);
return -1;
}
/* now we must allocate C Runtime handles for Read and Write handles */
if ((phandles[0] = _alloc_osfhnd()) != -1) {
_osfile[phandles[0]] = (char)(FOPEN | FPIPE | FTEXT);
if ((phandles[1] = _alloc_osfhnd()) != -1) {
_osfile[phandles[1]] = (char)(FOPEN | FPIPE | FTEXT);
if ( (textmode & _O_BINARY) ||
((textmode & _O_TEXT == 0) &&
(_fmode == _O_BINARY)) ) {
/* binary mode */
_osfile[phandles[0]] &= ~FTEXT;
_osfile[phandles[1]] &= ~FTEXT;
}
_set_osfhnd(phandles[0], (long)ReadHandle);
_set_osfhnd(phandles[1], (long)WriteHandle);
errno = 0;
_unlock_fh(phandles[1]); /* unlock handle */
}
else {
_osfile[phandles[0]] = 0;
errno = EMFILE; /* too many files */
}
_unlock_fh(phandles[0]); /* unlock handle */
}
else {
errno = EMFILE; /* too many files */
}
/* If error occurred, close Win32 handles and return -1 */
if (errno != 0) {
CloseHandle(ReadHandle);
CloseHandle(WriteHandle);
_doserrno = 0; /* not an OS/2 error */
return -1;
}
#else /* ndef _WIN32_ */
#error ERROR - ONLY CRUISER OR WIN32 TARGET SUPPORTED!
#endif /* _WIN32_ */
#endif /* _CRUISER_ */
return 0;
}
|
