TTreeCacheUnzip Class Reference

#include <TTreeCacheUnzip.h>

Inheritance diagram for TTreeCacheUnzip:

TTreeCache TTreeCache TFileCacheRead TFileCacheRead TFileCacheRead TFileCacheRead TObject TObject TObject TObject TObject TObject TObject TObject List of all members.

Public Types

enum  EParUnzipMode
enum  EParUnzipMode

Public Member Functions

 TTreeCacheUnzip ()
 TTreeCacheUnzip (TTree *tree, Int_t buffersize=0)
virtual ~TTreeCacheUnzip ()
virtual void AddBranch (TBranch *b, Bool_t subbranches=kFALSE)
virtual void AddBranch (const char *branch, Bool_t subbranches=kFALSE)
Bool_t FillBuffer ()
virtual Int_t ReadBufferExt (char *buf, Long64_t pos, Int_t len, Int_t &loc)
void SetEntryRange (Long64_t emin, Long64_t emax)
virtual void StopLearningPhase ()
void UpdateBranches (TTree *tree, Bool_t owner=kFALSE)
Bool_t IsActiveThread ()
Bool_t IsQueueEmpty ()
void WaitUnzipStartSignal ()
void SendUnzipStartSignal (Bool_t broadcast)
Int_t GetRecordHeader (char *buf, Int_t maxbytes, Int_t &nbytes, Int_t &objlen, Int_t &keylen)
virtual void ResetCache ()
virtual Int_t GetUnzipBuffer (char **buf, Long64_t pos, Int_t len, Bool_t *free)
void SetUnzipBufferSize (Long64_t bufferSize)
Int_t UnzipBuffer (char **dest, char *src)
Int_t UnzipCache (Int_t &startindex, Int_t &locbuffsz, char *&locbuff)
Int_t GetNUnzip ()
Int_t GetNFound ()
Int_t GetNMissed ()
void Print (Option_t *option="") const
 TTreeCacheUnzip ()
 TTreeCacheUnzip (TTree *tree, Int_t buffersize=0)
virtual ~TTreeCacheUnzip ()
virtual void AddBranch (TBranch *b, Bool_t subbranches=kFALSE)
virtual void AddBranch (const char *branch, Bool_t subbranches=kFALSE)
Bool_t FillBuffer ()
virtual Int_t ReadBufferExt (char *buf, Long64_t pos, Int_t len, Int_t &loc)
void SetEntryRange (Long64_t emin, Long64_t emax)
virtual void StopLearningPhase ()
void UpdateBranches (TTree *tree, Bool_t owner=kFALSE)
Bool_t IsActiveThread ()
Bool_t IsQueueEmpty ()
void WaitUnzipStartSignal ()
void SendUnzipStartSignal (Bool_t broadcast)
Int_t GetRecordHeader (char *buf, Int_t maxbytes, Int_t &nbytes, Int_t &objlen, Int_t &keylen)
virtual void ResetCache ()
virtual Int_t GetUnzipBuffer (char **buf, Long64_t pos, Int_t len, Bool_t *free)
void SetUnzipBufferSize (Long64_t bufferSize)
Int_t UnzipBuffer (char **dest, char *src)
Int_t UnzipCache (Int_t &startindex, Int_t &locbuffsz, char *&locbuff)
Int_t GetNUnzip ()
Int_t GetNFound ()
Int_t GetNMissed ()
void Print (Option_t *option="") const

Static Public Member Functions

static EParUnzipMode GetParallelUnzip ()
static Bool_t IsParallelUnzip ()
static Int_t SetParallelUnzip (TTreeCacheUnzip::EParUnzipMode option=TTreeCacheUnzip::kEnable)
static void SetUnzipRelBufferSize (Float_t relbufferSize)
static void * UnzipLoop (void *arg)
static EParUnzipMode GetParallelUnzip ()
static Bool_t IsParallelUnzip ()
static Int_t SetParallelUnzip (TTreeCacheUnzip::EParUnzipMode option=TTreeCacheUnzip::kEnable)
static void SetUnzipRelBufferSize (Float_t relbufferSize)
static void * UnzipLoop (void *arg)

