Inheritance diagram for evf::GlobalEvFOutputModule:

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

	~GlobalEvFOutputModule () override

Public Member Functions inherited from edm::global::OutputModule< T >
const OutputModule &	operator= (const OutputModule &)=delete

	OutputModule (edm::ParameterSet const &iPSet)

	OutputModule (const OutputModule &)=delete

bool	wantsInputProcessBlocks () const final

bool	wantsProcessBlocks () const final

bool	wantsStreamLuminosityBlocks () const final

bool	wantsStreamRuns () const final

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

	OutputModuleBase (ParameterSet const &pset)

	OutputModuleBase (OutputModuleBase const &)=delete

bool	wantsGlobalLuminosityBlocks () const

bool	wantsGlobalRuns () const

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

void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

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

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

std::vector< ESResolverIndex > 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

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

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

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

void	updateLookup (eventsetup::ESRecordsToProductResolverIndices const &)

virtual	~EDConsumerBase () noexcept(false)

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

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	acquire (edm::StreamID, edm::EventForOutput const &, edm::WaitingTaskWithArenaHolder) const final

void	beginJob () final

std::unique_ptr< SerializeDataBuffer >	beginStream (edm::StreamID) const final

void	cacheEventMetaData ()

Trig	getTriggerResults (edm::EDGetTokenT< edm::TriggerResults > const &token, edm::EventForOutput const &e) const

std::shared_ptr< GlobalEvFOutputEventWriter >	globalBeginLuminosityBlock (edm::LuminosityBlockForOutput const &iLB) const final

std::shared_ptr< GlobalEvFOutputJSONDef >	globalBeginRun (edm::RunForOutput const &run) const final

void	globalEndLuminosityBlock (edm::LuminosityBlockForOutput const &iLB) const final

void	globalEndRun (edm::RunForOutput const &) const final

void	respondToCloseInputFile (edm::FileBlock const &) final

void	respondToOpenInputFile (edm::FileBlock const &) final

void	write (edm::EventForOutput const &e) final

void	writeLuminosityBlock (edm::LuminosityBlockForOutput const &) final

void	writeRun (edm::RunForOutput const &) final

Private Attributes
StreamerOutputMsgBuilders::Parameters	commonParameters_

evf::FastMonitoringService *	fms_

std::atomic< GlobalEvFOutputEventWriter * >	lastWriter_ = nullptr

std::shared_ptr< MetaDataCache const >	metaDataCache_

std::unique_ptr< const StreamerOutputMsgBuilders >	msgBuilders_

unsigned int	presentBranchIDListSize_ = 0

edm::EDGetTokenT< edm::SendJobHeader::ParameterSetMap >	psetToken_

std::string	streamLabel_

edm::EDGetTokenT< edm::TriggerResults >	trToken_

Additional Inherited Members
Public Types inherited from edm::global::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::global::OutputModuleBase
void	doAcquire (EventTransitionInfo const &, ActivityRegistry , ModuleCallingContext const , WaitingTaskWithArenaHolder &)

void	doBeginJob ()

void	doBeginStream (StreamID id)

void	doEndStream (StreamID id)

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

void	doPreallocate (PreallocationConfiguration const &)

void	preActionBeforeRunEventAsync (WaitingTaskHolder iTask, ModuleCallingContext const &iModuleCallingContext, Principal const &iPrincipal) 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 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 ()

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

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

Definition at line 193 of file GlobalEvFOutputModule.cc.

Constructor & Destructor Documentation

◆ GlobalEvFOutputModule()

evf::GlobalEvFOutputModule::GlobalEvFOutputModule ( edm::ParameterSet const & ps )

explicit

Definition at line 329 of file GlobalEvFOutputModule.cc.

References Exception, geometryDiff::file, fms_, streamLabel_, AlCaHLTBitMon_QueryRunRegistry::string, and to_lower().

       : edm::global::OutputModuleBase(ps),
         GlobalEvFOutputModuleType(ps),
         commonParameters_(StreamerOutputMsgBuilders::parameters(ps)),
         streamLabel_(ps.getParameter<std::string>("@module_label")),
         trToken_(consumes<edm::TriggerResults>(edm::InputTag("TriggerResults"))),
         psetToken_(consumes<edm::SendJobHeader::ParameterSetMap, edm::InRun>(
             ps.getUntrackedParameter<edm::InputTag>("psetMap"))) {
     //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("GlobalEvFOutputModule")
           << "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("GlobalEvFOutputModule")
           << "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";
 
     //output initemp file. This lets hltd know number of streams early on
     if (!edm::Service<evf::EvFDaqDirector>().isAvailable())
       throw cms::Exception("GlobalEvFOutputModule") << "EvFDaqDirector is not available";
 
     const std::string iniFileName = edm::Service<evf::EvFDaqDirector>()->getInitTempFilePath(streamLabel_);
     std::ofstream file(iniFileName);
     if (!file)
       throw cms::Exception("GlobalEvFOutputModule") << "can not create " << iniFileName << "error: " << strerror(errno);
     file.close();
 
     edm::LogInfo("GlobalEvFOutputModule") << "Constructor created initemp file -: " << iniFileName;
 
     //create JSD
     GlobalEvFOutputJSONDef(streamLabel_, true);
 
     fms_ = (evf::FastMonitoringService*)(edm::Service<evf::MicroStateService>().operator->());
   }

◆ ~GlobalEvFOutputModule()

evf::GlobalEvFOutputModule::~GlobalEvFOutputModule ( )

override

Definition at line 375 of file GlobalEvFOutputModule.cc.

375 {}

Member Function Documentation

◆ acquire()

void evf::GlobalEvFOutputModule::acquire	(	edm::StreamID	id,
		edm::EventForOutput const &	e,
		edm::WaitingTaskWithArenaHolder	iHolder
	)		const

finalprivate

Definition at line 492 of file GlobalEvFOutputModule.cc.

References edmScanValgrind::buffer, MillePedeFileConverter_cfg::e, getTriggerResults(), edm::WaitingTaskWithArenaHolder::makeWaitingTaskHolderAndRelease(), metaDataCache_, eostools::move(), mps_check::msg, msgBuilders_, edm::core::OutputModuleCore::selectorConfig(), triggerResults, and trToken_.

                                                                                    {
     edm::Handle<edm::TriggerResults> const& triggerResults = getTriggerResults(trToken_, e);
 
     auto buffer = streamCache(id);
     std::unique_ptr<EventMsgBuilder> msg =
         msgBuilders_->serializeEvent(*buffer, e, triggerResults, selectorConfig(), metaDataCache_->checksum_);
 
     auto lumiWriter = luminosityBlockCache(e.getLuminosityBlock().index());
     const_cast<evf::GlobalEvFOutputEventWriter*>(lumiWriter)
         ->doOutputEventAsync(std::move(msg), iHolder.makeWaitingTaskHolderAndRelease());
   }

◆ beginJob()

void evf::GlobalEvFOutputModule::beginJob ( void )

finalprivatevirtual

Reimplemented from edm::core::OutputModuleCore.

Definition at line 472 of file GlobalEvFOutputModule.cc.

References cacheEventMetaData(), commonParameters_, edm::core::OutputModuleCore::description(), edm::InEvent, edm::core::OutputModuleCore::keptProducts(), edm::ModuleDescription::moduleLabel(), and msgBuilders_.

                                        {
     msgBuilders_ = std::make_unique<StreamerOutputMsgBuilders>(
         commonParameters_, &keptProducts()[edm::InEvent], description().moduleLabel());
 
     cacheEventMetaData();
   }

◆ beginStream()

std::unique_ptr< SerializeDataBuffer > evf::GlobalEvFOutputModule::beginStream ( edm::StreamID ) const

finalprivate

