ByteStreamEventStorageOutputSvc Class Reference

This class provides the services for writing FullEventFragment into file. This class implements the interface ByteStreamOutputSvc for the conversion service to write the output to a file. More...

#include <ByteStreamEventStorageOutputSvc.h>

Inheritance diagram for ByteStreamEventStorageOutputSvc:

Collaboration diagram for ByteStreamEventStorageOutputSvc:

Classes
struct	EventCache

Public Member Functions
	ByteStreamEventStorageOutputSvc (const std::string &name, ISvcLocator *pSvcLocator)
	Constructors: More...
virtual	~ByteStreamEventStorageOutputSvc ()
	Destructor. More...
StatusCode	initialize () override
	Required of all Gaudi Services. More...
StatusCode	stop () override
StatusCode	finalize () override
StatusCode	queryInterface (const InterfaceID &riid, void **ppvInterface) override
virtual bool	putEvent (const RawEvent *re) override
	Implementation of the ByteStreamOutputSvc interface method putEvent. More...
virtual bool	putEvent (const RawEvent *re, const EventContext &ctx) override
StatusCode	io_reinit () override

Private Member Functions
StatusCode	reinit ()
	reinitialize the service when a fork() occurred/was-issued More...
bool	initDataWriter (const EventContext *ctx=nullptr)
	initialize EventStorage's DataWriter More...
bool	initDataWriterContents (const xAOD::EventInfo *, const ByteStreamMetadata *)
const ByteStreamMetadata *	getByteStreamMetadata ()
const ByteStreamMetadata *	getByteStreamMetadata (const EventContext &ctx)
void	updateDataWriterParameters (DataWriterParameters &) const
	Create DataWriter parameters from job properties. More...
void	updateDataWriterParameters (DataWriterParameters &params, const xAOD::EventInfo &evtInfo) const
	Create DataWriter parameters from EventInfo. More...
void	updateDataWriterParameters (DataWriterParameters &params, const ByteStreamMetadata &metaData) const
	Create DataWriter parameters from MetaData. More...

Private Attributes
Gaudi::Property< std::string >	m_inputDir
	< directory for the data files More...
Gaudi::Property< std::string >	m_projectTag
	Application Name. More...
Gaudi::Property< std::string >	m_appName
	File Tag. More...
Gaudi::Property< std::string >	m_fileTag
	stream type More...
Gaudi::Property< std::string >	m_streamType
	stream name More...
Gaudi::Property< std::string >	m_streamName
	eformat event version to produce, "v40" for run1, or "current" More...
Gaudi::Property< std::string >	m_eformatVersion
	EventStorage BS version to produce, "v5" for run1, or "current". More...
Gaudi::Property< std::string >	m_eventStorageVersion
	stream name for multiple output More...
Gaudi::Property< std::string >	m_bsOutputStreamName
Gaudi::Property< std::string >	m_simpleFileName
	use this string for filename, not from the "AgreedFileName" More...
Gaudi::Property< int >	m_lumiBlockNumber
	run number More...
Gaudi::Property< int >	m_run {this, "RunNumber", 0, "part of filename"}
	Dump fragments. More...
Gaudi::Property< bool >	m_dump {this, "DumpFlag", false, "dump fragments"}
	Write eventless files. More...
Gaudi::Property< bool >	m_writeEventless
	Compress events. More...
Gaudi::Property< bool >	m_compressEvents {this, "CompressEvents", false, ""}
	number of MB per file More...
Gaudi::Property< unsigned int >	m_maxFileMB
	number of events per file More...
Gaudi::Property< unsigned int >	m_maxFileNE
SG::ReadHandleKey< xAOD::EventInfo >	m_eventInfoKey
SG::ReadHandleKey< ByteStreamMetadataContainer >	m_byteStreamMetadataKey
ServiceHandle< IIoComponentMgr >	m_ioMgr {"IoComponentMgr", name()}
int	m_totalEventCounter {0}
	number of event counter More...
