CAFEBS::BSDataHolder Class Reference

#include <zbsDataHolders.h>

List of all members.

Public Member Functions

 ~BSDataHolder ()
 BSDataHolder ()
 BSDataHolder (std::vector< std::string > _pv, std::vector< unsigned int > _handle)
 BSDataHolder (std::vector< std::string > _pv)
void init (std::vector< std::string > _pv)
unsigned int getHWM ()
int getTimeout ()
void setHWM (unsigned short _nhwm)
void setTimeout (int _timeoutMS)
unsigned int getNPV ()
unsigned int getNBSEnabled ()
BSChannel getBSChannel (unsigned int idx)
BSChannel getBSChannel (std::string _name)
void setBSChannel (unsigned int idx, BSChannel bsc)
void setBSChannel (BSChannel bsc)
void setBSModulo (std::string pv, int modulo)
void setBSOffset (std::string pv, int offset)
void setBSModuloOffset (std::string pv, int modulo, int offset)
int getIdxFromName (std::string _name)
void verifyIndex (unsigned int idx)
bool isIndexOutOfRange (unsigned int idx)
void printHeader ()
bool isResourceConnected ()
void setResourceConnected (bool _rc)
int getPVIdx (std::string _pv)
std::vector< std::string > getPV ()
std::string getPV (unsigned int idx) throw (std::out_of_range)
std::vector< unsigned int > getHandles ()
unsigned int getHandle (unsigned int idx) throw (std::out_of_range)
std::string getHtype ()
void setHtype (std::string _htype)
unsigned long long getPulse_id ()
void setPulse_id (unsigned long long _pulse_id)
etsNorm getGlobal_timestamp ()
void setGlobal_timestamp (unsigned int _sec, unsigned int _nsec)
std::string getHash ()
void setHash (std::string _hash)
std::string getDH_compression ()
void setDH_compression (std::string dhc)
void setNChannels (unsigned int _nc)
void setNNullData (unsigned int _nn)
void setPGoodData (float _pg)
unsigned int getNChannels ()
unsigned int getNNullData ()
float getPGoodData ()
std::vector< int > getStatusV ()
std::vector< float > getAsFloatV ()
int getAsFloatV (std::vector< float > &valueV, std::vector< int > &statusV)
std::vector< double > getAsDoubleV ()
int getAsDoubleV (std::vector< double > &valueV, std::vector< int > &statusV)
std::vector< std::string > getAsStringV ()
int getAsStringV (std::vector< std::string > &valueV, std::vector< int > &statusV)
std::vector< int > getAsIntV ()
int getAsIntV (std::vector< int > &valueV, std::vector< int > &statusV)
std::vector< double > getAttributeAsDoubleV (std::string attribute)
std::vector< PVDataHolder > getPVDataV ()
PVDataHolder getPVData (unsigned int idx)
PVDataHolder getPVData (std::string name)
int getStatus ()
int reconnect ()
bool setBS (bool BSFlag)
bool resetBS ()
bool setCA (bool CAFlag)
void closeBS ()
bool getIsBS ()

Static Public Member Functions

static size_t RecvResponseCallback (char *contents, size_t size, size_t nmemb, void *up)
static size_t RecvResponseCallbackLive (char *contents, size_t size, size_t nmemb, void *up)

Public Attributes

bool initCalled
PVDataHolder * pvd
std::string globalBSZmqStream
int overallStatus
void * subscriber
int timeout

Private Attributes

std::string htype
unsigned long long pulse_id
etsNorm global_timestamp
std::string hash
std::string dh_compression
std::vector< BSChannel > bsChannel
HandleHelper helper
std::vector< std::string > pv
std::vector< unsigned int > handle
bool isBS
bool BSInitialized
bool resourceConnected
unsigned int nPV
unsigned int nBSEnabled
unsigned int nChannels
unsigned int nNullData
float pGoodData
void * context
void * receiver
int rc
unsigned short nhwm
int timeoutMS
Json::Value parsedFromString
Json::Reader reader
bool parsingSuccessful

Friends

class ::CAFE

Constructor & Destructor Documentation

