#include <JsonWritingTimeoutPoolOutputModule.h>

Inheritance diagram for dqmservices::JsonWritingTimeoutPoolOutputModule:

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

	~JsonWritingTimeoutPoolOutputModule () override

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

	TimeoutPoolOutputModule (ParameterSet const &ps)

	TimeoutPoolOutputModule (TimeoutPoolOutputModule const &)=delete

	~TimeoutPoolOutputModule () override

Public Member Functions inherited from edm::PoolOutputModule
AuxItemArray const &	auxItems () const

std::string const &	basketOrder () const

int const &	basketSize () const

BranchChildren const &	branchChildren () const

std::string const &	catalog () const

std::string const &	compressionAlgorithm () const

int const &	compressionLevel () const

std::string const &	currentFileName () const

DropMetaData const &	dropMetaData () const

int	eventAutoFlushSize () const

std::string const &	fileName () const

int const &	inputFileCount () const

std::string const &	logicalFileName () const

unsigned int const &	maxFileSize () const

std::string const &	moduleLabel () const

PoolOutputModule &	operator= (PoolOutputModule const &)=delete

bool const &	overrideInputFileSplitLevels () const

	PoolOutputModule (ParameterSet const &ps)

	PoolOutputModule (PoolOutputModule const &)=delete

OutputItemListArray const &	selectedOutputItemList () const

int const &	splitLevel () const

int const &	treeMaxVirtualSize () const

int const &	whyNotFastClonable () const

	~PoolOutputModule () override

Public Member Functions inherited from edm::one::OutputModule< WatchInputFiles >
	OutputModule (edm::ParameterSet const &iPSet)

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () const final

Public Member Functions inherited from edm::one::OutputModuleBase
BranchIDLists const *	branchIDLists ()

SerialTaskQueue *	globalLuminosityBlocksQueue ()

SerialTaskQueue *	globalRunsQueue ()

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

SelectedProductsForBranchType const &	keptProducts () const

int	maxEvents () const

const ModuleDescription &	moduleDescription () const

OutputModuleBase &	operator= (OutputModuleBase const &)=delete

	OutputModuleBase (ParameterSet const &pset)

	OutputModuleBase (OutputModuleBase const &)=delete

std::string const &	processName () const

int	remainingEvents () const

bool	selected (BranchDescription const &desc) const

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

SharedResourcesAcquirer &	sharedResourcesAcquirer ()

SubProcessParentageHelper const *	subProcessParentageHelper () const

ThinnedAssociationsHelper const *	thinnedAssociationsHelper () const

bool	wantAllEvents () const

bool	wantsStreamLuminosityBlocks () const

bool	wantsStreamRuns () const

	~OutputModuleBase () 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

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::vector< ModuleDescription const * > &modules, 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

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

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

virtual	~EDConsumerBase () noexcept(false)

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

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

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

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

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

static void	fillDescription (ParameterSetDescription &desc)

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &)

Protected Member Functions
void	doExtrasAfterCloseFile () override

std::pair< std::string, std::string >	physicalAndLogicalNameForNewFile () override

Protected Member Functions inherited from edm::TimeoutPoolOutputModule
bool	shouldWeCloseFile () const override
	allow inheriting classes to override but still be able to call this method in the overridden version More...

void	write (EventForOutput const &e) override

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

ModuleDescription const &	description () const

void	doBeginJob ()

bool	doBeginLuminosityBlock (LuminosityBlockPrincipal const &lbp, EventSetup const &c, ModuleCallingContext const *)

bool	doBeginRun (RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *)

void	doEndJob ()

bool	doEndLuminosityBlock (LuminosityBlockPrincipal const &lbp, EventSetup const &c, ModuleCallingContext const *)

bool	doEndRun (RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *)

bool	doEvent (EventPrincipal const &ep, EventSetup const &c, ActivityRegistry , ModuleCallingContext const )

void	doPreallocate (PreallocationConfiguration const &)

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

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)

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 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)

Protected Attributes
std::string	currentFileName_

std::string	currentJsonName_

std::string	outputPath_

uint32_t	runNumber_

uint32_t	sequence_

std::string	streamLabel_

Additional Inherited Members
Public Types inherited from edm::PoolOutputModule
typedef std::array< AuxItem, NumBranchTypes >	AuxItemArray

enum	DropMetaData { DropNone, DropDroppedPrior, DropPrior, DropAll }

typedef std::vector< OutputItem >	OutputItemList

typedef std::array< OutputItemList, NumBranchTypes >	OutputItemListArray

