TQueryResultManager Class Reference

#include <TQueryResultManager.h>

Inheritance diagram for TQueryResultManager:

TObject TObject List of all members.

Public Member Functions

 TQueryResultManager (const char *qdir, const char *stag, const char *sdir, TProofLockPath *lck, FILE *logfile=0)
virtual ~TQueryResultManager ()
const char * QueryDir () const
Int_t SeqNum () const
Int_t DrawQueries () const
Int_t KeptQueries () const
TList * Queries () const
TList * PreviousQueries () const
void IncrementSeqNum ()
void IncrementDrawQueries ()
Int_t ApplyMaxQueries (Int_t mxq)
Int_t CleanupQueriesDir ()
Bool_t FinalizeQuery (TProofQueryResult *pq, TProof *proof, TVirtualProofPlayer *player)
Float_t GetCpuTime ()
Float_t GetRealTime ()
TProofQueryResult * LocateQuery (TString queryref, Int_t &qry, TString &qdir)
void RemoveQuery (TQueryResult *qr, Bool_t soft=kFALSE)
void RemoveQuery (const char *queryref, TList *otherlist=0)
void ResetTime ()
void SaveQuery (TProofQueryResult *qr, const char *fout=0)
void SaveQuery (TProofQueryResult *qr, Int_t mxq)
Int_t LockSession (const char *sessiontag, TProofLockPath **lck)
Int_t CleanupSession (const char *sessiontag)
void ScanPreviousQueries (const char *dir)
 TQueryResultManager (const char *qdir, const char *stag, const char *sdir, TProofLockPath *lck, FILE *logfile=0)
virtual ~TQueryResultManager ()
const char * QueryDir () const
Int_t SeqNum () const
Int_t DrawQueries () const
Int_t KeptQueries () const
TList * Queries () const
TList * PreviousQueries () const
void IncrementSeqNum ()
void IncrementDrawQueries ()
Int_t ApplyMaxQueries (Int_t mxq)
Int_t CleanupQueriesDir ()
Bool_t FinalizeQuery (TProofQueryResult *pq, TProof *proof, TVirtualProofPlayer *player)
Float_t GetCpuTime ()
Float_t GetRealTime ()
TProofQueryResult * LocateQuery (TString queryref, Int_t &qry, TString &qdir)
void RemoveQuery (TQueryResult *qr, Bool_t soft=kFALSE)
void RemoveQuery (const char *queryref, TList *otherlist=0)
void ResetTime ()
void SaveQuery (TProofQueryResult *qr, const char *fout=0)
void SaveQuery (TProofQueryResult *qr, Int_t mxq)
Int_t LockSession (const char *sessiontag, TProofLockPath **lck)
Int_t CleanupSession (const char *sessiontag)
void ScanPreviousQueries (const char *dir)

Private Member Functions

void AddLogFile (TProofQueryResult *pq)
void AddLogFile (TProofQueryResult *pq)

Private Attributes

TString fQueryDir
TString fSessionTag
TString fSessionDir
Int_t fSeqNum
Int_t fDrawQueries
Int_t fKeptQueries
TList * fQueries
TList * fPreviousQueries
TProofLockPath * fLock
FILE * fLogFile
TStopwatch fCompute
TList * fQueries
TList * fPreviousQueries
TProofLockPath * fLock
FILE * fLogFile

Detailed Description

Definition at line 41 of file TQueryResultManager.h.

Constructor & Destructor Documentation

TQueryResultManager::TQueryResultManager ( const char *  qdir,
const char *  stag,
const char *  sdir,
TProofLockPath *  lck,
FILE *  logfile = 0 
)

Definition at line 41 of file TQueryResultManager.cxx.

References fDrawQueries, fKeptQueries, fLock, fLogFile, fPreviousQueries, fQueries, fQueryDir, fSeqNum, fSessionDir, and fSessionTag.

TQueryResultManager::~TQueryResultManager (  )  [virtual]

Definition at line 60 of file TQueryResultManager.cxx.

References fPreviousQueries, fQueries, and SafeDelete.