bool	m_isRun1 {false}
std::unique_ptr< ByteStreamDataWriter >	m_dataWriter
	pointer to DataWriter More...
std::mutex	m_dataWriterMutex
	mutex to lock data writer during initialization or writing More...
SG::SlotSpecificObj< EventCache >	m_eventCache
	Cache of event data for each slot. More...

Detailed Description

This class provides the services for writing FullEventFragment into file. This class implements the interface ByteStreamOutputSvc for the conversion service to write the output to a file.

Definition at line 46 of file ByteStreamEventStorageOutputSvc.h.

Constructor & Destructor Documentation

ByteStreamEventStorageOutputSvc()

ByteStreamEventStorageOutputSvc::ByteStreamEventStorageOutputSvc	(	const std::string &	name,
		ISvcLocator *	pSvcLocator
	)

Constructors:

Definition at line 29 of file ByteStreamEventStorageOutputSvc.cxx.

  : base_class(name, pSvcLocator) {
}

~ByteStreamEventStorageOutputSvc()

virtual ByteStreamEventStorageOutputSvc::~ByteStreamEventStorageOutputSvc ( )

inlinevirtual

Destructor.

Definition at line 56 of file ByteStreamEventStorageOutputSvc.h.

{}

Member Function Documentation

finalize()

StatusCode ByteStreamEventStorageOutputSvc::finalize ( )

override

Definition at line 109 of file ByteStreamEventStorageOutputSvc.cxx.

                                          {
  // clean up
  ATH_MSG_DEBUG("deleting DataWriter");
  m_dataWriter.reset();
  ATH_MSG_INFO("number of events written: " << m_totalEventCounter);
  return StatusCode::SUCCESS;
}

getByteStreamMetadata() [1/2]

const ByteStreamMetadata * ByteStreamEventStorageOutputSvc::getByteStreamMetadata ( )

private

Definition at line 291 of file ByteStreamEventStorageOutputSvc.cxx.

{
  SG::ReadHandle<ByteStreamMetadataContainer> metaDataCont (m_byteStreamMetadataKey);
 
  if (!metaDataCont.isValid()) return nullptr;
 
  if (metaDataCont->size() > 1)
    ATH_MSG_WARNING("Multiple run parameters in MetaDataStore. "
                    "Bytestream format only supports one. Arbitrarily "
                    "choosing first.");
 
  return metaDataCont->front();
}

getByteStreamMetadata() [2/2]

const ByteStreamMetadata * ByteStreamEventStorageOutputSvc::getByteStreamMetadata ( const EventContext &  ctx )

private

Definition at line 307 of file ByteStreamEventStorageOutputSvc.cxx.

{
  SG::ReadHandle<ByteStreamMetadataContainer> metaDataCont (m_byteStreamMetadataKey, ctx);
 
  if (!metaDataCont.isValid()) return nullptr;
 
  if (metaDataCont->size() > 1)
    ATH_MSG_WARNING("Multiple run parameters in MetaDataStore. "
                    "Bytestream format only supports one. Arbitrarily "
                    "choosing first.");
 
  return metaDataCont->front();
}

initDataWriter()

bool ByteStreamEventStorageOutputSvc::initDataWriter ( const EventContext *  ctx = nullptr )

private

initialize EventStorage's DataWriter

Definition at line 119 of file ByteStreamEventStorageOutputSvc.cxx.

                                                                       {
  // Called on first event. Reads run parameters first event and/or first event
  const xAOD::EventInfo* eventInfo = ctx == nullptr
      ? SG::get(m_eventInfoKey)
      : SG::get(m_eventInfoKey, *ctx);
  if (eventInfo == nullptr) ATH_MSG_WARNING("failed to retrieve EventInfo");
 
  const ByteStreamMetadata* metaData = ctx == nullptr ? getByteStreamMetadata() : getByteStreamMetadata(*ctx);
  if (metaData == nullptr)
    ATH_MSG_WARNING("failed to retrieve ByteStreamMetaData");
 
  // Now open a file for writing from retrieved parameters
  return initDataWriterContents(eventInfo, metaData);
}

