---

TFWLiteSelectorBasic Class Reference

Description: A ROOT TSelector which accesses data using an edm::Event. More...

#include <FWCore/FWLite/interface/TFWLiteSelectorBasic.h>

Inheritance diagram for TFWLiteSelectorBasic:

List of all members.

Public Member Functions
virtual void	begin (TList *&in)=0
	Called each time the 'client' begins processing (remote 'slaves' do not see this message).
virtual void	postProcessing (TList &out)=0
	Called each time the 'slave' has seen all the events.
virtual void	preProcessing (const TList *in, TList &out)=0
	Called each time the 'slave' is about to start processing.
virtual void	process (const edm::Event &event)=0
	Call each time the 'slave' gets a new Event.
virtual void	terminate (TList &out)=0
	Called each time the 'client' has finished processing.
	TFWLiteSelectorBasic ()
virtual	~TFWLiteSelectorBasic ()
Private Member Functions
virtual void	Begin (TTree *)
virtual void	Init (TTree *)
virtual Bool_t	Notify ()
const TFWLiteSelectorBasic &	operator= (const TFWLiteSelectorBasic &)
virtual Bool_t	Process (Long64_t)
void	setupNewFile (TFile &)
virtual void	SlaveBegin (TTree *)
virtual void	SlaveTerminate ()
virtual void	Terminate ()
	TFWLiteSelectorBasic (const TFWLiteSelectorBasic &)
virtual Int_t	Version () const
Private Attributes
bool	everythingOK_
edm::root::TFWLiteSelectorMembers *	m_

---

Detailed Description

Description: A ROOT TSelector which accesses data using an edm::Event.

Usage: By inheriting from this class one can make a TSelector for ROOT which works with PROOF and which allows you to access data using an edm::Event.

Definition at line 41 of file TFWLiteSelectorBasic.h.

---

Constructor & Destructor Documentation

TFWLiteSelectorBasic::TFWLiteSelectorBasic

(

)

Definition at line 176 of file TFWLiteSelectorBasic.cc.

                                           : m_(new edm::root::TFWLiteSelectorMembers),
                                     everythingOK_(false)
{
}

TFWLiteSelectorBasic::~TFWLiteSelectorBasic

(

)

[virtual]

Definition at line 186 of file TFWLiteSelectorBasic.cc.

References m_.

{
  delete m_;
}

TFWLiteSelectorBasic::TFWLiteSelectorBasic

(

const TFWLiteSelectorBasic &

)

[private]

---

Member Function Documentation

void TFWLiteSelectorBasic::Begin

(

TTree *

iTree

)

[private, virtual]

Definition at line 207 of file TFWLiteSelectorBasic.cc.

References begin(), and Init().

                                         { 
  Init(iTree);
  begin(fInput);
}

virtual void TFWLiteSelectorBasic::begin

(

TList *&

in

)

[pure virtual]

Called each time the 'client' begins processing (remote 'slaves' do not see this message).

Parameters:

in

an assignable pointer to a list of objects you want passed to 'preProcessing'. This list is used to communicate with remote slaves. NOTE: you are responsible for deleting this TList and its content once you are done with it.

Implemented in tselname, tfwliteselectortest::ThingsTSelector, tfwliteselectortest::ThingsTSelector2, and examples::TrackTSelector.

Referenced by Begin().

void TFWLiteSelectorBasic::Init

(

TTree *

iTree

)

[private, virtual]

Definition at line 219 of file TFWLiteSelectorBasic.cc.

References m_, and edm::root::TFWLiteSelectorMembers::setTree().

Referenced by Begin(), and SlaveBegin().

                                       { 
  if(iTree==0) return;
  m_->setTree(iTree);
}

Bool_t TFWLiteSelectorBasic::Notify

(

)

[private, virtual]

Definition at line 226 of file TFWLiteSelectorBasic.cc.

