b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync/* $Id$ */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync/** @file
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * IPRT Testcase - RTPipe.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync/*
c7814cf6e1240a519cbec0441e033d0e2470ed00vboxsync * Copyright (C) 2010-2011 Oracle Corporation
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
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync/*******************************************************************************
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync* Header Files *
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync*******************************************************************************/
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include <iprt/pipe.h>
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync#include <iprt/env.h>
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include <iprt/err.h>
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync#include <iprt/initterm.h>
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include <iprt/mem.h>
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync#include <iprt/message.h>
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync#include <iprt/param.h>
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync#include <iprt/process.h>
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include <iprt/string.h>
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include <iprt/test.h>
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync/*******************************************************************************
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync* Global Variables *
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync*******************************************************************************/
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsyncstatic const char g_szTest4Message[] = "This is test #4, everything is working fine.\n\r";
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsyncstatic const char g_szTest5Message[] = "This is test #5, everything is working fine.\n\r";
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsyncstatic RTEXITCODE tstRTPipe5Child(const char *pszPipe)
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync{
230bd8589bba39933ac5ec21482d6186d675e604vboxsync int rc = RTR3InitExeNoArguments(0);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (RT_FAILURE(rc))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return RTMsgInitFailure(rc);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync int64_t iNative;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync rc = RTStrToInt64Full(pszPipe, 10, &iNative);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (RT_FAILURE(rc))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTStrToUInt64Full(%s) -> %Rrc\n", pszPipe, rc);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTPIPE hPipe;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync rc = RTPipeFromNative(&hPipe, (RTHCINTPTR)iNative, RTPIPE_N_READ);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (RT_FAILURE(rc))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTPipeFromNative(,%s,READ) -> %Rrc\n", pszPipe, rc);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync ///
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync char szTmp[1024];
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync size_t cbRead = 0;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync rc = RTPipeReadBlocking(hPipe, szTmp, sizeof(szTmp) - 1, &cbRead);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (RT_FAILURE(rc))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTPipeReadBlocking() -> %Rrc\n", rc);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync szTmp[cbRead] = '\0';
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync size_t cbRead2;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync char szTmp2[4];
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync rc = RTPipeReadBlocking(hPipe, szTmp2, sizeof(szTmp2), &cbRead2);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (rc != VERR_BROKEN_PIPE)
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTPipeReadBlocking() -> %Rrc instead of VERR_BROKEN_PIPE\n", rc);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync rc = RTPipeClose(hPipe);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (RT_FAILURE(rc))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTPipeClose() -> %Rrc\n", rc);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (memcmp(szTmp, g_szTest5Message, sizeof(g_szTest5Message)))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return RTMsgErrorExit(RTEXITCODE_FAILURE, "Message mismatch.\n:Expected '%s'\nGot '%s'\n", g_szTest5Message, szTmp);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return RTEXITCODE_SUCCESS;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync}
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsyncstatic void tstRTPipe5(void)
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync{
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTestISub("Inherit non-standard pipe handle, read end");
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync char szPathSelf[RTPATH_MAX];
a0cfaded2376888b45a6a207baa4e1dc0acf866dvboxsync RTTESTI_CHECK_RETV(RTProcGetExecutablePath(szPathSelf, sizeof(szPathSelf)) == szPathSelf);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTPIPE hPipeR;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTPIPE hPipeW;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_READ), VINF_SUCCESS);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTHCINTPTR hNative = RTPipeToNative(hPipeR);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RETV(hNative != -1);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync char szNative[64];
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTStrPrintf(szNative, sizeof(szNative), "%RHi", hNative);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync const char *papszArgs[4] = { szPathSelf, "--child-5", szNative, NULL };
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTPROCESS hChild;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RC_RETV(RTProcCreate(szPathSelf, papszArgs, RTENV_DEFAULT, 0 /*fFlags*/, &hChild), VINF_SUCCESS);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeR), VINF_SUCCESS);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RC(RTPipeWriteBlocking(hPipeW, g_szTest5Message, sizeof(g_szTest5Message) - 1, NULL), VINF_SUCCESS);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync int rc;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RC(rc = RTPipeClose(hPipeW), VINF_SUCCESS);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (RT_FAILURE(rc))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RC(RTProcTerminate(hChild), VINF_SUCCESS);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTPROCSTATUS ProcStatus;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RC(rc = RTProcWait(hChild, RTPROCWAIT_FLAGS_BLOCK, &ProcStatus), VINF_SUCCESS);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (RT_FAILURE(rc))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK( ProcStatus.enmReason == RTPROCEXITREASON_NORMAL
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync && ProcStatus.iStatus == 0);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync}
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsyncstatic RTEXITCODE tstRTPipe4Child(const char *pszPipe)
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync{
230bd8589bba39933ac5ec21482d6186d675e604vboxsync int rc = RTR3InitExeNoArguments(0);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (RT_FAILURE(rc))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return RTMsgInitFailure(rc);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync int64_t iNative;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync rc = RTStrToInt64Full(pszPipe, 10, &iNative);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (RT_FAILURE(rc))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTStrToUInt64Full(%s) -> %Rrc\n", pszPipe, rc);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTPIPE hPipe;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync rc = RTPipeFromNative(&hPipe, (RTHCINTPTR)iNative, RTPIPE_N_WRITE);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (RT_FAILURE(rc))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTPipeFromNative(,%s,WRITE) -> %Rrc\n", pszPipe, rc);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync rc = RTPipeWriteBlocking(hPipe, g_szTest4Message, sizeof(g_szTest4Message) - 1, NULL);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (RT_FAILURE(rc))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTPipeWriteBlocking() -> %Rrc\n", rc);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync rc = RTPipeClose(hPipe);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (RT_FAILURE(rc))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return RTMsgErrorExit(RTEXITCODE_FAILURE, "RTPipeClose() -> %Rrc\n", rc);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return RTEXITCODE_SUCCESS;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync}
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsyncstatic void tstRTPipe4(void)
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync{
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTestISub("Inherit non-standard pipe handle, write end");
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync char szPathSelf[RTPATH_MAX];
a0cfaded2376888b45a6a207baa4e1dc0acf866dvboxsync RTTESTI_CHECK_RETV(RTProcGetExecutablePath(szPathSelf, sizeof(szPathSelf)) == szPathSelf);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTPIPE hPipeR;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTPIPE hPipeW;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_WRITE), VINF_SUCCESS);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTHCINTPTR hNative = RTPipeToNative(hPipeW);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RETV(hNative != -1);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync char szNative[64];
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTStrPrintf(szNative, sizeof(szNative), "%RHi", hNative);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync const char *papszArgs[4] = { szPathSelf, "--child-4", szNative, NULL };
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTPROCESS hChild;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RC_RETV(RTProcCreate(szPathSelf, papszArgs, RTENV_DEFAULT, 0 /*fFlags*/, &hChild), VINF_SUCCESS);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeW), VINF_SUCCESS);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync char szTmp[1024];
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync size_t cbRead = 0;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync int rc;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RC(rc = RTPipeReadBlocking(hPipeR, szTmp, sizeof(szTmp) - 1, &cbRead), VINF_SUCCESS);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (RT_FAILURE(rc))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync cbRead = 0;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RETV(cbRead < sizeof(szTmp));
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync szTmp[cbRead] = '\0';
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync size_t cbRead2;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync char szTmp2[4];
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RC(RTPipeReadBlocking(hPipeR, szTmp2, sizeof(szTmp2), &cbRead2), VERR_BROKEN_PIPE);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RC(rc = RTPipeClose(hPipeR), VINF_SUCCESS);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (RT_FAILURE(rc))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RC(RTProcTerminate(hChild), VINF_SUCCESS);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTPROCSTATUS ProcStatus;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK_RC(rc = RTProcWait(hChild, RTPROCWAIT_FLAGS_BLOCK, &ProcStatus), VINF_SUCCESS);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (RT_FAILURE(rc))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTESTI_CHECK( ProcStatus.enmReason == RTPROCEXITREASON_NORMAL
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync && ProcStatus.iStatus == 0);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (memcmp(szTmp, g_szTest4Message, sizeof(g_szTest4Message)))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync RTTestIFailed("Message mismatch.\n:Expected '%s'\nGot '%s'\n", g_szTest4Message, szTmp);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync}
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
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);
5e08248e91d26e48931e78837c050a7210b10f52vboxsync RTTESTI_CHECK_MSG(rc == VINF_SUCCESS || rc == VINF_TRY_AGAIN, ("rc=%Rrc\n", rc));
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);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC(RTPipeReadBlocking(hPipeW, abBuf, 0, NULL), VERR_ACCESS_DENIED);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC(RTPipeReadBlocking(hPipeW, abBuf, 1, NULL), 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);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC(RTPipeWriteBlocking(hPipeR, "asdf", 0, NULL), VERR_ACCESS_DENIED);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC(RTPipeWriteBlocking(hPipeR, "asdf", 4, NULL), 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);
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync RTTESTI_CHECK_MSG(rc == VERR_NOT_SUPPORTED || rc == VINF_SUCCESS, ("%Rrc\n", rc));
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);
bd51228d218e2f43d2d5d7f0559901dfaac31c9cvboxsync RTTESTI_CHECK_MSG_RETV(cbWritten == 2, ("cbWritten=%zu\n", cbWritten));
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 RTTESTI_CHECK_RC_RETV(RTPipeSelectOne(hPipeR, 0), VINF_SUCCESS);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTTESTI_CHECK_RC_RETV(RTPipeSelectOne(hPipeR, 1), VINF_SUCCESS);
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync cbRead = ~(size_t)0;
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync RTTESTI_CHECK_RC_RETV(RTPipeQueryReadable(hPipeR, &cbRead), VINF_SUCCESS);
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync RTTESTI_CHECK_MSG(cbRead == cbWritten, ("cbRead=%zu cbWritten=%zu\n", cbRead, cbWritten));
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync cbRead = ~(size_t)0;
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;
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync RTTESTI_CHECK_RC_RETV(RTPipeQueryReadable(hPipeR, &cbRead), VINF_SUCCESS);
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync RTTESTI_CHECK_MSG(cbRead == cbWritten, ("cbRead=%zu cbWritten=%zu\n", cbRead, cbWritten));
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync 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;
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync RTTESTI_CHECK_RC_RETV(RTPipeQueryReadable(hPipeR, &cbRead), VINF_SUCCESS);
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync RTTESTI_CHECK_MSG(cbRead == cbWritten - 1, ("cbRead=%zu cbWritten=%zu\n", cbRead, cbWritten));
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync 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;
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync RTTESTI_CHECK_RC_RETV(RTPipeQueryReadable(hPipeR, &cbRead), VINF_SUCCESS);
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync RTTESTI_CHECK_MSG(cbRead == cbWritten - 2, ("cbRead=%zu cbWritten=%zu\n", cbRead, cbWritten));
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync 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;
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync RTTESTI_CHECK_RC_RETV(RTPipeQueryReadable(hPipeR, &cbRead), VINF_SUCCESS);
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync RTTESTI_CHECK_MSG(cbRead == cbWritten - 3, ("cbRead=%zu cbWritten=%zu\n", cbRead, cbWritten));
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync 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));
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync cbRead = ~(size_t)0;
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync RTTESTI_CHECK_RC_RETV(RTPipeQueryReadable(hPipeR, &cbRead), VINF_SUCCESS);
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync RTTESTI_CHECK_MSG(cbRead == cbWritten - 4, ("cbRead=%zu cbWritten=%zu\n", cbRead, cbWritten));
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;
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync RTTESTI_CHECK_RC(RTPipeWrite(hPipeW, "", 0, &cbWritten), VINF_SUCCESS);
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync RTTESTI_CHECK(cbWritten == 0);
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;
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync 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);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, abBuf, 3, NULL), VINF_SUCCESS);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTTESTI_CHECK(!memcmp(abBuf, "42!", 3));
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTTESTI_CHECK_RC(RTPipeClose(hPipeW), VINF_SUCCESS);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[0], 0, NULL), VINF_SUCCESS);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync cbRead = ~(size_t)42;
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[0], 0, &cbRead), VINF_SUCCESS);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK(cbRead == 0);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[0], 1, NULL), VERR_BROKEN_PIPE);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync cbRead = ~(size_t)42;
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[0], 1, &cbRead), VERR_BROKEN_PIPE);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK(cbRead == 0);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC_RETV(RTPipeWriteBlocking(hPipeW, "42!", 3, NULL), 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);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[1], 1, NULL), VINF_SUCCESS);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC_RETV(RTPipeReadBlocking(hPipeR, &abBuf[2], 1, NULL), VINF_SUCCESS);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTTESTI_CHECK(!memcmp(abBuf, "42!", 3));
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC_RETV(RTPipeWriteBlocking(hPipeW, "", 0, NULL), VINF_SUCCESS);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync cbWritten = ~(size_t)9;
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC_RETV(RTPipeWriteBlocking(hPipeW, "", 0, &cbWritten), VINF_SUCCESS);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK(cbWritten == 0);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC_RETV(RTPipeWriteBlocking(hPipeW, "42", 2, NULL), VERR_BROKEN_PIPE);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync cbWritten = ~(size_t)9;
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK_RC_RETV(RTPipeWriteBlocking(hPipeW, "42", 2, &cbWritten), VERR_BROKEN_PIPE);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync RTTESTI_CHECK(cbWritten == 0);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTTESTI_CHECK_RC(RTPipeClose(hPipeW), VINF_SUCCESS);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync}
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsyncint main(int argc, char **argv)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync{
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (argc == 3 && !strcmp(argv[1], "--child-4"))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return tstRTPipe4Child(argv[2]);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync if (argc == 3 && !strcmp(argv[1], "--child-5"))
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync return tstRTPipe5Child(argv[2]);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
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();
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync tstRTPipe4();
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync tstRTPipe5();
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync /*
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * Summary.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return RTTestSummaryAndDestroy(hTest);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync}
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync