#include <RootInterface.h>

Public Member Functions
	RootInterface (MsgStream log)

virtual	~RootInterface ()

virtual StatusCode	finalize ()

virtual bool	checkEndOfTree ()
	check if all the files is over 2005-11-28

virtual bool	getENDFILE ()

virtual StatusCode	addInput (const std::string &treename, const std::string &file)
	add input tree to the list

virtual StatusCode	addOutput (const std::string &treename, const std::string &file, int splitx, int bufsize, int compression)
	add output tree to the list

virtual StatusCode	createBranch (const std::string &tree, const std::string &branch, const char classname, void addr, int &branchnr)
	create a branch in this tree

virtual StatusCode	setBranchAddress (const std::string treename, const std::string branchname, void *addr, int &nb)
	set branch address

virtual StatusCode	getBranchEntry (int nr, int entry, int &nb)
	get entry from this branch

virtual StatusCode	getBranchEntry (int nr, int entry, void *addr, int &nb)
	get entry from this branch with addr

virtual bool	getEOF ()
	get EOF flag

virtual Int_t	getEntries ()
	get nr of entries

virtual StatusCode	fillTrees ()
	fill in all trees

virtual std::string	getCurrentFileName ()

virtual std::vector< int >	getTotEvtNo ()

virtual std::string	getJobOptions ()

virtual std::string	getDecayOptions ()

virtual void	printJobInfo (TFile *file, int level)

virtual void	setSelectFromTag (bool temp)

virtual bool	getSelectFromTag ()

virtual int	getCurrentFileNum ()

virtual int	getTotalFileNum ()

virtual void	setTagInputFile (std::vector< std::string > input)

virtual std::vector< std::string >	getTagInputFile ()

virtual StatusCode	f_addOutput (const std::string &treename, const std::string &file, int splitx=1, int bufsize=64000, int compression=1)

virtual StatusCode	f_createTree (unsigned int treenr, const std::string treename)

virtual StatusCode	f_createBranch (const std::string &treename, const std::string &branchname, const char classname, void addr, int &branchnr)

virtual StatusCode	f_getTreeNr (const std::string treename, unsigned int &treenr, bool doAdd=false)

virtual StatusCode	f_fillTrees ()

virtual StatusCode	f_finalize ()

Static Public Member Functions
static RootInterface *	Instance (MsgStream log)
	singleton behaviour

Detailed Description

Definition at line 19 of file RootInterface.h.

Constructor & Destructor Documentation

◆ RootInterface()

RootInterface::RootInterface ( MsgStream log )

Definition at line 31 of file RootInterface.cxx.

                                          : log(str)
{ 
  
  m_branches= new TClonesArray("TBranch",1); 
  m_branchesRead= new TClonesArray("TBranch",1);
  m_entries=-1;
  m_EOF=false;
  m_ENDFILE = false ;
  m_fileNum = 0; //-1
 }

◆ ~RootInterface()

RootInterface::~RootInterface ( )

virtual

Definition at line 43 of file RootInterface.cxx.

44{

45}

Member Function Documentation

◆ addInput()

StatusCode RootInterface::addInput	(	const std::string &	treename,
		const std::string &	file
	)

virtual

add input tree to the list

Definition at line 163 of file RootInterface.cxx.

                                                                                  {
  log << MSG::DEBUG << "addInput  for Tree "<<treename<<endreq;
  StatusCode sc=StatusCode::SUCCESS;
  m_fileNames.push_back(file); //input files 2005-11-28
  m_otherTrees.push_back(NULL);
  inputFiles.push_back(NULL);
  unsigned int treenr;
  sc=getTreeNr(treename,treenr,true);
  m_inputFilenames[treenr]=file; // the last one file is setted 
  m_inputFiles[treenr]=NULL;
  m_inputTrees[treenr]=NULL;
  m_currentFileName = m_fileNames[treenr].c_str();
  return sc;
}

Referenced by RootEvtSelector::initialize().

◆ addOutput()

StatusCode RootInterface::addOutput	(	const std::string &	treename,
		const std::string &	file,
		int	splitx,
		int	bufsize,
		int	compression
	)