Protected Attributes

TThread * fUnzipThread [10]
Bool_t fActiveThread
TCondition * fUnzipStartCondition
TCondition * fUnzipDoneCondition
Bool_t fParallel
Bool_t fAsyncReading
TMutex * fMutexList
TMutex * fIOMutex
Int_t fCycle
Int_t fLastReadPos
Int_t fBlocksToGo
Int_t * fUnzipLen
char ** fUnzipChunks
 [fNseek] Length of the unzipped buffers
Byte_t * fUnzipStatus
 [fNseek] Individual unzipped chunks. Their summed size is kept under control.
Long64_t fTotalUnzipBytes
 [fNSeek] For each blk, tells us if it's unzipped or pending
Int_t fNseekMax
 The total sum of the currently unzipped blks.
Long64_t fUnzipBufferSize
 fNseek can change so we need to know its max size
Int_t fNUnzip
Int_t fNFound
 number of blocks that were unzipped
Int_t fNStalls
 number of blocks that were found in the cache
Int_t fNMissed
 number of hits which caused a stall
std::queue< Int_t > fActiveBlks
 number of blocks that were not found in the cache and were unzipped
TThread * fUnzipThread [10]
TCondition * fUnzipStartCondition
TCondition * fUnzipDoneCondition
TMutex * fMutexList
TMutex * fIOMutex
Int_t * fUnzipLen
char ** fUnzipChunks
 [fNseek] Length of the unzipped buffers
Byte_t * fUnzipStatus
 [fNseek] Individual unzipped chunks. Their summed size is kept under control.
std::queue< Int_t > fActiveBlks
 number of blocks that were not found in the cache and were unzipped

Static Protected Attributes

static TTreeCacheUnzip::EParUnzipMode fgParallel
static Double_t fgRelBuffSize
 Max Size for the ready unzipped blocks (default is 2*fBufferSize).

Private Member Functions

 TTreeCacheUnzip (const TTreeCacheUnzip &)
TTreeCacheUnzip & operator= (const TTreeCacheUnzip &)
void Init ()
Int_t StartThreadUnzip (Int_t nthreads)
Int_t StopThreadUnzip ()
 TTreeCacheUnzip (const TTreeCacheUnzip &)
TTreeCacheUnzip & operator= (const TTreeCacheUnzip &)
void Init ()
Int_t StartThreadUnzip (Int_t nthreads)
Int_t StopThreadUnzip ()

Private Attributes

char * fCompBuffer
Int_t fCompBufferSize
char * fCompBuffer

Detailed Description

Definition at line 41 of file TTreeCacheUnzip.h.

Member Enumeration Documentation

enum TTreeCacheUnzip::EParUnzipMode

Definition at line 45 of file TTreeCacheUnzip.h.

enum TTreeCacheUnzip::EParUnzipMode

Definition at line 45 of file TTreeCacheUnzip.h.

Constructor & Destructor Documentation

TTreeCacheUnzip::TTreeCacheUnzip ( const TTreeCacheUnzip &   )  [private]

TTreeCacheUnzip::TTreeCacheUnzip (  ) 

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

Definition at line 100 of file TTreeCacheUnzip.cxx.

References Init().

TTreeCacheUnzip::~TTreeCacheUnzip (  )  [virtual]

Definition at line 170 of file TTreeCacheUnzip.cxx.

References fIOMutex, fMutexList, fUnzipChunks, fUnzipDoneCondition, fUnzipLen, fUnzipStartCondition, fUnzipStatus, IsActiveThread(), ResetCache(), and StopThreadUnzip().

TTreeCacheUnzip::TTreeCacheUnzip ( const TTreeCacheUnzip &   )  [private]

TTreeCacheUnzip::TTreeCacheUnzip (  ) 

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

virtual TTreeCacheUnzip::~TTreeCacheUnzip (  )  [virtual]

Member Function Documentation

TTreeCacheUnzip& TTreeCacheUnzip::operator= ( const TTreeCacheUnzip &   )  [private]

