zbsread.h File Reference

#include <zmq.h>
#include <assert.h>
#include <signal.h>
#include <json/json.h>
#include <zbsDataHolders.h>
#include <zbsdtHelper.h>

Go to the source code of this file.

Defines
#define	__METHOD__   "z_bsread (BSDataHolder &bsd)"
Functions
static void	z_bsread_dbpm (DBPMKeeper &dbpm)
	Receives all message parts from zeromq socket.
static void	z_bsread (BSDataHolder &bsd)
	Receives all message parts from zeromq socket.
Variables
IntegerBitset< unsigned char >	bsetUChar
IntegerBitset< char >	bsetChar
IntegerBitset< unsigned short >	bsetUShort
IntegerBitset< short >	bsetShort
IntegerBitset< unsigned int >	bsetUInt
IntegerBitset< int >	bsetInt
IntegerBitset< unsigned long long >	bsetULongLong
IntegerBitset< long long >	bsetLongLong
FloatBitset< float >	bsetFloat
FloatBitset< double >	bsetDouble
bool	bsdtInsertFlag = false
bool	dataHeaderReceived = false
unsigned short	inDumpFlag = 2
std::string	hashIs = ""
std::string	hashOriginal = ""
unsigned short	hashOriginalFlag = 0
bool	fillBSPV = false
std::vector< std::string >	bsPV
bool	fill_bs_read_PV = false
std::vector< std::string >	bs_read_PV

---

Define Documentation

#define __METHOD__   "z_bsread (BSDataHolder &bsd)"

---

Function Documentation

static void z_bsread

(

BSDataHolder &

bsd

)

[static]

Receives all message parts from zeromq socket.

Parameters:

dbpm

in/output: BSDataHolder object

Returns:

long ICAFE_NORMAL else ECAFE_error

References __METHOD__, CAFE_BSHELPER::bitshuffleDecompress(), CAFE_BSHELPER::BS_BOOL, CAFE_BSHELPER::BS_FLOAT32, CAFE_BSHELPER::BS_FLOAT64, CAFE_BSHELPER::BS_INT16, CAFE_BSHELPER::BS_INT32, CAFE_BSHELPER::BS_INT64, CAFE_BSHELPER::BS_INT8, CAFE_BSHELPER::BS_STRING, CAFE_BSHELPER::BS_UINT16, CAFE_BSHELPER::BS_UINT32, CAFE_BSHELPER::BS_UINT64, CAFE_BSHELPER::BS_UINT8, CAFE_BSHELPER::bsdt, CAFE_BSHELPER::bsdtInsert(), bsdtInsertFlag, CAFE_BSHELPER::bsrdV, dataHeaderReceived, ECAFE_BSREAD_MULTIPART_MESS_NODATA, ECAFE_BSREAD_PARSEFAIL_DATAHEADER, ECAFE_BSREAD_PARSEFAIL_MAINHEADER, ECAFE_INVALID_SWITCH_CASE, CAFE_BSHELPER::getByteSize(), ICAFE_ERRNO_BASE, ICAFE_NORMAL, CAFE_BSHELPER::IntegerBitset< CTYPE >::unfold(), CAFE_BSHELPER::FloatBitset< CTYPE >::unfold(), CAFE_BSHELPER::IntegerBitset< CTYPE >::unfoldScalar(), and CAFE_BSHELPER::FloatBitset< CTYPE >::unfoldScalar().

static void z_bsread_dbpm

(

DBPMKeeper &

dbpm

)

[static]

Receives all message parts from zeromq socket.

Parameters:

dbpm

in/output: DBPMKeeper object

Returns:

long ICAFE_NORMAL else ECAFE_error

References bsPV, fillBSPV, hashIs, hashOriginal, hashOriginalFlag, ICAFE_ERRNO_BASE, ICAFE_NORMAL, and inDumpFlag.

---

Variable Documentation

std::vector<std::string> bs_read_PV

bool bsdtInsertFlag = false

Referenced by z_bsread().

IntegerBitset<char> bsetChar

FloatBitset<double> bsetDouble

FloatBitset<float> bsetFloat

IntegerBitset<int> bsetInt

IntegerBitset<long long> bsetLongLong

IntegerBitset<short> bsetShort

IntegerBitset<unsigned char> bsetUChar

IntegerBitset<unsigned int> bsetUInt

IntegerBitset<unsigned long long> bsetULongLong

IntegerBitset<unsigned short> bsetUShort

std::vector<std::string> bsPV

Referenced by z_bsread_dbpm().

bool dataHeaderReceived = false

Referenced by z_bsread().

bool fill_bs_read_PV = false

bool fillBSPV = false

Referenced by z_bsread_dbpm().

std::string hashIs = ""

Referenced by z_bsread_dbpm().

std::string hashOriginal = ""

Referenced by z_bsread_dbpm().

unsigned short hashOriginalFlag = 0

Referenced by z_bsread_dbpm().

unsigned short inDumpFlag = 2

Referenced by z_bsread_dbpm().