TestPVMonitor Struct Reference

#include "utilities.h"

Inheritance diagram for TestPVMonitor:

Collaboration diagram for TestPVMonitor:

Public Member Functions
	POINTER_DEFINITIONS (TestPVMonitor)
	TestPVMonitor (const TestPVChannel::shared_pointer &ch, const epics::pvData::MonitorRequester::shared_pointer &req, size_t bsize)
virtual	~TestPVMonitor ()
virtual void	destroy ()
virtual epics::pvData::Status	start ()
virtual epics::pvData::Status	stop ()
virtual epics::pvData::MonitorElementPtr	poll ()
virtual void	release (epics::pvData::MonitorElementPtr const &monitorElement)
Public Member Functions inherited from epics::pvAccess::Monitor
	POINTER_DEFINITIONS (Monitor)
virtual	~Monitor ()
virtual void	release (MonitorElementPtr const &monitorElement)=0
virtual void	getStats (Stats &s) const
virtual void	reportRemoteQueueStatus (epics::pvData::int32 freeElements)
Public Member Functions inherited from epics::pvAccess::Destroyable
	POINTER_DEFINITIONS (Destroyable)

Public Attributes
std::tr1::weak_ptr< TestPVMonitor >	weakself
const TestPVChannel::shared_pointer	channel
const epics::pvData::MonitorRequester::weak_pointer	requester
bool	running
bool	finalize
bool	inoverflow
bool	needWakeup
std::deque< epics::pvData::MonitorElementPtr >	buffer
std::deque< epics::pvData::MonitorElementPtr >	free
epics::pvData::MonitorElementPtr	overflow

Additional Inherited Members
Public Types inherited from epics::pvAccess::Monitor
typedef MonitorRequester	requester_type
Protected Member Functions inherited from epics::pvAccess::Destroyable
virtual	~Destroyable ()

Detailed Description

Definition at line 210 of file utilities.h.

Constructor & Destructor Documentation

TestPVMonitor::TestPVMonitor	(	const TestPVChannel::shared_pointer &	ch,
		const epics::pvData::MonitorRequester::shared_pointer &	req,
		size_t	bsize
	)

Definition at line 267 of file utilities.cpp.

    :channel(ch)
    ,requester(req)
    ,running(false)
    ,finalize(false)
    ,inoverflow(false)
    ,needWakeup(false)
{
    pvd::PVDataCreatePtr fact(pvd::PVDataCreate::getPVDataCreate());
    for(size_t i=0; i<bsize; i++) {
        pva::MonitorElementPtr elem(new pvd::MonitorElement(fact->createPVStructure(channel->pv->dtype)));
        free.push_back(elem);
    }
    overflow.reset(new pvd::MonitorElement(fact->createPVStructure(channel->pv->dtype)));
    overflow->changedBitSet->set(0); // initially all changed
    epicsAtomicIncrSizeT(&countTestPVMonitor);
}

TestPVMonitor::~TestPVMonitor ( )

virtual

Definition at line 287 of file utilities.cpp.

{
    epicsAtomicDecrSizeT(&countTestPVMonitor);
}

Member Function Documentation

void TestPVMonitor::destroy ( )

virtual

Destroy this instance.

Implements epics::pvAccess::Destroyable.

Definition at line 292 of file utilities.cpp.

{
    Guard G(channel->pv->lock);

    shared_pointer self(weakself);
    channel->monitors.erase(self); // ensure we don't get more notifications
}

TestPVMonitor::POINTER_DEFINITIONS

(

TestPVMonitor

)

pva::MonitorElementPtr TestPVMonitor::poll ( )

virtual

If monitor has occurred return data.

Returns

monitorElement for modified data. Must call get to determine if data is available.

May recursively call MonitorRequester::unlisten()

Implements epics::pvAccess::Monitor.

Definition at line 356 of file utilities.cpp.

{
    pva::MonitorElementPtr ret;
    Guard G(channel->pv->lock);
    if(!buffer.empty()) {
        ret = buffer.front();
        buffer.pop_front();
    }
    testDiag("TestPVMonitor::poll %p %p", this, ret.get());
    return ret;
}

