|
| GlobalEvFOutputModule (edm::ParameterSet const &ps) |
|
| ~GlobalEvFOutputModule () override |
|
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 |
|
OutputModuleBase & | operator= (OutputModuleBase const &)=delete |
|
| OutputModuleBase (ParameterSet const &pset) |
|
| OutputModuleBase (OutputModuleBase const &)=delete |
|
bool | wantsGlobalLuminosityBlocks () const |
|
bool | wantsGlobalRuns () const |
|
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 |
|
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) |
|
|
typedef OutputModuleBase | ModuleType |
|
typedef OutputModuleCore | ModuleType |
|
typedef ProductLabels | Labels |
|
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 |
|
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) |
|
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 () |
|
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) |
|
std::atomic< int > | remainingEvents_ |
|
Definition at line 139 of file GlobalEvFOutputModule.cc.
Definition at line 306 of file GlobalEvFOutputModule.cc.
References cms::Adler32(), StreamerOutputFile::adler32(), edm::core::OutputModuleCore::branchIDLists(), StreamerOutputFile::close(), edm::core::OutputModuleCore::description(), Exception, edm::InEvent, edm::Hash< I >::isValid(), edm::core::OutputModuleCore::keptProducts(), LogDebug, edm::ModuleDescription::mainParameterSetID(), edm::core::OutputModuleCore::moduleDescription(), HerwigMaxPtPartonFilter_cfi::moduleLabel, edm::ModuleDescription::moduleLabel(), SimL1EmulatorRepack_CalouGT_cff::processName, ps_, psetToken_, writedatasetfile::run, TrackRefitter_38T_cff::src, edm_modernize_messagelogger::stat, streamLabel_, AlCaHLTBitMon_QueryRunRegistry::string, edm::core::OutputModuleCore::thinnedAssociationsHelper(), and StreamerOutputFile::write().
308 auto jsonDef = std::make_unique<GlobalEvFOutputJSONDef>(
streamLabel_);
314 edm::LogInfo(
"GlobalEvFOutputModule") <<
"beginRun init stream -: " << openIniFileName;
317 uint32 preamble_adler32 = 1;
322 std::unique_ptr<InitMsgBuilder> init_message =
323 streamerCommon.serializeRegistry(*streamerCommon.getSerializerBuffer(),
329 psetMapHandle.
isValid() ? psetMapHandle.product() :
nullptr);
335 stream_writer_preamble.write(view);
336 preamble_adler32 = stream_writer_preamble.adler32();
337 stream_writer_preamble.close();
340 stat(openIniFileName.c_str(), &istat);
343 uint32_t adlera = 1, adlerb = 0;
344 FILE*
src = fopen(openIniFileName.c_str(),
"r");
347 std::unique_ptr<unsigned char[]> outBuf = std::make_unique<unsigned char[]>(1024 * 1024);
348 while (readInput < istat.st_size) {
349 size_t toRead = readInput + 1024 * 1024 < istat.st_size ? 1024 * 1024 : istat.st_size - readInput;
350 fread(outBuf.get(), toRead, 1,
src);
351 cms::Adler32(const_cast<const char*>(reinterpret_cast<char*>(outBuf.get())), toRead, adlera, adlerb);
357 streamerCommon.getSerializerBuffer()->clearHeaderBuffer();
362 uint32_t adler32c = (adlerb << 16) | adlera;
363 if (adler32c != preamble_adler32) {
364 throw cms::Exception(
"GlobalEvFOutputModule") <<
"Checksum mismatch of ini file -: " << openIniFileName
365 <<
" expected:" << preamble_adler32 <<
" obtained:" << adler32c;
367 LogDebug(
"GlobalEvFOutputModule") <<
"Ini file checksum -: " <<
streamLabel_ <<
" " << adler32c;
std::vector< BranchIDList > BranchIDLists
ParameterSetID const & mainParameterSetID() const
ModuleDescription const & description() const
edm::EDGetTokenT< edm::SendJobHeader::ParameterSetMap > psetToken_
ThinnedAssociationsHelper const * thinnedAssociationsHelper() const
BranchIDLists const * branchIDLists() const
Log< level::Info, false > LogInfo
void Adler32(char const *data, size_t len, uint32_t &a, uint32_t &b)
SelectedProductsForBranchType const & keptProducts() const
edm::ParameterSet const & ps_
const ModuleDescription & moduleDescription() const
std::string const & moduleLabel() const