virtual

add output tree to the list

Definition at line 189 of file RootInterface.cxx.

                                                                                                                           {
  static int i =0;
  i ++;
  log << MSG::DEBUG << "addOutput  for Tree "<<treename<<endreq;
  StatusCode sc=StatusCode::SUCCESS;
  unsigned int treenr;
  sc=getTreeNr(treename,treenr,true);
  m_outputFilenames[treenr]=file;
  m_outputFiles[treenr]=NULL;
  m_outputTrees[treenr]=NULL;
  m_splitModes[treenr]=split;
  m_bufSizes[treenr]=bufsize;
  m_compressionLevels[treenr]=compression;
 
  return sc;
}

◆ checkEndOfTree()

bool RootInterface::checkEndOfTree ( )

virtual

check if all the files is over 2005-11-28

Definition at line 436 of file RootInterface.cxx.

                                  {
 
  if ( m_fileNum >= int(m_fileNames.size())-1 ){
    if(m_inputFiles[0]){ 
      delete m_inputFiles[0];   
      m_inputFiles[0] = NULL;   
    }   
    return true;
  }
  
  (*m_branchesRead).Clear();
  unsigned int treenr;
  getTreeNr("Event",treenr);
  if(m_inputFiles[treenr]){ 
    delete m_inputFiles[treenr];
    m_inputFiles[treenr] = NULL;
  }
  if(m_inputTrees[treenr]){
    //delete m_inputTrees[treenr];
    m_inputTrees[treenr] = NULL;
  }
  if(m_otherTrees[m_fileNum]) delete m_otherTrees[m_fileNum];
  if(inputFiles[m_fileNum])   delete inputFiles[m_fileNum];
 
  m_ENDFILE = true;
  m_fileNum++;
  m_currentFileName = m_fileNames[m_fileNum].c_str();
 
  m_entries=-1;
  m_EOF = false;
  return false;
}

Referenced by RootEvtSelector::getEntryFromTag(), and RootEvtSelector::next().

◆ createBranch()

StatusCode RootInterface::createBranch	(	const std::string &	tree,
		const std::string &	branch,
		const char *	classname,
		void *	addr,
		int &	branchnr
	)

virtual

create a branch in this tree

Definition at line 206 of file RootInterface.cxx.

                                                                                                                                            {
 
  log << MSG::DEBUG << "CreateBranch, Tree "<<treename<<" branch "<<branchname<<endreq;
 
  TBranch *branch;
  unsigned int treenr;
  StatusCode sc=getTreeNr(treename,treenr);
  if (!sc.isSuccess()) return sc;
 
  if ( m_outputFilenames[treenr].empty() ) {
     log << MSG::DEBUG << "No corresponding output file specified, ignore createBranch: "<<branchname<<endreq;
     return StatusCode::SUCCESS;
  }
 
  if(!m_outputTrees[treenr])  sc=this->createTree(treenr,treename);
  if (!sc.isSuccess()) return sc;
  TTree *  tree=m_outputTrees[treenr];
  tree->SetUniqueID(treenr);
 
  branch = tree->Branch(branchname.c_str(),classname,addr,m_bufSizes[treenr],m_splitModes[treenr]);
  branch->SetUniqueID(treenr);
  branchnr=m_branches->GetEntriesFast()+1;
  m_branches->Expand(branchnr);
  TClonesArray &a = *m_branches;
  a[branchnr-1]=branch;
  tree->SetBasketSize(branchname.c_str(),m_bufSizes[treenr]); //some problem with above method to set buffersize, so we set it here.
  return StatusCode::SUCCESS;
}

Referenced by DigiCnv::DataObjectToTObject(), DstCnv::DataObjectToTObject(), EvtHeaderCnv::DataObjectToTObject(), EvtNavigatorCnv::DataObjectToTObject(), EvtRecCnv::DataObjectToTObject(), HltCnv::DataObjectToTObject(), McCnv::DataObjectToTObject(), RecTrackCnv::DataObjectToTObject(), and TrigCnv::DataObjectToTObject().

