LeafCnv.cxx

Go to the documentation of this file.

 
/*
  Copyright (C) 2002-2018 CERN for the benefit of the ATLAS collaboration
*/
 
// LeafCnv.cxx 
// Implementation file for class LeafCnv
// Author: S.Binet<binet@cern.ch>
 
// AthenaRootComps includes
#include "LeafCnv.h"
#include "RootBranchAddress.h"
#include "RootDataBucketBranch.h"
 
// STL includes
#include <sstream>
#include <typeinfo>
#include <stdexcept>
 
// framework
#include "GaudiKernel/DataObject.h"
//#include "GaudiKernel/GenericAddress.h"
#include "GaudiKernel/ServiceHandle.h"
#include "GaudiKernel/System.h"
#include "AthenaKernel/IDictLoaderSvc.h"
#include "AthenaKernel/DataBucketBase.h"
 
// ROOT 
#include "TBranch.h"
#include "RootUtils/TBranchElementClang.h"
#include "TLeaf.h"
#include "TTree.h"
 
namespace {
  std::string name_from_clid (const CLID clid)
  {
    std::ostringstream o;
    o << "AthenaRootLeafCnv_" << clid;
    return o.str();
  }
}
 
namespace Athena {
 
// Public methods: 
 
// Constructors
LeafCnv::LeafCnv( const CLID& clid,
                  ISvcLocator* pSvcLocator ) : 
  ::Converter( ROOT_StorageType, clid, pSvcLocator ),
  ::AthMessaging( msgSvc(),    name_from_clid(clid) ),
  m_type()
{
  //
  // Property declaration
  // 
  //declareProperty( "Property", m_nProperty );
 
}
 
LeafCnv::LeafCnv( ISvcLocator* pSvcLocator ) : 
  ::Converter   ( ROOT_StorageType, CLID_NULL, pSvcLocator ),
  ::AthMessaging( msgSvc(),    name_from_clid(CLID_NULL) ),
  m_type()
{
  //
  // Property declaration
  // 
  //declareProperty( "Property", m_nProperty );
 
}
 
// Destructor
LeafCnv::~LeafCnv()
{ 
  ATH_MSG_DEBUG("Calling destructor");
}
 
// Athena Service's Hooks
StatusCode LeafCnv::initialize()
{
  // configure our MsgStream
  msg().setLevel( MSG::INFO );
 
  ATH_MSG_DEBUG("Initializing LeafCnv...");
 
  ATH_MSG_DEBUG("Initializing base class...");
  if ( ::Converter::initialize().isFailure() ) {
    ATH_MSG_ERROR("Could not intialize base class !!");
    return StatusCode::FAILURE;
  } else {
    ATH_MSG_VERBOSE("Base class initialized");
  }
 
  // retrieve the dict-loader-svc
  typedef ServiceHandle<IDictLoaderSvc> IDictLoaderSvc_t;
  IDictLoaderSvc_t dictSvc("AthDictLoaderSvc", 
                           "Athena::LeafCnv");
                           // name_from_clid(objType()));
  if ( !dictSvc.retrieve().isSuccess() ) {
    ATH_MSG_ERROR("could not retrieve [" << dictSvc.typeAndName() << "] !");
    return StatusCode::FAILURE;
  }
 
  RootType ty = dictSvc->load_type(this->objType());
  ATH_MSG_VERBOSE("loaded dictionary for clid ["
                  << this->objType() << "]: name=["
                  << ty.Name() << "]");
  m_type = ty;
 
  ATH_MSG_DEBUG("converter correctly initialized - clid=[" << objType() << "]");
  return StatusCode::SUCCESS;
}
 
// StatusCode LeafCnv::finalize()
// {
//   m_msg << MSG::INFO 
//      << "Finalizing " << name() << "..." 
//      << endmsg;
 
//   return StatusCode::SUCCESS;
// }
 
// Query the interfaces.
//   Input: riid, Requested interface ID
//          ppvInterface, Pointer to requested interface
//   Return: StatusCode indicating SUCCESS or FAILURE.
// N.B. Don't forget to release the interface after use!!!
// StatusCode 
// LeafCnv::queryInterface(const InterfaceID& riid, void** ppvInterface) 
// {
//   if ( IConverter::interfaceID().versionMatch(riid) ) {
//     *ppvInterface = dynamic_cast<IConverter*>(this);
//   } else {
//     // Interface is not directly available : try out a base class
//     return ::Service::queryInterface(riid, ppvInterface);
//   }
//   addRef();
//   return StatusCode::SUCCESS;
// }
 
// Const methods: 
 
long
LeafCnv::repSvcType() const
{
  return ROOT_StorageType;
}
 
// Non-const methods: 
 
StatusCode 
LeafCnv::createObj(IOpaqueAddress* pAddr, DataObject*& pObj)
{
  ATH_MSG_DEBUG("::createObj(" << pAddr << ", " << pObj << ")");
  Athena::RootBranchAddress *rba = dynamic_cast<Athena::RootBranchAddress*>(pAddr);
  if (!rba) {
    ATH_MSG_DEBUG(*pAddr->par() << " is NOT a GenericAddress!");
    return StatusCode::FAILURE;
  }
  ATH_MSG_DEBUG("loading branch: [" << rba->par()[0]
                << "/" << rba->par()[1] << "]...");
  rba->setBranchAddress(m_type);
  ATH_MSG_DEBUG("loading branch: [" << rba->par()[0]
                << "/" << rba->par()[1] << "]... [done]");
  Athena::DataBucketBranch *dbb = new DataBucketBranch(rba->clID(), rba->m_type, rba->m_ptr);
  pObj = dbb;
  return StatusCode::SUCCESS;
}
 
StatusCode 
LeafCnv::createRep(DataObject* pObj, IOpaqueAddress*& pAddr)
{
  ATH_MSG_INFO("::createRep(" << pObj << ", " << pAddr << ")");
  if (0==pObj) {
    ATH_MSG_ERROR("::createRep: received null ptr to dobj");
    return StatusCode::FAILURE;
  }
  msg(MSG::INFO) << " -> clid: [" << pObj->clID() << "]" << endmsg
                 << " -> name: [" << pObj->name() << "]" << endmsg;
 
  /*
  Athena::DataBucketBranch *dbb = 0;
  dbb = dynamic_cast<Athena::DataBucketBranch*>(pObj);
  if (!dbb) {
    ATH_MSG_INFO("dataobject at [" << pObj->name() << "] is not"
                 << " a DataBucketBranch ! [clid=" << pObj->clID() << "]");
    return StatusCode::FAILURE;
  }
  */
 
  // FIXME:
  // Athena::RootBranchAddress* addr = new Athena::RootBranchAddress
  //   (ROOT_StorageType, 
  //    dbb->clID(), 
  //    m_tupleName.value(), 
  //    br_name, 
  //    (unsigned long)(value_ptr),
  //    (unsigned long)(m_nbrEvts-1));
#if 1
  GenericAddress* addr = new GenericAddress(ROOT_StorageType, 
                                            pObj->clID(),
                                            pObj->name());
#else
  Athena::RootBranchAddress* addr = new Athena::RootBranchAddress
    (ROOT_StorageType, id, 
     "foo",//m_tupleName.value(), 
     dbb->name(), 
     (unsigned long)(value_ptr),
     (unsigned long)(m_nbrEvts-1));
#endif
  pAddr = addr;
  return StatusCode::SUCCESS;
}
 
long 
LeafCnv::storageType()
{
  return ROOT_StorageType;
}
 
// Const methods: 
 
// Non-const methods: 
 
// Protected methods: 
 
} //> end namespace Athena