#include <new>
#include <float.h>
#include "dbDefs.h"
#include "epicsExit.h"
#include "iocinf.h"
#include "oldAccess.h"
#include "cac.h"

Include dependency graph for access.cpp:

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

#define	CA_ERROR_GLBLSOURCE

#define	CAC_VERSION_GLOBAL

Functions
void	ca_init_client_context (void *)

int	fetchClientContext (ca_client_context **ppcac)

int epicsStdCall	ca_task_initialize (void)

int epicsStdCall	ca_context_create (ca_preemptive_callback_select premptiveCallbackSelect)

int epicsStdCall	ca_modify_host_name (const char *)

int epicsStdCall	ca_modify_user_name (const char *)

void epicsStdCall	ca_context_destroy ()

int epicsStdCall	ca_task_exit ()

int epicsStdCall	ca_build_and_connect (const char name_str, chtype get_type, arrayElementCount get_count, chid chan, void pvalue, caCh conn_func, void *puser)

int epicsStdCall	ca_search_and_connect (const char name_str, chid chanptr, caCh conn_func, void puser)

int epicsStdCall	ca_create_channel (const char name_str, caCh conn_func, void puser, capri priority, chid chanptr)

int epicsStdCall	ca_clear_channel (chid pChan)

int epicsStdCall	ca_add_exception_event (caExceptionHandler pfunc, void arg)

int epicsStdCall	ca_add_masked_array_event (chtype type, arrayElementCount count, chid pChan, caEventCallBackFunc pCallBack, void pCallBackArg, ca_real, ca_real, ca_real, evid *monixptr, long mask)

int epicsStdCall	ca_clear_event (evid pMon)

chid epicsStdCall	ca_evid_to_chid (evid pMon)

int epicsStdCall	ca_pend (ca_real timeout, int early)

int epicsStdCall	ca_pend_event (ca_real timeout)

int epicsStdCall	ca_pend_io (ca_real timeout)

int epicsStdCall	ca_flush_io ()

int epicsStdCall	ca_test_io ()

void epicsStdCall	ca_signal (long ca_status, const char *message)

const char *epicsStdCall	ca_message (long ca_status)

void epicsStdCall	ca_signal_with_file_and_lineno (long ca_status, const char message, const char pfilenm, int lineno)

void epicsStdCall	ca_signal_formated (long ca_status, const char pfilenm, int lineno, const char pFormat,...)

int epicsStdCall	ca_add_fd_registration (CAFDHANDLER func, void arg)

const char *epicsStdCall	ca_version ()

int epicsStdCall	ca_replace_printf_handler (caPrintfFunc *ca_printf_func)

unsigned epicsStdCall	ca_get_ioc_connection_count ()

unsigned epicsStdCall	ca_beacon_anomaly_count ()

int epicsStdCall	ca_channel_status (epicsThreadId)

int epicsStdCall	ca_client_status (unsigned level)

int epicsStdCall	ca_context_status (ca_client_context *pcac, unsigned level)

struct ca_client_context *epicsStdCall	ca_current_context ()

int epicsStdCall	ca_attach_context (struct ca_client_context *pCtx)

void epicsStdCall	ca_detach_context ()

int epicsStdCall	ca_preemtive_callback_is_enabled ()

void epicsStdCall	ca_self_test ()

Variables
epicsThreadPrivateId	caClientContextId

const char *	ca_message_text []

const int	epicsTypeToDBR_XXXX [lastEpicsType+1]

const epicsType	DBR_XXXXToEpicsType [LAST_BUFFER_TYPE+1]

const unsigned short	dbr_size [LAST_BUFFER_TYPE+1]

const unsigned short	dbr_value_size [LAST_BUFFER_TYPE+1]

enum dbr_value_class	dbr_value_class [LAST_BUFFER_TYPE+1]

const unsigned short	dbr_value_offset [LAST_BUFFER_TYPE+1]

const char *	dbf_text [LAST_TYPE+3]

const char *	dbf_text_invalid = "DBF_invalid"

const short	dbf_text_dim = (sizeof dbf_text)/(sizeof (char *))

