jsoncollector::DataPoint Class Reference

#include <DataPoint.h>

Inheritance diagram for jsoncollector::DataPoint:

Public Member Functions
	DataPoint ()
	DataPoint (std::string const &source, std::string const &definition, bool fast=false)
virtual void	deserialize (Json::Value &root)
void	discardCollected (unsigned int forLumi)
std::string	fastOutCSV (int sid=-1)
std::vector< std::string > &	getData ()
std::string &	getDefinition ()
std::string const &	getName ()
void	makeStreamLumiMap (unsigned int size)
JsonMonitorable *	mergeAndRetrieveValue (unsigned int forLumi)
void	mergeAndSerialize (Json::Value &jsonRoot, unsigned int lumi, bool initJsonValue, int sid)
virtual void	serialize (Json::Value &root) const
void	serialize (Json::Value &root, bool rootInit, std::string const &input) const
void	setNBins (unsigned int *nBins)
void	setOperation (OperationType op)
void	setStreamLumiPtr (std::vector< unsigned int > *streamLumiPtr)
void	snap (unsigned int lumi)
void	snapGlobal (unsigned int lumi)
void	snapStreamAtomic (unsigned int lumi, unsigned int streamID)
void	trackDummy (std::string const &name, bool setNAifZeroUpdates)
void	trackMonitorable (JsonMonitorable *monitorable, bool NAifZeroUpdates)
void	trackVectorUInt (std::string const &name, std::vector< unsigned int > *monvec, bool NAifZeroUpdates)
void	trackVectorUIntAtomic (std::string const &name, std::vector< AtomicMonUInt * > *monvec, bool NAifZeroUpdates)
void	updateDefinition (std::string const &definition)
	~DataPoint ()
Public Member Functions inherited from jsoncollector::JsonSerializable
virtual	~JsonSerializable ()

Static Public Attributes
static const std::string	DATA = "data"
static const std::string	DEFINITION = "definition"
static const std::string	SOURCE = "source"

Protected Attributes
uint32_t *	buf_ = nullptr
unsigned int	bufLen_ =0
int	cacheI_
std::vector< std::string >	data_
std::string	definition_
unsigned int	fastIndex_ = 0
MonPtrMap	globalDataMap_
bool	isAtomic_ = false
bool	isCached_ =0
bool	isDummy_ = false
bool	isFastOnly_
bool	isStream_ = false
MonType	monType_
bool	NAifZeroUpdates_ = false
std::string	name_
unsigned int *	nBinsPtr_ = nullptr
OperationType	opType_
std::string	source_
std::vector< MonPtrMap >	streamDataMaps_
std::vector< unsigned int > *	streamLumisPtr_ = nullptr
void *	tracked_ = nullptr

Detailed Description

Definition at line 36 of file DataPoint.h.

Constructor & Destructor Documentation

jsoncollector::DataPoint::DataPoint ( )

inline

Definition at line 40 of file DataPoint.h.

{ }

jsoncollector::DataPoint::DataPoint ( std::string const &  source, std::string const &  definition, bool  fast = false  )

inline

Definition at line 42 of file DataPoint.h.

References deserialize(), serialize(), and ~DataPoint().

                                                                                     :
                 source_(source), definition_(definition), isFastOnly_(fast) { }

DataPoint::~DataPoint

(

)

Definition at line 31 of file DataPoint.cc.

References buf_.

Referenced by DataPoint().

{
  if (buf_) delete[] buf_;
}

Member Function Documentation

void DataPoint::deserialize ( Json::Value &  root )

virtual

JSON deserialization procedure for this class

Implements jsoncollector::JsonSerializable.

Definition at line 56 of file DataPoint.cc.

References Json::Value::asString(), DATA, data_, DEFINITION, definition_, Json::Value::get(), mps_fire::i, Json::Value::isArray(), Json::Value::size(), findQualityFiles::size, SOURCE, and source_.

Referenced by DataPoint(), evf::EvFDaqDirector::getNFilesFromEoLS(), and FedRawDataInputSource::grabNextJsonFile().

{
  source_ = root.get(SOURCE, "").asString();
  definition_ = root.get(DEFINITION, "").asString();
  if (root.get(DATA, "").isArray()) {
    unsigned int size = root.get(DATA, "").size();
    for (unsigned int i = 0; i < size; i++) {
      data_.push_back(root.get(DATA, "")[i].asString());
    }
  }
}

