Inheritance diagram for edm::TestOneOutput:

Public Member Functions
	TestOneOutput (ParameterSet const &pset)

	~TestOneOutput () override

Public Member Functions inherited from edm::one::OutputModule< WatchInputFiles, RunCache< int >, LuminosityBlockCache< int > >
SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

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

	OutputModule (edm::ParameterSet const &iPSet)

	OutputModule (const OutputModule &)=delete

bool	wantsGlobalLuminosityBlocks () const noexcept final

bool	wantsGlobalRuns () const noexcept final

bool	wantsInputProcessBlocks () const noexcept final

bool	wantsProcessBlocks () const noexcept 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 noexcept

bool	wantsStreamRuns () const noexcept

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 (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	endJob () override

std::shared_ptr< int >	globalBeginLuminosityBlock (LuminosityBlockForOutput const &) const override

std::shared_ptr< int >	globalBeginRun (RunForOutput const &) const override

void	globalEndLuminosityBlock (LuminosityBlockForOutput const &) override

void	globalEndRun (RunForOutput const &) override

void	respondToCloseInputFile (FileBlock const &) override

void	respondToOpenInputFile (FileBlock const &) override

void	testFileBlock (FileBlock const &)

void	write (EventForOutput const &e) override

void	writeLuminosityBlock (LuminosityBlockForOutput const &) override

void	writeProcessBlock (ProcessBlockForOutput const &) override

void	writeRun (RunForOutput const &) override

Private Attributes
unsigned int	countInputFiles_ = 0

unsigned int	countWriteProcessBlockTransitions_ = 0

std::vector< std::string >	expectedAddedProcesses_

std::vector< unsigned int >	expectedCacheEntriesPerFile0_

std::vector< unsigned int >	expectedCacheEntriesPerFile1_

std::vector< unsigned int >	expectedCacheEntriesPerFile2_

std::vector< unsigned int >	expectedCacheIndexSize_

std::vector< unsigned int >	expectedCacheIndexVectorsPerFile_

unsigned int	expectedNAddedProcesses_

std::vector< unsigned int >	expectedNEntries0_

std::vector< unsigned int >	expectedNEntries1_

std::vector< unsigned int >	expectedNEntries2_

std::vector< unsigned int >	expectedOuterOffset_

unsigned int	expectedProcessesInFirstFile_

std::vector< std::string >	expectedProcessesWithProcessBlockProducts_

std::vector< std::string >	expectedProcessNamesAtWrite_

bool	expectedProductsFromInputKept_

std::vector< std::string >	expectedTopAddedProcesses_

std::vector< unsigned int >	expectedTopCacheIndices0_

std::vector< unsigned int >	expectedTopCacheIndices1_

std::vector< unsigned int >	expectedTopCacheIndices2_

std::vector< std::string >	expectedTopProcessesWithProcessBlockProducts_

std::vector< unsigned int >	expectedTranslateFromStoredIndex_

int	expectedWriteProcessBlockTransitions_

bool	requireNullTTreesInFileBlock_

bool	testTTreesInFileBlock_

bool	verbose_

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 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 24 of file TestOneOutput.cc.

Constructor & Destructor Documentation

◆ TestOneOutput()

edm::TestOneOutput::TestOneOutput ( ParameterSet const & pset )

explicit

Definition at line 76 of file TestOneOutput.cc.

       : one::OutputModuleBase(pset),
         one::OutputModule<WatchInputFiles, RunCache<int>, LuminosityBlockCache<int>>(pset),
         verbose_(pset.getUntrackedParameter<bool>("verbose")),
         expectedProcessesWithProcessBlockProducts_(
             pset.getUntrackedParameter<std::vector<std::string>>("expectedProcessesWithProcessBlockProducts")),
         expectedTopProcessesWithProcessBlockProducts_(
             pset.getUntrackedParameter<std::vector<std::string>>("expectedTopProcessesWithProcessBlockProducts")),
         expectedAddedProcesses_(pset.getUntrackedParameter<std::vector<std::string>>("expectedAddedProcesses")),
         expectedTopAddedProcesses_(pset.getUntrackedParameter<std::vector<std::string>>("expectedTopAddedProcesses")),
         expectedTopCacheIndices0_(pset.getUntrackedParameter<std::vector<unsigned int>>("expectedTopCacheIndices0")),
         expectedTopCacheIndices1_(pset.getUntrackedParameter<std::vector<unsigned int>>("expectedTopCacheIndices1")),
         expectedTopCacheIndices2_(pset.getUntrackedParameter<std::vector<unsigned int>>("expectedTopCacheIndices2")),
         expectedProcessNamesAtWrite_(
             pset.getUntrackedParameter<std::vector<std::string>>("expectedProcessNamesAtWrite")),
         expectedWriteProcessBlockTransitions_(pset.getUntrackedParameter<int>("expectedWriteProcessBlockTransitions")),
         requireNullTTreesInFileBlock_(pset.getUntrackedParameter<bool>("requireNullTTreesInFileBlock")),
         testTTreesInFileBlock_(pset.getUntrackedParameter<bool>("testTTreesInFileBlock")),
         expectedCacheIndexSize_(pset.getUntrackedParameter<std::vector<unsigned int>>("expectedCacheIndexSize")),
         expectedProcessesInFirstFile_(pset.getUntrackedParameter<unsigned int>("expectedProcessesInFirstFile")),
         expectedCacheIndexVectorsPerFile_(
             pset.getUntrackedParameter<std::vector<unsigned int>>("expectedCacheIndexVectorsPerFile")),
         expectedNEntries0_(pset.getUntrackedParameter<std::vector<unsigned int>>("expectedNEntries0")),
         expectedNEntries1_(pset.getUntrackedParameter<std::vector<unsigned int>>("expectedNEntries1")),
         expectedNEntries2_(pset.getUntrackedParameter<std::vector<unsigned int>>("expectedNEntries2")),
         expectedCacheEntriesPerFile0_(
             pset.getUntrackedParameter<std::vector<unsigned int>>("expectedCacheEntriesPerFile0")),
         expectedCacheEntriesPerFile1_(
             pset.getUntrackedParameter<std::vector<unsigned int>>("expectedCacheEntriesPerFile1")),
         expectedCacheEntriesPerFile2_(
             pset.getUntrackedParameter<std::vector<unsigned int>>("expectedCacheEntriesPerFile2")),
         expectedOuterOffset_(pset.getUntrackedParameter<std::vector<unsigned int>>("expectedOuterOffset")),
         expectedTranslateFromStoredIndex_(
             pset.getUntrackedParameter<std::vector<unsigned int>>("expectedTranslateFromStoredIndex")),
         expectedNAddedProcesses_(pset.getUntrackedParameter<unsigned int>("expectedNAddedProcesses")),
         expectedProductsFromInputKept_(pset.getUntrackedParameter<bool>("expectedProductsFromInputKept")) {}

◆ ~TestOneOutput()

edm::TestOneOutput::~TestOneOutput ( )

override

Definition at line 113 of file TestOneOutput.cc.

113 {}

Member Function Documentation

◆ endJob()

void edm::TestOneOutput::endJob ( void )

overrideprivatevirtual

Reimplemented from edm::core::OutputModuleCore.

Definition at line 367 of file TestOneOutput.cc.

References countWriteProcessBlockTransitions_, Exception, and expectedWriteProcessBlockTransitions_.

                              {
     if (expectedWriteProcessBlockTransitions_ >= 0) {
       if (static_cast<unsigned int>(expectedWriteProcessBlockTransitions_) != countWriteProcessBlockTransitions_) {
         throw cms::Exception("TestFailure")
             << "TestOneOutput::writeProcessBlock unexpected number of writeProcessBlock transitions";
       }
     }
   }

◆ fillDescriptions()

void edm::TestOneOutput::fillDescriptions ( ConfigurationDescriptions & descriptions )

static

Definition at line 376 of file TestOneOutput.cc.

References edm::ConfigurationDescriptions::addDefault(), submitPVResolutionJobs::desc, kDoNotTest, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                               {
     ParameterSetDescription desc;
     OutputModule::fillDescription(desc);
     desc.addUntracked<bool>("verbose", true);
     desc.addUntracked<std::vector<std::string>>("expectedProcessesWithProcessBlockProducts",
                                                 std::vector<std::string>());
     desc.addUntracked<std::vector<std::string>>("expectedTopProcessesWithProcessBlockProducts",
                                                 std::vector<std::string>());
     desc.addUntracked<std::vector<std::string>>("expectedAddedProcesses",
                                                 std::vector<std::string>(1, std::string("DONOTTEST")));
     desc.addUntracked<std::vector<std::string>>("expectedTopAddedProcesses",
                                                 std::vector<std::string>(1, std::string("DONOTTEST")));
     desc.addUntracked<std::vector<unsigned int>>("expectedTopCacheIndices0", std::vector<unsigned int>());
     desc.addUntracked<std::vector<unsigned int>>("expectedTopCacheIndices1", std::vector<unsigned int>());
     desc.addUntracked<std::vector<unsigned int>>("expectedTopCacheIndices2", std::vector<unsigned int>());
     desc.addUntracked<std::vector<std::string>>("expectedProcessNamesAtWrite", std::vector<std::string>());
     desc.addUntracked<int>("expectedWriteProcessBlockTransitions", -1);
     desc.addUntracked<bool>("requireNullTTreesInFileBlock", false);
     desc.addUntracked<bool>("testTTreesInFileBlock", false);
     desc.addUntracked<std::vector<unsigned int>>("expectedCacheIndexSize", std::vector<unsigned int>());
     desc.addUntracked<unsigned int>("expectedProcessesInFirstFile", 0);
     desc.addUntracked<std::vector<unsigned int>>("expectedCacheIndexVectorsPerFile", std::vector<unsigned int>());
     desc.addUntracked<std::vector<unsigned int>>("expectedNEntries0", std::vector<unsigned int>());
     desc.addUntracked<std::vector<unsigned int>>("expectedNEntries1", std::vector<unsigned int>());
     desc.addUntracked<std::vector<unsigned int>>("expectedNEntries2", std::vector<unsigned int>());
     desc.addUntracked<std::vector<unsigned int>>("expectedCacheEntriesPerFile0", std::vector<unsigned int>());
     desc.addUntracked<std::vector<unsigned int>>("expectedCacheEntriesPerFile1", std::vector<unsigned int>());
     desc.addUntracked<std::vector<unsigned int>>("expectedCacheEntriesPerFile2", std::vector<unsigned int>());
     desc.addUntracked<std::vector<unsigned int>>("expectedOuterOffset", std::vector<unsigned int>());
     desc.addUntracked<std::vector<unsigned int>>("expectedTranslateFromStoredIndex", std::vector<unsigned int>());
     desc.addUntracked<unsigned int>("expectedNAddedProcesses", kDoNotTest);
     desc.addUntracked<bool>("expectedProductsFromInputKept", true);
 
     descriptions.addDefault(desc);
   }

◆ globalBeginLuminosityBlock()

std::shared_ptr< int > edm::TestOneOutput::globalBeginLuminosityBlock ( LuminosityBlockForOutput const & ) const

overrideprivate

Definition at line 354 of file TestOneOutput.cc.

References verbose_.

                                                                                                     {
     if (verbose_) {
       LogAbsolute("TestOneOutput") << "one globalBeginLuminosityBlock";
     }
     return std::make_shared<int>(0);
   }

◆ globalBeginRun()

std::shared_ptr< int > edm::TestOneOutput::globalBeginRun ( RunForOutput const & ) const

overrideprivate

Definition at line 337 of file TestOneOutput.cc.

References ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, edm::ConstProductRegistry::productList(), and verbose_.

                                                                             {
     if (verbose_) {
       LogAbsolute("TestOneOutput") << "one globalBeginRun";
       edm::Service<edm::ConstProductRegistry> reg;
       for (auto const& it : reg->productList()) {
         LogAbsolute("TestOneOutput") << it.second;
       }
     }
     return std::make_shared<int>(0);
   }

◆ globalEndLuminosityBlock()

void edm::TestOneOutput::globalEndLuminosityBlock ( LuminosityBlockForOutput const & )

overrideprivate

Definition at line 361 of file TestOneOutput.cc.

References verbose_.

                                                                               {
     if (verbose_) {
       LogAbsolute("TestOneOutput") << "one globalEndLuminosityBlock";
     }
   }

◆ globalEndRun()

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

overrideprivate

Definition at line 348 of file TestOneOutput.cc.

References verbose_.

                                                       {
     if (verbose_) {
       LogAbsolute("TestOneOutput") << "one globalEndRun";
     }
   }

◆ respondToCloseInputFile()

void edm::TestOneOutput::respondToCloseInputFile ( FileBlock const & fb )

overrideprivate

Definition at line 306 of file TestOneOutput.cc.

References testFileBlock(), and verbose_.

                                                                  {
     if (verbose_) {
       LogAbsolute("TestOneOutput") << "one respondToCloseInputFile";
     }
     testFileBlock(fb);
   }

◆ respondToOpenInputFile()

void edm::TestOneOutput::respondToOpenInputFile ( FileBlock const & fb )

overrideprivate

Definition at line 298 of file TestOneOutput.cc.

References countInputFiles_, testFileBlock(), and verbose_.

                                                                 {
     if (verbose_) {
       LogAbsolute("TestOneOutput") << "one respondToOpenInputFile";
     }
     testFileBlock(fb);
     ++countInputFiles_;
   }

◆ testFileBlock()

void edm::TestOneOutput::testFileBlock ( FileBlock const & fb )

private

Definition at line 313 of file TestOneOutput.cc.

References Exception, edm::FileBlock::lumiTree(), edm::FileBlock::processBlockTree(), edm::FileBlock::processBlockTrees(), edm::FileBlock::processesWithProcessBlockTrees(), requireNullTTreesInFileBlock_, edm::FileBlock::runTree(), AlCaHLTBitMon_QueryRunRegistry::string, testTTreesInFileBlock_, and edm::FileBlock::tree().

Referenced by respondToCloseInputFile(), and respondToOpenInputFile().

                                                        {
     if (requireNullTTreesInFileBlock_) {
       if (fb.tree() != nullptr || fb.lumiTree() != nullptr || fb.runTree() != nullptr ||
           !fb.processBlockTrees().empty() || !fb.processesWithProcessBlockTrees().empty() ||
           fb.processBlockTree(std::string("DoesNotExist")) != nullptr) {
         throw cms::Exception("TestFailure")
             << "TestOneOutput::respondToOpenInputFile expected null TTree pointers in FileBlock";
       }
     } else if (testTTreesInFileBlock_) {
       if (fb.tree() == nullptr || std::string("Events") != fb.tree()->GetName() ||
           std::string("LuminosityBlocks") != fb.lumiTree()->GetName() ||
           std::string("Runs") != fb.runTree()->GetName() || fb.processesWithProcessBlockTrees().size() != 2 ||
           fb.processesWithProcessBlockTrees()[0] != "PROD1" || fb.processesWithProcessBlockTrees()[1] != "MERGE" ||
           fb.processBlockTrees().size() != 2 ||
           std::string("ProcessBlocksPROD1") != fb.processBlockTrees()[0]->GetName() ||
           std::string("ProcessBlocksMERGE") != fb.processBlockTrees()[1]->GetName() ||
           std::string("ProcessBlocksPROD1") != fb.processBlockTree("PROD1")->GetName() ||
           std::string("ProcessBlocksMERGE") != fb.processBlockTree("MERGE")->GetName() ||
           fb.processBlockTree("DOESNOTEXIST") != nullptr) {
         throw cms::Exception("TestFailure") << "TestOneOutput::testFileBlock failed. Testing tree pointers";
       }
     }
   }

◆ write()

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

overrideprivatevirtual

Implements edm::core::OutputModuleCore.

Definition at line 115 of file TestOneOutput.cc.

References verbose_.

Referenced by pkg.AbstractPkg::generate().

                                                    {
     if (verbose_) {
       LogAbsolute("TestOneOutput") << "one write event";
     }
   }

◆ writeLuminosityBlock()

void edm::TestOneOutput::writeLuminosityBlock ( LuminosityBlockForOutput const & )

overrideprivatevirtual

Implements edm::core::OutputModuleCore.

Definition at line 121 of file TestOneOutput.cc.

References verbose_.

                                                                           {
     if (verbose_) {
       LogAbsolute("TestOneOutput") << "one writeLuminosityBlock";
     }
   }

◆ writeProcessBlock()

void edm::TestOneOutput::writeProcessBlock ( ProcessBlockForOutput const & pb )

overrideprivatevirtual

Reimplemented from edm::core::OutputModuleCore.

Definition at line 133 of file TestOneOutput.cc.

                                                                        {
     if (verbose_) {
       LogAbsolute("TestOneOutput") << "one writeProcessBlock";
     }
     if (countWriteProcessBlockTransitions_ < expectedProcessNamesAtWrite_.size()) {
       if (expectedProcessNamesAtWrite_[countWriteProcessBlockTransitions_] != pb.processName()) {
         throw cms::Exception("TestFailure") << "TestOneOutput::writeProcessBlock unexpected process name";
       }
     }
     if (!expectedProcessesWithProcessBlockProducts_.empty()) {
       if (verbose_) {
         for (auto const& process : outputProcessBlockHelper().processesWithProcessBlockProducts()) {
           LogAbsolute("TestOneOutput") << "    " << process;
         }
       }
       if (expectedProcessesWithProcessBlockProducts_ !=
           outputProcessBlockHelper().processesWithProcessBlockProducts()) {
         throw cms::Exception("TestFailure") << "TestOneOutput::writeProcessBlock unexpected process name list";
       }
     }
     if (!(!expectedAddedProcesses_.empty() && expectedAddedProcesses_[0] == "DONOTTEST")) {
       if (expectedAddedProcesses_ != outputProcessBlockHelper().processBlockHelper()->addedProcesses()) {
         throw cms::Exception("TestFailure") << "TestOneOutput::writeProcessBlock unexpected addedProcesses list";
       }
     }
     if (!(!expectedTopAddedProcesses_.empty() && expectedTopAddedProcesses_[0] == "DONOTTEST")) {
       if (expectedTopAddedProcesses_ !=
           outputProcessBlockHelper().processBlockHelper()->topProcessBlockHelper()->addedProcesses()) {
         throw cms::Exception("TestFailure") << "TestOneOutput::writeProcessBlock unexpected top addedProcesses list";
       }
     }
     if (!expectedTopProcessesWithProcessBlockProducts_.empty()) {
       // Same test as the previous except check the list of names in
       // the top level process name list from the EventProcessor
       if (expectedTopProcessesWithProcessBlockProducts_ != outputProcessBlockHelper()
                                                                .processBlockHelper()
                                                                ->topProcessBlockHelper()
                                                                ->topProcessesWithProcessBlockProducts()) {
         throw cms::Exception("TestFailure") << "TestOneOutput::writeProcessBlock unexpected top process name list";
       }
       // Almost the same as the previous test, should get the same result
       if (expectedTopProcessesWithProcessBlockProducts_ !=
           outputProcessBlockHelper().processBlockHelper()->topProcessesWithProcessBlockProducts()) {
         throw cms::Exception("TestFailure") << "TestOneOutput::writeProcessBlock unexpected top process name list 2";
       }
 
       std::vector<unsigned int> const* expectedTopCacheIndices = nullptr;
       if (countInputFiles_ == 1 && !expectedTopCacheIndices0_.empty()) {
         expectedTopCacheIndices = &expectedTopCacheIndices0_;
       } else if (countInputFiles_ == 2 && !expectedTopCacheIndices1_.empty()) {
         expectedTopCacheIndices = &expectedTopCacheIndices1_;
       } else if (countInputFiles_ == 3 && !expectedTopCacheIndices2_.empty()) {
         expectedTopCacheIndices = &expectedTopCacheIndices2_;
       }
       if (expectedTopCacheIndices != nullptr) {
         unsigned int expectedInputProcesses =
             expectedTopProcessesWithProcessBlockProducts_.size() -
             outputProcessBlockHelper().processBlockHelper()->topProcessBlockHelper()->addedProcesses().size();
 
         std::vector<std::vector<unsigned int>> const& topProcessBlockCacheIndices =
             outputProcessBlockHelper().processBlockHelper()->processBlockCacheIndices();
         if (expectedTopCacheIndices->size() != expectedInputProcesses * topProcessBlockCacheIndices.size()) {
           throw cms::Exception("TestFailure")
               << "TestOneOutput::writeProcessBlock unexpected sizes related to top cache indices on input file "
               << (countInputFiles_ - 1);
         }
         unsigned int iStored = 0;
         for (unsigned int i = 0; i < topProcessBlockCacheIndices.size(); ++i) {
           if (topProcessBlockCacheIndices[i].size() != expectedInputProcesses) {
             throw cms::Exception("TestFailure")
                 << "TestOneOutput::writeProcessBlock unexpected size of inner cache indices vector on input file "
                 << (countInputFiles_ - 1);
           }
           for (unsigned int j = 0; j < topProcessBlockCacheIndices[i].size(); ++j) {
             if (topProcessBlockCacheIndices[i][j] != (*expectedTopCacheIndices)[iStored]) {
               throw cms::Exception("TestFailure")
                   << "TestOneOutput::writeProcessBlock unexpected cache index value on input file "
                   << (countInputFiles_ - 1);
             }
             ++iStored;
           }
         }
       }
     }
     if (expectedProcessesInFirstFile_ != 0) {
       if (expectedProcessesInFirstFile_ != outputProcessBlockHelper().processBlockHelper()->nProcessesInFirstFile()) {
         throw cms::Exception("TestFailure")
             << "TestOneOutput::writeProcessBlock unexpected value for nProcessesInFirstFile";
       }
     }
     for (unsigned int i = 0; i < expectedCacheIndexVectorsPerFile_.size(); ++i) {
       if (i < countInputFiles_) {
         if (expectedCacheIndexVectorsPerFile_[i] !=
             outputProcessBlockHelper().processBlockHelper()->cacheIndexVectorsPerFile()[i]) {
           throw cms::Exception("TestFailure")
               << "TestOneOutput::writeProcessBlock unexpected value for cacheIndexVectorsPerFile, element " << i;
         }
       }
     }
     if (countInputFiles_ >= 1 && !expectedNEntries0_.empty()) {
       if (expectedNEntries0_ != outputProcessBlockHelper().processBlockHelper()->nEntries()[0]) {
         throw cms::Exception("TestFailure") << "TestOneOutput::writeProcessBlock unexpected value for nEntries 0";
       }
     }
     if (countInputFiles_ >= 2 && !expectedNEntries1_.empty()) {
       if (expectedNEntries1_ != outputProcessBlockHelper().processBlockHelper()->nEntries()[1]) {
         throw cms::Exception("TestFailure") << "TestOneOutput::writeProcessBlock unexpected value for nEntries 1";
       }
     }
     if (countInputFiles_ >= 3 && !expectedNEntries2_.empty()) {
       if (expectedNEntries2_ != outputProcessBlockHelper().processBlockHelper()->nEntries()[2]) {
         throw cms::Exception("TestFailure") << "TestOneOutput::writeProcessBlock unexpected value for nEntries 2";
       }
     }
 
     if (countInputFiles_ == 1 && !expectedCacheEntriesPerFile0_.empty()) {
       if (expectedCacheEntriesPerFile0_ != outputProcessBlockHelper().processBlockHelper()->cacheEntriesPerFile()) {
         throw cms::Exception("TestFailure")
             << "TestOneOutput::writeProcessBlock unexpected value for cacheEntriesPerFile 0";
       }
     } else if (countInputFiles_ == 2 && !expectedCacheEntriesPerFile1_.empty()) {
       if (expectedCacheEntriesPerFile1_ != outputProcessBlockHelper().processBlockHelper()->cacheEntriesPerFile()) {
         throw cms::Exception("TestFailure")
             << "TestOneOutput::writeProcessBlock unexpected value for cacheEntriesPerFile 1";
       }
     } else if (countInputFiles_ == 3 && !expectedCacheEntriesPerFile2_.empty()) {
       if (expectedCacheEntriesPerFile2_ != outputProcessBlockHelper().processBlockHelper()->cacheEntriesPerFile()) {
         throw cms::Exception("TestFailure")
             << "TestOneOutput::writeProcessBlock unexpected value for cacheEntriesPerFile 2";
       }
     }
 
     if (!expectedOuterOffset_.empty() && (countInputFiles_ - 1) < expectedOuterOffset_.size()) {
       if (expectedOuterOffset_[countInputFiles_ - 1] !=
           outputProcessBlockHelper().processBlockHelper()->outerOffset()) {
         throw cms::Exception("TestFailure")
             << "TestOneOutput::writeProcessBlock unexpected value for outerOffset, file " << (countInputFiles_ - 1);
       }
     }
     if (countWriteProcessBlockTransitions_ < expectedCacheIndexSize_.size()) {
       if (expectedCacheIndexSize_[countWriteProcessBlockTransitions_] !=
           outputProcessBlockHelper().processBlockHelper()->processBlockCacheIndices().size()) {
         throw cms::Exception("TestFailure")
             << "TestOneOutput::writeProcessBlock unexpected cache index size "
             << outputProcessBlockHelper().processBlockHelper()->processBlockCacheIndices().size();
       }
     }
     if (!expectedTranslateFromStoredIndex_.empty()) {
       if (expectedTranslateFromStoredIndex_ != outputProcessBlockHelper().translateFromStoredIndex()) {
         throw cms::Exception("TestFailure")
             << "TestOneOutput::writeProcessBlock unexpected value for translateFromStoredIndex";
       }
     }
     if (expectedNAddedProcesses_ != kDoNotTest) {
       if (expectedNAddedProcesses_ != outputProcessBlockHelper().nAddedProcesses()) {
         throw cms::Exception("TestFailure") << "TestOneOutput::writeProcessBlock unexpected value for nAddedProcesses";
       }
     }
     if (expectedProductsFromInputKept_ != outputProcessBlockHelper().productsFromInputKept()) {
       throw cms::Exception("TestFailure")
           << "TestOneOutput::writeProcessBlock unexpected value for productsFromInputKept";
     }
     ++countWriteProcessBlockTransitions_;
   }

◆ writeRun()

void edm::TestOneOutput::writeRun ( RunForOutput const & )

overrideprivatevirtual

Implements edm::core::OutputModuleCore.

Definition at line 127 of file TestOneOutput.cc.

References verbose_.

                                                   {
     if (verbose_) {
       LogAbsolute("TestOneOutput") << "one writeRun";
     }
   }

Member Data Documentation

◆ countInputFiles_

unsigned int edm::TestOneOutput::countInputFiles_ = 0

private

Definition at line 58 of file TestOneOutput.cc.

Referenced by respondToOpenInputFile(), and writeProcessBlock().

◆ countWriteProcessBlockTransitions_

unsigned int edm::TestOneOutput::countWriteProcessBlockTransitions_ = 0

private

Definition at line 57 of file TestOneOutput.cc.

Referenced by endJob(), and writeProcessBlock().

◆ expectedAddedProcesses_

std::vector<std::string> edm::TestOneOutput::expectedAddedProcesses_

private

Definition at line 50 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedCacheEntriesPerFile0_

std::vector<unsigned int> edm::TestOneOutput::expectedCacheEntriesPerFile0_

private

Definition at line 67 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedCacheEntriesPerFile1_

std::vector<unsigned int> edm::TestOneOutput::expectedCacheEntriesPerFile1_

private

Definition at line 68 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedCacheEntriesPerFile2_

std::vector<unsigned int> edm::TestOneOutput::expectedCacheEntriesPerFile2_

private

Definition at line 69 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedCacheIndexSize_

std::vector<unsigned int> edm::TestOneOutput::expectedCacheIndexSize_

private

Definition at line 61 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedCacheIndexVectorsPerFile_

std::vector<unsigned int> edm::TestOneOutput::expectedCacheIndexVectorsPerFile_

private

Definition at line 63 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedNAddedProcesses_

unsigned int edm::TestOneOutput::expectedNAddedProcesses_

private

Definition at line 72 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedNEntries0_

std::vector<unsigned int> edm::TestOneOutput::expectedNEntries0_

private

Definition at line 64 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedNEntries1_

std::vector<unsigned int> edm::TestOneOutput::expectedNEntries1_

private

Definition at line 65 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedNEntries2_

std::vector<unsigned int> edm::TestOneOutput::expectedNEntries2_

private

Definition at line 66 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedOuterOffset_

std::vector<unsigned int> edm::TestOneOutput::expectedOuterOffset_

private

Definition at line 70 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedProcessesInFirstFile_

unsigned int edm::TestOneOutput::expectedProcessesInFirstFile_

private

Definition at line 62 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedProcessesWithProcessBlockProducts_

std::vector<std::string> edm::TestOneOutput::expectedProcessesWithProcessBlockProducts_

private

Definition at line 48 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedProcessNamesAtWrite_

std::vector<std::string> edm::TestOneOutput::expectedProcessNamesAtWrite_

private

Definition at line 55 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedProductsFromInputKept_

bool edm::TestOneOutput::expectedProductsFromInputKept_

private

Definition at line 73 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedTopAddedProcesses_

std::vector<std::string> edm::TestOneOutput::expectedTopAddedProcesses_

private

Definition at line 51 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedTopCacheIndices0_

std::vector<unsigned int> edm::TestOneOutput::expectedTopCacheIndices0_

private

Definition at line 52 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedTopCacheIndices1_

std::vector<unsigned int> edm::TestOneOutput::expectedTopCacheIndices1_

private

Definition at line 53 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedTopCacheIndices2_

std::vector<unsigned int> edm::TestOneOutput::expectedTopCacheIndices2_

private

Definition at line 54 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedTopProcessesWithProcessBlockProducts_

std::vector<std::string> edm::TestOneOutput::expectedTopProcessesWithProcessBlockProducts_

private

Definition at line 49 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedTranslateFromStoredIndex_

std::vector<unsigned int> edm::TestOneOutput::expectedTranslateFromStoredIndex_

private

Definition at line 71 of file TestOneOutput.cc.

Referenced by writeProcessBlock().

◆ expectedWriteProcessBlockTransitions_

int edm::TestOneOutput::expectedWriteProcessBlockTransitions_

private

Definition at line 56 of file TestOneOutput.cc.

Referenced by endJob().

◆ requireNullTTreesInFileBlock_

bool edm::TestOneOutput::requireNullTTreesInFileBlock_

private

Definition at line 59 of file TestOneOutput.cc.

Referenced by testFileBlock().

◆ testTTreesInFileBlock_

bool edm::TestOneOutput::testTTreesInFileBlock_

private

Definition at line 60 of file TestOneOutput.cc.

Referenced by testFileBlock().

◆ verbose_

bool edm::TestOneOutput::verbose_

private

Definition at line 47 of file TestOneOutput.cc.

Referenced by globalBeginLuminosityBlock(), globalBeginRun(), globalEndLuminosityBlock(), globalEndRun(), respondToCloseInputFile(), respondToOpenInputFile(), write(), writeLuminosityBlock(), writeProcessBlock(), and writeRun().

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ TestOneOutput()

◆ ~TestOneOutput()

Member Function Documentation

◆ endJob()

◆ fillDescriptions()

◆ globalBeginLuminosityBlock()

◆ globalBeginRun()

◆ globalEndLuminosityBlock()

◆ globalEndRun()

◆ respondToCloseInputFile()

◆ respondToOpenInputFile()

◆ testFileBlock()

◆ write()

◆ writeLuminosityBlock()

◆ writeProcessBlock()

◆ writeRun()

Member Data Documentation

◆ countInputFiles_

◆ countWriteProcessBlockTransitions_

◆ expectedAddedProcesses_

◆ expectedCacheEntriesPerFile0_

◆ expectedCacheEntriesPerFile1_

◆ expectedCacheEntriesPerFile2_

◆ expectedCacheIndexSize_

◆ expectedCacheIndexVectorsPerFile_

◆ expectedNAddedProcesses_

◆ expectedNEntries0_

◆ expectedNEntries1_

◆ expectedNEntries2_

◆ expectedOuterOffset_

◆ expectedProcessesInFirstFile_

◆ expectedProcessesWithProcessBlockProducts_

◆ expectedProcessNamesAtWrite_

◆ expectedProductsFromInputKept_

◆ expectedTopAddedProcesses_

◆ expectedTopCacheIndices0_

◆ expectedTopCacheIndices1_

◆ expectedTopCacheIndices2_

◆ expectedTopProcessesWithProcessBlockProducts_

◆ expectedTranslateFromStoredIndex_

◆ expectedWriteProcessBlockTransitions_

◆ requireNullTTreesInFileBlock_

◆ testTTreesInFileBlock_

◆ verbose_