initDataWriterContents()

bool ByteStreamEventStorageOutputSvc::initDataWriterContents ( const xAOD::EventInfo *  evtInfo, const ByteStreamMetadata *  metaData  )

private

Definition at line 136 of file ByteStreamEventStorageOutputSvc.cxx.

                                        {
  // check that we have sufficient information to do what we need
  if (evtInfo or metaData)
    ATH_MSG_DEBUG("Looking up data writer parameters");
  else
    throw std::runtime_error("Cannot write data without run parameters");
 
  // The heirarchy of run/lumiblock number, GNARR
  //
  //   1) User override
  //   2) Event data
  //   3) File metadata
  //   4) default = unknown = 0
  //
  // Go from 4 to 1 and overwrite
  DataWriterParameters params; 
  if (metaData != nullptr) updateDataWriterParameters(params, *metaData);
  if (evtInfo != nullptr) updateDataWriterParameters(params, *evtInfo);
  updateDataWriterParameters(params);
 
  m_dataWriter = ByteStreamDataWriter::makeWriter(params);
 
  bool result = m_dataWriter->good();
  if (result)
    ATH_MSG_DEBUG("initialized output stream to file with name "
                  << params.fileNameCore);
  else
    ATH_MSG_ERROR("Unable to initialize file");
 
  return result;
}

initialize()

StatusCode ByteStreamEventStorageOutputSvc::initialize ( )

override

Required of all Gaudi Services.

Definition at line 36 of file ByteStreamEventStorageOutputSvc.cxx.

                                            {
  ATH_MSG_INFO("Initializing");
 
  ATH_CHECK(ByteStreamOutputSvc::initialize());
 
  ATH_CHECK(m_eventInfoKey.initialize());
  ATH_CHECK(m_byteStreamMetadataKey.initialize());
 
  // register this service for 'I/O' events
  ATH_CHECK(m_ioMgr.retrieve());
  ATH_CHECK(m_ioMgr->io_register(this));
 
  // Register output file's name with the I/O manager
  if (!m_simpleFileName.empty()) {
    ATH_CHECK(m_ioMgr->io_register(this, IIoComponentMgr::IoMode::WRITE,
                                   m_simpleFileName));
    ATH_MSG_VERBOSE("io_register[" << this->name() << "]("
                    << m_simpleFileName << ") [ok]");
  }
 
  // validate m_eformatVersion
  const std::vector< std::string > choices_ef{"current", "v40", "run1"};
  if (std::find(choices_ef.begin(), choices_ef.end(), m_eformatVersion)
      == choices_ef.end()) {
    ATH_MSG_FATAL("Unexpected value for EformatVersion property: "
                  << m_eformatVersion);
    return StatusCode::FAILURE;
  }
  ATH_MSG_INFO("eformat version to use: \"" << m_eformatVersion << "\"");
 
  // validate m_eventStorageVersion
  const std::vector< std::string > choices_es{"current", "v5", "run1"};
  if (std::find(choices_es.begin(), choices_es.end(), m_eventStorageVersion)
      == choices_es.end()) {
    ATH_MSG_FATAL("Unexpected value for EventStorageVersion property: "
                  << m_eventStorageVersion);
    return StatusCode::FAILURE;
  }
  ATH_MSG_INFO("event storage (BS) version to use: \""
               << m_eventStorageVersion << "\"");
 
  m_isRun1 = (m_eformatVersion == "v40" or m_eformatVersion == "run1");
 
  ATH_CHECK(reinit());
 
  return StatusCode::SUCCESS;
}

io_reinit()

StatusCode ByteStreamEventStorageOutputSvc::io_reinit ( )

override