void TTreeCacheUnzip::Init (  )  [private]

Definition at line 123 of file TTreeCacheUnzip.cxx.

References fAsyncReading, fCompBuffer, fCompBufferSize, TFileCacheRead::fFile, fgParallel, fgRelBuffSize, fIOMutex, fMutexList, fParallel, fTotalUnzipBytes, fUnzipBufferSize, fUnzipDoneCondition, fUnzipStartCondition, fUnzipThread, gDebug, gEnv, TFileCacheRead::GetBufferSize(), TSystem::GetSysInfo(), TEnv::GetValue(), gSystem, i, info, TObject::Info(), kDisable, kEnable, kFALSE, kForce, kTRUE, Long64_t, TFile::ReadBufferAsync(), StartThreadUnzip(), THREADCNT, and TObject::Warning().

Referenced by TTreeCacheUnzip().

Int_t TTreeCacheUnzip::StartThreadUnzip ( Int_t  nthreads  )  [private]

Definition at line 450 of file TTreeCacheUnzip.cxx.

References d, TObject::Error(), fActiveThread, fUnzipThread, gDebug, i, TObject::Info(), kTRUE, TThread::Run(), and UnzipLoop().

Referenced by Init().

Int_t TTreeCacheUnzip::StopThreadUnzip (  )  [private]

Definition at line 490 of file TTreeCacheUnzip.cxx.

References Exists, fActiveThread, fUnzipThread, i, kFALSE, kTRUE, and SendUnzipStartSignal().

Referenced by ~TTreeCacheUnzip().

void TTreeCacheUnzip::AddBranch ( TBranch *  b,
Bool_t  subbranches = kFALSE 
) [virtual]

Reimplemented from TTreeCache.

Definition at line 195 of file TTreeCacheUnzip.cxx.

References TTreeCache::AddBranch(), b, fMutexList, and R__LOCKGUARD.

void TTreeCacheUnzip::AddBranch ( const char *  branch,
Bool_t  subbranches = kFALSE 
) [virtual]

Reimplemented from TTreeCache.

Definition at line 205 of file TTreeCacheUnzip.cxx.

References TTreeCache::AddBranch(), fMutexList, and R__LOCKGUARD.

Bool_t TTreeCacheUnzip::FillBuffer (  )  [virtual]

Reimplemented from TTreeCache.

Definition at line 215 of file TTreeCacheUnzip.cxx.

References b, chain, xmlio::Class, elist, entries, entry, TTreeCache::fBranches, TFileCacheRead::fBufferSizeMin, TTreeCache::fEntryCurrent, TTreeCache::fEntryMax, TTreeCache::fEntryNext, TFileCacheRead::fFile, TTreeCache::fIsLearning, TFileCacheRead::fIsTransferred, fMutexList, TTreeCache::fNbranches, TTreeCache::fNReadPref, TFileCacheRead::fNseek, TFileCacheRead::fNtot, TTreeCache::fOwner, TTreeCache::fZipBytes, gDebug, TTree::GetAutoFlush(), TTree::GetEntries(), TTree::GetEventList(), TObject::GetName(), TTree::GetReadEntry(), TTreeCache::GetTree(), TChain::GetTreeNumber(), TChain::GetTreeOffset(), TTree::GetZipBytes(), i, j, kFALSE, kTRUE, len, Long64_t, TFileCacheRead::Prefetch(), R__LOCKGUARD, ResetCache(), t, and TObjArray::UncheckedAt().

Int_t TTreeCacheUnzip::ReadBufferExt ( char *  buf,
Long64_t  pos,
Int_t  len,
Int_t &  loc 
) [virtual]

Reimplemented from TFileCacheRead.

Definition at line 1274 of file TTreeCacheUnzip.cxx.

References fIOMutex, R__LOCKGUARD, and TFileCacheRead::ReadBufferExt().

Referenced by GetUnzipBuffer(), and UnzipCache().

void TTreeCacheUnzip::SetEntryRange ( Long64_t  emin,
Long64_t  emax 
) [virtual]

