#include <RecoEventOutputModuleForFU.h>

Inheritance diagram for evf::RecoEventOutputModuleForFU< Consumer >:

Public Member Functions
	RecoEventOutputModuleForFU (edm::ParameterSet const &ps)

	~RecoEventOutputModuleForFU () override

Public Member Functions inherited from edm::StreamerOutputModuleBase
	StreamerOutputModuleBase (ParameterSet const &ps)

	~StreamerOutputModuleBase () override

Public Member Functions inherited from edm::one::OutputModule< one::WatchRuns, one::WatchLuminosityBlocks >
SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

const OutputModule &	operator= (const OutputModule &)=delete

	OutputModule (edm::ParameterSet const &iPSet)

	OutputModule (const OutputModule &)=delete

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () const final

bool	wantsInputProcessBlocks () const final

bool	wantsProcessBlocks () const final

Public Member Functions inherited from edm::one::OutputModuleBase
OutputModuleBase &	operator= (OutputModuleBase const &)=delete

	OutputModuleBase (ParameterSet const &pset)

	OutputModuleBase (OutputModuleBase const &)=delete

SharedResourcesAcquirer &	sharedResourcesAcquirer ()

SubProcessParentageHelper const *	subProcessParentageHelper () const

bool	wantsStreamLuminosityBlocks () const

bool	wantsStreamRuns () const

Public Member Functions inherited from edm::core::OutputModuleCore
BranchIDLists const *	branchIDLists () const

std::array< bool, NumBranchTypes > const &	hasNewlyDroppedBranch () const

SelectedProductsForBranchType const &	keptProducts () const

int	maxEvents () const

const ModuleDescription &	moduleDescription () const

OutputModuleCore &	operator= (OutputModuleCore const &)=delete

	OutputModuleCore (ParameterSet const &pset)

	OutputModuleCore (OutputModuleCore const &)=delete

OutputProcessBlockHelper const &	outputProcessBlockHelper () const

std::string const &	processName () const

int	remainingEvents () const

bool	selected (BranchDescription const &desc) const

void	selectProducts (ProductRegistry const &preg, ThinnedAssociationsHelper const &, ProcessBlockHelperBase const &)

ThinnedAssociationsHelper const *	thinnedAssociationsHelper () const

bool	wantAllEvents () const

	~OutputModuleCore () override

Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const

void	convertCurrentProcessAlias (std::string const &processName)
	Convert "@currentProcess" in InputTag process names to the actual current process name. More...

	EDConsumerBase ()

	EDConsumerBase (EDConsumerBase const &)=delete

	EDConsumerBase (EDConsumerBase &&)=default

ESProxyIndex const *	esGetTokenIndices (edm::Transition iTrans) const

std::vector< ESProxyIndex > const &	esGetTokenIndicesVector (edm::Transition iTrans) const

std::vector< ESRecordIndex > const &	esGetTokenRecordIndicesVector (edm::Transition iTrans) const

ProductResolverIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const

void	itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

void	itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

std::vector < ProductResolverIndexAndSkipBit > const &	itemsToGetFrom (BranchType iType) const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesWhoseProductsAreConsumed (std::array< std::vector< ModuleDescription const * > , NumBranchTypes > &modulesAll, std::vector< ModuleProcessName > &modulesInPreviousProcesses, ProductRegistry const &preg, std::map< std::string, ModuleDescription const > const &labelsToDesc, std::string const &processName) const

EDConsumerBase const &	operator= (EDConsumerBase const &)=delete

EDConsumerBase &	operator= (EDConsumerBase &&)=default

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

void	selectInputProcessBlocks (ProductRegistry const &productRegistry, ProcessBlockHelperBase const &processBlockHelperBase)

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)

void	updateLookup (eventsetup::ESRecordsToProxyIndices const &)

virtual	~EDConsumerBase () noexcept(false)

Static Public Member Functions
static void	fillDescriptions (edm::ConfigurationDescriptions &descriptions)

Static Public Member Functions inherited from edm::StreamerOutputModuleBase
static void	fillDescription (ParameterSetDescription &desc)

Static Public Member Functions inherited from edm::core::OutputModuleCore
static const std::string &	baseType ()

static void	fillDescription (ParameterSetDescription &desc, std::vector< std::string > const &iDefaultOutputCommands=ProductSelectorRules::defaultSelectionStrings())

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &)

Private Member Functions
void	beginJob () override

void	beginLuminosityBlock (edm::LuminosityBlockForOutput const &) override

void	doOutputEvent (EventMsgBuilder const &msg) override

void	doOutputHeader (InitMsgBuilder const &init_message) override

void	endLuminosityBlock (edm::LuminosityBlockForOutput const &) override

void	initRun ()

void	start () override

void	stop () override

Private Attributes
jsoncollector::IntJ	accepted_

std::unique_ptr< Consumer >	c_

jsoncollector::IntJ	errorEvents_

jsoncollector::IntJ	fileAdler32_

jsoncollector::StringJ	filelist_

jsoncollector::IntJ	filesize_

evf::FastMonitoringService *	fms_

jsoncollector::IntJ	hltErrorEvents_

jsoncollector::StringJ	inputFiles_

std::shared_ptr < jsoncollector::FastMonitor >	jsonMonitor_

jsoncollector::StringJ	mergeType_

std::filesystem::path	openDatChecksumFilePath_

std::filesystem::path	openDatFilePath_

unsigned char *	outBuf_ = nullptr

jsoncollector::DataPointDefinition	outJsonDef_

jsoncollector::IntJ	processed_

bool	readAdler32Check_ = false

jsoncollector::IntJ	retCodeMask_

std::string	streamLabel_

jsoncollector::StringJ	transferDestination_

Additional Inherited Members
Public Types inherited from edm::one::OutputModuleBase
typedef OutputModuleBase	ModuleType

Public Types inherited from edm::core::OutputModuleCore
typedef OutputModuleCore	ModuleType

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Protected Member Functions inherited from edm::one::OutputModuleBase
void	configure (OutputModuleDescription const &desc)

void	doBeginJob ()

bool	doEvent (EventTransitionInfo const &, ActivityRegistry , ModuleCallingContext const )

void	doPreallocate (PreallocationConfiguration const &)

Protected Member Functions inherited from edm::core::OutputModuleCore
void	configure (OutputModuleDescription const &desc)

ModuleDescription const &	description () const

void	doAccessInputProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)

void	doBeginJob_ ()

bool	doBeginLuminosityBlock (LumiTransitionInfo const &, ModuleCallingContext const *)

void	doBeginProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)

bool	doBeginRun (RunTransitionInfo const &, ModuleCallingContext const *)

void	doEndJob ()

bool	doEndLuminosityBlock (LumiTransitionInfo const &, ModuleCallingContext const *)

void	doEndProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)

bool	doEndRun (RunTransitionInfo const &, ModuleCallingContext const *)

bool	doEvent_ (EventTransitionInfo const &, ActivityRegistry , ModuleCallingContext const )

void	doPreallocate_ (PreallocationConfiguration const &)

std::map< BranchID::value_type, BranchID::value_type > const &	droppedBranchIDToKeptBranchID ()

virtual void	preallocLumis (unsigned int)

ParameterSetID	selectorConfig () const

void	setEventSelectionInfo (std::map< std::string, std::vector< std::pair< std::string, int >>> const &outputModulePathPositions, bool anyProductProduced)

Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

template<BranchType B = InEvent>
EDConsumerBaseAdaptor< B >	consumes (edm::InputTag tag) noexcept

EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	consumes (TypeToGet const &id, edm::InputTag const &tag)

ConsumesCollector	consumesCollector ()
	Use a ConsumesCollector to gather consumes information from helper functions. More...

template<typename ProductType , BranchType B = InEvent>
void	consumesMany ()

void	consumesMany (const TypeToGet &id)

template<BranchType B>
void	consumesMany (const TypeToGet &id)

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)

template<Transition Tr = Transition::Event>
constexpr auto	esConsumes () noexcept

template<Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag tag) noexcept

template<Transition Tr = Transition::Event>
ESGetTokenGeneric	esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
	Used with EventSetupRecord::doGet. More...

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

void	resetItemsToGetFrom (BranchType iType)

Protected Attributes inherited from edm::core::OutputModuleCore
std::atomic< int >	remainingEvents_

Detailed Description

template<typename Consumer>
class evf::RecoEventOutputModuleForFU< Consumer >

Definition at line 26 of file RecoEventOutputModuleForFU.h.

Constructor & Destructor Documentation

template<typename Consumer >

evf::RecoEventOutputModuleForFU< Consumer >::RecoEventOutputModuleForFU ( edm::ParameterSet const & ps )

explicit

Consumers are supposed to provide

void doOutputHeader(InitMsgBuilder const& init_message) void doOutputEvent(EventMsgBuilder const& msg) void start() void stop() static void fillDescription(ParameterSetDescription&)

Definition at line 75 of file RecoEventOutputModuleForFU.h.

References Exception, evf::RecoEventOutputModuleForFU< Consumer >::fms_, evf::RecoEventOutputModuleForFU< Consumer >::streamLabel_, AlCaHLTBitMon_QueryRunRegistry::string, and to_lower().

       : edm::one::OutputModuleBase::OutputModuleBase(ps),
         edm::StreamerOutputModuleBase(ps),
         c_(new Consumer(ps)),
         streamLabel_(ps.getParameter<std::string>("@module_label")),
         processed_(0),
         accepted_(0),
         errorEvents_(0),
         retCodeMask_(0),
         filelist_(),
         filesize_(0),
         inputFiles_(),
         fileAdler32_(1),
         transferDestination_(),
         mergeType_(),
         hltErrorEvents_(0),
         outBuf_(new unsigned char[1024 * 1024]) {
     //replace hltOutoputA with stream if the HLT menu uses this convention
     std::string testPrefix = "hltOutput";
     if (streamLabel_.find(testPrefix) == 0)
       streamLabel_ = std::string("stream") + streamLabel_.substr(testPrefix.size());
 
     if (streamLabel_.find('_') != std::string::npos) {
       throw cms::Exception("RecoEventOutputModuleForFU") << "Underscore character is reserved can not be used for "
                                                             "stream names in FFF, but was detected in stream name -: "
                                                          << streamLabel_;
     }
 
     std::string streamLabelLow = streamLabel_;
     boost::algorithm::to_lower(streamLabelLow);
     auto streampos = streamLabelLow.rfind("stream");
     if (streampos != 0 && streampos != std::string::npos)
       throw cms::Exception("RecoEventOutputModuleForFU")
           << "stream (case-insensitive) sequence was found in stream suffix. This is reserved and can not be used for "
              "names in FFF based HLT, but was detected in stream name";
 
     fms_ = (evf::FastMonitoringService*)(edm::Service<evf::MicroStateService>().operator->());
   }

template<typename Consumer >

evf::RecoEventOutputModuleForFU< Consumer >::~RecoEventOutputModuleForFU ( )

override

Definition at line 182 of file RecoEventOutputModuleForFU.h.

182 {}

Member Function Documentation

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::beginJob ( void )

overrideprivatevirtual

Reimplemented from edm::core::OutputModuleCore.

Definition at line 258 of file RecoEventOutputModuleForFU.h.

References evf::MergeTypeDAT.

                                                       {
     //get stream transfer destination
     transferDestination_ = edm::Service<evf::EvFDaqDirector>()->getStreamDestinations(streamLabel_);
     mergeType_ = edm::Service<evf::EvFDaqDirector>()->getStreamMergeType(streamLabel_, evf::MergeTypeDAT);
   }

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::beginLuminosityBlock ( edm::LuminosityBlockForOutput const & ls )

overrideprivate

Definition at line 265 of file RecoEventOutputModuleForFU.h.

