marko10_000
/
wine-wine
forked from Mirrors/wine-wine
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

ntoskrnl/tests: Add test for WSK send and receive. 

Signed-off-by: Paul Gofman <pgofman@codeweavers.com>
Signed-off-by: Alexandre Julliard <julliard@winehq.org>
master
Paul Gofman 2020-06-19 13:13:16 +03:00 committed by Alexandre Julliard
parent defd4d5380
commit 717c5ff0a1
2 changed files with 60 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
dlls/ntoskrnl.exe/tests/driver4.c
View File

@ -167,15 +167,22 @@ struct socket_context
{ {
}; };
#define TEST_BUFFER_LENGTH 256
static void test_wsk_listen_socket(void) static void test_wsk_listen_socket(void)
{ {
static const char test_receive_string[] = "Client test string 1.";
const WSK_PROVIDER_LISTEN_DISPATCH *tcp_dispatch, *udp_dispatch; const WSK_PROVIDER_LISTEN_DISPATCH *tcp_dispatch, *udp_dispatch;
static const char test_send_string[] = "Server test string 1.";
static const WSK_CLIENT_LISTEN_DISPATCH client_listen_dispatch; static const WSK_CLIENT_LISTEN_DISPATCH client_listen_dispatch;
const WSK_PROVIDER_CONNECTION_DISPATCH *accept_dispatch; const WSK_PROVIDER_CONNECTION_DISPATCH *accept_dispatch;
WSK_SOCKET *tcp_socket, *udp_socket, *accept_socket; WSK_SOCKET *tcp_socket, *udp_socket, *accept_socket;
struct socket_context context; struct socket_context context;
WSK_BUF wsk_buf1, wsk_buf2;
void *buffer1, *buffer2;
struct sockaddr_in addr; struct sockaddr_in addr;
LARGE_INTEGER timeout; LARGE_INTEGER timeout;
MDL *mdl1, *mdl2;
NTSTATUS status; NTSTATUS status;
KEVENT event; KEVENT event;
IRP *irp; IRP *irp;
@ -183,6 +190,19 @@ static void test_wsk_listen_socket(void)
irp = IoAllocateIrp(1, FALSE); irp = IoAllocateIrp(1, FALSE);
KeInitializeEvent(&event, SynchronizationEvent, FALSE); KeInitializeEvent(&event, SynchronizationEvent, FALSE);
buffer1 = ExAllocatePool(NonPagedPool, TEST_BUFFER_LENGTH);
mdl1 = IoAllocateMdl(buffer1, TEST_BUFFER_LENGTH, FALSE, FALSE, NULL);
MmBuildMdlForNonPagedPool(mdl1);
buffer2 = ExAllocatePool(NonPagedPool, TEST_BUFFER_LENGTH);
mdl2 = IoAllocateMdl(buffer2, TEST_BUFFER_LENGTH, FALSE, FALSE, NULL);
MmBuildMdlForNonPagedPool(mdl2);
wsk_buf1.Mdl = mdl1;
wsk_buf1.Offset = 0;
wsk_buf1.Length = TEST_BUFFER_LENGTH;
wsk_buf2 = wsk_buf1;
wsk_buf2.Mdl = mdl2;
status = provider_npi.Dispatch->WskSocket(NULL, AF_INET, SOCK_STREAM, IPPROTO_TCP, status = provider_npi.Dispatch->WskSocket(NULL, AF_INET, SOCK_STREAM, IPPROTO_TCP,
WSK_FLAG_LISTEN_SOCKET, &context, &client_listen_dispatch, NULL, NULL, NULL, NULL); WSK_FLAG_LISTEN_SOCKET, &context, &client_listen_dispatch, NULL, NULL, NULL, NULL);
ok(status == STATUS_INVALID_PARAMETER, "Got unexpected status %#x.\n", status); ok(status == STATUS_INVALID_PARAMETER, "Got unexpected status %#x.\n", status);
@ -283,6 +303,32 @@ static void test_wsk_listen_socket(void)
accept_socket = (WSK_SOCKET *)wsk_irp->IoStatus.Information; accept_socket = (WSK_SOCKET *)wsk_irp->IoStatus.Information;
accept_dispatch = accept_socket->Dispatch; accept_dispatch = accept_socket->Dispatch;
IoReuseIrp(irp, STATUS_UNSUCCESSFUL);
IoSetCompletionRoutine(irp, irp_completion_routine, &event, TRUE, TRUE, TRUE);
status = accept_dispatch->WskReceive(accept_socket, &wsk_buf2, 0, irp);
ok(status == STATUS_PENDING, "Got unexpected status %#x.\n", status);
IoReuseIrp(wsk_irp, STATUS_UNSUCCESSFUL);
IoSetCompletionRoutine(wsk_irp, irp_completion_routine, &irp_complete_event, TRUE, TRUE, TRUE);
strcpy(buffer1, test_send_string);
/* Setting Length in WSK_BUF greater than MDL allocation size BSODs Windows.
* wsk_buf1.Length = TEST_BUFFER_LENGTH * 2; */
status = accept_dispatch->WskSend(accept_socket, &wsk_buf1, 0, wsk_irp);
ok(status == STATUS_PENDING, "Got unexpected status %#x.\n", status);
status = KeWaitForSingleObject(&irp_complete_event, Executive, KernelMode, FALSE, &timeout);
ok(status == STATUS_SUCCESS, "Got unexpected status %#x.\n", status);
ok(wsk_irp->IoStatus.Status == STATUS_SUCCESS, "Got unexpected status %#x.\n", wsk_irp->IoStatus.Status);
ok(wsk_irp->IoStatus.Information == TEST_BUFFER_LENGTH, "Got unexpected status %#x.\n",
wsk_irp->IoStatus.Status);
status = KeWaitForSingleObject(&event, Executive, KernelMode, FALSE, &timeout);
ok(status == STATUS_SUCCESS, "Got unexpected status %#x.\n", status);
ok(irp->IoStatus.Status == STATUS_SUCCESS, "Got unexpected status %#x.\n", irp->IoStatus.Status);
ok(irp->IoStatus.Information == sizeof(test_receive_string), "Got unexpected Information %#lx.\n",
irp->IoStatus.Information);
ok(!strcmp(buffer2, test_receive_string), "Received unexpected data.\n");
IoReuseIrp(wsk_irp, STATUS_UNSUCCESSFUL); IoReuseIrp(wsk_irp, STATUS_UNSUCCESSFUL);
IoSetCompletionRoutine(wsk_irp, irp_completion_routine, &irp_complete_event, TRUE, TRUE, TRUE); IoSetCompletionRoutine(wsk_irp, irp_completion_routine, &irp_complete_event, TRUE, TRUE, TRUE);
status = accept_dispatch->Basic.WskCloseSocket(accept_socket, wsk_irp); status = accept_dispatch->Basic.WskCloseSocket(accept_socket, wsk_irp);
@ -317,6 +363,11 @@ static void test_wsk_listen_socket(void)
ok(irp->IoStatus.Status == STATUS_CANCELLED, "Got unexpected status %#x.\n", irp->IoStatus.Status); ok(irp->IoStatus.Status == STATUS_CANCELLED, "Got unexpected status %#x.\n", irp->IoStatus.Status);
ok(!irp->IoStatus.Information, "Got unexpected Information %#lx.\n", irp->IoStatus.Information); ok(!irp->IoStatus.Information, "Got unexpected Information %#lx.\n", irp->IoStatus.Information);
IoFreeIrp(irp); IoFreeIrp(irp);
IoFreeMdl(mdl1);
IoFreeMdl(mdl2);
ExFreePool(buffer1);
ExFreePool(buffer2);
} }
static NTSTATUS main_test(DEVICE_OBJECT *device, IRP *irp, IO_STACK_LOCATION *stack) static NTSTATUS main_test(DEVICE_OBJECT *device, IRP *irp, IO_STACK_LOCATION *stack)

