Logo ROOT  
Reference Guide
 
Loading...
Searching...
No Matches
TMPWorkerTree Class Reference

This class works in conjuction with TTreeProcessorMP, reacting to messages received from it as specified by the Notify and HandleInput methods.

Definition at line 33 of file TMPWorkerTree.h.

Public Member Functions

 TMPWorkerTree ()
 Class constructors.
 
 TMPWorkerTree (const std::vector< std::string > &fileNames, TEntryList *entries, const std::string &treeName, UInt_t nWorkers, ULong64_t maxEntries, ULong64_t firstEntry)
 
 TMPWorkerTree (const TMPWorkerTree &)=delete
 
 TMPWorkerTree (TTree *tree, TEntryList *entries, UInt_t nWorkers, ULong64_t maxEntries, ULong64_t firstEntry)
 
virtual ~TMPWorkerTree ()
 
TMPWorkerTreeoperator= (const TMPWorkerTree &)=delete
 
- Public Member Functions inherited from TMPWorker
 TMPWorker ()
 
 TMPWorker (const TMPWorker &)=delete
 
 TMPWorker (unsigned nWorkers, ULong64_t maxEntries)
 
virtual ~TMPWorker ()
 
unsigned GetNWorker () const
 
pid_t GetPid ()
 
TSocketGetSocket ()
 
virtual void Init (int fd, unsigned workerN)
 This method is called by children processes right after forking.
 
TMPWorkeroperator= (const TMPWorker &)=delete
 
void Run ()
 

Protected Member Functions

void CloseFile ()
 Handle file closing.
 
ULong64_t EvalMaxEntries (ULong64_t maxEntries)
 Max entries evaluation.
 
void HandleInput (MPCodeBufPair &msg)
 Execute instructions received from a MP client.
 
void Init (int fd, UInt_t workerN)
 Init overload definign max entries.
 
Int_t LoadTree (UInt_t code, MPCodeBufPair &msg, Long64_t &start, Long64_t &finish, TEntryList **enl, std::string &errmsg)
 Load the requierd tree and evaluate the processing range.
 
TFileOpenFile (const std::string &fileName)
 Handle file opening.
 
virtual void Process (UInt_t, MPCodeBufPair &)
 
TTreeRetrieveTree (TFile *fp)
 Retrieve a tree from an open file.
 
virtual void SendResult ()
 
void Setup ()
 Auxilliary method for common initializations.
 
void SetupTreeCache (TTree *tree)
 Tree cache handling.
 
- Protected Member Functions inherited from TMPWorker
void SendError (const std::string &errmsg, unsigned int code=MPCode::kError)
 Error sender.
 

Protected Attributes

TEntryListfEntryList
 entrylist
 
TFilefFile
 last open file
 
std::vector< std::string > fFileNames
 the files to be processed by all workers
 
ULong64_t fFirstEntry
 first entry to br processed
 
TTreefTree
 pointer to the tree to be processed. It is only used if the tree is directly passed to TProcessExecutor::Process as argument
 
std::string fTreeName
 the name of the tree to be processed
 
- Protected Attributes inherited from TMPWorker
std::string fId
 identifier string in the form W<nwrk>|P<proc id>
 
ULong64_t fMaxNEntries
 the maximum number of entries to be processed by this worker
 
unsigned fNWorkers
 the number of workers spawned
 
ULong64_t fProcessedEntries
 the number of entries processed by this worker so far
 

Private Attributes

Long64_t fCacheSize
 Cache size.
 
TTreeCachefTreeCache
 instance of the tree cache for the tree
 
Bool_t fTreeCacheIsLearning
 Whether cache is in learning phase.
 
Bool_t fUseTreeCache
 Control usage of the tree cache.
 

#include <TMPWorkerTree.h>

Inheritance diagram for TMPWorkerTree:
[legend]

Constructor & Destructor Documentation

◆ TMPWorkerTree() [1/4]

TMPWorkerTree::TMPWorkerTree ( )

Class constructors.

