153 lines
4.3 KiB
C++
153 lines
4.3 KiB
C++
/* pvaClientNTMultiMonitor.cpp */
|
|
/**
|
|
* Copyright - See the COPYRIGHT that is included with this distribution.
|
|
* EPICS pvData is distributed subject to a Software License Agreement found
|
|
* in file LICENSE that is included with this distribution.
|
|
*/
|
|
/**
|
|
* @author mrk
|
|
* @date 2015.03
|
|
*/
|
|
|
|
#include <epicsThread.h>
|
|
#include <pv/standardField.h>
|
|
#include <pv/convert.h>
|
|
#include <epicsMath.h>
|
|
|
|
#define epicsExportSharedSymbols
|
|
|
|
#include <pv/pvaClientMultiChannel.h>
|
|
|
|
using std::tr1::static_pointer_cast;
|
|
using namespace epics::pvData;
|
|
using namespace epics::pvAccess;
|
|
using namespace epics::nt;
|
|
using namespace std;
|
|
|
|
namespace epics { namespace pvaClient {
|
|
|
|
static FieldCreatePtr fieldCreate = getFieldCreate();
|
|
|
|
PvaClientNTMultiMonitorPtr PvaClientNTMultiMonitor::create(
|
|
PvaClientMultiChannelPtr const &pvaMultiChannel,
|
|
PvaClientChannelArray const &pvaClientChannelArray,
|
|
epics::pvData::PVStructurePtr const & pvRequest)
|
|
{
|
|
UnionConstPtr u = fieldCreate->createVariantUnion();
|
|
PvaClientNTMultiMonitorPtr pvaClientNTMultiMonitor(
|
|
new PvaClientNTMultiMonitor(u,pvaMultiChannel,pvaClientChannelArray,pvRequest));
|
|
return pvaClientNTMultiMonitor;
|
|
}
|
|
|
|
PvaClientNTMultiMonitor::PvaClientNTMultiMonitor(
|
|
UnionConstPtr const & u,
|
|
PvaClientMultiChannelPtr const &pvaClientMultiChannel,
|
|
PvaClientChannelArray const &pvaClientChannelArray,
|
|
PVStructurePtr const & pvRequest)
|
|
: pvaClientMultiChannel(pvaClientMultiChannel),
|
|
pvaClientChannelArray(pvaClientChannelArray),
|
|
pvRequest(pvRequest),
|
|
nchannel(pvaClientChannelArray.size()),
|
|
pvaClientNTMultiData(
|
|
PvaClientNTMultiData::create(
|
|
u,
|
|
pvaClientMultiChannel,
|
|
pvaClientChannelArray,
|
|
pvRequest)),
|
|
isConnected(false),
|
|
isDestroyed(false)
|
|
{
|
|
}
|
|
|
|
|
|
PvaClientNTMultiMonitor::~PvaClientNTMultiMonitor()
|
|
{
|
|
destroy();
|
|
}
|
|
|
|
void PvaClientNTMultiMonitor::destroy()
|
|
{
|
|
{
|
|
Lock xx(mutex);
|
|
if(isDestroyed) return;
|
|
isDestroyed = true;
|
|
}
|
|
pvaClientChannelArray.clear();
|
|
}
|
|
|
|
|
|
void PvaClientNTMultiMonitor::connect()
|
|
{
|
|
pvaClientMonitor.resize(nchannel);
|
|
shared_vector<epics::pvData::boolean> isConnected = pvaClientMultiChannel->getIsConnected();
|
|
string request = "value";
|
|
if(pvRequest->getSubField("field.alarm")) request += ",alarm";
|
|
if(pvRequest->getSubField("field.timeStamp")) request += ",timeStamp";
|
|
for(size_t i=0; i<nchannel; ++i)
|
|
{
|
|
if(isConnected[i]) {
|
|
pvaClientMonitor[i] = pvaClientChannelArray[i]->createMonitor(request);
|
|
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;
|
|
}
|
|
|
|
bool PvaClientNTMultiMonitor::poll()
|
|
{
|
|
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();
|
|
return result;
|
|
}
|
|
|
|
bool PvaClientNTMultiMonitor::waitEvent(double waitForEvent)
|
|
{
|
|
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;
|
|
}
|
|
|
|
PvaClientNTMultiDataPtr PvaClientNTMultiMonitor::getData()
|
|
{
|
|
return pvaClientNTMultiData;
|
|
}
|
|
|
|
}}
|