PDBGroupPV Struct Reference

Inheritance diagram for PDBGroupPV:

Collaboration diagram for PDBGroupPV:

Classes
struct	Info

Public Types
typedef epics::pvData::shared_vector< Info >	members_t
typedef std::set< PDBGroupMonitor * >	interested_t
typedef std::set< BaseMonitor::shared_pointer >	interested_remove_t

Public Member Functions
	POINTER_DEFINITIONS (PDBGroupPV)
shared_pointer	shared_from_this ()
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 (PDBGroupMonitor *)
void	removeMonitor (PDBGroupMonitor *)
void	finalizeMonitor ()
virtual void	show (int lvl) OVERRIDE
Public Member Functions inherited from PDBPV
	POINTER_DEFINITIONS (PDBPV)

Public Attributes
weak_pointer	weakself
epics::pvData::BitSet	scratch
epicsMutex	lock
bool	pgatomic
bool	monatomic
std::string	name
members_t	members
DBManyLock	locker
epics::pvData::PVStructurePtr	complete
bool	interested_iterating
interested_t	interested
interested_t	interested_add
interested_remove_t	interested_remove
size_t	initial_waits
Public Attributes inherited from PDBPV
epics::pvData::StructureConstPtr	fielddesc

Static Public Attributes
static size_t	num_instances

Detailed Description

Definition at line 71 of file pdbgroup.h.

Member Typedef Documentation

interested_remove_t

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

Definition at line 114 of file pdbgroup.h.

interested_t

typedef std::set<PDBGroupMonitor*> PDBGroupPV::interested_t

Definition at line 110 of file pdbgroup.h.

members_t

typedef epics::pvData::shared_vector<Info> PDBGroupPV::members_t

Definition at line 103 of file pdbgroup.h.

Constructor & Destructor Documentation

PDBGroupPV()

PDBGroupPV::PDBGroupPV

(

)

Definition at line 123 of file pdbgroup.cpp.

    :pgatomic(false)
    ,monatomic(false)
    ,interested_iterating(false)
    ,initial_waits(0)
{
    epics::atomic::increment(num_instances);
}

~PDBGroupPV()

PDBGroupPV::~PDBGroupPV ( )

virtual

Definition at line 132 of file pdbgroup.cpp.

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

Member Function Documentation

addMonitor()

void PDBGroupPV::addMonitor

(

PDBGroupMonitor *

mon

)

Definition at line 155 of file pdbgroup.cpp.

{
    Guard G(lock);
    if(interested.empty() && interested_add.empty()) {
        // first monitor
        // start subscriptions
 
        size_t ievts = 0;
        for(size_t i=0; i<members.size(); i++) {
            PDBGroupPV::Info& info = members[i];
 
            if(!!info.evt_VALUE) {
                db_event_enable(info.evt_VALUE.subscript);
                db_post_single_event(info.evt_VALUE.subscript);
                ievts++;
                info.had_initial_VALUE = false;
            } else {
                info.had_initial_VALUE = true;
            }
            assert(info.evt_PROPERTY.subscript);
            db_event_enable(info.evt_PROPERTY.subscript);
            db_post_single_event(info.evt_PROPERTY.subscript);
            ievts++;
            info.had_initial_PROPERTY = false;
        }
        initial_waits = ievts;
 
    } else if(initial_waits==0) {
        // 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);
}

connect()

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

virtual

Implements PDBPV.

Definition at line 138 of file pdbgroup.cpp.

{
    PDBGroupChannel::shared_pointer ret(new PDBGroupChannel(shared_from_this(), prov, req));
 
    ret->cred.update(req);
 
    ret->aspvt.resize(members.size());
    for(size_t i=0, N=members.size(); i<N; i++)
    {
        ret->aspvt[i].add(members[i].chan, ret->cred);
    }
 
    return ret;
}

finalizeMonitor()

void PDBGroupPV::finalizeMonitor

(

)

Definition at line 212 of file pdbgroup.cpp.

{
    assert(!interested_iterating);
 
    if(!interested.empty())
        return;
 
    // last subscriber
    for(size_t i=0; i<members.size(); i++) {
        PDBGroupPV::Info& info = members[i];
 
        if(!!info.evt_VALUE) {
            db_event_disable(info.evt_VALUE.subscript);
        }
        db_event_disable(info.evt_PROPERTY.subscript);
    }
}

removeMonitor()

void PDBGroupPV::removeMonitor

(

PDBGroupMonitor *

mon

)

Definition at line 194 of file pdbgroup.cpp.

{
    Guard G(lock);
 
    if(interested_add.erase(mon)) {
        // and+remove while iterating.  no-op
 
    } else if(interested_iterating) {
        // keep the monitor alive until we've finished iterating
        interested_remove.insert(mon->shared_from_this());
 
    } else {
        interested.erase(mon);
        finalizeMonitor();
    }
}

shared_from_this()

shared_pointer PDBGroupPV::shared_from_this ( )

inline

Definition at line 75 of file pdbgroup.h.

{ return shared_pointer(weakself); }

show()

void PDBGroupPV::show ( int lvl )

virtual

Reimplemented from PDBPV.

Definition at line 230 of file pdbgroup.cpp.

{
    // no locking as we only print things which are const after initialization
 
    printf("  Atomic Get/Put:%s Monitor:%s Members:%zu\n",
           pgatomic?"yes":"no", monatomic?"yes":"no", members.size());
 
    if(lvl<=1)
        return;
 
    for(members_t::const_iterator it(members.begin()), end(members.end());
        it != end; ++it)
    {
        const Info& info = *it;
        printf("  ");
        info.attachment.show(); // printf()s
        printf("\t<-> %s\n", dbChannelName(info.chan));
    }
}

Member Data Documentation

complete

epics::pvData::PVStructurePtr PDBGroupPV::complete

Definition at line 108 of file pdbgroup.h.

initial_waits

size_t PDBGroupPV::initial_waits

Definition at line 117 of file pdbgroup.h.

interested

interested_t PDBGroupPV::interested

Definition at line 112 of file pdbgroup.h.

interested_add

interested_t PDBGroupPV::interested_add

Definition at line 112 of file pdbgroup.h.

interested_iterating

bool PDBGroupPV::interested_iterating

Definition at line 111 of file pdbgroup.h.

interested_remove

interested_remove_t PDBGroupPV::interested_remove

Definition at line 115 of file pdbgroup.h.

lock

epicsMutex PDBGroupPV::lock

Definition at line 81 of file pdbgroup.h.

locker

DBManyLock PDBGroupPV::locker

Definition at line 106 of file pdbgroup.h.

members

members_t PDBGroupPV::members

Definition at line 104 of file pdbgroup.h.

monatomic

bool PDBGroupPV::monatomic

Definition at line 83 of file pdbgroup.h.

name

std::string PDBGroupPV::name

Definition at line 86 of file pdbgroup.h.

num_instances

size_t PDBGroupPV::num_instances

static

Definition at line 119 of file pdbgroup.h.

pgatomic

bool PDBGroupPV::pgatomic

Definition at line 83 of file pdbgroup.h.

scratch

epics::pvData::BitSet PDBGroupPV::scratch

Definition at line 79 of file pdbgroup.h.

weakself

weak_pointer PDBGroupPV::weakself

Definition at line 74 of file pdbgroup.h.

---

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

• pdbApp/pdbgroup.h
• pdbApp/pdbgroup.cpp