79 Info(
"TEventIter",
"fPackets list '%s' created",
n.Data());
81 Warning(
"TEventIter",
"fPackets list could not be created");
89 : fDSet(dset), fSel(
sel)
112 Info(
"TEventIter",
"fPackets list '%s' created",
n.Data());
114 Warning(
"TEventIter",
"fPackets list could not be created");
153 }
else if (dset->
IsTree()) {
193 if (dirsave) dirsave->
cd();
197 Error(
"Process",
"Cannot open file: %s (%s)",
200 Error(
"Process",
"Cannot open file: %s (errno unavailable)",
215 Error(
"Process",
"Cannot cd to: %s",
221 if (dirsave) dirsave->
cd();
289 PDB(kLoop, 2)
Info(
"GetNextPacket",
"bytes written: %lld", bytesWritten);
324 Error(
"GetNextPacket",
"data element must be set to kEmtpy");
330 if (num == 0)
return -1;
352 PDB(kLoop, 2)
Info(
"GetNextEvent",
"bytes written: %lld", bytesWritten);
387 Error(
"GetNextEvent",
"data element must be set to kEmtpy");
469 Error(
"GetNextPacket",
"entry- or event-list not available");
487 }
else if (
r == 1 ) {
510 Error(
"GetNextPacket",
"First (%lld) higher then number of keys (%lld) in %s",
519 Error(
"GetNextPacket",
"Num (%lld) + First (%lld) larger then number of keys (%lld) in %s",
552 if (dirsave) dirsave->
cd();
584 Error(
"GetNextEvent",
"Entry- or event-list not available");
602 }
else if (
r == 1 ) {
625 Error(
"GetNextEvent",
"First (%lld) higher then number of keys (%lld) in %s",
634 Error(
"GetNextEvent",
"Num (%lld) + First (%lld) larger then number of keys (%lld) in %s",
679 tree = (
TTree *)fTrees->After(tree);
788 Info(
"GetTrees",
"the tree cache is in learning phase");
791 Warning(
"GetTrees",
"default tree does nto have a file attached: corruption? Tree cache untouched");
795 main->SetCacheSize(0);
809 if ((from = uo.Index(
"friend_alias=")) !=
kNPOS) {
810 from += strlen(
"friend_alias=");
811 if (!uo.Tokenize(alias, from,
"|"))
812 Warning(
"GetTrees",
"empty 'friend_alias' found for tree friend");
819 if (friendTree &&
main) {
827 if (fe->
GetTree() == friendTree) {
835 main->AddFriend(friendTree);
837 main->AddFriend(friendTree, alias);
864 Error(
"Load",
"undefined element");
868 const char *fn =
e->GetFileName();
869 const char *dn =
e->GetDirectory();
871 if (objname && strlen(objname) > 0) {
876 if (!tn || (tn && strlen(tn) <= 0)) tn =
"*";
879 Info(
"Load",
"loading: fn:'%s' dn:'%s' tn:'%s'", fn, dn, tn);
911 Error(
"Load",
"file '%s' ('%s') could not be open", fn, fname.
Data());
915#if defined(R__MACOSX)
918 fcntl(
f->GetFd(), F_NOCACHE, 1);
929 Info(
"Load",
"file '%s' already open (local:%d)", fn, localfile);
935 if (!strcmp(tn,
"*"))
948 Error(
"Load",
"Cannot get to: %s", dn);
952 Info(
"Load",
"got directory: %s", dn);
967 while ((k = (
TKey *) nxk())) {
982 Error(
"Load",
"Cannot find tree \"%s\" in %s", tn, fn);
986 PDB(kLoop,2)
Info(
"Load",
"Reading: %s", tn);
992 Error(
"Load",
"Cannot <dynamic_cast> obj to tree \"%s\"", tn);
1000 Info(
"Load",
"TFileTree for '%s' flagged as 'in-use' ...", ft->
GetName());
1069 if (newTree !=
fTree) {
1107 Error(
"GetNextPacket",
"first (%lld) higher then number of entries (%lld) in %s",
1115 Error(
"GetNextPacket",
"num (%lld) + first (%lld) larger then number of entries (%lld) in %s",
1131 PDB(kLoop,1)
Info(
"GetNextPacket",
"call Init(%p) and Notify()",
fTree);
1182 Warning(
"PreEventProcess",
"problems setting entry in TTree");
1245 if (newTree !=
fTree) {
1280 Error(
"GetNextEvent",
"first (%lld) higher then number of entries (%lld) in %s",
1288 Error(
"GetNextEvent",
"num (%lld) + first (%lld) larger then number of entries (%lld) in %s",
1304 PDB(kLoop,1)
Info(
"GetNextEvent",
"call Init(%p) and Notify()",
fTree);
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t Int_t Int_t Window_t TString Int_t GCValues_t GetPrimarySelectionOwner GetDisplay GetScreen GetColormap GetNativeEvent const char const char dpyName wid window const char font_name cursor keysym reg const char only_if_exist regb h Point_t winding char text const char depth char const char Int_t count const char ColorStruct_t color const char Pixmap_t Pixmap_t PictureAttributes_t attr const char char ret_data h unsigned char height h Atom_t Int_t ULong_t ULong_t unsigned char prop_list Atom_t sel
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t r
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void on
R__EXTERN TProofServ * gProofServ
R__EXTERN TSystem * gSystem
void SetName(const char *name)
virtual void SetOwner(Bool_t enable=kTRUE)
Set whether this collection is the owner (enable==true) of its content.
virtual Int_t GetSize() const
Return the capacity of the collection, i.e.
Manages an element of a TDSet.
const char * GetObjName() const
TObject * GetEntryList() const
virtual TList * GetListOfFriends() const
const char * GetDirectory() const
Return directory where to look for object.
const char * GetFileName() const
Long64_t GetFirst() const
This class implements a data set to be used for PROOF processing.
virtual TDSetElement * Next(Long64_t totalEntries=-1)
Returns next TDSetElement.
const char * GetType() const
const char * GetObjName() const
Bool_t cd() override
Change current directory to "this" directory.
Describe directory structure in memory.
virtual TDirectory * GetDirectory(const char *namecycle, Bool_t printError=false, const char *funcname="GetDirectory")
Find a directory using apath.
virtual Bool_t cd()
Change current directory to "this" directory.
virtual TKey * GetKey(const char *, Short_t=9999) const
virtual TList * GetListOfKeys() const
A List of entry numbers in a TTree or TChain.
virtual void SetTree(const TTree *tree)
If a list for a tree with such name and filename exists, sets it as the current sublist If not,...
virtual Long64_t GetEntriesToProcess() const
virtual Long64_t GetEntry(Long64_t index)
Return the number of the entry #index of this TEntryList in the TTree or TChain See also Next().
virtual Int_t GetValue(const char *name, Int_t dflt) const
Returns the integer value for a resource.
Int_t GetNextPacket(Long64_t &first, Long64_t &num) override
Get loop range.
TEventIterObj()
Default ctor.
void PreProcessEvent(Long64_t) override
To be executed before by TProofPlayer calling TSelector::Process.
Long64_t GetNextEvent() override
Get next event.
~TEventIterObj() override
Destructor.
TFileTree(const char *name, TFile *f, Bool_t islocal)
Default ctor.
~TFileTree() override
Default dtor.
void PreProcessEvent(Long64_t ent) override
Actions to be done just before processing entry 'entry'.
Int_t GetNextPacket(Long64_t &first, Long64_t &num) override
Get loop range.
~TEventIterTree() override
Destructor.
TEventIterTree()
Default ctor.
Long64_t GetNextEvent() override
Get next event.
TTree * Load(TDSetElement *elem, Bool_t &localfile, const char *objname=0)
Load a tree from s TDSetElement.
Bool_t fTreeCacheIsLearning
Int_t GetLearnEntries() override
Return the number of entries in the learning phase.
Long64_t GetCacheSize() override
Return the size in bytes of the cache, if any Return -1 if not used.
TTree * GetTrees(TDSetElement *elem)
Create a Tree for the main TDSetElement and for all the friends.
Long64_t GetNextEvent() override
Get next event.
TEventIterUnit()
Default constructor.
Int_t GetNextPacket(Long64_t &first, Long64_t &num) override
Get loop range.
Special iterator class used in TProofPlayer to iterate over events or objects in the packets.
Long64_t fEntryListPos
entry list for processing
virtual Long64_t GetEntryNumber(Long64_t)
TList * fPackets
current position in the entrylist
virtual void StopProcess(Bool_t abort)
Set flag to stop the process.
Int_t fEventListPos
eventList for processing
static TEventIter * Create(TDSet *dset, TSelector *sel, Long64_t first, Long64_t num)
Create and instance of the appropriate iterator.
Int_t LoadDir()
Load directory.
virtual void InvalidatePacket()
Invalidated the current packet (if any) by setting the TDSetElement::kCorrupted bit.
TEntryList * fEntryList
current position in the eventList
virtual void PreProcessEvent(Long64_t)
TEventIter()
Default constructor.
~TEventIter() override
Destructor.
<div class="legacybox"><h2>Legacy Code</h2> TEventList is a legacy interface: there will be no bug fi...
virtual Long64_t GetEntry(Int_t index) const
Return value of entry at index in the list.
virtual Int_t GetN() const
A ROOT file is an on-disk file, usually with extension .root, that stores objects in a file-system-li...
virtual void SetCacheRead(TFileCacheRead *cache, TObject *tree=nullptr, ECacheAction action=kDisconnect)
Set a pointer to the read cache.
static Long64_t GetFileBytesWritten()
Static function returning the total number of bytes written to all files.
virtual Long64_t GetBytesRead() const
virtual Int_t GetErrno() const
Method returning errno.
static EFileType GetType(const char *name, Option_t *option="", TString *prefix=nullptr)
Resolve the file type as a function of the protocol field in 'name'.
static TFile * Open(const char *name, Option_t *option="", const char *ftitle="", Int_t compress=ROOT::RCompressionSetting::EDefaults::kUseCompiledDefault, Int_t netopt=0)
Create / open a file.
TFileCacheRead * GetCacheRead(const TObject *tree=nullptr) const
Return a pointer to the current read cache.
A TFriendElement TF describes a TTree object TF in a file.
virtual TTree * GetTree()
Return pointer to friend TTree.
Book space in a file, create I/O buffers, to fill them, (un)compress them.
T * ReadObject()
To read an object (non deriving from TObject) from the file.
virtual const char * GetClassName() const
virtual TObject * ReadObj()
To read a TObject* from the file.
TObject * FindObject(const char *name) const override
Find an object in this list using its name.
void Add(TObject *obj) override
TObject * Remove(TObject *obj) override
Remove object from the list.
TObject * First() const override
Return the first object in the list. Returns 0 when list is empty.
The TNamed class is the base class for all named ROOT classes.
const char * GetName() const override
Returns name of object.
virtual void SetName(const char *name)
Set the name of the TNamed.
R__ALWAYS_INLINE Bool_t TestBit(UInt_t f) const
virtual void Warning(const char *method, const char *msgfmt,...) const
Issue warning message.
R__ALWAYS_INLINE Bool_t IsZombie() const
void SetBit(UInt_t f, Bool_t set)
Set or unset the user status bits as specified in f.
virtual Bool_t InheritsFrom(const char *classname) const
Returns kTRUE if object inherits from class "classname".
virtual void Error(const char *method, const char *msgfmt,...) const
Issue error message.
virtual void Info(const char *method, const char *msgfmt,...) const
Issue info message.
const char * GetOrdinal() const
void RestartComputeTime()
Reset the compute time.
Regular expression class.
A TSelector object is used by the TTree::Draw, TTree::Scan, TTree::Process to navigate in a TTree and...
virtual void SetObject(TObject *obj)
virtual EAbort GetAbort() const
virtual void Init(TTree *)
bool Notify() override
This method must be overridden to handle object notification (the base implementation is no-op).
virtual TList * GetOutputList() const
const char * Data() const
TString & ReplaceAll(const TString &s1, const TString &s2)
TObjArray * Tokenize(const TString &delim) const
This function is used to isolate sequential tokens in a TString.
static TString Format(const char *fmt,...)
Static method which formats a string using a printf style format descriptor and return a TString.
Bool_t Contains(const char *pat, ECaseCompare cmp=kExact) const
Ssiz_t Index(const char *pat, Ssiz_t i=0, ECaseCompare cmp=kExact) const
virtual const char * BaseName(const char *pathname)
Base name of a file name. Base name of /user/root is root.
The TTimeStamp encapsulates seconds and ns since EPOCH.
static Int_t SetParallelUnzip(TTreeCacheUnzip::EParUnzipMode option=TTreeCacheUnzip::kEnable)
Static function that (de)activates multithreading unzipping.
A cache to speed-up the reading of ROOT datasets.
virtual void UpdateBranches(TTree *tree)
Update pointer to current Tree and recompute pointers to the branches in the cache.
bool IsLearning() const override
virtual void SetEntryRange(Long64_t emin, Long64_t emax)
Set the minimum and maximum entry number to be processed this information helps to optimize the numbe...
virtual void ResetCache()
This will simply clear the cache.
static Int_t GetLearnEntries()
Static function returning the number of entries used to train the cache see SetLearnEntries.
A TTree represents a columnar dataset.
TFile * GetCurrentFile() const
Return pointer to the current file.
virtual Long64_t GetEntries() const
virtual Long64_t LoadTree(Long64_t entry)
Set current entry.
This class represents a WWW compatible URL.
const char * GetUrl(Bool_t withDeflt=kFALSE) const
Return full URL.
const char * GetFileAndOptions() const
Return the file and its options (the string specified behind the ?).
void SetOptions(const char *opt)
const char * GetOptions() const