Changeset 19185 in vbox for trunk/src/VBox/Runtime/testcase

Timestamp:

Apr 26, 2009 9:04:33 AM (16 years ago)

Author:

vboxsync

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

46509

Message:

Runtime/Aio: Slight changes to the API for Windows. Fix the Solaris backend

File:

• trunk/src/VBox/Runtime/testcase/tstFileAio.cpp (modified) (2 diffs)

trunk/src/VBox/Runtime/testcase/tstFileAio.cpp

@@ -63 +63 @@
         RTFOFF           Offset = 0;
         size_t           cbLeft = cbTestFile;
-
-        /* Initialize buffers. */
-        for (unsigned i = 0; i < RT_ELEMENTS(apvBuf); i++)
+        int cRun = 0;
+
+        /* Associate file with context.*/
+        rc = RTFileAioCtxAssociateWithFile(hAioContext, File);
+        if (RT_SUCCESS(rc))
         {
-            apvBuf[i] = RTMemPageAllocZ(cbTestBuf);
-
-            if (fWrite)
-                memcpy(apvBuf[i], pvTestBuf, cbTestBuf);
+            /* Initialize buffers. */
+            for (unsigned i = 0; i < RT_ELEMENTS(apvBuf); i++)
+            {
+                apvBuf[i] = RTMemPageAllocZ(cbTestBuf);
+
+                if (fWrite)
+                    memcpy(apvBuf[i], pvTestBuf, cbTestBuf);
+            }
+
+            /* Initialize requests. */
+            for (unsigned i = 0; i < RT_ELEMENTS(aReqs); i++)
+                RTFileAioReqCreate(&aReqs[i]);
+
+            while (cbLeft)
+            {
+                int cReqs = 0;
+                size_t cReqsSubmitted = 0;
+
+                for (unsigned i = 0; i < RT_ELEMENTS(aReqs); i++)
+                {
+                    size_t cbTransfer = (cbLeft < cbTestBuf) ? cbLeft : cbTestBuf;
+
+                    if (!cbTransfer)
+                        break;
+
+                    if (fWrite)
+                        rc = RTFileAioReqPrepareWrite(aReqs[i], File, Offset, apvBuf[i],
+                                                      cbTransfer, apvBuf[i]);
+                    else
+                        rc = RTFileAioReqPrepareRead(aReqs[i], File, Offset, apvBuf[i],
+                                                     cbTransfer, apvBuf[i]);
+
+                    cbLeft -= cbTransfer;
+                    Offset += cbTransfer;
+                    cReqs++;
+                }
+
+                rc = RTFileAioCtxSubmit(hAioContext, aReqs, cReqs, &cReqsSubmitted);
+                if (RT_FAILURE(rc))
+                {
+                    RTPrintf("tstFileAio: FATAL ERROR - Failed to submit tasks after %d runs. rc=%Rrc\n", cRun, rc);
+                    cErrors++;
+                    break;
+                }
+                else if (cReqs != cReqsSubmitted)
+                {
+                    RTPrintf("tstFileAio: FATAL ERROR - Submitted tasks but the result is not equal to the number of submitted tasks\n", rc);
+                    cErrors++;
+                    break;
+                }
+
+                /* Wait */
+                RTFILEAIOREQ aReqsCompleted[TSTFILEAIO_MAX_REQS_IN_FLIGHT];
+                uint32_t cCompleted = 0;
+                rc = RTFileAioCtxWait(hAioContext, cReqs, RT_INDEFINITE_WAIT,
+                                      aReqsCompleted, TSTFILEAIO_MAX_REQS_IN_FLIGHT,
+                                      &cCompleted);
+                if (RT_FAILURE(rc))
+                {
+                    RTPrintf("tstFileAio: FATAL ERROR - Waiting failed. rc=%Rrc\n", rc);
+                    cErrors++;
+                    break;
+                }
+
+                if (!fWrite)
+                {
+                    for (uint32_t i = 0; i < cCompleted; i++)
+                    {
+                        /* Compare that we read the right stuff. */
+                        void *pvBuf = RTFileAioReqGetUser(aReqsCompleted[i]);
+
+                        size_t cbTransfered;
+                        int rcReq = RTFileAioReqGetRC(aReqsCompleted[i], &cbTransfered);
+                        if (RT_FAILURE(rcReq) || (cbTransfered != cbTestBuf))
+                        {
+                            RTPrintf("tstFileAio: FATAL ERROR - Request %d failed with rc=%Rrc cbTransfered=%d.\n",
+                                     i, rcReq, cbTransfered);
+                            cErrors++;
+                            rc = rcReq;
+                            break;
+                        }
+
+                        if (memcmp(pvBuf, pvTestBuf, cbTestBuf) != 0)
+                        {
+                            RTPrintf("tstFileAio: FATAL ERROR - Unexpected content in memory.\n");
+                            cErrors++;
+                            break;
+                        }
+                        memset(pvBuf, 0, cbTestBuf);
+                    }
+                }
+                cRun++;
+                if (RT_FAILURE(rc))
+                    break;
+            }
+
+            /* Free buffers. */
+            for (unsigned i = 0; i < RT_ELEMENTS(apvBuf); i++)
+                RTMemPageFree(apvBuf[i]);
+
+            /* Free requests. */
+            for (unsigned i = 0; i < RT_ELEMENTS(aReqs); i++)
+                RTFileAioReqDestroy(aReqs[i]);
+
+            NanoTS = RTTimeNanoTS() - NanoTS;
+            unsigned SpeedKBs = cbTestFile / (NanoTS / 1000000000.0) / 1024;
+
+            RTPrintf("tstFileAio: Completed simple %s test: %d.%03d MB/sec\n",
+                     fWrite ? "write" : "read",
+                     SpeedKBs / 1000,
+                     SpeedKBs % 1000);
         }
