#include <FastMonitor.h>

Public Member Functions
	FastMonitor (const std::vector< JsonMonitorable * > &monitorableVariables, std::string defPath)

void	outputFullHistoDataPoint (std::string path)

void	snap (bool outputCSVFile, std::string path)

virtual	~FastMonitor ()

Private Member Functions
JsonMonitorable *	getVarForName (string name) const

Private Attributes
std::vector< string >	accumulatedCSV_

std::string	defPath_

DataPointDefinition	dpd_

std::vector< JsonMonitorable * >	monitorableVars_

std::vector< JsonMonitorable * >	monitoredVars_

bool	snappedOnce_

Detailed Description

Definition at line 17 of file FastMonitor.h.

Constructor & Destructor Documentation

FastMonitor::FastMonitor	(	const std::vector< JsonMonitorable * > &	monitorableVariables,
		std::string	defPath
	)

Definition at line 25 of file FastMonitor.cc.

References defPath_, dpd_, jsoncollector::ObjectMerger::getDataPointDefinitionFor(), jsoncollector::DataPointDefinition::getLegend(), getVarForName(), i, jsoncollector::DataPointDefinition::isPopulated(), and monitoredVars_.

                         :
     snappedOnce_(false), monitorableVars_(monitorableVariables),
             defPath_(defPath) {
 
     ObjectMerger::getDataPointDefinitionFor(defPath_, dpd_);
     if (dpd_.isPopulated()) {
         for (unsigned int i = 0; i < dpd_.getLegend().size(); i++) {
             string toBeMonitored = dpd_.getLegend()[i].getName();
             monitoredVars_.push_back(getVarForName(toBeMonitored));
         }
     }
 }

FastMonitor::~FastMonitor ( )

virtual

Definition at line 39 of file FastMonitor.cc.

39 {

40 }

Member Function Documentation

JsonMonitorable * FastMonitor::getVarForName ( string name ) const

private

Definition at line 99 of file FastMonitor.cc.

References i, and monitorableVars_.

Referenced by FastMonitor().

                                                              {
     for (unsigned int i = 0; i < monitorableVars_.size(); i++)
         if (name.compare(monitorableVars_[i]->getName()) == 0)
             return monitorableVars_[i];
     return 0;
 }

void FastMonitor::outputFullHistoDataPoint ( std::string path )

Definition at line 65 of file FastMonitor.cc.

References accumulatedCSV_, gather_cfg::cout, jsoncollector::ObjectMerger::csvToJson(), defPath_, dpd_, jsoncollector::Utils::getHostAndPID(), i, jsoncollector::ObjectMerger::merge(), lumiQueryAPI::msg, jsoncollector::JSONSerializer::serialize(), jsoncollector::DataPoint::setSource(), snappedOnce_, and jsoncollector::FileIO::writeStringToFile().

                                                       {
     if (accumulatedCSV_.size() > 0) {
       std::cout << "accumulatedCSV_.size()=" <<  accumulatedCSV_.size() << std::endl;
       assert(accumulatedCSV_.size()<100);
         vector<DataPoint*> dpToMerge;
 
         for (unsigned int i = 0; i < accumulatedCSV_.size(); i++) {
             string currentCSV = accumulatedCSV_[i];
             DataPoint* currentDP = ObjectMerger::csvToJson(currentCSV, &dpd_,
                     defPath_);
             string hpid;
             Utils::getHostAndPID(hpid);
             currentDP->setSource(hpid);
             dpToMerge.push_back(currentDP);
         }
 
         string outputJSONAsString;
         string msg;
 
         DataPoint* mergedDP = ObjectMerger::merge(dpToMerge, msg, true);
         mergedDP->setSource(dpToMerge[0]->getSource());
 
         for (unsigned int i = 0; i < dpToMerge.size(); i++)
             delete dpToMerge[i];
 
         JSONSerializer::serialize(mergedDP, outputJSONAsString);
         FileIO::writeStringToFile(path, outputJSONAsString);
 
         accumulatedCSV_.clear();
         snappedOnce_ = false;
 
     }
 }

void FastMonitor::snap	(	bool	outputCSVFile,
		std::string	path
	)

Definition at line 42 of file FastMonitor.cc.

References accumulatedCSV_, defPath_, i, monitoredVars_, dbtoconf::out, download_sqlite_cfg::outputFile, and estimatePileup_makeJSON::trunc.

                                                       {
     std::stringstream ss;
     for (unsigned int i = 0; i < monitoredVars_.size(); i++) {
         if (i == monitoredVars_.size() - 1) {
             ss << monitoredVars_[i]->toString();
             break;
         }
         ss << monitoredVars_[i]->toString() << ",";
     }
 
     if (outputCSVFile) {
         ofstream outputFile;
         outputFile.open(path.c_str(), fstream::out | fstream::trunc);
         outputFile << defPath_ << endl;
         outputFile << ss.str();
         outputFile << endl;
         outputFile.close();
     }
 
     string inputStringCSV = ss.str();
     accumulatedCSV_.push_back(inputStringCSV);
 }