L1CaloByteStreamAuxCnv.icc

Go to the documentation of this file.

/*
  Copyright (C) 2002-2021 CERN for the benefit of the ATLAS collaboration
*/
 
#include <vector>
#include <stdint.h>
 
#include "ByteStreamCnvSvcBase/ByteStreamAddress.h"
#include "ByteStreamCnvSvcBase/IROBDataProviderSvc.h"
 
#include "ByteStreamData/RawEvent.h"
#include "ByteStreamData/ROBData.h"
 
#include "AthenaKernel/errorcheck.h"
#include "GaudiKernel/DataObject.h"
#include "GaudiKernel/IOpaqueAddress.h"
#include "GaudiKernel/IRegistry.h"
#include "GaudiKernel/ISvcLocator.h"
#include "GaudiKernel/StatusCode.h"
 
#include "AthenaKernel/ClassID_traits.h"
#include "AthenaKernel/StorableConversions.h"
#include "StoreGate/StoreGateSvc.h"
 
 
#include "../ToString.h"
#include "L1CaloByteStreamReadTool.h"
 
namespace LVL1BS {
 
template<typename ContainerT, typename AuxContainerT>
L1CaloByteStreamAuxCnv<ContainerT, AuxContainerT>::L1CaloByteStreamAuxCnv(ISvcLocator* svcloc) :
    Converter(storageType(), classID(), svcloc),
    AthMessaging(svcloc != 0 ? msgSvc() : 0, "L1CaloByteStreamAuxCnv"),
    m_name("L1CaloByteStreamAuxCnv"),
    m_readTool("LVL1BS::L1CaloByteStreamReadTool/L1CaloByteStreamReadTool") {
 
}
 
// CLID
template<typename ContainerT, typename AuxContainerT>
const CLID& L1CaloByteStreamAuxCnv<ContainerT,AuxContainerT>::classID() {
  return ClassID_traits<ContainerT>::ID();
}
 
long L1CaloByteStreamAuxCnv<ContainerT,AuxContainerT>::storageType()
{
  return ByteStreamAddress::storageType();
}
 
//  Init method gets all necessary services etc.
 
 
template<typename ContainerT, typename AuxContainerT>
StatusCode L1CaloByteStreamAuxCnv<ContainerT, AuxContainerT>::initialize() {
  ATH_MSG_DEBUG("Initializing " << m_name);
 
  CHECK(Converter::initialize());
  CHECK(m_readTool.retrieve());
 
  return StatusCode::SUCCESS;
}
 
// createObj should create the RDO from bytestream.
 
template<typename ContainerT, typename AuxContainerT>
StatusCode L1CaloByteStreamAuxCnv<ContainerT, AuxContainerT>::createObj(IOpaqueAddress* pAddr,
    DataObject*& pObj) {
  ATH_MSG_DEBUG("createObj() called");
  // -------------------------------------------------------------------------
  ByteStreamAddress *pBS_Addr = dynamic_cast<ByteStreamAddress *>(pAddr);
  CHECK(pBS_Addr != nullptr);
  // -------------------------------------------------------------------------
  const std::string nm = *(pBS_Addr->par());
  ATH_MSG_DEBUG("Creating Objects " << nm);
 
  AuxContainerT* aux = new AuxContainerT();
  ContainerT* const ttCollection = new ContainerT();
  ttCollection->setStore(aux);
 
  StatusCode sc = m_readTool->convert(ttCollection);
  if (sc.isFailure()) {
      ATH_MSG_ERROR("Failed to create Objects");
      delete ttCollection;
      return sc;
    }
  ATH_MSG_VERBOSE(ToString(*ttCollection));
  ATH_MSG_DEBUG("Number of readed objects: " << ttCollection->size());
 
  
  pObj = SG::asStorable(aux);
  
  return StatusCode::SUCCESS;
}
 
// createRep should create the bytestream from RDOs.
 
template<typename ContainerT, typename AuxContainerT>
StatusCode L1CaloByteStreamAuxCnv<ContainerT, AuxContainerT>::createRep(DataObject* /*pObj*/,
    IOpaqueAddress*& /*pAddr*/) {
  return StatusCode::FAILURE;
}
 
} // end namespace