TQueryResultManager::TQueryResultManager ( const char *  qdir,
const char *  stag,
const char *  sdir,
TProofLockPath *  lck,
FILE *  logfile = 0 
)

virtual TQueryResultManager::~TQueryResultManager (  )  [virtual]

Member Function Documentation

void TQueryResultManager::AddLogFile ( TProofQueryResult *  pq  )  [private]

Definition at line 70 of file TQueryResultManager.cxx.

References TQueryResult::AddLogLine(), TObject::Error(), fflush(), fLogFile, TProofQueryResult::fStartLog, kMAXBUF, line, lseek, SEEK_CUR, SEEK_SET, and start.

Referenced by FinalizeQuery().

const char* TQueryResultManager::QueryDir (  )  const [inline]

Definition at line 63 of file TQueryResultManager.h.

References TString::Data(), and fQueryDir.

Int_t TQueryResultManager::SeqNum (  )  const [inline]

Definition at line 64 of file TQueryResultManager.h.

References fSeqNum.

Referenced by TProofServ::MakeQueryResult(), and TProofLite::MakeQueryResult().

Int_t TQueryResultManager::DrawQueries (  )  const [inline]

Definition at line 65 of file TQueryResultManager.h.

References fDrawQueries.

Referenced by TProofLite::GetListOfQueries(), and TProofServ::HandleQueryList().

Int_t TQueryResultManager::KeptQueries (  )  const [inline]

Definition at line 66 of file TQueryResultManager.h.

References fKeptQueries.

TList* TQueryResultManager::Queries (  )  const [inline]

Definition at line 67 of file TQueryResultManager.h.

References fQueries.

Referenced by TProofLite::GetListOfQueries(), TProofServ::HandleProcess(), TProofServ::HandleQueryList(), TProofLite::Process(), TProofServ::ProcessNext(), TProofServ::Terminate(), TXProofServ::Terminate(), and TProofLite::~TProofLite().

TList* TQueryResultManager::PreviousQueries (  )  const [inline]

Definition at line 68 of file TQueryResultManager.h.

References fPreviousQueries.

Referenced by TProofLite::GetListOfQueries(), and TProofServ::HandleQueryList().

void TQueryResultManager::IncrementSeqNum (  )  [inline]

Definition at line 70 of file TQueryResultManager.h.

References fSeqNum.

Referenced by TProofServ::MakeQueryResult(), and TProofLite::MakeQueryResult().

void TQueryResultManager::IncrementDrawQueries (  )  [inline]

Definition at line 71 of file TQueryResultManager.h.

References fDrawQueries.

Referenced by TProofLite::Process(), and TProofServ::ProcessNext().

Int_t TQueryResultManager::ApplyMaxQueries ( Int_t  mxq  ) 

Definition at line 222 of file TQueryResultManager.cxx.

References TSortedList::Add(), TList::Add(), TString::Data(), dir(), TSystem::DirName(), dirs(), TSystem::Exec(), TList::FindObject(), THashList::FindObject(), Form(), TString::Format(), fQueryDir, TSystem::FreeDirectory(), fSessionTag, TSystem::GetDirEntry(), TObjString::GetName(), TSystem::GetPathInfo(), TNamed::GetTitle(), gSystem, TObject::Info(), kIterBackward, kNPOS, kRM, TSystem::OpenDirectory(), PDB, TCollection::SetOwner(), TSystem::Unlink(), and val.

Referenced by TProofLite::Init(), and TProofServ::SetupCommon().

Int_t TQueryResultManager::CleanupQueriesDir (  ) 

Definition at line 106 of file TQueryResultManager.cxx.

References TString::Data(), TList::Delete(), dirs(), TSystem::Exec(), TString::Form(), Form(), fPreviousQueries, fQueryDir, fSessionTag, TSystem::GetDirEntry(), gSystem, TString::Index(), TObject::Info(), kPROOF_QueryDir, kRM, TSystem::OpenDirectory(), PDB, TString::Remove(), and SafeDelete.

Referenced by TProofServ::HandleRemove(), and TProofLite::Remove().

Bool_t TQueryResultManager::FinalizeQuery ( TProofQueryResult *  pq,
TProof *  proof,
TVirtualProofPlayer *  player 
)

