Subversion Repositories openrisc_me

//==========================================================================

//

//        sigsetjmp.c

//

//        POSIX sigsetjmp test

//

//==========================================================================

//####ECOSGPLCOPYRIGHTBEGIN####

// -------------------------------------------

// This file is part of eCos, the Embedded Configurable Operating System.

// Copyright (C) 1998, 1999, 2000, 2001, 2002 Red Hat, Inc.

//

// eCos is free software; you can redistribute it and/or modify it under

// the terms of the GNU General Public License as published by the Free

// Software Foundation; either version 2 or (at your option) any later version.

//

// eCos 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 General Public License

// for more details.

//

// You should have received a copy of the GNU General Public License along

// with eCos; if not, write to the Free Software Foundation, Inc.,

// 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.

//

// As a special exception, if other files instantiate templates or use macros

// or inline functions from this file, or you compile this file and link it

// with other works to produce a work based on this file, this file does not

// by itself cause the resulting work to be covered by the GNU General Public

// License. However the source code for this file must still be made available

// in accordance with section (3) of the GNU General Public License.

//

// This exception does not invalidate any other reasons why a work based on

// this file might be covered by the GNU General Public License.

//

// Alternative licenses for eCos may be arranged by contacting Red Hat, Inc.

// at http://sources.redhat.com/ecos/ecos-license/

// -------------------------------------------

//####ECOSGPLCOPYRIGHTEND####

//==========================================================================

//#####DESCRIPTIONBEGIN####

//

// Author(s):     nickg

// Contributors:  nickg

// Date:          2000-04-10

// Description:   Tests POSIX sigsetjmp functionality.

//

//####DESCRIPTIONEND####

//==========================================================================

#include <cyg/infra/testcase.h>

#include <pkgconf/posix.h>

#if !defined(CYGPKG_POSIX_SIGNALS)

#define NA_MSG "POSIX signals not enabled"

#elif !defined(CYGPKG_POSIX_PTHREAD)

#define NA_MSG "POSIX threads not enabled"

#endif

#ifdef NA_MSG

void

cyg_start(void)

{

    CYG_TEST_INIT();

    CYG_TEST_NA(NA_MSG);

}

#else

#include <sys/types.h>

#include <pthread.h>

#include <signal.h>

#include <semaphore.h>

#include <time.h>

#include <setjmp.h>

#include <cyg/infra/testcase.h>

//--------------------------------------------------------------------------

// Thread stack.

char thread1_stack[PTHREAD_STACK_MIN*2];

char thread2_stack[PTHREAD_STACK_MIN*2];

//--------------------------------------------------------------------------

// Local variables

// Sync semaphore

sem_t sem;

// Thread IDs

pthread_t thread1;

pthread_t thread2;

timer_t timer1;

timer_t timer2;

volatile int sigusr1_called = 0;

volatile int sigusr2_called = 0;

sigjmp_buf jmpbuf1;

sigjmp_buf jmpbuf2;

//--------------------------------------------------------------------------

// Signal handler functions

static void sigusr1( int signo, siginfo_t *info, void *context )

{

    CYG_TEST_INFO( "sigusr1() handler called" );

    CYG_TEST_CHECK( signo == SIGUSR1, "Signal not SIGUSR1");

    CYG_TEST_CHECK( signo == info->si_signo, "Bad signal number in siginfo" );

    CYG_TEST_CHECK( info->si_code == SI_TIMER, "Siginfo code not SI_TIMER" );

    CYG_TEST_CHECK( info->si_value.sival_int == 0xABCDEF01, "Siginfo value wrong");

    CYG_TEST_CHECK( pthread_equal(pthread_self(), thread1), "Not called in thread1");

    sigusr1_called++;

    CYG_TEST_INFO( "sigusr1() handler calling siglongjmp()" );

    siglongjmp( jmpbuf1, sigusr1_called );

}

static void sigusr2( int signo, siginfo_t *info, void *context )