CAFEBS::BSDataHolder::~BSDataHolder (  )  [inline]
CAFEBS::BSDataHolder::BSDataHolder (  )  [inline]

References BSREAD_ZEROMQ_HIGH_WATER_MARK, BSREAD_ZEROMQ_TIMEOUT_MS, dh_compression, global_timestamp, hash, ICAFE_NORMAL, initCalled, nChannels, nhwm, nNullData, nPV, etsNorm::nsec, overallStatus, pGoodData, pulse_id, resourceConnected, etsNorm::secPastEpoch, and timeoutMS.

CAFEBS::BSDataHolder::BSDataHolder ( std::vector< std::string >  _pv,
std::vector< unsigned int >  _handle 
) [inline]

References bsChannel, BSREAD_ZEROMQ_HIGH_WATER_MARK, BSREAD_ZEROMQ_TIMEOUT_MS, dh_compression, HandleHelper::getNelemNative(), global_timestamp, handle, hash, helper, ICAFE_NORMAL, initCalled, nChannels, nhwm, nNullData, nPV, etsNorm::nsec, overallStatus, pGoodData, pulse_id, pv, pvd, resourceConnected, etsNorm::secPastEpoch, PVDataHolder::setNelem(), and timeoutMS.

CAFEBS::BSDataHolder::BSDataHolder ( std::vector< std::string >  _pv  )  [inline]

References bsChannel, BSREAD_ZEROMQ_HIGH_WATER_MARK, BSREAD_ZEROMQ_TIMEOUT_MS, dh_compression, global_timestamp, handle, hash, ICAFE_NORMAL, initCalled, nChannels, nhwm, nNullData, nPV, etsNorm::nsec, overallStatus, pGoodData, pulse_id, pv, pvd, resourceConnected, etsNorm::secPastEpoch, and timeoutMS.

Member Function Documentation

void CAFEBS::BSDataHolder::closeBS (  )  [inline]

References BSInitialized, context, initCalled, isBS, pvd, and subscriber.

Referenced by resetBS().

int CAFEBS::BSDataHolder::getAsDoubleV ( std::vector< double > &  valueV,
std::vector< int > &  statusV 
) [inline]

References getStatus(), nPV, overallStatus, and pvd.

std::vector<double> CAFEBS::BSDataHolder::getAsDoubleV (  )  [inline]

References nPV, and pvd.

int CAFEBS::BSDataHolder::getAsFloatV ( std::vector< float > &  valueV,
std::vector< int > &  statusV 
) [inline]

References getStatus(), nPV, overallStatus, and pvd.

std::vector<float> CAFEBS::BSDataHolder::getAsFloatV (  )  [inline]

References nPV, and pvd.

int CAFEBS::BSDataHolder::getAsIntV ( std::vector< int > &  valueV,
std::vector< int > &  statusV 
) [inline]

References getStatus(), nPV, overallStatus, and pvd.

std::vector<int> CAFEBS::BSDataHolder::getAsIntV (  )  [inline]

References nPV, and pvd.

int CAFEBS::BSDataHolder::getAsStringV ( std::vector< std::string > &  valueV,
std::vector< int > &  statusV 
) [inline]

References getStatus(), nPV, overallStatus, and pvd.

std::vector<std::string> CAFEBS::BSDataHolder::getAsStringV (  )  [inline]

References nPV, and pvd.

std::vector<double> CAFEBS::BSDataHolder::getAttributeAsDoubleV ( std::string  attribute  )  [inline]

References helper, nPV, pvd, PVNAME_SIZE, and Helper::removeLeadingAndTrailingSpaces().

BSChannel CAFEBS::BSDataHolder::getBSChannel ( std::string  _name  ) 

References bsChannel.

BSChannel CAFEBS::BSDataHolder::getBSChannel ( unsigned int  idx  ) 

References bsChannel, isIndexOutOfRange(), and nPV.

Referenced by setBSModulo(), setBSModuloOffset(), and setBSOffset().

std::string CAFEBS::BSDataHolder::getDH_compression (  )  [inline]

References dh_compression.

etsNorm CAFEBS::BSDataHolder::getGlobal_timestamp (  )  [inline]

References global_timestamp.

