---

RFileCnv.cpp

Go to the documentation of this file.

#define ROOTHISTCNV_RFILECNV_CPP


// Include files
#include "GaudiKernel/CnvFactory.h"
#include "GaudiKernel/GenericAddress.h"
#include "GaudiKernel/MsgStream.h"
#include "GaudiKernel/NTuple.h"

#include "RFileCnv.h"

#include "TROOT.h"
#include "TFile.h"

//------------------------------------------------------------------------------
//
// Implementation of class :  RootHistCnv::RFileCnv
//
// Author :                   Charles Leggett
//
//------------------------------------------------------------------------------


// Instantiation of a static factory class used by clients to create
// instances of this service
static CnvFactory<RootHistCnv::RFileCnv> s_factory;
const ICnvFactory& RootHistRFileCnvFactory = s_factory;


StatusCode RootHistCnv::RFileCnv::createObj(IOpaqueAddress* pAddress, DataObject*& refpObject)   {
  MsgStream log(msgSvc(), "RFileCnv");
//    log << MSG::DEBUG << "createObj()" << endreq;

  std::string fname = pAddress->dbName();
  std::string ooname = pAddress->objectName();

  // Strip of store name to get the top level RZ directory
  std::string oname = ooname.substr(ooname.find("/",1)+1, ooname.length());

  // Protect against multiple instances of TROOT
  if ( 0 == gROOT )   {
    static TROOT root("root","ROOT I/O");  
    //    gDebug = 99;
  } else {
    log << MSG::INFO << "ROOT already initialized, debug = " << gDebug
        << endreq;
  }
  rfile = new TFile(fname.c_str(),"RECREATE","Athena Trees");
  m_rootfile = rfile;
  if (! rfile->IsOpen() ) {
    log << MSG::ERROR << "Could not open file " << fname << " for writing"
        << endreq;
    return StatusCode::FAILURE;
  }  

//    log << MSG::DEBUG << "fname: " << fname << "  ooname: " << ooname 
//        << "  oname: " << oname << endreq;

  long lun = 1;

  NTuple::File* pFile = new NTuple::File(objType(), fname, oname);
  pAddress->genericLink()->genericInfo()->m_info[0] = lun;
  pFile->setOpen(true);
  refpObject = pFile;
  return StatusCode::SUCCESS;
}


StatusCode RootHistCnv::RFileCnv::createRep( DataObject* pObject, IOpaqueAddress*& refpAddress )   {
  MsgStream log(msgSvc(), "RFileCnv");
//    log << MSG::DEBUG << "createRep()" << endreq;
  refpAddress = pObject->address();
  return RFileCnv::updateRep( refpAddress, pObject );
}


StatusCode RootHistCnv::RFileCnv::updateRep( IOpaqueAddress* /*pAddress*/, DataObject* pObject )   {
  MsgStream log(msgSvc(), "RFileCnv");
//    log << MSG::DEBUG << "updateRep()" << endreq;

  NTuple::File* pFile = dynamic_cast<NTuple::File*>(pObject);
  if ( pFile->isOpen() )    {
    std::string oname = pFile->logicalName();

    log << MSG::INFO << "Closing ROOT file \"" << pFile->name() << "\""
        << endreq;

    rfile->Write();

    if ( log.isActive() ) {
      log << MSG::INFO;
      rfile->Print();
      log << endreq;
    }

    rfile->Close();

    pFile->setOpen(false);
    return StatusCode::SUCCESS;
  }
  return StatusCode::FAILURE;
}

RootHistCnv::RFileCnv::~RFileCnv() {

  if (rfile != 0) {
    delete rfile;
    rfile = 0;
  }

}

---