ws2_32/tests: Test for AcceptEx IOCP behavior for a duplicated handle.
This commit is contained in:
parent
23a785af7e
commit
a766ee4b1d
|
@ -5330,7 +5330,8 @@ static void test_completion_port(void)
|
|||
{
|
||||
HANDLE previous_port, io_port;
|
||||
WSAOVERLAPPED ov, *olp;
|
||||
SOCKET src, dest, connector = INVALID_SOCKET;
|
||||
SOCKET src, dest, dup, connector = INVALID_SOCKET;
|
||||
WSAPROTOCOL_INFOA info;
|
||||
char buf[1024];
|
||||
WSABUF bufs;
|
||||
DWORD num_bytes, flags;
|
||||
|
@ -5553,6 +5554,169 @@ static void test_completion_port(void)
|
|||
ok(num_bytes == 0xdeadbeef, "Number of bytes transferred is %u\n", num_bytes);
|
||||
ok(!olp, "Overlapped structure is at %p\n", olp);
|
||||
|
||||
/* Test IOCP with duplicated handle */
|
||||
|
||||
if ((src = setup_iocp_src(&bindAddress)) == INVALID_SOCKET)
|
||||
goto end;
|
||||
|
||||
SetLastError(0xdeadbeef);
|
||||
|
||||
io_port = CreateIoCompletionPort((HANDLE)src, previous_port, 125, 0);
|
||||
ok(io_port != NULL, "failed to create completion port %u\n", GetLastError());
|
||||
|
||||
WSADuplicateSocket( src, GetCurrentProcessId(), &info );
|
||||
dup = WSASocket(AF_INET, SOCK_STREAM, 0, &info, 0, WSA_FLAG_OVERLAPPED);
|
||||
ok(dup != INVALID_SOCKET, "failed to duplicate socket!\n");
|
||||
|
||||
bret = pAcceptEx(dup, dest, buf, sizeof(buf) - 2*(sizeof(struct sockaddr_in) + 16),
|
||||
sizeof(struct sockaddr_in) + 16, sizeof(struct sockaddr_in) + 16,
|
||||
&num_bytes, &ov);
|
||||
ok(bret == FALSE, "AcceptEx returned %d\n", bret);
|
||||
ok(GetLastError() == ERROR_IO_PENDING, "Last error was %d\n", GetLastError());
|
||||
|
||||
SetLastError(0xdeadbeef);
|
||||
key = 0xdeadbeef;
|
||||
num_bytes = 0xdeadbeef;
|
||||
olp = (WSAOVERLAPPED *)0xdeadbeef;
|
||||
bret = GetQueuedCompletionStatus( io_port, &num_bytes, &key, &olp, 200 );
|
||||
ok(bret == FALSE, "failed to get completion status %u\n", bret);
|
||||
ok(GetLastError() == WAIT_TIMEOUT, "Last error was %d\n", GetLastError());
|
||||
ok(key == 0xdeadbeef, "Key is %lu\n", key);
|
||||
ok(num_bytes == 0xdeadbeef, "Number of bytes transferred is %u\n", num_bytes);
|
||||
ok(!olp, "Overlapped structure is at %p\n", olp);
|
||||
|
||||
|
||||
closesocket(src);
|
||||
src = INVALID_SOCKET;
|
||||
closesocket(dup);
|
||||
dup = INVALID_SOCKET;
|
||||
|
||||
/* Test IOCP with duplicated handle (closing duplicated handle) */
|
||||
|
||||
if ((src = setup_iocp_src(&bindAddress)) == INVALID_SOCKET)
|
||||
goto end;
|
||||
|
||||
SetLastError(0xdeadbeef);
|
||||
|
||||
io_port = CreateIoCompletionPort((HANDLE)src, previous_port, 125, 0);
|
||||
ok(io_port != NULL, "failed to create completion port %u\n", GetLastError());
|
||||
|
||||
WSADuplicateSocket( src, GetCurrentProcessId(), &info );
|
||||
dup = WSASocket(AF_INET, SOCK_STREAM, 0, &info, 0, WSA_FLAG_OVERLAPPED);
|
||||
ok(dup != INVALID_SOCKET, "failed to duplicate socket!\n");
|
||||
|
||||
bret = pAcceptEx(dup, dest, buf, sizeof(buf) - 2*(sizeof(struct sockaddr_in) + 16),
|
||||
sizeof(struct sockaddr_in) + 16, sizeof(struct sockaddr_in) + 16,
|
||||
&num_bytes, &ov);
|
||||
ok(bret == FALSE, "AcceptEx returned %d\n", bret);
|
||||
ok(GetLastError() == ERROR_IO_PENDING, "Last error was %d\n", GetLastError());
|
||||
|
||||
closesocket(dup);
|
||||
dup = INVALID_SOCKET;
|
||||
|
||||
SetLastError(0xdeadbeef);
|
||||
key = 0xdeadbeef;
|
||||
num_bytes = 0xdeadbeef;
|
||||
olp = (WSAOVERLAPPED *)0xdeadbeef;
|
||||
|
||||
bret = GetQueuedCompletionStatus(io_port, &num_bytes, &key, &olp, 100);
|
||||
ok(bret == FALSE, "failed to get completion status %u\n", bret);
|
||||
todo_wine ok(GetLastError() == ERROR_OPERATION_ABORTED, "Last error was %d\n", GetLastError());
|
||||
todo_wine ok(key == 125, "Key is %lu\n", key);
|
||||
todo_wine ok(num_bytes == 0, "Number of bytes transferred is %u\n", num_bytes);
|
||||
todo_wine ok(olp == &ov, "Overlapped structure is at %p\n", olp);
|
||||
todo_wine ok(olp && (broken(olp->Internal == (ULONG)STATUS_PENDING) || (olp->Internal == (ULONG)STATUS_CANCELLED)),
|
||||
"Internal status is %lx\n", olp ? olp->Internal : 0);
|
||||
|
||||
SetLastError(0xdeadbeef);
|
||||
key = 0xdeadbeef;
|
||||
num_bytes = 0xdeadbeef;
|
||||
olp = (WSAOVERLAPPED *)0xdeadbeef;
|
||||
bret = GetQueuedCompletionStatus( io_port, &num_bytes, &key, &olp, 200 );
|
||||
ok(bret == FALSE, "failed to get completion status %u\n", bret);
|
||||
ok(GetLastError() == WAIT_TIMEOUT, "Last error was %d\n", GetLastError());
|
||||
ok(key == 0xdeadbeef, "Key is %lu\n", key);
|
||||
ok(num_bytes == 0xdeadbeef, "Number of bytes transferred is %u\n", num_bytes);
|
||||
ok(!olp, "Overlapped structure is at %p\n", olp);
|
||||
|
||||
closesocket(src);
|
||||
src = INVALID_SOCKET;
|
||||
|
||||
bret = GetQueuedCompletionStatus(io_port, &num_bytes, &key, &olp, 100);
|
||||
ok(bret == FALSE, "failed to get completion status %u\n", bret);
|
||||
todo_wine ok(GetLastError() == ERROR_OPERATION_ABORTED, "Last error was %d\n", GetLastError());
|
||||
todo_wine ok(key == 125, "Key is %lu\n", key);
|
||||
todo_wine ok(num_bytes == 0, "Number of bytes transferred is %u\n", num_bytes);
|
||||
todo_wine ok(olp == &ov, "Overlapped structure is at %p\n", olp);
|
||||
todo_wine ok(olp && (olp->Internal == (ULONG)STATUS_CANCELLED), "Internal status is %lx\n", olp ? olp->Internal : 0);
|
||||
|
||||
SetLastError(0xdeadbeef);
|
||||
key = 0xdeadbeef;
|
||||
num_bytes = 0xdeadbeef;
|
||||
olp = (WSAOVERLAPPED *)0xdeadbeef;
|
||||
bret = GetQueuedCompletionStatus( io_port, &num_bytes, &key, &olp, 200 );
|
||||
ok(bret == FALSE, "failed to get completion status %u\n", bret);
|
||||
ok(GetLastError() == WAIT_TIMEOUT, "Last error was %d\n", GetLastError());
|
||||
ok(key == 0xdeadbeef, "Key is %lu\n", key);
|
||||
ok(num_bytes == 0xdeadbeef, "Number of bytes transferred is %u\n", num_bytes);
|
||||
ok(!olp, "Overlapped structure is at %p\n", olp);
|
||||
|
||||
/* Test IOCP with duplicated handle (closing original handle) */
|
||||
|
||||
if ((src = setup_iocp_src(&bindAddress)) == INVALID_SOCKET)
|
||||
goto end;
|
||||
|
||||
SetLastError(0xdeadbeef);
|
||||
|
||||
io_port = CreateIoCompletionPort((HANDLE)src, previous_port, 125, 0);
|
||||
ok(io_port != NULL, "failed to create completion port %u\n", GetLastError());
|
||||
|
||||
WSADuplicateSocket( src, GetCurrentProcessId(), &info );
|
||||
dup = WSASocket(AF_INET, SOCK_STREAM, 0, &info, 0, WSA_FLAG_OVERLAPPED);
|
||||
ok(dup != INVALID_SOCKET, "failed to duplicate socket!\n");
|
||||
|
||||
bret = pAcceptEx(dup, dest, buf, sizeof(buf) - 2*(sizeof(struct sockaddr_in) + 16),
|
||||
sizeof(struct sockaddr_in) + 16, sizeof(struct sockaddr_in) + 16,
|
||||
&num_bytes, &ov);
|
||||
ok(bret == FALSE, "AcceptEx returned %d\n", bret);
|
||||
ok(GetLastError() == ERROR_IO_PENDING, "Last error was %d\n", GetLastError());
|
||||
|
||||
closesocket(src);
|
||||
src = INVALID_SOCKET;
|
||||
|
||||
SetLastError(0xdeadbeef);
|
||||
key = 0xdeadbeef;
|
||||
num_bytes = 0xdeadbeef;
|
||||
olp = (WSAOVERLAPPED *)0xdeadbeef;
|
||||
bret = GetQueuedCompletionStatus( io_port, &num_bytes, &key, &olp, 200 );
|
||||
ok(bret == FALSE, "failed to get completion status %u\n", bret);
|
||||
ok(GetLastError() == WAIT_TIMEOUT, "Last error was %d\n", GetLastError());
|
||||
ok(key == 0xdeadbeef, "Key is %lu\n", key);
|
||||
ok(num_bytes == 0xdeadbeef, "Number of bytes transferred is %u\n", num_bytes);
|
||||
ok(!olp, "Overlapped structure is at %p\n", olp);
|
||||
|
||||
closesocket(dup);
|
||||
dup = INVALID_SOCKET;
|
||||
|
||||
bret = GetQueuedCompletionStatus(io_port, &num_bytes, &key, &olp, 100);
|
||||
ok(bret == FALSE, "failed to get completion status %u\n", bret);
|
||||
todo_wine ok(GetLastError() == ERROR_OPERATION_ABORTED, "Last error was %d\n", GetLastError());
|
||||
todo_wine ok(key == 125, "Key is %lu\n", key);
|
||||
todo_wine ok(num_bytes == 0, "Number of bytes transferred is %u\n", num_bytes);
|
||||
todo_wine ok(olp == &ov, "Overlapped structure is at %p\n", olp);
|
||||
todo_wine ok(olp && (olp->Internal == (ULONG)STATUS_CANCELLED), "Internal status is %lx\n", olp ? olp->Internal : 0);
|
||||
|
||||
SetLastError(0xdeadbeef);
|
||||
key = 0xdeadbeef;
|
||||
num_bytes = 0xdeadbeef;
|
||||
olp = (WSAOVERLAPPED *)0xdeadbeef;
|
||||
bret = GetQueuedCompletionStatus( io_port, &num_bytes, &key, &olp, 200 );
|
||||
ok(bret == FALSE, "failed to get completion status %u\n", bret);
|
||||
ok(GetLastError() == WAIT_TIMEOUT, "Last error was %d\n", GetLastError());
|
||||
ok(key == 0xdeadbeef, "Key is %lu\n", key);
|
||||
ok(num_bytes == 0xdeadbeef, "Number of bytes transferred is %u\n", num_bytes);
|
||||
ok(!olp, "Overlapped structure is at %p\n", olp);
|
||||
|
||||
/* */
|
||||
|
||||
if ((src = setup_iocp_src(&bindAddress)) == INVALID_SOCKET)
|
||||
|
|
Loading…
Reference in New Issue