Definition at line 386 of file GlobalEvFOutputModule.cc.

                                                                                          {
     return std::make_unique<SerializeDataBuffer>();
   }

◆ cacheEventMetaData()

void evf::GlobalEvFOutputModule::cacheEventMetaData ( )

private

Definition at line 488 of file GlobalEvFOutputModule.cc.

References edm::core::OutputModuleCore::branchIDLists(), metaDataCache_, msgBuilders_, and edm::core::OutputModuleCore::thinnedAssociationsHelper().

Referenced by beginJob(), and respondToOpenInputFile().

                                                  {
     metaDataCache_ = std::make_shared<MetaDataCache>(*msgBuilders_, *branchIDLists(), *thinnedAssociationsHelper());
   }

◆ fillDescriptions()

void evf::GlobalEvFOutputModule::fillDescriptions ( edm::ConfigurationDescriptions & descriptions )

static

Definition at line 377 of file GlobalEvFOutputModule.cc.

References edm::ConfigurationDescriptions::add(), submitPVResolutionJobs::desc, edm::streamer::StreamerOutputMsgBuilders::fillDescription(), and edm::core::OutputModuleCore::fillDescription().

                                                                                          {
     edm::ParameterSetDescription desc;
     StreamerOutputMsgBuilders::fillDescription(desc);
     GlobalEvFOutputModuleType::fillDescription(desc);
     desc.addUntracked<edm::InputTag>("psetMap", {"hltPSetMap"})
         ->setComment("Optionally allow the map of ParameterSets to be calculated externally.");
     descriptions.add("globalEvfOutputModule", desc);
   }

◆ getTriggerResults()

Trig evf::GlobalEvFOutputModule::getTriggerResults	(	edm::EDGetTokenT< edm::TriggerResults > const &	token,
		edm::EventForOutput const &	e
	)		const

private

Definition at line 456 of file GlobalEvFOutputModule.cc.

References MillePedeFileConverter_cfg::e, mps_fire::result, and unpackBuffers-CaloStage2::token.

Referenced by acquire().

                                                                                   {
     Trig result;
     e.getByToken<edm::TriggerResults>(token, result);
     return result;
   }

◆ globalBeginLuminosityBlock()

std::shared_ptr< GlobalEvFOutputEventWriter > evf::GlobalEvFOutputModule::globalBeginLuminosityBlock ( edm::LuminosityBlockForOutput const & iLB ) const

finalprivate

Definition at line 463 of file GlobalEvFOutputModule.cc.

References lastWriter_, edm::LuminosityBlockForOutput::luminosityBlock(), metaDataCache_, runTheMatrix::ret, and streamLabel_.

                                                     {
     auto openDatFilePath = edm::Service<evf::EvFDaqDirector>()->getOpenDatFilePath(iLB.luminosityBlock(), streamLabel_);
 
     auto ret = std::make_shared<GlobalEvFOutputEventWriter>(openDatFilePath, iLB.luminosityBlock(), metaDataCache_);
     lastWriter_ = ret.get();
     return ret;
   }

◆ globalBeginRun()

std::shared_ptr< GlobalEvFOutputJSONDef > evf::GlobalEvFOutputModule::globalBeginRun ( edm::RunForOutput const & run ) const

finalprivate

Definition at line 390 of file GlobalEvFOutputModule.cc.

References cms::Adler32(), edm::streamer::StreamerOutputFile::adler32(), edmScanValgrind::buffer, edm::streamer::StreamerOutputFile::close(), edm::core::OutputModuleCore::description(), Exception, LogDebug, edm::core::OutputModuleCore::moduleDescription(), HerwigMaxPtPartonFilter_cfi::moduleLabel, msgBuilders_, SimL1EmulatorRepack_CalouGT_cff::processName, psetToken_, writedatasetfile::run, TrackRefitter_38T_cff::src, edm_modernize_messagelogger::stat, streamLabel_, AlCaHLTBitMon_QueryRunRegistry::string, and edm::streamer::StreamerOutputFile::write().

                                                                                                               {
     //create run Cache holding JSON file writer and variables
     auto jsonDef = std::make_unique<GlobalEvFOutputJSONDef>(streamLabel_, false);
     jsonDef->updateDestination(streamLabel_);
 
     //output INI file (non-const). This doesn't require globalBeginRun to be finished
     const std::string openIniFileName = edm::Service<evf::EvFDaqDirector>()->getOpenInitFilePath(streamLabel_);
     edm::LogInfo("GlobalEvFOutputModule") << "beginRun init stream -: " << openIniFileName;
 
     StreamerOutputFile stream_writer_preamble(openIniFileName);
     uint32 preamble_adler32 = 1;
 
     auto psetMapHandle = run.getHandle(psetToken_);
 
     SerializeDataBuffer buffer;
     std::unique_ptr<InitMsgBuilder> init_message =
         msgBuilders_->serializeRegistry(buffer,
                                         OutputModule::processName(),
                                         description().moduleLabel(),
                                         moduleDescription().mainParameterSetID(),
                                         psetMapHandle.isValid() ? psetMapHandle.product() : nullptr);
 
     //Let us turn it into a View
     InitMsgView view(init_message->startAddress());
 
     //output header
     stream_writer_preamble.write(view);
     preamble_adler32 = stream_writer_preamble.adler32();
     stream_writer_preamble.close();
 
     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;
     std::ifstream src(openIniFileName, std::ifstream::binary);
     if (!src)
       throw cms::Exception("GlobalEvFOutputModule")
           << "can not read back " << openIniFileName << " error: " << strerror(errno);
 
     //allocate buffer to write INI file
     std::unique_ptr<char[]> outBuf = std::make_unique<char[]>(1024 * 1024);
     while (readInput < istat.st_size) {
       size_t toRead = readInput + 1024 * 1024 < istat.st_size ? 1024 * 1024 : istat.st_size - readInput;
       src.read(outBuf.get(), toRead);
       //cms::Adler32(const_cast<const char*>(reinterpret_cast<char*>(outBuf.get())), toRead, adlera, adlerb);
       cms::Adler32(const_cast<const char*>(outBuf.get()), toRead, adlera, adlerb);
       readInput += toRead;
     }
     src.close();
 
     //free output buffer needed only for the file write
     outBuf.reset();
 
     uint32_t adler32c = (adlerb << 16) | adlera;
     if (adler32c != preamble_adler32) {
       throw cms::Exception("GlobalEvFOutputModule") << "Checksum mismatch of ini file -: " << openIniFileName
                                                     << " expected:" << preamble_adler32 << " obtained:" << adler32c;
     } else {
       LogDebug("GlobalEvFOutputModule") << "Ini file checksum -: " << streamLabel_ << " " << adler32c;
       std::filesystem::rename(openIniFileName, edm::Service<evf::EvFDaqDirector>()->getInitFilePath(streamLabel_));
     }
 
     return jsonDef;
   }

◆ globalEndLuminosityBlock()

void evf::GlobalEvFOutputModule::globalEndLuminosityBlock ( edm::LuminosityBlockForOutput const & iLB ) const

finalprivate

Definition at line 507 of file GlobalEvFOutputModule.cc.