-
-        /* Initialize requests. */
-        for (unsigned i = 0; i < RT_ELEMENTS(aReqs); i++)
-            RTFileAioReqCreate(&aReqs[i]);
-
-        while (cbLeft)
+        else
         {
-            int cReqs = 0;
-
-            for (unsigned i = 0; i < RT_ELEMENTS(aReqs); i++)
-            {
-                size_t cbTransfer = (cbLeft < cbTestBuf) ? cbLeft : cbTestBuf;
-
-                if (!cbTransfer)
-                    break;
-
-                if (fWrite)
-                    rc = RTFileAioReqPrepareWrite(aReqs[i], File, Offset, apvBuf[i],
-                                                  cbTransfer, apvBuf[i]);
-                else
-                    rc = RTFileAioReqPrepareRead(aReqs[i], File, Offset, apvBuf[i],
-                                                 cbTransfer, apvBuf[i]);
-
-                cbLeft -= cbTransfer;
-                Offset += cbTransfer;
-                cReqs++;
-            }
-
-            rc = RTFileAioCtxSubmit(hAioContext, aReqs, cReqs);
-            if (RT_FAILURE(rc))
-            {
-                RTPrintf("tstFileAio: FATAL ERROR - Failed to submit tasks. rc=%Rrc\n", rc);
-                cErrors++;
-                break;
-            }
-
-            /* Wait */
-            RTFILEAIOREQ aReqsCompleted[TSTFILEAIO_MAX_REQS_IN_FLIGHT];
-            uint32_t cCompleted = 0;
-            rc = RTFileAioCtxWait(hAioContext, cReqs, RT_INDEFINITE_WAIT,
-                                  aReqsCompleted, TSTFILEAIO_MAX_REQS_IN_FLIGHT,
-                                  &cCompleted);
-            if (RT_FAILURE(rc))
-            {
-                RTPrintf("tstFileAio: FATAL ERROR - Waiting failed. rc=%Rrc\n", rc);
-                cErrors++;
-                break;
-            }
-
-            if (!fWrite)
-            {
-                for (uint32_t i = 0; i < cCompleted; i++)
-                {
-                    /* Compare that we read the right stuff. */
-                    void *pvBuf = RTFileAioReqGetUser(aReqsCompleted[i]);
-
-                    if (memcmp(pvBuf, pvTestBuf, cbTestBuf) != 0)
-                    {
-                        RTPrintf("tstFileAio: FATAL ERROR - Unexpected content in memory.\n");
-                        cErrors++;
-                        break;
-                    }
-                    memset(pvBuf, 0, cbTestBuf);
-                }
-            }
+            RTPrintf("tstFileAio: FATAL ERROR - Failed to asssociate file with async I/O context. rc=%Rrc\n", rc);
+            cErrors++;
         }
-
-        /* Free buffers. */
-        for (unsigned i = 0; i < RT_ELEMENTS(apvBuf); i++)
-            RTMemPageFree(apvBuf[i]);
-
-        /* Free requests. */
-        for (unsigned i = 0; i < RT_ELEMENTS(aReqs); i++)
-            RTFileAioReqDestroy(aReqs[i]);
-
-        NanoTS = RTTimeNanoTS() - NanoTS;
-        unsigned SpeedKBs = cbTestFile / (NanoTS / 1000000000.0) / 1024;
-
-        RTPrintf("tstFileAio: Completed simple %s test: %d.%03d MB/sec\n",
-                 fWrite ? "write" : "read",
-                 SpeedKBs / 1000,
-                 SpeedKBs % 1000);
 
         rc = RTFileAioCtxDestroy(hAioContext);
@@ -190 +222 @@
     RTPrintf("tstFileAio: Preparing test file, this can take some time and needs quite a bit of harddisk\n");
     tstFileAioTestReadWriteBasic(File, true, pvTestBuf, 64*_1K, 100*_1M);
-    tstFileAioTestReadWriteBasic(File, false, pvTestBuf, 64*_1K, 100*_1M);
-
+    /* Reopen the file. */
     RTFileClose(File);
+    rc = RTFileOpen(&File, "tstFileAio#1.tst", RTFILE_O_READWRITE | RTFILE_O_DENY_NONE | RTFILE_O_ASYNC_IO);
+    if (RT_SUCCESS(rc))
+    {
+        tstFileAioTestReadWriteBasic(File, false, pvTestBuf, 64*_1K, 100*_1M);
+        RTFileClose(File);
+    }
+    else
+    {
+        RTPrintf("tstFileAio: FATAL ERROR - Failed to open file #1. rc=%Rrc\n", rc);
+        cErrors++;
+    }
+
+    /* Cleanup */
     RTMemFree(pvTestBuf);
     RTFileDelete("tstFileAio#1.tst");