RawDataZddEventCnv.hpp

Go to the documentation of this file.

#pragma once
 
#include "RawDataCnv/Util/ZddConverter.h"
#include "ZddEvent/ZddEvent.h"
 
#include "RawDataBaseCnv.h"
 
extern const CLID& CLID_ZddEvent;
 
class RawDataZddEventCnv : public RawDataBaseCnv {
private:
  ZddConverter* m_cnv;
 
public:
  RawDataZddEventCnv( ISvcLocator* svc )
      : RawDataBaseCnv( PACKEDRAWEVENT_StorageType, classID(), svc ) {}
  ~RawDataZddEventCnv() { ZddConverter::destroy(); }
 
  static const CLID& classID() { return CLID_ZddEvent; }
 
  StatusCode initialize() override {
    MsgStream log( msgSvc(), "RawDataZddEventCnv" );
    log << MSG::INFO << "RawDataZddEventCnv::initialize" << endmsg;
 
    StatusCode sc = RawDataBaseCnv::initialize();
    if ( sc.isFailure() )
    {
      log << MSG::ERROR << "Failed to initialize Converter" << endmsg;
      return sc;
    }
 
    m_cnv = ZddConverter::instance( m_inputSvc->runMode() );
 
    return StatusCode::SUCCESS;
  }
 
  StatusCode createObj( IOpaqueAddress* /*pAddr*/, DataObject*& pObj ) {
    Event::ZddEvent* zddEvt = new Event::ZddEvent;
    pObj                    = zddEvt;
 
    RAWEVENT* evt = m_inputSvc->currentEvent();
    if ( evt == NULL )
    {
      // log << MSG::ERROR << "RawDataZddEventCnv::createObj has no event!" << endmsg;
      return StatusCode::FAILURE;
    }
 
    const BufferHolder& zddBuf = evt->getZddBuf();
 
    // Data decoding
    uint32_t nbuf = zddBuf.nBuf();
    for ( uint32_t i = 0; i < nbuf; ++i )
    { // loop the buffers
      uint32_t* buf = zddBuf( i );
      m_cnv->convert( buf, zddBuf.bufSize( i ), zddEvt );
    }
 
    return StatusCode::SUCCESS;
  }
};