void DataPoint::discardCollected

(

unsigned int

forLumi

)

Definition at line 413 of file DataPoint.cc.

References end, globalDataMap_, mps_fire::i, and streamDataMaps_.

Referenced by setStreamLumiPtr().

{
  for (unsigned int i=0;i<streamDataMaps_.size();i++)
  {
    auto itr = streamDataMaps_[i].find(lumi);
    if (itr!=streamDataMaps_[i].end()) streamDataMaps_[i].erase(lumi);
  }

  auto itr = globalDataMap_.find(lumi);
  if (itr!=globalDataMap_.end())
    globalDataMap_.erase(lumi);
}

std::string DataPoint::fastOutCSV

(

int

sid = -1

)

Definition at line 251 of file DataPoint.cc.

References fastIndex_, isAtomic_, isStream_, findQualityFiles::size, AlCaHLTBitMon_QueryRunRegistry::string, and tracked_.

Referenced by setStreamLumiPtr().

{
  if (tracked_) {
    if (isStream_) {
      std::stringstream ss;
      if (sid<0) {
        if (isAtomic_) { 
//        if ATOMIC_LEVEL>0
//        ss << (unsigned int) (static_cast<std::vector<AtomicMonUInt*>*>(tracked_))->at(fastIndex_)->load(std::memory_order_relaxed); 

          ss << (unsigned int) *((static_cast<std::vector<AtomicMonUInt*>*>(tracked_))->at(fastIndex_));
          fastIndex_ = (fastIndex_+1) % (static_cast<std::vector<AtomicMonUInt*>*>(tracked_))->size();
        }
        else {
          ss << (static_cast<std::vector<unsigned int>*>(tracked_))->at(fastIndex_);
          fastIndex_ = (fastIndex_+1) % (static_cast<std::vector<unsigned int>*>(tracked_))->size();
        }

      }
      else {
        if (isAtomic_)
          ss << (unsigned int) *((static_cast<std::vector<AtomicMonUInt*>*>(tracked_))->at(unsigned(sid)));
        else
          ss << (static_cast<std::vector<unsigned int>*>(tracked_))->at(unsigned(sid));
      }
      return ss.str();
    }
    return (static_cast<JsonMonitorable*>(tracked_))->toString();
  }
  return std::string("");
}

std::vector<std::string>& jsoncollector::DataPoint::getData ( void  )

inline

Definition at line 58 of file DataPoint.h.

References data_.

Referenced by evf::EvFDaqDirector::getNFilesFromEoLS(), and FedRawDataInputSource::grabNextJsonFile().

{return data_;}

std::string& jsoncollector::DataPoint::getDefinition ( )

inline

Definition at line 59 of file DataPoint.h.

References definition_, input, dataset::name, serialize(), snap(), snapGlobal(), snapStreamAtomic(), AlCaHLTBitMon_QueryRunRegistry::string, trackMonitorable(), trackVectorUInt(), and trackVectorUIntAtomic().

Referenced by evf::EvFDaqDirector::getNFilesFromEoLS().

{return definition_;}

std::string const& jsoncollector::DataPoint::getName ( void  )

inline

Definition at line 116 of file DataPoint.h.

References name_.

Referenced by plotting.Plot::draw().

{return name_;}

void DataPoint::makeStreamLumiMap

(

unsigned int

size

)

Definition at line 107 of file DataPoint.cc.

References mps_fire::i, findQualityFiles::size, and streamDataMaps_.

Referenced by trackDummy(), trackVectorUInt(), and trackVectorUIntAtomic().

{
  for (unsigned int i=0;i<size;i++) {
    streamDataMaps_.push_back(MonPtrMap());
  }
}

JsonMonitorable * DataPoint::mergeAndRetrieveValue

(

unsigned int

forLumi

)

Definition at line 283 of file DataPoint.cc.

References jsoncollector::IntJ::add(), cacheI_, end, mps_fire::i, isCached_, isStream_, monType_, streamDataMaps_, jsoncollector::TYPEUINT, relativeConstraints::value, and jsoncollector::IntJ::value().

Referenced by setStreamLumiPtr().