{

    CYG_TEST_INFO( "sigusr2() handler called" );

    CYG_TEST_CHECK( signo == SIGUSR2, "Signal not SIGUSR2");

    CYG_TEST_CHECK( signo == info->si_signo, "Bad signal number in siginfo" );

    CYG_TEST_CHECK( info->si_code == SI_TIMER, "Siginfo code not SI_TIMER" );

    CYG_TEST_CHECK( info->si_value.sival_int == 0xABCDEF02, "Siginfo value wrong");

    CYG_TEST_CHECK( pthread_equal(pthread_self(), thread2), "Not called in thread2");

    sigusr2_called++;

    CYG_TEST_INFO( "sigusr2() handler calling siglongjmp()" );

    siglongjmp( jmpbuf2, sigusr2_called );

}

//--------------------------------------------------------------------------

void *pthread_entry1( void *arg)

{

    sigset_t mask;

    CYG_TEST_INFO( "Thread 1 running" );

    // Make a full set

    sigfillset( &mask );

    // remove USR1 signal

    sigdelset( &mask, SIGUSR1 );

    // Set signal mask

    pthread_sigmask( SIG_SETMASK, &mask, NULL );

    // Get main thread going again

    sem_post( &sem );

    do

    {

        sigset_t curmask;

        CYG_TEST_INFO( "Thread1: calling sigsetjmp()");

        if( sigsetjmp( jmpbuf1, 1 ) != 0 )

            CYG_TEST_INFO( "Thread1: sigsetjmp() returned non-zero");

        pthread_sigmask( SIG_SETMASK, NULL, &curmask );

        CYG_TEST_CHECK( curmask == mask, "Thread1: Signal masks not equal" );

        if ( sigusr1_called >= 1 )

            break;

        CYG_TEST_INFO( "Thread1: calling pause()");

        pause();

        CYG_TEST_INFO( "Thread1: pause() returned");

    } while(1);

    CYG_TEST_INFO( "Thread1: calling pthread_exit()");

    pthread_exit( arg );

}

//--------------------------------------------------------------------------

void *pthread_entry2( void *arg)

{

    sigset_t mask;

    CYG_TEST_INFO( "Thread 2 running" );

    // Make a full set

    sigfillset( &mask );

    // remove USR2 signal

    sigdelset( &mask, SIGUSR2 );

    // Set signal mask

    pthread_sigmask( SIG_SETMASK, &mask, NULL );

    // Get main thread going again

    sem_post( &sem );

    do

    {

        sigset_t curmask;

        CYG_TEST_INFO( "Thread2: calling sigsetjmp()");

        if( sigsetjmp( jmpbuf2, 1 ) != 0 )

            CYG_TEST_INFO( "Thread2: sigsetjmp() returned non-zero");

        pthread_sigmask( SIG_SETMASK, NULL, &curmask );

        CYG_TEST_CHECK( curmask == mask, "Thread2: Signal masks not equal" );

        if ( sigusr2_called >= 6 )

            break;

        CYG_TEST_INFO( "Thread2: calling pause()");

        pause();

        CYG_TEST_INFO( "Thread2: pause() returned");

    } while(1);

    CYG_TEST_INFO( "Thread2: calling pthread_exit()");

    pthread_exit( arg );

}

//--------------------------------------------------------------------------

int main(int argc, char **argv)

