Runtime/testcase/tstRTPipe.cpp

	tstRTPipe.cpp revision b41f65ee355ae1d4b24473c6d6d70c653497429a
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync/* $Id$ */
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync/** @file
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync * IPRT Testcase - RTPipe.
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync */
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync/*
1c94c0a63ba68be1a7b2c640e70d7a06464e4fcavboxsync * Copyright (C) 2010 Sun Microsystems, Inc.
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync *
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync * This file is part of VirtualBox Open Source Edition (OSE), as
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync * available from http://www.virtualbox.org. This file is free software;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync * you can redistribute it and/or modify it under the terms of the GNU
a16eb14ad7a4b5ef91ddc22d3e8e92d930f736fcvboxsync * General Public License (GPL) as published by the Free Software
a16eb14ad7a4b5ef91ddc22d3e8e92d930f736fcvboxsync * Foundation, in version 2 as it comes in the "COPYING" file of the
a16eb14ad7a4b5ef91ddc22d3e8e92d930f736fcvboxsync * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
a16eb14ad7a4b5ef91ddc22d3e8e92d930f736fcvboxsync * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
1c94c0a63ba68be1a7b2c640e70d7a06464e4fcavboxsync *
1c94c0a63ba68be1a7b2c640e70d7a06464e4fcavboxsync * The contents of this file may alternatively be used under the terms
1c94c0a63ba68be1a7b2c640e70d7a06464e4fcavboxsync * of the Common Development and Distribution License Version 1.0
1c94c0a63ba68be1a7b2c640e70d7a06464e4fcavboxsync * (CDDL) only, as it comes in the "COPYING.CDDL" file of the
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync * VirtualBox OSE distribution, in which case the provisions of the
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync * CDDL are applicable instead of those of the GPL.
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync *
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync * You may elect to license modified versions of this file under the
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync * terms and conditions of either the GPL or the CDDL or both.
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync *
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync * Clara, CA 95054 USA or visit http://www.sun.com if you need
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync * additional information or have any questions.
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync */
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync/*******************************************************************************
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync*   Header Files                                                               *
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync*******************************************************************************/
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync#include <iprt/pipe.h>
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync#include <iprt/err.h>
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync#include <iprt/mem.h>
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync#include <iprt/string.h>
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync#include <iprt/test.h>
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsyncstatic void tstRTPipe2(void)
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync{
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTestISub("Negative");
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTPIPE  hPipeR = (RTPIPE)1;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTPIPE  hPipeW = (RTPIPE)1;
223cf005b18af2c21352a70693ebaf0582f68ebcvboxsync    RTTESTI_CHECK_RC(RTPipeCreate(&hPipeR, &hPipeW, ~0), VERR_INVALID_PARAMETER);
223cf005b18af2c21352a70693ebaf0582f68ebcvboxsync    RTTESTI_CHECK_RC(RTPipeCreate(NULL, &hPipeW, 0), VERR_INVALID_POINTER);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeCreate(&hPipeR, NULL, 0), VERR_INVALID_POINTER);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(hPipeR == (RTPIPE)1);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(hPipeW == (RTPIPE)1);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
afed5ab737f4aacfae3fe73776f40e989190a7cavboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    char abBuf[_4K];
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    size_t cbRead = ~(size_t)3;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeRead(hPipeW, abBuf, 0, &cbRead), VERR_ACCESS_DENIED);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeRead(hPipeW, abBuf, 1, &cbRead), VERR_ACCESS_DENIED);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(cbRead == ~(size_t)3);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeReadBlocking(hPipeW, abBuf, 0), VERR_ACCESS_DENIED);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeReadBlocking(hPipeW, abBuf, 1), VERR_ACCESS_DENIED);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    size_t cbWrite = ~(size_t)5;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeWrite(hPipeR, "asdf", 0, &cbWrite), VERR_ACCESS_DENIED);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeWrite(hPipeR, "asdf", 4, &cbWrite), VERR_ACCESS_DENIED);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(cbWrite == ~(size_t)5);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeWriteBlocking(hPipeR, "asdf", 0), VERR_ACCESS_DENIED);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeWriteBlocking(hPipeR, "asdf", 4), VERR_ACCESS_DENIED);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeFlush(hPipeR), VERR_ACCESS_DENIED);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeClose(hPipeW), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync}
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsyncstatic void tstRTPipe1(void)
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync{
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTestISub("Basics");
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTPIPE  hPipeR = NIL_RTPIPE;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTPIPE  hPipeW = NIL_RTPIPE;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(hPipeR != NIL_RTPIPE);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(hPipeW != NIL_RTPIPE);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeR), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeClose(NIL_RTPIPE), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    hPipeR = NIL_RTPIPE;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    hPipeW = NIL_RTPIPE;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_READ | RTPIPE_C_INHERIT_WRITE), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    int rc = RTPipeFlush(hPipeW);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(rc == VERR_NOT_SUPPORTED || rc == VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeR), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_READ), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeSelectOne(hPipeR, 0), VERR_TIMEOUT);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeSelectOne(hPipeR, 1), VERR_TIMEOUT);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeSelectOne(hPipeW, 0), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeSelectOne(hPipeW, 1), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeR), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_WRITE), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeR), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_READ), VINF_SUCCESS);
fdea543f71872a3ec3909536a4fce37ab7aa3a8bvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    size_t  cbRead = ~(size_t)0;
fdea543f71872a3ec3909536a4fce37ab7aa3a8bvboxsync    char    abBuf[_64K + _4K];
fdea543f71872a3ec3909536a4fce37ab7aa3a8bvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, abBuf, sizeof(abBuf), &cbRead), VINF_TRY_AGAIN);
fdea543f71872a3ec3909536a4fce37ab7aa3a8bvboxsync    RTTESTI_CHECK_RETV(cbRead == 0);
fdea543f71872a3ec3909536a4fce37ab7aa3a8bvboxsync
fdea543f71872a3ec3909536a4fce37ab7aa3a8bvboxsync    cbRead = ~(size_t)0;
fdea543f71872a3ec3909536a4fce37ab7aa3a8bvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, abBuf, 1, &cbRead), VINF_TRY_AGAIN);
8f7bc6ad2b7bbcb4b3b96248cd2478e45f2e3b88vboxsync    RTTESTI_CHECK_RETV(cbRead == 0);
8f7bc6ad2b7bbcb4b3b96248cd2478e45f2e3b88vboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbRead = ~(size_t)0;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, abBuf, 0, &cbRead), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(cbRead == 0);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    size_t cbWritten = ~(size_t)2;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeWrite(hPipeW, abBuf, 0, &cbWritten), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(cbWritten == 0);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    /* We can write a number of bytes without blocking (see PIPE_BUF on
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync       POSIX systems). */
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbWritten = ~(size_t)2;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeWrite(hPipeW, "42", 2, &cbWritten), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(cbWritten == 2);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbWritten = ~(size_t)2;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeWrite(hPipeW, "!", 1, &cbWritten), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(cbWritten == 1);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbRead = ~(size_t)0;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, abBuf, 3, &cbRead), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(cbRead == 3);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(!memcmp(abBuf, "42!", 3));
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbWritten = ~(size_t)2;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeWrite(hPipeW, "BigQ", 4, &cbWritten), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(cbWritten == 4);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbRead = ~(size_t)0;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeSelectOne(hPipeR, 0), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeSelectOne(hPipeR, 1), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, abBuf, sizeof(abBuf), &cbRead), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(cbRead == 4);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(!memcmp(abBuf, "BigQ", 4));
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbWritten = ~(size_t)2;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeWrite(hPipeW, "H2G2", 4, &cbWritten), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(cbWritten == 4);
a11c569636fa6838bd423f4631a9660a5a84204bvboxsync    cbRead = ~(size_t)0;
a11c569636fa6838bd423f4631a9660a5a84204bvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, &abBuf[0], 1, &cbRead), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(cbRead == 1);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbRead = ~(size_t)0;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, &abBuf[1], 1, &cbRead), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(cbRead == 1);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbRead = ~(size_t)0;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, &abBuf[2], 1, &cbRead), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(cbRead == 1);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbRead = ~(size_t)0;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, &abBuf[3], 1, &cbRead), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(cbRead == 1);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RETV(!memcmp(abBuf, "H2G2", 4));
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeR), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
3ecf9412133496b2aeb090cfd33a286404ec59fbvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTestISub("VERR_BROKEN_PIPE");
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeR), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbWritten = ~(size_t)2;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeWrite(hPipeW, "", 0, &cbWritten), VERR_BROKEN_PIPE);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(cbWritten == ~(size_t)2);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbWritten = ~(size_t)2;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeWrite(hPipeW, "4", 1, &cbWritten), VERR_BROKEN_PIPE);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(cbWritten == ~(size_t)2);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeClose(hPipeW), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbRead = ~(size_t)0;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeRead(hPipeR, abBuf, 0, &cbRead), VINF_SUCCESS);         // !?
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(cbRead == 0);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbRead = ~(size_t)3;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeRead(hPipeR, abBuf, sizeof(abBuf), &cbRead), VERR_BROKEN_PIPE);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(cbRead == ~(size_t)3);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
aaeb2e2f6ed5b164f1dec9a16a7adeb84f64cf31vboxsync    cbWritten = ~(size_t)2;
223cf005b18af2c21352a70693ebaf0582f68ebcvboxsync    RTTESTI_CHECK_RC(RTPipeWrite(hPipeW, "42", 2, &cbWritten), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(cbWritten == 2);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbRead = ~(size_t)0;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, abBuf, 0, &cbRead), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(cbRead == 0);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbRead = ~(size_t)0;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeRead(hPipeR, &abBuf[0], 1, &cbRead), VINF_SUCCESS);
aaeb2e2f6ed5b164f1dec9a16a7adeb84f64cf31vboxsync    RTTESTI_CHECK(cbRead == 1);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbRead = ~(size_t)0;
aaeb2e2f6ed5b164f1dec9a16a7adeb84f64cf31vboxsync    RTTESTI_CHECK_RC(RTPipeRead(hPipeR, &abBuf[1], 1, &cbRead), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(cbRead == 1);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(!memcmp(abBuf, "42", 2));
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbRead = ~(size_t)0;
78a205e3fc6719d59e8c561b3d287d3a4f879852vboxsync    RTTESTI_CHECK_RC(RTPipeRead(hPipeR, abBuf, 0, &cbRead), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(cbRead == 0);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbRead = ~(size_t)3;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, abBuf, sizeof(abBuf), &cbRead), VERR_BROKEN_PIPE);
aaeb2e2f6ed5b164f1dec9a16a7adeb84f64cf31vboxsync    RTTESTI_CHECK(cbRead == ~(size_t)3);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTestISub("Blocking");
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeWrite(hPipeW, "42!", 3, &cbWritten), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(cbWritten == 3);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, abBuf, 3), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(!memcmp(abBuf, "42!", 3));
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeClose(hPipeW), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[0], 0), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[0], 1), VERR_BROKEN_PIPE);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeWriteBlocking(hPipeW, "42!", 3), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(cbWritten == 3);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    cbRead = ~(size_t)0;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeRead(hPipeR, &abBuf[0], 1, &cbRead), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(cbRead == 1);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[1], 1), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[2], 1), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK(!memcmp(abBuf, "42!", 3));
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeWriteBlocking(hPipeW, "", 0), VERR_BROKEN_PIPE);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC_RETV(RTPipeWriteBlocking(hPipeW, "42", 2), VERR_BROKEN_PIPE);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTESTI_CHECK_RC(RTPipeClose(hPipeW), VINF_SUCCESS);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync}
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsyncint main()
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync{
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    RTTEST hTest;
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    int rc = RTTestInitAndCreate("tstRTPipe", &hTest);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    if (rc)
8a132edc1577cbe2a19cd778c1b2bea6ae5e8515vboxsync        return rc;
8a132edc1577cbe2a19cd778c1b2bea6ae5e8515vboxsync    RTTestBanner(hTest);
8a132edc1577cbe2a19cd778c1b2bea6ae5e8515vboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    /*
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync     * The tests.
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync     */
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    tstRTPipe1();
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    if (RTTestErrorCount(hTest) == 0)
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    {
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync        bool fMayPanic = RTAssertMayPanic();
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync        bool fQuiet    = RTAssertAreQuiet();
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync        RTAssertSetMayPanic(false);
f9147fe1eaa4e35287f8f39282c7f92f0d7de0b7vboxsync        RTAssertSetQuiet(true);
585f64d6f624f9e683321dabeb21b0eb2e6aa473vboxsync        tstRTPipe2();
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync        RTAssertSetQuiet(fQuiet);
223cf005b18af2c21352a70693ebaf0582f68ebcvboxsync        RTAssertSetMayPanic(fMayPanic);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    }
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    /*
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync     * Summary.
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync     */
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync    return RTTestSummaryAndDestroy(hTest);
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync}
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync
d408b82da0773c7e8cd4b3a01cb8a065a2c73a2dvboxsync