#include <FUShmOutputModule.h>

Inheritance diagram for edm::FUShmOutputModule:

Public Member Functions
void	clearDatasetCounts ()

void	countEventForDatasets (EventMsgView const &eventMessage)

void	doOutputEvent (EventMsgBuilder const &eventMessage)

void	doOutputHeader (InitMsgBuilder const &initMessage)

	FUShmOutputModule (edm::ParameterSet const &ps)

unsigned int	getCounts ()

std::vector< unsigned int > &	getDatasetCounts ()

std::vector< std::string >	getDatasetNames ()

std::string	getStreamId ()

void	insertStreamAndDatasetInfo (edm::ParameterSet &streams, edm::ParameterSet datasets)

void	parseDatasets (InitMsgView const &initMessage)

void	sendPostponedInitMsg ()

void	sendPostponedStart ()

void	setNExpectedEPs (unsigned int EPs)

void	setPostponeInitMsg ()

void	start ()

void	stop ()

void	unregisterFromShm ()

	~FUShmOutputModule ()

Static Public Member Functions
static void	fillDescription (ParameterSetDescription &)

Private Attributes
unsigned int	count_

std::vector< unsigned int >	datasetCounts_

std::vector< Strings >	datasetPaths_

std::vector< std::pair < std::string, edm::EventSelector * > >	dpEventSelectors_

std::string	name_

unsigned int	nExpectedEPs_

unsigned int	numDatasets_

std::vector< std::string >	selectedDatasetNames_

evf::FUShmBuffer *	shmBuffer_

std::string	streamId_

unsigned int	totalPaths_

Static Private Attributes
static uint32	fuGuidValue_ = 0

static bool	fuIdsInitialized_ = false

Detailed Description

Definition at line 59 of file FUShmOutputModule.h.

Constructor & Destructor Documentation

edm::FUShmOutputModule::FUShmOutputModule ( edm::ParameterSet const & ps )

Definition at line 44 of file FUShmOutputModule.cc.

References FDEBUG, fuGuidValue_, fuIdsInitialized_, dttmaxenums::L, name_, AlCaHLTBitMon_QueryRunRegistry::string, and edm::Guid::toString().

                                                                :
     shmBuffer_(0)
     , name_(ps.getParameter<std::string>( "@module_label" ))
     , count_(0)
     , nExpectedEPs_(0)
     , numDatasets_(0)
     , streamId_()
   {
     FDEBUG(9) << "FUShmOutputModule: constructor" << endl;
     if(edm::Service<evf::ShmOutputModuleRegistry>())
       edm::Service<evf::ShmOutputModuleRegistry>()->registerModule(name_, this);  
     if (! fuIdsInitialized_) {
       fuIdsInitialized_ = true;
 
       edm::Guid guidObj(true);
       std::string guidString = guidObj.toString();
 
       uLong crc = crc32(0L, Z_NULL, 0);
       Bytef* buf = (Bytef*)guidString.data();
       crc = crc32(crc, buf, guidString.length());
       fuGuidValue_ = crc;
     }
   }

edm::FUShmOutputModule::~FUShmOutputModule ( )

Definition at line 68 of file FUShmOutputModule.cc.

References SM_SharedMemoryHandle::detachShmBuffer(), FDEBUG, and sm_sharedmemory.

   {
     FDEBUG(9) << "FUShmOutputModule: FUShmOutputModule destructor" << endl;
     sm_sharedmemory.detachShmBuffer();
     //shmdt(shmBuffer_);
   }

Member Function Documentation

void edm::FUShmOutputModule::clearDatasetCounts ( )

inline

Definition at line 80 of file FUShmOutputModule.h.

References datasetCounts_, and i.

                               {
         for (unsigned int i=0;i<datasetCounts_.size();i++) datasetCounts_[i]=0;
     }

void edm::FUShmOutputModule::countEventForDatasets ( EventMsgView const & eventMessage )

Definition at line 202 of file FUShmOutputModule.cc.

References datasetCounts_, dpEventSelectors_, EventMsgView::hltTriggerBits(), i, numDatasets_, edm::second(), and totalPaths_.

Referenced by doOutputEvent().

   {
     if (!numDatasets_) return;
     uint8 hlt_out[totalPaths_];
     eventMessage.hltTriggerBits( hlt_out );
     for (size_t i=0;i<numDatasets_;i++) {
       if ( dpEventSelectors_[i].second->acceptEvent( hlt_out, totalPaths_)) {
     datasetCounts_[i]++;
       }
     }
   }

void edm::FUShmOutputModule::doOutputEvent ( EventMsgBuilder const & eventMessage )

Definition at line 133 of file FUShmOutputModule.cc.

