ca_client_context.cpp File Reference

#include <stdexcept>
#include <string>
#include <stdio.h>
#include "epicsExit.h"
#include "errlog.h"
#include "locationException.h"
#include "iocinf.h"
#include "oldAccess.h"
#include "cac.h"

Include dependency graph for ca_client_context.cpp:

Go to the source code of this file.

Functions
void	cacOnceFunc (void *)
void epicsStdCall	caInstallDefaultService (cacService &service)
LIBCA_API int epicsStdCall	ca_clear_subscription (evid pMon)

Variables
epicsThreadPrivateId	caClientCallbackThreadId
epicsThreadPrivateId	caClientContextId

Function Documentation

LIBCA_API int epicsStdCall ca_clear_subscription

(

evid

pMon

)

Definition at line 743 of file ca_client_context.cpp.

{
    oldChannelNotify & chan = pMon->channel ();
    ca_client_context & cac = chan.getClientCtx ();
    // !!!! the order in which we take the mutex here prevents deadlocks
    {
        epicsGuard < epicsMutex > guard ( cac.mutex );
        try {
            // if this stalls out on a live circuit then an exception
            // can be forthcoming which we must ignore as the clear
            // request must always be successful
            chan.eliminateExcessiveSendBacklog ( guard );
        }
        catch ( cacChannel::notConnected & ) {
            // intentionally ignored
        }
    }
    if ( cac.pCallbackGuard.get() &&
        cac.createdByThread == epicsThreadGetIdSelf () ) {
      epicsGuard < epicsMutex > guard ( cac.mutex );
      pMon->cancel ( *cac.pCallbackGuard.get(), guard );
    }
    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 );
      pMon->cancel ( cbGuard, guard );
    }
    return ECA_NORMAL;
}

void cacOnceFunc

(

void *

)

Definition at line 48 of file ca_client_context.cpp.

{
    caClientCallbackThreadId = epicsThreadPrivateCreate ();
    assert ( caClientCallbackThreadId );
    ca_client_context::pDefaultServiceInstallMutex = newEpicsMutex;
}

void epicsStdCall caInstallDefaultService

(

cacService &

service

)

Definition at line 738 of file ca_client_context.cpp.

{
    ca_client_context::installDefaultService ( service );
}

Variable Documentation

epicsThreadPrivateId caClientCallbackThreadId

Definition at line 41 of file ca_client_context.cpp.

epicsThreadPrivateId caClientContextId

Definition at line 46 of file access.cpp.