pvalink::pvaLink Struct Reference

#include "pvalink.h"

Inheritance diagram for pvalink::pvaLink:

Collaboration diagram for pvalink::pvaLink:

Public Member Functions
	pvaLink ()
virtual	~pvaLink ()
pvd::PVStructurePtr	makeRequest ()
bool	valid () const
pvd::PVField::const_shared_pointer	getSubField (const char *name)
void	onDisconnect ()
void	onTypeChange ()
Public Member Functions inherited from pvalink::pvaLinkConfig
	pvaLinkConfig ()
virtual	~pvaLinkConfig ()

Public Attributes
bool	alive
DBLINK *	plink
std::tr1::shared_ptr< pvaLinkChannel >	lchan
bool	used_scratch
bool	used_queue
pvd::shared_vector< const void >	put_scratch
pvd::shared_vector< const void >	put_queue
epics::pvData::PVField::const_shared_pointer	fld_value
epics::pvData::PVScalar::const_shared_pointer	fld_severity
epics::pvData::PVScalar::const_shared_pointer	fld_seconds
epics::pvData::PVScalar::const_shared_pointer	fld_nanoseconds
epics::pvData::PVStructure::const_shared_pointer	fld_display
epics::pvData::PVStructure::const_shared_pointer	fld_control
epics::pvData::PVStructure::const_shared_pointer	fld_valueAlarm
epics::pvData::BitSet	proc_changed
epicsTimeStamp	snap_time
short	snap_severity
Public Attributes inherited from pvalink::pvaLinkConfig
std::string	channelName
	Channel (aka PV) name string. More...
std::string	fieldName
	sub-field within addressed PVStructure More...
size_t	queueSize
enum pvalink::pvaLinkConfig::pp_t	pp
enum pvalink::pvaLinkConfig::ms_t	ms
bool	defer
bool	pipeline
bool	time
bool	retry
bool	local
bool	always
int	monorder
std::string	jkey

Static Public Attributes
static size_t	num_instances

Additional Inherited Members
Public Types inherited from pvalink::pvaLinkConfig
enum	pp_t {   NPP, Default, PP, CP,   CPP }
enum	ms_t { NMS, MS, MSI }

Detailed Description

Definition at line 196 of file pvalink.h.

Constructor & Destructor Documentation

pvalink::pvaLink::pvaLink

(

)

Definition at line 8 of file pvalink_link.cpp.

    :alive(true)
    ,plink(0)
    ,used_scratch(false)
    ,used_queue(false)
{
    REFTRACE_INCREMENT(num_instances);

    snap_severity = INVALID_ALARM;
    snap_time.secPastEpoch = 0;
    snap_time.nsec = 0;

    //TODO: valgrind tells me these aren't initialized by Base, but probably should be.
    parseDepth = 0;
    parent = 0;
}

pvalink::pvaLink::~pvaLink ( )

virtual

Definition at line 25 of file pvalink_link.cpp.

{
    alive = false;

    if(lchan) { // may be NULL if parsing fails
        Guard G(lchan->lock);

        lchan->links.erase(this);
        lchan->links_changed = true;

        bool new_debug = false;
        for(pvaLinkChannel::links_t::const_iterator it(lchan->links.begin()), end(lchan->links.end())
            ; it!=end; ++it)
        {
            const pvaLink *pval = *it;
            if(pval->debug) {
                new_debug = true;
                break;
            }
        }

        lchan->debug = new_debug;
    }

    REFTRACE_DECREMENT(num_instances);
}

Member Function Documentation

pvd::PVField::const_shared_pointer pvalink::pvaLink::getSubField

(

const char *

name

)

Definition at line 81 of file pvalink_link.cpp.

{
    pvd::PVField::const_shared_pointer ret;
    if(valid()) {
        if(fieldName.empty()) {
            // we access the top level struct
            ret = lchan->op_mon.root->getSubField(name);

        } else {
            // we access a sub-struct
            ret = lchan->op_mon.root->getSubField(fieldName);
            if(ret->getField()->getType()!=pvd::structure) {
                // addressed sub-field isn't a sub-structure
                if(strcmp(name, "value")!=0) {
                    // unless we are trying to fetch the "value", we fail here
                    ret.reset();
                }
            } else {
                ret = static_cast<const pvd::PVStructure*>(ret.get())->getSubField(name);
            }
        }
    }
    return ret;
}

pvd::PVStructurePtr pvalink::pvaLink::makeRequest

(

)

Definition at line 65 of file pvalink_link.cpp.

{
    pvd::PVStructurePtr ret(pvd::getPVDataCreate()->createPVStructure(monitorRequestType));
    ret->getSubFieldT<pvd::PVBoolean>("record._options.pipeline")->put(pipeline);
    ret->getSubFieldT<pvd::PVBoolean>("record._options.atomic")->put(true);
    ret->getSubFieldT<pvd::PVUInt>("record._options.queueSize")->put(queueSize);
    return ret;
}