Definition at line 253 of file ByteStreamEventStorageOutputSvc.cxx.

                                           {
  ATH_MSG_INFO("I/O reinitialization...");
 
  if (!m_ioMgr->io_hasitem(this)) {
    ATH_MSG_FATAL("IoComponentMgr does not know about myself !");
    return StatusCode::FAILURE;
  }
 
  if (!m_simpleFileName.empty()) {
    std::string outputFile = m_simpleFileName;
    ATH_MSG_INFO("I/O reinitialization, file = "  << outputFile);
    std::string &fname = outputFile;
    if (!m_ioMgr->io_contains(this, fname)) {
      ATH_MSG_ERROR("IoComponentMgr does not know about [" << fname << "] !");
      return(StatusCode::FAILURE);
    }
    if (!m_ioMgr->io_retrieve(this, fname).isSuccess()) {
      ATH_MSG_FATAL("Could not retrieve new value for [" << fname << "] !");
      return(StatusCode::FAILURE);
    }
    // all good... copy over.
    // modify directory
    m_inputDir.setValue(outputFile.substr(0, outputFile.find_last_of("/")));
    // FIXME: modify file name, not done for now because of
    // IoUtils.update_io_registry vs. merge conflict.
    //m_simpleFileName.setValue(
    //    outputFile.substr(outputFile.find_last_of("/") + 1));
  }
  ATH_MSG_DEBUG("Deleting DataWriter");
  m_dataWriter.reset();
 
  ATH_CHECK(reinit());
 
  return StatusCode::SUCCESS;
}

putEvent() [1/2]

bool ByteStreamEventStorageOutputSvc::putEvent ( const RawEvent *  re )

overridevirtual

Implementation of the ByteStreamOutputSvc interface method putEvent.

Definition at line 172 of file ByteStreamEventStorageOutputSvc.cxx.

                                                            {
  // Read the next event.
  return putEvent(re, Gaudi::Hive::currentContext());
}

putEvent() [2/2]

bool ByteStreamEventStorageOutputSvc::putEvent ( const RawEvent *  re, const EventContext &  ctx  )

overridevirtual

Definition at line 179 of file ByteStreamEventStorageOutputSvc.cxx.

                                                 {
  // Read the next event.
  using OFFLINE_FRAGMENTS_NAMESPACE::DataType;
  using OFFLINE_FRAGMENTS_NAMESPACE::PointerType;
 
  EventCache* cache = m_eventCache.get(ctx);
  cache->releaseEvent();
 
  // we need the size and the start of the event to give to the data writer
  cache->size = re->fragment_size_word();
  ATH_MSG_DEBUG("event size = " << cache->size << ", start = " << re->start());
 
  if (m_isRun1) {
    // convert to current eformat
    // allocate some extra space just in case
    ATH_MSG_DEBUG("converting Run 1 format ");
 
    cache->size += 128;
    cache->buffer = std::make_unique< DataType[] >(cache->size);
    ATH_MSG_DEBUG("created buffer 0x"
                  << std::hex << cache->buffer.get() << std::dec);
 
    // This builds no-checksum headers, should use the same
    // checksum type as original event
    cache->size = offline_eformat::old::convert_to_40(
        re->start(), cache->buffer.get(), cache->size);
    ATH_MSG_DEBUG("filled buffer");
 
    if (cache->size == 0) {
      // not enough space in buffer
      ATH_MSG_ERROR("Failed to convert event, buffer is too small");
      return false;
    }
 
    ATH_MSG_DEBUG("event size after conversion =  " << cache->size
                  << "  version = " << cache->buffer.get()[3]);
 
  } else {
    cache->buffer = std::make_unique< DataType[] >(cache->size);
    std::copy(re->start(), re->start() + cache->size, cache->buffer.get());
  }
 
  {
    // multiple data writers concurrently sounds like a bad idea
    std::lock_guard< std::mutex > lock(m_dataWriterMutex);
 
    // make sure the data writer is ready
    ATH_MSG_DEBUG("looking up data writer");
    if (!m_dataWriter) {
      if (!initDataWriter(&ctx)) {
        ATH_MSG_ERROR("Failed to initialize DataWriter");
        return false;
      }
    }
 
    // write event to disk
    EventStorage::DWError write_result = m_dataWriter->putData(
        sizeof(DataType) * cache->size,
        reinterpret_cast< void* >(cache->buffer.get()));
 
    // Report success or failure
    if (write_result != EventStorage::DWOK) {
      ATH_MSG_ERROR("Failed to write event to DataWriter");
      return false;
    }
    ++m_totalEventCounter;
  }
 
  return true;
}