Reimplemented from TTreeCache.

Definition at line 321 of file TTreeCacheUnzip.cxx.

References fMutexList, R__LOCKGUARD, and TTreeCache::SetEntryRange().

void TTreeCacheUnzip::StopLearningPhase (  )  [virtual]

Reimplemented from TTreeCache.

Definition at line 332 of file TTreeCacheUnzip.cxx.

References fMutexList, R__LOCKGUARD, and TTreeCache::StopLearningPhase().

void TTreeCacheUnzip::UpdateBranches ( TTree *  tree,
Bool_t  owner = kFALSE 
) [virtual]

Reimplemented from TTreeCache.

Definition at line 344 of file TTreeCacheUnzip.cxx.

References fMutexList, R__LOCKGUARD, and TTreeCache::UpdateBranches().

TTreeCacheUnzip::EParUnzipMode TTreeCacheUnzip::GetParallelUnzip (  )  [static]

Definition at line 359 of file TTreeCacheUnzip.cxx.

References fgParallel.

Referenced by G__G__Tree_284_0_15(), and G__setup_memfuncTTreeCacheUnzip().

Bool_t TTreeCacheUnzip::IsParallelUnzip (  )  [static]

Definition at line 368 of file TTreeCacheUnzip.cxx.

References fgParallel, kEnable, kFALSE, kForce, and kTRUE.

Referenced by G__G__Tree_284_0_16(), G__setup_memfuncTTreeCacheUnzip(), and TTree::SetCacheSize().

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

Definition at line 425 of file TTreeCacheUnzip.cxx.

References fgParallel, kDisable, kEnable, and kForce.

Referenced by G__G__Tree_284_0_17(), G__setup_memfuncTTreeCacheUnzip(), TTree::SetParallelUnzip(), and TEventIterTree::TEventIterTree().

Bool_t TTreeCacheUnzip::IsActiveThread (  ) 

Definition at line 380 of file TTreeCacheUnzip.cxx.

References fActiveThread, fMutexList, and R__LOCKGUARD.

Referenced by GetUnzipBuffer(), UnzipCache(), UnzipLoop(), and ~TTreeCacheUnzip().

Bool_t TTreeCacheUnzip::IsQueueEmpty (  ) 

Definition at line 391 of file TTreeCacheUnzip.cxx.

References TTreeCache::fIsLearning, fMutexList, kFALSE, kTRUE, and R__LOCKGUARD.

void TTreeCacheUnzip::WaitUnzipStartSignal (  ) 

Definition at line 403 of file TTreeCacheUnzip.cxx.

References fUnzipStartCondition, and TCondition::TimedWaitRelative().

Referenced by UnzipLoop().

void TTreeCacheUnzip::SendUnzipStartSignal ( Bool_t  broadcast  ) 

Definition at line 411 of file TTreeCacheUnzip.cxx.

References TCondition::Broadcast(), fUnzipStartCondition, gDebug, TObject::Info(), and TCondition::Signal().

Referenced by GetUnzipBuffer(), ResetCache(), and StopThreadUnzip().

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

Definition at line 579 of file TTreeCacheUnzip.cxx.

References frombuf().

Referenced by UnzipBuffer(), and UnzipCache().

void TTreeCacheUnzip::ResetCache (  )  [virtual]

Reimplemented from TTreeCache.

Definition at line 617 of file TTreeCacheUnzip.cxx.

References fActiveBlks, fBlocksToGo, fCycle, fLastReadPos, fMutexList, TFileCacheRead::fNseek, fNseekMax, fTotalUnzipBytes, fUnzipChunks, fUnzipLen, fUnzipStatus, gDebug, i, TObject::Info(), kTRUE, R__LOCKGUARD, TThread::SelfId(), and SendUnzipStartSignal().

Referenced by FillBuffer(), and ~TTreeCacheUnzip().

Int_t TTreeCacheUnzip::GetUnzipBuffer ( char **  buf,
Long64_t  pos,
Int_t  len,
Bool_t *  free 
) [virtual]

