Changeset 45678 in vbox for trunk/src/VBox/Runtime/r3/posix/fileaio-posix.cpp

Timestamp:

Apr 23, 2013 11:28:41 AM (12 years ago)

Author:

vboxsync

svn:sync-xref-src-repo-rev:

85204

Message:

Runtime/aio: Add flags parameter to RTFileAioCtxCreate

File:

• trunk/src/VBox/Runtime/r3/posix/fileaio-posix.cpp (modified) (5 diffs)

trunk/src/VBox/Runtime/r3/posix/fileaio-posix.cpp

@@ -123 +123 @@
     /** Flag whether the thread is currently waiting in the syscall. */
     volatile bool         fWaiting;
+    /** Flags given during creation. */
+    uint32_t              fFlags;
     /** Magic value (RTFILEAIOCTX_MAGIC). */
     uint32_t              u32Magic;
@@ -523 +525 @@
 
 
-RTDECL(int) RTFileAioCtxCreate(PRTFILEAIOCTX phAioCtx, uint32_t cAioReqsMax)
+RTDECL(int) RTFileAioCtxCreate(PRTFILEAIOCTX phAioCtx, uint32_t cAioReqsMax,
+                               uint32_t fFlags)
 {
     PRTFILEAIOCTXINTERNAL pCtxInt;
@@ -529 +532 @@
 
     AssertPtrReturn(phAioCtx, VERR_INVALID_POINTER);
+    AssertReturn(!(fFlags & ~RTFILEAIOCTX_FLAGS_VALID_MASK), VERR_INVALID_PARAMETER);
 
     if (cAioReqsMax == RTFILEAIO_UNLIMITED_REQS)
@@ -551 +555 @@
     pCtxInt->cMaxRequests = cAioReqsMax;
     pCtxInt->cReqsWaitMax = cReqsWaitMax;
+    pCtxInt->fFlags       = fFlags;
     *phAioCtx = (RTFILEAIOCTX)pCtxInt;
 
@@ -872 +877 @@
     int32_t cRequestsWaiting = ASMAtomicReadS32(&pCtxInt->cRequests);
 
-    if (RT_UNLIKELY(cRequestsWaiting <= 0))
+    if (   RT_UNLIKELY(cRequestsWaiting <= 0)
+        && !(pCtxInt->fFlags & RTFILEAIOCTX_FLAGS_WAIT_WITHOUT_PENDING_REQUESTS))
         return VERR_FILE_AIO_NO_REQUEST;