{
  assert(monType_==TYPEUINT && isStream_);//for now only support UINT and SUM for stream variables
  IntJ *newJ = new IntJ;
  for (unsigned int i=0;i<streamDataMaps_.size();i++) {
    auto itr = streamDataMaps_[i].find(lumi);
    if (itr!=streamDataMaps_[i].end()) {
      newJ->add(static_cast<IntJ*>(itr->second.get())->value());
    }
  }
  cacheI_=newJ->value();
  isCached_=true;
  return newJ;//assume the caller takes care of deleting the object
}

void DataPoint::mergeAndSerialize	(	Json::Value &	jsonRoot,
		unsigned int	lumi,
		bool	initJsonValue,
		int	sid
	)

Definition at line 298 of file DataPoint.cc.

References Json::Value::append(), buf_, bufLen_, cacheI_, DATA, DEFINITION, definition_, end, jsoncollector::JsonMonitorable::getUpdates(), globalDataMap_, mps_fire::i, createfilelist::int, isCached_, isDummy_, isStream_, monType_, NAifZeroUpdates_, nBinsPtr_, jsoncollector::OPHISTO, opType_, SOURCE, source_, streamDataMaps_, jsoncollector::TYPESTRING, jsoncollector::TYPEUINT, relativeConstraints::value, and jsoncollector::HistoJ< T >::value().

Referenced by setStreamLumiPtr().

{
  if (initJsonValue) {
    root[SOURCE] = source_;
    root[DEFINITION] = definition_;
  }

  if (isDummy_) {
    root[DATA].append("N/A");
    return;
  }
  if (!isStream_) {
    auto itr = globalDataMap_.find(lumi);
    if (itr != globalDataMap_.end()) {
      root[DATA].append(itr->second.get()->toString());
    }
    else {
      if (NAifZeroUpdates_) root[DATA].append("N/A");
      else if (monType_==TYPESTRING)  root[DATA].append("");
      else  root[DATA].append("0");
    }
    return;
  }
  else {
    assert(monType_==TYPEUINT);
    if (isCached_) {
      std::stringstream ss;
      ss << cacheI_;
      root[DATA].append(ss.str());
      return;
    }
    if (opType_!=OPHISTO) {//sum is default
      std::stringstream ss;
      unsigned int updates=0;
      unsigned int sum=0;
      if (sid<1)
        for (unsigned int i=0;i<streamDataMaps_.size();i++) {
          auto itr = streamDataMaps_[i].find(lumi);
          if (itr!=streamDataMaps_[i].end()) {
            sum+=static_cast<IntJ*>(itr->second.get())->value();
            updates++;
          }
        }
      else {
        auto itr = streamDataMaps_[unsigned(sid)].find(lumi);
        if (itr!=streamDataMaps_[unsigned(sid)].end()) {
          sum+=static_cast<IntJ*>(itr->second.get())->value();
          updates++;
        }
      }
      if (!updates && NAifZeroUpdates_) ss << "N/A";
      ss << sum;
      root[DATA].append(ss.str());
      return;
    }
    if (opType_==OPHISTO) {
      if (nBinsPtr_==nullptr) {
        root[DATA].append("N/A");
        return;
      }
      if (*nBinsPtr_>bufLen_) {
        if (buf_) delete[] buf_;
        bufLen_=*nBinsPtr_;
        buf_= new uint32_t[bufLen_];
      }
      memset(buf_,0,bufLen_*sizeof(uint32_t));
      unsigned int updates=0;
      if (sid<1)
      for (unsigned int i=0;i<streamDataMaps_.size();i++) {
          auto itr = streamDataMaps_[i].find(lumi);
          if (itr!=streamDataMaps_[i].end()) {
            HistoJ <unsigned int>* monObj = static_cast<HistoJ<unsigned int>*>(itr->second.get());
            updates+=monObj->getUpdates();
            auto &hvec = monObj->value();
            for (unsigned int j=0;j<hvec.size();j++) {
              unsigned int thisbin=(unsigned int) hvec[j];
              if (thisbin<*nBinsPtr_) {
                buf_[thisbin]++;
              }
            }
          }
        }
      else {
        auto itr = streamDataMaps_[unsigned(sid)].find(lumi);
        if (itr!=streamDataMaps_[unsigned(sid)].end()) {
          HistoJ <unsigned int>* monObj = static_cast<HistoJ<unsigned int>*>(itr->second.get());
          updates+=monObj->getUpdates();
          auto &hvec = monObj->value();
          for (unsigned int j=0;j<hvec.size();j++) {
            unsigned int thisbin=(unsigned int) hvec[j];
            if (thisbin<*nBinsPtr_) {
              buf_[thisbin]++;
            }
          }
        }
      }
      std::stringstream ss;
      if (!*nBinsPtr_ || (!updates && NAifZeroUpdates_)) ss << "N/A";
      else {
        ss << "[";
        if (*nBinsPtr_) {
          for (unsigned int i=0;i<*nBinsPtr_-1;i++) {
            ss << buf_[i] << ",";
          }
          ss << buf_[*nBinsPtr_-1];
        }
        ss << "]";
      }
      root[DATA].append(ss.str());
      return;
    }
  }
}

void DataPoint::serialize ( Json::Value &  root ) const

virtual

JSON serialization procedure for this class

Implements jsoncollector::JsonSerializable.

Definition at line 43 of file DataPoint.cc.

References mps_alisetup::append, DATA, data_, DEFINITION, definition_, mps_fire::i, SOURCE, and source_.

Referenced by DataPoint(), and getDefinition().

{
  if (source_.size()) {
    root[SOURCE] = source_;
  }
  if (definition_.size()) {
    root[DEFINITION] = definition_;
  }
  for (unsigned int i=0;i<data_.size();i++)
    root[DATA].append(data_[i]);
}

void DataPoint::serialize	(	Json::Value &	root,
		bool	rootInit,
		std::string const &	input
	)		const

Functions specific to new monitoring implementation

Definition at line 114 of file DataPoint.cc.

References Json::Value::append(), DATA, DEFINITION, definition_, SOURCE, and source_.

{
  if (rootInit) {
    if (source_.size())
      root[SOURCE] = source_;
    if (definition_.size())
      root[DEFINITION] = definition_;
  }
  root[DATA].append(input);
}

void jsoncollector::DataPoint::setNBins ( unsigned int *  nBins )

inline

Definition at line 114 of file DataPoint.h.

References nBinsPtr_.

Referenced by jsoncollector::FastMonitor::registerGlobalMonitorable(), jsoncollector::FastMonitor::registerStreamMonitorableUIntVec(), and jsoncollector::FastMonitor::registerStreamMonitorableUIntVecAtomic().

{nBinsPtr_ = nBins;}

void jsoncollector::DataPoint::setOperation ( OperationType  op )

inline

Definition at line 92 of file DataPoint.h.

References opType_.

                                            {
            opType_=op;
    }

void jsoncollector::DataPoint::setStreamLumiPtr ( std::vector< unsigned int > *  streamLumiPtr )

inline

Definition at line 97 of file DataPoint.h.

References discardCollected(), fastOutCSV(), mergeAndRetrieveValue(), mergeAndSerialize(), streamLumisPtr_, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                  {
      streamLumisPtr_=streamLumiPtr;
    }

void DataPoint::snap

(

unsigned int

lumi

)

Definition at line 125 of file DataPoint.cc.

References end, mps_fire::i, isAtomic_, isCached_, isStream_, MAXUPDATES, monType_, nBinsPtr_, jsoncollector::OPHISTO, opType_, snapGlobal(), streamDataMaps_, streamLumisPtr_, tracked_, jsoncollector::TYPEINT, jsoncollector::TYPEUINT, jsoncollector::IntJ::update(), and jsoncollector::HistoJ< T >::update().

Referenced by getDefinition().

{
  isCached_=false;
  if (isStream_) {
    if (monType_==TYPEUINT)
    {
      for (unsigned int i=0; i<streamDataMaps_.size();i++) {
        unsigned int streamLumi_=streamLumisPtr_->at(i);//get currently processed stream lumi
        unsigned int monVal;

#if ATOMIC_LEVEL>0
        if (isAtomic_) monVal = (static_cast<std::vector<AtomicMonUInt*>*>(tracked_))->at(i)->load(std::memory_order_relaxed);
#else 
        if (isAtomic_) monVal = *((static_cast<std::vector<AtomicMonUInt*>*>(tracked_))->at(i));
#endif
    else monVal = (static_cast<std::vector<unsigned int>*>(tracked_))->at(i);

    auto itr =  streamDataMaps_[i].find(streamLumi_);
    if (itr==streamDataMaps_[i].end())
    {
      if (opType_==OPHISTO) {
            if (*nBinsPtr_) {
              HistoJ<unsigned int> *nh = new HistoJ<unsigned int>(1,MAXUPDATES);
              nh->update(monVal);
              streamDataMaps_[i][streamLumi_] = nh;
            }
          }
          else {//default to SUM
            IntJ *nj = new IntJ;
            nj->update(monVal);
            streamDataMaps_[i][streamLumi_]= nj;
          }
        }
        else { 
          if (opType_==OPHISTO) {
            if (*nBinsPtr_) {
              (static_cast<HistoJ<unsigned int> *>(itr->second.get()))->update(monVal);
            }
          }
          else {
            *(static_cast<IntJ*>(itr->second.get()))=monVal;
          }
        }
      }
    }
    else assert(monType_!=TYPEINT);//not yet implemented, application error
  }
  else snapGlobal(lumi);
}

