CMS 3D CMS Logo

List of all members | Public Member Functions | Static Public Member Functions | Private Member Functions | Private Attributes
evf::GlobalEvFOutputModule Class Reference
Inheritance diagram for evf::GlobalEvFOutputModule:
edm::global::OutputModule< T > edm::global::OutputModuleBase edm::EDConsumerBase

Public Member Functions

 GlobalEvFOutputModule (edm::ParameterSet const &ps)
 
 ~GlobalEvFOutputModule () override
 
- Public Member Functions inherited from edm::global::OutputModule< T >
const OutputModuleoperator= (const OutputModule &)=delete
 
 OutputModule (const OutputModule &)=delete
 
 OutputModule (edm::ParameterSet const &iPSet)
 
bool wantsInputProcessBlocks () const final
 
bool wantsProcessBlocks () const final
 
bool wantsStreamLuminosityBlocks () const final
 
bool wantsStreamRuns () const final
 
- Public Member Functions inherited from edm::global::OutputModuleBase
BranchIDLists const * branchIDLists () const
 
std::array< bool, NumBranchTypes > const & hasNewlyDroppedBranch () const
 
SelectedProductsForBranchType const & keptProducts () const
 
int maxEvents () const
 
const ModuleDescriptionmoduleDescription () const
 
OutputModuleBaseoperator= (OutputModuleBase const &)=delete
 
 OutputModuleBase (OutputModuleBase const &)=delete
 
 OutputModuleBase (ParameterSet const &pset)
 
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
 
bool wantsGlobalLuminosityBlocks () const
 
bool wantsGlobalRuns () const
 
 ~OutputModuleBase () override
 
- Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfoconsumesInfo () const
 
void convertCurrentProcessAlias (std::string const &processName)
 Convert "@currentProcess" in InputTag process names to the actual current process name. More...
 
 EDConsumerBase ()
 
 EDConsumerBase (EDConsumerBase &&)=default
 
 EDConsumerBase (EDConsumerBase const &)=delete
 
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
 
EDConsumerBaseoperator= (EDConsumerBase &&)=default
 
EDConsumerBase const & operator= (EDConsumerBase const &)=delete
 
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::global::OutputModuleBase
static const std::string & baseType ()
 
static void fillDescription (ParameterSetDescription &desc)
 
static void fillDescriptions (ConfigurationDescriptions &descriptions)
 
static void prevalidate (ConfigurationDescriptions &)
 

Private Member Functions

void acquire (edm::StreamID, edm::EventForOutput const &, edm::WaitingTaskWithArenaHolder) const final
 
std::unique_ptr< edm::StreamerOutputModuleCommonbeginStream (edm::StreamID) const final
 
Trig getTriggerResults (edm::EDGetTokenT< edm::TriggerResults > const &token, edm::EventForOutput const &e) const
 
std::shared_ptr< GlobalEvFOutputEventWriterglobalBeginLuminosityBlock (edm::LuminosityBlockForOutput const &iLB) const final
 
std::shared_ptr< GlobalEvFOutputJSONDefglobalBeginRun (edm::RunForOutput const &run) const final
 
void globalEndLuminosityBlock (edm::LuminosityBlockForOutput const &iLB) const final
 
void globalEndRun (edm::RunForOutput const &) const final
 
void write (edm::EventForOutput const &e) final
 
void writeLuminosityBlock (edm::LuminosityBlockForOutput const &) final
 
void writeRun (edm::RunForOutput const &) final
 

Private Attributes

evf::FastMonitoringServicefms_
 
edm::ParameterSet const & ps_
 
edm::EDGetTokenT< edm::SendJobHeader::ParameterSetMappsetToken_
 
std::string streamLabel_
 
edm::EDGetTokenT< edm::TriggerResultstrToken_
 

Additional Inherited Members

- Public Types inherited from edm::global::OutputModuleBase
typedef OutputModuleBase ModuleType
 
- Public Types inherited from edm::EDConsumerBase
typedef ProductLabels Labels
 
- Protected Member Functions inherited from edm::global::OutputModuleBase
void configure (OutputModuleDescription const &desc)
 
ModuleDescription const & description () const
 
void doAccessInputProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)
 
void doAcquire (EventTransitionInfo const &, ActivityRegistry *, ModuleCallingContext const *, WaitingTaskWithArenaHolder &)
 
void doBeginJob ()
 
bool doBeginLuminosityBlock (LumiTransitionInfo const &, ModuleCallingContext const *)
 
void doBeginProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)
 
bool doBeginRun (RunTransitionInfo const &, ModuleCallingContext const *)
 
void doBeginStream (StreamID id)
 
void doEndJob ()
 
bool doEndLuminosityBlock (LumiTransitionInfo const &, ModuleCallingContext const *)
 
void doEndProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)
 
bool doEndRun (RunTransitionInfo const &, ModuleCallingContext const *)
 
void doEndStream (StreamID id)
 
bool doEvent (EventTransitionInfo const &, ActivityRegistry *, ModuleCallingContext const *)
 
void doPreallocate (PreallocationConfiguration const &)
 
std::map< BranchID::value_type, BranchID::value_type > const & droppedBranchIDToKeptBranchID ()
 
void preActionBeforeRunEventAsync (WaitingTaskHolder iTask, ModuleCallingContext const &iModuleCallingContext, Principal const &iPrincipal) const
 
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
EDGetToken consumes (const TypeToGet &id, edm::InputTag const &tag)
 
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > consumes (edm::InputTag const &tag)
 
template<BranchType B = InEvent>
EDConsumerBaseAdaptor< B > consumes (edm::InputTag tag) noexcept
 
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<Transition Tr = Transition::Event>
constexpr auto esConsumes () noexcept
 
template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto esConsumes (ESInputTag const &tag)
 
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...
 
EDGetToken mayConsume (const TypeToGet &id, edm::InputTag const &tag)
 
template<BranchType B>
EDGetToken mayConsume (const TypeToGet &id, edm::InputTag const &tag)
 
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > mayConsume (edm::InputTag const &tag)
 

Detailed Description

Definition at line 121 of file GlobalEvFOutputModule.cc.

Constructor & Destructor Documentation

◆ GlobalEvFOutputModule()

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

Definition at line 236 of file GlobalEvFOutputModule.cc.

239  ps_(ps),
240  streamLabel_(ps.getParameter<std::string>("@module_label")),
241  trToken_(consumes<edm::TriggerResults>(edm::InputTag("TriggerResults"))),
242  psetToken_(consumes<edm::SendJobHeader::ParameterSetMap, edm::InRun>(
243  ps.getUntrackedParameter<edm::InputTag>("psetMap"))) {
244  //replace hltOutoputA with stream if the HLT menu uses this convention
245  std::string testPrefix = "hltOutput";
246  if (streamLabel_.find(testPrefix) == 0)
247  streamLabel_ = std::string("stream") + streamLabel_.substr(testPrefix.size());
248 
249  if (streamLabel_.find('_') != std::string::npos) {
250  throw cms::Exception("GlobalEvFOutputModule")
251  << "Underscore character is reserved can not be used for stream names in "
252  "FFF, but was detected in stream name -: "
253  << streamLabel_;
254  }
255 
256  std::string streamLabelLow = streamLabel_;
257  boost::algorithm::to_lower(streamLabelLow);
258  auto streampos = streamLabelLow.rfind("stream");
259  if (streampos != 0 && streampos != std::string::npos)
260  throw cms::Exception("GlobalEvFOutputModule")
261  << "stream (case-insensitive) sequence was found in stream suffix. This is reserved and can not be used for "
262  "names in FFF based HLT, but was detected in stream name";
263 
265  }

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

◆ ~GlobalEvFOutputModule()

evf::GlobalEvFOutputModule::~GlobalEvFOutputModule ( )
override

Definition at line 267 of file GlobalEvFOutputModule.cc.

267 {}

Member Function Documentation

◆ acquire()

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

Definition at line 364 of file GlobalEvFOutputModule.cc.

366  {
368 
369  auto streamerCommon = streamCache(id);
370  std::unique_ptr<EventMsgBuilder> msg =
371  streamerCommon->serializeEvent(*streamerCommon->getSerializerBuffer(), e, triggerResults, selectorConfig());
372 
373  auto lumiWriter = luminosityBlockCache(e.getLuminosityBlock().index());
374  const_cast<evf::GlobalEvFOutputEventWriter*>(lumiWriter)
375  ->doOutputEventAsync(std::move(msg), iHolder.makeWaitingTaskHolderAndRelease());
376  }

References MillePedeFileConverter_cfg::e, getTriggerResults(), edm::WaitingTaskWithArenaHolder::makeWaitingTaskHolderAndRelease(), eostools::move(), mps_check::msg, edm::global::OutputModuleBase::selectorConfig(), triggerResults, and trToken_.

◆ beginStream()

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

Definition at line 278 of file GlobalEvFOutputModule.cc.

278  {
279  return std::make_unique<edm::StreamerOutputModuleCommon>(ps_, &keptProducts()[edm::InEvent]);
280  }

References edm::InEvent, edm::global::OutputModuleBase::keptProducts(), and ps_.

◆ fillDescriptions()

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

Definition at line 269 of file GlobalEvFOutputModule.cc.

269  {
273  desc.addUntracked<edm::InputTag>("psetMap", {"hltPSetMap"})
274  ->setComment("Optionally allow the map of ParameterSets to be calculated externally.");
275  descriptions.add("globalEvfOutputModule", desc);
276  }

References edm::ConfigurationDescriptions::add(), submitPVResolutionJobs::desc, edm::StreamerOutputModuleCommon::fillDescription(), and edm::global::OutputModuleBase::fillDescription().

◆ getTriggerResults()

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

Definition at line 350 of file GlobalEvFOutputModule.cc.

351  {
352  Trig result;
353  e.getByToken<edm::TriggerResults>(token, result);
354  return result;
355  }

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

Referenced by acquire().

◆ globalBeginLuminosityBlock()

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

Definition at line 357 of file GlobalEvFOutputModule.cc.

358  {
359  auto openDatFilePath = edm::Service<evf::EvFDaqDirector>()->getOpenDatFilePath(iLB.luminosityBlock(), streamLabel_);
360 
361  return std::make_shared<GlobalEvFOutputEventWriter>(openDatFilePath);
362  }

References edm::LuminosityBlockForOutput::luminosityBlock(), and streamLabel_.

◆ globalBeginRun()

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

Definition at line 282 of file GlobalEvFOutputModule.cc.

282  {
283  //create run Cache holding JSON file writer and variables
284  auto jsonDef = std::make_unique<GlobalEvFOutputJSONDef>();
285 
287 
288  //output INI file (non-const). This doesn't require globalBeginRun to be finished
289  const std::string openIniFileName = edm::Service<evf::EvFDaqDirector>()->getOpenInitFilePath(streamLabel_);
290  edm::LogInfo("GlobalEvFOutputModule") << "beginRun init stream -: " << openIniFileName;
291 
292  StreamerOutputFile stream_writer_preamble(openIniFileName);
293  uint32 preamble_adler32 = 1;
294  edm::BranchIDLists const* bidlPtr = branchIDLists();
295 
296  auto psetMapHandle = run.getHandle(psetToken_);
297 
298  std::unique_ptr<InitMsgBuilder> init_message =
299  streamerCommon.serializeRegistry(*streamerCommon.getSerializerBuffer(),
300  *bidlPtr,
305  psetMapHandle.isValid() ? psetMapHandle.product() : nullptr);
306 
307  //Let us turn it into a View
308  InitMsgView view(init_message->startAddress());
309 
310  //output header
311  stream_writer_preamble.write(view);
312  preamble_adler32 = stream_writer_preamble.adler32();
313  stream_writer_preamble.close();
314 
315  struct stat istat;
316  stat(openIniFileName.c_str(), &istat);
317  //read back file to check integrity of what was written
318  off_t readInput = 0;
319  uint32_t adlera = 1, adlerb = 0;
320  FILE* src = fopen(openIniFileName.c_str(), "r");
321 
322  //allocate buffer to write INI file
323  std::unique_ptr<unsigned char[]> outBuf = std::make_unique<unsigned char[]>(1024 * 1024);
324  while (readInput < istat.st_size) {
325  size_t toRead = readInput + 1024 * 1024 < istat.st_size ? 1024 * 1024 : istat.st_size - readInput;
326  fread(outBuf.get(), toRead, 1, src);
327  cms::Adler32(const_cast<const char*>(reinterpret_cast<char*>(outBuf.get())), toRead, adlera, adlerb);
328  readInput += toRead;
329  }
330  fclose(src);
331 
332  //clear serialization buffers
333  streamerCommon.getSerializerBuffer()->clearHeaderBuffer();
334 
335  //free output buffer needed only for the file write
336  outBuf.reset();
337 
338  uint32_t adler32c = (adlerb << 16) | adlera;
339  if (adler32c != preamble_adler32) {
340  throw cms::Exception("GlobalEvFOutputModule") << "Checksum mismatch of ini file -: " << openIniFileName
341  << " expected:" << preamble_adler32 << " obtained:" << adler32c;
342  } else {
343  LogDebug("GlobalEvFOutputModule") << "Ini file checksum -: " << streamLabel_ << " " << adler32c;
344  std::filesystem::rename(openIniFileName, edm::Service<evf::EvFDaqDirector>()->getInitFilePath(streamLabel_));
345  }
346 
347  return jsonDef;
348  }