unsigned int CAFEBS::BSDataHolder::getHandle ( unsigned int  idx  )  throw (std::out_of_range) [inline]

References handle, isIndexOutOfRange(), and nPV.

std::vector<unsigned int> CAFEBS::BSDataHolder::getHandles (  )  [inline]

References handle.

std::string CAFEBS::BSDataHolder::getHash (  )  [inline]

References hash.

std::string CAFEBS::BSDataHolder::getHtype (  )  [inline]

References htype.

unsigned int CAFEBS::BSDataHolder::getHWM (  )  [inline]

References nhwm.

int CAFEBS::BSDataHolder::getIdxFromName ( std::string  _name  ) 

References bsChannel.

Referenced by setBSChannel().

bool CAFEBS::BSDataHolder::getIsBS (  )  [inline]

References isBS.

unsigned int CAFEBS::BSDataHolder::getNBSEnabled (  )  [inline]

References nBSEnabled.

unsigned int CAFEBS::BSDataHolder::getNChannels (  )  [inline]

References nChannels.

unsigned int CAFEBS::BSDataHolder::getNNullData (  )  [inline]

References nNullData.

unsigned int CAFEBS::BSDataHolder::getNPV (  )  [inline]

References nPV.

float CAFEBS::BSDataHolder::getPGoodData (  )  [inline]

References pGoodData.

unsigned long long CAFEBS::BSDataHolder::getPulse_id (  )  [inline]

References pulse_id.

std::string CAFEBS::BSDataHolder::getPV ( unsigned int  idx  )  throw (std::out_of_range) [inline]

References isIndexOutOfRange(), nPV, and pv.

std::vector<std::string> CAFEBS::BSDataHolder::getPV ( void   )  [inline]

References pv.

PVDataHolder CAFEBS::BSDataHolder::getPVData ( std::string  name  )  [inline]

References bsChannel, nPV, and pvd.

PVDataHolder CAFEBS::BSDataHolder::getPVData ( unsigned int  idx  )  [inline]

References nPV, and pvd.

std::vector<PVDataHolder> CAFEBS::BSDataHolder::getPVDataV (  )  [inline]

References nPV, and pvd.

int CAFEBS::BSDataHolder::getPVIdx ( std::string  _pv  )  [inline]

References __METHOD__, and pv.

int CAFEBS::BSDataHolder::getStatus ( void   )  [inline]

References overallStatus.

Referenced by getAsDoubleV(), getAsFloatV(), getAsIntV(), getAsStringV(), and getStatusV().

std::vector<int> CAFEBS::BSDataHolder::getStatusV (  )  [inline]

References getStatus(), nPV, and pvd.

int CAFEBS::BSDataHolder::getTimeout (  )  [inline]

References timeoutMS.

void CAFEBS::BSDataHolder::init ( std::vector< std::string >  _pv  )  [inline]

References bsChannel, BSInitialized, handle, initCalled, isBS, nBSEnabled, nPV, pv, and pvd.

bool CAFEBS::BSDataHolder::isIndexOutOfRange ( unsigned int  idx  )  [inline]

References nPV.

Referenced by getBSChannel(), getHandle(), and getPV().

bool CAFEBS::BSDataHolder::isResourceConnected (  )  [inline]

References resourceConnected.

void CAFEBS::BSDataHolder::printHeader (  ) 

References dh_compression, global_timestamp, hash, htype, etsNorm::nsec, pulse_id, and etsNorm::secPastEpoch.

int CAFEBS::BSDataHolder::reconnect (  ) 

References BSInitialized, context, globalBSZmqStream, ICAFE_ERRNO_BASE, ICAFE_NORMAL, isBS, nhwm, rc, resourceConnected, subscriber, and timeoutMS.

static size_t CAFEBS::BSDataHolder::RecvResponseCallback ( char *  contents,
size_t  size,
size_t  nmemb,
void *  up 
) [inline, static]

References contentsBS, and nCBs.

Referenced by setBS().

static size_t CAFEBS::BSDataHolder::RecvResponseCallbackLive ( char *  contents,
size_t  size,
size_t  nmemb,
void *  up 
) [inline, static]

References callbackLiveFlag.

