#include <RecoEventOutputModuleForFU.h>

Inheritance diagram for evf::RecoEventOutputModuleForFU< Consumer >:

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

virtual	~RecoEventOutputModuleForFU ()

Public Member Functions inherited from edm::StreamerOutputModuleBase
	StreamerOutputModuleBase (ParameterSet const &ps)

virtual	~StreamerOutputModuleBase ()

Public Member Functions inherited from edm::OutputModule
BranchChildren const &	branchChildren () const

BranchIDLists const *	branchIDLists () const

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

SelectedProductsForBranchType const &	keptProducts () const

int	maxEvents () const

OutputModule &	operator= (OutputModule const &)=delete

	OutputModule (ParameterSet const &pset)

	OutputModule (OutputModule const &)=delete

std::string const &	processName () const

int	remainingEvents () const

bool	selected (BranchDescription const &desc) const

void	selectProducts (ProductRegistry const &preg)

bool	wantAllEvents () const

virtual	~OutputModule ()

Public Member Functions inherited from edm::EDConsumerBase
	EDConsumerBase ()

ProductHolderIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const

void	itemsMayGet (BranchType, std::vector< ProductHolderIndexAndSkipBit > &) const

void	itemsToGet (BranchType, std::vector< ProductHolderIndexAndSkipBit > &) const

std::vector < ProductHolderIndexAndSkipBit > const &	itemsToGetFromEvent () const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

bool	registeredToConsume (ProductHolderIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

void	updateLookup (BranchType iBranchType, ProductHolderIndexHelper const &)

virtual	~EDConsumerBase ()

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

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

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

static void	fillDescription (ParameterSetDescription &desc)

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &)

Private Member Functions
virtual void	beginLuminosityBlock (edm::LuminosityBlockPrincipal const &, edm::ModuleCallingContext const *)

virtual void	doOutputEvent (EventMsgBuilder const &msg) const

virtual void	doOutputHeader (InitMsgBuilder const &init_message) const

virtual void	endLuminosityBlock (edm::LuminosityBlockPrincipal const &, edm::ModuleCallingContext const *)

void	initializeStreams ()

virtual void	start () const

virtual void	stop () const

Private Attributes
IntJ	accepted_

std::string	baseDir_

std::auto_ptr< Consumer >	c_

std::string	events_base_filename_

StringJ	filelist_

evf::FastMonitoringService *	fms_

std::string	jsonDefPath_

boost::shared_ptr< FastMonitor >	jsonMonitor_

boost::filesystem::path	openDatFilePath_

IntJ	processed_

std::string	smpath_

std::string	stream_label_

Additional Inherited Members
Public Types inherited from edm::OutputModule
typedef OutputModule	ModuleType

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

ModuleDescription const &	description () const

void	doBeginJob ()

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

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

void	doEndJob ()

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

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

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

void	doPreallocate (PreallocationConfiguration const &)

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

Trig	getTriggerResults (EventPrincipal const &ep, ModuleCallingContext const *) const

ModuleDescription const &	moduleDescription () 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
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)

Detailed Description

template<typename Consumer>
class evf::RecoEventOutputModuleForFU< Consumer >

Definition at line 21 of file RecoEventOutputModuleForFU.h.

Constructor & Destructor Documentation

template<typename Consumer >

evf::RecoEventOutputModuleForFU< Consumer >::RecoEventOutputModuleForFU ( edm::ParameterSet const & ps )

explicit

Consumers are supposed to provide

void doOutputHeader(InitMsgBuilder const& init_message) void doOutputEvent(EventMsgBuilder const& msg) void start() void stop() static void fillDescription(ParameterSetDescription&)

Definition at line 84 of file RecoEventOutputModuleForFU.h.

References evf::RecoEventOutputModuleForFU< Consumer >::accepted_, evf::RecoEventOutputModuleForFU< Consumer >::filelist_, evf::RecoEventOutputModuleForFU< Consumer >::fms_, evf::FastMonitoringService::getOutputDefPath(), evf::RecoEventOutputModuleForFU< Consumer >::initializeStreams(), evf::RecoEventOutputModuleForFU< Consumer >::jsonDefPath_, evf::RecoEventOutputModuleForFU< Consumer >::jsonMonitor_, evf::RecoEventOutputModuleForFU< Consumer >::processed_, and jsoncollector::JsonMonitorable::setName().

                                                                                             :
     edm::StreamerOutputModuleBase(ps),
     c_(new Consumer(ps)),
     stream_label_(ps.getParameter<std::string>("@module_label")),
     baseDir_(ps.getUntrackedParameter<std::string>("baseDir","")),
     processed_(0),
     accepted_(0),
     filelist_("")
   {
     initializeStreams();
     
     fms_ = (evf::FastMonitoringService *)(edm::Service<evf::MicroStateService>().operator->());
     jsonDefPath_ = fms_->getOutputDefPath();
     
     processed_.setName("Processed");
     accepted_.setName("Accepted");
     filelist_.setName("Filelist");
     vector<JsonMonitorable*> monParams;
     monParams.push_back(&processed_);
     monParams.push_back(&accepted_);
     monParams.push_back(&filelist_);
     
     jsonMonitor_.reset(new FastMonitor(monParams, jsonDefPath_));
   }

