#include <RawEventOutputModuleForBU.h>

Inheritance diagram for RawEventOutputModuleForBU< Consumer >:

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

	~RawEventOutputModuleForBU ()

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, ThinnedAssociationsHelper const &)

ThinnedAssociationsHelper const *	thinnedAssociationsHelper () const

bool	wantAllEvents () const

virtual	~OutputModule ()

Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const

	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

void	modulesDependentUpon (const std::string &iProcessName, std::vector< const char * > &oModuleLabels) const

void	modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const

bool	registeredToConsume (ProductHolderIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

void	updateLookup (BranchType iBranchType, ProductHolderIndexHelper const &)

virtual	~EDConsumerBase ()

Private Types
typedef unsigned int	uint32

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

virtual void	beginRun (edm::RunPrincipal const &, edm::ModuleCallingContext const *)

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

virtual void	endRun (edm::RunPrincipal const &, edm::ModuleCallingContext const *)

virtual void	write (edm::EventPrincipal const &e, edm::ModuleCallingContext const *)

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

virtual void	writeRun (const edm::RunPrincipal &, edm::ModuleCallingContext const *)

Private Attributes
bool	firstLumi_

unsigned int	frdVersion_

unsigned int	index_

std::string	instance_

std::string	label_

unsigned int	numEventsPerFile_

timeval	startOfLastLumi

std::auto_ptr< Consumer >	templateConsumer_

unsigned int	totevents

unsigned long long	totsize

unsigned long long	writtensize

unsigned long long	writtenSizeLast

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

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

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

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, ActivityRegistry act, 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<class Consumer>
class RawEventOutputModuleForBU< Consumer >

Definition at line 24 of file RawEventOutputModuleForBU.h.

Member Typedef Documentation

template<class Consumer >

typedef unsigned int RawEventOutputModuleForBU< Consumer >::uint32

private

Definition at line 26 of file RawEventOutputModuleForBU.h.

Constructor & Destructor Documentation

template<class Consumer >

RawEventOutputModuleForBU< Consumer >::RawEventOutputModuleForBU ( edm::ParameterSet const & ps )

explicit

Consumers are suppose to provide: void doOutputEvent(const FRDEventMsgView& msg) void start() void stop()

Definition at line 63 of file RawEventOutputModuleForBU.h.

                                                                                         :
   edm::OutputModule(ps),
   templateConsumer_(new Consumer(ps)),
   label_(ps.getUntrackedParameter<std::string>("ProductLabel","source")),
   instance_(ps.getUntrackedParameter<std::string>("ProductInstance","")),
   numEventsPerFile_(ps.getUntrackedParameter<unsigned int>("numEventsPerFile",100)),
   frdVersion_(ps.getUntrackedParameter<unsigned int>("frdVersion",3)),
   totsize(0LL),
   writtensize(0LL),
   writtenSizeLast(0LL),
   totevents(0),
   index_(0),
   firstLumi_(true)
 {
 }

template<class Consumer >

RawEventOutputModuleForBU< Consumer >::~RawEventOutputModuleForBU ( )

Definition at line 80 of file RawEventOutputModuleForBU.h.

80 {}

Member Function Documentation

template<class Consumer >

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

privatevirtual

Reimplemented from edm::OutputModule.

Definition at line 182 of file RawEventOutputModuleForBU.h.

References gather_cfg::cout, lut2db_cfg::filename, edm::LuminosityBlockPrincipal::id(), edm::LuminosityBlockID::luminosityBlock(), fileCollector::now, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                                                                    {
     index_ = 0;
     std::string filename = edm::Service<evf::EvFDaqDirector>()->getOpenRawFilePath( ls.id().luminosityBlock(),index_);
     std::string destinationDir = edm::Service<evf::EvFDaqDirector>()->buBaseRunDir();
         std::cout << " writing to destination dir " << destinationDir << " name: " << filename << std::endl;
     templateConsumer_->initialize(destinationDir,filename,ls.id().luminosityBlock());
   //edm::Service<evf::EvFDaqDirector>()->updateBuLock(ls.id().luminosityBlock()+1);
   if(!firstLumi_){
     timeval now;
     ::gettimeofday(&now,0);
     //long long elapsedusec = (now.tv_sec - startOfLastLumi.tv_sec)*1000000+now.tv_usec-startOfLastLumi.tv_usec;
 /*     std::cout << "(now.tv_sec - startOfLastLumi.tv_sec) " << now.tv_sec <<"-" << startOfLastLumi.tv_sec */
 /*        <<" (now.tv_usec-startOfLastLumi.tv_usec) " << now.tv_usec << "-" << startOfLastLumi.tv_usec << std::endl; */
 /*     std::cout << "elapsedusec " << elapsedusec << "  totevents " << totevents << "  size (GB)" << writtensize  */
 /*        << "  rate " << (writtensize-writtenSizeLast)/elapsedusec << " MB/s" <<std::endl; */
     writtenSizeLast=writtensize;
     ::gettimeofday(&startOfLastLumi,0);
     //edm::Service<evf::EvFDaqDirector>()->writeLsStatisticsBU(ls.id().luminosityBlock(), totevents, totsize, elapsedusec);
   }
   else
     ::gettimeofday(&startOfLastLumi,0);
   totevents = 0;
   totsize = 0LL;
   firstLumi_ = false;
 }

template<class Consumer >

void RawEventOutputModuleForBU< Consumer >::beginRun	(	edm::RunPrincipal const &	,
		edm::ModuleCallingContext const *
	)

privatevirtual

Reimplemented from edm::OutputModule.

Definition at line 169 of file RawEventOutputModuleForBU.h.

 {
  // edm::Service<evf::EvFDaqDirector>()->updateBuLock(1);
   templateConsumer_->start();
 }

template<class Consumer >

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

privatevirtual

Reimplemented from edm::OutputModule.

Definition at line 208 of file RawEventOutputModuleForBU.h.

References edm::LuminosityBlockPrincipal::id(), and edm::LuminosityBlockID::luminosityBlock().

                                                                                                                                  {
 
   //  templateConsumer_->touchlock(ls.id().luminosityBlock(),basedir);
   templateConsumer_->endOfLS(ls.id().luminosityBlock());
 }

template<class Consumer >

void RawEventOutputModuleForBU< Consumer >::endRun	(	edm::RunPrincipal const &	,
		edm::ModuleCallingContext const *
	)

privatevirtual

Reimplemented from edm::OutputModule.

Definition at line 176 of file RawEventOutputModuleForBU.h.

 {
   templateConsumer_->stop();
 }

template<class Consumer >

void RawEventOutputModuleForBU< Consumer >::write	(	edm::EventPrincipal const &	e,
		edm::ModuleCallingContext const *	mcc
	)

privatevirtual

Implements edm::OutputModule.

Definition at line 83 of file RawEventOutputModuleForBU.h.

References cms::Adler32(), crc32c(), FEDRawData::data(), idDealer::description, edm::EventID::event(), event(), lut2db_cfg::filename, FRDHeaderVersionSize, edm::EventBase::id(), customizeTrackingMonitorSeedNumber::idx, FEDNumbering::lastFEDId(), python.rootplot.utilities::ls(), edm::EventBase::luminosityBlock(), edm::EventPrincipal::luminosityBlock(), producerFileCleanner::msg, edm::EventID::run(), FEDRawData::size(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by pkg.AbstractPkg::generate().

 {
   unsigned int ls = e.luminosityBlock();
   if(totevents>0 && totevents%numEventsPerFile_==0){
       index_++;
       std::string filename = edm::Service<evf::EvFDaqDirector>()->getOpenRawFilePath( ls,index_);
       std::string destinationDir = edm::Service<evf::EvFDaqDirector>()->buBaseRunDir();
       templateConsumer_->initialize(destinationDir,filename,ls);
   }
   totevents++;
   // serialize the FEDRawDataCollection into the format that we expect for
   // FRDEventMsgView objects (may be better ways to do this)
   edm::Event event(const_cast<edm::EventPrincipal&>(e), description(),mcc);
   edm::Handle<FEDRawDataCollection> fedBuffers;
   event.getByLabel(label_, instance_, fedBuffers);
 
   // determine the expected size of the FRDEvent IN BYTES !!!!!
   int headerSize = FRDHeaderVersionSize[frdVersion_];
   int expectedSize = headerSize;
   int nFeds = frdVersion_<3? 1024 : FEDNumbering::lastFEDId()+1;
 
 
   for (int idx = 0; idx < nFeds; ++idx) {
     FEDRawData singleFED = fedBuffers->FEDData(idx);
     expectedSize += singleFED.size();
   }
 
   totsize += expectedSize;
   // build the FRDEvent into a temporary buffer
   boost::shared_array<unsigned char> workBuffer(new unsigned char[expectedSize + 256]);
   uint32 *bufPtr = (uint32*) workBuffer.get();
   *bufPtr++ = (uint32) frdVersion_;  // version number
   *bufPtr++ = (uint32) event.id().run();
   *bufPtr++ = (uint32) event.luminosityBlock();
   *bufPtr++ = (uint32) event.id().event();
   if (frdVersion_==4)
     *bufPtr++ = 0;//64-bit event id high part
 
   if (frdVersion_<3) {
     uint32 fedsize[1024];
     for (int idx = 0; idx < 1024; ++idx) {
       FEDRawData singleFED = fedBuffers->FEDData(idx);
       fedsize[idx] = singleFED.size();
       //std::cout << "fed size " << singleFED.size()<< std::endl;
     }
     memcpy(bufPtr,fedsize,1024 * sizeof(uint32));
     bufPtr += 1024;
   }
   else {
     *bufPtr++ = expectedSize-headerSize;
     *bufPtr++ = 0;
      if (frdVersion_<=4)
       *bufPtr++ = 0;
   }
   uint32 *payloadPtr=bufPtr;
   for (int idx = 0; idx < nFeds; ++idx) {
     FEDRawData singleFED = fedBuffers->FEDData(idx);
     if (singleFED.size() > 0) {
       memcpy(bufPtr, singleFED.data(), singleFED.size());
       bufPtr += singleFED.size()/4;
     }
   }
   if (frdVersion_>4) {
     //crc32c checksum
     uint32_t crc = 0;
     *(payloadPtr-1) = crc32c(crc,(const unsigned char*) payloadPtr, expectedSize-headerSize);
   }
   else if (frdVersion_>=3) {
     //adler32 checksum
     uint32 adlera = 1;
     uint32 adlerb = 0;
     cms::Adler32((const char*) payloadPtr, expectedSize-headerSize, adlera, adlerb);
     *(payloadPtr-1) = (adlerb << 16) | adlera;
   }
 
   // create the FRDEventMsgView and use the template consumer to write it out
   FRDEventMsgView msg(workBuffer.get());
   writtensize+=msg.size();
 
   if (templateConsumer_->sharedMode())
     templateConsumer_->doOutputEvent(workBuffer);
   else
     templateConsumer_->doOutputEvent(msg);
 }