xAODCnvSvc.cxx

Go to the documentation of this file.

 
/*
  Copyright (C) 2002-2024 CERN for the benefit of the ATLAS collaboration
*/
 
// xAODCnvSvc.cxx 
// Implementation file for class Athena::xAODCnvSvc
// Author: Johannes Elmsheuser, Will Buttinger
 
// AthenaRootComps includes
#include "xAODCnvSvc.h"
#include "xAODCnv.h"
#include "RootBranchAddress.h"
 
// STL includes
 
// FrameWork includes
#include "GaudiKernel/GenericAddress.h"
#include "GaudiKernel/IRegistry.h"
#include "Gaudi/Property.h"
#include "StorageSvc/DbType.h"
 
// ROOT includes
#include "TFile.h"
 
namespace Athena {

// Public methods: 
 
// Constructors
xAODCnvSvc::xAODCnvSvc( const std::string& name, 
                            ISvcLocator* pSvcLocator ) : 
  base_class( name, pSvcLocator, pool::ROOT_StorageType.type() )
{
}
 
// Destructor
xAODCnvSvc::~xAODCnvSvc()
{}
 
// Athena Service's Hooks
StatusCode
xAODCnvSvc::initialize()
{
  ATH_MSG_DEBUG ("Initializing " << name() << "...");
 
  return AthCnvSvc::initialize();
}
 
StatusCode
xAODCnvSvc::finalize()
{
  ATH_MSG_DEBUG ("Finalizing " << name() << "...");
 
  return AthCnvSvc::finalize();
}

StatusCode 
xAODCnvSvc::updateServiceState(IOpaqueAddress* pAddress)
{
  ATH_MSG_DEBUG("updateServiceState(" << pAddress << ")...");
  if (pAddress) {
    return dynamic_cast<GenericAddress*>(pAddress) 
      ? StatusCode::SUCCESS
      : StatusCode::FAILURE;
  }
  return StatusCode::FAILURE;
}

StatusCode 
xAODCnvSvc::createObj(IOpaqueAddress* pAddress, DataObject*& refpObject)
{
  ATH_MSG_DEBUG("-->createObj(" << pAddress->par()[0] << "/" << pAddress->par()[1]
                << ", " << refpObject << ")...");
  GenericAddress *addr = dynamic_cast<GenericAddress*>(pAddress);
  if (!addr) {
    ATH_MSG_DEBUG(pAddress->par()[0] << "/" << pAddress->par()[1]
                  << " is NOT a GenericAddress!");
    return StatusCode::FAILURE;
  }
  ATH_MSG_DEBUG("  par:  " << pAddress->par()[0] << "/" << pAddress->par()[1]
                << endmsg <<
                "  ipar: " << *pAddress->ipar());
  return AthCnvSvc::createObj(pAddress, refpObject);
}

StatusCode 
xAODCnvSvc::createRep(DataObject* pObject, IOpaqueAddress*& refpAddress)
{
  ATH_MSG_DEBUG("::createRep(" << refpAddress << ", " << pObject << ")...");
  //std::cerr << "::NCS::createRep(" << this->name() << ", " << pObject << ")...\n";
  if (0==pObject) {
    ATH_MSG_ERROR("::createRep: received null ptr to DataObject");
    return StatusCode::FAILURE;
  }
  return ::AthCnvSvc::createRep(pObject, refpAddress);
}

StatusCode 
xAODCnvSvc::fillRepRefs(IOpaqueAddress* pAddress, DataObject* pObject)
{
  ATH_MSG_DEBUG("::fillRepRefs(" << pAddress << ", " << pObject << ")...");
  if (0==pAddress || 0==pObject) {
    ATH_MSG_ERROR("::fillRepRefs: null ptr received! (paddr=" << pAddress
                  << ", pobj=" << pObject << ")");
    return StatusCode::FAILURE;
  }
  return ::AthCnvSvc::fillRepRefs(pAddress, pObject);
}

StatusCode 
xAODCnvSvc::connectOutput(const std::string& outputConnectionSpec,
                const std::string& openMode)
{
  ATH_MSG_DEBUG("::connectOutput(" 
                << outputConnectionSpec << ", " 
                << openMode << ")");
  // std::cerr << "::connectOutput(" << outputConnectionSpec << ", openmode="
  //       << openMode << ")...\n";
  TFile *f = TFile::Open(outputConnectionSpec.c_str(), "recreate");
  if (f == 0) {
    return StatusCode::FAILURE;
  }
 
  return StatusCode::SUCCESS;
}

StatusCode
xAODCnvSvc::connectOutput(const std::string& outputConnectionSpec)
{
  ATH_MSG_DEBUG("::connectOutput(" 
                << outputConnectionSpec << ")");
  // std::cerr << "::connectOutput(" << outputConnectionSpec << ")...\n";
  TFile *f = TFile::Open(outputConnectionSpec.c_str(), "recreate");
  if (f == 0) {
    return StatusCode::FAILURE;
  }
  return StatusCode::SUCCESS;
}

StatusCode 
xAODCnvSvc::commitOutput(const std::string& outputConnectionSpec,
                        bool doCommit)
{
  ATH_MSG_DEBUG("::commitOutput(" << outputConnectionSpec
               << ", " << doCommit << ")...");
  return StatusCode::SUCCESS;
}

 



StatusCode
xAODCnvSvc::createAddress(long svcType,
                         const CLID& clid,
                         const std::string* par,
                         const unsigned long* ip,
                         IOpaqueAddress*& refpAddress)
{
  ATH_MSG_DEBUG("::createAddress(" << svcType << ", " << clid 
                << ", " << par << ", " << ip << ", " << refpAddress
                << ")...");
  return ::AthCnvSvc::createAddress(svcType, clid, par, ip, refpAddress);
}

StatusCode 
xAODCnvSvc::convertAddress(const IOpaqueAddress* pAddress,
                          std::string& refAddress)
{
  ATH_MSG_DEBUG("::convertAddress(" << pAddress << ", " 
                << refAddress << ")...");
  if (pAddress) {
    refAddress = *pAddress->par();
    return StatusCode::SUCCESS;
  }
  ATH_MSG_ERROR("::convertAddress: null pointer to IOpaqueAddress !");
  return StatusCode::FAILURE;
}

StatusCode 
xAODCnvSvc::createAddress(long svcType,
                            const CLID& clid,
                            const std::string& refAddress,
                            IOpaqueAddress*& refpAddress)
{
  ATH_MSG_VERBOSE("::createAddress(" << svcType << ", " << clid 
               << ", " << refAddress << ", " << refpAddress
               << ")...");
  if (svcType != pool::ROOT_StorageType.type()) {
    ATH_MSG_ERROR("::createAddress: svcType != root-type");
    ATH_MSG_ERROR("    svcType   = [" << svcType << "]");
    ATH_MSG_ERROR("    root-type = [" << pool::ROOT_StorageType.type() << "]");
    return StatusCode::FAILURE;
  }
  refpAddress = new GenericAddress(pool::ROOT_StorageType.type(), clid, refAddress);
  return StatusCode::SUCCESS;
}


// Const methods: 

// Non-const methods: 

// Protected methods: 

IConverter* 
xAODCnvSvc::createConverter(long typ, 
                              const CLID& clid, 
                              const ICnvFactory* fac)
{
  ATH_MSG_VERBOSE("xAODCnvSvc::createConverter(" << typ << ", " << clid
                << ", " << fac << ")...");
  IConverter* cnv = new Athena::xAODCnv(clid, serviceLocator());
  ATH_MSG_VERBOSE("xAODCnvSvc::createConverter 2");
  if (cnv) {
    ATH_MSG_VERBOSE("xAODCnvSvc::createConverter 3");
    return cnv;
  }
  ATH_MSG_VERBOSE("xAODCnvSvc::createConverter 4");
  return AthCnvSvc::createConverter(typ, clid, fac);
}

// Const methods: 

// Non-const methods: 
 
} //> end namespace Athena