References edm::LuminosityBlockForOutput::luminosityBlock().

                                                                                                        {
     //edm::LogInfo("RecoEventOutputModuleForFU") << "begin lumi";
     openDatFilePath_ = edm::Service<evf::EvFDaqDirector>()->getOpenDatFilePath(ls.luminosityBlock(), streamLabel_);
     openDatChecksumFilePath_ =
         edm::Service<evf::EvFDaqDirector>()->getOpenDatFilePath(ls.luminosityBlock(), streamLabel_);
     c_->setOutputFile(openDatFilePath_.string());
     filelist_ = openDatFilePath_.filename().string();
   }

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::doOutputEvent ( EventMsgBuilder const & msg )

overrideprivatevirtual

Implements edm::StreamerOutputModuleBase.

Definition at line 233 of file RecoEventOutputModuleForFU.h.

                                                                                      {
     accepted_.value()++;
     c_->doOutputEvent(msg);  // You can't use msg in RecoEventOutputModuleForFU after this point
   }

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::doOutputHeader ( InitMsgBuilder const & init_message )

overrideprivatevirtual

Implements edm::StreamerOutputModuleBase.

Definition at line 200 of file RecoEventOutputModuleForFU.h.

References cms::Adler32(), Exception, LogDebug, alcazmumu_cfi::src, edm_modernize_messagelogger::stat, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                               {
     c_->doOutputHeader(init_message);
 
     const std::string openIniFileName = edm::Service<evf::EvFDaqDirector>()->getOpenInitFilePath(streamLabel_);
     struct stat istat;
     stat(openIniFileName.c_str(), &istat);
     //read back file to check integrity of what was written
     off_t readInput = 0;
     uint32_t adlera = 1, adlerb = 0;
     FILE* src = fopen(openIniFileName.c_str(), "r");
     while (readInput < istat.st_size) {
       size_t toRead = readInput + 1024 * 1024 < istat.st_size ? 1024 * 1024 : istat.st_size - readInput;
       fread(outBuf_, toRead, 1, src);
       cms::Adler32((const char*)outBuf_, toRead, adlera, adlerb);
       readInput += toRead;
     }
     fclose(src);
     //free output buffer needed only for the INI file
     delete[] outBuf_;
     outBuf_ = nullptr;
 
     uint32_t adler32c = (adlerb << 16) | adlera;
     if (adler32c != c_->get_adler32_ini()) {
       throw cms::Exception("RecoEventOutputModuleForFU")
           << "Checksum mismatch of ini file -: " << openIniFileName << " expected:" << c_->get_adler32_ini()
           << " obtained:" << adler32c;
     } else {
       LogDebug("RecoEventOutputModuleForFU") << "Ini file checksum -: " << streamLabel_ << " " << adler32c;
       std::filesystem::rename(openIniFileName, edm::Service<evf::EvFDaqDirector>()->getInitFilePath(streamLabel_));
     }
   }

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::endLuminosityBlock ( edm::LuminosityBlockForOutput const & ls )

overrideprivate

Definition at line 275 of file RecoEventOutputModuleForFU.h.

References edm::LuminosityBlockForOutput::luminosityBlock(), edm_modernize_messagelogger::stat, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                                      {
     //edm::LogInfo("RecoEventOutputModuleForFU") << "end lumi";
     long filesize = 0;
     fileAdler32_.value() = c_->get_adler32();
     c_->closeOutputFile();
     bool abortFlag = false;
     processed_.value() = fms_->getEventsProcessedForLumi(ls.luminosityBlock(), &abortFlag);
 
     if (abortFlag) {
       edm::LogInfo("RecoEventOutputModuleForFU") << "output suppressed";
       return;
     }
 
     if (processed_.value() != 0) {
       //lock
       struct stat istat;
       stat(openDatFilePath_.string().c_str(), &istat);
       filesize = istat.st_size;
       std::filesystem::rename(openDatFilePath_.string().c_str(),
                               edm::Service<evf::EvFDaqDirector>()->getDatFilePath(ls.luminosityBlock(), streamLabel_));
     } else {
       filelist_ = "";
       fileAdler32_.value() = -1;
     }
 
     //remove file
     remove(openDatFilePath_.string().c_str());
     filesize_ = filesize;
 
     jsonMonitor_->snap(ls.luminosityBlock());
     const std::string outputJsonNameStream =
         edm::Service<evf::EvFDaqDirector>()->getOutputJsonFilePath(ls.luminosityBlock(), streamLabel_);
     jsonMonitor_->outputFullJSON(outputJsonNameStream, ls.luminosityBlock());
 
     // reset monitoring params
     accepted_.value() = 0;
     filelist_ = "";
   }

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::fillDescriptions ( edm::ConfigurationDescriptions & descriptions )