References GenMuonPlsPt100GeV_cfg::cout, lat::endl(), everythingOK_, file, m_, setupNewFile(), and edm::root::TFWLiteSelectorMembers::tree_.

                             { 
   //std::cout <<"Notify start"<<std::endl;
  //we have switched to a new file  
  //get new file from Tree
  if(0==m_->tree_) {
    std::cout <<"No tree"<<std::endl;
    return kFALSE;
  }
  TFile* file = m_->tree_->GetCurrentFile();
  if(0 == file) {
     //When in Rome, do as the Romans
     TChain* chain = dynamic_cast<TChain*>(m_->tree_);
     if(0 == chain) {
        std::cout <<"No file"<<std::endl;
        return kFALSE;
     }
     file = chain->GetFile();
     if(0==file) {
        std::cout <<"No file"<<std::endl;
        return kFALSE;
     }
  }
  setupNewFile(*file);
  return everythingOK_ ? kTRUE: kFALSE; 
}

const TFWLiteSelectorBasic& TFWLiteSelectorBasic::operator=

(

const TFWLiteSelectorBasic &

)

[private]

virtual void TFWLiteSelectorBasic::postProcessing

(

TList &

out

)

[pure virtual]

Called each time the 'slave' has seen all the events.

Parameters:

out

the list of objects that will be sent to 'terminate'. You can Add() additional objects to 'out' at this point as well.

Implemented in TFWLiteSelector< TWorker >, tfwliteselectortest::ThingsTSelector, TFWLiteSelector< tselnameWorker >, TFWLiteSelector< tfwliteselectortest::ThingsWorker >, and TFWLiteSelector< examples::TrackAnalysisAlgorithm >.

Referenced by SlaveTerminate().

virtual void TFWLiteSelectorBasic::preProcessing	(	const TList *	in,
		TList &	out
	)			[pure virtual]

Called each time the 'slave' is about to start processing.

Parameters:

	in	a pointer to the list of objects created in 'begin()'. The pointer can be 0
	out	a list of objects that are the result of processing (e.g. histograms). You should call 'Add()' for each object you want sent to the 'terminate' method.

Implemented in TFWLiteSelector< TWorker >, tfwliteselectortest::ThingsTSelector, TFWLiteSelector< tselnameWorker >, TFWLiteSelector< tfwliteselectortest::ThingsWorker >, and TFWLiteSelector< examples::TrackAnalysisAlgorithm >.

Referenced by SlaveBegin().

Bool_t TFWLiteSelectorBasic::Process

(

Long64_t

iEntry

)

[private, virtual]

Definition at line 253 of file TFWLiteSelectorBasic.cc.