void DataPoint::snapGlobal

(

unsigned int

lumi

)

Definition at line 175 of file DataPoint.cc.

References globalDataMap_, isCached_, isStream_, csvLumiCalc::lumi, monType_, tracked_, jsoncollector::TYPEDOUBLE, jsoncollector::TYPEINT, jsoncollector::TYPESTRING, update, jsoncollector::IntJ::update(), jsoncollector::DoubleJ::update(), jsoncollector::StringJ::update(), and relativeConstraints::value.

Referenced by getDefinition(), and snap().

{
  isCached_=false;
  if (isStream_) return;
  auto itr = globalDataMap_.find(lumi);
  if (itr==globalDataMap_.end()) {
    if (monType_==TYPEINT) {
      IntJ *ij = new IntJ;
      ij->update((static_cast<IntJ*>(tracked_))->value());
      globalDataMap_[lumi]=ij;
    }
    if (monType_==TYPEDOUBLE) {
      DoubleJ *dj = new DoubleJ;
      dj->update((static_cast<DoubleJ*>(tracked_))->value());
      globalDataMap_[lumi]=dj;
    }
    if (monType_==TYPESTRING) {
      StringJ *sj = new StringJ;
      sj->update((static_cast<StringJ*>(tracked_))->value());
      globalDataMap_[lumi]=sj;
    }
  } else { 
    if (monType_==TYPEINT)
      static_cast<IntJ*>(itr->second.get())->update((static_cast<IntJ*>(tracked_))->value());
    else if (monType_==TYPEDOUBLE)
      static_cast<DoubleJ*>(itr->second.get())->update((static_cast<DoubleJ*>(tracked_))->value());
    else if (monType_==TYPESTRING)
      static_cast<StringJ*>(itr->second.get())->concatenate((static_cast<StringJ*>(tracked_))->value());
  }
}

void DataPoint::snapStreamAtomic	(	unsigned int	lumi,
		unsigned int	streamID
	)

Definition at line 206 of file DataPoint.cc.

References end, h, isAtomic_, isCached_, isStream_, csvLumiCalc::lumi, MAXUPDATES, monType_, nBinsPtr_, jsoncollector::OPHISTO, opType_, streamDataMaps_, tracked_, jsoncollector::TYPEINT, jsoncollector::TYPEUINT, update, jsoncollector::IntJ::update(), and jsoncollector::HistoJ< T >::update().

Referenced by getDefinition().

{
  if (!isStream_ || !isAtomic_) return;
  isCached_=false;
  if (monType_==TYPEUINT)
  {
    unsigned int monVal;
#if ATOMIC_LEVEL>0
    if (isAtomic_) monVal = (static_cast<std::vector<AtomicMonUInt*>*>(tracked_))->at(streamID)->load(std::memory_order_relaxed);
#else 
    if (isAtomic_) monVal = *((static_cast<std::vector<AtomicMonUInt*>*>(tracked_))->at(streamID));
#endif
    else monVal = (static_cast<std::vector<unsigned int>*>(tracked_))->at(streamID);

    auto itr =  streamDataMaps_[streamID].find(lumi);
    if (itr==streamDataMaps_[streamID].end()) //insert
    {
      if (opType_==OPHISTO) {
        if (*nBinsPtr_) {
          HistoJ<unsigned int> *h = new HistoJ<unsigned int>(1,MAXUPDATES);
          h->update(monVal);
          streamDataMaps_[streamID][lumi] = h;
        }
      }
      else {//default to SUM

        IntJ *h = new IntJ;
        h->update(monVal);
        streamDataMaps_[streamID][lumi] = h;
      }
    }
    else 
    { 
      if (opType_==OPHISTO) {
        if (*nBinsPtr_) {
          static_cast<HistoJ<unsigned int>*>(itr->second.get())->update(monVal);
        }
      }
      else
        *(static_cast<IntJ*>(itr->second.get()))=monVal;
    }
  }
  else assert(monType_!=TYPEINT);//not yet implemented
}