void TestPVMonitor::release ( epics::pvData::MonitorElementPtr const &  monitorElement )

virtual

Definition at line 368 of file utilities.cpp.

{
    Guard G(channel->pv->lock);
    testDiag("TestPVMonitor::release %p %p", this, monitorElement.get());

    if(inoverflow) {
        // buffer.empty() may be true if all elements poll()d by user
        assert(this->free.empty());

        monitorElement->pvStructurePtr->copyUnchecked(*overflow->pvStructurePtr);
        *monitorElement->changedBitSet = *overflow->changedBitSet;
        *monitorElement->overrunBitSet = *overflow->overrunBitSet;

        overflow->changedBitSet->clear();
        overflow->overrunBitSet->clear();

        buffer.push_back(monitorElement);
        testDiag("TestPVMonitor::release overflow resume %p %p", this, monitorElement.get());
        inoverflow = false;
    } else {
        this->free.push_back(monitorElement);
    }
}

pvd::Status TestPVMonitor::start ( )

virtual

Start monitoring.

Returns

completion status.

Implements epics::pvAccess::Monitor.

Definition at line 300 of file utilities.cpp.

{
    testDiag("TestPVMonitor::start %p", this);

    Guard G(channel->pv->lock);
    if(finalize && buffer.empty())
        return pvd::Status();

    if(running)
        return pvd::Status();
    running = true;

    // overflow element does double duty to hold this monitor's copy
    overflow->pvStructurePtr->copyUnchecked(*channel->pv->value);

    if(this->buffer.empty()) {
        needWakeup = true;
        testDiag(" need wakeup");
    }

    if(!this->free.empty()) {
        pva::MonitorElementPtr monitorElement(this->free.front());

        if(overflow->changedBitSet->isEmpty()) {
            overflow->changedBitSet->set(0); // initial update has all changed
            overflow->overrunBitSet->clear();
        }

        monitorElement->pvStructurePtr->copyUnchecked(*overflow->pvStructurePtr);
        *monitorElement->changedBitSet = *overflow->changedBitSet;
        *monitorElement->overrunBitSet = *overflow->overrunBitSet;
        overflow->changedBitSet->clear();
        overflow->overrunBitSet->clear();

        buffer.push_back(monitorElement);
        this->free.pop_front();
        testDiag(" push current");

    } else {
        inoverflow = true;
        overflow->changedBitSet->clear();
        overflow->changedBitSet->set(0);
        testDiag(" push overflow");
    }

    return pvd::Status();
}

pvd::Status TestPVMonitor::stop ( )

virtual

Stop Monitoring.

Returns

completion status.

Implements epics::pvAccess::Monitor.

Definition at line 348 of file utilities.cpp.

{
    testDiag("TestPVMonitor::stop %p", this);
    Guard G(channel->pv->lock);
    running = false;
    return pvd::Status();
}

Member Data Documentation

std::deque<epics::pvData::MonitorElementPtr> TestPVMonitor::buffer

Definition at line 235 of file utilities.h.

const TestPVChannel::shared_pointer TestPVMonitor::channel

Definition at line 215 of file utilities.h.

bool TestPVMonitor::finalize

Definition at line 219 of file utilities.h.

std::deque<epics::pvData::MonitorElementPtr> TestPVMonitor::free

Definition at line 235 of file utilities.h.

bool TestPVMonitor::inoverflow

Definition at line 220 of file utilities.h.

bool TestPVMonitor::needWakeup

Definition at line 221 of file utilities.h.

epics::pvData::MonitorElementPtr TestPVMonitor::overflow

Definition at line 236 of file utilities.h.

const epics::pvData::MonitorRequester::weak_pointer TestPVMonitor::requester

Definition at line 216 of file utilities.h.

bool TestPVMonitor::running

Definition at line 218 of file utilities.h.

std::tr1::weak_ptr<TestPVMonitor> TestPVMonitor::weakself

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