---

edm::FRDStreamService Class Reference

#include <EventFilter/StorageManager/interface/FRDStreamService.h>

Inheritance diagram for edm::FRDStreamService:

List of all members.

Public Member Functions
void	closeTimedOutFiles ()
void	closeTimedOutFiles (int lumi, double timeoutstart)
	FRDStreamService (ParameterSet const &)
bool	nextEvent (const uint8 *const)
void	report (std::ostream &os, int indentation) const
void	stop ()
	~FRDStreamService ()
Private Member Functions
bool	checkEvent (boost::shared_ptr< FileRecord >, FRDEventMsgView const &) const
boost::shared_ptr< FileRecord >	generateFileRecord ()
boost::shared_ptr< OutputService >	getOutputService (FRDEventMsgView const &)
boost::shared_ptr< OutputService >	newOutputService ()

---

Detailed Description

Definition at line 23 of file FRDStreamService.h.

---

Constructor & Destructor Documentation

FRDStreamService::FRDStreamService

(

ParameterSet const &

pset

)

Definition at line 22 of file FRDStreamService.cc.

References edm::StreamService::highWaterMark_, edm::StreamService::lumiSection_, edm::StreamService::lumiSectionTimeOut_, edm::StreamService::maxFileSizeInMB_, edm::StreamService::maxSize_, edm::StreamService::ntotal_, edm::StreamService::numberOfFileSystems_, edm::StreamService::parameterSet_, edm::StreamService::runNumber_, and edm::StreamService::setStreamParameter().

{
  parameterSet_ = pset;
  runNumber_ = 0;
  lumiSection_ = 0;
  numberOfFileSystems_ = 0;
  maxFileSizeInMB_ = 0;
  maxSize_ = 0;
  highWaterMark_ = 0;
  lumiSectionTimeOut_ = 0;
  ntotal_ = 0;

  setStreamParameter();
}

edm::FRDStreamService::~FRDStreamService

(

)

[inline]

Definition at line 27 of file FRDStreamService.h.

References stop().

{ stop(); }

---

Member Function Documentation

bool edm::FRDStreamService::checkEvent	(	boost::shared_ptr< FileRecord >	,
		FRDEventMsgView const &
	)			const [private]

Referenced by getOutputService().

void FRDStreamService::closeTimedOutFiles

(

)

[virtual]

Implements edm::StreamService.

Definition at line 95 of file FRDStreamService.cc.

{
  // since we are currently storing all events in a single file,
  // we never close files at lumi section boundaries

  return;
}

void FRDStreamService::closeTimedOutFiles	(	int	lumi,
		double	timeoutstart
	)			[virtual]

Implements edm::StreamService.

Definition at line 83 of file FRDStreamService.cc.

{
  // since we are currently storing all events in a single file,
  // we never close files at lumi section boundaries

  return;
}

boost::shared_ptr< FileRecord > FRDStreamService::generateFileRecord

(

)

[private]

Definition at line 166 of file FRDStreamService.cc.

References fd, aod_PYTHIA_cfg::fileName, edm::StreamService::fileName_, edm::StreamService::filePath_, it, edm::StreamService::list_lock_, edm::StreamService::lumiSection_, edm::StreamService::ntotal_, edm::StreamService::numberOfFileSystems_, edm::StreamService::outputSummary_, edm::StreamService::runNumber_, edm::StreamService::setupLabel_, sl, edm::StreamService::sourceId_, and edm::StreamService::streamLabel_.

Referenced by newOutputService().

