Mercurial > flash_v2
diff packages/compat/posix/current/tests/pthread3.c @ 115:6ed91473a1cd ecos-sw-2000-08-21
Merge from eCos master repository on 2000-08-21-22:40:54-BST
| author | jlarmour |
|---|---|
| date | Fri, 25 Aug 2000 17:32:38 +0000 |
| parents | |
| children | 6bd9d475ed4b |
line wrap: on
line diff
new file mode 100644 --- /dev/null +++ b/packages/compat/posix/current/tests/pthread3.c @@ -0,0 +1,213 @@ +//========================================================================== +// +// pthread3.cxx +// +// POSIX pthread test 2 - cancellation +// +//========================================================================== +//####COPYRIGHTBEGIN#### +// +// ------------------------------------------- +// The contents of this file are subject to the Red Hat eCos Public License +// Version 1.1 (the "License"); you may not use this file except in +// compliance with the License. You may obtain a copy of the License at +// http://www.redhat.com/ +// +// Software distributed under the License is distributed on an "AS IS" +// basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the +// License for the specific language governing rights and limitations under +// the License. +// +// The Original Code is eCos - Embedded Configurable Operating System, +// released September 30, 1998. +// +// The Initial Developer of the Original Code is Red Hat. +// Portions created by Red Hat are +// Copyright (C) 1998, 1999, 2000 Red Hat, Inc. +// All Rights Reserved. +// ------------------------------------------- +// +//####COPYRIGHTEND#### +//========================================================================== +//#####DESCRIPTIONBEGIN#### +// +// Author(s): nickg +// Contributors: nickg +// Date: 2000-04-10 +// Description: Tests POSIX cancellation. +// +//####DESCRIPTIONEND#### +//========================================================================== + +#include <sys/types.h> +#include <pthread.h> + +#include <cyg/infra/testcase.h> + +//-------------------------------------------------------------------------- +// Thread info + +#define NTHREADS 2 + +char thread_stack[NTHREADS][PTHREAD_STACK_MIN*2]; + +pthread_t thread[NTHREADS]; + +void *pthread_entry1( void *arg); +void *pthread_entry2( void *arg); + +void *(*pthread_entry[NTHREADS])(void *) = +{ + pthread_entry1, + pthread_entry2 +}; + +//-------------------------------------------------------------------------- + +volatile cyg_bool cancel_handler1_called = false; +volatile cyg_bool cancel_handler2_called = false; +volatile cyg_bool cancel_handler3_called = false; + +//-------------------------------------------------------------------------- + +void cancel_handler1( void * arg ) +{ + CYG_TEST_INFO( "cancel_handler1 called" ); + + CYG_TEST_CHECK( (long)arg == 0x12340000, "cancel_handler1: bad arg value"); + + cancel_handler1_called = true; +} + +//-------------------------------------------------------------------------- + +void cancel_handler2( void * arg ) +{ + CYG_TEST_INFO( "cancel_handler2 called" ); + + CYG_TEST_CHECK( (long)arg == 0xFFFF1111, "cancel_handler2: bad arg value"); + + cancel_handler2_called = true; +} + +//-------------------------------------------------------------------------- + +void cancel_handler3( void * arg ) +{ + CYG_TEST_INFO( "cancel_handler3 called" ); + + CYG_TEST_CHECK( (long)arg == 0x12340001, "cancel_handler3: bad arg value"); + + cancel_handler3_called = true; +} + +//-------------------------------------------------------------------------- + +void function1(void) +{ + + pthread_cleanup_push( cancel_handler2, (void *)0xFFFF1111 ); + + for(;;) + { + sched_yield(); + pthread_testcancel(); + } + + pthread_cleanup_pop( 0 ); +} + +//-------------------------------------------------------------------------- + +void *pthread_entry1( void *arg) +{ + int retval = 1; + + CYG_TEST_INFO( "pthread_entry1 entered"); + + pthread_setcanceltype( PTHREAD_CANCEL_DEFERRED, NULL ); + + pthread_cleanup_push( cancel_handler1, arg ); + + function1(); + + pthread_cleanup_pop( 0 ); + + pthread_exit( (void *)retval ); +} + +//-------------------------------------------------------------------------- + +void *pthread_entry2( void *arg) +{ + int retval = 1; + + CYG_TEST_INFO( "pthread_entry2 entered"); + + pthread_setcanceltype( PTHREAD_CANCEL_ASYNCHRONOUS, NULL ); + + pthread_cleanup_push( cancel_handler3, arg ); + + for(;;) sched_yield(); + + pthread_cleanup_pop( 0 ); + + pthread_exit( (void *)retval ); +} + +//-------------------------------------------------------------------------- + +int main(int argc, char **argv) +{ + int i; + int ret; + void *retval[NTHREADS]; + + CYG_TEST_INIT(); + + // Create test threads + for( i = 0; i < NTHREADS; i++ ) + { + pthread_attr_t attr; + pthread_attr_init( &attr ); + + pthread_attr_setstackaddr( &attr, (void *)&thread_stack[i][sizeof(thread_stack)] ); + pthread_attr_setstacksize( &attr, sizeof(thread_stack[i]) ); + + ret = pthread_create( &thread[i], + &attr, + pthread_entry[i], + (void *)(0x12340000+i)); + CYG_TEST_CHECK( ret == 0, "pthread_create() returned error"); + } + + // Let the threads get going + sched_yield(); + sched_yield(); + sched_yield(); + + // Now cancel them + for( i = 0; i < NTHREADS; i++ ) + pthread_cancel( thread[i] ); + + // Now join with threads + for( i = 0; i < NTHREADS; i++ ) + pthread_join( thread[i], &retval[i] ); + + + // check retvals + for( i = 0; i < NTHREADS; i++ ) + if( retval[0] != PTHREAD_CANCELED ) + CYG_TEST_FAIL_FINISH( "pthread3" ); + + if( !cancel_handler1_called ) CYG_TEST_FAIL_FINISH( "pthread3" ); + if( !cancel_handler2_called ) CYG_TEST_FAIL_FINISH( "pthread3" ); + if( !cancel_handler3_called ) CYG_TEST_FAIL_FINISH( "pthread3" ); + + + CYG_TEST_PASS_FINISH( "pthread3" ); + +} + +//-------------------------------------------------------------------------- +// end of pthread3.c