References edm::aux, edm::BranchTypeToAuxiliaryBranchName(), GenMuonPlsPt100GeV_cfg::cout, lat::endl(), event(), edm::poolNames::eventHistoryBranchName(), edm::root::TFWLiteSelectorMembers::eventHistoryTree_, everythingOK_, exception, edm::errors::FatalRootError, edm::root::TFWLiteSelectorMembers::fileFormatVersion_, edm::InEvent, edm::lumiAux, m_, process(), edm::EventAuxiliary::processHistoryID(), edm::History::processHistoryID(), edm::EventAuxiliary::processHistoryID_, edm::root::TFWLiteSelectorMembers::processNames_, edm::root::TFWLiteSelectorMembers::productMap_, edm::root::TFWLiteSelectorMembers::reader_, edm::root::TFWLiteSelectorMembers::reg_, edm::EventAuxiliary::run(), edm::runAux, edm::EventAuxiliary::time(), edm::root::TFWLiteSelectorMembers::tree_, and edm::FileFormatVersion::value_.

                                             { 
   //std::cout <<"Process start"<<std::endl;
   if(everythingOK_) {
      edm::EventAuxiliary aux;
      edm::EventAuxiliary* pAux= &aux;
      TBranch* branch = m_->tree_->GetBranch(edm::BranchTypeToAuxiliaryBranchName(edm::InEvent).c_str());

      branch->SetAddress(&pAux);
      //provBranch->SetAddress(&pProv);
      branch->GetEntry(iEntry);
      //provBranch->GetEntry(iEntry);
      //CDJ turn off reading meta tree until we fix handling of provenance
      //m_->metaTree_->GetEntry(iEntry);

//NEW      m_->processNames_ = aux.processHistory();

//      std::cout <<"ProcessNames\n";
//      for(edm::ProcessNameList::const_iterator itName = m_->processNames_.begin(),
//        itNameEnd = m_->processNames_.end();
//        itName != itNameEnd;
//        ++itName) {
//       std::cout <<"  "<<*itName<< std::endl;
      //     }

      edm::History history;
      if (m_->fileFormatVersion_.value_ >= 7) {
         edm::History* pHistory = &history;
         TBranch* eventHistoryBranch = m_->eventHistoryTree_->GetBranch(edm::poolNames::eventHistoryBranchName().c_str());
         if (!eventHistoryBranch)
            throw edm::Exception(edm::errors::FatalRootError)
            << "Failed to find history branch in event history tree";
         eventHistoryBranch->SetAddress(&pHistory);
         m_->eventHistoryTree_->GetEntry(iEntry);
         aux.processHistoryID_ = history.processHistoryID();
      }
      try {
         m_->reader_->setEntry(iEntry);
         edm::ProcessConfiguration pc;
         boost::shared_ptr<edm::ProductRegistry const> reg(m_->reg_);
         edm::RunAuxiliary runAux(aux.run(), aux.time(), aux.time());
         boost::shared_ptr<edm::RunPrincipal> rp(new edm::RunPrincipal(runAux, reg, pc));
         edm::LuminosityBlockAuxiliary lumiAux(rp->run(), 1, aux.time(), aux.time());
         boost::shared_ptr<edm::LuminosityBlockPrincipal>lbp(
            new edm::LuminosityBlockPrincipal(lumiAux, reg, pc));
         lbp->setRunPrincipal(rp);
         boost::shared_ptr<edm::BranchMapper> mapper(new edm::BranchMapper);
         edm::EventPrincipal ep(aux, reg, pc, aux.processHistoryID(), mapper, m_->reader_);
         ep.setLuminosityBlockPrincipal(lbp);
         ep.setHistory(history);
         m_->processNames_ = ep.processHistory();

         using namespace edm;
         std::map<ProductID, BranchDescription>::iterator pit = m_->productMap_.begin();
         std::map<ProductID, BranchDescription>::iterator pitEnd = m_->productMap_.end();
         for (; pit != pitEnd; ++pit) {
            BranchDescription &product = pit->second;
            if (not product.oldProductID().isValid()) continue;
            ep.addGroup(edm::ConstBranchDescription(product));
         }

         edm::ModuleDescription md;
         edm::Event event(ep,md);
         
         //Make the event principal accessible to edm::Ref's
         edm::EDProductGetter::Operate sentry(ep.prodGetter());
         process(event);
      } catch( const std::exception& iEx ) {
         std::cout <<"While processing entry "<<iEntry<<" the following exception was caught \n"
                   <<iEx.what()<<std::endl;
      } catch(...) {
         std::cout <<"While processing entry "<<iEntry<<" an unknown exception was caught" << std::endl;
      }
   }
   //std::cout <<"Process end"<<std::endl;
  return kFALSE; 
}

virtual void TFWLiteSelectorBasic::process

(

const edm::Event &

event

)

[pure virtual]

Call each time the 'slave' gets a new Event.

Parameters:

event

a standard edm::Event which works just like it does in cmsRun

Implemented in TFWLiteSelector< TWorker >, tfwliteselectortest::ThingsTSelector, TFWLiteSelector< tselnameWorker >, TFWLiteSelector< tfwliteselectortest::ThingsWorker >, and TFWLiteSelector< examples::TrackAnalysisAlgorithm >.

Referenced by Process().

void TFWLiteSelectorBasic::setupNewFile

(

TFile &

iFile

)

[private]

Definition at line 341 of file TFWLiteSelectorBasic.cc.

