#include <TPerfStats.h>
Inheritance diagram for TPerfStats:
Public Member Functions | |
virtual | ~TPerfStats () |
void | SimpleEvent (EEventType type) |
void | PacketEvent (const char *slave, const char *slavename, const char *filename, Long64_t eventsprocessed, Double_t latency, Double_t proctime, Double_t cputime, Long64_t bytesRead) |
void | FileEvent (const char *slave, const char *slavename, const char *nodename, const char *filename, Bool_t isStart) |
void | FileOpenEvent (TFile *file, const char *filename, Double_t start) |
void | FileReadEvent (TFile *file, Int_t len, Double_t start) |
void | RateEvent (Double_t proctime, Double_t deltatime, Long64_t eventsprocessed, Long64_t bytesRead) |
void | SetBytesRead (Long64_t num) |
Long64_t | GetBytesRead () const |
void | SetNumEvents (Long64_t num) |
Long64_t | GetNumEvents () const |
virtual | ~TPerfStats () |
void | SimpleEvent (EEventType type) |
void | PacketEvent (const char *slave, const char *slavename, const char *filename, Long64_t eventsprocessed, Double_t latency, Double_t proctime, Double_t cputime, Long64_t bytesRead) |
void | FileEvent (const char *slave, const char *slavename, const char *nodename, const char *filename, Bool_t isStart) |
void | FileOpenEvent (TFile *file, const char *filename, Double_t start) |
void | FileReadEvent (TFile *file, Int_t len, Double_t start) |
void | RateEvent (Double_t proctime, Double_t deltatime, Long64_t eventsprocessed, Long64_t bytesRead) |
void | SetBytesRead (Long64_t num) |
Long64_t | GetBytesRead () const |
void | SetNumEvents (Long64_t num) |
Long64_t | GetNumEvents () const |
Static Public Member Functions | |
static void | Start (TList *input, TList *output) |
static void | Stop () |
static void | Setup (TList *input) |
static void | Start (TList *input, TList *output) |
static void | Stop () |
static void | Setup (TList *input) |
Private Member Functions | |
TPerfStats (TList *input, TList *output) | |
Monitoring engine. | |
void | WriteQueryLog () |
TPerfStats (TList *input, TList *output) | |
Monitoring engine. | |
void | WriteQueryLog () |
Private Attributes | |
TTree * | fTrace |
TTimeStamp | fTzero |
TTree with trace events. | |
TPerfEvent * | fPerfEvent |
start time of this run | |
TH1D * | fPacketsHist |
TPerfEvent used to fill tree. | |
TH1D * | fEventsHist |
histogram of packets processed per slave | |
TH1D * | fNodeHist |
histogram of events processed per slave | |
TH2D * | fLatencyHist |
histogram of slaves per file serving node | |
TH2D * | fProcTimeHist |
histogram of latency due to packet requests | |
TH2D * | fCpuTimeHist |
histogram of real time spent processing packets | |
Long64_t | fBytesRead |
histogram of cpu time spent processing packets | |
Double_t | fTotCpuTime |
track bytes read of main file | |
Long64_t | fTotBytesRead |
total cpu time of all slaves | |
Long64_t | fTotEvents |
total bytes read on all slaves | |
Long64_t | fNumEvents |
total number of events processed | |
Int_t | fSlaves |
total number of events to be processed | |
Bool_t | fDoHist |
number of active slaves | |
Bool_t | fDoTrace |
Fill histos. | |
Bool_t | fDoTraceRate |
Trace details in master. | |
Bool_t | fDoSlaveTrace |
Trace processing rate in master. | |
Bool_t | fDoQuota |
Full tracing in workers. | |
Bool_t | fMonitorPerPacket |
Save stats on SQL server for quota management. | |
TVirtualMonitoringWriter * | fMonitoringWriter |
Whether to send the full entry per each packet. | |
TTree * | fTrace |
TPerfEvent * | fPerfEvent |
start time of this run | |
TH1D * | fPacketsHist |
TPerfEvent used to fill tree. | |
TH1D * | fEventsHist |
histogram of packets processed per slave | |
TH1D * | fNodeHist |
histogram of events processed per slave | |
TH2D * | fLatencyHist |
histogram of slaves per file serving node | |
TH2D * | fProcTimeHist |
histogram of latency due to packet requests | |
TH2D * | fCpuTimeHist |
histogram of real time spent processing packets | |
TVirtualMonitoringWriter * | fMonitoringWriter |
Whether to send the full entry per each packet. |
Definition at line 77 of file TPerfStats.h.
Monitoring engine.
Definition at line 114 of file TPerfStats.cxx.
References a, TTree::Bronch(), TString::Data(), fCpuTimeHist, fDoHist, fDoQuota, fDoSlaveTrace, fDoTrace, fDoTraceRate, fEventsHist, TPluginManager::FindHandler(), TDirectory::FindObject(), fLatencyHist, fMonitoringWriter, fMonitorPerPacket, fNodeHist, fPacketsHist, fPerfEvent, fProcTimeHist, fSlaves, fTrace, gDirectory, gEnv, TProof::GetListOfSlaveInfos(), TProof::GetParameter(), TROOT::GetPluginManager(), TProofServ::GetProof(), TEnv::GetValue(), TH1::GetXaxis(), gProof, gProofServ, gROOT, h, TObject::Info(), TProofServ::IsMaster(), TObject::IsZombie(), TSlaveInfo::kActive, TH1::kCanRebin, kFALSE, kGreen, TProof::kIsMaster, kTRUE, l, output(), PDB, proof, TDirectory::RecursiveRemove(), TIter::Reset(), TAxis::SetBinLabel(), TObject::SetBit(), TTree::SetDirectory(), TH1::SetDirectory(), TAttFill::SetFillColor(), TAttMarker::SetMarkerStyle(), TH1::SetMinimum(), TObject::TestBit(), and TString::Tokenize().
Referenced by Start().
virtual TPerfStats::~TPerfStats | ( | ) | [inline, virtual] |
Definition at line 110 of file TPerfStats.h.
virtual TPerfStats::~TPerfStats | ( | ) | [inline, virtual] |
Definition at line 110 of file TPerfStats.h.
void TPerfStats::WriteQueryLog | ( | ) | [private] |
Definition at line 485 of file TPerfStats.cxx.
References TTimeStamp::AsString(), TSQLServer::Connect(), TString::Data(), TObject::Error(), fMonitoringWriter, TString::Form(), fSlaves, fTotBytesRead, fTotCpuTime, fTotEvents, fTzero, gEnv, TProofServ::GetGroup(), TProofServ::GetProof(), TProof::GetQueryResult(), TTimeStamp::GetSec(), TQueryResult::GetSeqNum(), TProofServ::GetSessionTag(), TProofServ::GetUser(), TEnv::GetValue(), gProofServ, TObject::IsZombie(), TSQLServer::Query(), and TVirtualMonitoringWriter::SendParameters().
Referenced by SimpleEvent().
void TPerfStats::SimpleEvent | ( | EEventType | type | ) | [virtual] |
Implements TVirtualPerfStats.
Definition at line 275 of file TPerfStats.cxx.
References fDoQuota, TTree::Fill(), fNodeHist, fPacketsHist, fPerfEvent, fTrace, TPerfEvent::fType, fTzero, TVirtualPerfStats::kStop, TH1::LabelsDeflate(), TH1::LabelsOption(), TTree::SetBranchAddress(), and WriteQueryLog().
void TPerfStats::PacketEvent | ( | const char * | slave, | |
const char * | slavename, | |||
const char * | filename, | |||
Long64_t | eventsprocessed, | |||
Double_t | latency, | |||
Double_t | proctime, | |||
Double_t | cputime, | |||
Long64_t | bytesRead | |||
) | [virtual] |
Implements TVirtualPerfStats.
Definition at line 299 of file TPerfStats.cxx.
References TTimeStamp::AsString(), TString::Data(), TObject::Error(), TPerfEvent::fBytesRead, TPerfEvent::fCpuTime, fCpuTimeHist, fDoHist, fDoQuota, fDoTrace, fEventsHist, TPerfEvent::fEventsProcessed, TPerfEvent::fFileName, TTree::Fill(), TH2::Fill(), TH1::Fill(), TPerfEvent::fLatency, fLatencyHist, fMonitoringWriter, fMonitorPerPacket, fNumEvents, TString::Form(), fPacketsHist, fPerfEvent, TPerfEvent::fProcTime, fProcTimeHist, TPerfEvent::fSlave, TPerfEvent::fSlaveName, fSlaves, fTotBytesRead, fTotCpuTime, fTotEvents, fTrace, TPerfEvent::fType, fTzero, TProofServ::GetGroup(), TProofServ::GetProof(), TProof::GetQueryResult(), TTimeStamp::GetSec(), TQueryResult::GetSeqNum(), TProofServ::GetSessionTag(), TProofServ::GetUser(), gProofServ, TObject::Info(), TVirtualPerfStats::kPacket, PDB, TVirtualMonitoringWriter::SendParameters(), and TTree::SetBranchAddress().
void TPerfStats::FileEvent | ( | const char * | slave, | |
const char * | slavename, | |||
const char * | nodename, | |||
const char * | filename, | |||
Bool_t | isStart | |||
) | [virtual] |
Implements TVirtualPerfStats.
Definition at line 378 of file TPerfStats.cxx.
References fDoHist, fDoTrace, TPerfEvent::fFileName, TTree::Fill(), TH1::Fill(), TPerfEvent::fIsStart, fNodeHist, TPerfEvent::fNodeName, fPacketsHist, fPerfEvent, TPerfEvent::fSlave, TPerfEvent::fSlaveName, fTrace, TPerfEvent::fType, fTzero, TVirtualPerfStats::kFile, and TTree::SetBranchAddress().
Implements TVirtualPerfStats.
Definition at line 405 of file TPerfStats.cxx.
References TObject::ClassName(), double, fDoTrace, TPerfEvent::fFileClass, TPerfEvent::fFileName, TTree::Fill(), TPerfEvent::fIsOk, fPerfEvent, TPerfEvent::fProcTime, fTrace, TPerfEvent::fType, fTzero, TVirtualPerfStats::kFileOpen, and TTree::SetBranchAddress().
Implements TVirtualPerfStats.
Definition at line 426 of file TPerfStats.cxx.
References TObject::ClassName(), double, fDoTrace, TPerfEvent::fFileClass, TPerfEvent::fFileName, TTree::Fill(), TPerfEvent::fLen, fPerfEvent, TPerfEvent::fProcTime, fTrace, TPerfEvent::fType, fTzero, TNamed::GetName(), TVirtualPerfStats::kFileRead, and TTree::SetBranchAddress().
void TPerfStats::RateEvent | ( | Double_t | proctime, | |
Double_t | deltatime, | |||
Long64_t | eventsprocessed, | |||
Long64_t | bytesRead | |||
) | [virtual] |
Implements TVirtualPerfStats.
Definition at line 447 of file TPerfStats.cxx.
References TPerfEvent::fBytesRead, fDoTrace, fDoTraceRate, TPerfEvent::fEventsProcessed, TTree::Fill(), TPerfEvent::fLatency, fPerfEvent, TPerfEvent::fProcTime, fTrace, TPerfEvent::fType, fTzero, TVirtualPerfStats::kRate, and TTree::SetBranchAddress().
void TPerfStats::SetBytesRead | ( | Long64_t | num | ) | [virtual] |
Long64_t TPerfStats::GetBytesRead | ( | ) | const [virtual] |
void TPerfStats::SetNumEvents | ( | Long64_t | num | ) | [inline, virtual] |
Long64_t TPerfStats::GetNumEvents | ( | ) | const [inline, virtual] |
Definition at line 604 of file TPerfStats.cxx.
References gPerfStats, TObject::kInvalidObject, TVirtualPerfStats::kStart, output(), SafeDelete, TVirtualPerfStats::SimpleEvent(), TObject::TestBit(), and TPerfStats().
Referenced by ClassImp(), G__G__ProofPlayer_197_0_13(), G__setup_memfuncTPerfStats(), TProofPlayerRemote::Process(), TProofPlayerLite::Process(), and TProofPlayer::Process().
void TPerfStats::Stop | ( | ) | [static] |
Definition at line 620 of file TPerfStats.cxx.
References gPerfStats, TVirtualPerfStats::kStop, and TVirtualPerfStats::SimpleEvent().
Referenced by ClassImp(), TProofPlayerLite::Finalize(), TProofPlayerRemote::Finalize(), G__G__ProofPlayer_197_0_14(), G__setup_memfuncTPerfStats(), and TProofPlayer::Process().
void TPerfStats::Setup | ( | TList * | input | ) | [static] |
Definition at line 576 of file TPerfStats.cxx.
References TString::Data(), gEnv, TEnv::GetValue(), and i.
Referenced by G__G__ProofPlayer_197_0_15(), G__setup_memfuncTPerfStats(), TProofPlayerRemote::Process(), and TProofPlayerLite::Process().
void TPerfStats::WriteQueryLog | ( | ) | [private] |
void TPerfStats::SimpleEvent | ( | EEventType | type | ) | [virtual] |
Implements TVirtualPerfStats.
void TPerfStats::PacketEvent | ( | const char * | slave, | |
const char * | slavename, | |||
const char * | filename, | |||
Long64_t | eventsprocessed, | |||
Double_t | latency, | |||
Double_t | proctime, | |||
Double_t | cputime, | |||
Long64_t | bytesRead | |||
) | [virtual] |
Implements TVirtualPerfStats.
void TPerfStats::FileEvent | ( | const char * | slave, | |
const char * | slavename, | |||
const char * | nodename, | |||
const char * | filename, | |||
Bool_t | isStart | |||
) | [virtual] |
Implements TVirtualPerfStats.
Implements TVirtualPerfStats.
Implements TVirtualPerfStats.
void TPerfStats::RateEvent | ( | Double_t | proctime, | |
Double_t | deltatime, | |||
Long64_t | eventsprocessed, | |||
Long64_t | bytesRead | |||
) | [virtual] |
Implements TVirtualPerfStats.
void TPerfStats::SetBytesRead | ( | Long64_t | num | ) | [virtual] |
Implements TVirtualPerfStats.
Long64_t TPerfStats::GetBytesRead | ( | ) | const [virtual] |
Implements TVirtualPerfStats.
void TPerfStats::SetNumEvents | ( | Long64_t | num | ) | [inline, virtual] |
Long64_t TPerfStats::GetNumEvents | ( | ) | const [inline, virtual] |
static void TPerfStats::Stop | ( | ) | [static] |
static void TPerfStats::Setup | ( | TList * | input | ) | [static] |
TTree* TPerfStats::fTrace [private] |
Definition at line 80 of file TPerfStats.h.
Referenced by FileEvent(), FileOpenEvent(), FileReadEvent(), PacketEvent(), RateEvent(), SimpleEvent(), and TPerfStats().
TTimeStamp TPerfStats::fTzero [private] |
TTree with trace events.
Definition at line 81 of file TPerfStats.h.
Referenced by FileEvent(), FileOpenEvent(), FileReadEvent(), PacketEvent(), RateEvent(), SimpleEvent(), and WriteQueryLog().
TPerfEvent* TPerfStats::fPerfEvent [private] |
start time of this run
Definition at line 82 of file TPerfStats.h.
Referenced by FileEvent(), FileOpenEvent(), FileReadEvent(), PacketEvent(), RateEvent(), SimpleEvent(), and TPerfStats().
TH1D* TPerfStats::fPacketsHist [private] |
TPerfEvent used to fill tree.
Definition at line 83 of file TPerfStats.h.
Referenced by FileEvent(), PacketEvent(), SimpleEvent(), and TPerfStats().
TH1D* TPerfStats::fEventsHist [private] |
histogram of packets processed per slave
Definition at line 84 of file TPerfStats.h.
Referenced by PacketEvent(), and TPerfStats().
TH1D* TPerfStats::fNodeHist [private] |
histogram of events processed per slave
Definition at line 85 of file TPerfStats.h.
Referenced by FileEvent(), SimpleEvent(), and TPerfStats().
TH2D* TPerfStats::fLatencyHist [private] |
histogram of slaves per file serving node
Definition at line 86 of file TPerfStats.h.
Referenced by PacketEvent(), and TPerfStats().
TH2D* TPerfStats::fProcTimeHist [private] |
histogram of latency due to packet requests
Definition at line 87 of file TPerfStats.h.
Referenced by PacketEvent(), and TPerfStats().
TH2D* TPerfStats::fCpuTimeHist [private] |
histogram of real time spent processing packets
Definition at line 88 of file TPerfStats.h.
Referenced by PacketEvent(), and TPerfStats().
Long64_t TPerfStats::fBytesRead [private] |
histogram of cpu time spent processing packets
Definition at line 89 of file TPerfStats.h.
Referenced by GetBytesRead(), and SetBytesRead().
Double_t TPerfStats::fTotCpuTime [private] |
track bytes read of main file
Definition at line 90 of file TPerfStats.h.
Referenced by PacketEvent(), and WriteQueryLog().
Long64_t TPerfStats::fTotBytesRead [private] |
total cpu time of all slaves
Definition at line 91 of file TPerfStats.h.
Referenced by PacketEvent(), and WriteQueryLog().
Long64_t TPerfStats::fTotEvents [private] |
total bytes read on all slaves
Definition at line 92 of file TPerfStats.h.
Referenced by PacketEvent(), and WriteQueryLog().
Long64_t TPerfStats::fNumEvents [private] |
total number of events processed
Definition at line 93 of file TPerfStats.h.
Referenced by GetNumEvents(), PacketEvent(), and SetNumEvents().
Int_t TPerfStats::fSlaves [private] |
total number of events to be processed
Definition at line 94 of file TPerfStats.h.
Referenced by PacketEvent(), TPerfStats(), and WriteQueryLog().
Bool_t TPerfStats::fDoHist [private] |
number of active slaves
Definition at line 96 of file TPerfStats.h.
Referenced by FileEvent(), PacketEvent(), and TPerfStats().
Bool_t TPerfStats::fDoTrace [private] |
Fill histos.
Definition at line 97 of file TPerfStats.h.
Referenced by FileEvent(), FileOpenEvent(), FileReadEvent(), PacketEvent(), RateEvent(), and TPerfStats().
Bool_t TPerfStats::fDoTraceRate [private] |
Trace details in master.
Definition at line 98 of file TPerfStats.h.
Referenced by RateEvent(), and TPerfStats().
Bool_t TPerfStats::fDoSlaveTrace [private] |
Trace processing rate in master.
Definition at line 99 of file TPerfStats.h.
Referenced by TPerfStats().
Bool_t TPerfStats::fDoQuota [private] |
Full tracing in workers.
Definition at line 100 of file TPerfStats.h.
Referenced by PacketEvent(), SimpleEvent(), and TPerfStats().
Bool_t TPerfStats::fMonitorPerPacket [private] |
Save stats on SQL server for quota management.
Definition at line 102 of file TPerfStats.h.
Referenced by PacketEvent(), and TPerfStats().
Whether to send the full entry per each packet.
Definition at line 104 of file TPerfStats.h.
Referenced by PacketEvent(), TPerfStats(), and WriteQueryLog().
TTree* TPerfStats::fTrace [private] |
Definition at line 80 of file TPerfStats.h.
TPerfEvent* TPerfStats::fPerfEvent [private] |
TH1D* TPerfStats::fPacketsHist [private] |
TH1D* TPerfStats::fEventsHist [private] |
TH1D* TPerfStats::fNodeHist [private] |
TH2D* TPerfStats::fLatencyHist [private] |
TH2D* TPerfStats::fProcTimeHist [private] |
TH2D* TPerfStats::fCpuTimeHist [private] |