References cms::Adler32(), StreamerOutputFile::adler32(), edm::global::OutputModuleBase::branchIDLists(), SerializeDataBuffer::clearHeaderBuffer(), StreamerOutputFile::close(), edm::global::OutputModuleBase::description(), Exception, edm::StreamerOutputModuleCommon::getSerializerBuffer(), edm::InEvent, edm::Hash< I >::isValid(), edm::global::OutputModuleBase::keptProducts(), LogDebug, edm::ModuleDescription::mainParameterSetID(), edm::global::OutputModuleBase::moduleDescription(), edm::ModuleDescription::moduleLabel(), SimL1EmulatorRepack_CalouGT_cff::processName, ps_, psetToken_, writedatasetfile::run, edm::StreamerOutputModuleCommon::serializeRegistry(), TrackRefitter_38T_cff::src, edm_modernize_messagelogger::stat, streamLabel_, AlCaHLTBitMon_QueryRunRegistry::string, edm::global::OutputModuleBase::thinnedAssociationsHelper(), and StreamerOutputFile::write().

◆ globalEndLuminosityBlock()

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

Definition at line 379 of file GlobalEvFOutputModule.cc.

379  {
380  auto lumiWriter = luminosityBlockCache(iLB.index());
381  //close dat file
382  const_cast<evf::GlobalEvFOutputEventWriter*>(lumiWriter)->close();
383 
384  //auto jsonWriter = const_cast<GlobalEvFOutputJSONWriter*>(runCache(iLB.getRun().index()));
385  auto jsonDef = runCache(iLB.getRun().index());
386  GlobalEvFOutputJSONWriter jsonWriter(streamLabel_, jsonDef->outJsonDef_, jsonDef->outJsonDefName_);
387 
388  jsonWriter.fileAdler32_.value() = lumiWriter->get_adler32();
389  jsonWriter.accepted_.value() = lumiWriter->getAccepted();
390 
391  bool abortFlag = false;
392  jsonWriter.processed_.value() = fms_->getEventsProcessedForLumi(iLB.luminosityBlock(), &abortFlag);
393  if (abortFlag) {
394  edm::LogInfo("GlobalEvFOutputModule") << "Abort flag has been set. Output is suppressed";
395  return;
396  }
397 
398  if (jsonWriter.processed_.value() != 0) {
399  struct stat istat;
400  std::filesystem::path openDatFilePath = lumiWriter->getFilePath();
401  stat(openDatFilePath.string().c_str(), &istat);
402  jsonWriter.filesize_ = istat.st_size;
403  std::filesystem::rename(openDatFilePath.string().c_str(),
404  edm::Service<evf::EvFDaqDirector>()->getDatFilePath(iLB.luminosityBlock(), streamLabel_));
405  jsonWriter.filelist_ = openDatFilePath.filename().string();
406  } else {
407  //remove empty file when no event processing has occurred
408  remove(lumiWriter->getFilePath().c_str());
409  jsonWriter.filesize_ = 0;
410  jsonWriter.filelist_ = "";
411  jsonWriter.fileAdler32_.value() = -1; //no files in signed long
412  }
413 
414  //produce JSON file
415  jsonWriter.jsonMonitor_->snap(iLB.luminosityBlock());
416  const std::string outputJsonNameStream =
417  edm::Service<evf::EvFDaqDirector>()->getOutputJsonFilePath(iLB.luminosityBlock(), streamLabel_);
418  jsonWriter.jsonMonitor_->outputFullJSON(outputJsonNameStream, iLB.luminosityBlock());
419  }

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