Reimplemented from TFileCacheRead.

Definition at line 685 of file TTreeCacheUnzip.cxx.

References TMath::BinarySearch(), fBlocksToGo, fCompBuffer, fCompBufferSize, fCycle, TFileCacheRead::fFile, fIOMutex, TTreeCache::fIsLearning, TFileCacheRead::fIsTransferred, fLastReadPos, fMutexList, fNFound, fNMissed, TFileCacheRead::fNseek, fNseekMax, fNStalls, fParallel, TFileCacheRead::fSeekIndex, TFileCacheRead::fSeekSort, fTotalUnzipBytes, fUnzipBufferSize, fUnzipChunks, fUnzipDoneCondition, fUnzipLen, fUnzipStatus, gDebug, i, TObject::Info(), IsActiveThread(), kFALSE, kTRUE, R__LOCKGUARD, TFile::ReadBuffer(), ReadBufferExt(), TFile::Seek(), SendUnzipStartSignal(), TCondition::TimedWaitRelative(), and UnzipBuffer().

void TTreeCacheUnzip::SetUnzipBufferSize ( Long64_t  bufferSize  ) 

Definition at line 934 of file TTreeCacheUnzip.cxx.

References fMutexList, fUnzipBufferSize, and R__LOCKGUARD.

void TTreeCacheUnzip::SetUnzipRelBufferSize ( Float_t  relbufferSize  )  [static]

Definition at line 924 of file TTreeCacheUnzip.cxx.

References fgRelBuffSize.

Referenced by G__G__Tree_284_0_26(), G__setup_memfuncTTreeCacheUnzip(), and TTree::SetParallelUnzip().

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

Definition at line 944 of file TTreeCacheUnzip.cxx.

References TObject::Error(), TTreeCache::fBranches, TFileCacheRead::fFile, gDebug, GetRecordHeader(), TFile::GetVersion(), TObject::Info(), kFALSE, kTRUE, l, R__unzip(), R__unzip_header(), and TObjArray::UncheckedAt().

Referenced by GetUnzipBuffer(), and UnzipCache().

Int_t TTreeCacheUnzip::UnzipCache ( Int_t &  startindex,
Int_t &  locbuffsz,
char *&  locbuff 
)

Definition at line 1045 of file TTreeCacheUnzip.cxx.

References fActiveBlks, fBlocksToGo, fCycle, TTreeCache::fIsLearning, TFileCacheRead::fIsTransferred, fMutexList, TFileCacheRead::fNseek, fNUnzip, TFileCacheRead::fSeek, TFileCacheRead::fSeekLen, fTotalUnzipBytes, fUnzipBufferSize, fUnzipChunks, fUnzipDoneCondition, fUnzipLen, fUnzipStatus, gDebug, GetRecordHeader(), TObject::Info(), IsActiveThread(), len, Long64_t, ptr, R__LOCKGUARD, ReadBufferExt(), TCondition::Signal(), THREADCNT, and UnzipBuffer().

Referenced by UnzipLoop().

Int_t TTreeCacheUnzip::GetNUnzip (  )  [inline]

Definition at line 129 of file TTreeCacheUnzip.h.

References fNUnzip.

Int_t TTreeCacheUnzip::GetNFound (  )  [inline]

Definition at line 130 of file TTreeCacheUnzip.h.

References fNFound.

Int_t TTreeCacheUnzip::GetNMissed (  )  [inline]

Definition at line 131 of file TTreeCacheUnzip.h.

References fNMissed.

void TTreeCacheUnzip::Print ( Option_t *  option = ""  )  const [virtual]

Reimplemented from TTreeCache.

Definition at line 1260 of file TTreeCacheUnzip.cxx.

References TFileCacheRead::fFile, fNFound, fNMissed, fNStalls, fNUnzip, fUnzipBufferSize, TNamed::GetName(), and TTreeCache::Print().

void * TTreeCacheUnzip::UnzipLoop ( void *  arg  )  [static]

Definition at line 518 of file TTreeCacheUnzip.cxx.