References edm::BranchDescription::branchType(), GenMuonPlsPt100GeV_cfg::cout, lat::endl(), edm::root::TFWLiteSelectorMembers::eventHistoryTree_, edm::poolNames::eventHistoryTreeName(), edm::poolNames::eventMetaDataTreeName(), everythingOK_, edm::root::TFWLiteSelectorMembers::fileFormatVersion_, edm::poolNames::fileFormatVersionBranchName(), i, edm::InEvent, edm::BranchDescription::init(), edm::detail::ThreadSafeRegistry< KEY, T, E >::insertMapped(), edm::detail::ThreadSafeRegistry< KEY, T, E >::instance(), it, j, k, m_, edm::metaDataTree, edm::poolNames::metaDataTreeName(), edm::root::TFWLiteSelectorMembers::metaTree_, edm::poolNames::moduleDescriptionMapBranchName(), edm::poolNames::parameterSetMapBranchName(), edm::root::TFWLiteSelectorMembers::pointerToBranchBuffer_, edm::poolNames::processHistoryMapBranchName(), edm::poolNames::productDescriptionBranchName(), edm::ProductRegistry::productList(), edm::root::TFWLiteSelectorMembers::productMap_, edm::root::TFWLiteSelectorMembers::prov_, edm::root::TFWLiteSelectorMembers::reg_, pyDBSRunClass::temp, tmp, and edm::FileFormatVersion::value_.

Referenced by Notify().

                                               { 
  //look up meta-data
  //get product registry
  edm::ProductRegistry* pReg = &(*m_->reg_);
  typedef std::map<edm::ParameterSetID, edm::ParameterSetBlob> PsetMap;
  PsetMap psetMap;
  edm::ProcessHistoryMap pHistMap;
  edm::ModuleDescriptionMap mdMap;
  PsetMap *psetMapPtr = &psetMap;
  edm::ProcessHistoryMap *pHistMapPtr = &pHistMap;
  edm::ModuleDescriptionMap *mdMapPtr = &mdMap;
  edm::FileFormatVersion* fftPtr = &(m_->fileFormatVersion_);
   
  TTree* metaDataTree = dynamic_cast<TTree*>(iFile.Get(edm::poolNames::metaDataTreeName().c_str()) );
  if ( 0 != metaDataTree) {
    metaDataTree->SetBranchAddress(edm::poolNames::productDescriptionBranchName().c_str(), &(pReg) );
    metaDataTree->SetBranchAddress(edm::poolNames::parameterSetMapBranchName().c_str(), &psetMapPtr);
    metaDataTree->SetBranchAddress(edm::poolNames::processHistoryMapBranchName().c_str(), &pHistMapPtr);
    metaDataTree->SetBranchAddress(edm::poolNames::moduleDescriptionMapBranchName().c_str(), &mdMapPtr);
     metaDataTree->SetBranchAddress(edm::poolNames::fileFormatVersionBranchName().c_str(), &fftPtr);
    metaDataTree->GetEntry(0);
    m_->reg_->setFrozen();
  } else {
    std::cout <<"could not find TTree "<<edm::poolNames::metaDataTreeName() <<std::endl;
    everythingOK_ = false;
    return;
  }
  m_->metaTree_ = dynamic_cast<TTree*>(iFile.Get(edm::poolNames::eventMetaDataTreeName().c_str()));
  if( 0 == m_->metaTree_) {
    std::cout <<"could not find TTree "<<edm::poolNames::eventMetaDataTreeName() <<std::endl;
    everythingOK_ = false;
    return;
  }

  // Merge into the registries. For now, we do NOT merge the product registry.
  edm::pset::Registry& psetRegistry = *edm::pset::Registry::instance();
  for (PsetMap::const_iterator i = psetMap.begin(), iEnd = psetMap.end();
      i != iEnd; ++i) {
    psetRegistry.insertMapped(edm::ParameterSet(i->second.pset_));
  } 
  edm::ProcessHistoryRegistry & processNameListRegistry = *edm::ProcessHistoryRegistry::instance();
  for (edm::ProcessHistoryMap::const_iterator j = pHistMap.begin(), jEnd = pHistMap.end();
      j != jEnd; ++j) {
    processNameListRegistry.insertMapped(j->second);
  } 
  edm::ModuleDescriptionRegistry & moduleDescriptionRegistry = *edm::ModuleDescriptionRegistry::instance();
  for (edm::ModuleDescriptionMap::const_iterator k = mdMap.begin(), kEnd = mdMap.end();
      k != kEnd; ++k) {
    moduleDescriptionRegistry.insertMapped(k->second);
  } 
  
  m_->productMap_.erase(m_->productMap_.begin(),m_->productMap_.end());
  m_->pointerToBranchBuffer_.erase(m_->pointerToBranchBuffer_.begin(),
                                   m_->pointerToBranchBuffer_.end());
  edm::ProductRegistry::ProductList const& prodList = pReg->productList();
  std::vector<edm::EventEntryDescription> temp( prodList.size(), edm::EventEntryDescription() );
  m_->prov_.swap( temp);
  std::vector<edm::EventEntryDescription>::iterator itB = m_->prov_.begin();
  m_->pointerToBranchBuffer_.reserve(prodList.size());
  for (edm::ProductRegistry::ProductList::const_iterator it = prodList.begin(), itEnd = prodList.end();
       it != itEnd; ++it, ++itB) {
    edm::BranchDescription const& prod = it->second;
    if( prod.branchType() == edm::InEvent) {
      prod.init();
      //NEED to do this and check to see if branch exists
      //prod.present_ = (branch != 0);
      m_->productMap_.insert(std::make_pair(it->second.oldProductID(), it->second));
      //std::cout <<"id "<<it->second.oldProductID()<<" branch "<<it->second.branchName()<<std::endl;
      m_->pointerToBranchBuffer_.push_back( & (*itB));
      void* tmp = &(m_->pointerToBranchBuffer_.back());
      //edm::EventEntryDescription* tmp = & (*itB);
      //CDJ need to fix provenance and be backwards compatible, for now just don't read the branch
      //m_->metaTree_->SetBranchAddress( prod.branchName().c_str(), tmp);
    }
  }  
  //std::cout <<"Notify end"<<std::endl;
   
   if (m_->fileFormatVersion_.value_ >= 7) {
      m_->eventHistoryTree_ = dynamic_cast<TTree*>(iFile.Get(edm::poolNames::eventHistoryTreeName().c_str()));
      if(0==m_->eventHistoryTree_) {
         std::cout <<"could not find TTree "<<edm::poolNames::eventHistoryTreeName() <<std::endl;
         everythingOK_ = false;
         return;
      }
   }
  everythingOK_ = true;
}