static

Definition at line 239 of file RecoEventOutputModuleForFU.h.

References edm::ConfigurationDescriptions::addDefault(), submitPVResolutionJobs::desc, and edm::StreamerOutputModuleBase::fillDescription().

                                                                                                         {
     edm::ParameterSetDescription desc;
     edm::StreamerOutputModuleBase::fillDescription(desc);
     Consumer::fillDescription(desc);
     // Use addDefault here instead of add for 4 reasons:
     // 1. Because EvFOutputModule_cfi.py is explicitly defined it does not need to be autogenerated
     // The explicitly defined version overrides the autogenerated version of the cfi file.
     // 2. That cfi file is not used anywhere in the release anyway
     // 3. There are two plugin names used for the same template instantiation of this
     // type, "ShmStreamConsumer" and "EvFOutputModule" and this causes name conflict
     // problems for the cfi generation code which are avoided with addDefault.
     // 4. At the present time, there is only one type of Consumer used to instantiate
     // instances of this template, but if there were more than one type then this function
     // would need to be specialized for each type unless the descriptions were the same
     // and addDefault was used.
     descriptions.addDefault(desc);
   }

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::initRun ( )

private

Definition at line 115 of file RecoEventOutputModuleForFU.h.

References jsoncollector::DataPointDefinition::ADLER32, jsoncollector::DataPointDefinition::BINARYOR, jsoncollector::DataPointDefinition::CAT, ws_sso_content_reader::content, LogDebug, jsoncollector::DataPointDefinition::MERGE, jsoncollector::DataPointDefinition::SAME, jsoncollector::JSONSerializer::serialize(), contentValuesCheck::ss, edm_modernize_messagelogger::stat, AlCaHLTBitMon_QueryRunRegistry::string, jsoncollector::DataPointDefinition::SUM, and jsoncollector::FileIO::writeStringToFile().

                                                      {
     std::string baseRunDir = edm::Service<evf::EvFDaqDirector>()->baseRunDir();
     readAdler32Check_ = edm::Service<evf::EvFDaqDirector>()->outputAdler32Recheck();
     LogDebug("RecoEventOutputModuleForFU") << "writing .dat files to -: " << baseRunDir;
     // create open dir if not already there
     edm::Service<evf::EvFDaqDirector>()->createRunOpendirMaybe();
 
     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");
 
     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 tmpss, ss;
     tmpss << baseRunDir << "/open/"
           << "output_" << getpid() << ".jsd";
     ss << baseRunDir << "/"
        << "output_" << getpid() << ".jsd";
     std::string outTmpJsonDefName = tmpss.str();
     std::string outJsonDefName = ss.str();
 
     edm::Service<evf::EvFDaqDirector>()->lockInitLock();
     struct stat fstat;
     if (stat(outJsonDefName.c_str(), &fstat) != 0) {  //file does not exist
       LogDebug("RecoEventOutputModuleForFU") << "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();
 
     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);
   }

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::start ( )

overrideprivatevirtual

Implements edm::StreamerOutputModuleBase.

Definition at line 185 of file RecoEventOutputModuleForFU.h.

References AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by progressbar.ProgressBar::__next__(), Types.LuminosityBlockRange::cppID(), and Types.EventRange::cppID().

                                                    {
     initRun();
     const std::string openInitFileName = edm::Service<evf::EvFDaqDirector>()->getOpenInitFilePath(streamLabel_);
     edm::LogInfo("RecoEventOutputModuleForFU")
         << "start() method, initializing streams. init stream -: " << openInitFileName;
     c_->setInitMessageFile(openInitFileName);
     c_->start();
   }

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::stop ( )

overrideprivatevirtual

Implements edm::StreamerOutputModuleBase.

Definition at line 195 of file RecoEventOutputModuleForFU.h.

                                                   {
     c_->stop();
   }

Member Data Documentation

template<typename Consumer >

jsoncollector::IntJ evf::RecoEventOutputModuleForFU< Consumer >::accepted_

mutableprivate

Definition at line 57 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

std::unique_ptr<Consumer> evf::RecoEventOutputModuleForFU< Consumer >::c_

private

Definition at line 52 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

jsoncollector::IntJ evf::RecoEventOutputModuleForFU< Consumer >::errorEvents_

private

Definition at line 58 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

jsoncollector::IntJ evf::RecoEventOutputModuleForFU< Consumer >::fileAdler32_

private

Definition at line 63 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

jsoncollector::StringJ evf::RecoEventOutputModuleForFU< Consumer >::filelist_

private

Definition at line 60 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

jsoncollector::IntJ evf::RecoEventOutputModuleForFU< Consumer >::filesize_

private

Definition at line 61 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

evf::FastMonitoringService* evf::RecoEventOutputModuleForFU< Consumer >::fms_

private

Definition at line 68 of file RecoEventOutputModuleForFU.h.

Referenced by evf::RecoEventOutputModuleForFU< Consumer >::RecoEventOutputModuleForFU().

template<typename Consumer >

jsoncollector::IntJ evf::RecoEventOutputModuleForFU< Consumer >::hltErrorEvents_

private

Definition at line 66 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

jsoncollector::StringJ evf::RecoEventOutputModuleForFU< Consumer >::inputFiles_

private

Definition at line 62 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

std::shared_ptr<jsoncollector::FastMonitor> evf::RecoEventOutputModuleForFU< Consumer >::jsonMonitor_

private

Definition at line 67 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

jsoncollector::StringJ evf::RecoEventOutputModuleForFU< Consumer >::mergeType_

private

Definition at line 65 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

std::filesystem::path evf::RecoEventOutputModuleForFU< Consumer >::openDatChecksumFilePath_

private

Definition at line 55 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

std::filesystem::path evf::RecoEventOutputModuleForFU< Consumer >::openDatFilePath_

private

Definition at line 54 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

unsigned char* evf::RecoEventOutputModuleForFU< Consumer >::outBuf_ = nullptr

private

Definition at line 70 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

jsoncollector::DataPointDefinition evf::RecoEventOutputModuleForFU< Consumer >::outJsonDef_

private

Definition at line 69 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

jsoncollector::IntJ evf::RecoEventOutputModuleForFU< Consumer >::processed_

private

Definition at line 56 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

bool evf::RecoEventOutputModuleForFU< Consumer >::readAdler32Check_ = false

private

Definition at line 71 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

jsoncollector::IntJ evf::RecoEventOutputModuleForFU< Consumer >::retCodeMask_

private

Definition at line 59 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

std::string evf::RecoEventOutputModuleForFU< Consumer >::streamLabel_

private

Definition at line 53 of file RecoEventOutputModuleForFU.h.

Referenced by evf::RecoEventOutputModuleForFU< Consumer >::RecoEventOutputModuleForFU().

template<typename Consumer >

jsoncollector::StringJ evf::RecoEventOutputModuleForFU< Consumer >::transferDestination_

private

Definition at line 64 of file RecoEventOutputModuleForFU.h.

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

template<typename Consumer> class evf::RecoEventOutputModuleForFU< Consumer >

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation

template<typename Consumer>
class evf::RecoEventOutputModuleForFU< Consumer >