/* $Id: test04.c,v 2.1 2000/05/29 13:10:38 cibrario Rel $
   Chf test program.
   General condition handling - single and multithreaded

   $Log: test04.c,v $
   Revision 2.1  2000/05/29 13:10:38  cibrario
   *** empty log message ***

*/

#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <setjmp.h>

#ifdef _REENTRANT
#  include <pthread.h>
#endif

#define CHF_MODULE_ID 255
#define CHF_EXTENDED_INFO
#include "Chf.h"

struct tdata_s {
    const ChfDescriptor *d, *e;
    int phase;
};

ChfAction h1( const ChfDescriptor* c, const ChfState s, ChfPointer p )
{
    struct tdata_s* tdata_p = ( struct tdata_s* )p;
    ChfAction action;

    if ( c != tdata_p->e || ChfGetNextDescriptor( c ) != tdata_p->d ) {
        ChfCondition 10, CHF_FATAL ChfEnd;
        action = CHF_RESIGNAL;
    }

    else
        action = CHF_CONTINUE;

    return action;
}

ChfAction h2( const ChfDescriptor* c, const ChfState s, ChfPointer p )
{
    struct tdata_s* tdata_p = ( struct tdata_s* )p;
    ChfAction action;

    switch ( s ) {
        case CHF_SIGNALING:
            {
                if ( c != tdata_p->e || ChfGetNextDescriptor( c ) != tdata_p->d || ( tdata_p->phase != 2 && tdata_p->phase != 4 ) ) {
                    ChfCondition 10, CHF_FATAL ChfEnd;
                    action = CHF_RESIGNAL;
                }

                else {
                    action = ( ChfGetConditionCode( c ) != 8 ? CHF_CONTINUE : CHF_UNWIND );
                }
                break;
            }
        case CHF_UNWINDING:
            {
                if ( tdata_p->phase != 4 )
                    exit( EXIT_FAILURE );
                tdata_p->phase = 5;
                action = CHF_CONTINUE;
                break;
            }
        default:
            {
                exit( EXIT_FAILURE );
            }
    }
    return action;
}

ChfAction h3( const ChfDescriptor* c, const ChfState s, ChfPointer p )
{
    struct tdata_s* tdata_p = ( struct tdata_s* )p;
    ChfAction action;

    /* This handler must be invoked only during the first signal */
    if ( tdata_p->phase != 3 )
        exit( EXIT_FAILURE );

    switch ( s ) {
        case CHF_SIGNALING:
            {
                if ( ChfGetConditionCode( c ) != 9 || ChfGetNextDescriptor( c ) != NULL ) {
                    exit( EXIT_FAILURE );
                }

                else {
                    tdata_p->phase = 4;
                    action = CHF_CONTINUE;
                }
                break;
            }
        default:
            {
                exit( EXIT_FAILURE );
            }
    }
    return action;
}

ChfAction h4( const ChfDescriptor* c, const ChfState s, ChfPointer p )
{
    struct tdata_s* tdata_p = ( struct tdata_s* )p;
    ChfAction action;

    /* This handler must be invoked only during the first signal */
    if ( tdata_p->phase != 2 )
        exit( EXIT_FAILURE );

    switch ( s ) {
        case CHF_SIGNALING:
            {
                if ( c != tdata_p->e || ChfGetNextDescriptor( c ) != tdata_p->d ) {
                    ChfCondition 10, CHF_FATAL ChfEnd;
                    action = CHF_RESIGNAL;
                }

                else {
                    /* This generates a new group and signals it */
                    tdata_p->phase = 3;
                    ChfCondition 9, CHF_INFO ChfEnd;
                    ChfSignal();

                    if ( tdata_p->phase != 4 )
                        exit( EXIT_FAILURE );
                    tdata_p->phase = 5;

                    if ( c != tdata_p->e || ChfGetNextDescriptor( c ) != tdata_p->d ) {
                        ChfCondition 10, CHF_FATAL ChfEnd;
                        action = CHF_RESIGNAL;
                    } else
                        action = CHF_CONTINUE;
                }
                break;
            }
        default:
            {
                exit( EXIT_FAILURE );
            }
    }
    return action;
}

