Runtime/testcase/tstRTPipe.cpp

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