637712559132d2b3617aea0103fb0385978da14evboxsync/* $Id$ */
637712559132d2b3617aea0103fb0385978da14evboxsync/** @file
4efd24e631e5312d1fb78ae7ccaf9de912ff0e9fvboxsync * IPRT - Anonymous Pipes, OS/2 Implementation.
637712559132d2b3617aea0103fb0385978da14evboxsync */
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync/*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * 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*******************************************************************************/
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#define INCL_ERRORS
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#define INCL_DOSSEMAPHORES
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#include <os2.h>
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync#include <iprt/pipe.h>
637712559132d2b3617aea0103fb0385978da14evboxsync#include "internal/iprt.h"
637712559132d2b3617aea0103fb0385978da14evboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#include <iprt/asm.h>
637712559132d2b3617aea0103fb0385978da14evboxsync#include <iprt/assert.h>
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#include <iprt/critsect.h>
637712559132d2b3617aea0103fb0385978da14evboxsync#include <iprt/err.h>
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#include <iprt/mem.h>
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#include <iprt/string.h>
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#include <iprt/poll.h>
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#include <iprt/process.h>
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#include <iprt/thread.h>
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#include <iprt/time.h>
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#include "internal/pipe.h"
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#include "internal/magics.h"
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync/*******************************************************************************
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync* Defined Constants And Macros *
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync*******************************************************************************/
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync/** The pipe buffer size we prefer. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#define RTPIPE_OS2_SIZE _32K
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync/*******************************************************************************
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync* Structures and Typedefs *
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync*******************************************************************************/
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsynctypedef struct RTPIPEINTERNAL
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /** Magic value (RTPIPE_MAGIC). */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync uint32_t u32Magic;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /** The pipe handle. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync HPIPE hPipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /** Set if this is the read end, clear if it's the write end. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync bool fRead;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /** Whether the pipe is in blocking or non-blocking mode. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync bool fBlocking;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /** Set if the pipe is broken. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync bool fBrokenPipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /** Usage counter. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync uint32_t cUsers;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /** The event semaphore associated with the pipe. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync HEV hev;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /** The handle of the poll set currently polling on this pipe.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * We can only have one poller at the time (lazy bird). */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPOLLSET hPollSet;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /** Critical section protecting the above members.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * (Taking the lazy/simple approach.) */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCRITSECT CritSect;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync} RTPIPEINTERNAL;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync/**
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Ensures that the pipe has a semaphore associated with it.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @returns VBox status code.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @param pThis The pipe.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsyncstatic int rtPipeOs2EnsureSem(RTPIPEINTERNAL *pThis)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (pThis->hev != NULLHANDLE)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return VINF_SUCCESS;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync HEV hev;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync APIRET orc = DosCreateEventSem(NULL, &hev, DC_SEM_SHARED, FALSE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc == NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync orc = DosSetNPipeSem(pThis->hPipe, (HSEM)hev, 1);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc == NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->hev = hev;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return VINF_SUCCESS;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync DosCloseEventSem(hev);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return RTErrConvertFromOS2(orc);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsyncRTDECL(int) RTPipeCreate(PRTPIPE phPipeRead, PRTPIPE phPipeWrite, uint32_t fFlags)
637712559132d2b3617aea0103fb0385978da14evboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(phPipeRead, VERR_INVALID_POINTER);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(phPipeWrite, VERR_INVALID_POINTER);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(!(fFlags & ~RTPIPE_C_VALID_MASK), VERR_INVALID_PARAMETER);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Try create and connect a pipe pair.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync APIRET orc;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync HPIPE hPipeR;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync HFILE hPipeW;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync int rc;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync for (;;)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync static volatile uint32_t g_iNextPipe = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync char szName[128];
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTStrPrintf(szName, sizeof(szName), "\\pipe\\iprt-pipe-%u-%u", RTProcSelf(), ASMAtomicIncU32(&g_iNextPipe));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Create the read end of the pipe.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG fPipeMode = 1 /*instance*/ | NP_TYPE_BYTE | NP_READMODE_BYTE | NP_NOWAIT;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG fOpenMode = NP_ACCESS_DUPLEX | NP_WRITEBEHIND;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (fFlags & RTPIPE_C_INHERIT_READ)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync fOpenMode |= NP_INHERIT;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync fOpenMode |= NP_NOINHERIT;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync orc = DosCreateNPipe((PSZ)szName, &hPipeR, fOpenMode, fPipeMode, RTPIPE_OS2_SIZE, RTPIPE_OS2_SIZE, NP_DEFAULT_WAIT);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc == NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync orc = DosConnectNPipe(hPipeR);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc == ERROR_PIPE_NOT_CONNECTED || orc == NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Connect to the pipe (the write end), attach sem below.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG ulAction = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG fOpenW = OPEN_ACTION_FAIL_IF_NEW | OPEN_ACTION_OPEN_IF_EXISTS;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG fModeW = OPEN_ACCESS_WRITEONLY | OPEN_SHARE_DENYNONE | OPEN_FLAGS_FAIL_ON_ERROR;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (!(fFlags & RTPIPE_C_INHERIT_WRITE))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync fModeW |= OPEN_FLAGS_NOINHERIT;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync orc = DosOpen((PSZ)szName, &hPipeW, &ulAction, 0 /*cbFile*/, FILE_NORMAL,
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync fOpenW, fModeW, NULL /*peaop2*/);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc == NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync break;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync DosClose(hPipeR);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if ( orc != ERROR_PIPE_BUSY /* already exist - compatible */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync && orc != ERROR_ACCESS_DENIED /* already exist - incompatible (?) */)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return RTErrConvertFromOS2(orc);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /* else: try again with a new name */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Create the two handles.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPIPEINTERNAL *pThisR = (RTPIPEINTERNAL *)RTMemAllocZ(sizeof(RTPIPEINTERNAL));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (pThisR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPIPEINTERNAL *pThisW = (RTPIPEINTERNAL *)RTMemAllocZ(sizeof(RTPIPEINTERNAL));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (pThisW)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /* Crit sects. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = RTCritSectInit(&pThisR->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (RT_SUCCESS(rc))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = RTCritSectInit(&pThisW->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (RT_SUCCESS(rc))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /* Initialize the structures. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThisR->u32Magic = RTPIPE_MAGIC;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThisW->u32Magic = RTPIPE_MAGIC;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThisR->hPipe = hPipeR;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThisW->hPipe = hPipeW;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThisR->hev = NULLHANDLE;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThisW->hev = NULLHANDLE;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThisR->fRead = true;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThisW->fRead = false;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThisR->fBlocking = false;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThisW->fBlocking = true;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync //pThisR->fBrokenPipe = false;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync //pThisW->fBrokenPipe = false;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync //pThisR->cUsers = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync //pThisW->cUsers = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThisR->hPollSet = NIL_RTPOLLSET;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThisW->hPollSet = NIL_RTPOLLSET;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *phPipeRead = pThisR;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *phPipeWrite = pThisW;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return VINF_SUCCESS;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectDelete(&pThisR->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTMemFree(pThisW);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VERR_NO_MEMORY;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTMemFree(pThisR);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VERR_NO_MEMORY;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /* Don't call DosDisConnectNPipe! */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync DosClose(hPipeW);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync DosClose(hPipeR);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return rc;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsyncRTDECL(int) RTPipeClose(RTPIPE hPipe)
637712559132d2b3617aea0103fb0385978da14evboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPIPEINTERNAL *pThis = hPipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (pThis == NIL_RTPIPE)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return VINF_SUCCESS;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(pThis, VERR_INVALID_PARAMETER);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Do the cleanup.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(ASMAtomicCmpXchgU32(&pThis->u32Magic, ~RTPIPE_MAGIC, RTPIPE_MAGIC), VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectEnter(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync Assert(pThis->cUsers == 0);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /* Don't call DosDisConnectNPipe! */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync DosClose(pThis->hPipe);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->hPipe = (HPIPE)-1;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (pThis->hev != NULLHANDLE)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync DosCloseEventSem(pThis->hev);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->hev = NULLHANDLE;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectLeave(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectDelete(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTMemFree(pThis);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return VINF_SUCCESS;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsyncRTDECL(int) RTPipeFromNative(PRTPIPE phPipe, RTHCINTPTR hNativePipe, uint32_t fFlags)
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(phPipe, VERR_INVALID_POINTER);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(!(fFlags & ~RTPIPE_N_VALID_MASK), VERR_INVALID_PARAMETER);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(!!(fFlags & RTPIPE_N_READ) != !!(fFlags & RTPIPE_N_WRITE), VERR_INVALID_PARAMETER);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Get and validate the pipe handle info.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync HPIPE hNative = (HPIPE)hNativePipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG ulType = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG ulAttr = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync APIRET orc = DosQueryHType(hNative, &ulType, &ulAttr);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertMsgReturn(orc == NO_ERROR, ("%d\n", orc), RTErrConvertFromOS2(orc));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn((ulType & 0x7) == HANDTYPE_PIPE, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#if 0
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync union
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync PIPEINFO PipeInfo;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync uint8_t abPadding[sizeof(PIPEINFO) + 127];
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync } Buf;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync orc = DosQueryNPipeInfo(hNative, 1, &Buf, sizeof(Buf));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc != NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /* Sorry, anonymous pips are not supported. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertMsgFailed(("%d\n", orc));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return VERR_INVALID_HANDLE;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(Buf.PipeInfo.cbMaxInst == 1, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#endif
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG fPipeState = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync orc = DosQueryNPHState(hNative, &fPipeState);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc != NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /* Sorry, anonymous pips are not supported. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertMsgFailed(("%d\n", orc));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return VERR_INVALID_HANDLE;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(!(fPipeState & NP_TYPE_MESSAGE), VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(!(fPipeState & NP_READMODE_MESSAGE), VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn((fPipeState & 0xff) == 1, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG fFileState = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync orc = DosQueryFHState(hNative, &fFileState);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertMsgReturn(orc == NO_ERROR, ("%d\n", orc), VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertMsgReturn( (fFileState & 0x3) == (fFlags & RTPIPE_N_READ ? OPEN_ACCESS_READONLY : OPEN_ACCESS_WRITEONLY)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync || (fFileState & 0x3) == OPEN_ACCESS_READWRITE
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync , ("%#x\n", fFileState), VERR_INVALID_HANDLE);
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Looks kind of OK. Fix the inherit flag.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync orc = DosSetFHState(hNative, (fFileState & (OPEN_FLAGS_WRITE_THROUGH | OPEN_FLAGS_FAIL_ON_ERROR | OPEN_FLAGS_NO_CACHE))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync | (fFlags & RTPIPE_N_INHERIT ? 0 : OPEN_FLAGS_NOINHERIT));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertMsgReturn(orc == NO_ERROR, ("%d\n", orc), RTErrConvertFromOS2(orc));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Create a handle so we can try rtPipeQueryInfo on it
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * and see if we need to duplicate it to make that call work.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPIPEINTERNAL *pThis = (RTPIPEINTERNAL *)RTMemAllocZ(sizeof(RTPIPEINTERNAL));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (!pThis)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return VERR_NO_MEMORY;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync int rc = RTCritSectInit(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (RT_SUCCESS(rc))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->u32Magic = RTPIPE_MAGIC;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->hPipe = hNative;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->hev = NULLHANDLE;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->fRead = !!(fFlags & RTPIPE_N_READ);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->fBlocking = !(fPipeState & NP_NOWAIT);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync //pThis->fBrokenPipe = false;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync //pThis->cUsers = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->hPollSet = NIL_RTPOLLSET;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *phPipe = pThis;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return VINF_SUCCESS;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync //RTCritSectDelete(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTMemFree(pThis);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return rc;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync}
33698994f509c2b3a92e81a828ee7a0e01b81de0vboxsync
637712559132d2b3617aea0103fb0385978da14evboxsyncRTDECL(RTHCINTPTR) RTPipeToNative(RTPIPE hPipe)
637712559132d2b3617aea0103fb0385978da14evboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPIPEINTERNAL *pThis = hPipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(pThis, -1);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, -1);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return (RTHCINTPTR)pThis->hPipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync}
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync/**
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Prepare blocking mode.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @returns IPRT status code.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @retval VERR_WRONG_ORDER if simultaneous non-blocking and blocking access is
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * attempted.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @param pThis The pipe handle.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @remarks Caller owns the critical section.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsyncstatic int rtPipeTryBlocking(RTPIPEINTERNAL *pThis)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (!pThis->fBlocking)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (pThis->cUsers != 0)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return VERR_WRONG_ORDER;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync APIRET orc = DosSetNPHState(pThis->hPipe, NP_WAIT | NP_READMODE_BYTE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc != NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc != ERROR_BROKEN_PIPE && orc != ERROR_PIPE_NOT_CONNECTED)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return RTErrConvertFromOS2(orc);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->fBrokenPipe = true;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->fBlocking = true;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->cUsers++;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return VINF_SUCCESS;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync}
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync/**
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Prepare non-blocking mode.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @returns IPRT status code.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @retval VERR_WRONG_ORDER if simultaneous non-blocking and blocking access is
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * attempted.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @param pThis The pipe handle.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsyncstatic int rtPipeTryNonBlocking(RTPIPEINTERNAL *pThis)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (pThis->fBlocking)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (pThis->cUsers != 0)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return VERR_WRONG_ORDER;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync APIRET orc = DosSetNPHState(pThis->hPipe, NP_NOWAIT | NP_READMODE_BYTE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc != NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc != ERROR_BROKEN_PIPE && orc != ERROR_PIPE_NOT_CONNECTED)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return RTErrConvertFromOS2(orc);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->fBrokenPipe = true;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->fBlocking = false;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->cUsers++;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return VINF_SUCCESS;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync}
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync/**
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Checks if the read pipe has been broken.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @returns true if broken, false if no.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @param pThis The pipe handle (read).
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsyncstatic bool rtPipeOs2IsBroken(RTPIPEINTERNAL *pThis)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync Assert(pThis->fRead);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#if 0
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Query it via the semaphore. Not sure how fast this is...
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync PIPESEMSTATE aStates[3]; RT_ZERO(aStates);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync APIRET orc = DosQueryNPipeSemState(pThis->hev, &aStates[0], sizeof(aStates));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc == NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (aStates[0].fStatus == NPSS_CLOSE)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return true;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (aStates[0].fStatus == NPSS_RDATA)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return false;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertMsgFailed(("%d / %d\n", orc, aStates[0].fStatus));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Fall back / alternative method.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#endif
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG cbActual = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG ulState = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AVAILDATA Avail = { 0, 0 };
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync APIRET orc = DosPeekNPipe(pThis->hPipe, NULL, 0, &cbActual, &Avail, &ulState);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc != NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc != ERROR_PIPE_BUSY)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertMsgFailed(("%d\n", orc));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return false;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return ulState != NP_STATE_CONNECTED;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsyncRTDECL(int) RTPipeRead(RTPIPE hPipe, void *pvBuf, size_t cbToRead, size_t *pcbRead)
637712559132d2b3617aea0103fb0385978da14evboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPIPEINTERNAL *pThis = hPipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(pThis->fRead, VERR_ACCESS_DENIED);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtr(pcbRead);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtr(pvBuf);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync int rc = RTCritSectEnter(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (RT_SUCCESS(rc))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = rtPipeTryNonBlocking(pThis);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (RT_SUCCESS(rc))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectLeave(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG cbActual = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync APIRET orc = DosRead(pThis->hPipe, pvBuf, cbToRead, &cbActual);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc == NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (cbActual || !cbToRead || !rtPipeOs2IsBroken(pThis))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *pcbRead = cbActual;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VERR_BROKEN_PIPE;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else if (orc == ERROR_NO_DATA)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *pcbRead = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VINF_TRY_AGAIN;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = RTErrConvertFromOS2(orc);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectEnter(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (rc == VERR_BROKEN_PIPE)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->fBrokenPipe = true;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->cUsers--;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VERR_WRONG_ORDER;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectLeave(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return rc;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsyncRTDECL(int) RTPipeReadBlocking(RTPIPE hPipe, void *pvBuf, size_t cbToRead, size_t *pcbRead)
637712559132d2b3617aea0103fb0385978da14evboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPIPEINTERNAL *pThis = hPipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(pThis->fRead, VERR_ACCESS_DENIED);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtr(pvBuf);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync int rc = RTCritSectEnter(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (RT_SUCCESS(rc))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = rtPipeTryBlocking(pThis);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (RT_SUCCESS(rc))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectLeave(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync size_t cbTotalRead = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync while (cbToRead > 0)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG cbActual = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync APIRET orc = DosRead(pThis->hPipe, pvBuf, cbToRead, &cbActual);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc != NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = RTErrConvertFromOS2(orc);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync break;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (!cbActual && rtPipeOs2IsBroken(pThis))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VERR_BROKEN_PIPE;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync break;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /* advance */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pvBuf = (char *)pvBuf + cbActual;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync cbTotalRead += cbActual;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync cbToRead -= cbActual;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (pcbRead)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *pcbRead = cbTotalRead;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if ( RT_FAILURE(rc)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync && cbTotalRead)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VINF_SUCCESS;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectEnter(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (rc == VERR_BROKEN_PIPE)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->fBrokenPipe = true;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->cUsers--;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VERR_WRONG_ORDER;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectLeave(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return rc;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync}
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync/**
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Gets the available write buffer size of the pipe.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @returns Number of bytes, 1 on failure.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @param pThis The pipe handle.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsyncstatic ULONG rtPipeOs2GetSpace(RTPIPEINTERNAL *pThis)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync Assert(!pThis->fRead);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#if 0 /* Not sure which is more efficient, neither are really optimal, I fear. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Query via semaphore state.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * This will walk the list of active named pipes...
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /** @todo Check how hev and hpipe are associated, if complicated, use the
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * alternative method below. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync PIPESEMSTATE aStates[3]; RT_ZERO(aStates);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync APIRET orc = DosQueryNPipeSemState((HSEM)pThis->hev, &aStates[0], sizeof(aStates));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc == NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (aStates[0].fStatus == NPSS_WSPACE)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return aStates[0].usAvail;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (aStates[1].fStatus == NPSS_WSPACE)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return aStates[1].usAvail;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertMsgFailed(("%d / %d\n", orc, aStates[0].fStatus));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Query via the pipe info.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * This will have to lookup and store the pipe name.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync union
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync PIPEINFO PipeInfo;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync uint8_t abPadding[sizeof(PIPEINFO) + 127];
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync } Buf;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync APIRET orc = DosQueryNPipeInfo(pThis->hPipe, 1, &Buf, sizeof(Buf));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc == NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return Buf.PipeInfo.cbOut;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertMsgFailed(("%d\n", orc));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync#endif
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return 1;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsyncRTDECL(int) RTPipeWrite(RTPIPE hPipe, const void *pvBuf, size_t cbToWrite, size_t *pcbWritten)
637712559132d2b3617aea0103fb0385978da14evboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPIPEINTERNAL *pThis = hPipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(!pThis->fRead, VERR_ACCESS_DENIED);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtr(pcbWritten);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtr(pvBuf);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync int rc = RTCritSectEnter(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (RT_SUCCESS(rc))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = rtPipeTryNonBlocking(pThis);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (RT_SUCCESS(rc))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (cbToWrite > 0)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG cbActual = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync APIRET orc = DosWrite(pThis->hPipe, pvBuf, cbToWrite, &cbActual);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc == NO_ERROR && cbActual == 0)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /* Retry with the request adjusted to the available buffer space. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG cbAvail = rtPipeOs2GetSpace(pThis);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync orc = DosWrite(pThis->hPipe, pvBuf, RT_MIN(cbAvail, cbToWrite), &cbActual);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc == NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *pcbWritten = cbActual;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (cbActual == 0)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VINF_TRY_AGAIN;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = RTErrConvertFromOS2(orc);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (rc == VERR_PIPE_NOT_CONNECTED)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VERR_BROKEN_PIPE;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *pcbWritten = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (rc == VERR_BROKEN_PIPE)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->fBrokenPipe = true;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->cUsers--;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VERR_WRONG_ORDER;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectLeave(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return rc;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
b1d7d513c459787311cd09c440524044fa7ff8a9vboxsyncRTDECL(int) RTPipeWriteBlocking(RTPIPE hPipe, const void *pvBuf, size_t cbToWrite, size_t *pcbWritten)
637712559132d2b3617aea0103fb0385978da14evboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPIPEINTERNAL *pThis = hPipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(!pThis->fRead, VERR_ACCESS_DENIED);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtr(pvBuf);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrNull(pcbWritten);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync int rc = RTCritSectEnter(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (RT_SUCCESS(rc))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = rtPipeTryBlocking(pThis);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (RT_SUCCESS(rc))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectLeave(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync size_t cbTotalWritten = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync while (cbToWrite > 0)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG cbActual = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync APIRET orc = DosWrite(pThis->hPipe, pvBuf, cbToWrite, &cbActual);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc != NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = RTErrConvertFromOS2(orc);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (rc == VERR_PIPE_NOT_CONNECTED)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VERR_BROKEN_PIPE;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync break;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pvBuf = (char const *)pvBuf + cbActual;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync cbToWrite -= cbActual;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync cbTotalWritten += cbActual;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (pcbWritten)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *pcbWritten = cbTotalWritten;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if ( RT_FAILURE(rc)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync && cbTotalWritten)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VINF_SUCCESS;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectEnter(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (rc == VERR_BROKEN_PIPE)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->fBrokenPipe = true;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->cUsers--;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VERR_WRONG_ORDER;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectLeave(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return rc;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsyncRTDECL(int) RTPipeFlush(RTPIPE hPipe)
637712559132d2b3617aea0103fb0385978da14evboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPIPEINTERNAL *pThis = hPipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(!pThis->fRead, VERR_ACCESS_DENIED);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync APIRET orc = DosResetBuffer(pThis->hPipe);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc != NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync int rc = RTErrConvertFromOS2(orc);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (rc == VERR_BROKEN_PIPE)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectEnter(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->fBrokenPipe = true;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectLeave(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return rc;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return VINF_SUCCESS;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsync
637712559132d2b3617aea0103fb0385978da14evboxsyncRTDECL(int) RTPipeSelectOne(RTPIPE hPipe, RTMSINTERVAL cMillies)
637712559132d2b3617aea0103fb0385978da14evboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPIPEINTERNAL *pThis = hPipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync uint64_t const StartMsTS = RTTimeMilliTS();
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync int rc = RTCritSectEnter(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (RT_FAILURE(rc))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return rc;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = rtPipeOs2EnsureSem(pThis);
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync if (RT_SUCCESS(rc) && cMillies > 0)
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync {
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync /* Stop polling attempts if we might block. */
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync if (pThis->hPollSet == NIL_RTPOLLSET)
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync pThis->hPollSet = (RTPOLLSET)(uintptr_t)0xbeef0042;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync else
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync rc = VERR_WRONG_ORDER;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (RT_SUCCESS(rc))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync for (unsigned iLoop = 0;; iLoop++)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Check the handle state.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync APIRET orc;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync if (cMillies > 0)
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync {
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync ULONG ulIgnore;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync orc = DosResetEventSem(pThis->hev, &ulIgnore);
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync AssertMsg(orc == NO_ERROR || orc == ERROR_ALREADY_RESET, ("%d\n", orc));
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync }
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync PIPESEMSTATE aStates[4]; RT_ZERO(aStates);
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync orc = DosQueryNPipeSemState((HSEM)pThis->hev, &aStates[0], sizeof(aStates));
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc != NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = RTErrConvertFromOS2(orc);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync break;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync int i = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (pThis->fRead)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync while (aStates[i].fStatus == NPSS_WSPACE)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync i++;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync while (aStates[i].fStatus == NPSS_RDATA)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync i++;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (aStates[i].fStatus == NPSS_CLOSE)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync break;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync Assert(aStates[i].fStatus == NPSS_WSPACE || aStates[i].fStatus == NPSS_RDATA || aStates[i].fStatus == NPSS_EOI);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if ( aStates[i].fStatus != NPSS_EOI
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync && aStates[i].usAvail > 0)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync break;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Check for timeout.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG cMsMaxWait = SEM_INDEFINITE_WAIT;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (cMillies != RT_INDEFINITE_WAIT)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync uint64_t cElapsed = RTTimeMilliTS() - StartMsTS;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (cElapsed >= cMillies)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VERR_TIMEOUT;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync break;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync cMsMaxWait = cMillies - (uint32_t)cElapsed;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /*
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Wait.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectLeave(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync orc = DosWaitEventSem(pThis->hev, cMsMaxWait);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectEnter(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc != NO_ERROR && orc != ERROR_TIMEOUT && orc != ERROR_SEM_TIMEOUT )
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = RTErrConvertFromOS2(orc);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync break;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (rc == VERR_BROKEN_PIPE)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->fBrokenPipe = true;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync if (cMillies > 0)
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync pThis->hPollSet = NIL_RTPOLLSET;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectLeave(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return rc;
637712559132d2b3617aea0103fb0385978da14evboxsync}
637712559132d2b3617aea0103fb0385978da14evboxsync
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsyncRTDECL(int) RTPipeQueryReadable(RTPIPE hPipe, size_t *pcbReadable)
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPIPEINTERNAL *pThis = hPipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(pThis->fRead, VERR_PIPE_NOT_READ);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(pcbReadable, VERR_INVALID_POINTER);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync int rc = RTCritSectEnter(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (RT_FAILURE(rc))
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return rc;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG cbActual = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync ULONG ulState = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AVAILDATA Avail = { 0, 0 };
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync APIRET orc = DosPeekNPipe(pThis->hPipe, NULL, 0, &cbActual, &Avail, &ulState);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (orc == NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (Avail.cbpipe > 0 || ulState == NP_STATE_CONNECTED)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *pcbReadable = Avail.cbpipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = VERR_PIPE_NOT_CONNECTED; /*??*/
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync rc = RTErrConvertFromOS2(orc);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectLeave(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return rc;
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync}
1729795f504cc1975ec195bca8b493c2faa0f5ddvboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
625fbb1328649ec29bf92374a6a980cdcd163726vboxsyncint rtPipePollGetHandle(RTPIPE hPipe, uint32_t fEvents, PRTHCINTPTR phNative)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPIPEINTERNAL *pThis = hPipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, VERR_INVALID_HANDLE);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync AssertReturn(!(fEvents & RTPOLL_EVT_READ) || pThis->fRead, VERR_INVALID_PARAMETER);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(!(fEvents & RTPOLL_EVT_WRITE) || !pThis->fRead, VERR_INVALID_PARAMETER);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync int rc = RTCritSectEnter(&pThis->CritSect);
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync if (RT_SUCCESS(rc))
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync {
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync rc = rtPipeOs2EnsureSem(pThis);
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync if (RT_SUCCESS(rc))
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync *phNative = (RTHCINTPTR)pThis->hev;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync RTCritSectLeave(&pThis->CritSect);
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync }
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync return rc;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync}
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync/**
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * Checks for pending events.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync *
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @returns Event mask or 0.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @param pThis The pipe handle.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync * @param fEvents The desired events.
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync * @param fResetEvtSem Whether to reset the event semaphore.
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync */
625fbb1328649ec29bf92374a6a980cdcd163726vboxsyncstatic uint32_t rtPipePollCheck(RTPIPEINTERNAL *pThis, uint32_t fEvents, bool fResetEvtSem)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync{
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync /*
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync * Reset the event semaphore if we're gonna wait.
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync */
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync APIRET orc;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync ULONG ulIgnore;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync if (fResetEvtSem)
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync {
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync orc = DosResetEventSem(pThis->hev, &ulIgnore);
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync AssertMsg(orc == NO_ERROR || orc == ERROR_ALREADY_RESET, ("%d\n", orc));
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync }
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync /*
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync * Check for events.
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync uint32_t fRetEvents = 0;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if (pThis->fBrokenPipe)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync fRetEvents |= RTPOLL_EVT_ERROR;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else if (pThis->fRead)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync ULONG cbActual = 0;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync ULONG ulState = 0;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync AVAILDATA Avail = { 0, 0 };
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync orc = DosPeekNPipe(pThis->hPipe, NULL, 0, &cbActual, &Avail, &ulState);
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync if (orc != NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync fRetEvents |= RTPOLL_EVT_ERROR;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync if (orc == ERROR_BROKEN_PIPE || orc == ERROR_PIPE_NOT_CONNECTED)
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync pThis->fBrokenPipe = true;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync }
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync else if (Avail.cbpipe > 0)
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync fRetEvents |= RTPOLL_EVT_READ;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync else if (ulState != NP_STATE_CONNECTED)
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync {
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync fRetEvents |= RTPOLL_EVT_ERROR;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync pThis->fBrokenPipe = true;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync PIPESEMSTATE aStates[4]; RT_ZERO(aStates);
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync orc = DosQueryNPipeSemState((HSEM)pThis->hev, &aStates[0], sizeof(aStates));
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync if (orc == NO_ERROR)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync int i = 0;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync while (aStates[i].fStatus == NPSS_RDATA)
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync i++;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync if (aStates[i].fStatus == NPSS_CLOSE)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync fRetEvents |= RTPOLL_EVT_ERROR;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync pThis->fBrokenPipe = true;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync else if ( aStates[i].fStatus == NPSS_WSPACE
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync && aStates[i].usAvail > 0)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync fRetEvents |= RTPOLL_EVT_WRITE;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync else
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync {
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync fRetEvents |= RTPOLL_EVT_ERROR;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync if (orc == ERROR_BROKEN_PIPE || orc == ERROR_PIPE_NOT_CONNECTED)
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync pThis->fBrokenPipe = true;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync return fRetEvents & (fEvents | RTPOLL_EVT_ERROR);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync}
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsyncuint32_t rtPipePollStart(RTPIPE hPipe, RTPOLLSET hPollSet, uint32_t fEvents, bool fFinalEntry, bool fNoWait)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPIPEINTERNAL *pThis = hPipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(pThis, UINT32_MAX);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, UINT32_MAX);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync int rc = RTCritSectEnter(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertRCReturn(rc, UINT32_MAX);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /* Check that this is the only current use of this pipe. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync uint32_t fRetEvents;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync if ( pThis->cUsers == 0
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync || pThis->hPollSet == NIL_RTPOLLSET)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync fRetEvents = rtPipePollCheck(pThis, fEvents, fNoWait);
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync if (!fRetEvents && !fNoWait)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync /* Mark the set busy while waiting. */
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync pThis->cUsers++;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync pThis->hPollSet = hPollSet;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync else
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync {
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertFailed();
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync fRetEvents = UINT32_MAX;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync }
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectLeave(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return fRetEvents;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync}
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsyncuint32_t rtPipePollDone(RTPIPE hPipe, uint32_t fEvents, bool fFinalEntry, bool fHarvestEvents)
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync{
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTPIPEINTERNAL *pThis = hPipe;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertPtrReturn(pThis, 0);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertReturn(pThis->u32Magic == RTPIPE_MAGIC, 0);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync int rc = RTCritSectEnter(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync AssertRCReturn(rc, 0);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync Assert(pThis->cUsers > 0);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /* harvest events. */
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync uint32_t fRetEvents = rtPipePollCheck(pThis, fEvents, false);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync /* update counters. */
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync pThis->cUsers--;
625fbb1328649ec29bf92374a6a980cdcd163726vboxsync pThis->hPollSet = NIL_RTPOLLSET;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync RTCritSectLeave(&pThis->CritSect);
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync return fRetEvents;
9f7c2715c84963f7a53bdbd1b9e9dadc533e6138vboxsync}