pipe-posix.cpp revision 9c901af82dd5443ef16e2412aa6109e1e3476325
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync/* $Id$ */
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync/** @file
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * IPRT - Anonymous Pipes, POSIX Implementation.
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync */
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync/*
c7814cf6e1240a519cbec0441e033d0e2470ed00vboxsync * Copyright (C) 2010 Oracle Corporation
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync *
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * This file is part of VirtualBox Open Source Edition (OSE), as
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * available from http://www.virtualbox.org. This file is free software;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * you can redistribute it and/or modify it under the terms of the GNU
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * General Public License (GPL) as published by the Free Software
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * Foundation, in version 2 as it comes in the "COPYING" file of the
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync *
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * The contents of this file may alternatively be used under the terms
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * of the Common Development and Distribution License Version 1.0
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * (CDDL) only, as it comes in the "COPYING.CDDL" file of the
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * VirtualBox OSE distribution, in which case the provisions of the
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * CDDL are applicable instead of those of the GPL.
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync *
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * You may elect to license modified versions of this file under the
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * terms and conditions of either the GPL or the CDDL or both.
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync */
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync/*******************************************************************************
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync* Header Files *
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync*******************************************************************************/
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync#include <iprt/pipe.h>
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync#include "internal/iprt.h"
3fa7a7e633f46a212052b510cdb8cee41f279a67vboxsync
3fa7a7e633f46a212052b510cdb8cee41f279a67vboxsync#include <iprt/asm.h>
11f8b3da5f2ead2461e7998b3b091bb0f7bd14d9vboxsync#include <iprt/assert.h>
cb0578a5309e1fc264e5a4acc30543bea075be43vboxsync#include <iprt/err.h>
384478d3896257fbce9ceb8c01e74040b969e6d7vboxsync#include <iprt/mem.h>
73ba84f95f918cc170be38908ad240fbb2f8f354vboxsync#include <iprt/string.h>
73ba84f95f918cc170be38908ad240fbb2f8f354vboxsync#include <iprt/thread.h>
73ba84f95f918cc170be38908ad240fbb2f8f354vboxsync#include "internal/magics.h"
384478d3896257fbce9ceb8c01e74040b969e6d7vboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync#include <errno.h>
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync#include <fcntl.h>
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync#include <limits.h>
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync#include <unistd.h>
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync#include <sys/poll.h>
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync#include <sys/stat.h>
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync#include <signal.h>
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
3ab1cd69595235a9f15ce27945574123b0f38b46vboxsync/*******************************************************************************
3ab1cd69595235a9f15ce27945574123b0f38b46vboxsync* Structures and Typedefs *
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync*******************************************************************************/
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsynctypedef struct RTPIPEINTERNAL
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync{
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync /** Magic value (RTPIPE_MAGIC). */
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync uint32_t u32Magic;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync /** The file descriptor. */
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync int fd;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync /** Set if this is the read end, clear if it's the write end. */
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync bool fRead;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync /** Atomically operated state variable.
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync *
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync * - Bits 0 thru 29 - Users of the new mode.
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync * - Bit 30 - The pipe mode, set indicates blocking.
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync * - Bit 31 - Set when we're switching the mode.
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync */
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync uint32_t volatile u32State;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync} RTPIPEINTERNAL;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync/*******************************************************************************
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync* Defined Constants And Macros *
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync*******************************************************************************/
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync/** @name RTPIPEINTERNAL::u32State defines
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync * @{ */
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync#define RTPIPE_POSIX_BLOCKING UINT32_C(0x40000000)
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync#define RTPIPE_POSIX_SWITCHING UINT32_C(0x80000000)
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync#define RTPIPE_POSIX_SWITCHING_BIT 31
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync#define RTPIPE_POSIX_USERS_MASK UINT32_C(0x3fffffff)
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync/** @} */
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsyncRTDECL(int) RTPipeCreate(PRTPIPE phPipeRead, PRTPIPE phPipeWrite, uint32_t fFlags)
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync{
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync AssertPtrReturn(phPipeRead, VERR_INVALID_POINTER);
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync AssertPtrReturn(phPipeWrite, VERR_INVALID_POINTER);
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync AssertReturn(!(fFlags & ~RTPIPE_C_VALID_MASK), VERR_INVALID_PARAMETER);
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync /*
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync * Create the pipe and set the close-on-exec flag if requested.
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync */
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync int aFds[2] = {-1, -1};
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync if (pipe(aFds))
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync return RTErrConvertFromErrno(errno);
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync int rc = VINF_SUCCESS;
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync if (!(fFlags & RTPIPE_C_INHERIT_READ))
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync {
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync if (fcntl(aFds[0], F_SETFD, FD_CLOEXEC))
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync rc = RTErrConvertFromErrno(errno);
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync }
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync if (!(fFlags & RTPIPE_C_INHERIT_WRITE))
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync {
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync if (fcntl(aFds[1], F_SETFD, FD_CLOEXEC))
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync rc = RTErrConvertFromErrno(errno);
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync }
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync if (RT_SUCCESS(rc))
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync {
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync /*
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync * Create the two handles.
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync */
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync RTPIPEINTERNAL *pThisR = (RTPIPEINTERNAL *)RTMemAlloc(sizeof(RTPIPEINTERNAL));
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync if (pThisR)
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync {
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync RTPIPEINTERNAL *pThisW = (RTPIPEINTERNAL *)RTMemAlloc(sizeof(RTPIPEINTERNAL));
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync if (pThisW)
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync {
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync pThisR->u32Magic = RTPIPE_MAGIC;
4a9af9a8062589b741444d717d2dd1ed22b0f583vboxsync pThisW->u32Magic = RTPIPE_MAGIC;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync pThisR->fd = aFds[0];
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync pThisW->fd = aFds[1];
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync pThisR->fRead = true;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync pThisW->fRead = false;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync pThisR->u32State = RTPIPE_POSIX_BLOCKING;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync pThisW->u32State = RTPIPE_POSIX_BLOCKING;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync *phPipeRead = pThisR;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync *phPipeWrite = pThisW;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync /*
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync * Before we leave, make sure to shut up SIGPIPE.
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync */
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync signal(SIGPIPE, SIG_IGN);
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync return VINF_SUCCESS;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync }
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync RTMemFree(pThisR);
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync rc = VERR_NO_MEMORY;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync }
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync else
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync rc = VERR_NO_MEMORY;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync }
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync close(aFds[0]);
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync close(aFds[1]);
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync return rc;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync}
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsyncRTDECL(int) RTPipeClose(RTPIPE hPipe)
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync{
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync RTPIPEINTERNAL *pThis = hPipe;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync if (pThis == NIL_RTPIPE)
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync return VINF_SUCCESS;
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync AssertPtrReturn(pThis, VERR_INVALID_PARAMETER);
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync /*
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync * Do the cleanup.
1c0d3d017f9a45748b4839bf6622b53e83a4f1f8vboxsync */
3a343ca21a267ec3c54e2317e2ed18fe99b8ebbbvboxsync AssertReturn(ASMAtomicCmpXchgU32(&pThis->u32Magic, ~RTPIPE_MAGIC, RTPIPE_MAGIC), VERR_INVALID_HANDLE);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync int fd = pThis->fd;
3a343ca21a267ec3c54e2317e2ed18fe99b8ebbbvboxsync pThis->fd = -1;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync close(fd);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync if (ASMAtomicReadU32(&pThis->u32State) & RTPIPE_POSIX_USERS_MASK)
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync {
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync AssertFailed();
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync RTThreadSleep(1);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync }
3a343ca21a267ec3c54e2317e2ed18fe99b8ebbbvboxsync
3a343ca21a267ec3c54e2317e2ed18fe99b8ebbbvboxsync RTMemFree(pThis);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync return VINF_SUCCESS;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync}
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsyncRTDECL(int) RTPipeFromNative(PRTPIPE phPipe, RTHCINTPTR hNativePipe, uint32_t fFlags)
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync{
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync AssertPtrReturn(phPipe, VERR_INVALID_POINTER);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync AssertReturn(!(fFlags & ~RTPIPE_N_VALID_MASK), VERR_INVALID_PARAMETER);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync AssertReturn(!!(fFlags & RTPIPE_N_READ) != !!(fFlags & RTPIPE_N_WRITE), VERR_INVALID_PARAMETER);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync /*
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * Get and validate the pipe handle info.
73ba84f95f918cc170be38908ad240fbb2f8f354vboxsync */
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync int hNative = (int)hNativePipe;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync struct stat st;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync AssertReturn(fstat(hNative, &st) == 0, RTErrConvertFromErrno(errno));
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync AssertMsgReturn(S_ISFIFO(st.st_mode) || S_ISSOCK(st.st_mode), ("%#x (%o)\n", st.st_mode, st.st_mode), VERR_INVALID_HANDLE);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync int fFd = fcntl(hNative, F_GETFL, 0);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync AssertReturn(fFd != -1, VERR_INVALID_HANDLE);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync AssertMsgReturn( (fFd & O_ACCMODE) == (fFlags & RTPIPE_N_READ ? O_RDONLY : O_WRONLY)
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync || (fFd & O_ACCMODE) == O_RDWR /* Solaris creates bi-directional pipes. */
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync , ("%#x\n", fFd), VERR_INVALID_HANDLE);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync /*
73ba84f95f918cc170be38908ad240fbb2f8f354vboxsync * Create the handle.
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync */
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync RTPIPEINTERNAL *pThis = (RTPIPEINTERNAL *)RTMemAlloc(sizeof(RTPIPEINTERNAL));
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync if (!pThis)
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync return VERR_NO_MEMORY;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync pThis->u32Magic = RTPIPE_MAGIC;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync pThis->fd = hNative;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync pThis->fRead = !!(fFlags & RTPIPE_N_READ);
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync pThis->u32State = fFd & O_NONBLOCK ? 0 : RTPIPE_POSIX_BLOCKING;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync /*
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * Fix up inheritability and shut up SIGPIPE and we're done.
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync */
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync if (fcntl(hNative, F_SETFD, fFlags & RTPIPE_N_INHERIT ? 0 : FD_CLOEXEC) == 0)
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync {
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync signal(SIGPIPE, SIG_IGN);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync *phPipe = pThis;
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync return VINF_SUCCESS;
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync }
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync int rc = RTErrConvertFromErrno(errno);
7b4ea63789001468ec3662bdfcd6432bf89095dfvboxsync RTMemFree(pThis);
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync return rc;
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync}
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsyncRTDECL(RTHCINTPTR) RTPipeToNative(RTPIPE hPipe)
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync{
46737b2c6b2da473108a7670c3682d88474bd8b9vboxsync RTPIPEINTERNAL *pThis = hPipe;
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync AssertPtrReturn(pThis, -1);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, -1);
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync
3fa7a7e633f46a212052b510cdb8cee41f279a67vboxsync return pThis->fd;
3fa7a7e633f46a212052b510cdb8cee41f279a67vboxsync}
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
1389294d44ac76b0a25f5655756c9d39855a73efvboxsync/**
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * Prepare blocking mode.
73ba84f95f918cc170be38908ad240fbb2f8f354vboxsync *
73ba84f95f918cc170be38908ad240fbb2f8f354vboxsync * @returns VINF_SUCCESS
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync * @retval VERR_WRONG_ORDER
73ba84f95f918cc170be38908ad240fbb2f8f354vboxsync * @retval VERR_INTERNAL_ERROR_4
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync *
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync * @param pThis The pipe handle.
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync */
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsyncstatic int rtPipeTryBlocking(RTPIPEINTERNAL *pThis)
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync{
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync /*
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync * Update the state.
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync */
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync for (;;)
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync {
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync uint32_t u32State = ASMAtomicReadU32(&pThis->u32State);
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync uint32_t const u32StateOld = u32State;
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync uint32_t const cUsers = (u32State & RTPIPE_POSIX_USERS_MASK);
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync if (u32State & RTPIPE_POSIX_BLOCKING)
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync {
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync AssertReturn(cUsers < RTPIPE_POSIX_USERS_MASK / 2, VERR_INTERNAL_ERROR_4);
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync u32State &= ~RTPIPE_POSIX_USERS_MASK;
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync u32State |= cUsers + 1;
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync if (ASMAtomicCmpXchgU32(&pThis->u32State, u32State, u32StateOld))
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync {
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync if (u32State & RTPIPE_POSIX_SWITCHING)
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync break;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync return VINF_SUCCESS;
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync }
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync }
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync else if (cUsers == 0)
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync {
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync u32State = 1 | RTPIPE_POSIX_SWITCHING | RTPIPE_POSIX_BLOCKING;
359416647a711739d1b14addbf399178949a1a60vboxsync if (ASMAtomicCmpXchgU32(&pThis->u32State, u32State, u32StateOld))
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync break;
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync }
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync else
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync return VERR_WRONG_ORDER;
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync ASMNopPause();
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync }
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync /*
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync * Do the switching.
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync */
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync int fFlags = fcntl(pThis->fd, F_GETFL, 0);
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync if (fFlags != -1)
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync {
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync if ( !(fFlags & O_NONBLOCK)
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync || fcntl(pThis->fd, F_SETFL, fFlags & ~O_NONBLOCK) != -1)
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync {
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync ASMAtomicBitClear(&pThis->u32State, RTPIPE_POSIX_SWITCHING_BIT);
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync return VINF_SUCCESS;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync }
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync }
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync ASMAtomicDecU32(&pThis->u32State);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync return RTErrConvertFromErrno(errno);
359416647a711739d1b14addbf399178949a1a60vboxsync}
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync/**
359416647a711739d1b14addbf399178949a1a60vboxsync * Prepare non-blocking mode.
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync *
359416647a711739d1b14addbf399178949a1a60vboxsync * @returns VINF_SUCCESS
359416647a711739d1b14addbf399178949a1a60vboxsync * @retval VERR_WRONG_ORDER
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync * @retval VERR_INTERNAL_ERROR_4
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync *
6902a98267d5180fb081cb5273751d0a628bf04dvboxsync * @param pThis The pipe handle.
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync */
1389294d44ac76b0a25f5655756c9d39855a73efvboxsyncstatic int rtPipeTryNonBlocking(RTPIPEINTERNAL *pThis)
1389294d44ac76b0a25f5655756c9d39855a73efvboxsync{
73ba84f95f918cc170be38908ad240fbb2f8f354vboxsync /*
1389294d44ac76b0a25f5655756c9d39855a73efvboxsync * Update the state.
73ba84f95f918cc170be38908ad240fbb2f8f354vboxsync */
73ba84f95f918cc170be38908ad240fbb2f8f354vboxsync for (;;)
73ba84f95f918cc170be38908ad240fbb2f8f354vboxsync {
73ba84f95f918cc170be38908ad240fbb2f8f354vboxsync uint32_t u32State = ASMAtomicReadU32(&pThis->u32State);
73ba84f95f918cc170be38908ad240fbb2f8f354vboxsync uint32_t const u32StateOld = u32State;
73ba84f95f918cc170be38908ad240fbb2f8f354vboxsync uint32_t const cUsers = (u32State & RTPIPE_POSIX_USERS_MASK);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
1389294d44ac76b0a25f5655756c9d39855a73efvboxsync if (!(u32State & RTPIPE_POSIX_BLOCKING))
1389294d44ac76b0a25f5655756c9d39855a73efvboxsync {
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync AssertReturn(cUsers < RTPIPE_POSIX_USERS_MASK / 2, VERR_INTERNAL_ERROR_4);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync u32State &= ~RTPIPE_POSIX_USERS_MASK;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync u32State |= cUsers + 1;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync if (ASMAtomicCmpXchgU32(&pThis->u32State, u32State, u32StateOld))
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync {
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync if (u32State & RTPIPE_POSIX_SWITCHING)
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync break;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync return VINF_SUCCESS;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync }
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync }
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync else if (cUsers == 0)
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync {
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync u32State = 1 | RTPIPE_POSIX_SWITCHING;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync if (ASMAtomicCmpXchgU32(&pThis->u32State, u32State, u32StateOld))
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync break;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync }
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync else
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync return VERR_WRONG_ORDER;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync ASMNopPause();
359416647a711739d1b14addbf399178949a1a60vboxsync }
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync /*
359416647a711739d1b14addbf399178949a1a60vboxsync * Do the switching.
359416647a711739d1b14addbf399178949a1a60vboxsync */
359416647a711739d1b14addbf399178949a1a60vboxsync int fFlags = fcntl(pThis->fd, F_GETFL, 0);
359416647a711739d1b14addbf399178949a1a60vboxsync if (fFlags != -1)
359416647a711739d1b14addbf399178949a1a60vboxsync {
359416647a711739d1b14addbf399178949a1a60vboxsync if ( (fFlags & O_NONBLOCK)
359416647a711739d1b14addbf399178949a1a60vboxsync || fcntl(pThis->fd, F_SETFL, fFlags | O_NONBLOCK) != -1)
359416647a711739d1b14addbf399178949a1a60vboxsync {
359416647a711739d1b14addbf399178949a1a60vboxsync ASMAtomicBitClear(&pThis->u32State, RTPIPE_POSIX_SWITCHING_BIT);
359416647a711739d1b14addbf399178949a1a60vboxsync return VINF_SUCCESS;
359416647a711739d1b14addbf399178949a1a60vboxsync }
359416647a711739d1b14addbf399178949a1a60vboxsync }
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync ASMAtomicDecU32(&pThis->u32State);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync return RTErrConvertFromErrno(errno);
359416647a711739d1b14addbf399178949a1a60vboxsync}
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync/**
359416647a711739d1b14addbf399178949a1a60vboxsync * Checks if the read pipe has a HUP condition.
359416647a711739d1b14addbf399178949a1a60vboxsync *
359416647a711739d1b14addbf399178949a1a60vboxsync * @returns true if HUP, false if no.
359416647a711739d1b14addbf399178949a1a60vboxsync * @param pThis The pipe handle (read).
359416647a711739d1b14addbf399178949a1a60vboxsync */
359416647a711739d1b14addbf399178949a1a60vboxsyncstatic bool rtPipePosixHasHup(RTPIPEINTERNAL *pThis)
359416647a711739d1b14addbf399178949a1a60vboxsync{
359416647a711739d1b14addbf399178949a1a60vboxsync Assert(pThis->fRead);
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync struct pollfd PollFd;
359416647a711739d1b14addbf399178949a1a60vboxsync RT_ZERO(PollFd);
359416647a711739d1b14addbf399178949a1a60vboxsync PollFd.fd = pThis->fd;
359416647a711739d1b14addbf399178949a1a60vboxsync PollFd.events = POLLHUP;
359416647a711739d1b14addbf399178949a1a60vboxsync return poll(&PollFd, 1, 0) >= 1
359416647a711739d1b14addbf399178949a1a60vboxsync && (PollFd.revents & POLLHUP);
359416647a711739d1b14addbf399178949a1a60vboxsync}
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsyncRTDECL(int) RTPipeRead(RTPIPE hPipe, void *pvBuf, size_t cbToRead, size_t *pcbRead)
359416647a711739d1b14addbf399178949a1a60vboxsync{
359416647a711739d1b14addbf399178949a1a60vboxsync RTPIPEINTERNAL *pThis = hPipe;
359416647a711739d1b14addbf399178949a1a60vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
359416647a711739d1b14addbf399178949a1a60vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
359416647a711739d1b14addbf399178949a1a60vboxsync AssertReturn(pThis->fRead, VERR_ACCESS_DENIED);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync AssertPtr(pcbRead);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync AssertPtr(pvBuf);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync int rc = rtPipeTryNonBlocking(pThis);
359416647a711739d1b14addbf399178949a1a60vboxsync if (RT_SUCCESS(rc))
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync {
359416647a711739d1b14addbf399178949a1a60vboxsync ssize_t cbRead = read(pThis->fd, pvBuf, RT_MIN(cbToRead, SSIZE_MAX));
359416647a711739d1b14addbf399178949a1a60vboxsync if (cbRead >= 0)
359416647a711739d1b14addbf399178949a1a60vboxsync {
359416647a711739d1b14addbf399178949a1a60vboxsync if (cbRead || !cbToRead || !rtPipePosixHasHup(pThis))
46737b2c6b2da473108a7670c3682d88474bd8b9vboxsync *pcbRead = cbRead;
359416647a711739d1b14addbf399178949a1a60vboxsync else
359416647a711739d1b14addbf399178949a1a60vboxsync rc = VERR_BROKEN_PIPE;
359416647a711739d1b14addbf399178949a1a60vboxsync }
359416647a711739d1b14addbf399178949a1a60vboxsync else if (errno == EAGAIN)
359416647a711739d1b14addbf399178949a1a60vboxsync {
359416647a711739d1b14addbf399178949a1a60vboxsync *pcbRead = 0;
359416647a711739d1b14addbf399178949a1a60vboxsync rc = VINF_TRY_AGAIN;
359416647a711739d1b14addbf399178949a1a60vboxsync }
359416647a711739d1b14addbf399178949a1a60vboxsync else
ad290511521ce8388a9926b165241ecf83c330a7vboxsync rc = RTErrConvertFromErrno(errno);
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync ASMAtomicDecU32(&pThis->u32State);
359416647a711739d1b14addbf399178949a1a60vboxsync }
359416647a711739d1b14addbf399178949a1a60vboxsync return rc;
359416647a711739d1b14addbf399178949a1a60vboxsync}
41fcf8465b641c7083d3b440451f17c1210fce33vboxsync
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync
359416647a711739d1b14addbf399178949a1a60vboxsyncRTDECL(int) RTPipeReadBlocking(RTPIPE hPipe, void *pvBuf, size_t cbToRead, size_t *pcbRead)
41fcf8465b641c7083d3b440451f17c1210fce33vboxsync{
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync RTPIPEINTERNAL *pThis = hPipe;
ad290511521ce8388a9926b165241ecf83c330a7vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
359416647a711739d1b14addbf399178949a1a60vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync AssertReturn(pThis->fRead, VERR_ACCESS_DENIED);
359416647a711739d1b14addbf399178949a1a60vboxsync AssertPtr(pvBuf);
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync int rc = rtPipeTryBlocking(pThis);
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync if (RT_SUCCESS(rc))
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync {
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync size_t cbTotalRead = 0;
ad290511521ce8388a9926b165241ecf83c330a7vboxsync while (cbToRead > 0)
bdbed0b8e7fb553d01417fdc976a76f3b287dbe2vboxsync {
ad290511521ce8388a9926b165241ecf83c330a7vboxsync ssize_t cbRead = read(pThis->fd, pvBuf, RT_MIN(cbToRead, SSIZE_MAX));
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync if (cbRead < 0)
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync {
359416647a711739d1b14addbf399178949a1a60vboxsync rc = RTErrConvertFromErrno(errno);
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync break;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync }
41fcf8465b641c7083d3b440451f17c1210fce33vboxsync if (!cbRead && rtPipePosixHasHup(pThis))
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync {
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync rc = VERR_BROKEN_PIPE;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync break;
9055f61bb57d2a625c6434d55beac7565c3b3c0dvboxsync }
359416647a711739d1b14addbf399178949a1a60vboxsync
329df9696e709dc71611f504a4774f323545be0avboxsync /* advance */
359416647a711739d1b14addbf399178949a1a60vboxsync pvBuf = (char *)pvBuf + cbRead;
3fa7a7e633f46a212052b510cdb8cee41f279a67vboxsync cbTotalRead += cbRead;
359416647a711739d1b14addbf399178949a1a60vboxsync cbToRead -= cbRead;
359416647a711739d1b14addbf399178949a1a60vboxsync }
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync if (pcbRead)
3fa7a7e633f46a212052b510cdb8cee41f279a67vboxsync {
329df9696e709dc71611f504a4774f323545be0avboxsync *pcbRead = cbTotalRead;
d9677fea1378fca6695c8f8fd3dbb21ac4607280vboxsync if ( RT_FAILURE(rc)
359416647a711739d1b14addbf399178949a1a60vboxsync && cbTotalRead
abac45bdfa95437daba28dd2d94bf7e0a25f75cdvboxsync && rc != VERR_INVALID_POINTER)
359416647a711739d1b14addbf399178949a1a60vboxsync rc = VINF_SUCCESS;
359416647a711739d1b14addbf399178949a1a60vboxsync }
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync ASMAtomicDecU32(&pThis->u32State);
359416647a711739d1b14addbf399178949a1a60vboxsync }
359416647a711739d1b14addbf399178949a1a60vboxsync return rc;
359416647a711739d1b14addbf399178949a1a60vboxsync}
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync
4ecd4ad59281328476ad14f2baa51716b6f5f804vboxsyncRTDECL(int) RTPipeWrite(RTPIPE hPipe, const void *pvBuf, size_t cbToWrite, size_t *pcbWritten)
359416647a711739d1b14addbf399178949a1a60vboxsync{
359416647a711739d1b14addbf399178949a1a60vboxsync RTPIPEINTERNAL *pThis = hPipe;
359416647a711739d1b14addbf399178949a1a60vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
359416647a711739d1b14addbf399178949a1a60vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
4ecd4ad59281328476ad14f2baa51716b6f5f804vboxsync AssertReturn(!pThis->fRead, VERR_ACCESS_DENIED);
359416647a711739d1b14addbf399178949a1a60vboxsync AssertPtr(pcbWritten);
359416647a711739d1b14addbf399178949a1a60vboxsync AssertPtr(pvBuf);
329df9696e709dc71611f504a4774f323545be0avboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync int rc = rtPipeTryNonBlocking(pThis);
359416647a711739d1b14addbf399178949a1a60vboxsync if (RT_SUCCESS(rc))
359416647a711739d1b14addbf399178949a1a60vboxsync {
359416647a711739d1b14addbf399178949a1a60vboxsync if (cbToWrite)
359416647a711739d1b14addbf399178949a1a60vboxsync {
359416647a711739d1b14addbf399178949a1a60vboxsync ssize_t cbWritten = write(pThis->fd, pvBuf, RT_MIN(cbToWrite, SSIZE_MAX));
359416647a711739d1b14addbf399178949a1a60vboxsync if (cbWritten >= 0)
329df9696e709dc71611f504a4774f323545be0avboxsync *pcbWritten = cbWritten;
46737b2c6b2da473108a7670c3682d88474bd8b9vboxsync else if (errno == EAGAIN)
359416647a711739d1b14addbf399178949a1a60vboxsync {
359416647a711739d1b14addbf399178949a1a60vboxsync *pcbWritten = 0;
359416647a711739d1b14addbf399178949a1a60vboxsync rc = VINF_TRY_AGAIN;
3fa7a7e633f46a212052b510cdb8cee41f279a67vboxsync }
359416647a711739d1b14addbf399178949a1a60vboxsync else
359416647a711739d1b14addbf399178949a1a60vboxsync rc = RTErrConvertFromErrno(errno);
329df9696e709dc71611f504a4774f323545be0avboxsync }
329df9696e709dc71611f504a4774f323545be0avboxsync else
359416647a711739d1b14addbf399178949a1a60vboxsync *pcbWritten = 0;
3fa7a7e633f46a212052b510cdb8cee41f279a67vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync ASMAtomicDecU32(&pThis->u32State);
359416647a711739d1b14addbf399178949a1a60vboxsync }
3fa7a7e633f46a212052b510cdb8cee41f279a67vboxsync return rc;
46737b2c6b2da473108a7670c3682d88474bd8b9vboxsync}
3fa7a7e633f46a212052b510cdb8cee41f279a67vboxsync
3fa7a7e633f46a212052b510cdb8cee41f279a67vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsyncRTDECL(int) RTPipeWriteBlocking(RTPIPE hPipe, const void *pvBuf, size_t cbToWrite, size_t *pcbWritten)
3fa7a7e633f46a212052b510cdb8cee41f279a67vboxsync{
3fa7a7e633f46a212052b510cdb8cee41f279a67vboxsync RTPIPEINTERNAL *pThis = hPipe;
359416647a711739d1b14addbf399178949a1a60vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
359416647a711739d1b14addbf399178949a1a60vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
359416647a711739d1b14addbf399178949a1a60vboxsync AssertReturn(!pThis->fRead, VERR_ACCESS_DENIED);
359416647a711739d1b14addbf399178949a1a60vboxsync AssertPtr(pvBuf);
359416647a711739d1b14addbf399178949a1a60vboxsync AssertPtrNull(pcbWritten);
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync int rc = rtPipeTryBlocking(pThis);
359416647a711739d1b14addbf399178949a1a60vboxsync if (RT_SUCCESS(rc))
359416647a711739d1b14addbf399178949a1a60vboxsync {
359416647a711739d1b14addbf399178949a1a60vboxsync size_t cbTotalWritten = 0;
359416647a711739d1b14addbf399178949a1a60vboxsync while (cbToWrite > 0)
359416647a711739d1b14addbf399178949a1a60vboxsync {
359416647a711739d1b14addbf399178949a1a60vboxsync ssize_t cbWritten = write(pThis->fd, pvBuf, RT_MIN(cbToWrite, SSIZE_MAX));
359416647a711739d1b14addbf399178949a1a60vboxsync if (cbWritten < 0)
359416647a711739d1b14addbf399178949a1a60vboxsync {
359416647a711739d1b14addbf399178949a1a60vboxsync rc = RTErrConvertFromErrno(errno);
359416647a711739d1b14addbf399178949a1a60vboxsync break;
359416647a711739d1b14addbf399178949a1a60vboxsync }
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync /* advance */
359416647a711739d1b14addbf399178949a1a60vboxsync pvBuf = (char const *)pvBuf + cbWritten;
359416647a711739d1b14addbf399178949a1a60vboxsync cbTotalWritten += cbWritten;
359416647a711739d1b14addbf399178949a1a60vboxsync cbToWrite -= cbWritten;
3fa7a7e633f46a212052b510cdb8cee41f279a67vboxsync }
3fa7a7e633f46a212052b510cdb8cee41f279a67vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync if (pcbWritten)
09f4b412099acda62997fd82c8608075c453b3ebvboxsync {
359416647a711739d1b14addbf399178949a1a60vboxsync *pcbWritten = cbTotalWritten;
359416647a711739d1b14addbf399178949a1a60vboxsync if ( RT_FAILURE(rc)
359416647a711739d1b14addbf399178949a1a60vboxsync && cbTotalWritten
359416647a711739d1b14addbf399178949a1a60vboxsync && rc != VERR_INVALID_POINTER)
359416647a711739d1b14addbf399178949a1a60vboxsync rc = VINF_SUCCESS;
359416647a711739d1b14addbf399178949a1a60vboxsync }
359416647a711739d1b14addbf399178949a1a60vboxsync
635c83753ed04cf3637e019af0e15ba40e07f2fevboxsync ASMAtomicDecU32(&pThis->u32State);
359416647a711739d1b14addbf399178949a1a60vboxsync }
359416647a711739d1b14addbf399178949a1a60vboxsync return rc;
359416647a711739d1b14addbf399178949a1a60vboxsync}
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsyncRTDECL(int) RTPipeFlush(RTPIPE hPipe)
359416647a711739d1b14addbf399178949a1a60vboxsync{
359416647a711739d1b14addbf399178949a1a60vboxsync RTPIPEINTERNAL *pThis = hPipe;
359416647a711739d1b14addbf399178949a1a60vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
359416647a711739d1b14addbf399178949a1a60vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
09f4b412099acda62997fd82c8608075c453b3ebvboxsync AssertReturn(!pThis->fRead, VERR_ACCESS_DENIED);
09f4b412099acda62997fd82c8608075c453b3ebvboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync if (fsync(pThis->fd))
359416647a711739d1b14addbf399178949a1a60vboxsync {
359416647a711739d1b14addbf399178949a1a60vboxsync if (errno == EINVAL || errno == ENOTSUP)
09f4b412099acda62997fd82c8608075c453b3ebvboxsync return VERR_NOT_SUPPORTED;
359416647a711739d1b14addbf399178949a1a60vboxsync return RTErrConvertFromErrno(errno);
359416647a711739d1b14addbf399178949a1a60vboxsync }
09f4b412099acda62997fd82c8608075c453b3ebvboxsync return VINF_SUCCESS;
09f4b412099acda62997fd82c8608075c453b3ebvboxsync}
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsyncRTDECL(int) RTPipeSelectOne(RTPIPE hPipe, RTMSINTERVAL cMillies)
359416647a711739d1b14addbf399178949a1a60vboxsync{
359416647a711739d1b14addbf399178949a1a60vboxsync RTPIPEINTERNAL *pThis = hPipe;
359416647a711739d1b14addbf399178949a1a60vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
359416647a711739d1b14addbf399178949a1a60vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync struct pollfd PollFd;
359416647a711739d1b14addbf399178949a1a60vboxsync RT_ZERO(PollFd);
359416647a711739d1b14addbf399178949a1a60vboxsync PollFd.fd = pThis->fd;
359416647a711739d1b14addbf399178949a1a60vboxsync PollFd.events = POLLHUP | POLLERR;
359416647a711739d1b14addbf399178949a1a60vboxsync if (pThis->fRead)
359416647a711739d1b14addbf399178949a1a60vboxsync PollFd.events |= POLLIN | POLLPRI;
359416647a711739d1b14addbf399178949a1a60vboxsync else
359416647a711739d1b14addbf399178949a1a60vboxsync PollFd.events |= POLLOUT;
359416647a711739d1b14addbf399178949a1a60vboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync int timeout;
359416647a711739d1b14addbf399178949a1a60vboxsync if ( cMillies == RT_INDEFINITE_WAIT
359416647a711739d1b14addbf399178949a1a60vboxsync || cMillies >= INT_MAX /* lazy bird */)
359416647a711739d1b14addbf399178949a1a60vboxsync timeout = -1;
359416647a711739d1b14addbf399178949a1a60vboxsync else
359416647a711739d1b14addbf399178949a1a60vboxsync timeout = cMillies;
09f4b412099acda62997fd82c8608075c453b3ebvboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync int rc = poll(&PollFd, 1, 0);
359416647a711739d1b14addbf399178949a1a60vboxsync if (rc == -1)
09f4b412099acda62997fd82c8608075c453b3ebvboxsync return RTErrConvertFromErrno(errno);
09f4b412099acda62997fd82c8608075c453b3ebvboxsync return rc > 0 ? VINF_SUCCESS : VERR_TIMEOUT;
359416647a711739d1b14addbf399178949a1a60vboxsync}
09f4b412099acda62997fd82c8608075c453b3ebvboxsync
359416647a711739d1b14addbf399178949a1a60vboxsync