template<typename Consumer >

evf::RecoEventOutputModuleForFU< Consumer >::~RecoEventOutputModuleForFU ( )

virtual

Definition at line 110 of file RecoEventOutputModuleForFU.h.

110 {}

Member Function Documentation

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::beginLuminosityBlock	(	edm::LuminosityBlockPrincipal const &	ls,
		edm::ModuleCallingContext const *
	)

privatevirtual

Reimplemented from edm::OutputModule.

Definition at line 165 of file RecoEventOutputModuleForFU.h.

References gather_cfg::cout, and edm::LuminosityBlockPrincipal::luminosityBlock().

                                                                                                                                       {
     std::cout << "RecoEventOutputModuleForFU : begin lumi " << std::endl;
     openDatFilePath_ = edm::Service<evf::EvFDaqDirector>()->getOpenDatFilePath(ls.luminosityBlock(),stream_label_);
     c_->setOutputFile(openDatFilePath_.string());
     filelist_ = openDatFilePath_.filename().string();
   }

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::doOutputEvent ( EventMsgBuilder const & msg ) const

privatevirtual

Implements edm::StreamerOutputModuleBase.

Definition at line 142 of file RecoEventOutputModuleForFU.h.

                                                                                       {
     accepted_.value()++;
     c_->doOutputEvent(msg); // You can't use msg in RecoEventOutputModuleForFU after this point
   }

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::doOutputHeader ( InitMsgBuilder const & init_message ) const

privatevirtual

Implements edm::StreamerOutputModuleBase.

Definition at line 135 of file RecoEventOutputModuleForFU.h.

                                                                                                {
     c_->doOutputHeader(init_message);
   }

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::endLuminosityBlock	(	edm::LuminosityBlockPrincipal const &	ls,
		edm::ModuleCallingContext const *
	)

privatevirtual

Reimplemented from edm::OutputModule.

Definition at line 173 of file RecoEventOutputModuleForFU.h.

References b, gather_cfg::cout, edm::LuminosityBlockPrincipal::luminosityBlock(), alcazmumu_cfi::src, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                                                                     {
     std::cout << "RecoEventOutputModuleForFU : end lumi " << std::endl;
     c_->closeOutputFile();
     processed_.value() = fms_->getEventsProcessedForLumi(ls.luminosityBlock());
     if(processed_.value()!=0){
       int b;
       // move dat file to one level up - this is VERRRRRY inefficient, come up with a smarter idea
 
       FILE *des = edm::Service<evf::EvFDaqDirector>()->maybeCreateAndLockFileHeadForStream(ls.luminosityBlock(),stream_label_);
       FILE *src = fopen(openDatFilePath_.string().c_str(),"r");
       if(des != 0 && src !=0){
     while((b=fgetc(src))!= EOF){
       fputc((unsigned char)b,des);
     }
       }
 
       edm::Service<evf::EvFDaqDirector>()->unlockAndCloseMergeStream();
       fclose(src);
     }
     //remove file
     remove(openDatFilePath_.string().c_str());
 
     // output jsn file
     if(processed_.value()!=0){
     jsonMonitor_->snap(false, "");
     const std::string outputJsonNameStream =
       edm::Service<evf::EvFDaqDirector>()->getOutputJsonFilePath(ls.luminosityBlock(),stream_label_);
     jsonMonitor_->outputFullHistoDataPoint(outputJsonNameStream);
     }
 
     // reset monitoring params
     accepted_.value() = 0;
     filelist_ = "";
   }

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::fillDescriptions ( edm::ConfigurationDescriptions & descriptions )

static