9
dlls/ntoskrnl.exe/tests/ntoskrnl.c
View File

@ -516,8 +516,10 @@ static void test_driver3(void)
static DWORD WINAPI wsk_test_thread(void *parameter) static DWORD WINAPI wsk_test_thread(void *parameter)
{ {
static const char test_send_string[] = "Client test string 1.";
static const WORD version = MAKEWORD(2, 2); static const WORD version = MAKEWORD(2, 2);
struct sockaddr_in addr; struct sockaddr_in addr;
char buffer[256];
int ret, err; int ret, err;
WSADATA data; WSADATA data;
SOCKET s; SOCKET s;
@ -541,6 +543,13 @@ static DWORD WINAPI wsk_test_thread(void *parameter)
} }
ok(!ret, "Error connecting, WSAGetLastError() %u.\n", WSAGetLastError()); ok(!ret, "Error connecting, WSAGetLastError() %u.\n", WSAGetLastError());
ret = send(s, test_send_string, sizeof(test_send_string), 0);
ok(ret == sizeof(test_send_string), "Got unexpected ret %d.\n", ret);
ret = recv(s, buffer, sizeof(buffer), 0);
ok(ret == sizeof(buffer), "Got unexpected ret %d.\n", ret);
ok(!strcmp(buffer, "Server test string 1."), "Received unexpected data.\n");
closesocket(s); closesocket(s);
return TRUE; return TRUE;
} }