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

A TTreeCache which exploits parallelized decompression of its own content.

Definition at line 35 of file TTreeCacheUnzip.h.

Classes

struct  UnzipState
 

Public Types

enum  EParUnzipMode { kEnable , kDisable , kForce }
 
enum  EUnzipState { kUntouched , kProgress , kFinished }
 
- Public Types inherited from TTreeCache
enum  EPrefillType { kNoPrefill , kAllBranches }
 
- Public Types inherited from TObject
enum  {
  kIsOnHeap = 0x01000000 , kNotDeleted = 0x02000000 , kZombie = 0x04000000 , kInconsistent = 0x08000000 ,
  kBitMask = 0x00ffffff
}
 
enum  { kSingleKey = (1ULL << ( 0 )) , kOverwrite = (1ULL << ( 1 )) , kWriteDelete = (1ULL << ( 2 )) }
 
enum  EDeprecatedStatusBits { kObjInCanvas = (1ULL << ( 3 )) }
 
enum  EStatusBits {
  kCanDelete = (1ULL << ( 0 )) , kMustCleanup = (1ULL << ( 3 )) , kIsReferenced = (1ULL << ( 4 )) , kHasUUID = (1ULL << ( 5 )) ,
  kCannotPick = (1ULL << ( 6 )) , kNoContextMenu = (1ULL << ( 8 )) , kInvalidObject = (1ULL << ( 13 ))
}
 

Public Member Functions

 TTreeCacheUnzip ()
 
 TTreeCacheUnzip (TTree *tree, Int_t buffersize=0)
 Constructor.
 
 ~TTreeCacheUnzip () override
 Destructor. (in general called by the TFile destructor)
 
Int_t AddBranch (const char *branch, bool subbranches=false) override
 Add a branch to the list of branches to be stored in the cache this function is called by TBranch::GetBasket Returns:
 
Int_t AddBranch (TBranch *b, bool subbranches=false) override
 Add a branch to the list of branches to be stored in the cache this function is called by TBranch::GetBasket Returns:
 
Int_t CreateTasks ()
 We create a TTaskGroup and asynchronously maps each group of baskets(> 100 kB in total) to a task.
 
bool FillBuffer () override
 Fill the cache buffer with the branches in the cache.
 
Int_t GetNFound ()
 
Int_t GetNMissed ()
 
Int_t GetNUnzip ()
 
Int_t GetRecordHeader (char *buf, Int_t maxbytes, Int_t &nbytes, Int_t &objlen, Int_t &keylen)
 Read the logical record header from the buffer buf.
 
Int_t GetUnzipBuffer (char **buf, Long64_t pos, Int_t len, bool *free) override
 We try to read a buffer that has already been unzipped Returns -1 in case of read failure, 0 in case it's not in the cache and n>0 in case read from cache (number of bytes copied).
 
Int_t GetUnzipGroupSize ()
 
TClassIsA () const override
 
void Print (Option_t *option="") const override
 Print cache statistics.
 
Int_t ReadBufferExt (char *buf, Long64_t pos, Int_t len, Int_t &loc) override
 
void ResetCache () override
 This will delete the list of buffers that are in the unzipping cache and will reset certain values in the cache.
 
Int_t SetBufferSize (Long64_t buffersize) override
 Change the underlying buffer size of the cache.
 
void SetEntryRange (Long64_t emin, Long64_t emax) override
 Set the minimum and maximum entry number to be processed this information helps to optimize the number of baskets to read when prefetching the branch buffers.
 
void SetUnzipBufferSize (Long64_t bufferSize)
 Sets the size for the unzipping cache... by default it should be two times the size of the prefetching cache.
 
void SetUnzipGroupSize (Int_t groupSize)
 
void StopLearningPhase () override
 It's the same as TTreeCache::StopLearningPhase but we guarantee that we start the unzipping just after getting the buffers.
 
void Streamer (TBuffer &) override
 Stream an object of class TObject.
 
void StreamerNVirtual (TBuffer &ClassDef_StreamerNVirtual_b)
 
Int_t UnzipBuffer (char **dest, char *src)
 Unzips a ROOT specific buffer... by reading the header at the beginning.
 
Int_t UnzipCache (Int_t index)
 This inflates a basket in the cache.
 
void UpdateBranches (TTree *tree) override
 update pointer to current Tree and recompute pointers to the branches in the cache
 
- Public Member Functions inherited from TTreeCache
 TTreeCache ()
 Default Constructor.
 
 TTreeCache (TTree *tree, Int_t buffersize=0)
 Constructor.
 
 ~TTreeCache () override
 Destructor. (in general called by the TFile destructor)
 
virtual void Disable ()
 
virtual Int_t DropBranch (const char *branch, bool subbranches=false)
 Remove a branch to the list of branches to be stored in the cache this is to be used by user (thats why we pass the name of the branch).
 
virtual Int_t DropBranch (TBranch *b, bool subbranches=false)
 Remove a branch to the list of branches to be stored in the cache this function is called by TBranch::GetBasket.
 
virtual void Enable ()
 
const TObjArrayGetCachedBranches () const
 
EPrefillType GetConfiguredPrefillType () const
 Return the desired prefill type from the environment or resource variable.
 
Double_t GetEfficiency () const
 Give the total efficiency of the primary cache... defined as the ratio of blocks found in the cache vs.
 
Double_t GetEfficiencyRel () const
 This will indicate a sort of relative efficiency... a ratio of the reads found in the cache to the number of reads so far.
 