void pvalink::pvaLink::onDisconnect

(

)

Definition at line 107 of file pvalink_link.cpp.

{
    DEBUG(this,<<plink->precord->name<<" disconnect");
    // TODO: option to remain queue'd while disconnected

    used_queue = used_scratch = false;
}

void pvalink::pvaLink::onTypeChange

(

)

Definition at line 115 of file pvalink_link.cpp.

{
    DEBUG(this,<<plink->precord->name<<" type change");

    assert(lchan->connected_latched && !!lchan->op_mon.root); // we should only be called when connected

    fld_value = getSubField("value");
    fld_seconds = std::tr1::dynamic_pointer_cast<const pvd::PVScalar>(getSubField("timeStamp.secondsPastEpoch"));
    fld_nanoseconds = std::tr1::dynamic_pointer_cast<const pvd::PVScalar>(getSubField("timeStamp.nanoseconds"));
    fld_severity = std::tr1::dynamic_pointer_cast<const pvd::PVScalar>(getSubField("alarm.severity"));
    fld_display = std::tr1::dynamic_pointer_cast<const pvd::PVStructure>(getSubField("display"));
    fld_control = std::tr1::dynamic_pointer_cast<const pvd::PVStructure>(getSubField("control"));
    fld_valueAlarm = std::tr1::dynamic_pointer_cast<const pvd::PVStructure>(getSubField("valueAlarm"));

    proc_changed.clear();

    // build mask of all "changed" bits associated with our .value
    // CP/CPP input links will process this link only for updates where
    // the changed mask and proc_changed share at least one set bit.
    if(fld_value) {
        // bit for this field
        proc_changed.set(fld_value->getFieldOffset());

        // bits of all parent fields
        for(const pvd::PVStructure* parent = fld_value->getParent(); parent; parent = parent->getParent()) {
            proc_changed.set(parent->getFieldOffset());
        }

        if(fld_value->getField()->getType()==pvd::structure)
        {
            // bits of all child fields
            const pvd::PVStructure *val = static_cast<const pvd::PVStructure*>(fld_value.get());
            for(size_t i=val->getFieldOffset(), N=val->getNextFieldOffset(); i<N; i++)
                proc_changed.set(i);
        }
    }
}

bool pvalink::pvaLink::valid

(

void

)

const

Definition at line 75 of file pvalink_link.cpp.

{
    return lchan->connected_latched && lchan->op_mon.root;
}

Member Data Documentation

bool pvalink::pvaLink::alive

Definition at line 200 of file pvalink.h.

epics::pvData::PVStructure::const_shared_pointer pvalink::pvaLink::fld_control

Definition at line 215 of file pvalink.h.

epics::pvData::PVStructure::const_shared_pointer pvalink::pvaLink::fld_display

Definition at line 215 of file pvalink.h.

epics::pvData::PVScalar::const_shared_pointer pvalink::pvaLink::fld_nanoseconds

Definition at line 212 of file pvalink.h.

epics::pvData::PVScalar::const_shared_pointer pvalink::pvaLink::fld_seconds

Definition at line 212 of file pvalink.h.

epics::pvData::PVScalar::const_shared_pointer pvalink::pvaLink::fld_severity

Definition at line 212 of file pvalink.h.

epics::pvData::PVField::const_shared_pointer pvalink::pvaLink::fld_value

Definition at line 211 of file pvalink.h.

epics::pvData::PVStructure::const_shared_pointer pvalink::pvaLink::fld_valueAlarm

Definition at line 215 of file pvalink.h.

std::tr1::shared_ptr<pvaLinkChannel> pvalink::pvaLink::lchan

Definition at line 204 of file pvalink.h.

size_t pvalink::pvaLink::num_instances

static

Definition at line 198 of file pvalink.h.

DBLINK* pvalink::pvaLink::plink

Definition at line 202 of file pvalink.h.

epics::pvData::BitSet pvalink::pvaLink::proc_changed

Definition at line 218 of file pvalink.h.

pvd::shared_vector<const void> pvalink::pvaLink::put_queue

Definition at line 207 of file pvalink.h.

pvd::shared_vector<const void> pvalink::pvaLink::put_scratch

Definition at line 207 of file pvalink.h.

short pvalink::pvaLink::snap_severity

Definition at line 224 of file pvalink.h.

epicsTimeStamp pvalink::pvaLink::snap_time

Definition at line 223 of file pvalink.h.

bool pvalink::pvaLink::used_queue

Definition at line 206 of file pvalink.h.

bool pvalink::pvaLink::used_scratch

Definition at line 206 of file pvalink.h.

---

The documentation for this struct was generated from the following files:

• modules/pva2pva/pdbApp/pvalink.h
• modules/pva2pva/pdbApp/pvalink_channel.cpp
• modules/pva2pva/pdbApp/pvalink_link.cpp