◆ globalEndRun()

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

Definition at line 138 of file GlobalEvFOutputModule.cc.

138 {}

◆ write()

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

Implements edm::global::OutputModuleBase.

Definition at line 377 of file GlobalEvFOutputModule.cc.

377 {}

Referenced by pkg.AbstractPkg::generate().

◆ writeLuminosityBlock()

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

Implements edm::global::OutputModuleBase.

Definition at line 136 of file GlobalEvFOutputModule.cc.

136 {}

◆ writeRun()

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

Implements edm::global::OutputModuleBase.

Definition at line 137 of file GlobalEvFOutputModule.cc.

137 {}

Member Data Documentation

◆ fms_

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

Definition at line 151 of file GlobalEvFOutputModule.cc.

Referenced by globalEndLuminosityBlock(), and GlobalEvFOutputModule().

◆ ps_

edm::ParameterSet const& evf::GlobalEvFOutputModule::ps_
private

Definition at line 146 of file GlobalEvFOutputModule.cc.

Referenced by beginStream(), and globalBeginRun().

◆ psetToken_

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

Definition at line 149 of file GlobalEvFOutputModule.cc.

Referenced by globalBeginRun().

◆ streamLabel_

std::string evf::GlobalEvFOutputModule::streamLabel_
private

◆ trToken_

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

Definition at line 148 of file GlobalEvFOutputModule.cc.

Referenced by acquire().

