Logo ROOT   6.30.04
Reference Guide
 All Namespaces Files Pages
TProofPerfAnalysis.h
Go to the documentation of this file.
1 // @(#)root/proofx:$Id$
2 // Author: G.Ganis Nov 2011
3 
4 /*************************************************************************
5  * Copyright (C) 1995-2005, Rene Brun and Fons Rademakers. *
6  * All rights reserved. *
7  * *
8  * For the licensing terms see $ROOTSYS/LICENSE. *
9  * For the list of contributors see $ROOTSYS/README/CREDITS. *
10  *************************************************************************/
11 
12 #ifndef ROOT_TProofPerfAnalysis
13 #define ROOT_TProofPerfAnalysis
14 
15 //////////////////////////////////////////////////////////////////////////
16 // //
17 // TProofPerfAnalysis //
18 // //
19 // Set of tools to analyse the performance tree //
20 // //
21 //////////////////////////////////////////////////////////////////////////
22 
23 #include "TNamed.h"
24 #include "TSortedList.h"
25 #include "TString.h"
26 
27 class TFile;
28 class TH1F;
29 class TH2F;
30 class TList;
31 class TTree;
32 class TProofPerfAnalysis : public TNamed {
33 
34 public: // public because of Sun CC bug
35  class TFileInfo;
36  class TPackInfo;
37  class TWrkEntry;
38  class TWrkInfo;
39  class TWrkInfoFile;
40 
41 private:
42  TFile *fFile; // The open performance file
43  TString fDirName; // The name of the subdir with the perfomance tree
44  TString fTreeName; // The name of the performance tree
45  TTree *fTree; // The performance tree
46  TSortedList fWrksInfo; // Sorted list of workers info
47  TSortedList fFilesInfo; // Sorted list of files info
48  Float_t fInitTime; // End of initialization time for this query
49  Float_t fMergeTime; // Begin of merging time for this query
50  Float_t fMaxTime; // Max time for this query (slowest worker)
51  TH1F *fEvents; // Event distribution per worker
52  TH1F *fPackets; // Packet distribution per worker
53  Double_t fEvtRateMax; // Max event processing rate per packet
54  Double_t fMBRateMax; // Max MB processing rate per packet
55  Double_t fLatencyMax; // Max retrieval latency per packet
56  TH1F *fEvtRate; // Event processing rate vs query time
57  TH1F *fEvtRateRun; // Event processing rate running avg vs query time
58  TH1F *fMBRate; // Byte processing rate vs query time
59  TH1F *fMBRateRun; // Byte processing rate running avg vs query time
60  Double_t fEvtRateAvgMax; // Max running event processing rate
61  Double_t fMBRateAvgMax; // Max running MB processing rate
62  Double_t fEvtRateAvg; // Average event processing rate
63  Double_t fMBRateAvg; // Average MB processing rate
64  TString fFileResult; // File where to save basics of a run when requested
65  Bool_t fSaveResult; // Whether to save the results of a run
66 
67  Int_t fDebug; // Local verbosity level
68 
69  static Bool_t fgDebug; // Global verbosity on/off
70 
71  Int_t CompareOrd(const char *ord1, const char *ord2);
72  void FillFileDist(TH1F *hf, TH1F *hb, TH2F *hx, Bool_t wdet = kFALSE);
73  void FillFileDistOneSrv(TH1F *hx, Bool_t wdet = kFALSE);
74  void FillWrkInfo(Bool_t force = kFALSE);
75  void FillFileInfo(Bool_t force = kFALSE);
76  TString GetCanvasTitle(const char *t);
77  void GetWrkFileList(TList *wl, TList *sl);
78  void LoadTree(TDirectory *dir);
79  void DoDraw(TObject *o, Option_t *opt = "", const char *name = 0);
80 
81 public:
82 
83  TProofPerfAnalysis(const char *perffile, const char *title = "",
84  const char *treename = "PROOF_PerfStats");
85  TProofPerfAnalysis(TTree *tree, const char *title = "");
86  virtual ~TProofPerfAnalysis();
87 
88  Bool_t IsValid() const { return (fFile && fTree) ? kTRUE : kFALSE; }
89  Bool_t WrkInfoOK() const { return (fWrksInfo.GetSize() > 0) ? kTRUE : kFALSE; }
90 
91  void EventDist(); // Analyse event and packet distribution
92  void FileDist(Bool_t writedet = kFALSE); // Analyse the file distribution
93  void LatencyPlot(const char *wrks = 0); // Packet latency distribution vs time
94  void RatePlot(const char *wrks = 0); // Rate distribution vs time
95  void WorkerActivity(); // Analyse the worker activity
96  void PrintWrkInfo(Int_t showlast = 10); // Print workers info
97  void PrintWrkInfo(const char *wrk); // Print worker info by name
98 
99  void PrintFileInfo(Int_t showlast = 10, const char *opt = "", const char *out = 0); // Print file info
100  void PrintFileInfo(const char *fn, const char *opt = "P", const char *out = 0); // Print file info by name
101  void FileProcPlot(const char *fn, const char *out = 0); // Plot info about file processing
102  void FileRatePlot(const char *fns = 0); // Plot info about file processing rates
103 
104  Double_t GetEvtRateAvgMax() const { return fEvtRateAvgMax; } // Max running event processing rate
105  Double_t GetMBRateAvgMax() const { return fMBRateAvgMax; } // Max running MB processing rate
106  Double_t GetEvtRateAvg() const { return fEvtRateAvg; } // Average event processing rate
107  Double_t GetMBRateAvg() const { return fMBRateAvg; } // Average MB processing rate
108  void GetAverages(Double_t &evtmax, Double_t &mbmax, Double_t &evt, Double_t &mb) const
109  { evtmax = fEvtRateAvgMax; mbmax = fMBRateAvgMax; evt = fEvtRateAvg; mb = fMBRateAvg; return; }
110 
111  void Summary(Option_t *opt = "", const char *out = "");
112 
113  Int_t SetSaveResult(const char *file = "results.root", Option_t *mode = "RECREATE");
114 
115  void SetDebug(Int_t d = 0); // Setter for the verbosity level
116  static void SetgDebug(Bool_t on = kTRUE); // Overall verbosity level
117 
118  ClassDef(TProofPerfAnalysis, 0) // Set of tools to analyse the performance tree
119 };
120 
121 #endif