stor::FRDStreamHandler Class Reference

#include <FRDStreamHandler.h>

Inheritance diagram for stor::FRDStreamHandler:

Public Member Functions
	FRDStreamHandler (const ErrorStreamConfigurationInfo &, const SharedResourcesPtr, const DbFileHandlerPtr)
Public Member Functions inherited from stor::StreamHandler
void	closeAllFiles ()
void	closeFilesForLumiSection (const uint32_t lumiSection)
void	closeFilesForLumiSection (const uint32_t &lumiSection, std::string &)
void	closeTimedOutFiles (utils::TimePoint_t currentTime=utils::getCurrentTime())
	StreamHandler (const SharedResourcesPtr, const DbFileHandlerPtr)
void	writeEvent (const I2OChain &event)
virtual	~StreamHandler ()

Private Member Functions
virtual double	fractionToDisk () const
virtual int	getStreamMaxFileSize () const
virtual FileHandlerPtr	newFileHandler (const I2OChain &event)
virtual std::string	streamLabel () const

Private Attributes
ErrorStreamConfigurationInfo	streamConfig_

Additional Inherited Members
Protected Types inherited from stor::StreamHandler
typedef std::map< std::string, unsigned int >	CoreFileNamesMap
typedef boost::shared_ptr < FileHandler >	FileHandlerPtr
typedef std::vector < FileHandlerPtr >	FileHandlers
Protected Member Functions inherited from stor::StreamHandler
virtual FileHandlerPtr	getFileHandler (const I2OChain &event)
unsigned long long	getMaxFileSize () const
FilesMonitorCollection::FileRecordPtr	getNewFileRecord (const I2OChain &event)
Protected Attributes inherited from stor::StreamHandler
const DbFileHandlerPtr	dbFileHandler_
const DiskWritingParams	diskWritingParams_
FileHandlers	fileHandlers_
const SharedResourcesPtr	sharedResources_
const StatisticsReporterPtr	statReporter_
const StreamsMonitorCollection::StreamRecordPtr	streamRecord_
CoreFileNamesMap	usedCoreFileNames_

Detailed Description

Handle one FED Raw Data (error) event stream written to disk.

Author:

mommsen

Revision:

1.6.10.1

Date:

2011/03/07 11:33:04

Definition at line 25 of file FRDStreamHandler.h.

Constructor & Destructor Documentation

stor::FRDStreamHandler::FRDStreamHandler	(	const ErrorStreamConfigurationInfo &	streamConfig,
		const SharedResourcesPtr	sharedResources,
		const DbFileHandlerPtr	dbFileHandler
	)

Definition at line 13 of file FRDStreamHandler.cc.

References python.StorageManager_cfg::streamLabel.

   :
  StreamHandler(sharedResources, dbFileHandler),
  streamConfig_(streamConfig)
  {
    streamRecord_->streamName = streamLabel();
    streamRecord_->fractionToDisk = fractionToDisk();
  }

Member Function Documentation

virtual double stor::FRDStreamHandler::fractionToDisk ( ) const

inlineprivatevirtual

Return the fraction-to-disk parameter This value is not configurable for FRD events, i.e. all events are always written

Implements stor::StreamHandler.

Definition at line 50 of file FRDStreamHandler.h.

    { return 1; }

virtual int stor::FRDStreamHandler::getStreamMaxFileSize ( ) const

inlineprivatevirtual

Return the maximum file size for the stream in MB

Implements stor::StreamHandler.

Definition at line 61 of file FRDStreamHandler.h.

References stor::ErrorStreamConfigurationInfo::maxFileSizeMB(), and streamConfig_.

    { return streamConfig_.maxFileSizeMB(); }

FRDStreamHandler::FileHandlerPtr stor::FRDStreamHandler::newFileHandler ( const I2OChain &  event )

privatevirtual

Return a new file handler for the provided event

Implements stor::StreamHandler.

Definition at line 27 of file FRDStreamHandler.cc.

References stor::StreamHandler::dbFileHandler_, stor::StreamHandler::diskWritingParams_, stor::StreamHandler::fileHandlers_, stor::StreamHandler::getMaxFileSize(), and stor::StreamHandler::getNewFileRecord().

  {
    FilesMonitorCollection::FileRecordPtr fileRecord = getNewFileRecord(event);
    
    FileHandlerPtr newFileHandler(
      new FRDFileHandler(fileRecord, dbFileHandler_, diskWritingParams_, getMaxFileSize())
    );
    fileHandlers_.push_back(newFileHandler);
    
    return newFileHandler;
  }

virtual std::string stor::FRDStreamHandler::streamLabel ( ) const

inlineprivatevirtual

Return the stream label

Implements stor::StreamHandler.

Definition at line 42 of file FRDStreamHandler.h.

References streamConfig_, and stor::ErrorStreamConfigurationInfo::streamLabel().

    { return streamConfig_.streamLabel(); }

Member Data Documentation

ErrorStreamConfigurationInfo stor::FRDStreamHandler::streamConfig_

private

Definition at line 65 of file FRDStreamHandler.h.

Referenced by getStreamMaxFileSize(), and streamLabel().