void jsoncollector::DataPoint::trackDummy ( std::string const &  name, bool  setNAifZeroUpdates  )

inline

Definition at line 82 of file DataPoint.h.

References isDummy_, makeStreamLumiMap(), NAifZeroUpdates_, dataset::name, name_, and findQualityFiles::size.

Referenced by jsoncollector::FastMonitor::commit().

    {
        name_ = name;
        isDummy_=true;
        NAifZeroUpdates_=true;
    }

void DataPoint::trackMonitorable	(	JsonMonitorable *	monitorable,
		bool	NAifZeroUpdates
	)

Definition at line 74 of file DataPoint.cc.

References jsoncollector::JsonMonitorable::getName(), monType_, NAifZeroUpdates_, name_, tracked_, jsoncollector::TYPEDOUBLE, jsoncollector::TYPEINT, and jsoncollector::TYPESTRING.

Referenced by getDefinition(), jsoncollector::FastMonitor::registerFastGlobalMonitorable(), and jsoncollector::FastMonitor::registerGlobalMonitorable().

{
  name_=monitorable->getName();
  tracked_ = (void*)monitorable;
  if (dynamic_cast<IntJ*>(monitorable)) monType_=TYPEINT;
  else if (dynamic_cast<DoubleJ*>(monitorable)) monType_=TYPEDOUBLE;
  else if (dynamic_cast<StringJ*>(monitorable)) monType_=TYPESTRING;
  else assert(0);
  NAifZeroUpdates_=NAifZeroUpdates;

}

void DataPoint::trackVectorUInt	(	std::string const &	name,
		std::vector< unsigned int > *	monvec,
		bool	NAifZeroUpdates
	)

Definition at line 86 of file DataPoint.cc.

References isStream_, makeStreamLumiMap(), monType_, NAifZeroUpdates_, dataset::name, name_, tracked_, and jsoncollector::TYPEUINT.

Referenced by getDefinition(), and jsoncollector::FastMonitor::registerStreamMonitorableUIntVec().

{
  name_=name;
  tracked_ = (void*)monvec;
  isStream_=true;
  monType_=TYPEUINT;
  NAifZeroUpdates_=NAifZeroUpdates;
  makeStreamLumiMap(monvec->size());
}

void DataPoint::trackVectorUIntAtomic	(	std::string const &	name,
		std::vector< AtomicMonUInt * > *	monvec,
		bool	NAifZeroUpdates
	)

Definition at line 96 of file DataPoint.cc.

References isAtomic_, isStream_, makeStreamLumiMap(), monType_, NAifZeroUpdates_, dataset::name, name_, tracked_, and jsoncollector::TYPEUINT.

Referenced by getDefinition(), and jsoncollector::FastMonitor::registerStreamMonitorableUIntVecAtomic().

{
  name_=name;
  tracked_ = (void*)monvec;
  isStream_=true;
  isAtomic_=true;
  monType_=TYPEUINT;
  NAifZeroUpdates_=NAifZeroUpdates;
  makeStreamLumiMap(monvec->size());
}

void jsoncollector::DataPoint::updateDefinition ( std::string const &  definition )

inline

Definition at line 118 of file DataPoint.h.

References definition_.

{definition_=definition;}

Member Data Documentation

uint32_t* jsoncollector::DataPoint::buf_ = nullptr

protected

Definition at line 149 of file DataPoint.h.

Referenced by mergeAndSerialize(), and ~DataPoint().

unsigned int jsoncollector::DataPoint::bufLen_ =0

protected

Definition at line 150 of file DataPoint.h.

Referenced by mergeAndSerialize().

int jsoncollector::DataPoint::cacheI_

protected

Definition at line 153 of file DataPoint.h.

Referenced by mergeAndRetrieveValue(), and mergeAndSerialize().

const std::string DataPoint::DATA = "data"

static

Definition at line 123 of file DataPoint.h.

Referenced by deserialize(), mergeAndSerialize(), and serialize().

std::vector<std::string> jsoncollector::DataPoint::data_

protected

Definition at line 129 of file DataPoint.h.

Referenced by deserialize(), getData(), and serialize().