References fms_, evf::FastMonitoringService::getEventsProcessedForLumi(), edm::LuminosityBlockForOutput::getRun(), edm::LuminosityBlockForOutput::index(), edm::RunForOutput::index(), edm::LuminosityBlockForOutput::luminosityBlock(), castor_dqm_sourceclient_file_cfg::path, edm_modernize_messagelogger::stat, streamLabel_, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                                    {
     auto lumiWriter = luminosityBlockCache(iLB.index());
     //close dat file
     const bool discarded = const_cast<evf::GlobalEvFOutputEventWriter*>(lumiWriter)->close();
 
     //auto jsonWriter = const_cast<GlobalEvFOutputJSONWriter*>(runCache(iLB.getRun().index()));
     auto jsonDef = runCache(iLB.getRun().index());
     GlobalEvFOutputJSONWriter jsonWriter(streamLabel_,
                                          jsonDef->outJsonDef_,
                                          jsonDef->outJsonDefName_,
                                          jsonDef->transferDestination_,
                                          jsonDef->mergeType_);
 
     jsonWriter.fileAdler32_.value() = lumiWriter->get_adler32();
     jsonWriter.accepted_.value() = lumiWriter->getAccepted();
 
     bool abortFlag = false;
 
     if (!discarded) {
       jsonWriter.processed_.value() = fms_->getEventsProcessedForLumi(iLB.luminosityBlock(), &abortFlag);
     } else {
       jsonWriter.errorEvents_.value() = fms_->getEventsProcessedForLumi(iLB.luminosityBlock(), &abortFlag);
       jsonWriter.processed_.value() = 0;
       jsonWriter.accepted_.value() = 0;
       edm::LogInfo("GlobalEvFOutputModule")
           << "Output suppressed, setting error events for LS -: " << iLB.luminosityBlock();
     }
 
     if (abortFlag) {
       edm::LogInfo("GlobalEvFOutputModule") << "Abort flag has been set. Output is suppressed";
       return;
     }
 
     if (jsonWriter.processed_.value() != 0) {
       struct stat istat;
       std::filesystem::path openDatFilePath = lumiWriter->getFilePath();
       stat(openDatFilePath.string().c_str(), &istat);
       jsonWriter.filesize_ = istat.st_size;
       std::filesystem::rename(openDatFilePath.string().c_str(),
                               edm::Service<evf::EvFDaqDirector>()->getDatFilePath(iLB.luminosityBlock(), streamLabel_));
       jsonWriter.filelist_ = openDatFilePath.filename().string();
     } else {
       //remove empty file when no event processing has occurred
       remove(lumiWriter->getFilePath().c_str());
       jsonWriter.filesize_ = 0;
       jsonWriter.filelist_ = "";
       jsonWriter.fileAdler32_.value() = -1;  //no files in signed long
     }
 
     //produce JSON file
     jsonWriter.jsonMonitor_->snap(iLB.luminosityBlock());
     const std::string outputJsonNameStream =
         edm::Service<evf::EvFDaqDirector>()->getOutputJsonFilePath(iLB.luminosityBlock(), streamLabel_);
     jsonWriter.jsonMonitor_->outputFullJSON(outputJsonNameStream, iLB.luminosityBlock());
   }

◆ globalEndRun()

void evf::GlobalEvFOutputModule::globalEndRun ( edm::RunForOutput const & ) const

inlinefinalprivate

Definition at line 210 of file GlobalEvFOutputModule.cc.

210 {}

◆ respondToCloseInputFile()

void evf::GlobalEvFOutputModule::respondToCloseInputFile ( edm::FileBlock const & )

inlinefinalprivate

Definition at line 213 of file GlobalEvFOutputModule.cc.

213 {}

◆ respondToOpenInputFile()

void evf::GlobalEvFOutputModule::respondToOpenInputFile ( edm::FileBlock const & )

finalprivate

Definition at line 479 of file GlobalEvFOutputModule.cc.

References edm::core::OutputModuleCore::branchIDLists(), cacheEventMetaData(), lastWriter_, metaDataCache_, presentBranchIDListSize_, and findQualityFiles::size.

                                                                         {
     if (branchIDLists()->size() != presentBranchIDListSize_) {
       cacheEventMetaData();
       if (lastWriter_) {
         lastWriter_.load()->setMetaCache(metaDataCache_);
       }
     }
   }

◆ write()

void evf::GlobalEvFOutputModule::write ( edm::EventForOutput const & e )

finalprivatevirtual

Implements edm::core::OutputModuleCore.

Definition at line 505 of file GlobalEvFOutputModule.cc.

Referenced by pkg.AbstractPkg::generate().

505 {}

◆ writeLuminosityBlock()

void evf::GlobalEvFOutputModule::writeLuminosityBlock ( edm::LuminosityBlockForOutput const & )

inlinefinalprivatevirtual

Implements edm::core::OutputModuleCore.

Definition at line 208 of file GlobalEvFOutputModule.cc.

208 {}

◆ writeRun()

void evf::GlobalEvFOutputModule::writeRun ( edm::RunForOutput const & )

inlinefinalprivatevirtual

Implements edm::core::OutputModuleCore.

Definition at line 209 of file GlobalEvFOutputModule.cc.

209 {}

Member Data Documentation

◆ commonParameters_

StreamerOutputMsgBuilders::Parameters evf::GlobalEvFOutputModule::commonParameters_

private

Definition at line 224 of file GlobalEvFOutputModule.cc.

Referenced by beginJob().

◆ fms_

evf::FastMonitoringService* evf::GlobalEvFOutputModule::fms_

private

Definition at line 230 of file GlobalEvFOutputModule.cc.

Referenced by globalEndLuminosityBlock(), and GlobalEvFOutputModule().

◆ lastWriter_

std::atomic<GlobalEvFOutputEventWriter*> evf::GlobalEvFOutputModule::lastWriter_ = nullptr

mutableprivate

Definition at line 235 of file GlobalEvFOutputModule.cc.

Referenced by globalBeginLuminosityBlock(), and respondToOpenInputFile().

◆ metaDataCache_

std::shared_ptr<MetaDataCache const> evf::GlobalEvFOutputModule::metaDataCache_

private

Definition at line 232 of file GlobalEvFOutputModule.cc.

Referenced by acquire(), cacheEventMetaData(), globalBeginLuminosityBlock(), and respondToOpenInputFile().

◆ msgBuilders_

std::unique_ptr<const StreamerOutputMsgBuilders> evf::GlobalEvFOutputModule::msgBuilders_

private

Definition at line 225 of file GlobalEvFOutputModule.cc.

Referenced by acquire(), beginJob(), cacheEventMetaData(), and globalBeginRun().

◆ presentBranchIDListSize_

unsigned int evf::GlobalEvFOutputModule::presentBranchIDListSize_ = 0

private

Definition at line 236 of file GlobalEvFOutputModule.cc.

Referenced by respondToOpenInputFile().

◆ psetToken_

edm::EDGetTokenT<edm::SendJobHeader::ParameterSetMap> evf::GlobalEvFOutputModule::psetToken_

private

Definition at line 228 of file GlobalEvFOutputModule.cc.

Referenced by globalBeginRun().

◆ streamLabel_

std::string evf::GlobalEvFOutputModule::streamLabel_

private

Definition at line 226 of file GlobalEvFOutputModule.cc.

Referenced by globalBeginLuminosityBlock(), globalBeginRun(), globalEndLuminosityBlock(), and GlobalEvFOutputModule().

◆ trToken_

edm::EDGetTokenT<edm::TriggerResults> evf::GlobalEvFOutputModule::trToken_

private

Definition at line 227 of file GlobalEvFOutputModule.cc.

Referenced by acquire().

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ GlobalEvFOutputModule()

◆ ~GlobalEvFOutputModule()

Member Function Documentation

◆ acquire()

◆ beginJob()

◆ beginStream()

◆ cacheEventMetaData()

◆ fillDescriptions()

◆ getTriggerResults()

◆ globalBeginLuminosityBlock()

◆ globalBeginRun()

◆ globalEndLuminosityBlock()

◆ globalEndRun()

◆ respondToCloseInputFile()

◆ respondToOpenInputFile()

◆ write()

◆ writeLuminosityBlock()

◆ writeRun()

Member Data Documentation

◆ commonParameters_

◆ fms_

◆ lastWriter_

◆ metaDataCache_

◆ msgBuilders_

◆ presentBranchIDListSize_

◆ psetToken_

◆ streamLabel_

◆ trToken_