system/wine
system/wine
1
0
Fork 0
mirror of git://source.winehq.org/git/wine.git synced 2024-09-06 08:53:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

kernel32/tests: Add tests for CancelSynchronousIo.

Browse source 
Signed-off-by: Daniel Lehman <dlehman25@gmail.com>
This commit is contained in:
Daniel Lehman 2022-04-18 22:40:41 -07:00 committed by Alexandre Julliard
parent 45bfd4e1d1
commit 3a4674f256
1 changed files with 105 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

105
dlls/kernel32/tests/pipe.c
View file

@ -37,6 +37,7 @@ static HANDLE alarm_event;
static BOOL (WINAPI *pDuplicateTokenEx)(HANDLE,DWORD,LPSECURITY_ATTRIBUTES,
SECURITY_IMPERSONATION_LEVEL,TOKEN_TYPE,PHANDLE);
static BOOL (WINAPI *pCancelIoEx)(HANDLE handle, LPOVERLAPPED lpOverlapped);
static BOOL (WINAPI *pCancelSynchronousIo)(HANDLE handle);
static BOOL (WINAPI *pGetNamedPipeClientProcessId)(HANDLE,ULONG*);
static BOOL (WINAPI *pGetNamedPipeServerProcessId)(HANDLE,ULONG*);
static BOOL (WINAPI *pGetNamedPipeClientSessionId)(HANDLE,ULONG*);
@ -4202,6 +4203,108 @@ static void test_exit_process_async(void)
CloseHandle(server);
}
static DWORD CALLBACK synchronousIoThreadMain(void *arg)
{
HANDLE pipe;
BOOL ret;
pipe = arg;
SetLastError(0xdeadbeef);
ret = ConnectNamedPipe(pipe, NULL);
ok(!ret, "expected failure\n");
ok(GetLastError() == ERROR_OPERATION_ABORTED, "got error %lu\n", GetLastError());
return 0;
}
static DWORD CALLBACK synchronousIoThreadMain2(void *arg)
{
OVERLAPPED ov;
HANDLE pipe;
BOOL ret;
pipe = arg;
memset(&ov, 0, sizeof(ov));
ov.hEvent = CreateEventW(NULL, TRUE, FALSE, NULL);
SetLastError(0xdeadbeef);
ret = ConnectNamedPipe(pipe, &ov);
ok(!ret, "expected failure\n");
ok(GetLastError() == ERROR_IO_PENDING, "got error %lu\n", GetLastError());
ret = WaitForSingleObject(ov.hEvent, 1000);
ok(ret == WAIT_OBJECT_0, "WaitForSingleObject returned %u\n", ret);
CloseHandle(ov.hEvent);
return 0;
}
static void test_CancelSynchronousIo(void)
{
BOOL res;
DWORD wait;
HANDLE file;
HANDLE pipe;
HANDLE thread;
/* bogus values */
SetLastError(0xdeadbeef);
res = pCancelSynchronousIo((HANDLE)0xdeadbeef);
ok(!res, "CancelSynchronousIo succeeded unexpectedly\n");
todo_wine
ok(GetLastError() == ERROR_INVALID_HANDLE,
"In CancelSynchronousIo failure, expected ERROR_INVALID_HANDLE, got %ld\n", GetLastError());
SetLastError(0xdeadbeef);
res = pCancelSynchronousIo(GetCurrentThread());
ok(!res, "CancelSynchronousIo succeeded unexpectedly\n");
todo_wine
ok(GetLastError() == ERROR_NOT_FOUND,
"In CancelSynchronousIo failure, expected ERROR_NOT_FOUND, got %ld\n", GetLastError());
/* synchronous i/o */
pipe = CreateNamedPipeA(PIPENAME, PIPE_ACCESS_DUPLEX,
PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
1, 1024, 1024, NMPWAIT_USE_DEFAULT_WAIT, NULL);
ok(pipe != INVALID_HANDLE_VALUE, "CreateNamedPipe failed with %lu\n", GetLastError());
thread = CreateThread(NULL, 0, synchronousIoThreadMain, pipe, 0, NULL);
/* wait for I/O to start, which transitions the pipe handle from signaled to nonsignaled state. */
while ((wait = WaitForSingleObject(pipe, 0)) == WAIT_OBJECT_0) Sleep(1);
ok(wait == WAIT_TIMEOUT, "WaitForSingleObject returned %lu (error %lu)\n", wait, GetLastError());
SetLastError(0xdeadbeef);
res = pCancelSynchronousIo(thread);
todo_wine
{
ok(res, "CancelSynchronousIo failed with error %ld\n", GetLastError());
ok(GetLastError() == 0xdeadbeef,
"In CancelSynchronousIo failure, expected 0xdeadbeef got %ld\n", GetLastError());
}
if (GetLastError() == ERROR_CALL_NOT_IMPLEMENTED)
CancelIoEx(pipe, NULL);
wait = WaitForSingleObject(thread, 1000);
ok(wait == WAIT_OBJECT_0, "WaitForSingleObject returned %lx\n", wait);
CloseHandle(thread);
CloseHandle(pipe);
/* asynchronous i/o */
pipe = CreateNamedPipeA(PIPENAME, PIPE_ACCESS_DUPLEX | FILE_FLAG_OVERLAPPED,
PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
1, 1024, 1024, NMPWAIT_USE_DEFAULT_WAIT, NULL);
ok(pipe != INVALID_HANDLE_VALUE, "CreateNamedPipe failed with %lu\n", GetLastError());
thread = CreateThread(NULL, 0, synchronousIoThreadMain2, pipe, 0, NULL);
/* wait for I/O to start, which transitions the pipe handle from signaled to nonsignaled state. */
while ((wait = WaitForSingleObject(pipe, 0)) == WAIT_OBJECT_0) Sleep(1);
ok(wait == WAIT_TIMEOUT, "WaitForSingleObject returned %lu (error %lu)\n", wait, GetLastError());
SetLastError(0xdeadbeef);
res = pCancelSynchronousIo(thread);
ok(!res, "CancelSynchronousIo succeeded unexpectedly\n");
todo_wine
ok(GetLastError() == ERROR_NOT_FOUND,
"In CancelSynchronousIo failure, expected ERROR_NOT_FOUND, got %ld\n", GetLastError());
file = CreateFileA(PIPENAME, GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, 0, 0);
ok(file != INVALID_HANDLE_VALUE, "CreateFile failed (%ld)\n", GetLastError());
WaitForSingleObject(thread, INFINITE);
CloseHandle(thread);
CloseHandle(file);
CloseHandle(pipe);
}
START_TEST(pipe)
{
char **argv;
@ -4212,6 +4315,7 @@ START_TEST(pipe)
pDuplicateTokenEx = (void *) GetProcAddress(hmod, "DuplicateTokenEx");
hmod = GetModuleHandleA("kernel32.dll");
pCancelIoEx = (void *) GetProcAddress(hmod, "CancelIoEx");
pCancelSynchronousIo = (void *) GetProcAddress(hmod, "CancelSynchronousIo");
pGetNamedPipeClientProcessId = (void *) GetProcAddress(hmod, "GetNamedPipeClientProcessId");
pGetNamedPipeServerProcessId = (void *) GetProcAddress(hmod, "GetNamedPipeServerProcessId");
pGetNamedPipeClientSessionId = (void *) GetProcAddress(hmod, "GetNamedPipeClientSessionId");
@ -4282,4 +4386,5 @@ START_TEST(pipe)
test_nowait(PIPE_TYPE_MESSAGE);
test_GetOverlappedResultEx();
test_exit_process_async();
test_CancelSynchronousIo();
}