◆ f_addOutput()

StatusCode RootInterface::f_addOutput	(	const std::string &	treename,
		const std::string &	file,
		int	splitx = `1`,
		int	bufsize = `64000`,
		int	compression = `1`
	)

virtual

Definition at line 636 of file RootInterface.cxx.

                                                                               {
    log << MSG::INFO << "addOutput to single event" << endreq;
    StatusCode status = StatusCode::FAILURE;
    unsigned int treenr;
 
    status = f_getTreeNr(treename, treenr, true);
    m_single_compressionLevels[treenr]  =   compression;
    m_single_outputFileNames[treenr]    =   file;
    m_single_outputFiles[treenr]    =   NULL;
    m_single_outputTrees[treenr]    =   NULL;
    m_single_splitModes[treenr] =   splitx;
    m_single_bufSizes[treenr]   =   bufsize;
 
    std::cout << "finish f_addOutput to single event" << std::endl;
    return status;
}

◆ f_createBranch()

StatusCode RootInterface::f_createBranch	(	const std::string &	treename,
		const std::string &	branchname,
		const char *	classname,
		void *	addr,
		int &	branchnr
	)

virtual

Definition at line 683 of file RootInterface.cxx.

                                   {
    log << MSG::INFO << "f_craeteBranch() create branch, tree name:"
    << treename << ", branch name:" << branchname << endreq;
 
    TBranch *branch;
    unsigned int treenr;
    StatusCode status = f_getTreeNr(treename, treenr);
    if ( !status.isSuccess()) return status;
 
    if ( !m_single_outputTrees[treenr])
        status = this->f_createTree(treenr, treename);
    if ( !status.isSuccess()) return status;
 
    TTree*  tree = m_single_outputTrees[treenr];
    tree->SetUniqueID(treenr);
 
    branch = tree->Branch(branchname.c_str(),
                          classname,
                          addr,
                          m_single_bufSizes[treenr],
                          m_single_splitModes[treenr]);
 
}

◆ f_createTree()

StatusCode RootInterface::f_createTree	(	unsigned int	treenr,
		const std::string	treename
	)

virtual

Definition at line 655 of file RootInterface.cxx.

                                                                {
    log << MSG::INFO << "f_createTree()" << endreq;
 
    TDirectory *saveDir = gDirectory;
 
    m_single_outputFiles[treenr] =
        TFile::Open(m_single_outputFileNames[treenr].c_str(), "RECREATE");
    if ( !m_single_outputFiles[treenr]->IsOpen()){
        log << MSG::ERROR << "ROOT share file: "
        << m_single_outputFileNames[treenr]
        << " could not be opened for writing"
        << endreq;
        return StatusCode::FAILURE;
    }
    log << MSG::INFO << "f_createTree()::open share file for writing: "
    << m_single_outputFileNames[treenr] << endreq;
 
    m_single_outputFiles[treenr]->cd();
    m_single_outputFiles[treenr]->SetCompressionLevel(m_single_compressionLevels[treenr]);
 
    std::string title = treename + " for share";
    m_single_outputTrees[treenr] = new TTree(treename.c_str(), title.c_str());
    saveDir->cd();
 
    return StatusCode::SUCCESS;
}

Referenced by f_createBranch().

◆ f_fillTrees()

StatusCode RootInterface::f_fillTrees ( )

virtual

Definition at line 740 of file RootInterface.cxx.

                                     {
    StatusCode status = StatusCode::FAILURE;
    int byte;
 
    std::vector<TTree *>::const_iterator tree;
    for ( tree = m_single_outputTrees.begin(); tree < m_single_outputTrees.end(); tree++){
        if ( (*tree) == NULL) continue;
        byte = (*tree)->Fill();
    (*tree)->Print();
        log << MSG::INFO << "f_fillTrees() filled tree " << (*tree)->GetName()
        << " with " << byte << " bytes!" << endreq;
        status = StatusCode::SUCCESS;
    }
 
    return status;
}

◆ f_finalize()

StatusCode RootInterface::f_finalize ( )

virtual

Definition at line 757 of file RootInterface.cxx.

                                    {
    log << MSG::INFO << "f_finalize() in RootInterface" << endreq;
 
    std::vector<TTree *>::const_iterator    tree;
    for ( tree = m_single_outputTrees.begin(); tree < m_single_outputTrees.end(); tree++){
        if ( *tree){
            unsigned int treenr = (*tree)->GetUniqueID();
            log << MSG::INFO << "tree id: " << treenr << endreq;
            if ( m_single_outputFiles[treenr] ){
                if ( !m_single_outputFiles[treenr]->IsOpen()){
                    log << MSG::ERROR << "f_finalize could not open share file for writing"
                    << endreq;
                    return StatusCode::FAILURE;
                }
                else {
                    log << MSG::INFO << "Closing file:" << treenr
                    << ", tree:" << (*tree)->GetName() << endreq;
 
                    TDirectory *saveDir = gDirectory;
                    m_single_outputFiles[treenr]->cd();
                    log <<MSG::INFO << "WREITE TO FILE BYTES: " 
                << m_single_outputFiles[treenr]->Write()
                << endreq;
                    m_single_outputFiles[treenr]->Close();
                    saveDir->cd();
                }
            }
        }
    }
    return StatusCode::SUCCESS;
}

◆ f_getTreeNr()

StatusCode RootInterface::f_getTreeNr	(	const std::string	treename,
		unsigned int &	treenr,
		bool	doAdd = `false`
	)

virtual

Definition at line 710 of file RootInterface.cxx.

                                                                      {
 
    std::vector<std::string>::iterator where =
        std::find(m_single_treenames.begin(), m_single_treenames.end(), treename);
 
    if ( where == m_single_treenames.end()){
        if ( doAdd){
            treenr = m_single_treenames.size();
            m_single_treenames.push_back(treename);
 
            m_single_outputFileNames.push_back("");
            m_single_outputFiles.push_back(NULL);
            m_single_outputTrees.push_back(NULL);
            m_single_splitModes.push_back(0);
            m_single_bufSizes.push_back(0);
            m_single_compressionLevels.push_back(0);
 
            return StatusCode::SUCCESS;
        }
        else {
            log << MSG::ERROR << "Invalid share tree name: "
            << treename << endreq;
            return StatusCode::FAILURE;
        }
    }
    treenr = where - m_single_treenames.begin();
    return StatusCode::SUCCESS;
}

Referenced by f_addOutput(), and f_createBranch().

◆ fillTrees()

StatusCode RootInterface::fillTrees ( )

virtual

fill in all trees

Definition at line 608 of file RootInterface.cxx.

                                    {
  // loop over all trees and fill them
  StatusCode sc=StatusCode::FAILURE;
  int nb;
  std::vector<TTree *>::const_iterator trees;
  for (trees=m_outputTrees.begin();trees<m_outputTrees.end();trees++) {
      if ((*trees)==NULL) continue;
      int treenr=(*trees)->GetUniqueID();
     if(m_outputFiles[treenr]->IsZombie()||(!m_outputFiles[treenr]->IsOpen())){
        std::cout<<"RootInterface ERROR::The ROOT File:"<<m_outputFilenames[treenr].c_str()<<"status is false"<<std::endl;
        exit(1);
     }
      nb=(*trees)->Fill();
      m_outputFiles[treenr] = (*trees)->GetCurrentFile();
      log << MSG::DEBUG << "filled tree "<<(* trees)->GetName() <<" with "<<nb<<" bytes"<< endreq;
      if(nb==-1){
         log << MSG::FATAL << "Error in filling tree "<<(* trees)->GetName() <<" with "<<nb<<" bytes"<< endreq; 
    exit(1);
        }
      sc=StatusCode::SUCCESS;
  }
  return sc;
}

Referenced by RootCnvSvc::commitOutput().

◆ finalize()

StatusCode RootInterface::finalize ( )

virtual

