#include "utilities.h"

Collaboration diagram for TestPV:

Public Types
typedef weak_set< TestPVChannel >	channels_t

Public Member Functions
	POINTER_DEFINITIONS (TestPV)

	TestPV (const std::string &name, const std::tr1::shared_ptr< TestProvider > &provider, const epics::pvData::StructureConstPtr &dtype)

	~TestPV ()

void	post (bool notify=true)

void	post (const epics::pvData::BitSet &changed, bool notify=true)

void	disconnect ()

Public Attributes
std::tr1::weak_ptr< TestPV >	weakself

const std::string	name

std::tr1::weak_ptr< TestProvider > const	provider

epics::pvData::PVDataCreatePtr	factory

const epics::pvData::StructureConstPtr	dtype

epics::pvData::PVStructurePtr	value

epicsMutex	lock

channels_t	channels

Friends
struct	TestProvider

Detailed Description

Definition at line 239 of file utilities.h.

Member Typedef Documentation

typedef weak_set<TestPVChannel> TestPV::channels_t

Definition at line 264 of file utilities.h.

Constructor & Destructor Documentation

TestPV::TestPV	(	const std::string &	name,
		const std::tr1::shared_ptr< TestProvider > &	provider,
		const epics::pvData::StructureConstPtr &	dtype
	)

Definition at line 394 of file utilities.cpp.

     :name(name)
     ,provider(provider)
     ,factory(pvd::PVDataCreate::getPVDataCreate())
     ,dtype(dtype)
     ,value(factory->createPVStructure(dtype))
 {
     epicsAtomicIncrSizeT(&countTestPV);
 }

TestPV::~TestPV ( )

Definition at line 406 of file utilities.cpp.

 {
     epicsAtomicDecrSizeT(&countTestPV);
 }

Member Function Documentation

void TestPV::disconnect ( )

Definition at line 479 of file utilities.cpp.

 {
     Guard G(lock);
     channels_t::vector_type toupdate(channels.lock_vector());
 
     FOREACH(channels_t::vector_type::const_iterator, it, end, toupdate) // channel
     {
         TestPVChannel *chan = it->get();
 
         chan->state = TestPVChannel::DISCONNECTED;
         {
             pva::ChannelRequester::shared_pointer req(chan->requester.lock());
             UnGuard U(G);
             if(req)
                 req->channelStateChange(*it, TestPVChannel::DISCONNECTED);
         }
     }
 }

TestPV::POINTER_DEFINITIONS ( TestPV )

void TestPV::post ( bool notify = true )

Definition at line 411 of file utilities.cpp.

 {
     pvd::BitSet changed;
     changed.set(0); // all
     post(changed, notify);
 }

void TestPV::post	(	const epics::pvData::BitSet &	changed,
		bool	notify = `true`
	)

Definition at line 418 of file utilities.cpp.

 {
     testDiag("post %s %d changed '%s'", name.c_str(), (int)notify, toString(changed).c_str());
     Guard G(lock);
 
     channels_t::vector_type toupdate(channels.lock_vector());
 
     FOREACH(channels_t::vector_type::const_iterator, it, end, toupdate) // channel
     {
         TestPVChannel *chan = it->get();
 
         TestPVChannel::monitors_t::vector_type tomon(chan->monitors.lock_vector());
         FOREACH(TestPVChannel::monitors_t::vector_type::const_iterator, it2, end2, tomon) // monitor/subscription
         {
             TestPVMonitor *mon = it2->get();
 
             if(!mon->running)
                 continue;
 
             mon->overflow->pvStructurePtr->copyUnchecked(*value, changed);
 
             if(mon->free.empty()) {
                 mon->inoverflow = true;
                 mon->overflow->overrunBitSet->or_and(*mon->overflow->changedBitSet, changed); // oflow |= prev_changed & new_changed
                 *mon->overflow->changedBitSet |= changed;
                 testDiag("overflow changed '%s' overrun '%s'",
                          toString(*mon->overflow->changedBitSet).c_str(),
                          toString(*mon->overflow->overrunBitSet).c_str());
 
             } else {
                 assert(!mon->inoverflow);
 
                 if(mon->buffer.empty())
                     mon->needWakeup = true;
 
                 pvd::MonitorElementPtr& elem(mon->free.front());
                 // Note: can't use 'changed' to optimize this copy since we don't know
                 //       the state of the free element
                 elem->pvStructurePtr->copyUnchecked(*mon->overflow->pvStructurePtr);
                 *elem->changedBitSet = changed;
                 elem->overrunBitSet->clear(); // redundant/paranoia
 
                 mon->buffer.push_back(elem);
                 mon->free.pop_front();
                 testDiag("push %p changed '%s' overflow '%s'", elem.get(),
                          toString(*elem->changedBitSet).c_str(),
                          toString(*elem->overrunBitSet).c_str());
             }
 
             if(mon->needWakeup && notify) {
                 testDiag(" wakeup");
                 mon->needWakeup = false;
                 pva::MonitorRequester::shared_pointer req(mon->requester.lock());
                 UnGuard U(G);
                 if(req)
                     req->monitorEvent(*it2);
             }
         }
     }
 }

Friends And Related Function Documentation

friend struct TestProvider

friend

Definition at line 266 of file utilities.h.

Member Data Documentation

channels_t TestPV::channels

Definition at line 265 of file utilities.h.

const epics::pvData::StructureConstPtr TestPV::dtype

Definition at line 249 of file utilities.h.

epics::pvData::PVDataCreatePtr TestPV::factory

Definition at line 247 of file utilities.h.

epicsMutex TestPV::lock

mutable

Definition at line 262 of file utilities.h.

const std::string TestPV::name

Definition at line 244 of file utilities.h.

std::tr1::weak_ptr<TestProvider> const TestPV::provider

Definition at line 245 of file utilities.h.

epics::pvData::PVStructurePtr TestPV::value

Definition at line 250 of file utilities.h.

std::tr1::weak_ptr<TestPV> TestPV::weakself

Definition at line 242 of file utilities.h.

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

modules/pva2pva/common/utilities.h
modules/pva2pva/common/utilities.cpp

Public Types

Public Member Functions