evf::GlobalEvFOutputJSONWriter Class Reference

Public Member Functions
	GlobalEvFOutputJSONWriter (std::string const &streamLabel, jsoncollector::DataPointDefinition const &, std::string const &outJsonDefName)

Public Attributes
jsoncollector::IntJ	accepted_
jsoncollector::IntJ	errorEvents_
jsoncollector::IntJ	fileAdler32_
jsoncollector::StringJ	filelist_
jsoncollector::IntJ	filesize_
jsoncollector::IntJ	hltErrorEvents_
jsoncollector::StringJ	inputFiles_
std::shared_ptr < jsoncollector::FastMonitor >	jsonMonitor_
jsoncollector::StringJ	mergeType_
jsoncollector::IntJ	processed_
jsoncollector::IntJ	retCodeMask_
jsoncollector::StringJ	transferDestination_

Detailed Description

Definition at line 95 of file GlobalEvFOutputModule.cc.

Constructor & Destructor Documentation

evf::GlobalEvFOutputJSONWriter::GlobalEvFOutputJSONWriter	(	std::string const &	streamLabel,
		jsoncollector::DataPointDefinition const &	outJsonDef,
		std::string const &	outJsonDefName
	)

Definition at line 193 of file GlobalEvFOutputModule.cc.

References accepted_, errorEvents_, fileAdler32_, filelist_, filesize_, hltErrorEvents_, inputFiles_, jsonMonitor_, mergeType_, evf::MergeTypeDAT, processed_, retCodeMask_, jsoncollector::JsonMonitorable::setName(), and transferDestination_.

      : processed_(0),
        accepted_(0),
        errorEvents_(0),
        retCodeMask_(0),
        filelist_(),
        filesize_(0),
        inputFiles_(),
        fileAdler32_(1),
        hltErrorEvents_(0) {
    transferDestination_ = edm::Service<evf::EvFDaqDirector>()->getStreamDestinations(streamLabel);
    mergeType_ = edm::Service<evf::EvFDaqDirector>()->getStreamMergeType(streamLabel, evf::MergeTypeDAT);

    processed_.setName("Processed");
    accepted_.setName("Accepted");
    errorEvents_.setName("ErrorEvents");
    retCodeMask_.setName("ReturnCodeMask");
    filelist_.setName("Filelist");
    filesize_.setName("Filesize");
    inputFiles_.setName("InputFiles");
    fileAdler32_.setName("FileAdler32");
    transferDestination_.setName("TransferDestination");
    mergeType_.setName("MergeType");
    hltErrorEvents_.setName("HLTErrorEvents");

    jsonMonitor_.reset(new jsoncollector::FastMonitor(&outJsonDef, true));
    jsonMonitor_->setDefPath(outJsonDefName);
    jsonMonitor_->registerGlobalMonitorable(&processed_, false);
    jsonMonitor_->registerGlobalMonitorable(&accepted_, false);
    jsonMonitor_->registerGlobalMonitorable(&errorEvents_, false);
    jsonMonitor_->registerGlobalMonitorable(&retCodeMask_, false);
    jsonMonitor_->registerGlobalMonitorable(&filelist_, false);
    jsonMonitor_->registerGlobalMonitorable(&filesize_, false);
    jsonMonitor_->registerGlobalMonitorable(&inputFiles_, false);
    jsonMonitor_->registerGlobalMonitorable(&fileAdler32_, false);
    jsonMonitor_->registerGlobalMonitorable(&transferDestination_, false);
    jsonMonitor_->registerGlobalMonitorable(&mergeType_, false);
    jsonMonitor_->registerGlobalMonitorable(&hltErrorEvents_, false);
    jsonMonitor_->commit(nullptr);
  }

Member Data Documentation

jsoncollector::IntJ evf::GlobalEvFOutputJSONWriter::accepted_

Definition at line 102 of file GlobalEvFOutputModule.cc.

Referenced by GlobalEvFOutputJSONWriter().

jsoncollector::IntJ evf::GlobalEvFOutputJSONWriter::errorEvents_

Definition at line 103 of file GlobalEvFOutputModule.cc.

Referenced by GlobalEvFOutputJSONWriter().

jsoncollector::IntJ evf::GlobalEvFOutputJSONWriter::fileAdler32_

Definition at line 108 of file GlobalEvFOutputModule.cc.

Referenced by GlobalEvFOutputJSONWriter().

jsoncollector::StringJ evf::GlobalEvFOutputJSONWriter::filelist_

Definition at line 105 of file GlobalEvFOutputModule.cc.

Referenced by GlobalEvFOutputJSONWriter().

jsoncollector::IntJ evf::GlobalEvFOutputJSONWriter::filesize_

Definition at line 106 of file GlobalEvFOutputModule.cc.

Referenced by GlobalEvFOutputJSONWriter().

jsoncollector::IntJ evf::GlobalEvFOutputJSONWriter::hltErrorEvents_

Definition at line 111 of file GlobalEvFOutputModule.cc.

Referenced by GlobalEvFOutputJSONWriter().

jsoncollector::StringJ evf::GlobalEvFOutputJSONWriter::inputFiles_

Definition at line 107 of file GlobalEvFOutputModule.cc.

Referenced by GlobalEvFOutputJSONWriter().

std::shared_ptr<jsoncollector::FastMonitor> evf::GlobalEvFOutputJSONWriter::jsonMonitor_

Definition at line 112 of file GlobalEvFOutputModule.cc.

Referenced by GlobalEvFOutputJSONWriter().

jsoncollector::StringJ evf::GlobalEvFOutputJSONWriter::mergeType_

Definition at line 110 of file GlobalEvFOutputModule.cc.

Referenced by GlobalEvFOutputJSONWriter().

jsoncollector::IntJ evf::GlobalEvFOutputJSONWriter::processed_

Definition at line 101 of file GlobalEvFOutputModule.cc.

Referenced by GlobalEvFOutputJSONWriter().

jsoncollector::IntJ evf::GlobalEvFOutputJSONWriter::retCodeMask_

Definition at line 104 of file GlobalEvFOutputModule.cc.

Referenced by GlobalEvFOutputJSONWriter().

jsoncollector::StringJ evf::GlobalEvFOutputJSONWriter::transferDestination_

Definition at line 109 of file GlobalEvFOutputModule.cc.

Referenced by GlobalEvFOutputJSONWriter().