virtual Int_t GetEntryMax () const
 
virtual Int_t GetEntryMin () const
 
virtual EPrefillType GetLearnPrefill () const
 
Double_t GetMissEfficiency () const
 The total efficiency of the 'miss cache' - defined as the ratio of blocks found in the cache versus the number of blocks prefetched.
 
Double_t GetMissEfficiencyRel () const
 Relative efficiency of the 'miss cache' - ratio of the reads found in cache to the number of reads so far.
 
bool GetOptimizeMisses () const
 
TTreeGetTree () const
 
bool IsAutoCreated () const
 
virtual bool IsEnabled () const
 
bool IsLearning () const override
 
Int_t LearnBranch (TBranch *b, bool subgbranches=false) override
 Add a branch discovered by actual usage to the list of branches to be stored in the cache this function is called by TBranch::GetBasket If we are not longer in the training phase this is an error.
 
virtual void LearnPrefill ()
 Perform an initial prefetch, attempting to read as much of the learning phase baskets for all branches at once.
 
Int_t ReadBuffer (char *buf, Long64_t pos, Int_t len) override
 Read buffer at position pos if the request is in the list of prefetched blocks read from fBuffer.
 
virtual Int_t ReadBufferNormal (char *buf, Long64_t pos, Int_t len)
 Old method ReadBuffer before the addition of the prefetch mechanism.
 
virtual Int_t ReadBufferPrefetch (char *buf, Long64_t pos, Int_t len)
 Used to read a chunk from a block previously fetched.
 
void ResetMissCache ()
 Reset all the miss cache training.
 
void SetAutoCreated (bool val)
 
void SetFile (TFile *file, TFile::ECacheAction action=TFile::kDisconnect) override
 Change the file that is being cached.
 
virtual void SetLearnPrefill (EPrefillType type=kNoPrefill)
 Set whether the learning period is started with a prefilling of the cache and which type of prefilling is used.
 
void SetOptimizeMisses (bool opt)
 Start of methods for the miss cache.
 
void StartLearningPhase ()
 The name should be enough to explain the method.
 
void StreamerNVirtual (TBuffer &ClassDef_StreamerNVirtual_b)
 
- Public Member Functions inherited from TFileCacheRead
 TFileCacheRead ()
 Default Constructor.
 
 TFileCacheRead (TFile *file, Int_t buffersize, TObject *tree=nullptr)
 Creates a TFileCacheRead data structure.
 
 ~TFileCacheRead () override
 Destructor.
 
virtual void AddNoCacheBytesRead (Long64_t len)
 
virtual void AddNoCacheReadCalls (Int_t reads)
 
virtual void Close (Option_t *option="")
 Close out any threads or asynchronous fetches used by the underlying implementation.
 
virtual Int_t GetBufferSize () const
 
virtual Long64_t GetBytesRead () const
 
virtual Long64_t GetBytesReadExtra () const
 
TFileGetFile () const
 
virtual Long64_t GetNoCacheBytesRead () const
 
virtual Int_t GetNoCacheReadCalls () const
 
Int_t GetNseek () const
 
Int_t GetNtot () const
 
Long64_t GetPrefetchedBlocks () const
 
virtual TFilePrefetchGetPrefetchObj ()
 
virtual Int_t GetReadCalls () const
 
virtual Bool_t IsAsyncReading () const
 
virtual Bool_t IsEnablePrefetching () const
 
virtual void Prefetch (Long64_t pos, Int_t len)
 Add block of length len at position pos in the list of blocks to be prefetched.
 
virtual Int_t ReadBufferExtNormal (char *buf, Long64_t pos, Int_t len, Int_t &loc)
 Base function for ReadBuffer.
 
virtual Int_t ReadBufferExtPrefetch (char *buf, Long64_t pos, Int_t len, Int_t &loc)
 prefetch the first block
 
virtual void SecondPrefetch (Long64_t, Int_t)
 
virtual void SecondSort ()
 Sort buffers to be prefetched in increasing order of positions.
 
virtual void SetEnablePrefetching (Bool_t setPrefetching=kFALSE)
 Set the prefetching mode of this file.
 
virtual void SetSkipZip (Bool_t=kTRUE)
 
virtual void Sort ()
 Sort buffers to be prefetched in increasing order of positions.
 
void StreamerNVirtual (TBuffer &ClassDef_StreamerNVirtual_b)
 
virtual void WaitFinishPrefetch ()
 
- Public Member Functions inherited from TObject
 TObject ()
 TObject constructor.
 
 TObject (const TObject &object)
 TObject copy ctor.
 
virtual ~TObject ()
 TObject destructor.
 
void AbstractMethod (const char *method) const
 Use this method to implement an "abstract" method that you don't want to leave purely abstract.
 
virtual void AppendPad (Option_t *option="")
 Append graphics object to current pad.
 
virtual void Browse (TBrowser *b)
 Browse object. May be overridden for another default action.
 
ULong_t CheckedHash ()
 Check and record whether this class has a consistent Hash/RecursiveRemove setup (*) and then return the regular Hash value for this object.
 
virtual const char * ClassName () const
 Returns name of class to which the object belongs.
 
virtual void Clear (Option_t *="")
 
virtual TObjectClone (const char *newname="") const
 Make a clone of an object using the Streamer facility.
 
virtual Int_t Compare (const TObject *obj) const
 Compare abstract method.
 
virtual void Copy (TObject &object) const
 Copy this to obj.
 