const std::string DataPoint::DEFINITION = "definition"

static

Definition at line 122 of file DataPoint.h.

Referenced by deserialize(), mergeAndSerialize(), and serialize().

std::string jsoncollector::DataPoint::definition_

protected

Definition at line 128 of file DataPoint.h.

Referenced by deserialize(), getDefinition(), mergeAndSerialize(), serialize(), and updateDefinition().

unsigned int jsoncollector::DataPoint::fastIndex_ = 0

protected

Definition at line 156 of file DataPoint.h.

Referenced by fastOutCSV().

MonPtrMap jsoncollector::DataPoint::globalDataMap_

protected

Definition at line 132 of file DataPoint.h.

Referenced by discardCollected(), mergeAndSerialize(), and snapGlobal().

bool jsoncollector::DataPoint::isAtomic_ = false

protected

Definition at line 139 of file DataPoint.h.

Referenced by fastOutCSV(), snap(), snapStreamAtomic(), and trackVectorUIntAtomic().

bool jsoncollector::DataPoint::isCached_ =0

protected

Definition at line 154 of file DataPoint.h.

Referenced by mergeAndRetrieveValue(), mergeAndSerialize(), snap(), snapGlobal(), and snapStreamAtomic().

bool jsoncollector::DataPoint::isDummy_ = false

protected

Definition at line 140 of file DataPoint.h.

Referenced by mergeAndSerialize(), and trackDummy().

bool jsoncollector::DataPoint::isFastOnly_

protected

Definition at line 142 of file DataPoint.h.

bool jsoncollector::DataPoint::isStream_ = false

protected

Definition at line 138 of file DataPoint.h.

Referenced by fastOutCSV(), mergeAndRetrieveValue(), mergeAndSerialize(), snap(), snapGlobal(), snapStreamAtomic(), trackVectorUInt(), and trackVectorUIntAtomic().

MonType jsoncollector::DataPoint::monType_

protected

Definition at line 144 of file DataPoint.h.

Referenced by mergeAndRetrieveValue(), mergeAndSerialize(), snap(), snapGlobal(), snapStreamAtomic(), trackMonitorable(), trackVectorUInt(), and trackVectorUIntAtomic().

bool jsoncollector::DataPoint::NAifZeroUpdates_ = false

protected

Definition at line 141 of file DataPoint.h.

Referenced by mergeAndSerialize(), trackDummy(), trackMonitorable(), trackVectorUInt(), and trackVectorUIntAtomic().

std::string jsoncollector::DataPoint::name_

protected

Definition at line 146 of file DataPoint.h.

Referenced by getName(), trackDummy(), trackMonitorable(), trackVectorUInt(), and trackVectorUIntAtomic().

unsigned int* jsoncollector::DataPoint::nBinsPtr_ = nullptr

protected

Definition at line 152 of file DataPoint.h.

Referenced by mergeAndSerialize(), setNBins(), snap(), and snapStreamAtomic().

OperationType jsoncollector::DataPoint::opType_

protected

Definition at line 145 of file DataPoint.h.

Referenced by mergeAndSerialize(), setOperation(), snap(), and snapStreamAtomic().

const std::string DataPoint::SOURCE = "source"

static

Definition at line 121 of file DataPoint.h.

Referenced by deserialize(), mergeAndSerialize(), and serialize().

std::string jsoncollector::DataPoint::source_

protected

Definition at line 127 of file DataPoint.h.

Referenced by deserialize(), Config.Process::dumpConfig(), Config.Process::dumpPython(), mergeAndSerialize(), and serialize().

std::vector<MonPtrMap> jsoncollector::DataPoint::streamDataMaps_

protected

Definition at line 131 of file DataPoint.h.

Referenced by discardCollected(), makeStreamLumiMap(), mergeAndRetrieveValue(), mergeAndSerialize(), snap(), and snapStreamAtomic().

std::vector<unsigned int>* jsoncollector::DataPoint::streamLumisPtr_ = nullptr

protected

Definition at line 136 of file DataPoint.h.

Referenced by setStreamLumiPtr(), and snap().

void* jsoncollector::DataPoint::tracked_ = nullptr

protected

Definition at line 133 of file DataPoint.h.

Referenced by fastOutCSV(), snap(), snapGlobal(), snapStreamAtomic(), trackMonitorable(), trackVectorUInt(), and trackVectorUIntAtomic().