{

    int ret;

    sigset_t mask;

    pthread_attr_t attr;

    void *retval;

    CYG_TEST_INIT();

    // Make a full signal set

    sigfillset( &mask );

    // Install signal handlers

    {

        struct sigaction sa;

        sa.sa_sigaction = sigusr1;

        sa.sa_mask = mask;

        sa.sa_flags = SA_SIGINFO;

        ret = sigaction( SIGUSR1, &sa, NULL );

        CYG_TEST_CHECK( ret == 0 , "sigaction returned error");

    }

    {

        struct sigaction sa;

        sa.sa_sigaction = sigusr2;

        sa.sa_mask = mask;

        sa.sa_flags = SA_SIGINFO;

        ret = sigaction( SIGUSR2, &sa, NULL );

        CYG_TEST_CHECK( ret == 0 , "sigaction returned error");

    }

    // Create the timers

    {

        struct sigevent sev;

        struct itimerspec value;

        sev.sigev_notify                = SIGEV_SIGNAL;

        sev.sigev_signo                 = SIGUSR1;

        sev.sigev_value.sival_int       = 0xABCDEF01;

        value.it_value.tv_sec           = 1;

        value.it_value.tv_nsec          = 0;

        value.it_interval.tv_sec        = 0;

        value.it_interval.tv_nsec       = 0;

        ret = timer_create( CLOCK_REALTIME, &sev, &timer1 );

        CYG_TEST_CHECK( ret == 0 , "timer_create returned error");

        ret = timer_settime( timer1, 0, &value, NULL );

        CYG_TEST_CHECK( ret == 0 , "timer_settime returned error");

    }

    {

        struct sigevent sev;

        struct itimerspec value;

        sev.sigev_notify                = SIGEV_SIGNAL;

        sev.sigev_signo                 = SIGUSR2;

        sev.sigev_value.sival_int       = 0xABCDEF02;

        value.it_value.tv_sec           = 0;

        value.it_value.tv_nsec          = 500000000;

        value.it_interval.tv_sec        = 0;

        value.it_interval.tv_nsec       = 250000000;

        ret = timer_create( CLOCK_REALTIME, &sev, &timer2 );

        CYG_TEST_CHECK( ret == 0 , "timer_create returned error");

        ret = timer_settime( timer2, 0, &value, NULL );

        CYG_TEST_CHECK( ret == 0 , "timer_settime returned error");

    }

    // Mask all signals

    pthread_sigmask( SIG_SETMASK, &mask, NULL );

    sem_init( &sem, 0, 0 );

    // Create test threads

    {

        pthread_attr_init( &attr );

        pthread_attr_setstackaddr( &attr, (void *)&thread1_stack[sizeof(thread1_stack)] );

        pthread_attr_setstacksize( &attr, sizeof(thread1_stack) );

        pthread_create( &thread1,

                        &attr,

                        pthread_entry1,

                        (void *)0x12345671);

    }

    {

        pthread_attr_init( &attr );

        pthread_attr_setstackaddr( &attr, (void *)&thread2_stack[sizeof(thread2_stack)] );

        pthread_attr_setstacksize( &attr, sizeof(thread2_stack) );

        pthread_create( &thread2,

                        &attr,

                        pthread_entry2,

                        (void *)0x12345672);

    }

    // Wait for other thread to get started

    CYG_TEST_INFO( "Main: calling sem_wait()");

    sem_wait( &sem );

    CYG_TEST_INFO( "Main: calling sem_wait() again");

    sem_wait( &sem );

    // Now join with thread1

    CYG_TEST_INFO( "Main: calling pthread_join(thread1)");

    pthread_join( thread1, &retval );

    CYG_TEST_CHECK( retval == (void *)0x12345671, "Thread 1 retval wrong");

    // And thread 2

    CYG_TEST_INFO( "Main: calling pthread_join(thread2)");

    pthread_join( thread2, &retval );

    // now delete the timers

    CYG_TEST_INFO( "Main: calling timer_delete(timer1)");

    ret = timer_delete( timer1 );

    CYG_TEST_CHECK( ret == 0 , "timer_delete(timer1) returned error");

    CYG_TEST_INFO( "Main: calling timer_delete(timer2)");

    ret = timer_delete( timer2 );

    CYG_TEST_CHECK( ret == 0 , "timer_delete(timer2) returned error");

    CYG_TEST_CHECK( retval == (void *)0x12345672, "Thread 2 retval wrong");

    CYG_TEST_CHECK( sigusr1_called == 1, "SIGUSR1 signal handler not called once" );

    CYG_TEST_CHECK( sigusr2_called == 6, "SIGUSR2 signal handler not called six times" );

    CYG_TEST_PASS_FINISH( "sigsetjmp" );

}

#endif

//--------------------------------------------------------------------------

// end of sigsetjmp.c