queryInterface()

StatusCode ByteStreamEventStorageOutputSvc::queryInterface ( const InterfaceID &  riid, void **  ppvInterface  )

override

Definition at line 459 of file ByteStreamEventStorageOutputSvc.cxx.

                                                  {
 
  if ( !ppvInterface ) return StatusCode::FAILURE;
 
  // find indirect interfaces :
  if (ByteStreamOutputSvc::interfaceID().versionMatch(riid)) {
    *ppvInterface = dynamic_cast<ByteStreamOutputSvc*>(this);
  } else if (base_class::queryInterface(riid, ppvInterface).isSuccess()) {
    return StatusCode::SUCCESS;
  } else {
    // Interface is not directly available: try out a base class
    return ::AthService::queryInterface(riid, ppvInterface);
  }
  addRef();
  return StatusCode::SUCCESS;
}

reinit()

StatusCode ByteStreamEventStorageOutputSvc::reinit ( )

private

reinitialize the service when a fork() occurred/was-issued

Definition at line 86 of file ByteStreamEventStorageOutputSvc.cxx.

                                        {
  ATH_MSG_INFO("Reinitialization...");
  return StatusCode::SUCCESS;
}

stop()

StatusCode ByteStreamEventStorageOutputSvc::stop ( )

override

Definition at line 93 of file ByteStreamEventStorageOutputSvc.cxx.

                                      {
  // Check whether anything has been written and whether the user wants metadata
  // only files
  if (m_dataWriter == 0 and m_writeEventless) {
    const ByteStreamMetadata* metaData = getByteStreamMetadata();
 
    // Try to write metadata to eventless file
    bool dWok = initDataWriterContents(nullptr, metaData);
    if (!dWok) ATH_MSG_WARNING("Could not write Metadata for eventless file");
  }
 
  return StatusCode::SUCCESS;
}

updateDataWriterParameters() [1/3]

void ByteStreamEventStorageOutputSvc::updateDataWriterParameters ( DataWriterParameters &  params ) const

private

Create DataWriter parameters from job properties.

Definition at line 324 of file ByteStreamEventStorageOutputSvc.cxx.

                                        {
 
  if (m_eventStorageVersion == "v5" or m_eventStorageVersion == "run1")
    params.version = 5;
  else params.version = 0;
 
  params.writingPath = m_inputDir;
 
  if (m_run != 0) params.rPar.run_number = m_run;
  ATH_MSG_DEBUG("Run number: " << params.rPar.run_number);
 
  if (m_lumiBlockNumber != 0) params.lumiBlockNumber = m_lumiBlockNumber;
  ATH_MSG_DEBUG("LB number: " << params.lumiBlockNumber);
 
  if (!m_streamType.empty()) params.streamType = m_streamType;
  if (!m_streamName.empty()) params.streamName = m_streamName;
 
  if (params.streamType.empty()) params.streamType = "Single";
  if (params.streamName.empty()) params.streamName = "Stream";
 
  params.stream = params.streamType + "_" + params.streamName;
 
  if (!m_projectTag.empty()) params.project = m_projectTag;
 
  params.applicationName = m_appName;
 
  if (!m_simpleFileName.empty()) {
    // set up for simple file name
    boost::shared_ptr<EventStorage::SimpleFileName> simple_file_name(
        new EventStorage::SimpleFileName(m_simpleFileName));
    params.theFNCB = simple_file_name;
  } else {
    // set up for production file name
    daq::RawFileName fileNameObj(
        params.project,
        params.rPar.run_number,
        params.streamType,
        params.streamName,
        params.lumiBlockNumber,
        params.applicationName);
    params.fileNameCore = fileNameObj.fileNameCore();
  }
 
  params.compression = m_compressEvents
      ? EventStorage::ZLIB
      : EventStorage::NONE;
 
  params.maxFileMB = m_maxFileMB;
  params.maxFileNE = params.rPar.max_events = m_maxFileNE;
}