const char *	dbr_text [LAST_BUFFER_TYPE+1]

const char *	dbr_text_invalid = "DBR_invalid"

const short	dbr_text_dim = (sizeof dbr_text) / (sizeof (char *)) + 1

Macro Definition Documentation

#define CA_ERROR_GLBLSOURCE

Definition at line 35 of file access.cpp.

#define CAC_VERSION_GLOBAL

Definition at line 40 of file access.cpp.

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

Definition at line 28 of file access.cpp.

Function Documentation

int epicsStdCall ca_add_exception_event	(	caExceptionHandler *	pfunc,
		void *	arg
	)

Definition at line 402 of file access.cpp.

 {
     ca_client_context *pcac;
     int caStatus = fetchClientContext ( &pcac );
     if ( caStatus != ECA_NORMAL ) {
         return caStatus;
     }
 
     pcac->changeExceptionEvent ( pfunc, arg );
 
     return ECA_NORMAL;
 }

int epicsStdCall ca_add_fd_registration	(	CAFDHANDLER *	func,
		void *	arg
	)

Definition at line 623 of file access.cpp.

 {
     ca_client_context *pcac;
     int caStatus = fetchClientContext ( &pcac );
     if ( caStatus != ECA_NORMAL ) {
         return caStatus;
     }
 
     pcac->registerForFileDescriptorCallBack ( func, arg );
 
     return ECA_NORMAL;
 }

int epicsStdCall ca_add_masked_array_event	(	chtype	type,
		arrayElementCount	count,
		chid	pChan,
		caEventCallBackFunc *	pCallBack,
		void *	pCallBackArg,
		ca_real	,
		ca_real	,
		ca_real	,
		evid *	monixptr,
		long	mask
	)

Definition at line 418 of file access.cpp.

 {
     return ca_create_subscription ( type, count, pChan, mask,
         pCallBack, pCallBackArg, monixptr );
 }

int epicsStdCall ca_attach_context ( struct ca_client_context * pCtx )

Definition at line 746 of file access.cpp.

 {
     ca_client_context *pcac = (ca_client_context *) epicsThreadPrivateGet ( caClientContextId );
     if ( pcac && pCtx != 0 ) {
         return ECA_ISATTACHED;
     }
     if ( ! pCtx->preemptiveCallbakIsEnabled() ) {
         return ECA_NOTTHREADED;
     }
     epicsThreadPrivateSet ( caClientContextId, pCtx );
     return ECA_NORMAL;
 }

unsigned epicsStdCall ca_beacon_anomaly_count ( void )

Definition at line 681 of file access.cpp.

 {
     ca_client_context * pcac;
     int caStatus = fetchClientContext ( & pcac );
     if ( caStatus != ECA_NORMAL ) {
         return 0u;
     }
 
     return pcac->beaconAnomaliesSinceProgramStart ();
 }

int epicsStdCall ca_build_and_connect	(	const char *	name_str,
		chtype	get_type,
		arrayElementCount	get_count,
		chid *	chan,
		void *	pvalue,
		caCh *	conn_func,
		void *	puser
	)

Definition at line 264 of file access.cpp.

 {
     if ( get_type != TYPENOTCONN && pvalue != 0 && get_count != 0 ) {
         return ECA_ANACHRONISM;
     }
 
     return ca_search_and_connect ( name_str, chan, conn_func, puser );
 }

int epicsStdCall ca_channel_status ( epicsThreadId )

Definition at line 693 of file access.cpp.

 {
     ::printf ("The R3.14 EPICS OS abstraction API does not allow peeking at thread private storage of another thread.\n");
     ::printf ("Please call \"ca_client_status ( unsigned level )\" from the subsystem specific diagnostic code.\n");
     return ECA_ANACHRONISM;
 }

int epicsStdCall ca_clear_channel ( chid pChan )