Definition at line 600 of file TQueryResultManager.cxx.

References AddLogFile(), TProof::GetBytesRead(), GetCpuTime(), TProof::GetCpuTime(), TVirtualProofPlayer::GetEventsProcessed(), TVirtualProofPlayer::GetExitStatus(), TVirtualProofPlayer::GetOutputList(), TQueryResult::GetSeqNum(), TQueryResult::GetUsedCPU(), TObject::Info(), TQueryResult::kAborted, TVirtualProofPlayer::kAborted, TQueryResult::kCompleted, kFALSE, TVirtualProofPlayer::kFinished, TQueryResult::kStopped, TVirtualProofPlayer::kStopped, kTRUE, Long64_t, out, PDB, proof, TProofQueryResult::RecordEnd(), TQueryResult::SetProcessInfo(), and TObject::Warning().

Referenced by TProofLite::Process(), and TProofServ::ProcessNext().

Float_t TQueryResultManager::GetCpuTime (  )  [inline]

Definition at line 77 of file TQueryResultManager.h.

References TStopwatch::CpuTime(), and fCompute.

Referenced by FinalizeQuery().

Float_t TQueryResultManager::GetRealTime (  )  [inline]

Definition at line 78 of file TQueryResultManager.h.

References fCompute, and TStopwatch::RealTime().

TProofQueryResult * TQueryResultManager::LocateQuery ( TString  queryref,
Int_t &  qry,
TString &  qdir 
)

Definition at line 535 of file TQueryResultManager.cxx.

References TString::Atoi(), TString::Contains(), TString::Data(), Form(), fPreviousQueries, fQueries, fQueryDir, fSessionTag, TNamed::GetName(), TQueryResult::GetSeqNum(), TNamed::GetTitle(), TString::Index(), TObject::Info(), TString::IsDigit(), kNPOS, kPROOF_QueryDir, PDB, TString::Remove(), and TString::ReplaceAll().

Referenced by TProofServ::HandleArchive(), TProofServ::HandleRetrieve(), and RemoveQuery().

void TQueryResultManager::RemoveQuery ( TQueryResult *  qr,
Bool_t  soft = kFALSE 
)

Definition at line 499 of file TQueryResultManager.cxx.

References TList::AddAt(), TQueryResult::CloneInfo(), TString::Data(), TSystem::Exec(), Form(), fQueries, fQueryDir, TQueryResult::GetSeqNum(), TNamed::GetTitle(), gSystem, TString::Index(), TSeqCollection::IndexOf(), TObject::Info(), kPROOF_QueryDir, kRM, PDB, TList::Remove(), TString::Remove(), and SafeDelete.

Referenced by TProofServ::HandleRemove(), TProofLite::Process(), TProofLite::Remove(), SaveQuery(), and ScanPreviousQueries().

void TQueryResultManager::RemoveQuery ( const char *  queryref,
TList *  otherlist = 0 
)

Definition at line 466 of file TQueryResultManager.cxx.

References TList::Add(), TString::Data(), TSystem::Exec(), Form(), fPreviousQueries, fQueries, gSystem, TObject::Info(), kRM, LocateQuery(), PDB, and TList::Remove().

void TQueryResultManager::ResetTime (  )  [inline]

Definition at line 82 of file TQueryResultManager.h.

References fCompute, and TStopwatch::Start().

Referenced by TProofServ::ProcessNext().

void TQueryResultManager::SaveQuery ( TProofQueryResult *  qr,
const char *  fout = 0 
)

Definition at line 437 of file TQueryResultManager.cxx.

References TSystem::AccessPathName(), TString::Data(), Form(), fQueryDir, TQueryResult::GetSeqNum(), gSystem, TQueryResult::IsArchived(), TQueryResult::IsDraw(), TSystem::MakeDirectory(), TFile::Open(), TProofQueryResult::SetResultFile(), and TObject::Write().

Referenced by TProofServ::HandleArchive(), TProofServ::HandleProcess(), TProofLite::Process(), TProofServ::ProcessNext(), and SaveQuery().

void TQueryResultManager::SaveQuery ( TProofQueryResult *  qr,
Int_t  mxq 
)

