r3/solaris/fileaio-solaris.cpp

83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync/* $Id$ */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync/** @file
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * IPRT - File async I/O, native implementation for the Solaris host platform.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync/*
c58f1213e628a545081c70e26c6b67a841cff880vboxsync * Copyright (C) 2006-2012 Oracle Corporation
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync *
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * This file is part of VirtualBox Open Source Edition (OSE), as
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * available from http://www.virtualbox.org. This file is free software;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * you can redistribute it and/or modify it under the terms of the GNU
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * General Public License (GPL) as published by the Free Software
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * Foundation, in version 2 as it comes in the "COPYING" file of the
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync *
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * The contents of this file may alternatively be used under the terms
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * of the Common Development and Distribution License Version 1.0
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * (CDDL) only, as it comes in the "COPYING.CDDL" file of the
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * VirtualBox OSE distribution, in which case the provisions of the
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * CDDL are applicable instead of those of the GPL.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync *
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * You may elect to license modified versions of this file under the
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * terms and conditions of either the GPL or the CDDL or both.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync/*******************************************************************************
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync*   Header Files                                                               *
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync*******************************************************************************/
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync#define LOG_GROUP RTLOGGROUP_FILE
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync#include <iprt/asm.h>
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync#include <iprt/file.h>
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync#include <iprt/mem.h>
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync#include <iprt/assert.h>
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync#include <iprt/string.h>
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync#include <iprt/err.h>
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync#include <iprt/log.h>
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync#include "internal/fileaio.h"
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync#include <port.h>
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync#include <aio.h>
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync#include <errno.h>
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync#include <unistd.h>
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync/*******************************************************************************
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync*   Structures and Typedefs                                                    *
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync*******************************************************************************/
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync/**
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * Async I/O completion context state.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsynctypedef struct RTFILEAIOCTXINTERNAL
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /** Handle to the port. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    int               iPort;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /** Current number of requests active on this context. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    volatile int32_t  cRequests;
10d739d22a5d5a13803f7e34de34de010099270cvboxsync    /** Flags given during creation. */
10d739d22a5d5a13803f7e34de34de010099270cvboxsync    uint32_t          fFlags;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /** Magic value (RTFILEAIOCTX_MAGIC). */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    uint32_t          u32Magic;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync} RTFILEAIOCTXINTERNAL;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync/** Pointer to an internal context structure. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsynctypedef RTFILEAIOCTXINTERNAL *PRTFILEAIOCTXINTERNAL;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync/**
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * Async I/O request state.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsynctypedef struct RTFILEAIOREQINTERNAL
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /** The aio control block. Must be the FIRST
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync     *  element. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    struct aiocb           AioCB;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /** Current state the request is in. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQSTATE      enmState;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /** Flag whether this is a flush request. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    bool                   fFlush;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /** Port notifier object to associate a request to a port. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    port_notify_t          PortNotifier;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /** Opaque user data. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    void                  *pvUser;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /** Completion context we are assigned to. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    PRTFILEAIOCTXINTERNAL  pCtxInt;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /** Magic value  (RTFILEAIOREQ_MAGIC). */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    uint32_t               u32Magic;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync} RTFILEAIOREQINTERNAL;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync/** Pointer to an internal request structure. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsynctypedef RTFILEAIOREQINTERNAL *PRTFILEAIOREQINTERNAL;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync/*******************************************************************************
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync*   Defined Constants And Macros                                               *
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync*******************************************************************************/
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync/** The max number of events to get in one call. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync#define AIO_MAXIMUM_REQUESTS_PER_CONTEXT 64
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync/** Id for the wakeup event. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync#define AIO_CONTEXT_WAKEUP_EVENT 1
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsyncRTR3DECL(int) RTFileAioGetLimits(PRTFILEAIOLIMITS pAioLimits)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    int rcBSD = 0;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    AssertPtrReturn(pAioLimits, VERR_INVALID_POINTER);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /* No limits known. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pAioLimits->cReqsOutstandingMax = RTFILEAIO_UNLIMITED_REQS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pAioLimits->cbBufferAlignment   = 0;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsyncRTR3DECL(int) RTFileAioReqCreate(PRTFILEAIOREQ phReq)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    AssertPtrReturn(phReq, VERR_INVALID_POINTER);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    PRTFILEAIOREQINTERNAL pReqInt = (PRTFILEAIOREQINTERNAL)RTMemAllocZ(sizeof(RTFILEAIOREQINTERNAL));
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    if (RT_UNLIKELY(!pReqInt))
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        return VERR_NO_MEMORY;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /* Ininitialize static parts. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pReqInt->AioCB.aio_sigevent.sigev_notify = SIGEV_PORT;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pReqInt->AioCB.aio_sigevent.sigev_value.sival_ptr = &pReqInt->PortNotifier;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pReqInt->PortNotifier.portnfy_user = pReqInt;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pReqInt->pCtxInt                   = NULL;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pReqInt->u32Magic                  = RTFILEAIOREQ_MAGIC;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQ_SET_STATE(pReqInt, COMPLETED);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    *phReq = (RTFILEAIOREQ)pReqInt;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsyncRTDECL(int) RTFileAioReqDestroy(RTFILEAIOREQ hReq)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /*
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync     * Validate the handle and ignore nil.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync     */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    if (hReq == NIL_RTFILEAIOREQ)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        return VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    PRTFILEAIOREQINTERNAL pReqInt = hReq;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQ_VALID_RETURN(pReqInt);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQ_NOT_STATE_RETURN_RC(pReqInt, SUBMITTED, VERR_FILE_AIO_IN_PROGRESS);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /*
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync     * Trash the magic and free it.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync     */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    ASMAtomicUoWriteU32(&pReqInt->u32Magic, ~RTFILEAIOREQ_MAGIC);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTMemFree(pReqInt);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync/**
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync * Worker setting up the request.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsyncDECLINLINE(int) rtFileAioReqPrepareTransfer(RTFILEAIOREQ hReq, RTFILE hFile,
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                                            unsigned uTransferDirection,
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                                            RTFOFF off, void *pvBuf, size_t cbTransfer,
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                                            void *pvUser)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /*
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync     * Validate the input.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync     */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    PRTFILEAIOREQINTERNAL pReqInt = hReq;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQ_VALID_RETURN(pReqInt);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQ_NOT_STATE_RETURN_RC(pReqInt, SUBMITTED, VERR_FILE_AIO_IN_PROGRESS);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    Assert(hFile != NIL_RTFILE);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    AssertPtr(pvBuf);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    Assert(off >= 0);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    Assert(cbTransfer > 0);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pReqInt->AioCB.aio_lio_opcode = uTransferDirection;
5241858827a9ef9bcad4f3e9bf3ade21ee9c6f97vboxsync    pReqInt->AioCB.aio_fildes     = RTFileToNative(hFile);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pReqInt->AioCB.aio_offset     = off;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pReqInt->AioCB.aio_nbytes     = cbTransfer;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pReqInt->AioCB.aio_buf        = pvBuf;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pReqInt->fFlush               = false;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pReqInt->pvUser               = pvUser;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pReqInt->pCtxInt              = NULL;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQ_SET_STATE(pReqInt, PREPARED);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsyncRTDECL(int) RTFileAioReqPrepareRead(RTFILEAIOREQ hReq, RTFILE hFile, RTFOFF off,
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                                    void *pvBuf, size_t cbRead, void *pvUser)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return rtFileAioReqPrepareTransfer(hReq, hFile, LIO_READ,
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                                       off, pvBuf, cbRead, pvUser);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsyncRTDECL(int) RTFileAioReqPrepareWrite(RTFILEAIOREQ hReq, RTFILE hFile, RTFOFF off,
88acfa6629a7976c0583c1712d2b5b22a87a5121vboxsync                                     void const *pvBuf, size_t cbWrite, void *pvUser)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return rtFileAioReqPrepareTransfer(hReq, hFile, LIO_WRITE,
88acfa6629a7976c0583c1712d2b5b22a87a5121vboxsync                                       off, (void *)pvBuf, cbWrite, pvUser);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsyncRTDECL(int) RTFileAioReqPrepareFlush(RTFILEAIOREQ hReq, RTFILE hFile, void *pvUser)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    PRTFILEAIOREQINTERNAL pReqInt = (PRTFILEAIOREQINTERNAL)hReq;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQ_VALID_RETURN(pReqInt);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQ_NOT_STATE_RETURN_RC(pReqInt, SUBMITTED, VERR_FILE_AIO_IN_PROGRESS);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    Assert(hFile != NIL_RTFILE);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pReqInt->fFlush           = true;
5241858827a9ef9bcad4f3e9bf3ade21ee9c6f97vboxsync    pReqInt->AioCB.aio_fildes = RTFileToNative(hFile);
427735c505430fb6cd1253b26ca5ac0e4c55cbcfvboxsync    pReqInt->AioCB.aio_offset = 0;
427735c505430fb6cd1253b26ca5ac0e4c55cbcfvboxsync    pReqInt->AioCB.aio_nbytes = 0;
427735c505430fb6cd1253b26ca5ac0e4c55cbcfvboxsync    pReqInt->AioCB.aio_buf    = NULL;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pReqInt->pvUser           = pvUser;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQ_SET_STATE(pReqInt, PREPARED);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsyncRTDECL(void *) RTFileAioReqGetUser(RTFILEAIOREQ hReq)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    PRTFILEAIOREQINTERNAL pReqInt = hReq;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQ_VALID_RETURN_RC(pReqInt, NULL);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return pReqInt->pvUser;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsyncRTDECL(int) RTFileAioReqCancel(RTFILEAIOREQ hReq)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    PRTFILEAIOREQINTERNAL pReqInt = hReq;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQ_VALID_RETURN(pReqInt);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQ_STATE_RETURN_RC(pReqInt, SUBMITTED, VERR_FILE_AIO_NOT_SUBMITTED);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    int rcSolaris = aio_cancel(pReqInt->AioCB.aio_fildes, &pReqInt->AioCB);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    if (rcSolaris == AIO_CANCELED)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        /*
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync         * Decrement request count because the request will never arrive at the
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync         * completion port.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync         */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        AssertMsg(VALID_PTR(pReqInt->pCtxInt),
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                  ("Invalid state. Request was canceled but wasn't submitted\n"));
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        ASMAtomicDecS32(&pReqInt->pCtxInt->cRequests);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        RTFILEAIOREQ_SET_STATE(pReqInt, COMPLETED);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        return VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    else if (rcSolaris == AIO_ALLDONE)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        return VERR_FILE_AIO_COMPLETED;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    else if (rcSolaris == AIO_NOTCANCELED)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        return VERR_FILE_AIO_IN_PROGRESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    else
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        return RTErrConvertFromErrno(errno);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsyncRTDECL(int) RTFileAioReqGetRC(RTFILEAIOREQ hReq, size_t *pcbTransfered)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    PRTFILEAIOREQINTERNAL pReqInt = hReq;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQ_VALID_RETURN(pReqInt);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQ_NOT_STATE_RETURN_RC(pReqInt, SUBMITTED, VERR_FILE_AIO_IN_PROGRESS);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOREQ_NOT_STATE_RETURN_RC(pReqInt, PREPARED, VERR_FILE_AIO_NOT_SUBMITTED);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    AssertPtrNull(pcbTransfered);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    int rcSol = aio_error(&pReqInt->AioCB);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    Assert(rcSol != EINPROGRESS); /* Handled by our own state handling. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    if (rcSol == 0)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        if (pcbTransfered)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            *pcbTransfered = aio_return(&pReqInt->AioCB);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        return VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /* An error occurred. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return RTErrConvertFromErrno(rcSol);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
10d739d22a5d5a13803f7e34de34de010099270cvboxsyncRTDECL(int) RTFileAioCtxCreate(PRTFILEAIOCTX phAioCtx, uint32_t cAioReqsMax,
10d739d22a5d5a13803f7e34de34de010099270cvboxsync                               uint32_t fFlags)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    int rc = VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    PRTFILEAIOCTXINTERNAL pCtxInt;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    AssertPtrReturn(phAioCtx, VERR_INVALID_POINTER);
10d739d22a5d5a13803f7e34de34de010099270cvboxsync    AssertReturn(!(fFlags & ~RTFILEAIOCTX_FLAGS_VALID_MASK), VERR_INVALID_PARAMETER);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pCtxInt = (PRTFILEAIOCTXINTERNAL)RTMemAllocZ(sizeof(RTFILEAIOCTXINTERNAL));
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    if (RT_UNLIKELY(!pCtxInt))
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        return VERR_NO_MEMORY;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /* Init the event handle. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    pCtxInt->iPort = port_create();
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    if (RT_LIKELY(pCtxInt->iPort > 0))
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    {
10d739d22a5d5a13803f7e34de34de010099270cvboxsync        pCtxInt->fFlags   = fFlags;
10d739d22a5d5a13803f7e34de34de010099270cvboxsync        pCtxInt->u32Magic = RTFILEAIOCTX_MAGIC;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        *phAioCtx = (RTFILEAIOCTX)pCtxInt;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    else
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        RTMemFree(pCtxInt);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        rc = RTErrConvertFromErrno(errno);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return rc;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsyncRTDECL(int) RTFileAioCtxDestroy(RTFILEAIOCTX hAioCtx)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /* Validate the handle and ignore nil. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    if (hAioCtx == NIL_RTFILEAIOCTX)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        return VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    PRTFILEAIOCTXINTERNAL pCtxInt = hAioCtx;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOCTX_VALID_RETURN(pCtxInt);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /* Cannot destroy a busy context. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    if (RT_UNLIKELY(pCtxInt->cRequests))
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        return VERR_FILE_AIO_BUSY;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    close(pCtxInt->iPort);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    ASMAtomicUoWriteU32(&pCtxInt->u32Magic, RTFILEAIOCTX_MAGIC_DEAD);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTMemFree(pCtxInt);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsyncRTDECL(uint32_t) RTFileAioCtxGetMaxReqCount(RTFILEAIOCTX hAioCtx)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return RTFILEAIO_UNLIMITED_REQS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsyncRTDECL(int) RTFileAioCtxAssociateWithFile(RTFILEAIOCTX hAioCtx, RTFILE hFile)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsyncRTDECL(int) RTFileAioCtxSubmit(RTFILEAIOCTX hAioCtx, PRTFILEAIOREQ pahReqs, size_t cReqs)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /*
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync     * Parameter validation.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync     */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    int rc = VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    PRTFILEAIOCTXINTERNAL pCtxInt = hAioCtx;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOCTX_VALID_RETURN(pCtxInt);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    AssertReturn(cReqs > 0,  VERR_INVALID_PARAMETER);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    AssertPtrReturn(pahReqs, VERR_INVALID_POINTER);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    size_t i = cReqs;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    do
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        int rcSol = 0;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        size_t cReqsSubmit = 0;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        PRTFILEAIOREQINTERNAL pReqInt;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        while(i-- > 0)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            pReqInt = pahReqs[i];
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            if (RTFILEAIOREQ_IS_NOT_VALID(pReqInt))
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                /* Undo everything and stop submitting. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                for (size_t iUndo = 0; iUndo < i; iUndo++)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                    pReqInt = pahReqs[iUndo];
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                    RTFILEAIOREQ_SET_STATE(pReqInt, PREPARED);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                    pReqInt->pCtxInt = NULL;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                rc = VERR_INVALID_HANDLE;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                break;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            pReqInt->PortNotifier.portnfy_port = pCtxInt->iPort;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            pReqInt->pCtxInt                   = pCtxInt;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            RTFILEAIOREQ_SET_STATE(pReqInt, SUBMITTED);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            if (pReqInt->fFlush)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                break;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            cReqsSubmit++;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        if (cReqsSubmit)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            rcSol = lio_listio(LIO_NOWAIT, (struct aiocb **)pahReqs, cReqsSubmit, NULL);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            if (RT_UNLIKELY(rcSol < 0))
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                if (rcSol == EAGAIN)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                    rc = VERR_FILE_AIO_INSUFFICIENT_RESSOURCES;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                else
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                    rc = RTErrConvertFromErrno(errno);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                /* Check which requests got actually submitted and which not. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                for (i = 0; i < cReqs; i++)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                    pReqInt = pahReqs[i];
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                    rcSol = aio_error(&pReqInt->AioCB);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                    if (rcSol == EINVAL)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                    {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                        /* Was not submitted. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                        RTFILEAIOREQ_SET_STATE(pReqInt, PREPARED);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                        pReqInt->pCtxInt = NULL;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                    }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                    else if (rcSol != EINPROGRESS)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                    {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                        /* The request encountered an error. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                        RTFILEAIOREQ_SET_STATE(pReqInt, COMPLETED);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                    }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                break;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            ASMAtomicAddS32(&pCtxInt->cRequests, cReqsSubmit);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            cReqs   -= cReqsSubmit;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            pahReqs += cReqsSubmit;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        if (cReqs)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            pReqInt = pahReqs[0];
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            RTFILEAIOREQ_VALID_RETURN(pReqInt);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            /*
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync             * If there are still requests left we have a flush request.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync             * lio_listio does not work with this requests so
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync             * we have to use aio_fsync directly.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync             */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            rcSol = aio_fsync(O_SYNC, &pReqInt->AioCB);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            if (RT_UNLIKELY(rcSol < 0))
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                RTFILEAIOREQ_SET_STATE(pReqInt, COMPLETED);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                rc = RTErrConvertFromErrno(errno);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                break;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            ASMAtomicIncS32(&pCtxInt->cRequests);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            cReqs--;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            pahReqs++;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    } while (cReqs);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return rc;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsyncRTDECL(int) RTFileAioCtxWait(RTFILEAIOCTX hAioCtx, size_t cMinReqs, RTMSINTERVAL cMillies,
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                             PRTFILEAIOREQ pahReqs, size_t cReqs, uint32_t *pcReqs)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    int rc = VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    int cRequestsCompleted = 0;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /*
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync     * Validate the parameters, making sure to always set pcReqs.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync     */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    AssertPtrReturn(pcReqs, VERR_INVALID_POINTER);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    *pcReqs = 0; /* always set */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    PRTFILEAIOCTXINTERNAL pCtxInt = hAioCtx;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOCTX_VALID_RETURN(pCtxInt);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    AssertPtrReturn(pahReqs, VERR_INVALID_POINTER);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    AssertReturn(cReqs != 0, VERR_INVALID_PARAMETER);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    AssertReturn(cReqs >= cMinReqs, VERR_OUT_OF_RANGE);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
10d739d22a5d5a13803f7e34de34de010099270cvboxsync    if (    RT_UNLIKELY(ASMAtomicReadS32(&pCtxInt->cRequests) == 0)
10d739d22a5d5a13803f7e34de34de010099270cvboxsync        && !(pCtxInt->fFlags & RTFILEAIOCTX_FLAGS_WAIT_WITHOUT_PENDING_REQUESTS))
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        return VERR_FILE_AIO_NO_REQUEST;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /*
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync     * Convert the timeout if specified.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync     */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    struct timespec    *pTimeout = NULL;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    struct timespec     Timeout = {0,0};
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    uint64_t            StartNanoTS = 0;
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsync    if (cMillies != RT_INDEFINITE_WAIT)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    {
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsync        Timeout.tv_sec  = cMillies / 1000;
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsync        Timeout.tv_nsec = cMillies % 1000 * 1000000;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        pTimeout = &Timeout;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        StartNanoTS = RTTimeNanoTS();
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /* Wait for at least one. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    if (!cMinReqs)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        cMinReqs = 1;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    while (   cMinReqs
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync           && RT_SUCCESS_NP(rc))
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        port_event_t aPortEvents[AIO_MAXIMUM_REQUESTS_PER_CONTEXT];
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        uint_t cRequests    = cMinReqs;
1404accf62d12d9e9cfca5a55f246fc0cd180b25vboxsync        int cRequestsToWait = RT_MIN(cReqs, AIO_MAXIMUM_REQUESTS_PER_CONTEXT);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        int rcSol;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        uint64_t StartTime;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        rcSol = port_getn(pCtxInt->iPort, &aPortEvents[0], cRequestsToWait, &cRequests, pTimeout);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        if (RT_UNLIKELY(rcSol < 0))
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            rc = RTErrConvertFromErrno(errno);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        /* Process received events. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        for (uint_t i = 0; i < cRequests; i++)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            if (aPortEvents[i].portev_source == PORT_SOURCE_ALERT)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                Assert(aPortEvents[i].portev_events == AIO_CONTEXT_WAKEUP_EVENT);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                rc = VERR_INTERRUPTED; /* We've got interrupted. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                /* Reset the port. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                port_alert(pCtxInt->iPort, PORT_ALERT_SET, 0, NULL);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            else
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                PRTFILEAIOREQINTERNAL pReqInt = (PRTFILEAIOREQINTERNAL)aPortEvents[i].portev_user;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                AssertPtr(pReqInt);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                Assert(pReqInt->u32Magic == RTFILEAIOREQ_MAGIC);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                /* A request has finished. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                pahReqs[cRequestsCompleted++] = pReqInt;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                /* Mark the request as finished. */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync                RTFILEAIOREQ_SET_STATE(pReqInt, COMPLETED);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        /*
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync         * Done Yet? If not advance and try again.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync         */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        if (cRequests >= cMinReqs)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            break;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        cMinReqs -= cRequests;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        cReqs    -= cRequests;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsync        if (cMillies != RT_INDEFINITE_WAIT)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        {
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            uint64_t NanoTS = RTTimeNanoTS();
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            uint64_t cMilliesElapsed = (NanoTS - StartNanoTS) / 1000000;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync            /* The syscall supposedly updates it, but we're paranoid. :-) */
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsync            if (cMilliesElapsed < cMillies)
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsync            {
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsync                Timeout.tv_sec  = (cMillies - (RTMSINTERVAL)cMilliesElapsed) / 1000;
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsync                Timeout.tv_nsec = (cMillies - (RTMSINTERVAL)cMilliesElapsed) % 1000 * 1000000;
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsync            }
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsync            else
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsync            {
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsync                Timeout.tv_sec  = 0;
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsync                Timeout.tv_nsec = 0;
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsync            }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    }
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    /*
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync     * Update the context state and set the return value.
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync     */
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    *pcReqs = cRequestsCompleted;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    ASMAtomicSubS32(&pCtxInt->cRequests, cRequestsCompleted);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return rc;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsyncRTDECL(int) RTFileAioCtxWakeup(RTFILEAIOCTX hAioCtx)
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync{
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    int rc = VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    PRTFILEAIOCTXINTERNAL pCtxInt = hAioCtx;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    RTFILEAIOCTX_VALID_RETURN(pCtxInt);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    rc = port_alert(pCtxInt->iPort, PORT_ALERT_UPDATE, AIO_CONTEXT_WAKEUP_EVENT, NULL);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    if (RT_UNLIKELY((rc < 0) && (errno != EBUSY)))
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync        return RTErrConvertFromErrno(errno);
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync    return VINF_SUCCESS;
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync}
83ef82c0f827540ae1bbbff41542f02cba3f4e95vboxsync