Definition at line 363 of file access.cpp.

 {
     ca_client_context & cac = pChan->getClientCtx ();
     {
         epicsGuard < epicsMutex > guard ( cac.mutex );
         try {
             pChan->eliminateExcessiveSendBacklog ( guard );
         }
         catch ( cacChannel::notConnected & ) {
             // intentionally ignored
         }
     }
     if ( cac.pCallbackGuard.get() &&
             cac.createdByThread == epicsThreadGetIdSelf () ) {
         epicsGuard < epicsMutex > guard ( cac.mutex );
         pChan->destructor ( *cac.pCallbackGuard.get(), guard );
         cac.oldChannelNotifyFreeList.release ( pChan );
     }
     else {
         //
         // we will definately stall out here if all of the
         // following are true
         //
         // o user creates non-preemtive mode client library context
         // o user doesnt periodically call a ca function
         // o user calls this function from an auxiillary thread
         //
         CallbackGuard cbGuard ( cac.cbMutex );
         epicsGuard < epicsMutex > guard ( cac.mutex );
         pChan->destructor ( *cac.pCallbackGuard.get(), guard );
         cac.oldChannelNotifyFreeList.release ( pChan );
     }
     return ECA_NORMAL;
 }

int epicsStdCall ca_clear_event ( evid pMon )

Definition at line 431 of file access.cpp.

 {
     return ca_clear_subscription ( pMon );
 }

int epicsStdCall ca_client_status ( unsigned level )

Definition at line 701 of file access.cpp.

 {
     ca_client_context *pcac;
     int caStatus = fetchClientContext ( &pcac );
     if ( caStatus != ECA_NORMAL ) {
         return caStatus;
     }
 
     pcac->show ( level );
     return ECA_NORMAL;
 }

int epicsStdCall ca_context_create ( ca_preemptive_callback_select premptiveCallbackSelect )

Definition at line 172 of file access.cpp.

 {
     ca_client_context *pcac;
 
     try {
         epicsThreadOnce ( & caClientContextIdOnce, ca_init_client_context, 0);
         if ( caClientContextId == 0 ) {
             return ECA_ALLOCMEM;
         }
 
         pcac = ( ca_client_context * ) epicsThreadPrivateGet ( caClientContextId );
         if ( pcac ) {
             if ( premptiveCallbackSelect == ca_enable_preemptive_callback &&
                 ! pcac->preemptiveCallbakIsEnabled() ) {
                 return ECA_NOTTHREADED;
             }
             return ECA_NORMAL;
         }
 
         pcac = new ca_client_context (
             premptiveCallbackSelect == ca_enable_preemptive_callback );
         if ( ! pcac ) {
             return ECA_ALLOCMEM;
         }
 
         epicsThreadPrivateSet ( caClientContextId, (void *) pcac );
     }
     catch ( ... ) {
         return ECA_ALLOCMEM;
     }
     return ECA_NORMAL;
 }

void epicsStdCall ca_context_destroy ( void )

Definition at line 232 of file access.cpp.

 {
     ca_client_context   *pcac;
 
     if ( caClientContextId != NULL ) {
         pcac = (ca_client_context *) epicsThreadPrivateGet ( caClientContextId );
         if ( pcac ) {
             delete pcac;
             epicsThreadPrivateSet ( caClientContextId, 0 );
         }
     }
 }

int epicsStdCall ca_context_status	(	ca_client_context *	pcac,
		unsigned	level
	)

Definition at line 713 of file access.cpp.

 {
     pcac->show ( level );
     return ECA_NORMAL;
 }

int epicsStdCall ca_create_channel	(	const char *	name_str,
		caCh *	conn_func,
		void *	puser,
		capri	priority,
		chid *	chanptr
	)

