CscPrepDataContainerCnv_p2.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2022 CERN for the benefit of the ATLAS collaboration
*/
 
#include "MuonPrepRawData/CscPrepData.h"
#include "MuonPrepRawData/CscPrepDataContainer.h"
#include "MuonEventTPCnv/MuonPrepRawData/CscPrepData_p2.h"
#include "MuonEventTPCnv/MuonPrepRawData/MuonPRD_Container_p2.h"
#include "MuonIdHelpers/CscIdHelper.h"
#include "MuonEventTPCnv/MuonPrepRawData/CscPrepDataCnv_p2.h"
#include "MuonEventTPCnv/MuonPrepRawData/CscPrepDataContainerCnv_p2.h"
#include "TrkEventCnvTools/ITrkEventCnvTool.h"
#include "GaudiKernel/ISvcLocator.h"
#include "GaudiKernel/Bootstrap.h"
 
// Athena
#include "StoreGate/StoreGateSvc.h"
 
 
StatusCode Muon::CscPrepDataContainerCnv_p2::initialize(MsgStream &log) {
   // Do not initialize again:
  m_isInitialized=true;
 
   // Get Storegate, ID helpers, and so on
  ISvcLocator* svcLocator = Gaudi::svcLocator();
   // get StoreGate service
  StatusCode sc = svcLocator->service("StoreGateSvc", m_storeGate);
  if (sc.isFailure()) {
    log << MSG::FATAL << "StoreGate service not found !" << endmsg;
    return StatusCode::FAILURE;
  }
 
   // get DetectorStore service
  StoreGateSvc *detStore;
  sc = svcLocator->service("DetectorStore", detStore);
  if (sc.isFailure()) {
    log << MSG::FATAL << "DetectorStore service not found !" << endmsg;
    return StatusCode::FAILURE;
  } else {
    if (log.level() <= MSG::DEBUG) log << MSG::DEBUG << "Found DetectorStore." << endmsg;
  }
 
   // Get the helper from the detector store
  sc = detStore->retrieve(m_CscId);
  if (sc.isFailure()) {
    log << MSG::FATAL << "Could not get ID helper !" << endmsg;
    return StatusCode::FAILURE;
  } else {
    if (log.level() <= MSG::DEBUG) log << MSG::DEBUG << "Found the  ID helper." << endmsg;
  }
 
  if (m_eventCnvTool.retrieve().isFailure()) {
    log << MSG::FATAL << "Could not get DetectorDescription manager" << endmsg;
    return StatusCode::FAILURE;
  }
 
  if (log.level() <= MSG::DEBUG) log << MSG::DEBUG << "Converter initialized." << endmsg;
  return StatusCode::SUCCESS;
}
const MuonGM::CscReadoutElement* Muon::CscPrepDataContainerCnv_p2::getReadOutElement(const Identifier& id ) const {
    const Trk::ITrkEventCnvTool* cnv_tool = m_eventCnvTool->getCnvTool(id);
    if (!cnv_tool) return nullptr; 
    return dynamic_cast<const MuonGM::CscReadoutElement*>(cnv_tool->getDetectorElement(id));
}
void Muon::CscPrepDataContainerCnv_p2::transToPers(const Muon::CscPrepDataContainer* transCont,  Muon::CscPrepDataContainer_p2* persCont, MsgStream &log) 
{
  if(log.level() <= MSG::DEBUG && !m_isInitialized) {
      if (this->initialize(log) != StatusCode::SUCCESS) {
          log << MSG::FATAL << "Could not initialize CscPrepDataContainerCnv_p2 " << endmsg;
      } 
  }
    // The transient model has a container holding collections and the
    // collections hold channels.
    //
    // The persistent model flattens this so that the persistent
    // container has two vectors:
    //   1) all collections, and
    //   2) all PRDs
    //
    // The persistent collections, then only maintain indexes into the
    // container's vector of all channels. 
    //
    // So here we loop over all collection and add their channels
    // to the container's vector, saving the indexes in the
    // collection. 
 
  typedef Muon::CscPrepDataContainer TRANS;
 
  CscPrepDataCnv_p2  chanCnv;
  TRANS::const_iterator it_Coll     = transCont->begin();
  TRANS::const_iterator it_CollEnd  = transCont->end();
  unsigned int pcollIndex = 0; // index to the persistent collection we're filling
  unsigned int pcollBegin = 0; // index to start of persistent collection we're filling, in long list of persistent PRDs
  unsigned int pcollEnd = 0; // index to end 
  int numColl = transCont->numberOfCollections();
  persCont->m_collections.resize(numColl);
 
  if (log.level() <= MSG::DEBUG) 
    log << MSG::DEBUG<< " Preparing " << persCont->m_collections.size() << "Collections" <<endmsg;
  for (pcollIndex = 0; it_Coll != it_CollEnd; ++pcollIndex, ++it_Coll)  {
        // Add in new collection
    if (log.level() <= MSG::DEBUG) 
      log << MSG::DEBUG<<"New collection"<<endmsg;
    const Muon::CscPrepDataCollection& collection = (**it_Coll);
    Muon::MuonPRD_Collection_p2& pcollection = persCont->m_collections[pcollIndex]; //get ref to collection we're going to fill
 
    pcollBegin  = pcollEnd; // Next collection starts at end of previous one.
    pcollEnd   += collection.size();
 
    pcollection.m_hashId = collection.identifyHash(); 
    pcollection.m_id = collection.identify().get_identifier32().get_compact();
    pcollection.m_size = collection.size();
 
        // Add in channels
    persCont->m_prds.resize(pcollEnd); // FIXME! isn't this potentially a bit slow? Do a resize and a copy for each loop? EJWM.
    persCont->m_prdDeltaId.resize(pcollEnd);
 
    unsigned int lastPRDIdHash = 0;
    for (unsigned int i = 0; i < collection.size(); ++i) {
      unsigned int pchanIndex=i+pcollBegin;
      const CscPrepData* chan = collection[i]; // channel being converted
      CscPrepData_p2*   pchan = &(persCont->m_prds[pchanIndex]); // persistent version to fill
      chanCnv.transToPers(chan, pchan, log); // convert from CscPrepData to CscPrepData_p2
      unsigned int clusIdCompact = chan->identify().get_identifier32().get_compact();
      unsigned int collIdCompact = collection.identify().get_identifier32().get_compact();
      int diff = clusIdCompact - collIdCompact;
      persCont->m_prdDeltaId[pchanIndex]=clusIdCompact - collIdCompact; //store delta identifiers, rather than full identifiers
      // sanity checks - to be removed at some point
      if(log.level() <= MSG::DEBUG){
        log << MSG::DEBUG<<i<<":\t clusId: "<<clusIdCompact<<", \t collectionId="<<collIdCompact<<"\t delta="<<persCont->m_prdDeltaId[pchanIndex]<<"\t diff="<<diff<<endmsg;
        Identifier temp(pcollection.m_id + persCont->m_prdDeltaId[pchanIndex]);
        if (temp!=chan->identify() ) 
          log << MSG::WARNING << "PRD ids differ! Transient:"<<chan->identify()<<", From persistent:"<<temp<<" diff = "<<chan->identify().get_compact()-temp.get_compact()<<endmsg;
        else 
          log << MSG::DEBUG <<" PRD ids match."<<endmsg;
        if (lastPRDIdHash && lastPRDIdHash != chan->collectionHash() )  log << MSG::WARNING << "Collection Identifier hashes differ!"<<endmsg;
        lastPRDIdHash = chan->collectionHash();
        log << MSG::DEBUG<<"Collection hash = "<<lastPRDIdHash<<endmsg;
        if (chan->collectionHash()!= collection.identifyHash() ) log << MSG::WARNING << "Collection's idHash does not match PRD collection hash!"<<endmsg;
        if (chan->detectorElement() != getReadOutElement(chan->identify())) 
          log << MSG::WARNING << "Getting de from identity didn't work!"<<endmsg;
        else 
          log << MSG::DEBUG<<"Getting de from identity did work "<<endmsg;
        if (chan->detectorElement() != getReadOutElement(temp)) log << MSG::WARNING << "Getting de from reconstructed identity didn't work!"<<endmsg;
        log << MSG::DEBUG<<"Finished loop"<<endmsg;
      }
    }
  }
  if (log.level() <= MSG::DEBUG) 
    log << MSG::DEBUG<< " ***  Writing CscPrepDataContainer ***" <<endmsg;
}
 
