637712559132d2b3617aea0103fb0385978da14evboxsync/* $Id$ */
637712559132d2b3617aea0103fb0385978da14evboxsync/** @file
4efd24e631e5312d1fb78ae7ccaf9de912ff0e9fvboxsync * IPRT - Anonymous Pipes, POSIX Implementation.
637712559132d2b3617aea0103fb0385978da14evboxsync */
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync/*
c7814cf6e1240a519cbec0441e033d0e2470ed00vboxsync * Copyright (C) 2010-2013 Oracle Corporation
637712559132d2b3617aea0103fb0385978da14evboxsync *
637712559132d2b3617aea0103fb0385978da14evboxsync * This file is part of VirtualBox Open Source Edition (OSE), as
637712559132d2b3617aea0103fb0385978da14evboxsync * available from http://www.virtualbox.org. This file is free software;
637712559132d2b3617aea0103fb0385978da14evboxsync * you can redistribute it and/or modify it under the terms of the GNU
637712559132d2b3617aea0103fb0385978da14evboxsync * General Public License (GPL) as published by the Free Software
637712559132d2b3617aea0103fb0385978da14evboxsync * Foundation, in version 2 as it comes in the "COPYING" file of the
637712559132d2b3617aea0103fb0385978da14evboxsync * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
637712559132d2b3617aea0103fb0385978da14evboxsync * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
637712559132d2b3617aea0103fb0385978da14evboxsync *
637712559132d2b3617aea0103fb0385978da14evboxsync * The contents of this file may alternatively be used under the terms
637712559132d2b3617aea0103fb0385978da14evboxsync * of the Common Development and Distribution License Version 1.0
637712559132d2b3617aea0103fb0385978da14evboxsync * (CDDL) only, as it comes in the "COPYING.CDDL" file of the
637712559132d2b3617aea0103fb0385978da14evboxsync * VirtualBox OSE distribution, in which case the provisions of the
637712559132d2b3617aea0103fb0385978da14evboxsync * CDDL are applicable instead of those of the GPL.
637712559132d2b3617aea0103fb0385978da14evboxsync *
637712559132d2b3617aea0103fb0385978da14evboxsync * You may elect to license modified versions of this file under the
637712559132d2b3617aea0103fb0385978da14evboxsync * terms and conditions of either the GPL or the CDDL or both.
637712559132d2b3617aea0103fb0385978da14evboxsync */
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync/*******************************************************************************
637712559132d2b3617aea0103fb0385978da14evboxsync* Header Files *
637712559132d2b3617aea0103fb0385978da14evboxsync*******************************************************************************/
637712559132d2b3617aea0103fb0385978da14evboxsync#include <iprt/pipe.h>
637712559132d2b3617aea0103fb0385978da14evboxsync#include "internal/iprt.h"
637712559132d2b3617aea0103fb0385978da14evboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include <iprt/asm.h>
637712559132d2b3617aea0103fb0385978da14evboxsync#include <iprt/assert.h>
637712559132d2b3617aea0103fb0385978da14evboxsync#include <iprt/err.h>
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include <iprt/mem.h>
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync#include <iprt/poll.h>
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include <iprt/string.h>
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include <iprt/thread.h>
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include "internal/magics.h"
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include <errno.h>
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include <fcntl.h>
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include <limits.h>
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include <unistd.h>
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync#include <sys/ioctl.h>
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include <sys/poll.h>
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync#include <sys/stat.h>
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#include <signal.h>
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync#ifdef RT_OS_LINUX
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync# include <sys/syscall.h>
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync#endif
c174d0addd9e326ef59c0de7ff0176345fb0118avboxsync#ifdef RT_OS_SOLARIS
c174d0addd9e326ef59c0de7ff0176345fb0118avboxsync# include <sys/filio.h>
c174d0addd9e326ef59c0de7ff0176345fb0118avboxsync#endif
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync#include "internal/pipe.h"
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync/*******************************************************************************
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync* Structures and Typedefs *
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync*******************************************************************************/
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsynctypedef struct RTPIPEINTERNAL
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync{
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync /** Magic value (RTPIPE_MAGIC). */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync uint32_t u32Magic;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync /** The file descriptor. */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync int fd;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync /** Set if this is the read end, clear if it's the write end. */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync bool fRead;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync /** Atomically operated state variable.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync *
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * - Bits 0 thru 29 - Users of the new mode.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * - Bit 30 - The pipe mode, set indicates blocking.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * - Bit 31 - Set when we're switching the mode.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync uint32_t volatile u32State;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync} RTPIPEINTERNAL;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync/*******************************************************************************
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync* Defined Constants And Macros *
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync*******************************************************************************/
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync/** @name RTPIPEINTERNAL::u32State defines
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * @{ */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#define RTPIPE_POSIX_BLOCKING UINT32_C(0x40000000)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#define RTPIPE_POSIX_SWITCHING UINT32_C(0x80000000)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#define RTPIPE_POSIX_SWITCHING_BIT 31
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync#define RTPIPE_POSIX_USERS_MASK UINT32_C(0x3fffffff)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync/** @} */
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync/**
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync * Wrapper for calling pipe2() or pipe().
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync *
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync * When using pipe2() the returned handles are marked close-on-exec and does
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync * not risk racing process creation calls on other threads.
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync *
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync * @returns See pipe().
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync * @param paFds See pipe().
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync * @param piNewPipeSyscall Where to cache which call we should used. -1 if
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync * pipe(), 1 if pipe2(), 0 if not yet decided.
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync */
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsyncstatic int my_pipe_wrapper(int *paFds, int *piNewPipeSyscall)
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync{
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync if (*piNewPipeSyscall >= 0)
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync {
34d9e1cb32bd0b95b641d278348417a6518d26d2vboxsync#if defined(RT_OS_LINUX) && defined(__NR_pipe2) && defined(O_CLOEXEC)
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync long rc = syscall(__NR_pipe2, paFds, O_CLOEXEC);
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync if (rc >= 0)
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync {
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync if (*piNewPipeSyscall == 0)
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync *piNewPipeSyscall = 1;
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync return (int)rc;
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync }
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync#endif
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync *piNewPipeSyscall = -1;
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync }
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync return pipe(paFds);
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync}
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync
637712559132d2b3617aea0103fb0385978da14evboxsyncRTDECL(int) RTPipeCreate(PRTPIPE phPipeRead, PRTPIPE phPipeWrite, uint32_t fFlags)
637712559132d2b3617aea0103fb0385978da14evboxsync{
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertPtrReturn(phPipeRead, VERR_INVALID_POINTER);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertPtrReturn(phPipeWrite, VERR_INVALID_POINTER);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(!(fFlags & ~RTPIPE_C_VALID_MASK), VERR_INVALID_PARAMETER);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync /*
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync * Create the pipe and clear/set the close-on-exec flag as required.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync int aFds[2] = {-1, -1};
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync static int s_iNewPipeSyscall = 0;
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync if (my_pipe_wrapper(aFds, &s_iNewPipeSyscall))
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return RTErrConvertFromErrno(errno);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync int rc = VINF_SUCCESS;
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync if (s_iNewPipeSyscall > 0)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync /* created with close-on-exec set. */
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync if (fFlags & RTPIPE_C_INHERIT_READ)
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync {
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync if (fcntl(aFds[0], F_SETFD, 0))
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync rc = RTErrConvertFromErrno(errno);
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync if (fFlags & RTPIPE_C_INHERIT_WRITE)
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync {
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync if (fcntl(aFds[1], F_SETFD, 0))
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync rc = RTErrConvertFromErrno(errno);
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync }
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync }
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync else
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync /* created with close-on-exec cleared. */
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync if (!(fFlags & RTPIPE_C_INHERIT_READ))
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync {
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync if (fcntl(aFds[0], F_SETFD, FD_CLOEXEC))
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync rc = RTErrConvertFromErrno(errno);
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync }
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync if (!(fFlags & RTPIPE_C_INHERIT_WRITE))
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync {
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync if (fcntl(aFds[1], F_SETFD, FD_CLOEXEC))
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync rc = RTErrConvertFromErrno(errno);
b2e185d7c946ed90402d1dd86b24c6d82d8e591bvboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (RT_SUCCESS(rc))
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync /*
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync * Create the two handles.
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync */
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync RTPIPEINTERNAL *pThisR = (RTPIPEINTERNAL *)RTMemAlloc(sizeof(RTPIPEINTERNAL));
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync if (pThisR)
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync {
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync RTPIPEINTERNAL *pThisW = (RTPIPEINTERNAL *)RTMemAlloc(sizeof(RTPIPEINTERNAL));
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync if (pThisW)
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync {
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync pThisR->u32Magic = RTPIPE_MAGIC;
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync pThisW->u32Magic = RTPIPE_MAGIC;
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync pThisR->fd = aFds[0];
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync pThisW->fd = aFds[1];
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync pThisR->fRead = true;
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync pThisW->fRead = false;
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync pThisR->u32State = RTPIPE_POSIX_BLOCKING;
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync pThisW->u32State = RTPIPE_POSIX_BLOCKING;
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync *phPipeRead = pThisR;
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync *phPipeWrite = pThisW;
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync /*
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync * Before we leave, make sure to shut up SIGPIPE.
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync */
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync signal(SIGPIPE, SIG_IGN);
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync return VINF_SUCCESS;
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync }
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync RTMemFree(pThisR);
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync rc = VERR_NO_MEMORY;
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync }
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync else
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync rc = VERR_NO_MEMORY;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync close(aFds[0]);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync close(aFds[1]);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return rc;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsyncRTDECL(int) RTPipeClose(RTPIPE hPipe)
637712559132d2b3617aea0103fb0385978da14evboxsync{
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTPIPEINTERNAL *pThis = hPipe;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (pThis == NIL_RTPIPE)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return VINF_SUCCESS;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertPtrReturn(pThis, VERR_INVALID_PARAMETER);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync /*
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * Do the cleanup.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(ASMAtomicCmpXchgU32(&pThis->u32Magic, ~RTPIPE_MAGIC, RTPIPE_MAGIC), VERR_INVALID_HANDLE);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync int fd = pThis->fd;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync pThis->fd = -1;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync close(fd);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (ASMAtomicReadU32(&pThis->u32State) & RTPIPE_POSIX_USERS_MASK)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertFailed();
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTThreadSleep(1);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTMemFree(pThis);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return VINF_SUCCESS;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsyncRTDECL(int) RTPipeFromNative(PRTPIPE phPipe, RTHCINTPTR hNativePipe, uint32_t fFlags)
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync{
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync AssertPtrReturn(phPipe, VERR_INVALID_POINTER);
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync AssertReturn(!(fFlags & ~RTPIPE_N_VALID_MASK), VERR_INVALID_PARAMETER);
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync AssertReturn(!!(fFlags & RTPIPE_N_READ) != !!(fFlags & RTPIPE_N_WRITE), VERR_INVALID_PARAMETER);
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync /*
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync * Get and validate the pipe handle info.
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync */
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync int hNative = (int)hNativePipe;
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync struct stat st;
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync AssertReturn(fstat(hNative, &st) == 0, RTErrConvertFromErrno(errno));
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync AssertMsgReturn(S_ISFIFO(st.st_mode) || S_ISSOCK(st.st_mode), ("%#x (%o)\n", st.st_mode, st.st_mode), VERR_INVALID_HANDLE);
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync int fFd = fcntl(hNative, F_GETFL, 0);
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync AssertReturn(fFd != -1, VERR_INVALID_HANDLE);
21a146e63ee0fdd6658cf0fb9ee378dacd5e416bvboxsync AssertMsgReturn( (fFd & O_ACCMODE) == (fFlags & RTPIPE_N_READ ? O_RDONLY : O_WRONLY)
21a146e63ee0fdd6658cf0fb9ee378dacd5e416bvboxsync || (fFd & O_ACCMODE) == O_RDWR /* Solaris creates bi-directional pipes. */
21a146e63ee0fdd6658cf0fb9ee378dacd5e416bvboxsync , ("%#x\n", fFd), VERR_INVALID_HANDLE);
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync /*
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync * Create the handle.
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync */
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync RTPIPEINTERNAL *pThis = (RTPIPEINTERNAL *)RTMemAlloc(sizeof(RTPIPEINTERNAL));
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync if (!pThis)
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync return VERR_NO_MEMORY;
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync pThis->u32Magic = RTPIPE_MAGIC;
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync pThis->fd = hNative;
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync pThis->fRead = !!(fFlags & RTPIPE_N_READ);
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync pThis->u32State = fFd & O_NONBLOCK ? 0 : RTPIPE_POSIX_BLOCKING;
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync /*
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync * Fix up inheritability and shut up SIGPIPE and we're done.
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync */
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync if (fcntl(hNative, F_SETFD, fFlags & RTPIPE_N_INHERIT ? 0 : FD_CLOEXEC) == 0)
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync {
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync signal(SIGPIPE, SIG_IGN);
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync *phPipe = pThis;
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync return VINF_SUCCESS;
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync }
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync int rc = RTErrConvertFromErrno(errno);
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync RTMemFree(pThis);
eeee785f36554f67d8737506fb0fadbf683cf9dfvboxsync return rc;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync}
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsyncRTDECL(RTHCINTPTR) RTPipeToNative(RTPIPE hPipe)
637712559132d2b3617aea0103fb0385978da14evboxsync{
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTPIPEINTERNAL *pThis = hPipe;
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync AssertPtrReturn(pThis, -1);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, -1);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return pThis->fd;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync}
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync/**
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * Prepare blocking mode.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync *
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * @returns VINF_SUCCESS
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * @retval VERR_WRONG_ORDER
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * @retval VERR_INTERNAL_ERROR_4
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync *
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * @param pThis The pipe handle.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsyncstatic int rtPipeTryBlocking(RTPIPEINTERNAL *pThis)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync{
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync /*
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * Update the state.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync for (;;)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync uint32_t u32State = ASMAtomicReadU32(&pThis->u32State);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync uint32_t const u32StateOld = u32State;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync uint32_t const cUsers = (u32State & RTPIPE_POSIX_USERS_MASK);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (u32State & RTPIPE_POSIX_BLOCKING)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(cUsers < RTPIPE_POSIX_USERS_MASK / 2, VERR_INTERNAL_ERROR_4);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync u32State &= ~RTPIPE_POSIX_USERS_MASK;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync u32State |= cUsers + 1;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (ASMAtomicCmpXchgU32(&pThis->u32State, u32State, u32StateOld))
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (u32State & RTPIPE_POSIX_SWITCHING)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync break;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return VINF_SUCCESS;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync else if (cUsers == 0)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync u32State = 1 | RTPIPE_POSIX_SWITCHING | RTPIPE_POSIX_BLOCKING;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (ASMAtomicCmpXchgU32(&pThis->u32State, u32State, u32StateOld))
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync break;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync else
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return VERR_WRONG_ORDER;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync ASMNopPause();
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync /*
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * Do the switching.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync int fFlags = fcntl(pThis->fd, F_GETFL, 0);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (fFlags != -1)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if ( !(fFlags & O_NONBLOCK)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync || fcntl(pThis->fd, F_SETFL, fFlags & ~O_NONBLOCK) != -1)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync ASMAtomicBitClear(&pThis->u32State, RTPIPE_POSIX_SWITCHING_BIT);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return VINF_SUCCESS;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync ASMAtomicDecU32(&pThis->u32State);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return RTErrConvertFromErrno(errno);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync}
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync/**
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * Prepare non-blocking mode.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync *
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * @returns VINF_SUCCESS
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * @retval VERR_WRONG_ORDER
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * @retval VERR_INTERNAL_ERROR_4
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync *
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * @param pThis The pipe handle.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsyncstatic int rtPipeTryNonBlocking(RTPIPEINTERNAL *pThis)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync{
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync /*
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * Update the state.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync for (;;)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync uint32_t u32State = ASMAtomicReadU32(&pThis->u32State);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync uint32_t const u32StateOld = u32State;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync uint32_t const cUsers = (u32State & RTPIPE_POSIX_USERS_MASK);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (!(u32State & RTPIPE_POSIX_BLOCKING))
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(cUsers < RTPIPE_POSIX_USERS_MASK / 2, VERR_INTERNAL_ERROR_4);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync u32State &= ~RTPIPE_POSIX_USERS_MASK;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync u32State |= cUsers + 1;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (ASMAtomicCmpXchgU32(&pThis->u32State, u32State, u32StateOld))
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (u32State & RTPIPE_POSIX_SWITCHING)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync break;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return VINF_SUCCESS;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync else if (cUsers == 0)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync u32State = 1 | RTPIPE_POSIX_SWITCHING;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (ASMAtomicCmpXchgU32(&pThis->u32State, u32State, u32StateOld))
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync break;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync else
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return VERR_WRONG_ORDER;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync ASMNopPause();
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync /*
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * Do the switching.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync int fFlags = fcntl(pThis->fd, F_GETFL, 0);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (fFlags != -1)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if ( (fFlags & O_NONBLOCK)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync || fcntl(pThis->fd, F_SETFL, fFlags | O_NONBLOCK) != -1)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync ASMAtomicBitClear(&pThis->u32State, RTPIPE_POSIX_SWITCHING_BIT);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return VINF_SUCCESS;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync ASMAtomicDecU32(&pThis->u32State);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return RTErrConvertFromErrno(errno);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync}
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync/**
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * Checks if the read pipe has a HUP condition.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync *
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * @returns true if HUP, false if no.
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync * @param pThis The pipe handle (read).
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync */
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsyncstatic bool rtPipePosixHasHup(RTPIPEINTERNAL *pThis)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync{
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync Assert(pThis->fRead);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync struct pollfd PollFd;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RT_ZERO(PollFd);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync PollFd.fd = pThis->fd;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync PollFd.events = POLLHUP;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return poll(&PollFd, 1, 0) >= 1
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync && (PollFd.revents & POLLHUP);
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsyncRTDECL(int) RTPipeRead(RTPIPE hPipe, void *pvBuf, size_t cbToRead, size_t *pcbRead)
637712559132d2b3617aea0103fb0385978da14evboxsync{
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTPIPEINTERNAL *pThis = hPipe;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(pThis->fRead, VERR_ACCESS_DENIED);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertPtr(pcbRead);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertPtr(pvBuf);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync int rc = rtPipeTryNonBlocking(pThis);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (RT_SUCCESS(rc))
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync ssize_t cbRead = read(pThis->fd, pvBuf, RT_MIN(cbToRead, SSIZE_MAX));
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (cbRead >= 0)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (cbRead || !cbToRead || !rtPipePosixHasHup(pThis))
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync *pcbRead = cbRead;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync else
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync rc = VERR_BROKEN_PIPE;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync else if (errno == EAGAIN)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync *pcbRead = 0;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync rc = VINF_TRY_AGAIN;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync else
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync rc = RTErrConvertFromErrno(errno);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync ASMAtomicDecU32(&pThis->u32State);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return rc;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsyncRTDECL(int) RTPipeReadBlocking(RTPIPE hPipe, void *pvBuf, size_t cbToRead, size_t *pcbRead)
637712559132d2b3617aea0103fb0385978da14evboxsync{
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTPIPEINTERNAL *pThis = hPipe;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(pThis->fRead, VERR_ACCESS_DENIED);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertPtr(pvBuf);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync int rc = rtPipeTryBlocking(pThis);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (RT_SUCCESS(rc))
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
9c901af82dd5443ef16e2412aa6109e1e3476325vboxsync size_t cbTotalRead = 0;
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync while (cbToRead > 0)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync ssize_t cbRead = read(pThis->fd, pvBuf, RT_MIN(cbToRead, SSIZE_MAX));
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (cbRead < 0)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync rc = RTErrConvertFromErrno(errno);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync break;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
9c901af82dd5443ef16e2412aa6109e1e3476325vboxsync if (!cbRead && rtPipePosixHasHup(pThis))
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync rc = VERR_BROKEN_PIPE;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync break;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync /* advance */
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync pvBuf = (char *)pvBuf + cbRead;
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync cbTotalRead += cbRead;
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync cbToRead -= cbRead;
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync }
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync if (pcbRead)
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync {
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync *pcbRead = cbTotalRead;
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync if ( RT_FAILURE(rc)
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync && cbTotalRead
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync && rc != VERR_INVALID_POINTER)
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync rc = VINF_SUCCESS;
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync ASMAtomicDecU32(&pThis->u32State);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return rc;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsyncRTDECL(int) RTPipeWrite(RTPIPE hPipe, const void *pvBuf, size_t cbToWrite, size_t *pcbWritten)
637712559132d2b3617aea0103fb0385978da14evboxsync{
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTPIPEINTERNAL *pThis = hPipe;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(!pThis->fRead, VERR_ACCESS_DENIED);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertPtr(pcbWritten);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertPtr(pvBuf);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync int rc = rtPipeTryNonBlocking(pThis);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (RT_SUCCESS(rc))
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync if (cbToWrite)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync ssize_t cbWritten = write(pThis->fd, pvBuf, RT_MIN(cbToWrite, SSIZE_MAX));
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync if (cbWritten >= 0)
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync *pcbWritten = cbWritten;
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync else if (errno == EAGAIN)
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync {
d142cd5e90598dd8d14744cb6bb7dd467cec446cvboxsync *pcbWritten = 0;
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync rc = VINF_TRY_AGAIN;
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync }
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync else
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync rc = RTErrConvertFromErrno(errno);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync else
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync *pcbWritten = 0;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync ASMAtomicDecU32(&pThis->u32State);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return rc;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsyncRTDECL(int) RTPipeWriteBlocking(RTPIPE hPipe, const void *pvBuf, size_t cbToWrite, size_t *pcbWritten)
637712559132d2b3617aea0103fb0385978da14evboxsync{
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTPIPEINTERNAL *pThis = hPipe;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(!pThis->fRead, VERR_ACCESS_DENIED);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertPtr(pvBuf);
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync AssertPtrNull(pcbWritten);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync int rc = rtPipeTryBlocking(pThis);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (RT_SUCCESS(rc))
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync size_t cbTotalWritten = 0;
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync while (cbToWrite > 0)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync ssize_t cbWritten = write(pThis->fd, pvBuf, RT_MIN(cbToWrite, SSIZE_MAX));
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (cbWritten < 0)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync {
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync rc = RTErrConvertFromErrno(errno);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync break;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync /* advance */
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync pvBuf = (char const *)pvBuf + cbWritten;
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync cbTotalWritten += cbWritten;
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync cbToWrite -= cbWritten;
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync }
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync if (pcbWritten)
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync {
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync *pcbWritten = cbTotalWritten;
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync if ( RT_FAILURE(rc)
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync && cbTotalWritten
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync && rc != VERR_INVALID_POINTER)
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync rc = VINF_SUCCESS;
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync ASMAtomicDecU32(&pThis->u32State);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return rc;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsyncRTDECL(int) RTPipeFlush(RTPIPE hPipe)
637712559132d2b3617aea0103fb0385978da14evboxsync{
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTPIPEINTERNAL *pThis = hPipe;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(!pThis->fRead, VERR_ACCESS_DENIED);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (fsync(pThis->fd))
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync {
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync if (errno == EINVAL || errno == ENOTSUP)
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync return VERR_NOT_SUPPORTED;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return RTErrConvertFromErrno(errno);
45c4c3d2db1a166b7b1e92960adb823960821386vboxsync }
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return VINF_SUCCESS;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsyncRTDECL(int) RTPipeSelectOne(RTPIPE hPipe, RTMSINTERVAL cMillies)
637712559132d2b3617aea0103fb0385978da14evboxsync{
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RTPIPEINTERNAL *pThis = hPipe;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync struct pollfd PollFd;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync RT_ZERO(PollFd);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync PollFd.fd = pThis->fd;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync PollFd.events = POLLHUP | POLLERR;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (pThis->fRead)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync PollFd.events |= POLLIN | POLLPRI;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync else
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync PollFd.events |= POLLOUT;
637712559132d2b3617aea0103fb0385978da14evboxsync
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync int timeout;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if ( cMillies == RT_INDEFINITE_WAIT
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync || cMillies >= INT_MAX /* lazy bird */)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync timeout = -1;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync else
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync timeout = cMillies;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync
2b82ac8b29c726b283836323dcc3603310953028vboxsync int rc = poll(&PollFd, 1, timeout);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync if (rc == -1)
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return RTErrConvertFromErrno(errno);
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync return rc > 0 ? VINF_SUCCESS : VERR_TIMEOUT;
b41f65ee355ae1d4b24473c6d6d70c653497429avboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsyncRTDECL(int) RTPipeQueryReadable(RTPIPE hPipe, size_t *pcbReadable)
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync{
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync RTPIPEINTERNAL *pThis = hPipe;
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync AssertReturn(pThis->fRead, VERR_PIPE_NOT_READ);
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync AssertPtrReturn(pcbReadable, VERR_INVALID_POINTER);
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync int cb = 0;
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync int rc = ioctl(pThis->fd, FIONREAD, &cb);
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync if (rc != -1)
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync {
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync AssertStmt(cb >= 0, cb = 0);
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync *pcbReadable = cb;
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync return VINF_SUCCESS;
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync }
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync rc = errno;
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync if (rc == ENOTTY)
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync rc = VERR_NOT_SUPPORTED;
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync else
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync rc = RTErrConvertFromErrno(rc);
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync return rc;
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync}
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsyncint rtPipePollGetHandle(RTPIPE hPipe, uint32_t fEvents, PRTHCINTPTR phNative)
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync{
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync RTPIPEINTERNAL *pThis = hPipe;
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync AssertReturn(!(fEvents & RTPOLL_EVT_READ) || pThis->fRead, VERR_INVALID_PARAMETER);
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync AssertReturn(!(fEvents & RTPOLL_EVT_WRITE) || !pThis->fRead, VERR_INVALID_PARAMETER);
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync *phNative = pThis->fd;
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync return VINF_SUCCESS;
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync}
5a80f559035e4c5600e6486ec9f3a7ebb28efc48vboxsync