Definition at line 149 of file RecoEventOutputModuleForFU.h.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addUntracked(), edm::StreamerOutputModuleBase::fillDescription(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                                    {
     edm::ParameterSetDescription desc;
     edm::StreamerOutputModuleBase::fillDescription(desc);
     Consumer::fillDescription(desc);
     desc.addUntracked<std::string>("baseDir", "")
         ->setComment("Top level output directory");
     descriptions.add("streamerOutput", desc);
   }

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::initializeStreams ( )

inlineprivate

Definition at line 45 of file RecoEventOutputModuleForFU.h.

References gather_cfg::cout, getHLTPrescaleColumns::path, and evf::RecoEventOutputModuleForFU< Consumer >::smpath_.

Referenced by evf::RecoEventOutputModuleForFU< Consumer >::RecoEventOutputModuleForFU().

                              {
       // find run dir
       boost::filesystem::path runDirectory(
                        edm::Service<evf::EvFDaqDirector>()->findCurrentRunDir());
       smpath_ = runDirectory.string();
       edm::LogInfo("RecoEventOutputModuleForFU") << "Writing .dat files to "
                          << smpath_;
       // create open dir if not already there
       boost::filesystem::path openPath = runDirectory;
       openPath /= "open";
       // do these dirs need to be created?
       bool foundOpenDir = false;
       if (boost::filesystem::is_directory(openPath))
     foundOpenDir = true;
       if (!foundOpenDir) {
     std::cout << "<open> FU dir not found. Creating..."
           << std::endl;
     boost::filesystem::create_directories(openPath);
       }
     }

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::start ( void ) const

privatevirtual

Implements edm::StreamerOutputModuleBase.

Definition at line 114 of file RecoEventOutputModuleForFU.h.

References gather_cfg::cout, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by progressbar.ProgressBar::__next__(), Types.LuminosityBlockRange::cppID(), and Types.EventRange::cppID().

   {
     std::cout << "RecoEventOutputModuleForFU: start() method " << std::endl;
     
     const std::string initFileName = edm::Service<evf::EvFDaqDirector>()->getInitFilePath(stream_label_);
     
     std::cout << "RecoEventOutputModuleForFU, initializing streams. init stream: " 
           << initFileName << std::endl;
 
     c_->setInitMessageFile(initFileName);
     c_->start();
   }

template<typename Consumer >

void evf::RecoEventOutputModuleForFU< Consumer >::stop ( ) const

privatevirtual

Implements edm::StreamerOutputModuleBase.

Definition at line 129 of file RecoEventOutputModuleForFU.h.

                                                    {
     c_->stop();
   }

Member Data Documentation

template<typename Consumer >

IntJ evf::RecoEventOutputModuleForFU< Consumer >::accepted_

mutableprivate

Definition at line 75 of file RecoEventOutputModuleForFU.h.

Referenced by evf::RecoEventOutputModuleForFU< Consumer >::RecoEventOutputModuleForFU().

template<typename Consumer >

std::string evf::RecoEventOutputModuleForFU< Consumer >::baseDir_

private

Definition at line 70 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

std::auto_ptr<Consumer> evf::RecoEventOutputModuleForFU< Consumer >::c_

private

Definition at line 67 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

std::string evf::RecoEventOutputModuleForFU< Consumer >::events_base_filename_

private

Definition at line 69 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

StringJ evf::RecoEventOutputModuleForFU< Consumer >::filelist_

private

Definition at line 76 of file RecoEventOutputModuleForFU.h.

Referenced by evf::RecoEventOutputModuleForFU< Consumer >::RecoEventOutputModuleForFU().

template<typename Consumer >

evf::FastMonitoringService* evf::RecoEventOutputModuleForFU< Consumer >::fms_

private

Definition at line 78 of file RecoEventOutputModuleForFU.h.

Referenced by evf::RecoEventOutputModuleForFU< Consumer >::RecoEventOutputModuleForFU().

template<typename Consumer >

std::string evf::RecoEventOutputModuleForFU< Consumer >::jsonDefPath_

private

Definition at line 72 of file RecoEventOutputModuleForFU.h.

Referenced by evf::RecoEventOutputModuleForFU< Consumer >::RecoEventOutputModuleForFU().

template<typename Consumer >

boost::shared_ptr<FastMonitor> evf::RecoEventOutputModuleForFU< Consumer >::jsonMonitor_

private

Definition at line 77 of file RecoEventOutputModuleForFU.h.

Referenced by evf::RecoEventOutputModuleForFU< Consumer >::RecoEventOutputModuleForFU().

template<typename Consumer >

boost::filesystem::path evf::RecoEventOutputModuleForFU< Consumer >::openDatFilePath_

private

Definition at line 73 of file RecoEventOutputModuleForFU.h.

template<typename Consumer >

IntJ evf::RecoEventOutputModuleForFU< Consumer >::processed_

private

Definition at line 74 of file RecoEventOutputModuleForFU.h.

Referenced by evf::RecoEventOutputModuleForFU< Consumer >::RecoEventOutputModuleForFU().

template<typename Consumer >

std::string evf::RecoEventOutputModuleForFU< Consumer >::smpath_

private

Definition at line 71 of file RecoEventOutputModuleForFU.h.

Referenced by evf::RecoEventOutputModuleForFU< Consumer >::initializeStreams().

template<typename Consumer >

std::string evf::RecoEventOutputModuleForFU< Consumer >::stream_label_

private

Definition at line 68 of file RecoEventOutputModuleForFU.h.

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

template<typename Consumer> class evf::RecoEventOutputModuleForFU< Consumer >

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation

template<typename Consumer>
class evf::RecoEventOutputModuleForFU< Consumer >