Definition at line 56 of file TParallelFileMerger.h.
Public Member Functions | |
TParallelFileMerger (const char *filename, bool writeCache=false) | |
~TParallelFileMerger () | |
const char * | GetName () const |
ULong_t | Hash () const |
bool | InitialMerge (TFile *input) |
bool | Merge () |
bool | NeedFinalMerge () |
bool | NeedMerge (Float_t clientThreshold) |
void | RegisterClient (UInt_t clientId, TFile *file) |
Private Types | |
typedef std::vector< ClientInfo > | ClientColl_t |
Private Attributes | |
ClientColl_t | fClients |
TBits | fClientsContact |
TString | fFilename |
TTimeStamp | fLastMerge |
TFileMerger | fMerger |
UInt_t | fNClientsContact |
#include <TParallelFileMerger.h>
|
private |
Definition at line 59 of file TParallelFileMerger.h.
TParallelFileMerger::TParallelFileMerger | ( | const char * | filename, |
bool | writeCache = false |
||
) |
Definition at line 102 of file TParallelFileMerger.cxx.
References fMerger.
TParallelFileMerger::~TParallelFileMerger | ( | ) |
Definition at line 110 of file TParallelFileMerger.cxx.
References fClients.
const char * TParallelFileMerger::GetName | ( | ) | const |
Definition at line 124 of file TParallelFileMerger.cxx.
References fFilename.
ULong_t TParallelFileMerger::Hash | ( | ) | const |
Definition at line 118 of file TParallelFileMerger.cxx.
References fFilename.
bool TParallelFileMerger::InitialMerge | ( | TFile * | input | ) |
Definition at line 130 of file TParallelFileMerger.cxx.
References DeleteObject(), and fMerger.
Referenced by TAnalysisWriteLoop::Server().
Bool_t TParallelFileMerger::Merge | ( | ) |
Definition at line 144 of file TParallelFileMerger.cxx.
References DeleteObject(), fClients, fClientsContact, fLastMerge, fMerger, and fNClientsContact.
Referenced by TAnalysisWriteLoop::Server().
Bool_t TParallelFileMerger::NeedFinalMerge | ( | ) |
Definition at line 173 of file TParallelFileMerger.cxx.
References fClientsContact.
Referenced by TAnalysisWriteLoop::Server().
Bool_t TParallelFileMerger::NeedMerge | ( | Float_t | clientThreshold | ) |
Definition at line 179 of file TParallelFileMerger.cxx.
References fClients, fClientsContact, fLastMerge, and fNClientsContact.
Referenced by TAnalysisWriteLoop::Server().
void TParallelFileMerger::RegisterClient | ( | UInt_t | clientId, |
TFile * | file | ||
) |
Definition at line 204 of file TParallelFileMerger.cxx.
References fClients, fClientsContact, fFilename, and fNClientsContact.
Referenced by TAnalysisWriteLoop::Server().
|
private |
Definition at line 64 of file TParallelFileMerger.h.
Referenced by Merge(), NeedMerge(), RegisterClient(), and ~TParallelFileMerger().
|
private |
Definition at line 62 of file TParallelFileMerger.h.
Referenced by Merge(), NeedFinalMerge(), NeedMerge(), and RegisterClient().
|
private |
Definition at line 61 of file TParallelFileMerger.h.
Referenced by GetName(), Hash(), and RegisterClient().
|
private |
Definition at line 65 of file TParallelFileMerger.h.
Referenced by Merge(), and NeedMerge().
|
private |
Definition at line 66 of file TParallelFileMerger.h.
Referenced by InitialMerge(), Merge(), and TParallelFileMerger().
|
private |
Definition at line 63 of file TParallelFileMerger.h.
Referenced by Merge(), NeedMerge(), and RegisterClient().