updateDataWriterParameters() [2/3]

void ByteStreamEventStorageOutputSvc::updateDataWriterParameters ( DataWriterParameters &  params, const ByteStreamMetadata &  metaData  ) const

private

Create DataWriter parameters from MetaData.

Definition at line 424 of file ByteStreamEventStorageOutputSvc.cxx.

                                                                            {
  ATH_MSG_DEBUG("Parsing run parameters from metadata:\n" << metaData); 
 
  params.rPar.run_number = metaData.getRunNumber();
  params.lumiBlockNumber = metaData.getLumiBlock();
 
  const std::string stream = metaData.getStream();
  const std::string::size_type split = stream.find('_');
 
  if (split != std::string::npos and params.streamType.empty())
    params.streamType = stream.substr(0,split);
 
  if (split != std::string::npos and params.streamName.empty())
    params.streamName = stream.substr(split+1);
 
  params.project = metaData.getProject();
  params.maxFileNE = params.rPar.max_events = metaData.getMaxEvents();
 
  params.rPar.rec_enable = metaData.getRecEnable();
  params.rPar.trigger_type = metaData.getTriggerType();
  params.rPar.beam_type = metaData.getBeamType();
  if (metaData.getBeamEnergy() != 0)
    params.rPar.beam_energy = metaData.getBeamEnergy();
 
  params.rPar.detector_mask_LS = metaData.getDetectorMask(); 
  params.rPar.detector_mask_MS = metaData.getDetectorMask2();
 
  for (const std::string& fmd : metaData.getFreeMetaDataStrings())
    params.fmdStrings.push_back(fmd);
  // if(fmd.find("Compression=") == std::string::npos)
}

updateDataWriterParameters() [3/3]

void ByteStreamEventStorageOutputSvc::updateDataWriterParameters ( DataWriterParameters &  params, const xAOD::EventInfo &  evtInfo  ) const

private

Create DataWriter parameters from EventInfo.

Definition at line 378 of file ByteStreamEventStorageOutputSvc.cxx.

                                                                        {
  ATH_MSG_DEBUG("Parsing run parameters from EventInfo" << eventInfo);
  
  params.rPar.run_number = eventInfo.runNumber();
  params.lumiBlockNumber = eventInfo.lumiBlock();
 
  for (const xAOD::EventInfo::StreamTag& tag : eventInfo.streamTags())
    if(!tag.type().empty()) {
      params.streamType = tag.type();
      break;
    }
 
  for (const xAOD::EventInfo::StreamTag& tag : eventInfo.streamTags())
    if (!tag.name().empty()) {
      params.streamName = tag.name();
      break;
    }
 
  for (const auto& tag : eventInfo.detDescrTags())
    params.fmdStrings.push_back(tag.first + ' ' + tag.second);
 
  params.rPar.trigger_type = eventInfo.level1TriggerType();
  params.rPar.detector_mask_LS = eventInfo.detectorMask();
  params.rPar.detector_mask_MS = eventInfo.detectorMaskExt();
 
  std::string event_type = "Event type: sim/data - ";
  if (eventInfo.eventType(xAOD::EventInfo::EventType::IS_SIMULATION))
    event_type += "is sim";
  else event_type += "is data";
 
  event_type += " , testbeam/atlas - ";
  if (eventInfo.eventType(xAOD::EventInfo::EventType::IS_TESTBEAM))
    event_type += "is testbeam";
  else event_type += "is atlas";
 
  event_type += " , calibration/physics - ";
  if (eventInfo.eventType(xAOD::EventInfo::EventType::IS_CALIBRATION))
    event_type += "is calibration";
  else event_type += "is physics";
 
  params.fmdStrings.push_back(event_type);
}