Definition at line 107 of file RootInterface.cxx.

                                   {
 
  //  Get the messaging service, print where you are
  log << MSG::INFO << "finalize() in RootInterface" << endreq;
 
  // close file (FIXME for several output files)
  std::vector<TTree *>::const_iterator trees;
  for (trees=m_outputTrees.begin();trees<m_outputTrees.end();trees++)
   if (*trees) {
    int treenr=(*trees)->GetUniqueID();
    if (m_outputFiles[treenr]) {
      if (!m_outputFiles[treenr]->IsOpen()) {
    log << MSG::ERROR << "Could not open file for writing" << endreq;
    return StatusCode::FAILURE;
      } else {
        log << MSG::DEBUG<<" Closing file "<<treenr<<", tree "<<(*trees)->GetName()<<endreq;
        TDirectory *saveDir = gDirectory;
    m_outputFiles[treenr]->cd();
 
  TJobInfo* jobInfo = new TJobInfo;
  TTree* m_jobInfoTree = new TTree("JobInfoTree","Job info");
  m_jobInfoTree->Branch("JobInfo",&jobInfo);
  
  m_bossVer = getenv("BES_RELEASE");
  log << MSG::INFO << "fill boss version: "<<m_bossVer << endreq;
 
  string tmpJobOptions = getJobOptions();
  m_jobOptions.push_back( tmpJobOptions );
 
  if(m_decayOptions.size()==0)
    m_decayOptions = getDecayOptions();
 
  m_totEvtNo = getTotEvtNo(); 
  jobInfo->setBossVer(m_bossVer);
  jobInfo->setJobOptions(m_jobOptions);
  jobInfo->setDecayOptions(m_decayOptions); 
  jobInfo->setTotEvtNo(m_totEvtNo); 
  m_jobInfoTree->Fill();
 
    //?    m_mcFile->Write(0, TObject::kOverwrite);
    int st =1;
    st = m_outputFiles[treenr]->Write();
    if(st==0){
       log << MSG::FATAL<<" can not write the file "<< m_outputFilenames[treenr].c_str()<<endreq;
       exit(1);
    }
 
    m_outputFiles[treenr]->Close();
    saveDir->cd();
      }
    }
   }
  if(m_outputTrees.size()>0) m_outputTrees.clear();
  return StatusCode::SUCCESS;
}

Referenced by RootCnvSvc::finalize().

◆ getBranchEntry() [1/2]

StatusCode RootInterface::getBranchEntry	(	int	nr,
		int	entry,
		int &	nb
	)

virtual

get entry from this branch

Definition at line 561 of file RootInterface.cxx.

{
  log << MSG::DEBUG <<"RootInterface::getBranchEntry: "<<", branch nr "<<nr  <<", entry "<<entry <<endreq;
 
  if (nr <0) return StatusCode::FAILURE;
  TBranch *branch=(TBranch *)m_branchesRead->At(nr);
  if (!branch) {
    log << MSG::ERROR << "Could not find branch " << nr <<endreq;
    return StatusCode::FAILURE;
  }
  nb=branch->GetEntry(entry);
  
  if (nb<=0){
    m_EOF=true;
    
  }
  
  return StatusCode::SUCCESS;
}

Referenced by RootEventBaseCnv::createObj().

◆ getBranchEntry() [2/2]

StatusCode RootInterface::getBranchEntry	(	int	nr,
		int	entry,
		void *	addr,
		int &	nb
	)

virtual

get entry from this branch with addr

Definition at line 539 of file RootInterface.cxx.

{
  log << MSG::DEBUG <<"RootInterface::getBranchEntry: "<<", branch nr "<<nr  <<", entry "<<entry <<endreq;
 
  if (nr <0) return StatusCode::FAILURE;
  TBranch *branch=(TBranch *)m_branchesRead->At(nr);
  if (!branch) {
    log << MSG::ERROR << "Could not find branch " << nr <<endreq;
    return StatusCode::FAILURE;
  }
 
  branch->SetAddress(addr);
  nb=branch->GetEntry(entry);
 
  if (nb<=0){
    m_EOF=true;
 
  }
  return StatusCode::SUCCESS;
}

◆ getCurrentFileName()