edm::ModuleDescription::moduleLabel
std::string const & moduleLabel() const
Definition: ModuleDescription.h:43
edm::global::OutputModuleBase::branchIDLists
BranchIDLists const * branchIDLists() const
Definition: OutputModuleBase.cc:356
evf::GlobalEvFOutputModule::ps_
edm::ParameterSet const & ps_
Definition: GlobalEvFOutputModule.cc:146
evf::FastMonitoringService::getEventsProcessedForLumi
unsigned int getEventsProcessedForLumi(unsigned int lumi, bool *abortFlag=nullptr)
Definition: FastMonitoringService.cc:724
edm::global::OutputModuleBase::description
ModuleDescription const & description() const
Definition: OutputModuleBase.cc:367
edm::global::OutputModuleBase
Definition: OutputModuleBase.h:66
evf::GlobalEvFOutputModule::fms_
evf::FastMonitoringService * fms_
Definition: GlobalEvFOutputModule.cc:151
edm::global::OutputModuleBase::selectorConfig
ParameterSetID selectorConfig() const
Definition: OutputModuleBase.h:124
edm::ParameterSetDescription
Definition: ParameterSetDescription.h:52
triggerResults
static const std::string triggerResults
Definition: EdmProvDump.cc:45
mps_check.msg
tuple msg
Definition: mps_check.py:285
edm::LogInfo
Log< level::Info, false > LogInfo
Definition: MessageLogger.h:125
edm::Handle< edm::TriggerResults >
uint32
unsigned int uint32
Definition: MsgTools.h:13
evf::FastMonitoringService
Definition: FastMonitoringService.h:153
edm::Hash::isValid
bool isValid() const
Definition: Hash.h:141
edm::ConfigurationDescriptions::add
void add(std::string const &label, ParameterSetDescription const &psetDescription)
Definition: ConfigurationDescriptions.cc:57
cms::Adler32
void Adler32(char const *data, size_t len, uint32_t &a, uint32_t &b)
Definition: Adler32Calculator.cc:10
edm::global::OutputModuleBase::moduleDescription
const ModuleDescription & moduleDescription() const
Definition: OutputModuleBase.h:110
StreamerOutputFile
Definition: StreamerOutputFile.h:23
edm::InEvent
Definition: BranchType.h:11
edm::BranchIDLists
std::vector< BranchIDList > BranchIDLists
Definition: BranchIDList.h:19
LogDebug
#define LogDebug(id)
Definition: MessageLogger.h:233
evf::GlobalEvFOutputModule::streamLabel_
std::string streamLabel_
Definition: GlobalEvFOutputModule.cc:147
TrackRefitter_38T_cff.src
src
Definition: TrackRefitter_38T_cff.py:24
to_lower
std::string to_lower(const std::string &s)
Definition: CredentialStore.h:23
edm::Service
Definition: Service.h:30
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
SimL1EmulatorRepack_CalouGT_cff.processName
processName
Definition: SimL1EmulatorRepack_CalouGT_cff.py:17
submitPVResolutionJobs.desc
string desc
Definition: submitPVResolutionJobs.py:251
eostools.move
def move(src, dest)
Definition: eostools.py:511
writedatasetfile.run
run
Definition: writedatasetfile.py:27
evf::GlobalEvFOutputModuleType
edm::global::OutputModule< edm::RunCache< GlobalEvFOutputJSONDef >, edm::LuminosityBlockCache< evf::GlobalEvFOutputEventWriter >, edm::StreamCache< edm::StreamerOutputModuleCommon >, edm::ExternalWork > GlobalEvFOutputModuleType
Definition: GlobalEvFOutputModule.cc:119
edm::ModuleDescription::mainParameterSetID
ParameterSetID const & mainParameterSetID() const
Definition: ModuleDescription.cc:53
Exception
Definition: hltDiff.cc:245
MatrixUtil.remove
def remove(d, key, TELL=False)
Definition: MatrixUtil.py:219
edm::global::OutputModuleBase::fillDescription
static void fillDescription(ParameterSetDescription &desc)
Definition: OutputModuleBase.cc:377
edm::WaitingTaskWithArenaHolder::makeWaitingTaskHolderAndRelease
WaitingTaskHolder makeWaitingTaskHolderAndRelease()
Definition: WaitingTaskWithArenaHolder.cc:103
evf::GlobalEvFOutputJSONWriter
Definition: GlobalEvFOutputModule.cc:95
mps_fire.result
result
Definition: mps_fire.py:311
evf::GlobalEvFOutputModule::trToken_
edm::EDGetTokenT< edm::TriggerResults > trToken_
Definition: GlobalEvFOutputModule.cc:148
evf::GlobalEvFOutputModule::getTriggerResults
Trig getTriggerResults(edm::EDGetTokenT< edm::TriggerResults > const &token, edm::EventForOutput const &e) const
Definition: GlobalEvFOutputModule.cc:350
castor_dqm_sourceclient_file_cfg.path
path
Definition: castor_dqm_sourceclient_file_cfg.py:37
edm::StreamerOutputModuleCommon::fillDescription
static void fillDescription(ParameterSetDescription &desc)
Definition: StreamerOutputModuleCommon.cc:270
edm::global::OutputModuleBase::keptProducts
SelectedProductsForBranchType const & keptProducts() const
Definition: OutputModuleBase.h:94
edm_modernize_messagelogger.stat
stat
Definition: edm_modernize_messagelogger.py:27
edm::StreamerOutputModuleCommon
Definition: StreamerOutputModuleCommon.h:21
edm::global::OutputModuleBase::thinnedAssociationsHelper
ThinnedAssociationsHelper const * thinnedAssociationsHelper() const
Definition: OutputModuleBase.cc:363
edm::InputTag
Definition: InputTag.h:15
evf::GlobalEvFOutputModule::psetToken_
edm::EDGetTokenT< edm::SendJobHeader::ParameterSetMap > psetToken_
Definition: GlobalEvFOutputModule.cc:149
edm::TriggerResults
Definition: TriggerResults.h:35
InitMsgView
Definition: InitMessage.h:61
MillePedeFileConverter_cfg.e
e
Definition: MillePedeFileConverter_cfg.py:37
unpackBuffers-CaloStage2.token
token
Definition: unpackBuffers-CaloStage2.py:316