VirtualBox

source: vbox/trunk/src/VBox/Runtime/testcase/tstRTPipe.cpp@ 32970

Last change on this file since 32970 was 28800, checked in by vboxsync, 15 years ago

Automated rebranding to Oracle copyright/license strings via filemuncher
  • Property svn:eol-style set to native
  • Property svn:keywords set to Author Date Id Revision
File size: 19.7 KB
Line 
1/* $Id: tstRTPipe.cpp 28800 2010-04-27 08:22:32Z vboxsync $ */
2/** @file
3 * IPRT Testcase - RTPipe.
4 */
5
6/*
7 * Copyright (C) 2010 Oracle Corporation
8 *
9 * This file is part of VirtualBox Open Source Edition (OSE), as
10 * available from http://www.virtualbox.org. This file is free software;
11 * you can redistribute it and/or modify it under the terms of the GNU
12 * General Public License (GPL) as published by the Free Software
13 * Foundation, in version 2 as it comes in the "COPYING" file of the
14 * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
15 * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
16 *
17 * The contents of this file may alternatively be used under the terms
18 * of the Common Development and Distribution License Version 1.0
19 * (CDDL) only, as it comes in the "COPYING.CDDL" file of the
20 * VirtualBox OSE distribution, in which case the provisions of the
21 * CDDL are applicable instead of those of the GPL.
22 *
23 * You may elect to license modified versions of this file under the
24 * terms and conditions of either the GPL or the CDDL or both.
25 */
26
27
28/*******************************************************************************
29* Header Files *
30*******************************************************************************/
31#include <iprt/pipe.h>
32
33#include <iprt/env.h>
34#include <iprt/err.h>
35#include <iprt/initterm.h>
36#include <iprt/mem.h>
37#include <iprt/message.h>
38#include <iprt/param.h>
39#include <iprt/process.h>
40#include <iprt/string.h>
41#include <iprt/test.h>
42
43
44/*******************************************************************************
45* Global Variables *
46*******************************************************************************/
47static const char g_szTest4Message[] = "This is test #4, everything is working fine.\n\r";
48static const char g_szTest5Message[] = "This is test #5, everything is working fine.\n\r";
49
50
51static RTEXITCODE tstRTPipe5Child(const char *pszPipe)
52{
53 int rc = RTR3Init();
54 if (RT_FAILURE(rc))
55 return RTMsgInitFailure(rc);
56
57 int64_t iNative;
58 rc = RTStrToInt64Full(pszPipe, 10, &iNative);
59 if (RT_FAILURE(rc))
60 return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTStrToUInt64Full(%s) -> %Rrc\n", pszPipe, rc);
61
62 RTPIPE hPipe;
63 rc = RTPipeFromNative(&hPipe, (RTHCINTPTR)iNative, RTPIPE_N_READ);
64 if (RT_FAILURE(rc))
65 return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTPipeFromNative(,%s,READ) -> %Rrc\n", pszPipe, rc);
66
67 ///
68 char szTmp[1024];
69 size_t cbRead = 0;
70 rc = RTPipeReadBlocking(hPipe, szTmp, sizeof(szTmp) - 1, &cbRead);
71 if (RT_FAILURE(rc))
72 return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTPipeReadBlocking() -> %Rrc\n", rc);
73 szTmp[cbRead] = '\0';
74
75 size_t cbRead2;
76 char szTmp2[4];
77 rc = RTPipeReadBlocking(hPipe, szTmp2, sizeof(szTmp2), &cbRead2);
78 if (rc != VERR_BROKEN_PIPE)
79 return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTPipeReadBlocking() -> %Rrc instead of VERR_BROKEN_PIPE\n", rc);
80
81 rc = RTPipeClose(hPipe);
82 if (RT_FAILURE(rc))
83 return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTPipeClose() -> %Rrc\n", rc);
84
85 if (memcmp(szTmp, g_szTest5Message, sizeof(g_szTest5Message)))
86 return RTMsgErrorExit(RTEXITCODE_FAILURE, "Message mismatch.\n:Expected '%s'\nGot '%s'\n", g_szTest5Message, szTmp);
87
88 return RTEXITCODE_SUCCESS;
89}
90
91static void tstRTPipe5(void)
92{
93 RTTestISub("Inherit non-standard pipe handle, read end");
94
95 char szPathSelf[RTPATH_MAX];
96 RTTESTI_CHECK_RETV(RTProcGetExecutableName(szPathSelf, sizeof(szPathSelf)) == szPathSelf);
97
98 RTPIPE hPipeR;
99 RTPIPE hPipeW;
100 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_READ), VINF_SUCCESS);
101
102 RTHCINTPTR hNative = RTPipeToNative(hPipeR);
103 RTTESTI_CHECK_RETV(hNative != -1);
104
105 char szNative[64];
106 RTStrPrintf(szNative, sizeof(szNative), "%RHi", hNative);
107 const char *papszArgs[4] = { szPathSelf, "--child-5", szNative, NULL };
108
109 RTPROCESS hChild;
110 RTTESTI_CHECK_RC_RETV(RTProcCreate(szPathSelf, papszArgs, RTENV_DEFAULT, 0 /*fFlags*/, &hChild), VINF_SUCCESS);
111 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeR), VINF_SUCCESS);
112
113 RTTESTI_CHECK_RC(RTPipeWriteBlocking(hPipeW, g_szTest5Message, sizeof(g_szTest5Message) - 1, NULL), VINF_SUCCESS);
114 int rc;
115 RTTESTI_CHECK_RC(rc = RTPipeClose(hPipeW), VINF_SUCCESS);
116 if (RT_FAILURE(rc))
117 RTTESTI_CHECK_RC(RTProcTerminate(hChild), VINF_SUCCESS);
118
119 RTPROCSTATUS ProcStatus;
120 RTTESTI_CHECK_RC(rc = RTProcWait(hChild, RTPROCWAIT_FLAGS_BLOCK, &ProcStatus), VINF_SUCCESS);
121 if (RT_FAILURE(rc))
122 return;
123 RTTESTI_CHECK( ProcStatus.enmReason == RTPROCEXITREASON_NORMAL
124 && ProcStatus.iStatus == 0);
125}
126
127
128static RTEXITCODE tstRTPipe4Child(const char *pszPipe)
129{
130 int rc = RTR3Init();
131 if (RT_FAILURE(rc))
132 return RTMsgInitFailure(rc);
133
134 int64_t iNative;
135 rc = RTStrToInt64Full(pszPipe, 10, &iNative);
136 if (RT_FAILURE(rc))
137 return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTStrToUInt64Full(%s) -> %Rrc\n", pszPipe, rc);
138
139 RTPIPE hPipe;
140 rc = RTPipeFromNative(&hPipe, (RTHCINTPTR)iNative, RTPIPE_N_WRITE);
141 if (RT_FAILURE(rc))
142 return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTPipeFromNative(,%s,WRITE) -> %Rrc\n", pszPipe, rc);
143
144 rc = RTPipeWriteBlocking(hPipe, g_szTest4Message, sizeof(g_szTest4Message) - 1, NULL);
145 if (RT_FAILURE(rc))
146 return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTPipeWriteBlocking() -> %Rrc\n", rc);
147
148 rc = RTPipeClose(hPipe);
149 if (RT_FAILURE(rc))
150 return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTPipeClose() -> %Rrc\n", rc);
151 return RTEXITCODE_SUCCESS;
152}
153
154static void tstRTPipe4(void)
155{
156 RTTestISub("Inherit non-standard pipe handle, write end");
157
158 char szPathSelf[RTPATH_MAX];
159 RTTESTI_CHECK_RETV(RTProcGetExecutableName(szPathSelf, sizeof(szPathSelf)) == szPathSelf);
160
161 RTPIPE hPipeR;
162 RTPIPE hPipeW;
163 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_WRITE), VINF_SUCCESS);
164
165 RTHCINTPTR hNative = RTPipeToNative(hPipeW);
166 RTTESTI_CHECK_RETV(hNative != -1);
167
168 char szNative[64];
169 RTStrPrintf(szNative, sizeof(szNative), "%RHi", hNative);
170 const char *papszArgs[4] = { szPathSelf, "--child-4", szNative, NULL };
171
172 RTPROCESS hChild;
173 RTTESTI_CHECK_RC_RETV(RTProcCreate(szPathSelf, papszArgs, RTENV_DEFAULT, 0 /*fFlags*/, &hChild), VINF_SUCCESS);
174 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
175
176 char szTmp[1024];
177 size_t cbRead = 0;
178 int rc;
179 RTTESTI_CHECK_RC(rc = RTPipeReadBlocking(hPipeR, szTmp, sizeof(szTmp) - 1, &cbRead), VINF_SUCCESS);
180 if (RT_FAILURE(rc))
181 cbRead = 0;
182 RTTESTI_CHECK_RETV(cbRead < sizeof(szTmp));
183 szTmp[cbRead] = '\0';
184
185 size_t cbRead2;
186 char szTmp2[4];
187 RTTESTI_CHECK_RC(RTPipeReadBlocking(hPipeR, szTmp2, sizeof(szTmp2), &cbRead2), VERR_BROKEN_PIPE);
188 RTTESTI_CHECK_RC(rc = RTPipeClose(hPipeR), VINF_SUCCESS);
189 if (RT_FAILURE(rc))
190 RTTESTI_CHECK_RC(RTProcTerminate(hChild), VINF_SUCCESS);
191
192 RTPROCSTATUS ProcStatus;
193 RTTESTI_CHECK_RC(rc = RTProcWait(hChild, RTPROCWAIT_FLAGS_BLOCK, &ProcStatus), VINF_SUCCESS);
194 if (RT_FAILURE(rc))
195 return;
196 RTTESTI_CHECK( ProcStatus.enmReason == RTPROCEXITREASON_NORMAL
197 && ProcStatus.iStatus == 0);
198 if (memcmp(szTmp, g_szTest4Message, sizeof(g_szTest4Message)))
199 RTTestIFailed("Message mismatch.\n:Expected '%s'\nGot '%s'\n", g_szTest4Message, szTmp);
200}
201
202
203static void tstRTPipe3(void)
204{
205 RTTestISub("Full write buffer");
206
207 RTPIPE hPipeR = (RTPIPE)999999;
208 RTPIPE hPipeW = (RTPIPE)999999;
209 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
210
211 static char s_abBuf[_256K];
212 int rc = VINF_SUCCESS;
213 size_t cbTotal = 0;
214 memset(s_abBuf, 0xff, sizeof(s_abBuf));
215 for (;;)
216 {
217 RTTESTI_CHECK(cbTotal < _1G);
218 if (cbTotal > _1G)
219 break;
220
221 size_t cbWritten = _1G;
222 rc = RTPipeWrite(hPipeW, s_abBuf, sizeof(s_abBuf), &cbWritten);
223 RTTESTI_CHECK_MSG(rc == VINF_SUCCESS || rc == VINF_TRY_AGAIN, ("rc=%Rrc\n", rc));
224 if (rc != VINF_SUCCESS)
225 break;
226 cbTotal += cbWritten;
227 }
228
229 if (rc == VINF_TRY_AGAIN)
230 {
231 RTTestIPrintf(RTTESTLVL_ALWAYS, "cbTotal=%zu (%#zx)\n", cbTotal, cbTotal);
232 RTTESTI_CHECK_RC(RTPipeSelectOne(hPipeW, 0), VERR_TIMEOUT);
233 RTTESTI_CHECK_RC(RTPipeSelectOne(hPipeW, 1), VERR_TIMEOUT);
234 size_t cbRead;
235 RTTESTI_CHECK_RC(RTPipeRead(hPipeR, s_abBuf, RT_MIN(sizeof(s_abBuf), cbTotal) / 2, &cbRead), VINF_SUCCESS);
236 RTTESTI_CHECK_RC(RTPipeSelectOne(hPipeW, 0), VINF_SUCCESS);
237 RTTESTI_CHECK_RC(RTPipeSelectOne(hPipeW, 1), VINF_SUCCESS);
238
239 size_t cbWritten = _1G;
240 rc = RTPipeWrite(hPipeW, s_abBuf, sizeof(s_abBuf), &cbWritten);
241 RTTESTI_CHECK(rc == VINF_SUCCESS);
242 }
243
244 RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS);
245 RTTESTI_CHECK_RC(RTPipeClose(hPipeW), VINF_SUCCESS);
246}
247
248static void tstRTPipe2(void)
249{
250 RTTestISub("Negative");
251
252 RTPIPE hPipeR = (RTPIPE)1;
253 RTPIPE hPipeW = (RTPIPE)1;
254 RTTESTI_CHECK_RC(RTPipeCreate(&hPipeR, &hPipeW, ~0), VERR_INVALID_PARAMETER);
255 RTTESTI_CHECK_RC(RTPipeCreate(NULL, &hPipeW, 0), VERR_INVALID_POINTER);
256 RTTESTI_CHECK_RC(RTPipeCreate(&hPipeR, NULL, 0), VERR_INVALID_POINTER);
257 RTTESTI_CHECK(hPipeR == (RTPIPE)1);
258 RTTESTI_CHECK(hPipeW == (RTPIPE)1);
259
260
261 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
262
263 char abBuf[_4K];
264 size_t cbRead = ~(size_t)3;
265 RTTESTI_CHECK_RC(RTPipeRead(hPipeW, abBuf, 0, &cbRead), VERR_ACCESS_DENIED);
266 RTTESTI_CHECK_RC(RTPipeRead(hPipeW, abBuf, 1, &cbRead), VERR_ACCESS_DENIED);
267 RTTESTI_CHECK(cbRead == ~(size_t)3);
268 RTTESTI_CHECK_RC(RTPipeReadBlocking(hPipeW, abBuf, 0, NULL), VERR_ACCESS_DENIED);
269 RTTESTI_CHECK_RC(RTPipeReadBlocking(hPipeW, abBuf, 1, NULL), VERR_ACCESS_DENIED);
270
271 size_t cbWrite = ~(size_t)5;
272 RTTESTI_CHECK_RC(RTPipeWrite(hPipeR, "asdf", 0, &cbWrite), VERR_ACCESS_DENIED);
273 RTTESTI_CHECK_RC(RTPipeWrite(hPipeR, "asdf", 4, &cbWrite), VERR_ACCESS_DENIED);
274 RTTESTI_CHECK(cbWrite == ~(size_t)5);
275 RTTESTI_CHECK_RC(RTPipeWriteBlocking(hPipeR, "asdf", 0, NULL), VERR_ACCESS_DENIED);
276 RTTESTI_CHECK_RC(RTPipeWriteBlocking(hPipeR, "asdf", 4, NULL), VERR_ACCESS_DENIED);
277
278 RTTESTI_CHECK_RC(RTPipeFlush(hPipeR), VERR_ACCESS_DENIED);
279
280 RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS);
281 RTTESTI_CHECK_RC(RTPipeClose(hPipeW), VINF_SUCCESS);
282}
283
284
285static void tstRTPipe1(void)
286{
287 RTTestISub("Basics");
288
289 RTPIPE hPipeR = NIL_RTPIPE;
290 RTPIPE hPipeW = NIL_RTPIPE;
291 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
292 RTTESTI_CHECK_RETV(hPipeR != NIL_RTPIPE);
293 RTTESTI_CHECK_RETV(hPipeW != NIL_RTPIPE);
294 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeR), VINF_SUCCESS);
295 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
296 RTTESTI_CHECK_RC_RETV(RTPipeClose(NIL_RTPIPE), VINF_SUCCESS);
297
298 hPipeR = NIL_RTPIPE;
299 hPipeW = NIL_RTPIPE;
300 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_READ | RTPIPE_C_INHERIT_WRITE), VINF_SUCCESS);
301 int rc = RTPipeFlush(hPipeW);
302 RTTESTI_CHECK_MSG(rc == VERR_NOT_SUPPORTED || rc == VINF_SUCCESS, ("%Rrc\n", rc));
303 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeR), VINF_SUCCESS);
304 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
305
306 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_READ), VINF_SUCCESS);
307 RTTESTI_CHECK_RC_RETV(RTPipeSelectOne(hPipeR, 0), VERR_TIMEOUT);
308 RTTESTI_CHECK_RC_RETV(RTPipeSelectOne(hPipeR, 1), VERR_TIMEOUT);
309 RTTESTI_CHECK_RC_RETV(RTPipeSelectOne(hPipeW, 0), VINF_SUCCESS);
310 RTTESTI_CHECK_RC_RETV(RTPipeSelectOne(hPipeW, 1), VINF_SUCCESS);
311 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeR), VINF_SUCCESS);
312 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
313
314 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_WRITE), VINF_SUCCESS);
315 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeR), VINF_SUCCESS);
316 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
317
318 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_READ), VINF_SUCCESS);
319
320 size_t cbRead = ~(size_t)0;
321 char abBuf[_64K + _4K];
322 RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, abBuf, sizeof(abBuf), &cbRead), VINF_TRY_AGAIN);
323 RTTESTI_CHECK_RETV(cbRead == 0);
324
325 cbRead = ~(size_t)0;
326 RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, abBuf, 1, &cbRead), VINF_TRY_AGAIN);
327 RTTESTI_CHECK_RETV(cbRead == 0);
328
329 cbRead = ~(size_t)0;
330 RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, abBuf, 0, &cbRead), VINF_SUCCESS);
331 RTTESTI_CHECK_RETV(cbRead == 0);
332
333 size_t cbWritten = ~(size_t)2;
334 RTTESTI_CHECK_RC_RETV(RTPipeWrite(hPipeW, abBuf, 0, &cbWritten), VINF_SUCCESS);
335 RTTESTI_CHECK_RETV(cbWritten == 0);
336
337 /* We can write a number of bytes without blocking (see PIPE_BUF on
338 POSIX systems). */
339 cbWritten = ~(size_t)2;
340 RTTESTI_CHECK_RC_RETV(RTPipeWrite(hPipeW, "42", 2, &cbWritten), VINF_SUCCESS);
341 RTTESTI_CHECK_MSG_RETV(cbWritten == 2, ("cbWritten=%zu\n", cbWritten));
342 cbWritten = ~(size_t)2;
343 RTTESTI_CHECK_RC_RETV(RTPipeWrite(hPipeW, "!", 1, &cbWritten), VINF_SUCCESS);
344 RTTESTI_CHECK_RETV(cbWritten == 1);
345 cbRead = ~(size_t)0;
346 RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, abBuf, 3, &cbRead), VINF_SUCCESS);
347 RTTESTI_CHECK_RETV(cbRead == 3);
348 RTTESTI_CHECK_RETV(!memcmp(abBuf, "42!", 3));
349
350 cbWritten = ~(size_t)2;
351 RTTESTI_CHECK_RC_RETV(RTPipeWrite(hPipeW, "BigQ", 4, &cbWritten), VINF_SUCCESS);
352 RTTESTI_CHECK_RETV(cbWritten == 4);
353 cbRead = ~(size_t)0;
354 RTTESTI_CHECK_RC_RETV(RTPipeSelectOne(hPipeR, 0), VINF_SUCCESS);
355 RTTESTI_CHECK_RC_RETV(RTPipeSelectOne(hPipeR, 1), VINF_SUCCESS);
356 RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, abBuf, sizeof(abBuf), &cbRead), VINF_SUCCESS);
357 RTTESTI_CHECK_RETV(cbRead == 4);
358 RTTESTI_CHECK_RETV(!memcmp(abBuf, "BigQ", 4));
359
360 cbWritten = ~(size_t)2;
361 RTTESTI_CHECK_RC_RETV(RTPipeWrite(hPipeW, "H2G2", 4, &cbWritten), VINF_SUCCESS);
362 RTTESTI_CHECK_RETV(cbWritten == 4);
363 cbRead = ~(size_t)0;
364 RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, &abBuf[0], 1, &cbRead), VINF_SUCCESS);
365 RTTESTI_CHECK_RETV(cbRead == 1);
366 cbRead = ~(size_t)0;
367 RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, &abBuf[1], 1, &cbRead), VINF_SUCCESS);
368 RTTESTI_CHECK_RETV(cbRead == 1);
369 cbRead = ~(size_t)0;
370 RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, &abBuf[2], 1, &cbRead), VINF_SUCCESS);
371 RTTESTI_CHECK_RETV(cbRead == 1);
372 cbRead = ~(size_t)0;
373 RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, &abBuf[3], 1, &cbRead), VINF_SUCCESS);
374 RTTESTI_CHECK_RETV(cbRead == 1);
375 RTTESTI_CHECK_RETV(!memcmp(abBuf, "H2G2", 4));
376
377 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeR), VINF_SUCCESS);
378 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
379
380
381 RTTestISub("VERR_BROKEN_PIPE");
382 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
383 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeR), VINF_SUCCESS);
384 cbWritten = ~(size_t)2;
385 RTTESTI_CHECK_RC(RTPipeWrite(hPipeW, "", 0, &cbWritten), VINF_SUCCESS);
386 RTTESTI_CHECK(cbWritten == 0);
387 cbWritten = ~(size_t)2;
388 RTTESTI_CHECK_RC(RTPipeWrite(hPipeW, "4", 1, &cbWritten), VERR_BROKEN_PIPE);
389 RTTESTI_CHECK(cbWritten == ~(size_t)2);
390 RTTESTI_CHECK_RC(RTPipeClose(hPipeW), VINF_SUCCESS);
391
392 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
393 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
394 cbRead = ~(size_t)0;
395 RTTESTI_CHECK_RC(RTPipeRead(hPipeR, abBuf, 0, &cbRead), VINF_SUCCESS);
396 RTTESTI_CHECK(cbRead == 0);
397 cbRead = ~(size_t)3;
398 RTTESTI_CHECK_RC(RTPipeRead(hPipeR, abBuf, sizeof(abBuf), &cbRead), VERR_BROKEN_PIPE);
399 RTTESTI_CHECK(cbRead == ~(size_t)3);
400 RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS);
401
402 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
403 cbWritten = ~(size_t)2;
404 RTTESTI_CHECK_RC(RTPipeWrite(hPipeW, "42", 2, &cbWritten), VINF_SUCCESS);
405 RTTESTI_CHECK(cbWritten == 2);
406 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
407 cbRead = ~(size_t)0;
408 RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, abBuf, 0, &cbRead), VINF_SUCCESS);
409 RTTESTI_CHECK(cbRead == 0);
410 cbRead = ~(size_t)0;
411 RTTESTI_CHECK_RC(RTPipeRead(hPipeR, &abBuf[0], 1, &cbRead), VINF_SUCCESS);
412 RTTESTI_CHECK(cbRead == 1);
413 cbRead = ~(size_t)0;
414 RTTESTI_CHECK_RC(RTPipeRead(hPipeR, &abBuf[1], 1, &cbRead), VINF_SUCCESS);
415 RTTESTI_CHECK(cbRead == 1);
416 RTTESTI_CHECK(!memcmp(abBuf, "42", 2));
417 cbRead = ~(size_t)0;
418 RTTESTI_CHECK_RC(RTPipeRead(hPipeR, abBuf, 0, &cbRead), VINF_SUCCESS);
419 RTTESTI_CHECK(cbRead == 0);
420 cbRead = ~(size_t)3;
421 RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, abBuf, sizeof(abBuf), &cbRead), VERR_BROKEN_PIPE);
422 RTTESTI_CHECK(cbRead == ~(size_t)3);
423 RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS);
424
425 RTTestISub("Blocking");
426 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
427 RTTESTI_CHECK_RC_RETV(RTPipeWrite(hPipeW, "42!", 3, &cbWritten), VINF_SUCCESS);
428 RTTESTI_CHECK(cbWritten == 3);
429 RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, abBuf, 3, NULL), VINF_SUCCESS);
430 RTTESTI_CHECK(!memcmp(abBuf, "42!", 3));
431 RTTESTI_CHECK_RC(RTPipeClose(hPipeW), VINF_SUCCESS);
432 RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[0], 0, NULL), VINF_SUCCESS);
433 cbRead = ~(size_t)42;
434 RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[0], 0, &cbRead), VINF_SUCCESS);
435 RTTESTI_CHECK(cbRead == 0);
436 RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[0], 1, NULL), VERR_BROKEN_PIPE);
437 cbRead = ~(size_t)42;
438 RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[0], 1, &cbRead), VERR_BROKEN_PIPE);
439 RTTESTI_CHECK(cbRead == 0);
440 RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS);
441
442 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
443 RTTESTI_CHECK_RC_RETV(RTPipeWriteBlocking(hPipeW, "42!", 3, NULL), VINF_SUCCESS);
444 RTTESTI_CHECK(cbWritten == 3);
445 cbRead = ~(size_t)0;
446 RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, &abBuf[0], 1, &cbRead), VINF_SUCCESS);
447 RTTESTI_CHECK(cbRead == 1);
448 RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[1], 1, NULL), VINF_SUCCESS);
449 RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[2], 1, NULL), VINF_SUCCESS);
450 RTTESTI_CHECK(!memcmp(abBuf, "42!", 3));
451 RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS);
452 RTTESTI_CHECK_RC_RETV(RTPipeWriteBlocking(hPipeW, "", 0, NULL), VINF_SUCCESS);
453 cbWritten = ~(size_t)9;
454 RTTESTI_CHECK_RC_RETV(RTPipeWriteBlocking(hPipeW, "", 0, &cbWritten), VINF_SUCCESS);
455 RTTESTI_CHECK(cbWritten == 0);
456 RTTESTI_CHECK_RC_RETV(RTPipeWriteBlocking(hPipeW, "42", 2, NULL), VERR_BROKEN_PIPE);
457 cbWritten = ~(size_t)9;
458 RTTESTI_CHECK_RC_RETV(RTPipeWriteBlocking(hPipeW, "42", 2, &cbWritten), VERR_BROKEN_PIPE);
459 RTTESTI_CHECK(cbWritten == 0);
460 RTTESTI_CHECK_RC(RTPipeClose(hPipeW), VINF_SUCCESS);
461}
462
463int main(int argc, char **argv)
464{
465 if (argc == 3 && !strcmp(argv[1], "--child-4"))
466 return tstRTPipe4Child(argv[2]);
467 if (argc == 3 && !strcmp(argv[1], "--child-5"))
468 return tstRTPipe5Child(argv[2]);
469
470 RTTEST hTest;
471 int rc = RTTestInitAndCreate("tstRTPipe", &hTest);
472 if (rc)
473 return rc;
474 RTTestBanner(hTest);
475
476 /*
477 * The tests.
478 */
479 tstRTPipe1();
480 if (RTTestErrorCount(hTest) == 0)
481 {
482 bool fMayPanic = RTAssertMayPanic();
483 bool fQuiet = RTAssertAreQuiet();
484 RTAssertSetMayPanic(false);
485 RTAssertSetQuiet(true);
486 tstRTPipe2();
487 RTAssertSetQuiet(fQuiet);
488 RTAssertSetMayPanic(fMayPanic);
489
490 tstRTPipe3();
491 tstRTPipe4();
492 tstRTPipe5();
493 }
494
495 /*
496 * Summary.
497 */
498 return RTTestSummaryAndDestroy(hTest);
499}
500
Note: See TracBrowser for help on using the repository browser.

© 2024 Oracle Support Privacy / Do Not Sell My Info Terms of Use Trademark Policy Automated Access Etiquette