virtual std::string RootInterface::getCurrentFileName ( )

inlinevirtual

Definition at line 55 of file RootInterface.h.

55{ return m_currentFileName;}

Referenced by RootEventBaseCnv::createObj(), TagWriterAlg::execute(), MixerAlg::execute(), RootEvtSelector::getEntryFromTag(), and RootEvtSelector::initialize().

◆ getCurrentFileNum()

virtual int RootInterface::getCurrentFileNum ( )

inlinevirtual

Definition at line 65 of file RootInterface.h.

65{return m_fileNum;}

Referenced by RootEvtSelector::getEntryFromTag().

◆ getDecayOptions()

std::string RootInterface::getDecayOptions ( )

virtual

Definition at line 70 of file RootInterface.cxx.

{ 
  ISvcLocator* svcLocator = Gaudi::svcLocator();
  IDataInfoSvc *tmpInfoSvc;
  DataInfoSvc* jobInfoSvc;
  string decayOptions;
  StatusCode status = svcLocator->service("DataInfoSvc",tmpInfoSvc);
  if (status.isSuccess()) {
    log << MSG::INFO << "get the DataInfoSvc" << endreq;
    jobInfoSvc=dynamic_cast<DataInfoSvc *>(tmpInfoSvc);
    decayOptions = jobInfoSvc->getDecayOptions();
    log << MSG::INFO << "get decay options" << endreq
        << decayOptions << endreq;
  }else {
    log << MSG::WARNING << "could not get the DataInfoSvc. Ignore it." << endreq;
  }
  return decayOptions;
}

Referenced by finalize().

◆ getENDFILE()

virtual bool RootInterface::getENDFILE ( )

inlinevirtual

Definition at line 31 of file RootInterface.h.

31{ return m_ENDFILE;}

Referenced by RootEventBaseCnv::createObj().

◆ getEntries()

virtual Int_t RootInterface::getEntries ( )

inlinevirtual

get nr of entries

Definition at line 51 of file RootInterface.h.

51{ return m_entries;}

Referenced by RootEventBaseCnv::createObj(), and RootEvtSelector::next().

◆ getEOF()

virtual bool RootInterface::getEOF ( )

inlinevirtual

get EOF flag

Definition at line 49 of file RootInterface.h.

49{ return m_EOF;}

Referenced by RootEvtSelector::next().

◆ getJobOptions()

std::string RootInterface::getJobOptions ( )

virtual

Definition at line 47 of file RootInterface.cxx.

{
  IInterface* iface = Gaudi::createApplicationMgr();
  SmartIF<IProperty> propMgr (iface );
  std::string path;
  propMgr->getProperty( "JobOptionsPath", path);
  log << MSG::INFO << "JobOptions file for current job: " <<path << endreq;
  ifstream fin(path.c_str());
  string jobOptions;
  string tempString;
  while(getline(fin,tempString))
  {
    if( tempString.size()>0 && tempString.find("//")>tempString.size() )
    { 
      jobOptions += tempString;
      jobOptions += "\n";
    }
  }
  log << MSG::INFO << "JobOptions: " << endreq
      << jobOptions << endreq;
  return jobOptions;
}

Referenced by finalize().

◆ getSelectFromTag()

virtual bool RootInterface::getSelectFromTag ( )

inlinevirtual

Definition at line 63 of file RootInterface.h.

63{ return m_selectFromTag;}

Referenced by RootEventBaseCnv::createObj(), and RootEvtSelector::next().

◆ getTagInputFile()

virtual std::vector< std::string > RootInterface::getTagInputFile ( )

inlinevirtual

Definition at line 69 of file RootInterface.h.

69{return m_tagInputFile;}

Referenced by RootEvtSelector::getEntryFromTag().

◆ getTotalFileNum()

virtual int RootInterface::getTotalFileNum ( )

inlinevirtual

Definition at line 66 of file RootInterface.h.

66{return m_fileNames.size();}

Referenced by RootEvtSelector::getEntryFromTag(), and TagWriterAlg::initialize().

◆ getTotEvtNo()

std::vector< int > RootInterface::getTotEvtNo ( )