References d, fCycle, TFileCacheRead::fIsTransferred, fLastReadPos, fMutexList, TFileCacheRead::fNseek, IsActiveThread(), R__LOCKGUARD, TThread::SetCancelDeferred(), TThread::SetCancelOn(), UnzipCache(), and WaitUnzipStartSignal().

Referenced by G__G__Tree_284_0_33(), G__setup_memfuncTTreeCacheUnzip(), and StartThreadUnzip().

TTreeCacheUnzip& TTreeCacheUnzip::operator= ( const TTreeCacheUnzip &   )  [private]

void TTreeCacheUnzip::Init (  )  [private]

Int_t TTreeCacheUnzip::StartThreadUnzip ( Int_t  nthreads  )  [private]

Int_t TTreeCacheUnzip::StopThreadUnzip (  )  [private]

virtual void TTreeCacheUnzip::AddBranch ( TBranch *  b,
Bool_t  subbranches = kFALSE 
) [virtual]

Reimplemented from TTreeCache.

virtual void TTreeCacheUnzip::AddBranch ( const char *  branch,
Bool_t  subbranches = kFALSE 
) [virtual]

Reimplemented from TTreeCache.

Bool_t TTreeCacheUnzip::FillBuffer (  )  [virtual]

Reimplemented from TTreeCache.

virtual Int_t TTreeCacheUnzip::ReadBufferExt ( char *  buf,
Long64_t  pos,
Int_t  len,
Int_t &  loc 
) [virtual]

Reimplemented from TFileCacheRead.

void TTreeCacheUnzip::SetEntryRange ( Long64_t  emin,
Long64_t  emax 
) [virtual]

Reimplemented from TTreeCache.

virtual void TTreeCacheUnzip::StopLearningPhase (  )  [virtual]

Reimplemented from TTreeCache.

void TTreeCacheUnzip::UpdateBranches ( TTree *  tree,
Bool_t  owner = kFALSE 
) [virtual]

Reimplemented from TTreeCache.

static EParUnzipMode TTreeCacheUnzip::GetParallelUnzip (  )  [static]

static Bool_t TTreeCacheUnzip::IsParallelUnzip (  )  [static]

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

Bool_t TTreeCacheUnzip::IsActiveThread (  ) 

Bool_t TTreeCacheUnzip::IsQueueEmpty (  ) 

void TTreeCacheUnzip::WaitUnzipStartSignal (  ) 

void TTreeCacheUnzip::SendUnzipStartSignal ( Bool_t  broadcast  ) 

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

virtual void TTreeCacheUnzip::ResetCache (  )  [virtual]

Reimplemented from TTreeCache.

virtual Int_t TTreeCacheUnzip::GetUnzipBuffer ( char **  buf,
Long64_t  pos,
Int_t  len,
Bool_t *  free 
) [virtual]

Reimplemented from TFileCacheRead.

void TTreeCacheUnzip::SetUnzipBufferSize ( Long64_t  bufferSize  ) 

static void TTreeCacheUnzip::SetUnzipRelBufferSize ( Float_t  relbufferSize  )  [static]

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

Int_t TTreeCacheUnzip::UnzipCache ( Int_t &  startindex,
Int_t &  locbuffsz,
char *&  locbuff 
)

Int_t TTreeCacheUnzip::GetNUnzip (  )  [inline]

Definition at line 129 of file TTreeCacheUnzip.h.

References fNUnzip.

Int_t TTreeCacheUnzip::GetNFound (  )  [inline]

Definition at line 130 of file TTreeCacheUnzip.h.

References fNFound.

Int_t TTreeCacheUnzip::GetNMissed (  )  [inline]

Definition at line 131 of file TTreeCacheUnzip.h.

References fNMissed.

void TTreeCacheUnzip::Print ( Option_t *  option = ""  )  const [virtual]

Reimplemented from TTreeCache.

static void* TTreeCacheUnzip::UnzipLoop ( void *  arg  )  [static]

Member Data Documentation

TThread* TTreeCacheUnzip::fUnzipThread[10] [protected]