void TFWLiteSelectorBasic::SlaveBegin

(

TTree *

iTree

)

[private, virtual]

Definition at line 213 of file TFWLiteSelectorBasic.cc.

References Init(), and preProcessing().

                                             { 
  Init(iTree);
  preProcessing(fInput,*fOutput);
}

void TFWLiteSelectorBasic::SlaveTerminate

(

)

[private, virtual]

Definition at line 331 of file TFWLiteSelectorBasic.cc.

References postProcessing().

                                     { 
  postProcessing(*fOutput);
}

void TFWLiteSelectorBasic::Terminate

(

)

[private, virtual]

Definition at line 336 of file TFWLiteSelectorBasic.cc.

References terminate().

                                {
  terminate(*fOutput);
}

virtual void TFWLiteSelectorBasic::terminate

(

TList &

out

)

[pure virtual]

Called each time the 'client' has finished processing.

Parameters:

out

contains the accumulated output of all slaves.

Implemented in tselname, tfwliteselectortest::ThingsTSelector, tfwliteselectortest::ThingsTSelector2, and examples::TrackTSelector.

Referenced by Terminate().

virtual Int_t TFWLiteSelectorBasic::Version

(

)

const [inline, private, virtual]

Definition at line 95 of file TFWLiteSelectorBasic.h.

{ return 1; }

---

Member Data Documentation

bool TFWLiteSelectorBasic::everythingOK_ [private]

Definition at line 100 of file TFWLiteSelectorBasic.h.

Referenced by Notify(), Process(), and setupNewFile().

edm::root::TFWLiteSelectorMembers* TFWLiteSelectorBasic::m_ [private]

Definition at line 99 of file TFWLiteSelectorBasic.h.

Referenced by Init(), Notify(), Process(), setupNewFile(), and ~TFWLiteSelectorBasic().

---

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

• FWCore/TFWLiteSelector/interface/TFWLiteSelectorBasic.h
• FWCore/TFWLiteSelector/src/TFWLiteSelectorBasic.cc

---