PDBSinglePV Struct Reference

#include "pdbsingle.h"

Inheritance diagram for PDBSinglePV:

Collaboration diagram for PDBSinglePV:

Public Types
typedef std::set< PDBSingleMonitor * >	interested_t
typedef std::set< BaseMonitor::shared_pointer >	interested_remove_t

Public Member Functions
	POINTER_DEFINITIONS (PDBSinglePV)
shared_pointer	shared_from_this ()
	PDBSinglePV (DBCH &chan, const PDBProvider::shared_pointer &prov)
virtual	~PDBSinglePV ()
void	activate ()
virtual epics::pvAccess::Channel::shared_pointer	connect (const std::tr1::shared_ptr< PDBProvider > &prov, const epics::pvAccess::ChannelRequester::shared_pointer &req) OVERRIDE FINAL
void	addMonitor (PDBSingleMonitor *)
void	removeMonitor (PDBSingleMonitor *)
void	finalizeMonitor ()
Public Member Functions inherited from PDBPV
	POINTER_DEFINITIONS (PDBPV)
	PDBPV ()
virtual	~PDBPV ()
virtual void	show (int lvl)

Public Attributes
weak_pointer	weakself
DBCH	chan
PDBProvider::shared_pointer	provider
epics::pvData::BitSet	scratch
epicsMutex	lock
p2p::auto_ptr< ScalarBuilder >	builder
p2p::auto_ptr< PVIF >	pvif
epics::pvData::PVStructurePtr	complete
bool	interested_iterating
interested_t	interested
interested_t	interested_add
interested_remove_t	interested_remove
DBEvent	evt_VALUE
DBEvent	evt_PROPERTY
bool	hadevent_VALUE
bool	hadevent_PROPERTY
Public Attributes inherited from PDBPV
epics::pvData::StructureConstPtr	fielddesc

Static Public Attributes
static size_t	num_instances

Detailed Description

Definition at line 23 of file pdbsingle.h.

Member Typedef Documentation

typedef std::set<BaseMonitor::shared_pointer> PDBSinglePV::interested_remove_t

Definition at line 52 of file pdbsingle.h.

typedef std::set<PDBSingleMonitor*> PDBSinglePV::interested_t

Definition at line 48 of file pdbsingle.h.

Constructor & Destructor Documentation

PDBSinglePV::PDBSinglePV	(	DBCH &	chan,
		const PDBProvider::shared_pointer &	prov
	)

Definition at line 96 of file pdbsingle.cpp.

    :provider(prov)
    ,builder(new ScalarBuilder)
    ,interested_iterating(false)
    ,evt_VALUE(this)
    ,evt_PROPERTY(this)
    ,hadevent_VALUE(false)
    ,hadevent_PROPERTY(false)
{
    this->chan.swap(chan);
    fielddesc = std::tr1::static_pointer_cast<const pvd::Structure>(builder->dtype(this->chan));

    complete = pvd::getPVDataCreate()->createPVStructure(fielddesc);
    FieldName temp;
    pvif.reset(builder->attach(this->chan, complete, temp));

    epics::atomic::increment(num_instances);
}

PDBSinglePV::~PDBSinglePV ( )

virtual

Definition at line 116 of file pdbsingle.cpp.

{
    epics::atomic::decrement(num_instances);
}

Member Function Documentation

void PDBSinglePV::activate

(

)

Definition at line 121 of file pdbsingle.cpp.

{
    evt_VALUE.create(provider->event_context, this->chan, &pdb_single_event, DBE_VALUE|DBE_ALARM);
    evt_PROPERTY.create(provider->event_context, this->chan, &pdb_single_event, DBE_PROPERTY);
}

void PDBSinglePV::addMonitor

(

PDBSingleMonitor *

mon

)

Definition at line 140 of file pdbsingle.cpp.