void  Muon::CscPrepDataContainerCnv_p2::persToTrans(const Muon::CscPrepDataContainer_p2* persCont, Muon::CscPrepDataContainer* transCont, MsgStream &log) 
{
 
    // The transient model has a container holding collections and the
    // collections hold channels.
    //
    // The persistent model flattens this so that the persistent
    // container has two vectors:
    //   1) all collections, and
    //   2) all channels
    //
    // The persistent collections, then only maintain indexes into the
    // container's vector of all channels. 
    //
    // So here we loop over all collection and extract their channels
    // from the vector.
 
  Muon::CscPrepDataCollection* coll = nullptr;
 
  CscPrepDataCnv_p2  chanCnv;
  unsigned int pchanIndex(0); // position within persCont->m_prds. Incremented inside innermost loop 
  unsigned int pCollEnd = persCont->m_collections.size();
  if (log.level() <= MSG::DEBUG) 
    log << MSG::DEBUG<< " Reading " << pCollEnd << "Collections" <<endmsg;
  for (unsigned int pcollIndex = 0; pcollIndex < pCollEnd; ++pcollIndex) {
    const Muon::MuonPRD_Collection_p2& pcoll = persCont->m_collections[pcollIndex];        
    IdentifierHash collIDHash(pcoll.m_hashId);
    coll = new Muon::CscPrepDataCollection(collIDHash);
        // Identifier firstChanId = persCont->m_prds[collBegin].m_clusId;
        // Identifier collId = m_CscId->parentID(firstChanId);
    coll->setIdentifier(Identifier(pcoll.m_id)); 
 
        // FIXME - really would like to remove Identifier from collection, but cannot as there is :
        // a) no way (apparently - find it hard to believe) to go from collection IdHash to collection Identifer.
 
    unsigned int pchanEnd = pchanIndex+pcoll.m_size;
    unsigned int chanIndex = 0; // transient index
 
    coll->reserve(pcoll.m_size);
        // Fill with channels
    for (; pchanIndex < pchanEnd; ++ pchanIndex, ++chanIndex) {
      const CscPrepData_p2* pchan = &(persCont->m_prds[pchanIndex]);
 
      Identifier clusId (pcoll.m_id + persCont->m_prdDeltaId[pchanIndex]);
      if ( !m_CscId->valid(clusId) ) {
                // have invalid PRD
        log << MSG::WARNING  << "Csc PRD has invalid Identifier of "<< m_CscId->show_to_string(clusId)
          <<" and will be skipped!" << endmsg;
        continue;
      }
 
        // The reason I need to do the following is that one collection can have several detector elements in, the collection hashes!=detector element hashes
      IdentifierHash deIDHash;
      int result = m_CscId->get_detectorElement_hash(clusId, deIDHash);
 
      if (result&&log.level() <= MSG::WARNING) 
        log << MSG::WARNING<< " Muon::CscPrepDataContainerCnv_p2::persToTrans: problem converting Identifier to DE hash "<<endmsg;
 
      const MuonGM::CscReadoutElement* detEl = getReadOutElement(clusId);
      if (!detEl) {
        if (log.level() <= MSG::WARNING) 
          log << MSG::WARNING<< "Muon::CscPrepDataContainerCnv_p2::persToTrans: could not get valid det element for PRD with id="<<clusId<<". Skipping."<<endmsg;
        continue;
      }
 
      auto chan = std::make_unique<CscPrepData>
        (chanCnv.createCscPrepData (pchan,
                                    clusId,
                                    detEl,
                                    log));
 
         
      chan->setHashAndIndex(collIDHash, chanIndex); 
      coll->push_back(std::move(chan));
    }
 
      // register the rdo collection in IDC with hash - faster addCollection
    StatusCode sc = transCont->addCollection(coll, collIDHash);
    if (sc.isFailure()) {
      throw std::runtime_error("Failed to add collection to Identifiable Container");
    }
    if (log.level() <= MSG::DEBUG) {
      log << MSG::DEBUG << "AthenaPoolTPCnvIDCont::persToTrans, collection, hash_id/coll id = " << (int) collIDHash << " / " << 
        coll->identify().get_compact() << ", added to Identifiable container." << endmsg;
    }
  }
 
    if (log.level() <= MSG::DEBUG) 
      log << MSG::DEBUG<< " ***  Reading CscPrepDataContainer ***" << endmsg;
}
 
Muon::CscPrepDataContainer* Muon::CscPrepDataContainerCnv_p2::createTransient(const Muon::CscPrepDataContainer_p2* persObj, MsgStream& log) 
{
  if(!m_isInitialized) {
    if (this->initialize(log) != StatusCode::SUCCESS) {
      log << MSG::FATAL << "Could not initialize CscPrepDataContainerCnv_p2 " << endmsg;
      return nullptr;
    } 
  }
  std::unique_ptr<Muon::CscPrepDataContainer> trans(new Muon::CscPrepDataContainer(m_CscId->module_hash_max()));
  persToTrans(persObj, trans.get(), log);
  return(trans.release());
}