Changeset 26775 in vbox

Timestamp:

Feb 25, 2010 2:42:45 AM (15 years ago)

Author:

vboxsync

Message:

tstRTPipe: another test.

File:

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

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

@@ -41 +41 @@
 
 
+static void tstRTPipe3(void)
+{
+    RTTestISub("Full write buffer");
+
+    RTPIPE  hPipeR = (RTPIPE)999999;
+    RTPIPE  hPipeW = (RTPIPE)999999;
+    RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0), VINF_SUCCESS);
+
+    static char s_abBuf[_256K];
+    int         rc      = VINF_SUCCESS;
+    size_t      cbTotal = 0;
+    memset(s_abBuf, 0xff, sizeof(s_abBuf));
+    for (;;)
+    {
+        RTTESTI_CHECK(cbTotal < _1G);
+        if (cbTotal > _1G)
+            break;
+
+        size_t cbWritten = _1G;
+        rc = RTPipeWrite(hPipeW, s_abBuf, sizeof(s_abBuf), &cbWritten);
+        RTTESTI_CHECK(rc == VINF_SUCCESS || rc == VINF_TRY_AGAIN);
+        if (rc != VINF_SUCCESS)
+            break;
+        cbTotal += cbWritten;
+    }
+
+    if (rc == VINF_TRY_AGAIN)
+    {
+        RTTestIPrintf(RTTESTLVL_ALWAYS, "cbTotal=%zu (%#zx)\n", cbTotal, cbTotal);
+        RTTESTI_CHECK_RC(RTPipeSelectOne(hPipeW, 0), VERR_TIMEOUT);
+        RTTESTI_CHECK_RC(RTPipeSelectOne(hPipeW, 1), VERR_TIMEOUT);
+        size_t cbRead;
+        RTTESTI_CHECK_RC(RTPipeRead(hPipeR, s_abBuf, RT_MIN(sizeof(s_abBuf), cbTotal) / 2, &cbRead), VINF_SUCCESS);
+        RTTESTI_CHECK_RC(RTPipeSelectOne(hPipeW, 0), VINF_SUCCESS);
+        RTTESTI_CHECK_RC(RTPipeSelectOne(hPipeW, 1), VINF_SUCCESS);
+
+        size_t cbWritten = _1G;
+        rc = RTPipeWrite(hPipeW, s_abBuf, sizeof(s_abBuf), &cbWritten);
+        RTTESTI_CHECK(rc == VINF_SUCCESS);
+    }
+
+    RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS);
+    RTTESTI_CHECK_RC(RTPipeClose(hPipeW), VINF_SUCCESS);
+}
+
 static void tstRTPipe2(void)
 {
@@ -265 +310 @@
         RTAssertSetQuiet(fQuiet);
         RTAssertSetMayPanic(fMayPanic);
+
+        tstRTPipe3();
     }