virtual

Definition at line 89 of file RootInterface.cxx.

{
  ISvcLocator* svcLocator = Gaudi::svcLocator();
  IDataInfoSvc *tmpInfoSvc;
  DataInfoSvc* jobInfoSvc;
  std::vector<int> totEvtNo;
  StatusCode status = svcLocator->service("DataInfoSvc",tmpInfoSvc);
  if (status.isSuccess()) {
    log << MSG::INFO << "get the DataInfoSvc" << endreq;
    jobInfoSvc=dynamic_cast<DataInfoSvc *>(tmpInfoSvc);
    totEvtNo = jobInfoSvc->getTotEvtNo();
    log << MSG::INFO << "get total event number for each run" << endreq;
  }else {
    log << MSG::WARNING << "could not get the DataInfoSvc. Ignore it." << endreq;
  }
  return totEvtNo;
}

Referenced by finalize().

◆ Instance()

RootInterface * RootInterface::Instance ( MsgStream log )

static

singleton behaviour

Definition at line 25 of file RootInterface.cxx.

                                                    {
  if (m_rootInterface) return m_rootInterface;
  m_rootInterface=new RootInterface(log);
  return m_rootInterface;
}

Referenced by MixerAlg::execute(), RootEvtSelector::initialize(), TagWriterAlg::initialize(), RootCnvSvc::RootCnvSvc(), and RootEventBaseCnv::RootEventBaseCnv().

◆ printJobInfo()

void RootInterface::printJobInfo	(	TFile *	file,
		int	level
	)

virtual

Definition at line 311 of file RootInterface.cxx.

{
  TTree* tree2  = (TTree *)file->Get("JobInfoTree");
  if(!tree2)
  {
    std::cout<<"no JobInfoTree for file "<<file->GetName()<<std::endl;
    exit(1);
  }
  else
  {
    log << MSG::INFO << "get JobInfoTree" << endreq;
    TBranch* branch = tree2->GetBranch("JobInfo");
    if(!branch)
    { 
      std::cout<<"ERROR! No branch in JobInfoTree"<<std::endl;
      exit(1);
    }
    else
    {
      TJobInfo* jobInfo= new TJobInfo;
      branch->SetAddress(&jobInfo);
      branch->GetEntry(0);
      m_bossVer = jobInfo->getBossVer() ;
      std::cout<<std::endl
             << "**************************************************" << std::endl
             <<"Print JobInfo for data file: "<< file->GetName()<<std::endl
             << "          BOSS version: "<< m_bossVer << std::endl
             << "**************************************************" << std::endl
             << std::endl;
 
      m_decayOptions = jobInfo->getDecayOptions();
      if(m_decayOptions.size()>0)
      {
        std::cout<< std::endl
                 <<"**************************************************" << std::endl
                 <<"          Decay Options: "<<std::endl
                 <<m_decayOptions << std::endl
                 <<"**************************************************" << std::endl
                 << std::endl;
      }
 
      ISvcLocator* svcLocator = Gaudi::svcLocator();
      IDataInfoSvc *tmpInfoSvc;
      DataInfoSvc* jobInfoSvc;
      StatusCode status = svcLocator->service("DataInfoSvc",tmpInfoSvc);
      if (status.isSuccess()) {
      log << MSG::INFO << "get the DataInfoSvc" << endreq;
      jobInfoSvc=dynamic_cast<DataInfoSvc *>(tmpInfoSvc);
      }else {
       log << MSG::WARNING << "could not get the DataInfoSvc." << endreq;
      }
 
      m_totEvtNo = jobInfo->getTotEvtNo();
      jobInfoSvc->setTotEvtNo(m_totEvtNo);
 
      if(level>0)
      {    
        std::cout<<std::endl
                 <<"**************************************************" << std::endl
                 <<"          JobOptions for this data file: " << std::endl
                 << std::endl;
      
               
        m_jobOptions = jobInfo->getJobOptions();
        vector<std::string> vs = m_jobOptions;
        int nv = vs.size();
        if(nv>0)
        {
          for(int i=0;i<nv;i++)
          {
            std::cout<<vs[i]<<std::endl;
            std::cout<<"          end of the jobOptions file " << std::endl; 
            std::cout<<"**************************************************" << std::endl
                     <<std::endl;
          }
        }
      }
    }
  } 
}