virtual void Delete (Option_t *option="")
 Delete this object.
 
virtual Int_t DistancetoPrimitive (Int_t px, Int_t py)
 Computes distance from point (px,py) to the object.
 
virtual void Draw (Option_t *option="")
 Default Draw method for all objects.
 
virtual void DrawClass () const
 Draw class inheritance tree of the class to which this object belongs.
 
virtual TObjectDrawClone (Option_t *option="") const
 Draw a clone of this object in the current selected pad with: gROOT->SetSelectedPad(c1).
 
virtual void Dump () const
 Dump contents of object on stdout.
 
virtual void Error (const char *method, const char *msgfmt,...) const
 Issue error message.
 
virtual void Execute (const char *method, const char *params, Int_t *error=nullptr)
 Execute method on this object with the given parameter string, e.g.
 
virtual void Execute (TMethod *method, TObjArray *params, Int_t *error=nullptr)
 Execute method on this object with parameters stored in the TObjArray.
 
virtual void ExecuteEvent (Int_t event, Int_t px, Int_t py)
 Execute action corresponding to an event at (px,py).
 
virtual void Fatal (const char *method, const char *msgfmt,...) const
 Issue fatal error message.
 
virtual TObjectFindObject (const char *name) const
 Must be redefined in derived classes.
 
virtual TObjectFindObject (const TObject *obj) const
 Must be redefined in derived classes.
 
virtual Option_tGetDrawOption () const
 Get option used by the graphics system to draw this object.
 
virtual const char * GetIconName () const
 Returns mime type name of object.
 
virtual const char * GetName () const
 Returns name of object.
 
virtual char * GetObjectInfo (Int_t px, Int_t py) const
 Returns string containing info about the object at position (px,py).
 
virtual Option_tGetOption () const
 
virtual const char * GetTitle () const
 Returns title of object.
 
virtual UInt_t GetUniqueID () const
 Return the unique object id.
 
virtual Bool_t HandleTimer (TTimer *timer)
 Execute action in response of a timer timing out.
 
virtual ULong_t Hash () const
 Return hash value for this object.
 
