Zebediah Figura : ws2_32/tests: Test selecting for FD_READ while there is a pending WSARecv() call.

[Alexandre Julliard]

Module: wine
Branch: master
Commit: 59beffb46c813a3de2eae6f28e3f7f321f666e89
URL:    https://source.winehq.org/git/wine.git/?a=commit;h=59beffb46c813a3de2eae6f28...

Author: Zebediah Figura <zfigura(a)codeweavers.com>
Date:   Thu Apr 28 22:02:28 2022 -0500

ws2_32/tests: Test selecting for FD_READ while there is a pending WSARecv() call.

Signed-off-by: Zebediah Figura <zfigura(a)codeweavers.com>
Signed-off-by: Alexandre Julliard <julliard(a)winehq.org>

---

 dlls/ws2_32/tests/sock.c | 33 +++++++++++++++++++++++++++++++++
 1 file changed, 33 insertions(+)

diff --git a/dlls/ws2_32/tests/sock.c b/dlls/ws2_32/tests/sock.c
index d501930b32d..3e8b1f21c1d 100644
--- a/dlls/ws2_32/tests/sock.c
+++ b/dlls/ws2_32/tests/sock.c
@@ -5709,11 +5709,16 @@ static void test_write_events(struct event_test_ctx *ctx)
 
 static void test_read_events(struct event_test_ctx *ctx)
 {
+    OVERLAPPED overlapped = {0};
     SOCKET server, client;
+    DWORD size, flags = 0;
     unsigned int i;
     char buffer[8];
+    WSABUF wsabuf;
     int ret;
 
+    overlapped.hEvent = CreateEventA(NULL, TRUE, FALSE, NULL);
+
     tcp_socketpair(&client, &server);
     set_blocking(client, FALSE);
 
@@ -5788,8 +5793,36 @@ static void test_read_events(struct event_test_ctx *ctx)
 
     check_events(ctx, 0, 0, 200);
 
+    /* Send data while there is a pending WSARecv(). */
+
+    select_events(ctx, server, FD_ACCEPT | FD_CLOSE | FD_CONNECT | FD_OOB | FD_READ);
+
+    wsabuf.buf = buffer;
+    wsabuf.len = 1;
+    ret = WSARecv(server, &wsabuf, 1, NULL, &flags, &overlapped, NULL);
+    ok(ret == -1, "got %d\n", ret);
+    ok(WSAGetLastError() == ERROR_IO_PENDING, "got error %u\n", WSAGetLastError());
+
+    ret = send(client, "a", 1, 0);
+    ok(ret == 1, "got %d\n", ret);
+
+    ret = WaitForSingleObject(overlapped.hEvent, 200);
+    ok(!ret, "got %d\n", ret);
+    ret = GetOverlappedResult((HANDLE)server, &overlapped, &size, FALSE);
+    ok(ret, "got error %lu\n", GetLastError());
+    ok(size == 1, "got size %lu\n", size);
+
+    check_events(ctx, 0, 0, 0);
+
+    ret = send(client, "a", 1, 0);
+    ok(ret == 1, "got %d\n", ret);
+
+    check_events(ctx, FD_READ, 0, 200);
+    check_events(ctx, 0, 0, 0);
+
     closesocket(server);
     closesocket(client);
+    CloseHandle(overlapped.hEvent);
 }
 
 static void test_oob_events(struct event_test_ctx *ctx)