References count_, countEventForDatasets(), FDEBUG, fuGuidValue_, SM_SharedMemoryHandle::getShmBuffer(), run_regression::ret, shmBuffer_, EventMsgBuilder::size(), findQualityFiles::size, sm_sharedmemory, EventMsgBuilder::startAddress(), and evf::FUShmBuffer::writeRecoEventData().

   {
     if(!shmBuffer_) edm::LogError("FUShmOutputModule") 
       << " Invalid shared memory buffer at first event"
       << " Make sure you configure the ResourceBroker before the FUEventProcessor! "
       << " No event is sent - this is fatal! Should throw here";
     else
     {
       count_++;
       unsigned char* buffer = (unsigned char*) eventMessage.startAddress();
       unsigned int size = eventMessage.size();
       EventMsgView eventView(eventMessage.startAddress());
       countEventForDatasets(eventView);
       unsigned int runid = eventView.run();
       unsigned int eventid = eventView.event();
       unsigned int outModId = eventView.outModId();
       FDEBUG(10) << "FUShmOutputModule: event size = " << size << std::endl;
       //bool ret = shmBuffer_->writeRecoEventData(runid, eventid, outModId, buffer, size);
       bool ret = sm_sharedmemory.getShmBuffer()->writeRecoEventData(runid, eventid, outModId, getpid(), fuGuidValue_, buffer, size);
       if(!ret) edm::LogError("FUShmOutputModule") << " Error with writing data to ShmBuffer";
     }
   }

void edm::FUShmOutputModule::doOutputHeader ( InitMsgBuilder const & initMessage )

Definition at line 109 of file FUShmOutputModule.cc.

References count_, FDEBUG, fuGuidValue_, SM_SharedMemoryHandle::getShmBuffer(), nExpectedEPs_, InitMsgView::outputModuleId(), parseDatasets(), run_regression::ret, shmBuffer_, InitMsgBuilder::size(), findQualityFiles::size, sm_sharedmemory, InitMsgBuilder::startAddress(), and evf::FUShmBuffer::writeRecoInitMsg().

   {
     unsigned char* buffer = (unsigned char*) initMessage.startAddress();
     unsigned int size = initMessage.size();
     InitMsgView dummymsg(buffer);
     parseDatasets(dummymsg);
     count_ = 0;
     if(!shmBuffer_) shmBuffer_ = sm_sharedmemory.getShmBuffer();
     if(!shmBuffer_) edm::LogError("FUShmOutputModule") 
       << " Error getting shared memory buffer for INIT. " 
       << " Make sure you configure the ResourceBroker before the FUEventProcessor! "
       << " No INIT is sent - this is probably fatal!";
     if(shmBuffer_)
     {
       FDEBUG(10) << "writing out INIT message with size = " << size << std::endl;
       // no method in InitMsgBuilder to get the output module id, recast
       uint32 dmoduleId = dummymsg.outputModuleId();
 
       //bool ret = shmBuffer_->writeRecoInitMsg(dmoduleId, buffer, size);
       bool ret = sm_sharedmemory.getShmBuffer()->writeRecoInitMsg(dmoduleId, getpid(), fuGuidValue_, buffer, size,nExpectedEPs_);
       if(!ret) edm::LogError("FUShmOutputModule") << " Error writing preamble to ShmBuffer";
     }
   }

void edm::FUShmOutputModule::fillDescription ( ParameterSetDescription & description )

static

Definition at line 104 of file FUShmOutputModule.cc.

105 {

106 }

unsigned int edm::FUShmOutputModule::getCounts ( )

inlinevirtual

Implements evf::OutputModule.

Definition at line 69 of file FUShmOutputModule.h.

References count_.

                             {
       return count_;
     }

std::vector<unsigned int>& edm::FUShmOutputModule::getDatasetCounts ( )

inline

Definition at line 79 of file FUShmOutputModule.h.

References datasetCounts_.

79 {return datasetCounts_;}

edm::FUShmOutputModule::datasetCounts_

std::vector< unsigned int > datasetCounts_

Definition: FUShmOutputModule.h:103

std::vector<std::string> edm::FUShmOutputModule::getDatasetNames ( )

inline

Definition at line 78 of file FUShmOutputModule.h.

References selectedDatasetNames_.

Referenced by evf::ShmOutputModuleRegistry::updateDatasetInfo().

78 {return selectedDatasetNames_;}

edm::FUShmOutputModule::selectedDatasetNames_

std::vector< std::string > selectedDatasetNames_

Definition: FUShmOutputModule.h:106

std::string edm::FUShmOutputModule::getStreamId ( )

inline

Definition at line 83 of file FUShmOutputModule.h.

References streamId_.