Definition at line 668 of file TQueryResultManager.cxx.

References emsg(), fKeptQueries, fQueries, TNamed::GetName(), TQueryResult::GetOutputList(), TQueryResult::GetStatus(), TNamed::GetTitle(), gProofServ, TQueryResult::IsArchived(), TQueryResult::kRunning, kTRUE, RemoveQuery(), SaveQuery(), TProofServ::SendAsynMessage(), and TObject::Warning().

Int_t TQueryResultManager::LockSession ( const char *  sessiontag,
TProofLockPath **  lck 
)

Definition at line 334 of file TQueryResultManager.cxx.

References TSystem::AccessPathName(), TObject::Error(), fLock, fSessionDir, fSessionTag, TNamed::GetName(), gSystem, TString::Index(), TObject::Info(), kNPOS, PDB, TString::Remove(), TString::ReplaceAll(), and SafeDelete.

Referenced by CleanupSession(), TProofServ::HandleRemove(), TProofLite::Remove(), and ScanPreviousQueries().

Int_t TQueryResultManager::CleanupSession ( const char *  sessiontag  ) 

Definition at line 395 of file TQueryResultManager.cxx.

References TSystem::AccessPathName(), TString::Data(), TObject::Error(), TSystem::Exec(), Form(), fQueryDir, fSessionTag, TNamed::GetName(), gSystem, TString::Index(), TObject::Info(), kNPOS, kRM, LockSession(), TString::Remove(), TString::ReplaceAll(), SafeDelete, and TSystem::Unlink().

Referenced by TProofServ::HandleSocketInput().

void TQueryResultManager::ScanPreviousQueries ( const char *  dir  ) 

Definition at line 148 of file TQueryResultManager.cxx.

References TList::Add(), TQueryResult::CloneInfo(), TList::Delete(), dirs(), Form(), fPreviousQueries, TSystem::FreeDirectory(), fSessionTag, TSystem::GetDirEntry(), TQueryResult::GetStatus(), TNamed::GetTitle(), gSystem, k, TQueryResult::kRunning, LockSession(), TFile::Open(), TSystem::OpenDirectory(), RemoveQuery(), and SafeDelete.

Referenced by TProofLite::GetListOfQueries(), and TProofServ::HandleQueryList().

void TQueryResultManager::AddLogFile ( TProofQueryResult *  pq  )  [private]

const char* TQueryResultManager::QueryDir (  )  const [inline]

Definition at line 63 of file TQueryResultManager.h.

References TString::Data(), and fQueryDir.

Int_t TQueryResultManager::SeqNum (  )  const [inline]

Definition at line 64 of file TQueryResultManager.h.

References fSeqNum.

Int_t TQueryResultManager::DrawQueries (  )  const [inline]

Definition at line 65 of file TQueryResultManager.h.

References fDrawQueries.

Int_t TQueryResultManager::KeptQueries (  )  const [inline]

Definition at line 66 of file TQueryResultManager.h.

References fKeptQueries.

TList* TQueryResultManager::Queries (  )  const [inline]

Definition at line 67 of file TQueryResultManager.h.

References fQueries.

TList* TQueryResultManager::PreviousQueries (  )  const [inline]

Definition at line 68 of file TQueryResultManager.h.

References fPreviousQueries.

void TQueryResultManager::IncrementSeqNum (  )  [inline]

Definition at line 70 of file TQueryResultManager.h.

References fSeqNum.

void TQueryResultManager::IncrementDrawQueries (  )  [inline]

Definition at line 71 of file TQueryResultManager.h.

References fDrawQueries.

Int_t TQueryResultManager::ApplyMaxQueries ( Int_t  mxq  ) 

Int_t TQueryResultManager::CleanupQueriesDir (  ) 

Bool_t TQueryResultManager::FinalizeQuery ( TProofQueryResult *  pq,
TProof *  proof,
TVirtualProofPlayer *  player 
)

Float_t TQueryResultManager::GetCpuTime (  )  [inline]

Definition at line 77 of file TQueryResultManager.h.

References TStopwatch::CpuTime(), and fCompute.