Referenced by setBS().

bool CAFEBS::BSDataHolder::resetBS (  )  [inline]

References closeBS(), and setBS().

bool CAFEBS::BSDataHolder::setBS ( bool  BSFlag  ) 

References bsChannel, BSInitialized, cafeMutex, callbackLiveFlag, contentsBS, context, global_timestamp, globalBSZmqStream, isBS, MUTEX, nBSEnabled, nhwm, etsNorm::nsec, parsedFromString, parsingSuccessful, pulse_id, pv, rc, reader, RecvResponseCallback(), RecvResponseCallbackLive(), etsNorm::secPastEpoch, subscriber, and timeoutMS.

Referenced by resetBS().

void CAFEBS::BSDataHolder::setBSChannel ( BSChannel  bsc  ) 

References bsChannel, getIdxFromName(), and CAFEBS::BSChannel::getName().

void CAFEBS::BSDataHolder::setBSChannel ( unsigned int  idx,
BSChannel  bsc 
)

References bsChannel.

Referenced by setBSModulo(), setBSModuloOffset(), and setBSOffset().

void CAFEBS::BSDataHolder::setBSModulo ( std::string  pv,
int  modulo 
) [inline]

References getBSChannel(), setBSChannel(), and CAFEBS::BSChannel::setModulo().

void CAFEBS::BSDataHolder::setBSModuloOffset ( std::string  pv,
int  modulo,
int  offset 
) [inline]

References getBSChannel(), setBSChannel(), CAFEBS::BSChannel::setModulo(), and CAFEBS::BSChannel::setOffset().

void CAFEBS::BSDataHolder::setBSOffset ( std::string  pv,
int  offset 
) [inline]

References getBSChannel(), setBSChannel(), and CAFEBS::BSChannel::setOffset().

bool CAFEBS::BSDataHolder::setCA ( bool  CAFlag  )  [inline]
void CAFEBS::BSDataHolder::setDH_compression ( std::string  dhc  )  [inline]

References dh_compression.

void CAFEBS::BSDataHolder::setGlobal_timestamp ( unsigned int  _sec,
unsigned int  _nsec 
) [inline]

References global_timestamp, etsNorm::nsec, and etsNorm::secPastEpoch.

void CAFEBS::BSDataHolder::setHash ( std::string  _hash  )  [inline]

References hash.

void CAFEBS::BSDataHolder::setHtype ( std::string  _htype  )  [inline]

References htype.

void CAFEBS::BSDataHolder::setHWM ( unsigned short  _nhwm  )  [inline]

References nhwm.

void CAFEBS::BSDataHolder::setNChannels ( unsigned int  _nc  )  [inline]

References nChannels.

void CAFEBS::BSDataHolder::setNNullData ( unsigned int  _nn  )  [inline]

References nNullData.

void CAFEBS::BSDataHolder::setPGoodData ( float  _pg  )  [inline]

References pGoodData.

void CAFEBS::BSDataHolder::setPulse_id ( unsigned long long  _pulse_id  )  [inline]

References pulse_id.

void CAFEBS::BSDataHolder::setResourceConnected ( bool  _rc  )  [inline]

References resourceConnected.

void CAFEBS::BSDataHolder::setTimeout ( int  _timeoutMS  )  [inline]

References timeoutMS.

void CAFEBS::BSDataHolder::verifyIndex ( unsigned int  idx  ) 

References nPV.

Friends And Related Function Documentation

friend class ::CAFE [friend]

Member Data Documentation

std::vector<BSChannel> CAFEBS::BSDataHolder::bsChannel [private]

Referenced by BSDataHolder(), getBSChannel(), getIdxFromName(), getPVData(), init(), setBS(), and setBSChannel().

bool CAFEBS::BSDataHolder::BSInitialized [private]

Referenced by closeBS(), init(), reconnect(), and setBS().

void* CAFEBS::BSDataHolder::context [private]

Referenced by closeBS(), reconnect(), and setBS().

std::string CAFEBS::BSDataHolder::dh_compression [private]

Referenced by BSDataHolder(), getDH_compression(), printHeader(), and setDH_compression().