Definition at line 288 of file access.cpp.

 {
     ca_client_context * pcac;
     int caStatus = fetchClientContext ( & pcac );
     if ( caStatus != ECA_NORMAL ) {
         return caStatus;
     }
 
     {
         CAFDHANDLER * pFunc = 0;
         void * pArg = 0;
         {
             epicsGuard < epicsMutex >
                 guard ( pcac->mutex );
             if ( pcac->fdRegFuncNeedsToBeCalled ) {
                 pFunc = pcac->fdRegFunc;
                 pArg = pcac->fdRegArg;
                 pcac->fdRegFuncNeedsToBeCalled = false;
             }
         }
         if ( pFunc ) {
             ( *pFunc ) ( pArg, pcac->sock, true );
         }
     }
 
     try {
         epicsGuard < epicsMutex > guard ( pcac->mutex );
         oldChannelNotify * pChanNotify =
             new ( pcac->oldChannelNotifyFreeList )
                 oldChannelNotify ( guard, *pcac, name_str,
                     conn_func, puser, priority );
         // make sure that their chan pointer is set prior to
         // calling connection call backs
         *chanptr = pChanNotify;
         pChanNotify->initiateConnect ( guard );
         // no need to worry about a connect preempting here because
         // the connect sequence will not start untill initiateConnect()
         // is called
     }
     catch ( cacChannel::badString & ) {
         return ECA_BADSTR;
     }
     catch ( std::bad_alloc & ) {
         return ECA_ALLOCMEM;
     }
     catch ( cacChannel::badPriority & ) {
         return ECA_BADPRIORITY;
     }
     catch ( cacChannel::unsupportedByService & ) {
         return ECA_UNAVAILINSERV;
     }
     catch ( std :: exception & except ) {
         pcac->printFormated (
             "ca_create_channel: "
             "unexpected exception was \"%s\"",
             except.what () );
         return ECA_INTERNAL;
     }
     catch ( ... ) {
         return ECA_INTERNAL;
     }
 
     return ECA_NORMAL;
 }

struct ca_client_context* epicsStdCall ca_current_context ( )

Definition at line 726 of file access.cpp.

 {
     struct ca_client_context *pCtx;
     if ( caClientContextId ) {
         pCtx = ( struct ca_client_context * )
             epicsThreadPrivateGet ( caClientContextId );
     }
     else {
         pCtx = 0;
     }
     return pCtx;
 }

void epicsStdCall ca_detach_context ( )

Definition at line 759 of file access.cpp.

 {
     if ( caClientContextId ) {
         epicsThreadPrivateSet ( caClientContextId, 0 );
     }
 }

chid epicsStdCall ca_evid_to_chid ( evid pMon )

Definition at line 437 of file access.cpp.

 {
     return & pMon->channel ();
 }

int epicsStdCall ca_flush_io ( void )

Definition at line 509 of file access.cpp.

 {
     ca_client_context * pcac;
     int caStatus = fetchClientContext (&pcac);
     if ( caStatus != ECA_NORMAL ) {
         return caStatus;
     }
 
     epicsGuard < epicsMutex > guard ( pcac->mutex );
     pcac->flush ( guard );
 
     return ECA_NORMAL;
 }

unsigned epicsStdCall ca_get_ioc_connection_count ( void )

Definition at line 670 of file access.cpp.

 {
     ca_client_context * pcac;
     int caStatus = fetchClientContext ( & pcac );
     if ( caStatus != ECA_NORMAL ) {
         return 0u;
     }
 
     return pcac->circuitCount ();
 }

void ca_init_client_context ( void * )

Definition at line 129 of file access.cpp.

 {
     caClientContextId = epicsThreadPrivateCreate ();
 }

const char* epicsStdCall ca_message ( long ca_status )

Definition at line 561 of file access.cpp.

 {
     unsigned msgNo = CA_EXTRACT_MSG_NO ( ca_status );
 
     if ( msgNo < NELEMENTS (ca_message_text) ) {
         return ca_message_text[msgNo];
     }
     else {
         return "new CA message number known only by server - see caerr.h";
     }
 }

int epicsStdCall ca_modify_host_name ( const char * )

Definition at line 212 of file access.cpp.

 {
     return ECA_NORMAL;
 }

int epicsStdCall ca_modify_user_name ( const char * )

Definition at line 223 of file access.cpp.

 {
     return ECA_NORMAL;
 }

int epicsStdCall ca_pend	(	ca_real	timeout,
		int	early
	)

Definition at line 443 of file access.cpp.

 {
     if ( early ) {
         return ca_pend_io ( timeout );
     }
     else {
         return ca_pend_event ( timeout );
     }
 }

int epicsStdCall ca_pend_event ( ca_real timeout )