Float_t TQueryResultManager::GetRealTime (  )  [inline]

Definition at line 78 of file TQueryResultManager.h.

References fCompute, and TStopwatch::RealTime().

TProofQueryResult* TQueryResultManager::LocateQuery ( TString  queryref,
Int_t &  qry,
TString &  qdir 
)

void TQueryResultManager::RemoveQuery ( TQueryResult *  qr,
Bool_t  soft = kFALSE 
)

void TQueryResultManager::RemoveQuery ( const char *  queryref,
TList *  otherlist = 0 
)

void TQueryResultManager::ResetTime (  )  [inline]

Definition at line 82 of file TQueryResultManager.h.

References fCompute, and TStopwatch::Start().

void TQueryResultManager::SaveQuery ( TProofQueryResult *  qr,
const char *  fout = 0 
)

void TQueryResultManager::SaveQuery ( TProofQueryResult *  qr,
Int_t  mxq 
)

Int_t TQueryResultManager::LockSession ( const char *  sessiontag,
TProofLockPath **  lck 
)

Int_t TQueryResultManager::CleanupSession ( const char *  sessiontag  ) 

void TQueryResultManager::ScanPreviousQueries ( const char *  dir  ) 

Member Data Documentation

TString TQueryResultManager::fQueryDir [private]

Definition at line 44 of file TQueryResultManager.h.

Referenced by ApplyMaxQueries(), CleanupQueriesDir(), CleanupSession(), LocateQuery(), QueryDir(), RemoveQuery(), SaveQuery(), and TQueryResultManager().

TString TQueryResultManager::fSessionTag [private]

Definition at line 45 of file TQueryResultManager.h.

Referenced by ApplyMaxQueries(), CleanupQueriesDir(), CleanupSession(), LocateQuery(), LockSession(), ScanPreviousQueries(), and TQueryResultManager().

TString TQueryResultManager::fSessionDir [private]

Definition at line 46 of file TQueryResultManager.h.

Referenced by LockSession(), and TQueryResultManager().

Int_t TQueryResultManager::fSeqNum [private]

Definition at line 47 of file TQueryResultManager.h.

Referenced by IncrementSeqNum(), SeqNum(), and TQueryResultManager().

Int_t TQueryResultManager::fDrawQueries [private]

Definition at line 48 of file TQueryResultManager.h.

Referenced by DrawQueries(), IncrementDrawQueries(), and TQueryResultManager().

Int_t TQueryResultManager::fKeptQueries [private]

Definition at line 49 of file TQueryResultManager.h.

Referenced by KeptQueries(), SaveQuery(), and TQueryResultManager().

TList* TQueryResultManager::fQueries [private]

Definition at line 50 of file TQueryResultManager.h.

Referenced by LocateQuery(), Queries(), RemoveQuery(), SaveQuery(), TQueryResultManager(), and ~TQueryResultManager().

TList* TQueryResultManager::fPreviousQueries [private]

Definition at line 51 of file TQueryResultManager.h.

Referenced by CleanupQueriesDir(), LocateQuery(), PreviousQueries(), RemoveQuery(), ScanPreviousQueries(), TQueryResultManager(), and ~TQueryResultManager().

TProofLockPath* TQueryResultManager::fLock [private]

Definition at line 52 of file TQueryResultManager.h.

Referenced by LockSession(), and TQueryResultManager().

FILE* TQueryResultManager::fLogFile [private]

Definition at line 53 of file TQueryResultManager.h.

Referenced by AddLogFile(), and TQueryResultManager().

TStopwatch TQueryResultManager::fCompute [private]

Definition at line 54 of file TQueryResultManager.h.

Referenced by GetCpuTime(), GetRealTime(), and ResetTime().

TList* TQueryResultManager::fQueries [private]

Definition at line 50 of file TQueryResultManager.h.

TList* TQueryResultManager::fPreviousQueries [private]

Definition at line 51 of file TQueryResultManager.h.

TProofLockPath* TQueryResultManager::fLock [private]

Definition at line 52 of file TQueryResultManager.h.

FILE* TQueryResultManager::fLogFile [private]

Definition at line 53 of file TQueryResultManager.h.

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