etsNorm CAFEBS::BSDataHolder::global_timestamp [private]

Referenced by BSDataHolder(), getGlobal_timestamp(), printHeader(), setBS(), and setGlobal_timestamp().

std::string CAFEBS::BSDataHolder::globalBSZmqStream

Referenced by reconnect(), and setBS().

std::vector<unsigned int> CAFEBS::BSDataHolder::handle [private]

Referenced by BSDataHolder(), getHandle(), getHandles(), and init().

std::string CAFEBS::BSDataHolder::hash [private]

Referenced by BSDataHolder(), getHash(), printHeader(), and setHash().

HandleHelper CAFEBS::BSDataHolder::helper [private]

Referenced by BSDataHolder(), and getAttributeAsDoubleV().

std::string CAFEBS::BSDataHolder::htype [private]

Referenced by getHtype(), printHeader(), and setHtype().

bool CAFEBS::BSDataHolder::initCalled

Referenced by BSDataHolder(), closeBS(), and init().

bool CAFEBS::BSDataHolder::isBS [private]

Referenced by closeBS(), getIsBS(), init(), reconnect(), and setBS().

unsigned int CAFEBS::BSDataHolder::nBSEnabled [private]

Referenced by getNBSEnabled(), init(), and setBS().

unsigned int CAFEBS::BSDataHolder::nChannels [private]

Referenced by BSDataHolder(), getNChannels(), and setNChannels().

unsigned short CAFEBS::BSDataHolder::nhwm [private]

Referenced by BSDataHolder(), getHWM(), reconnect(), setBS(), and setHWM().

unsigned int CAFEBS::BSDataHolder::nNullData [private]

Referenced by BSDataHolder(), getNNullData(), and setNNullData().

unsigned int CAFEBS::BSDataHolder::nPV [private]

Referenced by BSDataHolder(), getAsDoubleV(), getAsFloatV(), getAsIntV(), getAsStringV(), getAttributeAsDoubleV(), getBSChannel(), getHandle(), getNPV(), getPV(), getPVData(), getPVDataV(), getStatusV(), init(), isIndexOutOfRange(), and verifyIndex().

int CAFEBS::BSDataHolder::overallStatus

Referenced by BSDataHolder(), getAsDoubleV(), getAsFloatV(), getAsIntV(), getAsStringV(), and getStatus().

Json::Value CAFEBS::BSDataHolder::parsedFromString [private]

Referenced by setBS().

bool CAFEBS::BSDataHolder::parsingSuccessful [private]

Referenced by setBS().

float CAFEBS::BSDataHolder::pGoodData [private]

Referenced by BSDataHolder(), getPGoodData(), and setPGoodData().

unsigned long long CAFEBS::BSDataHolder::pulse_id [private]

Referenced by BSDataHolder(), getPulse_id(), printHeader(), setBS(), and setPulse_id().

std::vector<std::string> CAFEBS::BSDataHolder::pv [private]

Referenced by BSDataHolder(), getPV(), getPVIdx(), init(), and setBS().

PVDataHolder* CAFEBS::BSDataHolder::pvd

Referenced by BSDataHolder(), closeBS(), getAsDoubleV(), getAsFloatV(), getAsIntV(), getAsStringV(), getAttributeAsDoubleV(), getPVData(), getPVDataV(), getStatusV(), and init().

int CAFEBS::BSDataHolder::rc [private]

Referenced by reconnect(), and setBS().

Json::Reader CAFEBS::BSDataHolder::reader [private]

Referenced by setBS().

void* CAFEBS::BSDataHolder::receiver [private]
bool CAFEBS::BSDataHolder::resourceConnected [private]

Referenced by BSDataHolder(), isResourceConnected(), reconnect(), and setResourceConnected().

void* CAFEBS::BSDataHolder::subscriber

Referenced by closeBS(), reconnect(), and setBS().

int CAFEBS::BSDataHolder::timeout
int CAFEBS::BSDataHolder::timeoutMS [private]

Referenced by BSDataHolder(), getTimeout(), reconnect(), setBS(), and setTimeout().

The documentation for this class was generated from the following files:
Generated on 28 May 2018 for CAFE by  doxygen 1.6.1