summaryrefslogtreecommitdiff
path: root/src/pal/tests/palsuite/threading/QueueUserAPC/test6/test6.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/pal/tests/palsuite/threading/QueueUserAPC/test6/test6.cpp')
-rw-r--r--src/pal/tests/palsuite/threading/QueueUserAPC/test6/test6.cpp129
1 files changed, 129 insertions, 0 deletions
diff --git a/src/pal/tests/palsuite/threading/QueueUserAPC/test6/test6.cpp b/src/pal/tests/palsuite/threading/QueueUserAPC/test6/test6.cpp
new file mode 100644
index 0000000000..e2e2464726
--- /dev/null
+++ b/src/pal/tests/palsuite/threading/QueueUserAPC/test6/test6.cpp
@@ -0,0 +1,129 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+// See the LICENSE file in the project root for more information.
+
+/*=============================================================================
+**
+** Source: test6.c
+**
+** Dependencies: PAL_Initialize
+** PAL_Terminate
+** CreateEvent
+** SetEvent
+** CreateThread
+** ResumeThread
+** WaitForMultipleObjectsEx
+** CloseHandle
+**
+** Purpose:
+**
+** Test to ensure proper operation of the QueueUserAPC()
+** API by trying to queue APC functions on a thread that
+** has already terminated.
+**
+**
+**===========================================================================*/
+#include <palsuite.h>
+
+
+static BOOL bAPCExecuted = FALSE;
+
+VOID PALAPI APCFunc( ULONG_PTR dwParam )
+{
+ bAPCExecuted = TRUE;
+}
+
+/**
+ * ThreadFunc
+ *
+ * Dummy thread function for APC queuing.
+ */
+DWORD PALAPI ThreadFunc( LPVOID param )
+{
+ int i;
+
+ /* simulate some activity */
+ for( i=0; i<250000; i++ )
+ ;
+
+ return 0;
+}
+
+
+int __cdecl main( int argc, char **argv )
+
+{
+ /* local variables */
+ HANDLE hThread = NULL;
+ DWORD IDThread;
+ DWORD ret;
+
+ /* PAL initialization */
+ if( (PAL_Initialize(argc, argv)) != 0 )
+ {
+ return( FAIL );
+ }
+
+ /* run another dummy thread to cause notification of the library */
+ hThread = CreateThread( NULL, /* no security attributes */
+ 0, /* use default stack size */
+ (LPTHREAD_START_ROUTINE) ThreadFunc, /* thread function */
+ (LPVOID) NULL, /* pass thread index as */
+ /* function argument */
+ CREATE_SUSPENDED, /* create suspended */
+ &IDThread ); /* returns thread id */
+
+ /* Check the return value for success. */
+ if( hThread == NULL )
+ {
+ /* error creating thread */
+ Fail( "ERROR:%lu:CreateThread call failed\n", GetLastError() );
+ }
+
+ /* Resume the suspended thread */
+ ResumeThread( hThread );
+
+ /* wait on the other thread to complete */
+ ret = WaitForSingleObject( hThread, INFINITE );
+ if( ret != WAIT_OBJECT_0 )
+ {
+ Trace( "ERROR:WaitForSingleObject() returned %lu, "
+ "expected WAIT_OBJECT_0\n",
+ ret );
+ if( ! CloseHandle( hThread ) )
+ {
+ Trace( "ERROR:%lu:CloseHandle() call failed\n", GetLastError() );
+ }
+ Fail( "test failed\n" );
+ }
+
+ /* queue our APC on the finished thread */
+ ret = QueueUserAPC( APCFunc, hThread, 0 );
+ if( ret != 0 )
+ {
+ Trace( "ERROR:QueueUserAPC call succeeded on a terminated thread\n" );
+ if( ! CloseHandle( hThread ) )
+ {
+ Trace( "ERROR:%lu:CloseHandle() call failed\n", GetLastError() );
+ }
+ Fail( "test failed\n" );
+ }
+
+ if( ! CloseHandle( hThread ) )
+ {
+ Fail( "ERROR:%lu:CloseHandle() call failed\n", GetLastError() );
+ }
+
+ /* dummy check that the APC function wasn't actually executed */
+ if( bAPCExecuted != FALSE )
+ {
+ Fail( "ERROR:APC function was executed\n" );
+ }
+
+
+ /* PAL termination */
+ PAL_Terminate();
+
+ /* return success */
+ return PASS;
+}