{
    Guard G(lock);
    if(interested.empty() && interested_add.empty()) {
        // first monitor
        // start subscription

        hadevent_VALUE = false;
        hadevent_PROPERTY = false;
        db_event_enable(evt_VALUE.subscript);
        db_event_enable(evt_PROPERTY.subscript);
        db_post_single_event(evt_VALUE.subscript);
        db_post_single_event(evt_PROPERTY.subscript);

    } else if(hadevent_VALUE && hadevent_PROPERTY) {
        // new subscriber and already had initial update
        mon->post(G);
    } // else new subscriber, but no initial update.  so just wait

    if(interested_iterating) {
        interested_add.insert(mon);
    } else {
        interested.insert(mon);
    }
}

pva::Channel::shared_pointer PDBSinglePV::connect ( const std::tr1::shared_ptr< PDBProvider > &  prov, const epics::pvAccess::ChannelRequester::shared_pointer &  req  )

virtual

Implements PDBPV.

Definition at line 128 of file pdbsingle.cpp.

{
    PDBSingleChannel::shared_pointer ret(new PDBSingleChannel(shared_from_this(), req));

    ret->cred.update(req);

    ret->aspvt.add(chan, ret->cred);

    return ret;
}

void PDBSinglePV::finalizeMonitor

(

)

Definition at line 183 of file pdbsingle.cpp.

{
    assert(!interested_iterating);

    if(interested.empty()) {
        db_event_disable(evt_VALUE.subscript);
        db_event_disable(evt_PROPERTY.subscript);
    }
}

PDBSinglePV::POINTER_DEFINITIONS

(

PDBSinglePV

)

void PDBSinglePV::removeMonitor

(

PDBSingleMonitor *

mon

)

Definition at line 166 of file pdbsingle.cpp.

{
    Guard G(lock);

    if(interested_add.erase(mon)) {
        // and+remove while iterating.  no-op

    } else if(interested_iterating) {
        // keep monitor alive while iterating
        interested_remove.insert(mon->shared_from_this());

    } else {
        interested.erase(mon);
        finalizeMonitor();
    }
}

shared_pointer PDBSinglePV::shared_from_this ( )

inline

Definition at line 27 of file pdbsingle.h.

{ return shared_pointer(weakself); }

Member Data Documentation

p2p::auto_ptr<ScalarBuilder> PDBSinglePV::builder

Definition at line 43 of file pdbsingle.h.

DBCH PDBSinglePV::chan

Definition at line 34 of file pdbsingle.h.

epics::pvData::PVStructurePtr PDBSinglePV::complete

Definition at line 46 of file pdbsingle.h.

DBEvent PDBSinglePV::evt_PROPERTY

Definition at line 55 of file pdbsingle.h.

DBEvent PDBSinglePV::evt_VALUE

Definition at line 55 of file pdbsingle.h.

bool PDBSinglePV::hadevent_PROPERTY

Definition at line 56 of file pdbsingle.h.

bool PDBSinglePV::hadevent_VALUE

Definition at line 56 of file pdbsingle.h.

interested_t PDBSinglePV::interested

Definition at line 50 of file pdbsingle.h.

interested_t PDBSinglePV::interested_add

Definition at line 50 of file pdbsingle.h.

bool PDBSinglePV::interested_iterating

Definition at line 49 of file pdbsingle.h.

interested_remove_t PDBSinglePV::interested_remove

Definition at line 53 of file pdbsingle.h.

epicsMutex PDBSinglePV::lock

Definition at line 41 of file pdbsingle.h.

size_t PDBSinglePV::num_instances

static

Definition at line 58 of file pdbsingle.h.

PDBProvider::shared_pointer PDBSinglePV::provider

Definition at line 35 of file pdbsingle.h.

p2p::auto_ptr<PVIF> PDBSinglePV::pvif

Definition at line 44 of file pdbsingle.h.

epics::pvData::BitSet PDBSinglePV::scratch

Definition at line 39 of file pdbsingle.h.

weak_pointer PDBSinglePV::weakself

Definition at line 26 of file pdbsingle.h.

---

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

• modules/pva2pva/pdbApp/pdbsingle.h
• modules/pva2pva/pdbApp/pdbsingle.cpp