Note that this does not set variables like fPid or fS (worker's socket).
These operations are handled by the Init method, which is called after forking.
This separation is in place because the instantiation of a worker must be done once before forking, while the initialization of the members must be done after forking by each of the children processes.

Definition at line 45 of file TMPWorkerTree.cxx.

◆ TMPWorkerTree() [2/4]

TMPWorkerTree::TMPWorkerTree ( const std::vector< std::string > &  fileNames,
TEntryList entries,
const std::string &  treeName,
UInt_t  nWorkers,
ULong64_t  maxEntries,
ULong64_t  firstEntry 
)

Definition at line 52 of file TMPWorkerTree.cxx.

◆ TMPWorkerTree() [3/4]

TMPWorkerTree::TMPWorkerTree ( TTree tree,
TEntryList entries,
UInt_t  nWorkers,
ULong64_t  maxEntries,
ULong64_t  firstEntry 
)

Definition at line 61 of file TMPWorkerTree.cxx.

◆ ~TMPWorkerTree()

TMPWorkerTree::~TMPWorkerTree ( )
virtual

Definition at line 69 of file TMPWorkerTree.cxx.

◆ TMPWorkerTree() [4/4]

TMPWorkerTree::TMPWorkerTree ( const TMPWorkerTree )
delete

Member Function Documentation

◆ CloseFile()

void TMPWorkerTree::CloseFile ( )
protected

Handle file closing.

Definition at line 87 of file TMPWorkerTree.cxx.

◆ EvalMaxEntries()

ULong64_t TMPWorkerTree::EvalMaxEntries ( ULong64_t  maxEntries)
protected

Max entries evaluation.

Definition at line 189 of file TMPWorkerTree.cxx.

◆ HandleInput()

void TMPWorkerTree::HandleInput ( MPCodeBufPair msg)
protectedvirtual

Execute instructions received from a MP client.

Generic input handling.

Reimplemented from TMPWorker.

Definition at line 203 of file TMPWorkerTree.cxx.

◆ Init()

void TMPWorkerTree::Init ( int  fd,
UInt_t  workerN 
)
protected

Init overload definign max entries.

Definition at line 179 of file TMPWorkerTree.cxx.

◆ LoadTree()

Int_t TMPWorkerTree::LoadTree ( UInt_t  code,
MPCodeBufPair msg,
Long64_t start,
Long64_t finish,
TEntryList **  enl,
std::string &  errmsg 
)
protected

Load the requierd tree and evaluate the processing range.

Definition at line 272 of file TMPWorkerTree.cxx.

◆ OpenFile()

TFile * TMPWorkerTree::OpenFile ( const std::string &  fileName)
protected

Handle file opening.

Definition at line 100 of file TMPWorkerTree.cxx.

◆ operator=()

TMPWorkerTree & TMPWorkerTree::operator= ( const TMPWorkerTree )
delete

◆ Process()

virtual void TMPWorkerTree::Process ( UInt_t  ,
MPCodeBufPair  
)
inlineprotectedvirtual

Reimplemented in TMPWorkerTreeFunc< F >, and TMPWorkerTreeSel.

Definition at line 57 of file TMPWorkerTree.h.

◆ RetrieveTree()

TTree * TMPWorkerTree::RetrieveTree ( TFile fp)
protected

Retrieve a tree from an open file.

Definition at line 118 of file TMPWorkerTree.cxx.

◆ SendResult()

virtual void TMPWorkerTree::SendResult ( )
inlineprotectedvirtual

Reimplemented in TMPWorkerTreeFunc< F >, and TMPWorkerTreeSel.

Definition at line 59 of file TMPWorkerTree.h.

◆ Setup()

void TMPWorkerTree::Setup ( )
protected

Auxilliary method for common initializations.

Definition at line 77 of file TMPWorkerTree.cxx.

◆ SetupTreeCache()

void TMPWorkerTree::SetupTreeCache ( TTree tree)
protected

Tree cache handling.

Definition at line 150 of file TMPWorkerTree.cxx.

Member Data Documentation

◆ fCacheSize

Long64_t TMPWorkerTree::fCacheSize
private

Cache size.

Definition at line 76 of file TMPWorkerTree.h.

◆ fEntryList

TEntryList* TMPWorkerTree::fEntryList
protected

entrylist

Definition at line 67 of file TMPWorkerTree.h.

◆ fFile

TFile* TMPWorkerTree::fFile
protected

last open file

Definition at line 66 of file TMPWorkerTree.h.

◆ fFileNames

std::vector<std::string> TMPWorkerTree::fFileNames
protected

the files to be processed by all workers

Definition at line 63 of file TMPWorkerTree.h.

◆ fFirstEntry

ULong64_t TMPWorkerTree::fFirstEntry
protected

first entry to br processed

Definition at line 68 of file TMPWorkerTree.h.

◆ fTree

TTree* TMPWorkerTree::fTree
protected

pointer to the tree to be processed. It is only used if the tree is directly passed to TProcessExecutor::Process as argument

Definition at line 65 of file TMPWorkerTree.h.

◆ fTreeCache

TTreeCache* TMPWorkerTree::fTreeCache
private

instance of the tree cache for the tree

Definition at line 73 of file TMPWorkerTree.h.

◆ fTreeCacheIsLearning

Bool_t TMPWorkerTree::fTreeCacheIsLearning
private

Whether cache is in learning phase.

Definition at line 74 of file TMPWorkerTree.h.

◆ fTreeName

std::string TMPWorkerTree::fTreeName
protected

the name of the tree to be processed

Definition at line 64 of file TMPWorkerTree.h.

◆ fUseTreeCache

Bool_t TMPWorkerTree::fUseTreeCache
private

Control usage of the tree cache.

Definition at line 75 of file TMPWorkerTree.h.

Libraries for TMPWorkerTree:

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