◆ setBranchAddress()

StatusCode RootInterface::setBranchAddress	(	const std::string	treename,
		const std::string	branchname,
		void *	addr,
		int &	nb
	)

virtual

set branch address

Definition at line 496 of file RootInterface.cxx.

{
  log << MSG::DEBUG <<"RootInterface::setbranch address, treename: "<<treename <<", branch "<<branchname <<endreq;
 
  branchnr=-1;
  
  TTree * tree;
  
  if(m_fileNum != 0){
   
    tree = getOtherTree(treename);
  }else{
    tree = getTree(treename);
  } 
    
  //TTree * tree = getTree("Dst");
  if (!tree) {
    log << MSG::ERROR << "Could not find tree " << treename <<endreq;
    log << MSG::ERROR << "terminate the process handly"<<endreq;
    exit(1);
    return StatusCode::FAILURE;
  }
  tree->SetMakeClass(1);  // necessary for separate branch reading (segv otherwise)!
 
  //   log << MSG::INFO <<"ok!!!!!!!!!!!!!11"<<endreq; 
  TBranch *b = tree->GetBranch(branchname.c_str());
  if (!b) {
    //tree->Print();
    log << MSG::DEBUG << "Could not find branch xx" << branchname <<"xx"<<endreq;
    return StatusCode::FAILURE;
  }
  // log << MSG::INFO <<"ok!!!!!!!!!!!!!22"<<endreq;
  // log << MSG::INFO <<"ok!!!!!!!!!!!!!22"<<(*addr)<<endreq; 
  b->SetAddress(addr);  
  // log << MSG::INFO <<"ok!!!!!!!!!!!!!33"<<endreq;  
  branchnr=m_branchesRead->GetEntries();
  // log << MSG::INFO <<"ok!!!!!!!!!!!!!44"<<endreq;
  TClonesArray &a = *m_branchesRead;
  m_branchesRead->Expand(branchnr+1);
  a[branchnr]=b;
  return StatusCode::SUCCESS;
}

Referenced by RootEventBaseCnv::createObj().

◆ setSelectFromTag()

virtual void RootInterface::setSelectFromTag ( bool temp )

inlinevirtual

Definition at line 62 of file RootInterface.h.

62{m_selectFromTag = temp;}

Referenced by RootCnvSvc::initialize().

◆ setTagInputFile()

void RootInterface::setTagInputFile ( std::vector< std::string > input )

virtual

Definition at line 179 of file RootInterface.cxx.

{
 
  for(int i=0; i<input.size(); i++)
  {
    log << MSG::DEBUG <<"input tag file: "<<i<<" "<<input[i]<<endreq;
    m_tagInputFile.push_back(input[i]);
  }
}

Referenced by RootCnvSvc::initialize(), and RootEvtSelector::initialize().

The documentation for this class was generated from the following files:

Public Member Functions

Static Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ RootInterface()

◆ ~RootInterface()

Member Function Documentation

◆ addInput()

◆ addOutput()

◆ checkEndOfTree()

◆ createBranch()

◆ f_addOutput()

◆ f_createBranch()

◆ f_createTree()

◆ f_fillTrees()

◆ f_finalize()

◆ f_getTreeNr()

◆ fillTrees()

◆ finalize()

◆ getBranchEntry() [1/2]

◆ getBranchEntry() [2/2]

◆ getCurrentFileName()

◆ getCurrentFileNum()

◆ getDecayOptions()

◆ getENDFILE()

◆ getEntries()

◆ getEOF()

◆ getJobOptions()

◆ getSelectFromTag()

◆ getTagInputFile()

◆ getTotalFileNum()

◆ getTotEvtNo()

◆ Instance()

◆ printJobInfo()

◆ setBranchAddress()

◆ setSelectFromTag()

◆ setTagInputFile()