Public Member Functions
	GlobalEvFOutputJSONDef (std::string const &streamLabel, bool writeJsd)

void	updateDestination (std::string const &streamLabel)

Public Attributes
jsoncollector::StringJ	mergeType_

jsoncollector::DataPointDefinition	outJsonDef_

std::string	outJsonDefName_

jsoncollector::StringJ	transferDestination_

Detailed Description

Definition at line 123 of file GlobalEvFOutputModule.cc.

Constructor & Destructor Documentation

◆ GlobalEvFOutputJSONDef()

evf::GlobalEvFOutputJSONDef::GlobalEvFOutputJSONDef	(	std::string const &	streamLabel,
		bool	writeJsd
	)

Definition at line 196 of file GlobalEvFOutputModule.cc.

                                                                                             {
     std::string baseRunDir = edm::Service<evf::EvFDaqDirector>()->baseRunDir();
     LogDebug("GlobalEvFOutputModule") << "writing .dat files to -: " << baseRunDir;
 
     outJsonDef_.setDefaultGroup("data");
     outJsonDef_.addLegendItem("Processed", "integer", jsoncollector::DataPointDefinition::SUM);
     outJsonDef_.addLegendItem("Accepted", "integer", jsoncollector::DataPointDefinition::SUM);
     outJsonDef_.addLegendItem("ErrorEvents", "integer", jsoncollector::DataPointDefinition::SUM);
     outJsonDef_.addLegendItem("ReturnCodeMask", "integer", jsoncollector::DataPointDefinition::BINARYOR);
     outJsonDef_.addLegendItem("Filelist", "string", jsoncollector::DataPointDefinition::MERGE);
     outJsonDef_.addLegendItem("Filesize", "integer", jsoncollector::DataPointDefinition::SUM);
     outJsonDef_.addLegendItem("InputFiles", "string", jsoncollector::DataPointDefinition::CAT);
     outJsonDef_.addLegendItem("FileAdler32", "integer", jsoncollector::DataPointDefinition::ADLER32);
     outJsonDef_.addLegendItem("TransferDestination", "string", jsoncollector::DataPointDefinition::SAME);
     outJsonDef_.addLegendItem("MergeType", "string", jsoncollector::DataPointDefinition::SAME);
     outJsonDef_.addLegendItem("HLTErrorEvents", "integer", jsoncollector::DataPointDefinition::SUM);
 
     std::stringstream ss;
     ss << baseRunDir << "/"
        << "output_" << getpid() << ".jsd";
     outJsonDefName_ = ss.str();
 
     if (writeJsd) {
       std::stringstream tmpss;
       tmpss << baseRunDir << "/open/"
             << "output_" << getpid() << ".jsd";
       std::string outTmpJsonDefName = tmpss.str();
       edm::Service<evf::EvFDaqDirector>()->createRunOpendirMaybe();
       edm::Service<evf::EvFDaqDirector>()->lockInitLock();
       struct stat fstat;
       if (stat(outJsonDefName_.c_str(), &fstat) != 0) {  //file does not exist
         LogDebug("GlobalEvFOutputModule") << "writing output definition file -: " << outJsonDefName_;
         std::string content;
         jsoncollector::JSONSerializer::serialize(&outJsonDef_, content);
         jsoncollector::FileIO::writeStringToFile(outTmpJsonDefName, content);
         std::filesystem::rename(outTmpJsonDefName, outJsonDefName_);
       }
     }
     edm::Service<evf::EvFDaqDirector>()->unlockInitLock();
   }

Member Function Documentation

◆ updateDestination()

void evf::GlobalEvFOutputJSONDef::updateDestination ( std::string const & streamLabel )

Definition at line 237 of file GlobalEvFOutputModule.cc.

References mergeType_, evf::MergeTypeDAT, beamhlt_dqm_sourceclient-live_cfg::streamLabel, and transferDestination_.

                                                                              {
     transferDestination_ = edm::Service<evf::EvFDaqDirector>()->getStreamDestinations(streamLabel);
     mergeType_ = edm::Service<evf::EvFDaqDirector>()->getStreamMergeType(streamLabel, evf::MergeTypeDAT);
   }