Public Types inherited from edm::one::OutputModuleBase
typedef OutputModuleBase	ModuleType

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Detailed Description

Definition at line 11 of file JsonWritingTimeoutPoolOutputModule.h.

Constructor & Destructor Documentation

dqmservices::JsonWritingTimeoutPoolOutputModule::JsonWritingTimeoutPoolOutputModule ( edm::ParameterSet const & ps )

explicit

Definition at line 13 of file JsonWritingTimeoutPoolOutputModule.cc.

References edm::ParameterSet::getUntrackedParameter(), outputPath_, runNumber_, sequence_, streamLabel_, and AlCaHLTBitMon_QueryRunRegistry::string.

     : edm::one::OutputModuleBase::OutputModuleBase(ps),
       edm::TimeoutPoolOutputModule(ps) {
   runNumber_ = ps.getUntrackedParameter<uint32_t>("runNumber");
   outputPath_ = ps.getUntrackedParameter<std::string>("outputPath");
   streamLabel_ = ps.getUntrackedParameter<std::string>("streamLabel");
 
   sequence_ = 0;
 }

dqmservices::JsonWritingTimeoutPoolOutputModule::~JsonWritingTimeoutPoolOutputModule ( )

inlineoverride

Definition at line 14 of file JsonWritingTimeoutPoolOutputModule.h.

References doExtrasAfterCloseFile(), fillDescriptions(), and physicalAndLogicalNameForNewFile().

14 {};

Member Function Documentation

void dqmservices::JsonWritingTimeoutPoolOutputModule::doExtrasAfterCloseFile ( )

overrideprotectedvirtual

Reimplemented from edm::PoolOutputModule.

Definition at line 39 of file JsonWritingTimeoutPoolOutputModule.cc.

References currentFileName_, currentJsonName_, DQMFileSaver::fillJson(), EnergyCorrector::pt, runNumber_, sequence_, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by ~JsonWritingTimeoutPoolOutputModule().

                                                                 {
   std::string json_tmp_ = currentJsonName_ + ".open";
   std::string transferDest = "";
   std::string mergeType = "ROOT";
   auto pt = DQMFileSaver::fillJson(runNumber_, sequence_, currentFileName_,
                                    transferDest, mergeType, nullptr);
   write_json(json_tmp_, pt);
   rename(json_tmp_.c_str(), currentJsonName_.c_str());
 }

void dqmservices::JsonWritingTimeoutPoolOutputModule::fillDescriptions ( edm::ConfigurationDescriptions & descriptions )

static

Definition at line 49 of file JsonWritingTimeoutPoolOutputModule.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addUntracked(), DEFINE_FWK_MODULE, edm::ParameterSetDescription::setComment(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by ~JsonWritingTimeoutPoolOutputModule().

                                                 {
   edm::ParameterSetDescription desc;
   TimeoutPoolOutputModule::fillDescription(desc);
 
   desc.setComment(
       "Almost same as TimeoutPoolOutputModule, but the output files names "
       "follow the FFF naming convention. Additionally a json 'description' "
       "file is emitted for every .root file written.");
 
   desc.addUntracked<uint32_t>("runNumber", 0)
       ->setComment(
           "The run number, only used for file prefix: "
           "'run000001_lumi0000_...'.");
 
   desc.addUntracked<std::string>("outputPath", "./")
       ->setComment(
           "Output path for the root and json files, usually the run "
           "directory.");
 
   desc.addUntracked<std::string>("streamLabel", "streamEvDOutput")
       ->setComment("Stream label, used for file suffix.");
 
   descriptions.add("jsonWriting", desc);
 }

std::pair< std::string, std::string > dqmservices::JsonWritingTimeoutPoolOutputModule::physicalAndLogicalNameForNewFile ( )

overrideprotectedvirtual

Reimplemented from edm::PoolOutputModule.

Definition at line 25 of file JsonWritingTimeoutPoolOutputModule.cc.

References runEdmFileComparison::base, currentFileName_, currentJsonName_, cmsPerfStripChart::format, outputPath_, AlCaHLTBitMon_ParallelJobs::p, callgraph::path, runNumber_, sequence_, str, streamLabel_, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by ~JsonWritingTimeoutPoolOutputModule().

                                                                      {
   sequence_++;
 
   std::string base = str(boost::format("run%06d_ls%04d_%s") % runNumber_ %
                          sequence_ % streamLabel_);
 
   boost::filesystem::path p(outputPath_);
 
   currentFileName_ = (p / base).string() + ".root";
   currentJsonName_ = (p / base).string() + ".jsn";
 
   return std::make_pair(currentFileName_, currentFileName_);
 }