caConnTest.cpp File Reference

#include <stdio.h>
#include <stdlib.h>
#include "cadef.h"
#include "epicsTime.h"

Include dependency graph for caConnTest.cpp:

Go to the source code of this file.

Macros
#define	epicsAssertAuthor   "Jeff Hill johill@lanl.gov"

Functions
void	caConnTestConnHandler (struct connection_handler_args args)
void	caConnTest (const char *pNameIn, unsigned channelCountIn, double delayIn)

Variables
epicsTime	begin

Macro Definition Documentation

#define epicsAssertAuthor   "Jeff Hill johill@lanl.gov"

Definition at line 13 of file caConnTest.cpp.

Function Documentation

void caConnTest	(	const char *	pNameIn,
		unsigned	channelCountIn,
		double	delayIn
	)

Definition at line 58 of file caConnTest.cpp.

{
    unsigned iteration = 0u;
    int status;
    unsigned i;
    chid *pChans;

    channelCount = channelCountIn;

    pChans = new chid [channelCount];

    while ( 1 ) {
        connCount = 0u;
        subsequentConnect = false;
        begin = epicsTime::getCurrent ();

        printf ( "initializing CA client library\n" );

        status = ca_task_initialize();
        SEVCHK ( status, "CA init failed" );

        printf ( "creating channels\n" );

        for ( i = 0u; i < channelCount; i++ ) {
            status = ca_search_and_connect ( pNameIn,
                &pChans[i], caConnTestConnHandler, 0 );
            SEVCHK ( status, "CA search problems" );
        }

        printf ( "all channels were created\n" );

        ca_pend_event ( delayIn );

        if ( iteration & 1 ) {
            for ( i = 0u; i < channelCount; i++ ) {
                status = ca_clear_channel ( pChans[i] );
                SEVCHK ( status, "ca_clear_channel() problems" );
            }
            printf ( "all channels were destroyed\n" );
        }

        printf ( "shutting down CA client library\n" );

        status = ca_task_exit ();
        SEVCHK ( status, "task exit problems" );

        iteration++;
    }

    //delete [] pChans;
}

void caConnTestConnHandler

(

struct connection_handler_args

args

)

Definition at line 24 of file caConnTest.cpp.

{
    if ( args.op == CA_OP_CONN_UP ) {
        if ( connCount == 0u ) {
            if ( subsequentConnect ) {
                printf ("the first channel connected\n");
                begin = epicsTime::getCurrent ();
            }
        }
        connCount++;
        // printf  ( "." );
        // fflush ( stdout );
        if ( connCount == channelCount ) {
            epicsTime current = epicsTime::getCurrent ();
            double delay = current - begin;
            printf ( "all channels connected after %f sec ( %f sec per channel)\n",
                delay, delay / channelCount );
        }
    }
    else if ( args.op == CA_OP_CONN_DOWN ) {
        if ( connCount == channelCount ) {
            printf ( "channels are disconnected\n" );
            subsequentConnect = true;
        }
        connCount--;
        if ( connCount == 0u ) {
            printf ( "all channels are disconnected\n" );
        }
    }
    else {
        assert ( 0 );
    }
}

Variable Documentation

epicsTime begin

Definition at line 22 of file caConnTest.cpp.