Definition at line 50 of file TTreeCacheUnzip.h.

Referenced by Init(), StartThreadUnzip(), and StopThreadUnzip().

Bool_t TTreeCacheUnzip::fActiveThread [protected]

Definition at line 51 of file TTreeCacheUnzip.h.

Referenced by IsActiveThread(), StartThreadUnzip(), and StopThreadUnzip().

TCondition* TTreeCacheUnzip::fUnzipStartCondition [protected]

Definition at line 52 of file TTreeCacheUnzip.h.

Referenced by Init(), SendUnzipStartSignal(), WaitUnzipStartSignal(), and ~TTreeCacheUnzip().

TCondition* TTreeCacheUnzip::fUnzipDoneCondition [protected]

Definition at line 53 of file TTreeCacheUnzip.h.

Referenced by GetUnzipBuffer(), Init(), UnzipCache(), and ~TTreeCacheUnzip().

Bool_t TTreeCacheUnzip::fParallel [protected]

Definition at line 54 of file TTreeCacheUnzip.h.

Referenced by GetUnzipBuffer(), and Init().

Bool_t TTreeCacheUnzip::fAsyncReading [protected]

Reimplemented from TFileCacheRead.

Definition at line 55 of file TTreeCacheUnzip.h.

Referenced by Init().

TMutex* TTreeCacheUnzip::fMutexList [protected]

Definition at line 56 of file TTreeCacheUnzip.h.

Referenced by AddBranch(), FillBuffer(), GetUnzipBuffer(), Init(), IsActiveThread(), IsQueueEmpty(), ResetCache(), SetEntryRange(), SetUnzipBufferSize(), StopLearningPhase(), UnzipCache(), UnzipLoop(), UpdateBranches(), and ~TTreeCacheUnzip().

TMutex* TTreeCacheUnzip::fIOMutex [protected]

Definition at line 57 of file TTreeCacheUnzip.h.

Referenced by GetUnzipBuffer(), Init(), ReadBufferExt(), and ~TTreeCacheUnzip().

Int_t TTreeCacheUnzip::fCycle [protected]

Definition at line 59 of file TTreeCacheUnzip.h.

Referenced by GetUnzipBuffer(), ResetCache(), UnzipCache(), and UnzipLoop().

TTreeCacheUnzip::EParUnzipMode TTreeCacheUnzip::fgParallel [static, protected]

Definition at line 60 of file TTreeCacheUnzip.h.

Referenced by GetParallelUnzip(), Init(), IsParallelUnzip(), and SetParallelUnzip().

Int_t TTreeCacheUnzip::fLastReadPos [protected]

Definition at line 62 of file TTreeCacheUnzip.h.

Referenced by GetUnzipBuffer(), ResetCache(), and UnzipLoop().

Int_t TTreeCacheUnzip::fBlocksToGo [protected]

Definition at line 63 of file TTreeCacheUnzip.h.

Referenced by GetUnzipBuffer(), ResetCache(), and UnzipCache().

Int_t* TTreeCacheUnzip::fUnzipLen [protected]

Definition at line 66 of file TTreeCacheUnzip.h.

Referenced by GetUnzipBuffer(), ResetCache(), UnzipCache(), and ~TTreeCacheUnzip().

char** TTreeCacheUnzip::fUnzipChunks [protected]

[fNseek] Length of the unzipped buffers

Definition at line 67 of file TTreeCacheUnzip.h.

Referenced by GetUnzipBuffer(), ResetCache(), UnzipCache(), and ~TTreeCacheUnzip().

Byte_t* TTreeCacheUnzip::fUnzipStatus [protected]

[fNseek] Individual unzipped chunks. Their summed size is kept under control.

Definition at line 68 of file TTreeCacheUnzip.h.

Referenced by GetUnzipBuffer(), ResetCache(), UnzipCache(), and ~TTreeCacheUnzip().

Long64_t TTreeCacheUnzip::fTotalUnzipBytes [protected]

[fNSeek] For each blk, tells us if it's unzipped or pending