void* task( void* arg )
{
    volatile struct tdata_s tdata;

    /* The sleep() is here to increase contention between threads */
    sleep( 1 );

    printf( "\tThread %d\n", ( int )arg );

    /* Push the handler */
    ChfPushHandler( h1, NULL, ( ChfPointer )( &tdata ) );

    /* Generate a condition group and signal it */
    ChfCondition 6, CHF_INFO, ( int )arg ChfEnd;
    tdata.d = ChfGetTopCondition();
    ChfCondition 7, CHF_INFO, ( int )arg ChfEnd;
    tdata.e = ChfGetTopCondition();

    /* The sleep() is here to increase contention between threads */
    sleep( 1 );
    ChfSignal();

    /* Pop the handler */
    ChfPopHandler();

    /* Generate a new condition group with (apparently) wrong linkage
       and signal it; this checks that the handler has actually been
       removed.
    */
    ChfCondition 6, CHF_INFO, ( int )arg ChfEnd;
    tdata.d = NULL;
    ChfCondition 7, CHF_INFO, ( int )arg ChfEnd;
    tdata.e = NULL;
    ChfSignal();

    /* Conditional unwind test */
    {
        sigjmp_buf jb;

        tdata.phase = 0;
        if ( setjmp( jb ) == 0 ) {
            ChfPushHandler( h2, jb, ( ChfPointer )( &tdata ) );

            /* Generate a condition group and signal it */
            tdata.phase = 1;
            ChfCondition 6, CHF_INFO, ( int )arg ChfEnd;
            tdata.d = ChfGetTopCondition();
            ChfCondition 7, CHF_INFO, ( int )arg ChfEnd;
            tdata.e = ChfGetTopCondition();

            /* This does not trigger an unwind */
            tdata.phase = 2;
            ChfSignal();

            tdata.phase = 3;
            ChfCondition 6, CHF_INFO, ( int )arg ChfEnd;
            tdata.d = ChfGetTopCondition();
            ChfCondition 8, CHF_INFO, ( int )arg ChfEnd;
            tdata.e = ChfGetTopCondition();

            /* This MUST trigger an unwind */
            tdata.phase = 4;
            ChfSignal();

            exit( EXIT_FAILURE );

        } else {
            /* Unwind */
            if ( tdata.phase != 5 )
                exit( EXIT_FAILURE );

            ChfPopHandler();
        }
    }

    /* Condition generation and signal while a signal is in progress;
       this requires two handlers.
    */
    {
        tdata.phase = 0;

        ChfPushHandler( h3, NULL, ( ChfPointer )&tdata );
        ChfPushHandler( h4, NULL, ( ChfPointer )&tdata );

        tdata.phase = 1;
        ChfCondition 6, CHF_INFO, ( int )arg ChfEnd;
        tdata.d = ChfGetTopCondition();
        ChfCondition 7, CHF_INFO, ( int )arg ChfEnd;
        tdata.e = ChfGetTopCondition();

        tdata.phase = 2;
        ChfSignal();

        if ( tdata.phase != 5 )
            exit( EXIT_FAILURE );

        ChfPopHandler();
        ChfPopHandler();
    }

    return ( void* )0;
}

#define N_THREADS 50

int main( int argc, char* argv[] )
{
    int st;
    int i;
    void* ret;

#ifdef _REENTRANT
    pthread_t t[ N_THREADS ];
#endif

    puts( "test04" );

    /* Initialization */
    if ( st = ChfMsgcatInit( argv[ 0 ], CHF_DEFAULT, "./test01.cat", 50, 10, 1 ) )
        exit( st );

#ifdef _REENTRANT
    /* Create */
    for ( i = 0; i < N_THREADS; i++ )
        if ( pthread_create( &( t[ i ] ), NULL, task, ( void* )i ) ) {
            perror( "pthread_create" );
            exit( EXIT_FAILURE );
        }

    /* Join */
    for ( i = 0; i < N_THREADS; i++ )
        if ( pthread_join( t[ i ], &ret ) ) {
            perror( "pthread_join" );
            exit( EXIT_FAILURE );
        }
#else
    task( ( void* )0 );
#endif

    /* Exit Chf */
    ChfExit();
    exit( EXIT_SUCCESS );
}