epics::pvaClient::PvaClientNTMultiMonitor Class Reference

Provides channel monitor to multiple channels where the value field of each channel is presented as a union. More...

#include "pvaClientMultiChannel.h"

Inheritance diagram for epics::pvaClient::PvaClientNTMultiMonitor:

Collaboration diagram for epics::pvaClient::PvaClientNTMultiMonitor:

Public Member Functions
	POINTER_DEFINITIONS (PvaClientNTMultiMonitor)
	~PvaClientNTMultiMonitor ()
void	connect ()
	Connect to a channel monitor for each channel. More...
bool	poll (bool valueOnly=true)
	Poll each channel. More...
bool	waitEvent (double secondsToWait)
	Wait until poll returns true. More...
PvaClientNTMultiDataPtr	getData ()
	Get the data for the last successfull poll. More...
PvaClientNTMultiMonitorPtr	getPtrSelf ()

Static Public Member Functions
static PvaClientNTMultiMonitorPtr	create (PvaClientMultiChannelPtr const &pvaClientMultiChannel, PvaClientChannelArray const &pvaClientChannelArray, epics::pvData::PVStructurePtr const &pvRequest)
	Create a PvaClientNTMultiMonitor. More...

Detailed Description

Provides channel monitor to multiple channels where the value field of each channel is presented as a union.

Definition at line 457 of file pvaClientMultiChannel.h.

Constructor & Destructor Documentation

epics::pvaClient::PvaClientNTMultiMonitor::~PvaClientNTMultiMonitor

(

)

Definition at line 60 of file pvaClientNTMultiMonitor.cpp.

{
    if(PvaClient::getDebug()) cout<< "PvaClientNTMultiMonitor::~PvaClientNTMultiMonitor()\n";
}

Member Function Documentation

void epics::pvaClient::PvaClientNTMultiMonitor::connect

(

)

Connect to a channel monitor for each channel.

Definition at line 66 of file pvaClientNTMultiMonitor.cpp.

{
    pvaClientMonitor.resize(nchannel);
    shared_vector<epics::pvData::boolean> isConnected = pvaClientMultiChannel->getIsConnected();
    for(size_t i=0; i<nchannel; ++i)
    {
         if(isConnected[i]) {
               pvaClientMonitor[i] = pvaClientChannelArray[i]->createMonitor(pvRequest);
               pvaClientMonitor[i]->issueConnect();
         }
    }
    for(size_t i=0; i<nchannel; ++i)
    {
         if(isConnected[i]) {
               Status status = pvaClientMonitor[i]->waitConnect();
               if(status.isOK()) continue;
               string message = string("channel ") +pvaClientChannelArray[i]->getChannelName()
                    + " PvaChannelMonitor::waitConnect " + status.getMessage();
               throw std::runtime_error(message);
         }
    }
    for(size_t i=0; i<nchannel; ++i)
    {
         if(isConnected[i]) pvaClientMonitor[i]->start();
    }
    this->isConnected = true;
}

PvaClientNTMultiMonitorPtr epics::pvaClient::PvaClientNTMultiMonitor::create ( PvaClientMultiChannelPtr const &  pvaClientMultiChannel, PvaClientChannelArray const &  pvaClientChannelArray, epics::pvData::PVStructurePtr const &  pvRequest  )

static

Create a PvaClientNTMultiMonitor.

Parameters

pvaClientMultiChannel	The interface to PvaClientMultiChannel.
pvaClientChannelArray	The PvaClientChannel array.
pvRequest	The pvRequest for each channel.

Returns

The interface.

Definition at line 28 of file pvaClientNTMultiMonitor.cpp.

{
    UnionConstPtr u = getFieldCreate()->createVariantUnion();
    PvaClientNTMultiMonitorPtr pvaClientNTMultiMonitor(
         new PvaClientNTMultiMonitor(u,pvaMultiChannel,pvaClientChannelArray,pvRequest));
    return pvaClientNTMultiMonitor;
}

PvaClientNTMultiDataPtr epics::pvaClient::PvaClientNTMultiMonitor::getData

(

)

Get the data for the last successfull poll.

Returns

the pvaClientNTMultiData.

Definition at line 131 of file pvaClientNTMultiMonitor.cpp.

{
    return pvaClientNTMultiData;
}

PvaClientNTMultiMonitorPtr epics::pvaClient::PvaClientNTMultiMonitor::getPtrSelf ( )

inline

Monitor the shared pointer to self.

Returns

The shared pointer.

Definition at line 501 of file pvaClientMultiChannel.h.

    {
        return shared_from_this();
    }

epics::pvaClient::PvaClientNTMultiMonitor::POINTER_DEFINITIONS

(

PvaClientNTMultiMonitor

)

bool epics::pvaClient::PvaClientNTMultiMonitor::poll

(

bool

valueOnly = true

)

Poll each channel.

Parameters

valueOnly

use only value for union. If any has new data it is used to update the double[].

Returns

(false,true) if (no, at least one) value was updated.

Definition at line 94 of file pvaClientNTMultiMonitor.cpp.

{
    if(!isConnected) connect();
    bool result = false;
    shared_vector<epics::pvData::boolean> isConnected = pvaClientMultiChannel->getIsConnected();
    pvaClientNTMultiData->startDeltaTime();
    for(size_t i=0; i<nchannel; ++i)
    {
         if(isConnected[i]) {
              if(pvaClientMonitor[i]->poll()) {
                   pvaClientNTMultiData->setPVStructure(
                       pvaClientMonitor[i]->getData()->getPVStructure(),i);
                   pvaClientMonitor[i]->releaseEvent();
                   result = true;
              }
         }
    }
    if(result) pvaClientNTMultiData->endDeltaTime(valueOnly);
    return result;
}

bool epics::pvaClient::PvaClientNTMultiMonitor::waitEvent

(

double

secondsToWait

)

Wait until poll returns true.

Parameters

secondsToWait

The time to keep trying. A thread sleep of .1 seconds occurs between each call to poll.

Returns

(false,true) if (timeOut, poll returned true).

Definition at line 115 of file pvaClientNTMultiMonitor.cpp.

{
    if(poll()) return true;
    TimeStamp start;
    start.getCurrent();
    TimeStamp now;
    while(true) {
          epicsThreadSleep(.1);
          if(poll()) return true;
          now.getCurrent();
          double diff = TimeStamp::diff(now,start);
          if(diff>=waitForEvent) break;
    }
    return false;
}

---

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

• modules/pvaClient/src/pv/pvaClientMultiChannel.h
• modules/pvaClient/src/pvaClientNTMultiMonitor.cpp