Member Data Documentation

m_appName

Gaudi::Property<std::string> ByteStreamEventStorageOutputSvc::m_appName

private

Initial value:

{this, "AppName", "",
    "part of filename"}

File Tag.

Definition at line 84 of file ByteStreamEventStorageOutputSvc.h.

m_bsOutputStreamName

Gaudi::Property<std::string> ByteStreamEventStorageOutputSvc::m_bsOutputStreamName

private

Initial value:

{this, "BSOutputStreamName",
    name(), "stream name for multiple output"}

Definition at line 111 of file ByteStreamEventStorageOutputSvc.h.

m_byteStreamMetadataKey

SG::ReadHandleKey< ByteStreamMetadataContainer > ByteStreamEventStorageOutputSvc::m_byteStreamMetadataKey

private

Initial value:

{this,
    "ByteStreamMetadataKey", "MetaDataStore+ByteStreamMetadata",
    "Key for bytestream metadata object in metadata store"}

Definition at line 146 of file ByteStreamEventStorageOutputSvc.h.

m_compressEvents

Gaudi::Property<bool> ByteStreamEventStorageOutputSvc::m_compressEvents {this, "CompressEvents", false, ""}

private

number of MB per file

Definition at line 133 of file ByteStreamEventStorageOutputSvc.h.

m_dataWriter

std::unique_ptr<ByteStreamDataWriter> ByteStreamEventStorageOutputSvc::m_dataWriter

private

pointer to DataWriter

Definition at line 159 of file ByteStreamEventStorageOutputSvc.h.

m_dataWriterMutex

std::mutex ByteStreamEventStorageOutputSvc::m_dataWriterMutex

private

mutex to lock data writer during initialization or writing

Definition at line 162 of file ByteStreamEventStorageOutputSvc.h.

m_dump

Gaudi::Property<bool> ByteStreamEventStorageOutputSvc::m_dump {this, "DumpFlag", false, "dump fragments"}

private

Write eventless files.

Definition at line 126 of file ByteStreamEventStorageOutputSvc.h.

m_eformatVersion

Gaudi::Property<std::string> ByteStreamEventStorageOutputSvc::m_eformatVersion

private

Initial value:

{this, "EformatVersion",
    "current", "Version of the event format data, use \"v40\" or \"run1\" "
    "for run1, \"current\" for most current version (default)."}

EventStorage BS version to produce, "v5" for run1, or "current".

Definition at line 100 of file ByteStreamEventStorageOutputSvc.h.

m_eventCache

SG::SlotSpecificObj<EventCache> ByteStreamEventStorageOutputSvc::m_eventCache

private

Cache of event data for each slot.

Definition at line 188 of file ByteStreamEventStorageOutputSvc.h.

m_eventInfoKey

SG::ReadHandleKey< xAOD::EventInfo > ByteStreamEventStorageOutputSvc::m_eventInfoKey

private

Initial value:

{this, "EventInfoKey",
    "EventInfo", "Key for EventInfo object in event store"}

Definition at line 143 of file ByteStreamEventStorageOutputSvc.h.

m_eventStorageVersion

Gaudi::Property<std::string> ByteStreamEventStorageOutputSvc::m_eventStorageVersion

private

Initial value:

{this,
    "EventStorageVersion", "current", "Version of the ByteStream file data, "
        "use \"v5\" or \"run1\" for run1, \"current\" for most current version "
        "(default)."}

stream name for multiple output

Definition at line 105 of file ByteStreamEventStorageOutputSvc.h.

m_fileTag

Gaudi::Property<std::string> ByteStreamEventStorageOutputSvc::m_fileTag