Definition at line 457 of file access.cpp.

 {
     ca_client_context *pcac;
     int status = fetchClientContext ( &pcac );
     if ( status != ECA_NORMAL ) {
         return status;
     }
 
     try {
         // preserve past odd ball behavior of waiting forever when
         // the delay is zero
         if ( timeout == 0.0 ) {
             while ( true ) {
                 pcac->pendEvent ( 60.0 );
             }
         }
         return pcac->pendEvent ( timeout );
     }
     catch ( ... ) {
         return ECA_INTERNAL;
     }
 }

int epicsStdCall ca_pend_io ( ca_real timeout )

Definition at line 484 of file access.cpp.

 {
     ca_client_context *pcac;
     int status = fetchClientContext ( &pcac );
     if ( status != ECA_NORMAL ) {
         return status;
     }
 
     try {
         // preserve past odd ball behavior of waiting forever when
         // the delay is zero
         if ( timeout == 0.0 ) {
             return pcac->pendIO ( DBL_MAX );
         }
 
         return pcac->pendIO ( timeout );
     }
     catch ( ... ) {
         return ECA_INTERNAL;
     }
 }

int epicsStdCall ca_preemtive_callback_is_enabled ( void )

Definition at line 766 of file access.cpp.

 {
     ca_client_context *pcac = (ca_client_context *) epicsThreadPrivateGet ( caClientContextId );
     if ( ! pcac ) {
         return 0;
     }
     return pcac->preemptiveCallbakIsEnabled ();
 }

int epicsStdCall ca_replace_printf_handler ( caPrintfFunc * ca_printf_func )

Definition at line 650 of file access.cpp.

 {
     ca_client_context *pcac;
     int caStatus = fetchClientContext (&pcac);
     if ( caStatus != ECA_NORMAL ) {
         return caStatus;
     }
 
     pcac->replaceErrLogHandler ( ca_printf_func );
 
     return ECA_NORMAL;
 }

int epicsStdCall ca_search_and_connect	(	const char *	name_str,
		chid *	chanptr,
		caCh *	conn_func,
		void *	puser
	)

Definition at line 279 of file access.cpp.

 {
     return ca_create_channel ( name_str, conn_func,
         puser, CA_PRIORITY_DEFAULT, chanptr );
 }

void epicsStdCall ca_self_test ( void )

Definition at line 777 of file access.cpp.

 {
     ca_client_context *pcac = (ca_client_context *) epicsThreadPrivateGet ( caClientContextId );
     if ( ! pcac ) {
         return;
     }
     pcac->selfTest ();
 }

void epicsStdCall ca_signal	(	long	ca_status,
		const char *	message
	)

Definition at line 546 of file access.cpp.

 {
     ca_signal_with_file_and_lineno ( ca_status, message, NULL, 0 );
 }

void epicsStdCall ca_signal_formated	(	long	ca_status,
		const char *	pfilenm,
		int	lineno,
		const char *	pFormat,
			...
	)

Definition at line 587 of file access.cpp.

 {
     ca_client_context *pcac;
 
     if ( caClientContextId ) {
         pcac = ( ca_client_context * ) epicsThreadPrivateGet ( caClientContextId );
     }
     else {
         pcac = 0;
     }
 
     va_list theArgs;
     va_start ( theArgs, pFormat );
     if ( pcac ) {
         pcac->vSignal ( ca_status, pfilenm, lineno, pFormat, theArgs );
     }
     else {
         fprintf ( stderr, "CA exception in thread w/o CA ctx: status=%s file=%s line=%d: \n",
             ca_message ( ca_status ), pfilenm, lineno );
         if ( pFormat ) {
             vfprintf ( stderr, pFormat, theArgs );
         }
     }
     va_end ( theArgs );
 }

void epicsStdCall ca_signal_with_file_and_lineno	(	long	ca_status,
		const char *	message,
		const char *	pfilenm,
		int	lineno
	)

Definition at line 577 of file access.cpp.

 {
     ca_signal_formated ( ca_status, pfilenm, lineno, message );
 }

int epicsStdCall ca_task_exit ( void )

