#include "pdbgroup.h"

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 ()

	PDBGroupPV ()

virtual	~PDBGroupPV ()

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)

	PDBPV ()

virtual	~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 73 of file pdbgroup.h.

Member Typedef Documentation

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

Definition at line 114 of file pdbgroup.h.

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

Definition at line 110 of file pdbgroup.h.

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

Definition at line 103 of file pdbgroup.h.

Constructor & Destructor Documentation

PDBGroupPV::PDBGroupPV ( )

Definition at line 122 of file pdbgroup.cpp.

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

PDBGroupPV::~PDBGroupPV ( )

virtual

Definition at line 131 of file pdbgroup.cpp.

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

Member Function Documentation

void PDBGroupPV::addMonitor ( PDBGroupMonitor * mon )

Definition at line 154 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);
 }

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 137 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;
 }

void PDBGroupPV::finalizeMonitor ( )

Definition at line 211 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);
     }
 }

PDBGroupPV::POINTER_DEFINITIONS ( PDBGroupPV )

void PDBGroupPV::removeMonitor ( PDBGroupMonitor * mon )

Definition at line 193 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_pointer PDBGroupPV::shared_from_this ( )

inline

Definition at line 77 of file pdbgroup.h.

77 { return shared_pointer(weakself); }

PDBGroupPV::weakself

weak_pointer weakself

Definition: pdbgroup.h:76

void PDBGroupPV::show ( int lvl )

virtual

Reimplemented from PDBPV.

Definition at line 229 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

epics::pvData::PVStructurePtr PDBGroupPV::complete

Definition at line 108 of file pdbgroup.h.

size_t PDBGroupPV::initial_waits

Definition at line 117 of file pdbgroup.h.

interested_t PDBGroupPV::interested

Definition at line 112 of file pdbgroup.h.

interested_t PDBGroupPV::interested_add

Definition at line 112 of file pdbgroup.h.

bool PDBGroupPV::interested_iterating

Definition at line 111 of file pdbgroup.h.

interested_remove_t PDBGroupPV::interested_remove

Definition at line 115 of file pdbgroup.h.

epicsMutex PDBGroupPV::lock

Definition at line 83 of file pdbgroup.h.

DBManyLock PDBGroupPV::locker

Definition at line 106 of file pdbgroup.h.

members_t PDBGroupPV::members

Definition at line 104 of file pdbgroup.h.

bool PDBGroupPV::monatomic

Definition at line 85 of file pdbgroup.h.

std::string PDBGroupPV::name

Definition at line 88 of file pdbgroup.h.

size_t PDBGroupPV::num_instances

static

Definition at line 119 of file pdbgroup.h.

bool PDBGroupPV::pgatomic

Definition at line 85 of file pdbgroup.h.

epics::pvData::BitSet PDBGroupPV::scratch

Definition at line 81 of file pdbgroup.h.

weak_pointer PDBGroupPV::weakself

Definition at line 76 of file pdbgroup.h.

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

modules/pva2pva/pdbApp/pdbgroup.h
modules/pva2pva/pdbApp/pdbgroup.cpp

Classes

Public Types

Public Member Functions

Public Attributes

Static Public Attributes

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation