RawDataOutputSvc.cxx

Go to the documentation of this file.

//===================================================================
//  Implementation of RawDataOutputSvc
//  Revision:  July 11, 2002
//      Modified for RawFileReader
//
//===================================================================
//
 
// Include files.
#include "GaudiKernel/Bootstrap.h"
#include "GaudiKernel/ISvcLocator.h"
#include "GaudiKernel/MsgStream.h"
#include "GaudiKernel/PropertyMgr.h"
 
#include "RawDataOutputSvc.h"
 
DECLARE_COMPONENT( RawDataOutputSvc )
// Constructor.
RawDataOutputSvc::RawDataOutputSvc( const std::string& name, ISvcLocator* svcloc )
    : base_class( name, svcloc ), m_fw( 0 ) {
 
  declareProperty( "OutputFile", m_outputFile = "offline.raw" );
 
  m_buffer = new uint32_t[64 * 1024]; // 256k bytes
}
 
// Destructor.
RawDataOutputSvc::~RawDataOutputSvc() {
  MsgStream log( msgSvc(), name() );
  log << MSG::DEBUG << "RawDataOutputSvc Destructor called " << endmsg;
 
  delete[] m_buffer;
}
 
StatusCode RawDataOutputSvc::finalize() {
  // clean up
  if ( m_fw )
  {
    delete m_fw;
    m_fw = nullptr;
  }
 
  return StatusCode::SUCCESS;
}
 
// Open the first input file and read the first event.
StatusCode RawDataOutputSvc::initialize() {
 
  auto sc = Service::initialize();
  if ( sc.isFailure() )
  {
    error() << "Failed to initialize Service" << endmsg;
    return sc;
  }
  // Open the first output file for writing.
  m_fw = new RawFileWriter( m_outputFile );
 
  debug() << "Opened output File " << m_outputFile << endmsg;
 
  return StatusCode::SUCCESS;
}
 
// Write the next event.
bool RawDataOutputSvc::putEvent( WriteRawEvent* re ) {
  MsgStream log( msgSvc(), name() );
 
  // uint32_t evt_size_w = re->size_word();
 
  const eformat::write::node_t* top = re->bind();
  if ( eformat::write::copy( *top, m_buffer, 64 * 1024 ) == 0 )
  {
    log << MSG::ERROR << "failed to copy Event to the buffer !" << endmsg;
    return false;
  }
 
  try
  {
    RawEvent evt( m_buffer );
    evt.check_tree();
  } catch ( std::exception& ex )
  {
    std::cerr << "Uncaught std exception: " << ex.what() << std::endl;
    std::exit( 1 );
  } catch ( ... )
  {
    std::cerr << std::endl << "Uncaught unknown exception" << std::endl;
    std::exit( 1 );
  }
 
  m_fw->writeEvent( m_buffer );
 
  return true;
}