Definition at line 251 of file access.cpp.

 {
     ca_context_destroy ();
     return ECA_NORMAL;
 }

int epicsStdCall ca_task_initialize ( void )

Definition at line 166 of file access.cpp.

 {
     return ca_context_create ( ca_disable_preemptive_callback );
 }

int epicsStdCall ca_test_io ( void )

Definition at line 526 of file access.cpp.

 {
     ca_client_context *pcac;
     int caStatus = fetchClientContext ( &pcac );
     if ( caStatus != ECA_NORMAL ) {
         return caStatus;
     }
 
     if ( pcac->ioComplete () ) {
         return ECA_IODONE;
     }
     else{
         return ECA_IOINPROGRESS;
     }
 }

const char* epicsStdCall ca_version ( void )

Definition at line 641 of file access.cpp.

 {
     return CA_VERSION_STRING ( CA_MINOR_PROTOCOL_REVISION );
 }

int fetchClientContext ( ca_client_context ** ppcac )

Definition at line 137 of file access.cpp.

 {
     epicsThreadOnce ( &caClientContextIdOnce, ca_init_client_context, 0 );
     if ( caClientContextId == 0 ) {
         return ECA_ALLOCMEM;
     }
 
     int status;
     *ppcac = ( ca_client_context * ) epicsThreadPrivateGet ( caClientContextId );
     if ( *ppcac ) {
         status = ECA_NORMAL;
     }
     else {
         status = ca_task_initialize ();
         if ( status == ECA_NORMAL ) {
             *ppcac = (ca_client_context *) epicsThreadPrivateGet ( caClientContextId );
             if ( ! *ppcac ) {
                 status = ECA_INTERNAL;
             }
         }
     }
 
     return status;
 }

Variable Documentation

const char* ca_message_text[]

Definition at line 49 of file access.cpp.

epicsThreadPrivateId caClientContextId

Definition at line 46 of file access.cpp.

const char* dbf_text[LAST_TYPE+3]

Initial value:

= {
    "TYPENOTCONN",
    "DBF_STRING",
    "DBF_SHORT",
    "DBF_FLOAT",
    "DBF_ENUM",
    "DBF_CHAR",
    "DBF_LONG",
    "DBF_DOUBLE",
    "DBF_NO_ACCESS"
}

Definition at line 1034 of file access.cpp.

const short dbf_text_dim = (sizeof dbf_text)/(sizeof (char *))

Definition at line 1048 of file access.cpp.

const char* dbf_text_invalid = "DBF_invalid"

Definition at line 1046 of file access.cpp.

const unsigned short dbr_size[LAST_BUFFER_TYPE+1]

Definition at line 847 of file access.cpp.

const char* dbr_text[LAST_BUFFER_TYPE+1]

Definition at line 1050 of file access.cpp.

const short dbr_text_dim = (sizeof dbr_text) / (sizeof (char *)) + 1

Definition at line 1094 of file access.cpp.

const char* dbr_text_invalid = "DBR_invalid"

Definition at line 1092 of file access.cpp.

enum dbr_value_class dbr_value_class[LAST_BUFFER_TYPE+1]

Definition at line 946 of file access.cpp.

const unsigned short dbr_value_offset[LAST_BUFFER_TYPE+1]

Definition at line 992 of file access.cpp.

const unsigned short dbr_value_size[LAST_BUFFER_TYPE+1]

Definition at line 896 of file access.cpp.

const epicsType DBR_XXXXToEpicsType[LAST_BUFFER_TYPE+1]

Definition at line 800 of file access.cpp.

const int epicsTypeToDBR_XXXX[lastEpicsType+1]

Initial value:

= {
    DBR_SHORT, 
    DBR_CHAR,
    DBR_SHORT,
    DBR_LONG, 
    DBR_ENUM,
    DBR_LONG,
    DBR_LONG, 
    DBR_FLOAT,
    DBR_DOUBLE,
    DBR_STRING,
    DBR_STRING
}

Definition at line 786 of file access.cpp.

Macros

Functions

Variables

Macro Definition Documentation

Function Documentation

Variable Documentation