epics::pvaClient::PvaClientNTMultiPut Class Reference

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

#include "pvaClientMultiChannel.h"

Inheritance diagram for epics::pvaClient::PvaClientNTMultiPut:

Collaboration diagram for epics::pvaClient::PvaClientNTMultiPut:

Public Member Functions
	POINTER_DEFINITIONS (PvaClientNTMultiPut)
	~PvaClientNTMultiPut ()
void	connect ()
	Connect a channelPut for each channel. More...
epics::pvData::shared_vector< epics::pvData::PVUnionPtr >	getValues ()
	Get the value field of each channel as a union. More...
void	put ()
	Issue a put for each channel. '. More...
PvaClientNTMultiPutPtr	getPtrSelf ()
	Get the shared pointer to self. More...

Static Public Member Functions
static PvaClientNTMultiPutPtr	create (PvaClientMultiChannelPtr const &pvaClientMultiChannel, PvaClientChannelArray const &pvaClientChannelArray)
	Create a PvaClientNTMultiPut. More...

Detailed Description

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

Definition at line 401 of file pvaClientMultiChannel.h.

Constructor & Destructor Documentation

epics::pvaClient::PvaClientNTMultiPut::~PvaClientNTMultiPut

(

)

Definition at line 49 of file pvaClientNTMultiPut.cpp.

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

Member Function Documentation

void epics::pvaClient::PvaClientNTMultiPut::connect

(

)

Connect a channelPut for each channel.

Definition at line 54 of file pvaClientNTMultiPut.cpp.

{
    pvaClientPut.resize(nchannel);
    shared_vector<epics::pvData::boolean> isConnected = pvaClientMultiChannel->getIsConnected();
    for(size_t i=0; i<nchannel; ++i)
    {
         if(isConnected[i]) {
               pvaClientPut[i] = pvaClientChannelArray[i]->createPut();
               pvaClientPut[i]->issueConnect();
         }
    }
    for(size_t i=0; i<nchannel; ++i)
    {
         if(isConnected[i]) {
               Status status = pvaClientPut[i]->waitConnect();
               if(status.isOK()) continue;
               string message = string("channel ") +pvaClientChannelArray[i]->getChannelName()
                    + " PvaChannelPut::waitConnect " + status.getMessage();
               throw std::runtime_error(message);
         }
    }
    for(size_t i=0; i<nchannel; ++i)
    {
         if(isConnected[i]) {
              pvaClientPut[i]->issueGet();
         }
    }
    for(size_t i=0; i<nchannel; ++i)
    {
         if(isConnected[i]) {
               Status status = pvaClientPut[i]->waitGet();
               if(status.isOK()) continue;
               string message = string("channel ") +pvaClientChannelArray[i]->getChannelName()
                    + " PvaChannelPut::waitGet " + status.getMessage();
               throw std::runtime_error(message);
         }
    }
    FieldCreatePtr fieldCreate = getFieldCreate();
    PVDataCreatePtr pvDataCreate = getPVDataCreate();
    for(size_t i=0; i<nchannel; ++i)
    {
         if(isConnected[i]) {
             value[i] = pvaClientPut[i]->getData()->getValue();
             FieldBuilderPtr builder = fieldCreate->createFieldBuilder();
             builder->add("value",value[i]->getField());
             unionValue[i] = pvDataCreate->createPVUnion(builder->createUnion());
         }
    }
    this->isConnected = true;
}

PvaClientNTMultiPutPtr epics::pvaClient::PvaClientNTMultiPut::create ( PvaClientMultiChannelPtr const &  pvaClientMultiChannel, PvaClientChannelArray const &  pvaClientChannelArray  )

static

Create a PvaClientNTMultiPut.

Parameters

pvaClientMultiChannel	The interface to PvaClientMultiChannel.
pvaClientChannelArray	The PvaClientChannel array.

Returns

The interface.

Definition at line 27 of file pvaClientNTMultiPut.cpp.

{
    return PvaClientNTMultiPutPtr(
        new PvaClientNTMultiPut(pvaMultiChannel,pvaClientChannelArray));
}

PvaClientNTMultiPutPtr epics::pvaClient::PvaClientNTMultiPut::getPtrSelf ( )

inline

Get the shared pointer to self.

Returns

The shared pointer.

Definition at line 434 of file pvaClientMultiChannel.h.

    {
        return shared_from_this();
    }

shared_vector< epics::pvData::PVUnionPtr > epics::pvaClient::PvaClientNTMultiPut::getValues

(

)

Get the value field of each channel as a union.

Returns

A shared vector of union.

Definition at line 105 of file pvaClientNTMultiPut.cpp.

{
    if(!isConnected) connect();
    return unionValue;
}

epics::pvaClient::PvaClientNTMultiPut::POINTER_DEFINITIONS

(

PvaClientNTMultiPut

)

void epics::pvaClient::PvaClientNTMultiPut::put

(

)

Issue a put for each channel. '.

Definition at line 111 of file pvaClientNTMultiPut.cpp.

{
    if(!isConnected) connect();
    shared_vector<epics::pvData::boolean> isConnected = pvaClientMultiChannel->getIsConnected();
    for(size_t i=0; i<nchannel; ++i)
    {
         if(isConnected[i]) {
               value[i]->copy(*unionValue[i]->get());
               pvaClientPut[i]->issuePut();
         }
         if(isConnected[i]) {
              Status status = pvaClientPut[i]->waitPut();
              if(status.isOK())  continue;
              string message = string("channel ") +pvaClientChannelArray[i]->getChannelName()
                    + " PvaChannelPut::waitPut " + status.getMessage();
              throw std::runtime_error(message);
         }
    }
}

---

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

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