Referenced by evf::ShmOutputModuleRegistry::updateDatasetInfo().

83 {return streamId_;}

edm::FUShmOutputModule::streamId_

std::string streamId_

Definition: FUShmOutputModule.h:111

void edm::FUShmOutputModule::insertStreamAndDatasetInfo	(	edm::ParameterSet &	streams,
		edm::ParameterSet	datasets
	)

Definition at line 75 of file FUShmOutputModule.cc.

References datasetPaths_, edm::ParameterSet::getParameter(), i, name_, numDatasets_, selectedDatasetNames_, streamId_, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by evf::ShmOutputModuleRegistry::insertStreamAndDatasetInfo().

   {
     if (numDatasets_) return;
     try {
       //compose dataset name string
       if (name_.size() > std::string("hltOutput").size() && name_.find("hltOutput")!=std::string::npos)
     streamId_=name_.substr(name_.find("hltOutput")+std::string("hltOutput").size());
       else return;
 
       //make local copy of dataset definitions
       if (streamId_.size()) {
     Strings streamDatasetList = streams.getParameter<Strings>(streamId_);
     for (size_t i=0;i<streamDatasetList.size();i++) {
       selectedDatasetNames_.push_back(streamDatasetList[i]);
       Strings thisDatasetPaths = datasets.getParameter<Strings>(streamDatasetList[i]); 
       datasetPaths_.push_back(thisDatasetPaths);
       numDatasets_++;
     }
       }
     }
     catch (...) {
       //not present:ignore
       selectedDatasetNames_.clear();
       datasetPaths_.clear();
       numDatasets_=0;
       streamId_=std::string();
     }
   }

void edm::FUShmOutputModule::parseDatasets ( InitMsgView const & initMessage )

Definition at line 185 of file FUShmOutputModule.cc.

References datasetCounts_, datasetPaths_, dpEventSelectors_, InitMsgView::hltTriggerNames(), i, numDatasets_, selectedDatasetNames_, AlCaHLTBitMon_QueryRunRegistry::string, and totalPaths_.

Referenced by doOutputHeader().

   {
      //reset counter
      for (size_t i=0;i<datasetCounts_.size();i++) datasetCounts_[i]=0;
      if (!numDatasets_) return;
      if (dpEventSelectors_.size()) return;
      Strings allPaths;
      initMessage.hltTriggerNames(allPaths);
      totalPaths_ = allPaths.size();
      for (size_t i=0;i<numDatasets_;i++)
      {
        dpEventSelectors_.push_back(std::pair<std::string,
          edm::EventSelector*>(selectedDatasetNames_[i],new edm::EventSelector(datasetPaths_[i],allPaths))); 
        datasetCounts_.push_back(0);
      }
   }

void edm::FUShmOutputModule::sendPostponedInitMsg ( )

void edm::FUShmOutputModule::sendPostponedStart ( )

void edm::FUShmOutputModule::setNExpectedEPs ( unsigned int EPs )

Definition at line 174 of file FUShmOutputModule.cc.

References nExpectedEPs_.

                                                           {
     nExpectedEPs_ = EPs;
   }

void edm::FUShmOutputModule::setPostponeInitMsg ( )

void edm::FUShmOutputModule::start ( void )

Definition at line 156 of file FUShmOutputModule.cc.

References SM_SharedMemoryHandle::getShmBuffer(), shmBuffer_, and sm_sharedmemory.

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

   {
     //shmBuffer_ = evf::FUShmBuffer::getShmBuffer();
     shmBuffer_ = sm_sharedmemory.getShmBuffer();
     if(0==shmBuffer_) 
       edm::LogError("FUShmOutputModule")<<"Failed to attach to shared memory";
   }

void edm::FUShmOutputModule::stop ( )

Definition at line 164 of file FUShmOutputModule.cc.

References SM_SharedMemoryHandle::detachShmBuffer(), FDEBUG, shmBuffer_, and sm_sharedmemory.

   {
     FDEBUG(9) << "FUShmOutputModule: sending terminate run" << std::endl;
     if(0!=shmBuffer_){
       sm_sharedmemory.detachShmBuffer();
       //shmdt(shmBuffer_);
       shmBuffer_ = 0;
     }
   }

void edm::FUShmOutputModule::unregisterFromShm ( )

Definition at line 178 of file FUShmOutputModule.cc.

References SM_SharedMemoryHandle::getBufferRef(), evf::FUShmBuffer::removeClientPrcId(), shmBuffer_, and sm_sharedmemory.

                                             {
     shmBuffer_=sm_sharedmemory.getBufferRef();
     if (0!=shmBuffer_) {
       shmBuffer_->removeClientPrcId(getpid());
     }
   }