private

Initial value:

{this, "FileTag", "",
    "part of filename"}

stream type

Definition at line 88 of file ByteStreamEventStorageOutputSvc.h.

m_inputDir

Gaudi::Property<std::string> ByteStreamEventStorageOutputSvc::m_inputDir

private

Initial value:

{this, "OutputDirectory", "",
    "directory for the data files"}

< directory for the data files

Project Tag

Definition at line 76 of file ByteStreamEventStorageOutputSvc.h.

m_ioMgr

ServiceHandle< IIoComponentMgr > ByteStreamEventStorageOutputSvc::m_ioMgr {"IoComponentMgr", name()}

private

Definition at line 150 of file ByteStreamEventStorageOutputSvc.h.

m_isRun1

bool ByteStreamEventStorageOutputSvc::m_isRun1 {false}

private

Definition at line 156 of file ByteStreamEventStorageOutputSvc.h.

m_lumiBlockNumber

Gaudi::Property<int> ByteStreamEventStorageOutputSvc::m_lumiBlockNumber

private

Initial value:

{this, "LumiBlockNumber", 0,
    "part of filename"}

run number

Definition at line 119 of file ByteStreamEventStorageOutputSvc.h.

m_maxFileMB

Gaudi::Property<unsigned int> ByteStreamEventStorageOutputSvc::m_maxFileMB

private

Initial value:

{this, "MaxFileMB", 10000,
    "MB per file"}

number of events per file

Definition at line 136 of file ByteStreamEventStorageOutputSvc.h.

m_maxFileNE

Gaudi::Property<unsigned int> ByteStreamEventStorageOutputSvc::m_maxFileNE

private

Initial value:

{this, "MaxFileNE", 100000,
    "evens per file"}

Definition at line 140 of file ByteStreamEventStorageOutputSvc.h.

m_projectTag

Gaudi::Property<std::string> ByteStreamEventStorageOutputSvc::m_projectTag

private

Initial value:

{this, "ProjectTag", "",
    "part of filename"}

Application Name.

Definition at line 80 of file ByteStreamEventStorageOutputSvc.h.

m_run

Gaudi::Property<int> ByteStreamEventStorageOutputSvc::m_run {this, "RunNumber", 0, "part of filename"}

private

Dump fragments.

Definition at line 123 of file ByteStreamEventStorageOutputSvc.h.

m_simpleFileName

Gaudi::Property<std::string> ByteStreamEventStorageOutputSvc::m_simpleFileName

private

Initial value:

{this, "SimpleFileName", "",
    "for filename not from AgreedFileName"}

use this string for filename, not from the "AgreedFileName"

luminosity block number

Definition at line 115 of file ByteStreamEventStorageOutputSvc.h.

m_streamName

Gaudi::Property<std::string> ByteStreamEventStorageOutputSvc::m_streamName

private

Initial value:

{this, "StreamName", "",
    "part of filename"}

eformat event version to produce, "v40" for run1, or "current"

Definition at line 96 of file ByteStreamEventStorageOutputSvc.h.

m_streamType

Gaudi::Property<std::string> ByteStreamEventStorageOutputSvc::m_streamType

private

Initial value:

{this, "StreamType",  "",
    "part of filename"}

stream name

Definition at line 92 of file ByteStreamEventStorageOutputSvc.h.

m_totalEventCounter

int ByteStreamEventStorageOutputSvc::m_totalEventCounter {0}

private

number of event counter

Definition at line 154 of file ByteStreamEventStorageOutputSvc.h.

m_writeEventless

Gaudi::Property<bool> ByteStreamEventStorageOutputSvc::m_writeEventless

private

Initial value:

{this, "WriteEventlessFiles", true,
    ""}

Compress events.

Definition at line 129 of file ByteStreamEventStorageOutputSvc.h.

---

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

• ByteStreamEventStorageOutputSvc.h
• ByteStreamEventStorageOutputSvc.cxx