{
  std::ostringstream oss;   
  oss    << setupLabel_ 
         << "." << setfill('0') << std::setw(8) << runNumber_ 
         << "." << setfill('0') << std::setw(4) << lumiSection_
         << "." << streamLabel_ 
         << "." << fileName_
         << "." << setfill('0') << std::setw(2) << sourceId_;
  string fileName = oss.str();

  shared_ptr<FileRecord> fd = shared_ptr<FileRecord>(new FileRecord(lumiSection_, fileName, filePath_));    
  ++ntotal_;

  boost::mutex::scoped_lock sl(list_lock_);
  map<string, int>::iterator it = outputSummary_.find(fileName);
  if(it==outputSummary_.end()) {
     outputSummary_.insert(std::pair<string, int>(fileName,0));
  } else {
     ++it->second;
     fd->setFileCounter(it->second);
  }

  if (numberOfFileSystems_ > 0)
    fd->fileSystem((runNumber_ + atoi(sourceId_.c_str()) + ntotal_) % numberOfFileSystems_); 
  
  fd->checkDirectories();
  fd->setRunNumber(runNumber_);
  fd->setStreamLabel(streamLabel_);
  fd->setSetupLabel(setupLabel_);

  // fd->report(cout, 12);
  return fd;
}

boost::shared_ptr< OutputService > FRDStreamService::getOutputService

(

FRDEventMsgView const &

view

)

[private]

Definition at line 107 of file FRDStreamService.cc.

References checkEvent(), fd, edm::StreamService::fillOutputSummaryClosed(), it, edm::StreamService::lumiSection_, and edm::StreamService::outputMap_.

Referenced by nextEvent().

{
  for (OutputMapIterator it = outputMap_.begin(); it != outputMap_.end(); ++it) {
       if (it->first->lumiSection() == lumiSection_) {
          if (checkEvent(it->first, view))
            return it->second;
          else {
            boost::shared_ptr<FileRecord> fd(it->first);
            outputMap_.erase(it);
            fillOutputSummaryClosed(fd);
            break;
          }
      }
  }
  return newOutputService();
}

boost::shared_ptr< OutputService > FRDStreamService::newOutputService

(

)

[private]

Definition at line 131 of file FRDStreamService.cc.

References file, generateFileRecord(), and edm::StreamService::outputMap_.

{
  boost::shared_ptr<FileRecord> file = generateFileRecord();

  shared_ptr<OutputService> outputService(new FRDOutputService(file));
  outputMap_[file] = outputService;

  return outputService;
}

bool FRDStreamService::nextEvent

(

const uint8 * const

bufPtr

)

[virtual]

Implements edm::StreamService.

Definition at line 41 of file FRDStreamService.cc.

References getOutputService(), edm::StreamService::lumiSection_, FRDEventMsgView::run(), and edm::StreamService::runNumber_.

{
  ProgressMarker::instance()->processing(true);
  FRDEventMsgView view((void *) bufPtr);

  // accept all Error events, so no call to any sort of acceptEvents() method...

  runNumber_   = view.run();
  lumiSection_ = 1;  // Error message doesn't yet have lumi section number
                     // *and* we want to keep all Error events in the same
                     // file, for now


  shared_ptr<OutputService> outputService = getOutputService(view);
  ProgressMarker::instance()->processing(false);
  
  ProgressMarker::instance()->writing(true);
  outputService->writeEvent(bufPtr);
  ProgressMarker::instance()->writing(false);
  return true;
}

void edm::FRDStreamService::report	(	std::ostream &	os,
		int	indentation
	)			const [virtual]

Implements edm::StreamService.

void FRDStreamService::stop

(

)

[virtual]

Implements edm::StreamService.

Definition at line 67 of file FRDStreamService.cc.

References fd, edm::StreamService::fillOutputSummaryClosed(), it, and edm::StreamService::outputMap_.

Referenced by ~FRDStreamService().

{
  for (OutputMapIterator it = outputMap_.begin(); it != outputMap_.end(); ) {
    boost::shared_ptr<FileRecord> fd(it->first);
    outputMap_.erase(it++);
    fillOutputSummaryClosed(fd);
  }
}

---

The documentation for this class was generated from the following files:

• EventFilter/StorageManager/interface/FRDStreamService.h
• EventFilter/StorageManager/src/FRDStreamService.cc

---