Bool_t HasInconsistentHash () const
 Return true is the type of this object is known to have an inconsistent setup for Hash and RecursiveRemove (i.e.
 
virtual void Info (const char *method, const char *msgfmt,...) const
 Issue info message.
 
virtual Bool_t InheritsFrom (const char *classname) const
 Returns kTRUE if object inherits from class "classname".
 
virtual Bool_t InheritsFrom (const TClass *cl) const
 Returns kTRUE if object inherits from TClass cl.
 
virtual void Inspect () const
 Dump contents of this object in a graphics canvas.
 
void InvertBit (UInt_t f)
 
Bool_t IsDestructed () const
 IsDestructed.
 
virtual Bool_t IsEqual (const TObject *obj) const
 Default equal comparison (objects are equal if they have the same address in memory).
 
virtual Bool_t IsFolder () const
 Returns kTRUE in case object contains browsable objects (like containers or lists of other objects).
 
R__ALWAYS_INLINE Bool_t IsOnHeap () const
 
virtual Bool_t IsSortable () const
 
R__ALWAYS_INLINE Bool_t IsZombie () const
 
virtual void ls (Option_t *option="") const
 The ls function lists the contents of a class on stdout.
 
void MayNotUse (const char *method) const
 Use this method to signal that a method (defined in a base class) may not be called in a derived class (in principle against good design since a child class should not provide less functionality than its parent, however, sometimes it is necessary).
 
virtual Bool_t Notify ()
 This method must be overridden to handle object notification (the base implementation is no-op).
 
void Obsolete (const char *method, const char *asOfVers, const char *removedFromVers) const
 Use this method to declare a method obsolete.
 
void operator delete (void *ptr)
 Operator delete.
 
void operator delete (void *ptr, void *vp)
 Only called by placement new when throwing an exception.
 
void operator delete[] (void *ptr)
 Operator delete [].
 
void operator delete[] (void *ptr, void *vp)
 Only called by placement new[] when throwing an exception.
 
void * operator new (size_t sz)
 
void * operator new (size_t sz, void *vp)
 
void * operator new[] (size_t sz)
 
void * operator new[] (size_t sz, void *vp)
 
TObjectoperator= (const TObject &rhs)
 TObject assignment operator.
 
virtual void Paint (Option_t *option="")
 This method must be overridden if a class wants to paint itself.
 
virtual void Pop ()
 Pop on object drawn in a pad to the top of the display list.
 
virtual Int_t Read (const char *name)
 Read contents of object with specified name from the current directory.
 
virtual void RecursiveRemove (TObject *obj)
 Recursively remove this object from a list.
 
void ResetBit (UInt_t f)
 
virtual void SaveAs (const char *filename="", Option_t *option="") const
 Save this object in the file specified by filename.
 
virtual void SavePrimitive (std::ostream &out, Option_t *option="")
 Save a primitive as a C++ statement(s) on output stream "out".
 
void SetBit (UInt_t f)
 
void SetBit (UInt_t f, Bool_t set)
 Set or unset the user status bits as specified in f.
 
virtual void SetDrawOption (Option_t *option="")
 Set drawing option for object.
 
virtual void SetUniqueID (UInt_t uid)
 Set the unique object id.
 
void StreamerNVirtual (TBuffer &ClassDef_StreamerNVirtual_b)
 
virtual void SysError (const char *method, const char *msgfmt,...) const
 Issue system error message.
 
R__ALWAYS_INLINE Bool_t TestBit (UInt_t f) const
 
Int_t TestBits (UInt_t f) const
 
virtual void UseCurrentStyle ()
 Set current style settings in this object This function is called when either TCanvas::UseCurrentStyle or TROOT::ForceStyle have been invoked.
 
virtual void Warning (const char *method, const char *msgfmt,...) const
 Issue warning message.
 
virtual Int_t Write (const char *name=nullptr, Int_t option=0, Int_t bufsize=0)
 Write this object to the current directory.
 
virtual Int_t Write (const char *name=nullptr, Int_t option=0, Int_t bufsize=0) const
 Write this object to the current directory.
 

Static Public Member Functions

static TClassClass ()
 
static const char * Class_Name ()
 
static constexpr Version_t Class_Version ()
 
static const char * DeclFileName ()
 
static EParUnzipMode GetParallelUnzip ()
 Static function that returns the parallel option (to indicate an additional thread)
 
static bool IsParallelUnzip ()
 Static function that tells wether the multithreading unzipping is activated.
 
static Int_t SetParallelUnzip (TTreeCacheUnzip::EParUnzipMode option=TTreeCacheUnzip::kEnable)
 Static function that (de)activates multithreading unzipping.
 
static void SetUnzipRelBufferSize (Float_t relbufferSize)
 static function: Sets the unzip relative buffer size
 
- Static Public Member Functions inherited from TTreeCache
static TClassClass ()
 
static const char * Class_Name ()
 
static constexpr Version_t Class_Version ()
 
static const char * DeclFileName ()
 
static Int_t GetLearnEntries ()
 Static function returning the number of entries used to train the cache see SetLearnEntries.
 
static void SetLearnEntries (Int_t n=10)
 Static function to set the number of entries to be used in learning mode The default value for n is 10.
 
- Static Public Member Functions inherited from TFileCacheRead
static TClassClass ()
 
static const char * Class_Name ()
 
static constexpr Version_t Class_Version ()
 
static const char * DeclFileName ()
 
- Static Public Member Functions inherited from TObject
static TClassClass ()
 
static const char * Class_Name ()
 
static constexpr Version_t Class_Version ()
 
static const char * DeclFileName ()
 
static Longptr_t GetDtorOnly ()
 Return destructor only flag.
 
static Bool_t GetObjectStat ()
 Get status of object stat flag.
 
static void SetDtorOnly (void *obj)
 Set destructor only flag.
 
static void SetObjectStat (Bool_t stat)
 Turn on/off tracking of objects in the TObjectTable.
 

Protected Types

typedef struct UnzipState UnzipState_t
 
- Protected Types inherited from TObject
enum  { kOnlyPrepStep = (1ULL << ( 3 )) }
 

Protected Attributes

bool fAsyncReading
 
Int_t fCycle
 
bool fEmpty
 
std::unique_ptr< TMutexfIOMutex
 
Int_t fNFound
 ! number of blocks that were found in the cache
 
Int_t fNMissed
 ! number of blocks that were not found in the cache and were unzipped
 
Int_t fNseekMax
 ! fNseek can change so we need to know its max size
 
Int_t fNStalls
 ! number of hits which caused a stall
 
Int_t fNUnzip
 ! number of blocks that were unzipped
 
bool fParallel
 Indicate if we want to activate the parallelism (for this instance)
 
Long64_t fUnzipBufferSize
 ! Max Size for the ready unzipped blocks (default is 2*fBufferSize)
 
Int_t fUnzipGroupSize
 ! Min accumulated size of a group of baskets ready to be unzipped by a IMT task
 
UnzipState_t fUnzipState
 
std::unique_ptr< ROOT::Experimental::TTaskGroupfUnzipTaskGroup
 
- Protected Attributes inherited from TTreeCache
bool fAutoCreated {false}
 ! true if cache was automatically created
 
TObjArrayfBranches {nullptr}
 ! List of branches to be stored in the cache
 
TListfBrNames {nullptr}
 ! list of branch names in the cache
 
Long64_t fCurrentClusterStart {-1}
 ! Start of the cluster(s) where the current content was picked out
 
bool fEnabled {true}
 ! cache enabled for cached reading
 
Long64_t fEntryCurrent {-1}
 ! current lowest entry number in the cache
 
Long64_t fEntryMax {1}
 ! last entry in the cache
 
Long64_t fEntryMin {0}
 ! first entry in the cache
 
Long64_t fEntryNext {-1}
 ! next entry number where cache must be filled
 
Int_t fFillTimes {0}
 ! how many times we can fill the current buffer
 
bool fFirstBuffer {true}
 ! true if first buffer is used for prefetching
 
Long64_t fFirstEntry {-1}
 ! save the value of the first entry
 
Long64_t fFirstMiss {-1}
 ! set to the event # of the first miss.
 
bool fFirstTime {true}
 ! save the fact that we processes the first entry
 
bool fIsLearning {true}
 ! true if cache is in learning mode
 
bool fIsManual {false}
 ! true if cache is StopLearningPhase was used
 
Long64_t fLastMiss {-1}
 ! set to the event # of the last miss.
 
bool fLearnPrefilling {false}
 ! true if we are in the process of executing LearnPrefill
 
std::unique_ptr< MissCachefMissCache
 ! Cache contents for misses
 
Int_t fNbranches {0}
 ! Number of branches in the cache
 
Long64_t fNextClusterStart {-1}
 ! End+1 of the cluster(s) where the current content was picked out
 
Int_t fNMissReadMiss {0}
 Number of blocks read and not found in either cache.
 
Int_t fNMissReadOk {0}
 Number of blocks read, not found in the primary cache, and found in the secondary cache.
 
Int_t fNMissReadPref {0}
 Number of blocks read into the secondary ("miss") cache.
 
Int_t fNReadMiss {0}
 Number of blocks read and not found in the cache.
 
Int_t fNReadOk {0}
 Number of blocks read and found in the cache.
 
Int_t fNReadPref {0}
 Number of blocks that were prefetched.
 
bool fOneTime {false}
 ! used in the learning phase
 
bool fOptimizeMisses {false}
 ! true if we should optimize cache misses.
 
EPrefillType fPrefillType
 Whether a pre-filling is enabled (and if applicable which type)
 
bool fReadDirectionSet {false}
 ! read direction established
 
bool fReverseRead {false}
 ! reading in reverse mode
 
TTreefTree {nullptr}
 ! pointer to the current Tree
 
- Protected Attributes inherited from TFileCacheRead
Bool_t fAsyncReading
 
Bool_t fBIsSorted
 
Bool_t fBIsTransferred
 
Int_tfBLen
 [fBNb]
 
Int_t fBNb
 
Int_t fBNseek
 
Int_t fBNtot
 
Long64_tfBPos
 [fBNb]
 
Long64_tfBSeek
 [fBNseek]
 
Int_tfBSeekIndex
 [fBNseek]
 
Int_tfBSeekLen
 [fBNseek]
 
Int_tfBSeekPos
 [fBNseek]
 
Int_t fBSeekSize
 
Long64_tfBSeekSort
 [fBNseek]
 
Int_tfBSeekSortLen
 [fBNseek]
 
char * fBuffer
 [fBufferSize] buffer of contiguous prefetched blocks
 
Int_t fBufferLen
 Current buffer length (<= fBufferSize)
 
Int_t fBufferSize
 Allocated size of fBuffer (at a given time)
 
Int_t fBufferSizeMin
 Original size of fBuffer.
 
Long64_t fBytesRead
 Number of bytes read for this cache.
 
Long64_t fBytesReadExtra
 Number of extra bytes (overhead) read by the readahead buffer.
 
Bool_t fEnablePrefetching
 reading by prefetching asynchronously
 
TFilefFile
 Pointer to file.
 
Bool_t fIsSorted
 True if fSeek array is sorted.
 
Bool_t fIsTransferred
 True when fBuffer contains something valid.
 
Int_tfLen
 [fNb] Length of long buffers
 
Int_t fNb
 Number of long buffers.
 
Long64_t fNoCacheBytesRead
 Number of bytes read by basket to fill cached tree.
 
Int_t fNoCacheReadCalls
 Number of read calls by basket to fill cached tree.
 
Int_t fNseek
 Number of blocks to be prefetched.
 
Int_t fNtot
 Total size of prefetched blocks.
 
Long64_tfPos
 [fNb] start of long buffers
 
TFilePrefetchfPrefetch
 ! Object that does the asynchronous reading in another thread
 
Long64_t fPrefetchedBlocks
 Number of blocks prefetched.
 
Int_t fReadCalls
 Number of read calls for this cache.
 
Long64_tfSeek
 [fNseek] Position on file of buffers to be prefetched
 
Int_tfSeekIndex
 [fNseek] sorted index table of fSeek
 
Int_tfSeekLen
 [fNseek] Length of buffers to be prefetched
 
Int_tfSeekPos
 [fNseek] Position of sorted blocks in fBuffer
 
Int_t fSeekSize
 Allocated size of fSeek.
 
Long64_tfSeekSort
 [fNseek] Position on file of buffers to be prefetched (sorted)
 
Int_tfSeekSortLen
 [fNseek] Length of buffers to be prefetched (sorted)
 

Static Protected Attributes

static TTreeCacheUnzip::EParUnzipMode fgParallel = TTreeCacheUnzip::kDisable
 Indicate if we want to activate the parallelism.
 
static Double_t fgRelBuffSize = .5
 This is the percentage of the TTreeCacheUnzip that will be used.
 
- Static Protected Attributes inherited from TTreeCache
static Int_t fgLearnEntries = 100
 number of entries used for learning mode
 

Private Member Functions

 TTreeCacheUnzip (const TTreeCacheUnzip &)=delete
 
void Init ()
 Initialization procedure common to all the constructors.
 
TTreeCacheUnzipoperator= (const TTreeCacheUnzip &)=delete
 

Private Attributes

char * fCompBuffer
 
Int_t fCompBufferSize
 

Additional Inherited Members

- Protected Member Functions inherited from TFileCacheRead
void SetEnablePrefetchingImpl (Bool_t setPrefetching=kFALSE)
 TFileCacheRead implementation of SetEnablePrefetching.
 
- Protected Member Functions inherited from TObject
virtual void DoError (int level, const char *location, const char *fmt, va_list va) const
 Interface to ErrorHandler (protected).
 
void MakeZombie ()
 

#include <TTreeCacheUnzip.h>

Inheritance diagram for TTreeCacheUnzip:
[legend]

Member Typedef Documentation

◆ UnzipState_t

typedef struct UnzipState TTreeCacheUnzip::UnzipState_t
protected

Definition at line 77 of file TTreeCacheUnzip.h.

Member Enumeration Documentation

◆ EParUnzipMode

Enumerator
kEnable 
kDisable 
kForce 

Definition at line 40 of file TTreeCacheUnzip.h.

◆ EUnzipState

Enumerator
kUntouched 
kProgress 
kFinished 

Definition at line 43 of file TTreeCacheUnzip.h.

Constructor & Destructor Documentation

◆ TTreeCacheUnzip() [1/3]

TTreeCacheUnzip::TTreeCacheUnzip ( const TTreeCacheUnzip )
privatedelete

◆ TTreeCacheUnzip() [2/3]

TTreeCacheUnzip::TTreeCacheUnzip ( )

Definition at line 159 of file TTreeCacheUnzip.cxx.

◆ TTreeCacheUnzip() [3/3]

TTreeCacheUnzip::TTreeCacheUnzip ( TTree tree,
Int_t  buffersize = 0 
)

Constructor.

Definition at line 178 of file TTreeCacheUnzip.cxx.

◆ ~TTreeCacheUnzip()

TTreeCacheUnzip::~TTreeCacheUnzip ( )
override

Destructor. (in general called by the TFile destructor)

Definition at line 235 of file TTreeCacheUnzip.cxx.

Member Function Documentation

◆ AddBranch() [1/2]

Int_t TTreeCacheUnzip::AddBranch ( const char *  branch,
bool  subbranches = false 
)
overridevirtual

Add a branch to the list of branches to be stored in the cache this function is called by TBranch::GetBasket Returns:

  • 0 branch added or already included
  • -1 on error

Reimplemented from TTreeCache.

Definition at line 260 of file TTreeCacheUnzip.cxx.

◆ AddBranch() [2/2]

Int_t TTreeCacheUnzip::AddBranch ( TBranch b,
bool  subbranches = false 
)
overridevirtual

Add a branch to the list of branches to be stored in the cache this function is called by TBranch::GetBasket Returns:

  • 0 branch added or already included
  • -1 on error

Reimplemented from TTreeCache.

Definition at line 248 of file TTreeCacheUnzip.cxx.

◆ Class()

static TClass * TTreeCacheUnzip::Class ( )
static
Returns
TClass describing this class

◆ Class_Name()

static const char * TTreeCacheUnzip::Class_Name ( )
static
Returns
Name of this class

◆ Class_Version()

static constexpr Version_t TTreeCacheUnzip::Class_Version ( )
inlinestaticconstexpr
Returns
Version of this class

Definition at line 159 of file TTreeCacheUnzip.h.

◆ CreateTasks()

Int_t TTreeCacheUnzip::CreateTasks ( )

We create a TTaskGroup and asynchronously maps each group of baskets(> 100 kB in total) to a task.

In TTaskGroup, we use TThreadExecutor to do the actually work of unzipping a group of basket. The purpose of creating TTaskGroup is to avoid competing with main thread.

Definition at line 614 of file TTreeCacheUnzip.cxx.

◆ DeclFileName()

static const char * TTreeCacheUnzip::DeclFileName ( )
inlinestatic
Returns
Name of the file containing the class declaration

Definition at line 159 of file TTreeCacheUnzip.h.

◆ FillBuffer()

bool TTreeCacheUnzip::FillBuffer ( )
overridevirtual

Fill the cache buffer with the branches in the cache.

Reimplemented from TTreeCache.

Definition at line 267 of file TTreeCacheUnzip.cxx.

◆ GetNFound()

Int_t TTreeCacheUnzip::GetNFound ( )
inline

Definition at line 154 of file TTreeCacheUnzip.h.

◆ GetNMissed()

Int_t TTreeCacheUnzip::GetNMissed ( )
inline

Definition at line 153 of file TTreeCacheUnzip.h.

◆ GetNUnzip()

Int_t TTreeCacheUnzip::GetNUnzip ( )
inline

Definition at line 152 of file TTreeCacheUnzip.h.

◆ GetParallelUnzip()

TTreeCacheUnzip::EParUnzipMode TTreeCacheUnzip::GetParallelUnzip ( )
static

Static function that returns the parallel option (to indicate an additional thread)

Definition at line 408 of file TTreeCacheUnzip.cxx.

◆ GetRecordHeader()

Int_t TTreeCacheUnzip::GetRecordHeader ( char *  buf,
Int_t  maxbytes,
Int_t nbytes,
Int_t objlen,
Int_t keylen 
)

Read the logical record header from the buffer buf.

That must be the pointer tho the header part not the object by itself and must contain data of at least maxbytes Returns nread;

In output arguments:

  • nbytes : number of bytes in record if negative, this is a deleted record if 0, cannot read record, wrong value of argument first
  • objlen : uncompressed object size
  • keylen : length of logical record header

Note that the arguments objlen and keylen are returned only if maxbytes >=16 Note: This was adapted from TFile... so some things dont apply

Definition at line 470 of file TTreeCacheUnzip.cxx.

◆ GetUnzipBuffer()

Int_t TTreeCacheUnzip::GetUnzipBuffer ( char **  buf,
Long64_t  pos,
Int_t  len,
bool free 
)
overridevirtual

We try to read a buffer that has already been unzipped Returns -1 in case of read failure, 0 in case it's not in the cache and n>0 in case read from cache (number of bytes copied).

pos and len are the original values as were passed to ReadBuffer but instead we will return the inflated buffer. Note!! : If *buf == 0 we will allocate the buffer and it will be the responsibility of the caller to free it... it is useful for example to pass it to the creator of TBuffer

Reimplemented from TFileCacheRead.

Definition at line 669 of file TTreeCacheUnzip.cxx.

◆ GetUnzipGroupSize()

Int_t TTreeCacheUnzip::GetUnzipGroupSize ( )
inline

Definition at line 142 of file TTreeCacheUnzip.h.

◆ Init()

void TTreeCacheUnzip::Init ( )
private

Initialization procedure common to all the constructors.

Definition at line 196 of file TTreeCacheUnzip.cxx.

◆ IsA()

TClass * TTreeCacheUnzip::IsA ( ) const
inlineoverridevirtual
Returns
TClass describing current object

Reimplemented from TTreeCache.

Definition at line 159 of file TTreeCacheUnzip.h.

◆ IsParallelUnzip()

bool TTreeCacheUnzip::IsParallelUnzip ( )
static

Static function that tells wether the multithreading unzipping is activated.

Definition at line 416 of file TTreeCacheUnzip.cxx.

◆ operator=()

TTreeCacheUnzip & TTreeCacheUnzip::operator= ( const TTreeCacheUnzip )
privatedelete

◆ Print()

void TTreeCacheUnzip::Print ( Option_t option = "") const
overridevirtual

Print cache statistics.

Like:

******TreeCache statistics for file: cms2.root ******
Number of branches in the cache ...: 1093
Cache Efficiency ..................: 0.997372
Cache Efficiency Rel...............: 1.000000
Learn entries......................: 100
Reading............................: 72761843 bytes in 7 transactions
Readahead..........................: 256000 bytes with overhead = 0 bytes
Average transaction................: 10394.549000 Kbytes
Number of blocks in current cache..: 210, total size: 6280352
size_t size(const MatrixT &matrix)
retrieve the size of a square matrix
static unsigned int total
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 bytes
  • if option = "a" the list of blocks in the cache is printed see also class TTreePerfStats.
  • if option contains 'cachedbranches', the list of branches being cached is printed.

Reimplemented from TTreeCache.

Definition at line 948 of file TTreeCacheUnzip.cxx.

◆ ReadBufferExt()

Int_t TTreeCacheUnzip::ReadBufferExt ( char *  buf,
Long64_t  pos,
Int_t  len,
Int_t loc 
)
overridevirtual

Reimplemented from TFileCacheRead.

Definition at line 962 of file TTreeCacheUnzip.cxx.

◆ ResetCache()

void TTreeCacheUnzip::ResetCache ( )
overridevirtual

This will delete the list of buffers that are in the unzipping cache and will reset certain values in the cache.

This name is ambiguos because the method doesn't reset the whole cache, only the part related to the unzipping Note: This method is completely different from TTreeCache::ResetCache(), in that method we were cleaning the prefetching buffer while here we delete the information about the unzipped buffers

Reimplemented from TTreeCache.

Definition at line 502 of file TTreeCacheUnzip.cxx.

◆ SetBufferSize()

Int_t TTreeCacheUnzip::SetBufferSize ( Long64_t  buffersize)
overridevirtual

Change the underlying buffer size of the cache.

The buffersize might be clamped, see TFileCacheRead::SetBufferSize Returns:

  • 0 if the buffer content is still available
  • 1 if some or all of the buffer content has been made unavailable
  • -1 on error

Reimplemented from TTreeCache.

Definition at line 360 of file TTreeCacheUnzip.cxx.

◆ SetEntryRange()

void TTreeCacheUnzip::SetEntryRange ( Long64_t  emin,
Long64_t  emax 
)
overridevirtual

Set the minimum and maximum entry number to be processed this information helps to optimize the number of baskets to read when prefetching the branch buffers.

Reimplemented from TTreeCache.

Definition at line 376 of file TTreeCacheUnzip.cxx.

◆ SetParallelUnzip()

Int_t TTreeCacheUnzip::SetParallelUnzip ( TTreeCacheUnzip::EParUnzipMode  option = TTreeCacheUnzip::kEnable)
static

Static function that (de)activates multithreading unzipping.

The possible options are:

  • kEnable Enable it, which causes an automatic detection and launches the additional thread if the number of cores in the machine is greater than one
  • kDisable Disable will not activate the additional thread.
  • kForce Force will start the additional thread even if there is only one core. the default will be taken as kEnable.

Returns 0 if there was an error, 1 otherwise.

Definition at line 437 of file TTreeCacheUnzip.cxx.

◆ SetUnzipBufferSize()

void TTreeCacheUnzip::SetUnzipBufferSize ( Long64_t  bufferSize)

Sets the size for the unzipping cache... by default it should be two times the size of the prefetching cache.

Definition at line 840 of file TTreeCacheUnzip.cxx.

◆ SetUnzipGroupSize()

void TTreeCacheUnzip::SetUnzipGroupSize ( Int_t  groupSize)
inline

Definition at line 146 of file TTreeCacheUnzip.h.

◆ SetUnzipRelBufferSize()

void TTreeCacheUnzip::SetUnzipRelBufferSize ( Float_t  relbufferSize)
static

static function: Sets the unzip relative buffer size

Definition at line 831 of file TTreeCacheUnzip.cxx.

◆ StopLearningPhase()

void TTreeCacheUnzip::StopLearningPhase ( )
overridevirtual

It's the same as TTreeCache::StopLearningPhase but we guarantee that we start the unzipping just after getting the buffers.

Reimplemented from TTreeCache.

Definition at line 385 of file TTreeCacheUnzip.cxx.

◆ Streamer()

void TTreeCacheUnzip::Streamer ( TBuffer R__b)
overridevirtual

Stream an object of class TObject.

Reimplemented from TTreeCache.

◆ StreamerNVirtual()

void TTreeCacheUnzip::StreamerNVirtual ( TBuffer ClassDef_StreamerNVirtual_b)
inline

Definition at line 159 of file TTreeCacheUnzip.h.

◆ UnzipBuffer()

Int_t TTreeCacheUnzip::UnzipBuffer ( char **  dest,
char *  src 
)

Unzips a ROOT specific buffer... by reading the header at the beginning.

returns the size of the inflated buffer or -1 if error Note!! : If *dest == 0 we will allocate the buffer and it will be the responsibility of the caller to free it... it is useful for example to pass it to the creator of TBuffer src is the original buffer with the record (header+compressed data) *dest is the inflated buffer (including the header)

Definition at line 854 of file TTreeCacheUnzip.cxx.

◆ UnzipCache()

Int_t TTreeCacheUnzip::UnzipCache ( Int_t  index)

This inflates a basket in the cache.

. passing the data to a new buffer that will only wait there to be read... This function is responsible to update corresponding elements in fUnzipStatus, fUnzipChunks and fUnzipLen. Since we use atomic variables in fUnzipStatus to exclusively unzip the basket, we must update fUnzipStatus after fUnzipChunks and fUnzipLen and make sure fUnzipChunks and fUnzipLen are ready before main thread fetch the data.

Definition at line 527 of file TTreeCacheUnzip.cxx.

◆ UpdateBranches()

void TTreeCacheUnzip::UpdateBranches ( TTree tree)
overridevirtual

update pointer to current Tree and recompute pointers to the branches in the cache

Reimplemented from TTreeCache.

Definition at line 393 of file TTreeCacheUnzip.cxx.

Member Data Documentation

◆ fAsyncReading

bool TTreeCacheUnzip::fAsyncReading
protected

Definition at line 81 of file TTreeCacheUnzip.h.

◆ fCompBuffer

char* TTreeCacheUnzip::fCompBuffer
private

Definition at line 112 of file TTreeCacheUnzip.h.

◆ fCompBufferSize

Int_t TTreeCacheUnzip::fCompBufferSize
private

Definition at line 113 of file TTreeCacheUnzip.h.

◆ fCycle

Int_t TTreeCacheUnzip::fCycle
protected

Definition at line 83 of file TTreeCacheUnzip.h.

◆ fEmpty

bool TTreeCacheUnzip::fEmpty
protected

Definition at line 82 of file TTreeCacheUnzip.h.

◆ fgParallel

TTreeCacheUnzip::EParUnzipMode TTreeCacheUnzip::fgParallel = TTreeCacheUnzip::kDisable
staticprotected

Indicate if we want to activate the parallelism.

Definition at line 88 of file TTreeCacheUnzip.h.

◆ fgRelBuffSize

Double_t TTreeCacheUnzip::fgRelBuffSize = .5
staticprotected

This is the percentage of the TTreeCacheUnzip that will be used.

Definition at line 100 of file TTreeCacheUnzip.h.

◆ fIOMutex

std::unique_ptr<TMutex> TTreeCacheUnzip::fIOMutex
protected

Definition at line 86 of file TTreeCacheUnzip.h.

◆ fNFound

Int_t TTreeCacheUnzip::fNFound
protected

! number of blocks that were found in the cache

Definition at line 103 of file TTreeCacheUnzip.h.

◆ fNMissed

Int_t TTreeCacheUnzip::fNMissed
protected

! number of blocks that were not found in the cache and were unzipped

Definition at line 104 of file TTreeCacheUnzip.h.

◆ fNseekMax

Int_t TTreeCacheUnzip::fNseekMax
protected

! fNseek can change so we need to know its max size

Definition at line 96 of file TTreeCacheUnzip.h.

◆ fNStalls

Int_t TTreeCacheUnzip::fNStalls
protected

! number of hits which caused a stall

Definition at line 105 of file TTreeCacheUnzip.h.

◆ fNUnzip

Int_t TTreeCacheUnzip::fNUnzip
protected

! number of blocks that were unzipped

Definition at line 106 of file TTreeCacheUnzip.h.

◆ fParallel

bool TTreeCacheUnzip::fParallel
protected

Indicate if we want to activate the parallelism (for this instance)

Definition at line 84 of file TTreeCacheUnzip.h.

◆ fUnzipBufferSize

Long64_t TTreeCacheUnzip::fUnzipBufferSize
protected

! Max Size for the ready unzipped blocks (default is 2*fBufferSize)

Definition at line 98 of file TTreeCacheUnzip.h.

◆ fUnzipGroupSize

Int_t TTreeCacheUnzip::fUnzipGroupSize
protected

! Min accumulated size of a group of baskets ready to be unzipped by a IMT task

Definition at line 97 of file TTreeCacheUnzip.h.

◆ fUnzipState

UnzipState_t TTreeCacheUnzip::fUnzipState
protected

Definition at line 78 of file TTreeCacheUnzip.h.

◆ fUnzipTaskGroup

std::unique_ptr<ROOT::Experimental::TTaskGroup> TTreeCacheUnzip::fUnzipTaskGroup
protected

Definition at line 92 of file TTreeCacheUnzip.h.

Libraries for TTreeCacheUnzip:

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