pipe-posix.cpp revision d142cd5e90598dd8d14744cb6bb7dd467cec446c
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq/* $Id$ */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq/** @file
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * IPRT - Anonymous Pipes, POSIX Implementation.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq/*
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * Copyright (C) 2010 Sun Microsystems, Inc.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * This file is part of VirtualBox Open Source Edition (OSE), as
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * available from http://www.virtualbox.org. This file is free software;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * you can redistribute it and/or modify it under the terms of the GNU
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * General Public License (GPL) as published by the Free Software
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * Foundation, in version 2 as it comes in the "COPYING" file of the
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * The contents of this file may alternatively be used under the terms
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * of the Common Development and Distribution License Version 1.0
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * (CDDL) only, as it comes in the "COPYING.CDDL" file of the
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * VirtualBox OSE distribution, in which case the provisions of the
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * CDDL are applicable instead of those of the GPL.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * You may elect to license modified versions of this file under the
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * terms and conditions of either the GPL or the CDDL or both.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * Clara, CA 95054 USA or visit http://www.sun.com if you need
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * additional information or have any questions.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq/*******************************************************************************
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq* Header Files *
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq*******************************************************************************/
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#include <iprt/pipe.h>
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#include "internal/iprt.h"
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#include <iprt/asm.h>
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#include <iprt/assert.h>
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#include <iprt/err.h>
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#include <iprt/mem.h>
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#include <iprt/string.h>
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#include <iprt/thread.h>
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#include "internal/magics.h"
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#include <errno.h>
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#include <fcntl.h>
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#include <limits.h>
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#include <unistd.h>
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#include <sys/poll.h>
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#include <signal.h>
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq/*******************************************************************************
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq* Structures and Typedefs *
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq*******************************************************************************/
f4d3a92b319b23e2b8d67298acc289d52bc1c517niqtypedef struct RTPIPEINTERNAL
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq{
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq /** Magic value (RTPIPE_MAGIC). */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq uint32_t u32Magic;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq /** The file descriptor. */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq int fd;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq /** Set if this is the read end, clear if it's the write end. */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq bool fRead;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq /** Atomically operated state variable.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * - Bits 0 thru 29 - Users of the new mode.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * - Bit 30 - The pipe mode, set indicates blocking.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * - Bit 31 - Set when we're switching the mode.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq uint32_t volatile u32State;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq} RTPIPEINTERNAL;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq/*******************************************************************************
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq* Defined Constants And Macros *
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq*******************************************************************************/
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq/** @name RTPIPEINTERNAL::u32State defines
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * @{ */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#define RTPIPE_POSIX_BLOCKING UINT32_C(0x40000000)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#define RTPIPE_POSIX_SWITCHING UINT32_C(0x80000000)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#define RTPIPE_POSIX_SWITCHING_BIT 31
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq#define RTPIPE_POSIX_USERS_MASK UINT32_C(0x3fffffff)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq/** @} */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niqRTDECL(int) RTPipeCreate(PRTPIPE phPipeRead, PRTPIPE phPipeWrite, uint32_t fFlags)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq{
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtrReturn(phPipeRead, VERR_INVALID_POINTER);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtrReturn(phPipeWrite, VERR_INVALID_POINTER);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(!(fFlags & ~RTPIPE_C_VALID_MASK), VERR_INVALID_PARAMETER);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq /*
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * Create the pipe and set the close-on-exec flag if requested.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq int aFds[2] = {-1, -1};
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (pipe(aFds))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return RTErrConvertFromErrno(errno);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq int rc = VINF_SUCCESS;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (!(fFlags & RTPIPE_C_INHERIT_READ))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (fcntl(aFds[0], F_SETFD, FD_CLOEXEC))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq rc = RTErrConvertFromErrno(errno);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (!(fFlags & RTPIPE_C_INHERIT_WRITE))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (fcntl(aFds[1], F_SETFD, FD_CLOEXEC))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq rc = RTErrConvertFromErrno(errno);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (RT_SUCCESS(rc))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq /*
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * Create the two handles.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq RTPIPEINTERNAL *pThisR = (RTPIPEINTERNAL *)RTMemAlloc(sizeof(RTPIPEINTERNAL));
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (pThisR)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq RTPIPEINTERNAL *pThisW = (RTPIPEINTERNAL *)RTMemAlloc(sizeof(RTPIPEINTERNAL));
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (pThisW)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq pThisR->u32Magic = RTPIPE_MAGIC;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq pThisW->u32Magic = RTPIPE_MAGIC;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq pThisR->fd = aFds[0];
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq pThisW->fd = aFds[1];
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq pThisR->fRead = true;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq pThisW->fRead = false;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq pThisR->u32State = RTPIPE_POSIX_BLOCKING;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq pThisW->u32State = RTPIPE_POSIX_BLOCKING;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *phPipeRead = pThisR;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *phPipeWrite = pThisW;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq /*
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * Before we leave, make sure to shut up SIGPIPE.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq signal(SIGPIPE, SIG_IGN);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return VINF_SUCCESS;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq RTMemFree(pThisR);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq rc = VERR_NO_MEMORY;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq else
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq rc = VERR_NO_MEMORY;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq close(aFds[0]);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq close(aFds[1]);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return rc;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq}
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niqRTDECL(int) RTPipeClose(RTPIPE hPipe)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq{
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq RTPIPEINTERNAL *pThis = hPipe;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (pThis == NIL_RTPIPE)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return VINF_SUCCESS;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtrReturn(pThis, VERR_INVALID_PARAMETER);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq /*
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * Do the cleanup.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(ASMAtomicCmpXchgU32(&pThis->u32Magic, ~RTPIPE_MAGIC, RTPIPE_MAGIC), VERR_INVALID_HANDLE);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq int fd = pThis->fd;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq pThis->fd = -1;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq close(fd);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (ASMAtomicReadU32(&pThis->u32State) & RTPIPE_POSIX_USERS_MASK)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertFailed();
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq RTThreadSleep(1);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq RTMemFree(pThis);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return VINF_SUCCESS;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq}
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niqRTDECL(RTHCINTPTR) RTPipeToNative(RTPIPE hPipe)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq{
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq RTPIPEINTERNAL *pThis = hPipe;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtrReturn(pThis, (RTHCINTPTR)(unsigned int)-1);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, (RTHCINTPTR)(unsigned int)-1);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return pThis->fd;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq}
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq/**
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * Prepare blocking mode.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * @returns VINF_SUCCESS
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * @retval VERR_WRONG_ORDER
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * @retval VERR_INTERNAL_ERROR_4
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * @param pThis The pipe handle.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niqstatic int rtPipeTryBlocking(RTPIPEINTERNAL *pThis)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq{
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq /*
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * Update the state.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq for (;;)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq uint32_t u32State = ASMAtomicReadU32(&pThis->u32State);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq uint32_t const u32StateOld = u32State;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq uint32_t const cUsers = (u32State & RTPIPE_POSIX_USERS_MASK);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (u32State & RTPIPE_POSIX_BLOCKING)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(cUsers < RTPIPE_POSIX_USERS_MASK / 2, VERR_INTERNAL_ERROR_4);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq u32State &= ~RTPIPE_POSIX_USERS_MASK;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq u32State |= cUsers + 1;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (ASMAtomicCmpXchgU32(&pThis->u32State, u32State, u32StateOld))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (u32State & RTPIPE_POSIX_SWITCHING)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq break;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return VINF_SUCCESS;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq else if (cUsers == 0)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq u32State = 1 | RTPIPE_POSIX_SWITCHING | RTPIPE_POSIX_BLOCKING;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (ASMAtomicCmpXchgU32(&pThis->u32State, u32State, u32StateOld))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq break;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq else
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return VERR_WRONG_ORDER;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq ASMNopPause();
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq /*
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * Do the switching.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq int fFlags = fcntl(pThis->fd, F_GETFL, 0);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (fFlags != -1)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if ( !(fFlags & O_NONBLOCK)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq || fcntl(pThis->fd, F_SETFL, fFlags & ~O_NONBLOCK) != -1)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq ASMAtomicBitClear(&pThis->u32State, RTPIPE_POSIX_SWITCHING_BIT);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return VINF_SUCCESS;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq ASMAtomicDecU32(&pThis->u32State);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return RTErrConvertFromErrno(errno);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq}
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq/**
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * Prepare non-blocking mode.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * @returns VINF_SUCCESS
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * @retval VERR_WRONG_ORDER
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * @retval VERR_INTERNAL_ERROR_4
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * @param pThis The pipe handle.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niqstatic int rtPipeTryNonBlocking(RTPIPEINTERNAL *pThis)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq{
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq /*
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * Update the state.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq for (;;)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq uint32_t u32State = ASMAtomicReadU32(&pThis->u32State);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq uint32_t const u32StateOld = u32State;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq uint32_t const cUsers = (u32State & RTPIPE_POSIX_USERS_MASK);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (!(u32State & RTPIPE_POSIX_BLOCKING))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(cUsers < RTPIPE_POSIX_USERS_MASK / 2, VERR_INTERNAL_ERROR_4);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq u32State &= ~RTPIPE_POSIX_USERS_MASK;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq u32State |= cUsers + 1;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (ASMAtomicCmpXchgU32(&pThis->u32State, u32State, u32StateOld))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (u32State & RTPIPE_POSIX_SWITCHING)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq break;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return VINF_SUCCESS;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq else if (cUsers == 0)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq u32State = 1 | RTPIPE_POSIX_SWITCHING;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (ASMAtomicCmpXchgU32(&pThis->u32State, u32State, u32StateOld))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq break;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq else
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return VERR_WRONG_ORDER;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq ASMNopPause();
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq /*
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * Do the switching.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq int fFlags = fcntl(pThis->fd, F_GETFL, 0);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (fFlags != -1)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if ( (fFlags & O_NONBLOCK)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq || fcntl(pThis->fd, F_SETFL, fFlags | O_NONBLOCK) != -1)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq ASMAtomicBitClear(&pThis->u32State, RTPIPE_POSIX_SWITCHING_BIT);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return VINF_SUCCESS;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq ASMAtomicDecU32(&pThis->u32State);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return RTErrConvertFromErrno(errno);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq}
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq/**
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * Checks if the read pipe has a HUP condition.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * @returns true if HUP, false if no.
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq * @param pThis The pipe handle (read).
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niqstatic bool rtPipePosixHasHup(RTPIPEINTERNAL *pThis)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq{
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq Assert(pThis->fRead);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq struct pollfd PollFd;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq RT_ZERO(PollFd);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq PollFd.fd = pThis->fd;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq PollFd.events = POLLHUP;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return poll(&PollFd, 1, 0) >= 1
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq && (PollFd.revents & POLLHUP);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq}
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niqRTDECL(int) RTPipeRead(RTPIPE hPipe, void *pvBuf, size_t cbToRead, size_t *pcbRead)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq{
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq RTPIPEINTERNAL *pThis = hPipe;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(pThis->fRead, VERR_ACCESS_DENIED);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtr(pcbRead);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtr(pvBuf);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq int rc = rtPipeTryNonBlocking(pThis);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (RT_SUCCESS(rc))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq ssize_t cbRead = read(pThis->fd, pvBuf, RT_MIN(cbToRead, SSIZE_MAX));
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (cbRead >= 0)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (cbRead || !cbToRead || !rtPipePosixHasHup(pThis))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *pcbRead = cbRead;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq else
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq rc = VERR_BROKEN_PIPE;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq else if (errno == EAGAIN)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *pcbRead = 0;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq rc = VINF_TRY_AGAIN;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq else
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq rc = RTErrConvertFromErrno(errno);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq ASMAtomicDecU32(&pThis->u32State);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return rc;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq}
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niqRTDECL(int) RTPipeReadBlocking(RTPIPE hPipe, void *pvBuf, size_t cbToRead, size_t *pcbRead)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq{
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq RTPIPEINTERNAL *pThis = hPipe;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(pThis->fRead, VERR_ACCESS_DENIED);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtr(pvBuf);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq int rc = rtPipeTryBlocking(pThis);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (RT_SUCCESS(rc))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq size_t cbTotalRead = 0;;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq while (cbToRead > 0)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq ssize_t cbRead = read(pThis->fd, pvBuf, RT_MIN(cbToRead, SSIZE_MAX));
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (cbRead < 0)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq rc = RTErrConvertFromErrno(errno);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq break;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (!cbRead && cbToRead > 0 && rtPipePosixHasHup(pThis))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq rc = VERR_BROKEN_PIPE;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq break;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq /* advance */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq pvBuf = (char *)pvBuf + cbRead;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq cbTotalRead += cbRead;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq cbToRead -= cbRead;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (pcbRead)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *pcbRead = cbTotalRead;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if ( RT_FAILURE(rc)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq && cbTotalRead
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq && rc != VERR_INVALID_POINTER)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq rc = VINF_SUCCESS;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq ASMAtomicDecU32(&pThis->u32State);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return rc;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq}
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niqRTDECL(int) RTPipeWrite(RTPIPE hPipe, const void *pvBuf, size_t cbToWrite, size_t *pcbWritten)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq{
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq RTPIPEINTERNAL *pThis = hPipe;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(!pThis->fRead, VERR_ACCESS_DENIED);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtr(pcbWritten);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtr(pvBuf);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq int rc = rtPipeTryNonBlocking(pThis);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (RT_SUCCESS(rc))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (cbToWrite)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq ssize_t cbWritten = write(pThis->fd, pvBuf, RT_MIN(cbToWrite, SSIZE_MAX));
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (cbWritten >= 0)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *pcbWritten = cbWritten;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq else if (errno == EAGAIN)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *pcbWritten = 0;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq rc = VINF_TRY_AGAIN;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq else
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq rc = RTErrConvertFromErrno(errno);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq else
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *pcbWritten = 0;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq ASMAtomicDecU32(&pThis->u32State);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return rc;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq}
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niqRTDECL(int) RTPipeWriteBlocking(RTPIPE hPipe, const void *pvBuf, size_t cbToWrite, size_t *pcbWritten)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq{
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq RTPIPEINTERNAL *pThis = hPipe;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(!pThis->fRead, VERR_ACCESS_DENIED);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtr(pvBuf);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtrNull(pcbWritten);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq int rc = rtPipeTryBlocking(pThis);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (RT_SUCCESS(rc))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq size_t cbTotalWritten = 0;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq while (cbToWrite > 0)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq ssize_t cbWritten = write(pThis->fd, pvBuf, RT_MIN(cbToWrite, SSIZE_MAX));
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (cbWritten < 0)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq rc = RTErrConvertFromErrno(errno);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq break;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq /* advance */
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq pvBuf = (char const *)pvBuf + cbWritten;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq cbTotalWritten += cbWritten;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq cbToWrite -= cbWritten;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (pcbWritten)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq *pcbWritten = cbTotalWritten;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if ( RT_FAILURE(rc)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq && cbTotalWritten
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq && rc != VERR_INVALID_POINTER)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq rc = VINF_SUCCESS;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq ASMAtomicDecU32(&pThis->u32State);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return rc;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq}
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niqRTDECL(int) RTPipeFlush(RTPIPE hPipe)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq{
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq RTPIPEINTERNAL *pThis = hPipe;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(!pThis->fRead, VERR_ACCESS_DENIED);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (fsync(pThis->fd))
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq {
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (errno == EINVAL || errno == ENOTSUP)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return VERR_NOT_SUPPORTED;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return RTErrConvertFromErrno(errno);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq }
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return VINF_SUCCESS;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq}
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niqRTDECL(int) RTPipeSelectOne(RTPIPE hPipe, RTMSINTERVAL cMillies)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq{
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq RTPIPEINTERNAL *pThis = hPipe;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq struct pollfd PollFd;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq RT_ZERO(PollFd);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq PollFd.fd = pThis->fd;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq PollFd.events = POLLHUP | POLLERR;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (pThis->fRead)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq PollFd.events |= POLLIN | POLLPRI;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq else
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq PollFd.events |= POLLOUT;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq int timeout;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if ( cMillies == RT_INDEFINITE_WAIT
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq || cMillies >= INT_MAX /* lazy bird */)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq timeout = -1;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq else
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq timeout = cMillies;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq int rc = poll(&PollFd, 1, 0);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq if (rc == -1)
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return RTErrConvertFromErrno(errno);
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq return rc > 0 ? VINF_SUCCESS : VERR_TIMEOUT;
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq}
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq
f4d3a92b319b23e2b8d67298acc289d52bc1c517niq