Definition at line 69 of file TTreeCacheUnzip.h.

Referenced by GetUnzipBuffer(), Init(), ResetCache(), and UnzipCache().

Int_t TTreeCacheUnzip::fNseekMax [protected]

The total sum of the currently unzipped blks.

Definition at line 71 of file TTreeCacheUnzip.h.

Referenced by GetUnzipBuffer(), and ResetCache().

Long64_t TTreeCacheUnzip::fUnzipBufferSize [protected]

fNseek can change so we need to know its max size

Definition at line 72 of file TTreeCacheUnzip.h.

Referenced by GetUnzipBuffer(), Init(), Print(), SetUnzipBufferSize(), and UnzipCache().

Double_t TTreeCacheUnzip::fgRelBuffSize [static, protected]

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

Definition at line 74 of file TTreeCacheUnzip.h.

Referenced by Init(), and SetUnzipRelBufferSize().

Int_t TTreeCacheUnzip::fNUnzip [protected]

Definition at line 77 of file TTreeCacheUnzip.h.

Referenced by GetNUnzip(), Print(), and UnzipCache().

Int_t TTreeCacheUnzip::fNFound [protected]

number of blocks that were unzipped

Definition at line 78 of file TTreeCacheUnzip.h.

Referenced by GetNFound(), GetUnzipBuffer(), and Print().

Int_t TTreeCacheUnzip::fNStalls [protected]

number of blocks that were found in the cache

Definition at line 79 of file TTreeCacheUnzip.h.

Referenced by GetUnzipBuffer(), and Print().

Int_t TTreeCacheUnzip::fNMissed [protected]

number of hits which caused a stall

Definition at line 80 of file TTreeCacheUnzip.h.

Referenced by GetNMissed(), GetUnzipBuffer(), and Print().

std::queue<Int_t> TTreeCacheUnzip::fActiveBlks [protected]

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

Definition at line 82 of file TTreeCacheUnzip.h.

Referenced by ResetCache(), and UnzipCache().

char* TTreeCacheUnzip::fCompBuffer [private]

Definition at line 88 of file TTreeCacheUnzip.h.

Referenced by GetUnzipBuffer(), and Init().

Int_t TTreeCacheUnzip::fCompBufferSize [private]

Definition at line 89 of file TTreeCacheUnzip.h.

Referenced by GetUnzipBuffer(), and Init().

TThread* TTreeCacheUnzip::fUnzipThread[10] [protected]

Definition at line 50 of file TTreeCacheUnzip.h.

TCondition* TTreeCacheUnzip::fUnzipStartCondition [protected]

Definition at line 52 of file TTreeCacheUnzip.h.

TCondition* TTreeCacheUnzip::fUnzipDoneCondition [protected]

Definition at line 53 of file TTreeCacheUnzip.h.

TMutex* TTreeCacheUnzip::fMutexList [protected]

Definition at line 56 of file TTreeCacheUnzip.h.

TMutex* TTreeCacheUnzip::fIOMutex [protected]

Definition at line 57 of file TTreeCacheUnzip.h.

Int_t* TTreeCacheUnzip::fUnzipLen [protected]

Definition at line 66 of file TTreeCacheUnzip.h.

char** TTreeCacheUnzip::fUnzipChunks [protected]

[fNseek] Length of the unzipped buffers

Definition at line 67 of file TTreeCacheUnzip.h.

Byte_t* TTreeCacheUnzip::fUnzipStatus [protected]

[fNseek] Individual unzipped chunks. Their summed size is kept under control.

Definition at line 68 of file TTreeCacheUnzip.h.

std::queue<Int_t> TTreeCacheUnzip::fActiveBlks [protected]

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

Definition at line 82 of file TTreeCacheUnzip.h.

char* TTreeCacheUnzip::fCompBuffer [private]

Definition at line 88 of file TTreeCacheUnzip.h.

The documentation for this class was generated from the following files:
Generated on Tue Jul 5 16:48:07 2011 for ROOT_528-00b_version by  doxygen 1.5.1