obs-studio/deps/w32-pthreads/tests/cancel9.c

203 lines
5.1 KiB
C

/*
* File: cancel9.c
*
*
* --------------------------------------------------------------------------
*
* Pthreads-win32 - POSIX Threads Library for Win32
* Copyright(C) 1998 John E. Bossom
* Copyright(C) 1999,2005 Pthreads-win32 contributors
*
* Contact Email: rpj@callisto.canberra.edu.au
*
* The current list of contributors is contained
* in the file CONTRIBUTORS included with the source
* code distribution. The list can also be seen at the
* following World Wide Web location:
* http://sources.redhat.com/pthreads-win32/contributors.html
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library in the file COPYING.LIB;
* if not, write to the Free Software Foundation, Inc.,
* 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA
*
* --------------------------------------------------------------------------
*
* Test Synopsis: Test true asynchronous cancelation with Alert driver.
*
* Test Method (Validation or Falsification):
* -
*
* Requirements Tested:
* - Cancel threads, including those blocked on system recources
* such as network I/O.
*
* Features Tested:
* -
*
* Cases Tested:
* -
*
* Description:
* -
*
* Environment:
* -
*
* Input:
* - None.
*
* Output:
* - File name, Line number, and failed expression on failure.
* - No output on success.
*
* Assumptions:
* - have working pthread_create, pthread_self, pthread_mutex_lock/unlock
* pthread_testcancel, pthread_cancel, pthread_join
*
* Pass Criteria:
* - Process returns zero exit status.
*
* Fail Criteria:
* - Process returns non-zero exit status.
*/
#include "test.h"
#include <windows.h>
void *
test_udp (void *arg)
{
struct sockaddr_in serverAddress;
struct sockaddr_in clientAddress;
SOCKET UDPSocket;
int addr_len;
int nbyte, bytes;
char buffer[4096];
WORD wsaVersion = MAKEWORD (2, 2);
WSADATA wsaData;
pthread_setcancelstate (PTHREAD_CANCEL_ENABLE, NULL);
pthread_setcanceltype (PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
if (WSAStartup (wsaVersion, &wsaData) != 0)
{
return NULL;
}
UDPSocket = socket (AF_INET, SOCK_DGRAM, 0);
if ((int)UDPSocket == -1)
{
printf ("Server: socket ERROR \n");
exit (-1);
}
serverAddress.sin_family = AF_INET;
serverAddress.sin_addr.s_addr = INADDR_ANY;
serverAddress.sin_port = htons (9003);
if (bind
(UDPSocket, (struct sockaddr *) &serverAddress,
sizeof (struct sockaddr_in)))
{
printf ("Server: ERROR can't bind UDPSocket");
exit (-1);
}
addr_len = sizeof (struct sockaddr);
nbyte = 512;
bytes =
recvfrom (UDPSocket, (char *) buffer, nbyte, 0,
(struct sockaddr *) &clientAddress, &addr_len);
closesocket (UDPSocket);
WSACleanup ();
return NULL;
}
void *
test_sleep (void *arg)
{
pthread_setcancelstate (PTHREAD_CANCEL_ENABLE, NULL);
pthread_setcanceltype (PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
Sleep (1000);
return NULL;
}
void *
test_wait (void *arg)
{
HANDLE hEvent;
DWORD dwEvent;
pthread_setcancelstate (PTHREAD_CANCEL_ENABLE, NULL);
pthread_setcanceltype (PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
hEvent = CreateEvent (NULL, FALSE, FALSE, NULL);
dwEvent = WaitForSingleObject (hEvent, 1000); /* WAIT_IO_COMPLETION */
return NULL;
}
int
main ()
{
pthread_t t;
void *result;
if (pthread_win32_test_features_np (PTW32_ALERTABLE_ASYNC_CANCEL))
{
printf ("Cancel sleeping thread.\n");
assert (pthread_create (&t, NULL, test_sleep, NULL) == 0);
/* Sleep for a while; then cancel */
Sleep (100);
assert (pthread_cancel (t) == 0);
assert (pthread_join (t, &result) == 0);
assert (result == PTHREAD_CANCELED && "test_sleep" != NULL);
printf ("Cancel waiting thread.\n");
assert (pthread_create (&t, NULL, test_wait, NULL) == 0);
/* Sleep for a while; then cancel. */
Sleep (100);
assert (pthread_cancel (t) == 0);
assert (pthread_join (t, &result) == 0);
assert (result == PTHREAD_CANCELED && "test_wait");
printf ("Cancel blocked thread (blocked on network I/O).\n");
assert (pthread_create (&t, NULL, test_udp, NULL) == 0);
/* Sleep for a while; then cancel. */
Sleep (100);
assert (pthread_cancel (t) == 0);
assert (pthread_join (t, &result) == 0);
assert (result == PTHREAD_CANCELED && "test_udp" != NULL);
}
else
{
printf ("Alertable async cancel not available.\n");
}
/*
* Success.
*/
return 0;
}