TestPVMonitor Struct Reference

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

Detailed Description

Definition at line 220 of file utilities.h.

Constructor & Destructor Documentation

TestPVMonitor()

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::~TestPVMonitor ( )

virtual

Definition at line 287 of file utilities.cpp.

{
    epicsAtomicDecrSizeT(&countTestPVMonitor);
}

Member Function Documentation

destroy()

void TestPVMonitor::destroy ( )

virtual

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
}

poll()

pva::MonitorElementPtr TestPVMonitor::poll ( )

virtual

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

release()

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

start()

pvd::Status TestPVMonitor::start ( )

virtual

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

stop()

pvd::Status TestPVMonitor::stop ( )

virtual

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

buffer

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

Definition at line 245 of file utilities.h.

channel

const TestPVChannel::shared_pointer TestPVMonitor::channel

Definition at line 225 of file utilities.h.

finalize

bool TestPVMonitor::finalize

Definition at line 229 of file utilities.h.

free

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

Definition at line 245 of file utilities.h.

inoverflow

bool TestPVMonitor::inoverflow

Definition at line 230 of file utilities.h.

needWakeup

bool TestPVMonitor::needWakeup

Definition at line 231 of file utilities.h.

overflow

epics::pvData::MonitorElementPtr TestPVMonitor::overflow

Definition at line 246 of file utilities.h.

requester

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

Definition at line 226 of file utilities.h.

running

bool TestPVMonitor::running

Definition at line 228 of file utilities.h.

weakself

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

Definition at line 223 of file utilities.h.

---

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

• common/utilities.h
• common/utilities.cpp