#include <TProof.h>
Inheritance diagram for TProof:
Definition at line 321 of file TProof.h.
typedef std::map<TString, MD5Mod_t> TProof::FileMap_t [private] |
typedef std::map<TString, MD5Mod_t> TProof::FileMap_t [private] |
| enum TProof::EStatusBits |
| enum TProof::EQueryMode |
| enum TProof::EUploadOpt |
| enum TProof::ERegisterOpt |
| enum TProof::ERunStatus |
| enum TProof::ESubMerger |
enum TProof::EUrgent [private] |
enum TProof::EProofCacheCommands [private] |
enum TProof::EProofDataSetCommands [private] |
enum TProof::ESendFileOpt [private] |
enum TProof::EProofWrkListAction [private] |
enum TProof::EBuildPackageOpt [private] |
enum TProof::EProofShowQuotaOpt [private] |
enum TProof::EProofClearData [private] |
enum TProof::ESlaves [protected] |
| enum TProof::EStatusBits |
| enum TProof::EQueryMode |
| enum TProof::EUploadOpt |
| enum TProof::ERegisterOpt |
| enum TProof::ERunStatus |
| enum TProof::ESubMerger |
enum TProof::EUrgent [private] |
enum TProof::EProofCacheCommands [private] |
enum TProof::EProofDataSetCommands [private] |
enum TProof::ESendFileOpt [private] |
enum TProof::EProofWrkListAction [private] |
enum TProof::EBuildPackageOpt [private] |
enum TProof::EProofShowQuotaOpt [private] |
enum TProof::EProofClearData [private] |
enum TProof::ESlaves [protected] |
| TProof::TProof | ( | const TProof & | ) | [private] |
| TProof::TProof | ( | ) | [protected] |
Definition at line 453 of file TProof.cxx.
References TSeqCollection::Add(), TCollection::FindObject(), TROOT::GetListOfProofs(), gProof, gROOT, and InitMembers().
| TProof::TProof | ( | const char * | masterurl, | |
| const char * | conffile = kPROOF_ConfFile, |
|||
| const char * | confdir = kPROOF_ConfDir, |
|||
| Int_t | loglevel = 0, |
|||
| const char * | alias = 0, |
|||
| TProofMgr * | mgr = 0 | |||
| ) |
Definition at line 337 of file TProof.cxx.
References TSeqCollection::Add(), TCollection::FindObject(), fManager, fMaster, fMasterServ, fQueryMode, fServType, fUrl, UserGroup_t::fUser, TSystem::Getenv(), TUrl::GetHost(), TSystem::GetHostByName(), TROOT::GetListOfProofs(), TROOT::GetListOfSockets(), TUrl::GetOptions(), TUrl::GetPort(), GetPort(), TUrl::GetUser(), TSystem::GetUserInfo(), gProof, gROOT, gROOTMutex, gSystem, TSystem::HostName(), Init(), InitMembers(), IsProofd(), kFALSE, kIsClient, kIsMaster, TProofMgr::kProofd, TProofMgr::kProofLite, kSync, kTRUE, TProofMgr::kXProofd, opts, R__LOCKGUARD2, TCollection::Remove(), TObject::ResetBit(), TObject::SetBit(), TSystem::Setenv(), TUrl::SetHost(), TUrl::SetOptions(), TUrl::SetPort(), TUrl::SetProtocol(), TUrl::SetUser(), and TObject::TestBit().
| TProof::~TProof | ( | ) | [virtual] |
Definition at line 585 of file TProof.cxx.
References chain, xmlio::Class, Close(), TProofMgr::DiscardSession(), TQObject::Emit(), fActiveMonitor, fActiveSlaves, fAllMonitor, fAllUniqueMonitor, fAllUniqueSlaves, fAvailablePackages, fBadSlaves, fChains, fclose(), fCloseMutex, fEnabledPackages, fEnabledPackagesOnClient, fFeedback, fGlobalPackageDirList, fInactiveSlaves, fInputData, fIntHandler, TList::First(), fLoadedMacros, fLogFileName, fLogFileR, fLogFileW, fManager, fNonUniqueMasters, fPackageLock, fPlayer, fRecvMessages, fRunningDSets, fSlaveInfo, fSlaves, fUniqueMonitor, fUniqueSlaves, fWaitingSlaves, TROOT::GetListOfProofs(), TSystem::GetPathInfo(), gProof, gROOT, gSystem, TObject::InheritsFrom(), TProofMgr::IsValid(), kIsClient, kIterBackward, TString::Length(), TCollection::Remove(), RemoveChain(), SafeDelete, TChain::SetProof(), stat, TObject::TestBit(), and TSystem::Unlink().
| TProof::TProof | ( | const TProof & | ) | [private] |
| TProof::TProof | ( | ) | [protected] |
| TProof::TProof | ( | const char * | masterurl, | |
| const char * | conffile = kPROOF_ConfFile, |
|||
| const char * | confdir = kPROOF_ConfDir, |
|||
| Int_t | loglevel = 0, |
|||
| const char * | alias = 0, |
|||
| TProofMgr * | mgr = 0 | |||
| ) |
| virtual TProof::~TProof | ( | ) | [virtual] |
| void TProof::operator= | ( | const TProof & | ) | [private] |
| void TProof::CleanGDirectory | ( | TList * | ol | ) | [private] |
Definition at line 2594 of file TProof.cxx.
References gDirectory, o, and TDirectory::RecursiveRemove().
Referenced by HandleInputMessage().
Definition at line 5345 of file TProof.cxx.
References TString::Data(), TObject::Error(), GetFileInCmd(), TROOT::GetMacroPath(), GetNumberOfUniqueSlaves(), GetParallel(), gROOT, gSystem, IsLite(), IsValid(), kAscii, TString::kBoth, kCpBin, kForward, kReadPermission, n, TROOT::ProcessLine(), s, SendCommand(), SendFile(), SetParallelSilent(), and TSystem::Which().
Referenced by Exec(), make_event_trees(), and TSessionFrame::OnCommandLine().
Definition at line 5400 of file TProof.cxx.
References Broadcast(), Collect(), fStatus, IsValid(), and kMESS_CINT.
Referenced by Exec(), and TProofServ::HandleSocketInput().
Definition at line 5419 of file TProof.cxx.
References Broadcast(), gDirectory, GetParallel(), TDirectory::GetPath(), IsValid(), and kPROOF_RESET.
Referenced by TProofServ::Reset(), and SetParallelSilent().
| Bool_t TProof::CheckFile | ( | const char * | file, | |
| TSlave * | sl, | |||
| Long_t | modtime, | |||
| Int_t | cpopt = (kCp|kCpBin) | |||
| ) | [private] |
Definition at line 5449 of file TProof.cxx.
References TSystem::BaseName(), Collect(), TObject::Error(), fCheckFileStatus, fCollectTimeout, fFileMap, TMD5::FileChecksum(), TProof::MD5Mod_t::fMD5, TProof::MD5Mod_t::fModtime, TSlave::GetName(), TSlave::GetOrdinal(), TSlave::GetSocket(), gSystem, if(), kFALSE, kIsMaster, kPROOF_CHECKFILE, kTRUE, md5, TSocket::Send(), and TObject::TestBit().
Referenced by SendFile().
Definition at line 5685 of file TProof.cxx.
References Broadcast(), IsValid(), kMESS_OBJECT, and TMessage::WriteObject().
| Int_t TProof::SendGroupView | ( | ) | [private] |
Definition at line 5274 of file TProof.cxx.
References xmlio::cnt, fActiveSlaves, fSendGroupView, GetNumberOfActiveSlaves(), TSlave::GetSocket(), IsValid(), kFALSE, kIsClient, kPROOF_GROUPVIEW, MarkBad(), TSocket::Send(), size, snprintf, str, and TObject::TestBit().
Referenced by Collect(), GoParallel(), and TProofLite::SetupWorkers().
| Int_t TProof::SendInitialState | ( | ) | [private] |
Definition at line 5435 of file TProof.cxx.
References fLogLevel, GetNumberOfActiveSlaves(), gProofDebugMask, IsValid(), and SetLogLevel().
Referenced by Init(), and TProofLite::Init().
Definition at line 5699 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, IsValid(), kActive, and kPROOF_PRINT.
Referenced by Print().
Definition at line 4157 of file TProof.cxx.
References fActiveSlaves, fAllUniqueSlaves, fSlaves, fUniqueSlaves, TCollection::GetSize(), TSlave::IsValid(), kActive, kAll, kAllUnique, kUnique, MarkBad(), and TSlave::Ping().
Referenced by TProofServ::HandleSocketInput(), and TXProofServ::HandleUrgentData().
Definition at line 1960 of file TProof.cxx.
References fActiveSlaves, fAllUniqueSlaves, fSlaves, fUniqueSlaves, TCollection::GetSize(), TSlave::Interrupt(), IsValid(), TSlave::IsValid(), kActive, kAll, kAllUnique, and kUnique.
Referenced by TProofServ::HandleSigPipe(), TProofServ::HandleUrgentData(), TXProofServ::HandleUrgentData(), and SendFile().
| void TProof::AskStatistics | ( | ) | [private] |
Definition at line 1706 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, IsValid(), kActive, and kPROOF_GETSTATS.
Referenced by GetStatistics(), GoParallel(), Print(), TProofLite::Process(), and TProofServ::ProcessNext().
| void TProof::AskParallel | ( | ) | [private] |
Definition at line 1761 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, IsValid(), kActive, and kPROOF_GETPARALLEL.
Referenced by TProofServ::SendParallel().
Definition at line 5787 of file TProof.cxx.
References TMonitor::Add(), TList::Add(), AskStatistics(), TList::At(), TList::Clear(), xmlio::cnt, Collect(), TObject::Error(), fActiveMonitor, fActiveSlaves, fBadSlaves, fCollectTimeout, fEndMaster, fInactiveSlaves, TList::FindObject(), FindUniqueSlaves(), TList::First(), fSlaves, TSlave::GetImage(), GetParallel(), TSlave::GetParallel(), TCollection::GetSize(), TSlave::GetSlaveType(), TSlave::GetSocket(), gRandom, TObject::Info(), IsValid(), TSlave::IsValid(), TSlave::kActive, kFALSE, TSlave::kInactive, kIsClient, kIsMaster, TSlave::kMaster, kPROOF_LOGFILE, kPROOF_PARALLEL, TSlave::kSlave, kTRUE, MarkBad(), n, PDB, R__ASSERT, TList::Remove(), TMonitor::RemoveAll(), TRandom::Rndm(), SafeDelete, TSocket::Send(), SendGroupView(), TCollection::SetOwner(), TSlave::SetStatus(), TMessage::SetWhat(), and TObject::TestBit().
Referenced by Init(), TProofLite::Init(), and SetParallelSilent().
Definition at line 5742 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, GetParallel(), GoParallel(), TObject::Info(), IsValid(), kActive, kFALSE, kIsMaster, kPROOF_PARALLEL, n, PDB, SendCurrentState(), and TObject::TestBit().
Referenced by Exec(), and SetParallel().
Definition at line 5111 of file TProof.cxx.
References buf, TQObject::EmitVA(), TObject::Error(), fLogFileW, fLogToWindowOnly, fRedirLog, IsIdle(), kFALSE, kIsMaster, kMAXBUF, lseek, p, s, SEEK_END, TObject::SysError(), TObject::TestBit(), w, TObject::Warning(), and write.
Referenced by HandleInputMessage().
| void TProof::NotifyLogMsg | ( | const char * | msg, | |
| const char * | sfx = "\n" | |||
| ) | [private] |
Definition at line 5173 of file TProof.cxx.
References TQObject::EmitVA(), fLogFileW, fLogToWindowOnly, fRedirLog, IsIdle(), kFALSE, len, lseek, p, SEEK_END, TObject::SysError(), w, TObject::Warning(), and write.
Referenced by HandleInputMessage(), and SendDataSetStatus().
| Int_t TProof::BuildPackage | ( | const char * | package, | |
| EBuildPackageOpt | opt = kBuildAll | |||
| ) | [private] |
Definition at line 6520 of file TProof.cxx.
References TSystem::BaseName(), Broadcast(), BuildPackageOnClient(), Collect(), TString::EndsWith(), TObject::Error(), fNonUniqueMasters, fPackageLock, fStatus, gSystem, IsLite(), IsValid(), kAllUnique, kBuildAll, kBuildPackage, kBuildSubPackage, kDontBuildOnClient, kFALSE, kIsClient, kPROOF_CACHE, kTRUE, kUnique, TString::Length(), TProofLockPath::Lock(), TString::Remove(), TObject::TestBit(), and TProofLockPath::Unlock().
Referenced by EnablePackage(), and TProofServ::HandleCache().
| Int_t TProof::BuildPackageOnClient | ( | const char * | package, | |
| Int_t | opt = 0, |
|||
| TString * | path = 0 | |||
| ) | [private] |
Definition at line 6590 of file TProof.cxx.
References TSystem::AccessPathName(), TSystem::BaseName(), TSystem::ChangeDirectory(), TString::Data(), DownloadPackage(), TString::EndsWith(), TObject::Error(), TSystem::Exec(), fclose(), fGlobalPackageDirList, TMD5::FileChecksum(), FileStat_t::fMode, fopen, TString::Form(), Form(), fPackageDir, TSystem::Getenv(), TSystem::GetPathInfo(), TCollection::GetSize(), TROOT::GetSvnRevision(), TNamed::GetTitle(), TROOT::GetVersion(), gROOT, gSystem, TObject::Info(), TString::IsNull(), kExecutePermission, kFALSE, kFileExists, kGUNZIP, kIsClient, kPROOF_PackDownloadDir, kReadPermission, kRM, kTRUE, kUntar, kUNTAR3, md5, par, PDB, R_ISLNK(), TObject::TestBit(), UploadPackageOnClient(), TSystem::Which(), and TSystem::WorkingDirectory().
Referenced by BuildPackage().
| Int_t TProof::LoadPackage | ( | const char * | package, | |
| Bool_t | notOnClient = kFALSE, |
|||
| TList * | loadopts = 0 | |||
| ) | [private] |
Definition at line 6786 of file TProof.cxx.
References TSystem::BaseName(), Broadcast(), Collect(), TString::EndsWith(), TObject::Error(), fStatus, gSystem, IsMaster(), IsValid(), kActive, kFALSE, kLoadPackage, kPROOF_CACHE, kTRUE, TString::Length(), LoadPackageOnClient(), and TString::Remove().
Referenced by EnablePackage(), and TProofServ::HandleCache().
Definition at line 6825 of file TProof.cxx.
References TSystem::AccessPathName(), TList::Add(), TSystem::AddIncludePath(), TSystem::ChangeDirectory(), TObject::ClassName(), TString::Data(), TObject::Error(), TMethodCall::Execute(), fEnabledPackagesOnClient, fGlobalPackageDirList, TList::FindObject(), TCollection::FindObject(), TList::First(), TString::Form(), Form(), TString::Format(), fPackageDir, fPackageLock, TMacro::GetLineWith(), TROOT::GetListOfGlobalFunctions(), TFunction::GetListOfMethodArgs(), TObjString::GetName(), TFunction::GetNargs(), TSystem::GetPathInfo(), TCollection::GetSize(), TObjString::GetString(), TNamed::GetTitle(), gROOT, gSystem, TNamed::Hash(), TObject::Info(), TMethodCall::InitWithPrototype(), kIsClient, kReadPermission, TString::Length(), TROOT::LoadMacro(), TProofLockPath::Lock(), PDB, TROOT::ProcessLine(), TMethodCall::ResetParam(), TMacro::SaveSource(), TMethodCall::SetParam(), TObjString::SetString(), stat, TSystem::Symlink(), TSystem::TempDirectory(), TObject::TestBit(), TSystem::Unlink(), TProofLockPath::Unlock(), TObject::Warning(), and TSystem::WorkingDirectory().
Referenced by LoadPackage().
| Int_t TProof::UnloadPackage | ( | const char * | package | ) | [private] |
Definition at line 7015 of file TProof.cxx.
References TSystem::BaseName(), Broadcast(), Collect(), TString::EndsWith(), TObject::Error(), fStatus, gSystem, IsLite(), IsValid(), kPROOF_CACHE, kUnloadPackage, TString::Length(), TString::Remove(), and UnloadPackageOnClient().
Referenced by ClearPackage(), and TProofServ::HandleCache().
| Int_t TProof::UnloadPackageOnClient | ( | const char * | package | ) | [private] |
Definition at line 7048 of file TProof.cxx.
References TSystem::AccessPathName(), fEnabledPackagesOnClient, TList::FindObject(), TSystem::GetIncludePath(), gInterpreter, gSystem, kIsClient, TString::Length(), pack(), TList::Remove(), TString::Remove(), TString::ReplaceAll(), TSystem::SetIncludePath(), TObject::TestBit(), TSystem::Unlink(), and TObject::Warning().
Referenced by UnloadPackage(), and UnloadPackages().
| Int_t TProof::UnloadPackages | ( | ) | [private] |
Definition at line 7085 of file TProof.cxx.
References Broadcast(), Collect(), fEnabledPackagesOnClient, fStatus, IsLite(), IsValid(), kIsClient, kPROOF_CACHE, kUnloadPackages, TObject::TestBit(), and UnloadPackageOnClient().
Referenced by ClearPackages(), and TProofServ::HandleCache().
| Int_t TProof::UploadPackageOnClient | ( | const char * | package, | |
| EUploadPackageOpt | opt, | |||
| TMD5 * | md5 | |||
| ) | [private] |
Definition at line 7470 of file TProof.cxx.
References TSystem::AccessPathName(), TSystem::BaseName(), TString::Data(), TObject::Error(), TSystem::Exec(), TString::Form(), Form(), fPackageDir, fPackageLock, TSystem::Getenv(), TSystem::GetErrno(), TSystem::GetPathInfo(), gSystem, TSystem::IsAbsoluteFileName(), kExecutePermission, kFileExists, kGUNZIP, kIsClient, kPROOF_PackDownloadDir, kRemoveOld, kRM, kUNTAR2, kWritePermission, TProofLockPath::Lock(), md5, par, TSystem::PrependPathName(), TMD5::ReadChecksum(), ssize_t, stat, TSystem::Symlink(), TObject::TestBit(), TSystem::Unlink(), TProofLockPath::Unlock(), TObject::Warning(), TSystem::Which(), TSystem::WorkingDirectory(), and TMD5::WriteChecksum().
Referenced by BuildPackageOnClient(), and UploadPackage().
| Int_t TProof::DisablePackage | ( | const char * | package | ) | [private] |
Definition at line 6408 of file TProof.cxx.
References TString::Append(), TSystem::BaseName(), Broadcast(), Collect(), DisablePackageOnClient(), TString::EndsWith(), TObject::Error(), fManager, fNonUniqueMasters, TString::Form(), fStatus, gSystem, IsLite(), IsValid(), kAllUnique, kDisablePackage, kDisableSubPackage, kFALSE, kPROOF_CACHE, kTRUE, kUnique, TString::Length(), TString::Remove(), and TProofMgr::Rm().
Referenced by ClearPackage(), and TProofServ::HandleCache().
| Int_t TProof::DisablePackageOnClient | ( | const char * | package | ) | [private] |
Definition at line 6465 of file TProof.cxx.
References TSystem::AccessPathName(), TString::Data(), TSystem::Exec(), Form(), fPackageDir, fPackageLock, gSystem, kIsClient, kPROOF_PackDownloadDir, kRM, TProofLockPath::Lock(), TObject::TestBit(), TProofLockPath::Unlock(), and TObject::Warning().
Referenced by DisablePackage().
| Int_t TProof::DisablePackages | ( | ) | [private] |
Definition at line 6489 of file TProof.cxx.
References Broadcast(), Collect(), TString::Data(), TSystem::Exec(), fNonUniqueMasters, Form(), fPackageDir, fPackageLock, fStatus, gSystem, IsLite(), IsValid(), kAllUnique, kDisablePackages, kDisableSubPackages, kIsClient, kPROOF_CACHE, kRM, kUnique, TProofLockPath::Lock(), TObject::TestBit(), and TProofLockPath::Unlock().
Referenced by ClearPackages(), and TProofServ::HandleCache().
| void TProof::Activate | ( | TList * | slaves = 0 |
) | [private] |
Definition at line 2073 of file TProof.cxx.
References TMonitor::Activate(), TMonitor::DeActivateAll(), fActiveSlaves, fAllMonitor, TSlave::GetSocket(), and TSlave::IsValid().
Referenced by HandleInputMessage(), and TProofPlayerRemote::Process().
Definition at line 2157 of file TProof.cxx.
References TCollection::GetSize(), TSlave::GetSocket(), IsValid(), TSlave::IsValid(), MarkBad(), and TSocket::Send().
Referenced by AddDynamicPath(), AddIncludePath(), Archive(), AskParallel(), AskStatistics(), Broadcast(), BroadcastObject(), BuildPackage(), CleanupSession(), ClearCache(), ClearDataSetCache(), DisablePackage(), DisablePackages(), ExistsDataSet(), GetDataSet(), GetDataSetQuota(), GetDataSets(), GetListOfEnabledPackages(), GetListOfPackages(), GetListOfQueries(), GetLog(), GetMaxQueries(), GoAsynchronous(), IsDataReady(), Load(), LoadPackage(), ModifyWorkerLists(), TProofPlayerRemote::Process(), RegisterDataSet(), Remove(), RemoveDataSet(), RemoveDynamicPath(), RemoveIncludePath(), Retrieve(), SendCommand(), SendCurrentState(), SendObject(), SendPrint(), SetDataSetTreeName(), SetLogLevel(), SetParallelSilent(), SetRealTimeLog(), TProofLite::SetupWorkers(), ShowCache(), ShowDataSetCache(), ShowDataSetQuota(), ShowDataSets(), ShowEnabledPackages(), ShowPackages(), TerminateWorker(), UnloadPackage(), UnloadPackages(), UploadDataSet(), and VerifyDataSet().
Definition at line 2184 of file TProof.cxx.
References Broadcast(), fActiveSlaves, fAllUniqueSlaves, fSlaves, fUniqueSlaves, kActive, kAll, kAllUnique, and kUnique.
| Int_t TProof::BroadcastFile | ( | const char * | file, | |
| Int_t | opt, | |||
| const char * | rfile, | |||
| TList * | wrks | |||
| ) | [private] |
Definition at line 2292 of file TProof.cxx.
References TObject::Error(), TSlave::GetName(), TSlave::GetOrdinal(), TCollection::GetSize(), IsValid(), TSlave::IsValid(), and SendFile().
Referenced by BroadcastFile(), and SendInputDataFile().
| Int_t TProof::BroadcastFile | ( | const char * | file, | |
| Int_t | opt, | |||
| const char * | rfile = 0, |
|||
| ESlaves | list = kAllUnique | |||
| ) | [private] |
Definition at line 2321 of file TProof.cxx.
References BroadcastFile(), fActiveSlaves, fAllUniqueSlaves, fSlaves, fUniqueSlaves, kActive, kAll, kAllUnique, and kUnique.
| Int_t TProof::BroadcastGroupPriority | ( | const char * | grp, | |
| Int_t | priority, | |||
| ESlaves | list = kAllUnique | |||
| ) | [private] |
Definition at line 2133 of file TProof.cxx.
References fActiveSlaves, fAllUniqueSlaves, fSlaves, fUniqueSlaves, kActive, kAll, kAllUnique, and kUnique.
Referenced by TXProofServ::HandleInput().
| Int_t TProof::BroadcastGroupPriority | ( | const char * | grp, | |
| Int_t | priority, | |||
| TList * | workers | |||
| ) | [private] |
Definition at line 2106 of file TProof.cxx.
References TCollection::GetSize(), IsValid(), TSlave::IsValid(), MarkBad(), and TSlave::SendGroupPriority().
Definition at line 2249 of file TProof.cxx.
References TCollection::GetSize(), TSlave::GetSocket(), IsValid(), TSlave::IsValid(), MarkBad(), and TSocket::SendRaw().
Referenced by BroadcastRaw().
Definition at line 2276 of file TProof.cxx.
References BroadcastRaw(), fActiveSlaves, fAllUniqueSlaves, fSlaves, fUniqueSlaves, kActive, kAll, kAllUnique, and kUnique.
| Int_t TProof::Collect | ( | const TSlave * | sl, | |
| Long_t | timeout = -1, |
|||
| Int_t | endtype = -1, |
|||
| Bool_t | deactonfail = kFALSE | |||
| ) | [private] |
Definition at line 2349 of file TProof.cxx.
References TMonitor::Activate(), TMonitor::DeActivateAll(), fAllMonitor, fCurrentMonitor, TSlave::GetSocket(), TSlave::IsValid(), and ReleaseMonitor().
Referenced by AddDynamicPath(), AddIncludePath(), Archive(), AskParallel(), AskStatistics(), BuildPackage(), CheckFile(), ClassImp(), CleanupSession(), ClearCache(), ClearDataSetCache(), Collect(), Detach(), DisablePackage(), DisablePackages(), ExistsDataSet(), GetDataSet(), GetDataSetQuota(), GetDataSets(), GetListOfEnabledPackages(), GetListOfPackages(), GetListOfQueries(), GetListOfSlaveInfos(), GetLog(), GetMaxQueries(), GetTreeHeader(), GoParallel(), TXProofServ::HandleTermination(), TSlave::Interrupt(), IsDataReady(), Load(), LoadPackage(), ModifyWorkerLists(), Print(), TProofPlayerRemote::Process(), RegisterDataSet(), Remove(), RemoveDataSet(), RemoveDynamicPath(), RemoveIncludePath(), Retrieve(), SendCommand(), SendFile(), SendPrint(), SetDataSetTreeName(), SetParallelSilent(), TProofLite::SetupWorkers(), ShowCache(), ShowDataSetCache(), ShowDataSetQuota(), ShowDataSets(), ShowEnabledPackages(), ShowPackages(), TProofSuperMaster::StartSlaves(), StartSlaves(), UnloadPackage(), UnloadPackages(), UploadDataSet(), UploadPackage(), ValidateDSet(), TProofSuperMaster::ValidateDSet(), and VerifyDataSet().
| Int_t TProof::Collect | ( | TMonitor * | mon, | |
| Long_t | timeout = -1, |
|||
| Int_t | endtype = -1, |
|||
| Bool_t | deactonfail = kFALSE | |||
| ) | [private] |
Definition at line 2434 of file TProof.cxx.
References ActivateAsyncInput(), TSignalHandler::Add(), TList::Clear(), xmlio::cnt, CollectInputFrom(), TMonitor::DeActivate(), TMonitor::DeActivateAll(), DeActivateAsyncInput(), fBytesRead, fCpuTime, fCurrentMonitor, FindSlave(), fIntHandler, TList::First(), fPlayer, fRealTime, fRecvMessages, fRedirLog, fStatus, gEnv, TMonitor::GetActive(), TVirtualProofPlayer::GetExitStatus(), TInetAddress::GetHostName(), TSocket::GetInetAddress(), TMonitor::GetListOfActives(), TSlave::GetName(), TSlave::GetOrdinal(), TInetAddress::GetPort(), TCollection::GetSize(), TEnv::GetValue(), TObject::Info(), IsIdle(), IsSync(), kFALSE, TVirtualProofPlayer::kFinished, PDB, TSignalHandler::Remove(), TMonitor::ResetInterrupt(), s, TMonitor::Select(), and SendGroupView().
| Int_t TProof::CollectInputFrom | ( | TSocket * | s, | |
| Int_t | endtype = -1, |
|||
| Bool_t | deactonfail = kFALSE | |||
| ) | [private] |
Definition at line 2607 of file TProof.cxx.
References fCurrentMonitor, FindSlave(), HandleInputMessage(), TObject::Info(), kFALSE, kTRUE, MarkBad(), PDB, TMonitor::Remove(), s, TMessage::What(), and what.
Referenced by Collect(), TXSlave::HandleInput(), and TProofInputHandler::Notify().
| Int_t TProof::HandleInputMessage | ( | TSlave * | wrk, | |
| TMessage * | m, | |||
| Bool_t | deactonfail = kFALSE | |||
| ) | [private] |
Definition at line 2651 of file TProof.cxx.
References a, Activate(), active, TList::Add(), TVirtualProofPlayer::AddEventsProcessed(), TVirtualProofPlayer::AddInput(), TQueryResult::AddInput(), TVirtualProofPlayer::AddOutput(), TVirtualProofPlayer::AddOutputObject(), TVirtualPacketizer::AddProcessed(), TVirtualProofPlayer::AddQueryResult(), xmlio::Class, CleanGDirectory(), TList::Clear(), TObject::Clone(), TString::Contains(), TString::Data(), DataSetStatus(), DeactivateWorker(), TProofMergePrg::DecreaseNWrks(), TList::Delete(), DisableGoAsyn(), TQObject::Emit(), TObject::Error(), TPluginHandler::ExecPlugin(), TProofMergePrg::Export(), fAvailablePackages, fBytesRead, TSlave::fBytesRead, fBytesReady, fCheckFileStatus, fCpuTime, TSlave::fCpuTime, TSlaveInfo::fDataDir, fDataReady, fDrawQueries, fDSet, fEnabledPackages, fFinalizationRunning, fGroup, TSlaveInfo::fHostName, TSlave::fImage, TList::FindObject(), TList::First(), TList::FirstLink(), fIsWaiting, TProofServ::FlushLogFile(), fMergePrg, fMergersSet, TSlave::fName, fNotIdle, TSlave::fOrdinal, TString::Form(), Form(), fOtherQueries, TSlave::fParallel, fPlayer, fprintf(), fProgressDialog, fProgressDialogStarted, TSlave::fProofWorkDir, fProtocol, fQueries, fRealTime, TSlave::fRealTime, fRecvMessages, fRedirLog, fSeqNum, fSlaveInfo, fStatus, TSlave::fStatus, fSync, fTotalBytes, fWaitingSlaves, TSlave::fWorkDir, gDirectory, TDirectory::Get(), TVirtualProofPlayer::GetCurrentQuery(), TSlave::GetImage(), TQueryResult::GetInputList(), TVirtualProofPlayer::GetInputList(), GetListOfActiveSlaves(), GetListOfBadSlaves(), TSlave::GetMsd(), TNamed::GetName(), TObject::GetName(), TVirtualProofPlayer::GetNextPacket(), TSlaveInfo::GetOrdinal(), TSlave::GetOrdinal(), GetOutput(), TVirtualProofPlayer::GetOutputList(), TVirtualProofPlayer::GetPacketizer(), TProofServ::GetPrefix(), GetRemoteProtocol(), TCollection::GetSize(), TSlave::GetSocket(), TProofServ::GetSocket(), TNamed::GetTitle(), gProofServ, gROOT, gSystem, TVirtualProofPlayer::HandleRecvHisto(), HandleSubmerger(), TSystem::HostName(), i, TProofMergePrg::IncreaseIdx(), TObject::Info(), TROOT::IsBatch(), IsLite(), TString::IsNull(), TSlaveInfo::kBad, kFALSE, kIsClient, kIsMaster, kListEnabledPackages, kListPackages, kMESS_NOTOK, kMESS_OBJECT, kMESS_OK, TSlaveInfo::kNotActive, kPROOF_AUTOBIN, kPROOF_CHECKFILE, kPROOF_DATA_READY, kPROOF_DATASET_STATUS, kPROOF_ENDINIT, kPROOF_FATAL, kPROOF_FEEDBACK, kPROOF_GETOBJECT, kPROOF_GETPACKET, kPROOF_GETPARALLEL, kPROOF_GETSLAVEINFO, kPROOF_GETSTATS, kPROOF_GETTREEHEADER, kPROOF_LOGDONE, kPROOF_LOGFILE, kPROOF_MAXQUERIES, kPROOF_MESSAGE, kPROOF_OUTPUTLIST, kPROOF_OUTPUTOBJECT, kPROOF_PACKAGE_LIST, kPROOF_PING, kPROOF_PROGRESS, kPROOF_QUERYLIST, kPROOF_QUERYSUBMITTED, kPROOF_RETRIEVE, kPROOF_SENDFILE, kPROOF_SERVERSTARTED, kPROOF_SESSIONTAG, kPROOF_SETIDLE, kPROOF_STARTPROCESS, kPROOF_STOP, kPROOF_STOPPROCESS, kPROOF_SUBMERGER, kPROOF_TOUCH, kPROOF_VALIDATE_DSET, kPROOF_VERSARCHCOMP, kTRUE, kUseProgressDialog, kUsingSessionGui, Long64_t, m, TVirtualPacketizer::MarkBad(), MarkBad(), max, name, nentries, NotifyLogMsg(), o, out, p, PDB, pi, prefix, Printf(), TVirtualProofPlayer::Progress(), QueryResultReady(), RecvLogFile(), TList::Remove(), TString::ReplaceAll(), TObject::ResetBit(), ResetProgressDialog(), s, SafeDelete, TSocket::Send(), TProofServ::SendAsynMessage(), TSlave::SetArchCompiler(), TVirtualProofPlayer::SetCurrentQuery(), TQueryResult::SetInputList(), TCollection::SetName(), TNamed::SetName(), TQueryResult::SetOutputList(), TCollection::SetOwner(), TSlave::SetROOTVersion(), TSlave::SetSessionTag(), TSlaveInfo::SetStatus(), TSlaveInfo::SetSysInfo(), size, snprintf, StartupMessage(), TVirtualProofPlayer::StoreFeedback(), str, TObject::TestBit(), TNamed::TNamed(), total, TSlave::Touch(), type, TVirtualProofPlayer::UpdateAutoBin(), UpdateDialog(), TDSet::Validate(), TObject::Warning(), TMessage::What(), what, xmax, xmin, ymax, and ymin.
Referenced by CollectInputFrom().
Definition at line 3503 of file TProof.cxx.
References TMergerInfo::AreAllWorkersMerged(), AskForOutput(), TList::At(), TList::Clear(), CreateMerger(), TMergerInfo::Deactivate(), TObject::Error(), fCurrentMonitor, fFinalizationRunning, fLastAssignedMerger, fMergePrg, fMergers, fMergersCount, fMergersSet, fRedirectNext, fWorkersToMerge, TMonitor::GetActive(), GetActiveMergersCount(), TMergerInfo::GetMerger(), TSlave::GetName(), GetNumberOfActiveSlaves(), TSlave::GetOrdinal(), GetParameter(), TSlave::GetPort(), TProofServ::GetPrefix(), TCollection::GetSize(), TSlave::GetSocket(), TParameter< AParamType >::GetVal(), TMergerInfo::GetWorkers(), gProofServ, TObject::Info(), TMergerInfo::IsActive(), IsEndMaster(), IsLite(), kFALSE, kMergerDown, kOutputSent, kOutputSize, kPROOF_SUBMERGER, kStopMerging, kTRUE, TMath::Nint(), o, PDB, prefix, Printf(), RedirectWorker(), s, TProofServ::SendAsynMessage(), TMergerInfo::SetMergedWorker(), TProofMergePrg::SetNWrks(), TMath::Sqrt(), and type.
Referenced by HandleInputMessage().
Definition at line 2091 of file TProof.cxx.
References TMonitor::ActivateAll(), fCurrentMonitor, and m.
Referenced by TXProofServ::Terminate().
| void TProof::ReleaseMonitor | ( | TMonitor * | mon | ) | [private] |
Definition at line 2337 of file TProof.cxx.
References fActiveMonitor, fAllMonitor, fAllUniqueMonitor, and fUniqueMonitor.
Referenced by Collect().
| void TProof::FindUniqueSlaves | ( | ) | [private, virtual] |
Definition at line 1590 of file TProof.cxx.
References TMonitor::Add(), TList::Add(), TList::Clear(), TMonitor::DeActivateAll(), TObject::Error(), fActiveSlaves, fAllUniqueMonitor, fAllUniqueSlaves, fImage, fNonUniqueMasters, fUniqueMonitor, fUniqueSlaves, kFALSE, TSlave::kMaster, TSlave::kSlave, kTRUE, R__ASSERT, TList::Remove(), TMonitor::Remove(), and TMonitor::RemoveAll().
Referenced by GoParallel(), MarkBad(), and ModifyWorkerLists().
Definition at line 1575 of file TProof.cxx.
References fSlaves, TSlave::GetSocket(), TSlave::IsValid(), and s.
Referenced by Collect(), CollectInputFrom(), and MarkBad().
| TList* TProof::GetListOfSlaves | ( | ) | const [inline, private] |
Definition at line 645 of file TProof.h.
References fSlaves.
Referenced by GetListOfSlaveInfos(), and TProofServ::HandleWorkerLists().
| TList* TProof::GetListOfInactiveSlaves | ( | ) | const [inline, private] |
Definition at line 646 of file TProof.h.
References fInactiveSlaves.
Referenced by TProofServ::HandleSocketInput().
| TList* TProof::GetListOfUniqueSlaves | ( | ) | const [inline, private] |
| TList* TProof::GetListOfBadSlaves | ( | ) | const [inline, private] |
Definition at line 648 of file TProof.h.
References fBadSlaves.
Referenced by GetListOfSlaveInfos(), HandleInputMessage(), and TProofServ::HandleWorkerLists().
| Int_t TProof::GetNumberOfSlaves | ( | ) | const [private] |
Definition at line 1662 of file TProof.cxx.
References fSlaves, and TCollection::GetSize().
Referenced by TProofLite::Print(), and Print().
| Int_t TProof::GetNumberOfActiveSlaves | ( | ) | const [private] |
Definition at line 1670 of file TProof.cxx.
References fActiveSlaves, and TCollection::GetSize().
Referenced by HandleSubmerger(), MarkBad(), TProofLite::Print(), Print(), SendGroupView(), and SendInitialState().
| Int_t TProof::GetNumberOfInactiveSlaves | ( | ) | const [private] |
Definition at line 1679 of file TProof.cxx.
References fInactiveSlaves, and TCollection::GetSize().
Referenced by TProofLite::Print(), and Print().
| Int_t TProof::GetNumberOfUniqueSlaves | ( | ) | const [private] |
Definition at line 1688 of file TProof.cxx.
References fUniqueSlaves, and TCollection::GetSize().
Referenced by Exec(), TProofLite::Print(), and Print().
| Int_t TProof::GetNumberOfBadSlaves | ( | ) | const [private] |
Definition at line 1697 of file TProof.cxx.
References fBadSlaves, and TCollection::GetSize().
Referenced by TProofLite::Print(), and Print().
| Bool_t TProof::IsEndMaster | ( | ) | const [inline, private] |
Definition at line 655 of file TProof.h.
References fEndMaster.
Referenced by TXProofServ::CreateServer(), TProofServ::CreateServer(), HandleSubmerger(), and ModifyWorkerLists().
| void TProof::ModifyWorkerLists | ( | const char * | ord, | |
| Bool_t | add | |||
| ) | [private] |
Definition at line 10221 of file TProof.cxx.
References TMonitor::Add(), Broadcast(), Collect(), fActiveMonitor, fActiveSlaves, fCollectTimeout, fInactiveSlaves, FindUniqueSlaves(), TSlave::GetOrdinal(), TObject::Info(), IsEndMaster(), kActivateWorker, kActive, TSlave::kActive, kDeactivateWorker, kFALSE, TSlave::kInactive, kIsMaster, kPROOF_WORKERLISTS, kTRUE, out, TMonitor::Remove(), and TObject::TestBit().
Referenced by ActivateWorker(), and DeactivateWorker().
| Bool_t TProof::IsSync | ( | ) | const [inline, private] |
Definition at line 658 of file TProof.h.
References fSync.
Referenced by Collect(), TProofPlayerRemote::Process(), and TProofProgressDialog::ResetProgressDialog().
| void TProof::InterruptCurrentMonitor | ( | ) | [private] |
Definition at line 10187 of file TProof.cxx.
References fCurrentMonitor, and TMonitor::Interrupt().
Referenced by TXProofServ::HandleTermination(), and StopProcess().
| void TProof::SetRunStatus | ( | ERunStatus | rst | ) | [inline, private] |
Definition at line 661 of file TProof.h.
References fRunStatus.
Referenced by TProofServ::HandleSocketInput(), TProofLite::Init(), TProofLite::Process(), Process(), and StopProcess().
| void TProof::MarkBad | ( | TSlave * | wrk, | |
| const char * | reason = 0 | |||
| ) | [private] |
Definition at line 3933 of file TProof.cxx.
References TList::Add(), TVirtualProofPlayer::AddOutputObject(), TSlave::Close(), TString::Data(), TMonitor::DeActivate(), TProofMgr::DiscardSession(), TObject::Error(), fActiveMonitor, fActiveSlaves, fAllMonitor, fAllUniqueSlaves, fBadSlaves, fCloseMutex, fCurrentMonitor, fInactiveSlaves, FindUniqueSlaves(), fManager, fMergersCount, fMergersSet, fNonUniqueMasters, Form(), fPlayer, fSendGroupView, fSlaves, fUniqueSlaves, fUrl, fValid, gDebug, gEnv, TMonitor::GetActive(), TUrl::GetHost(), TSlave::GetName(), GetNumberOfActiveSlaves(), TSlave::GetOrdinal(), GetOutput(), TVirtualProofPlayer::GetPacketizer(), GetParameter(), TSlave::GetPort(), TUrl::GetPort(), TSlave::GetSocket(), TUrl::GetUser(), TParameter< AParamType >::GetVal(), TEnv::GetValue(), gProofServ, gSystem, TSystem::HostName(), TObject::Info(), IsMaster(), TString::IsNull(), TProofServ::IsTopMaster(), IsValid(), kFALSE, kIsClient, kNPOS, kPROOF_TerminateWorker, kPROOF_WorkerIdleTO, kTRUE, TVirtualPacketizer::MarkBad(), TMath::Nint(), ord, XrdMonCtrCollector::port, Printf(), R__LOCKGUARD2, TProofServ::ReleaseWorker(), TList::Remove(), TMonitor::Remove(), SaveWorkerInfo(), TProofServ::SendAsynMessage(), TCollection::SetName(), TMath::Sqrt(), and TObject::TestBit().
Referenced by Broadcast(), BroadcastGroupPriority(), BroadcastRaw(), CollectInputFrom(), GetListOfSlaveInfos(), GoParallel(), HandleInputMessage(), MarkBad(), Ping(), SendFile(), SendGroupView(), and TerminateWorker().
| void TProof::MarkBad | ( | TSocket * | s, | |
| const char * | reason = 0 | |||
| ) | [private] |
Definition at line 4086 of file TProof.cxx.
References fCloseMutex, FindSlave(), IsValid(), MarkBad(), R__LOCKGUARD2, and s.
| void TProof::TerminateWorker | ( | TSlave * | wrk | ) | [private] |
Definition at line 4101 of file TProof.cxx.
References gDebug, TSlave::GetSocket(), TObject::Info(), TSocket::IsValid(), kPROOF_STOP, kPROOF_TerminateWorker, MarkBad(), TSocket::Send(), and TObject::Warning().
Referenced by TProofServ::HandleSocketInput(), RemoveWorkers(), and TerminateWorker().
| void TProof::TerminateWorker | ( | const char * | ord | ) | [private] |
Definition at line 4125 of file TProof.cxx.
References Broadcast(), fSlaves, TSlave::GetOrdinal(), IsMaster(), kFALSE, kPROOF_STOP, kTRUE, and TerminateWorker().
| void TProof::ActivateAsyncInput | ( | ) | [private] |
Definition at line 3839 of file TProof.cxx.
References TFileHandler::Add(), fSlaves, and TSlave::GetInputHandler().
Referenced by Collect(), Init(), and TProofLite::Init().
| void TProof::DeActivateAsyncInput | ( | ) | [private] |
Definition at line 3852 of file TProof.cxx.
References fSlaves, TSlave::GetInputHandler(), and TFileHandler::Remove().
Definition at line 4680 of file TProof.cxx.
References Form(), fQueries, GetListOfQueries(), TNamed::GetName(), TQueryResult::GetSeqNum(), and TNamed::GetTitle().
Referenced by Archive(), Finalize(), Remove(), and Retrieve().
| void TProof::PrintProgress | ( | Long64_t | total, | |
| Long64_t | processed, | |||
| Float_t | procTime = -1., |
|||
| Long64_t | bytesread = -1 | |||
| ) | [private] |
Definition at line 8077 of file TProof.cxx.
References TString::Data(), fprintf(), fPrintProgress, fRedirLog, kFALSE, and l.
Referenced by Progress().
Definition at line 3883 of file TProof.cxx.
References TList::Add(), fMergers, fMergersCount, fRedirectNext, fWorkersToMerge, TSlave::GetOrdinal(), TCollection::GetSize(), TSlave::GetSocket(), TObject::Info(), kBeMerger, kFALSE, kPROOF_SUBMERGER, kTRUE, PDB, and TSocket::Send().
Referenced by HandleSubmerger().
Definition at line 3700 of file TProof.cxx.
References TMergerInfo::AddMergedObjects(), TMergerInfo::AddWorker(), AskForOutput(), TList::At(), TObject::Error(), FindNextFreeMerger(), fMergers, TMergerInfo::GetMerger(), TSlave::GetName(), TSlave::GetOrdinal(), TMergerInfo::GetPort(), TCollection::GetSize(), TObject::Info(), IsLite(), kPROOF_SUBMERGER, kSendOutput, PDB, and s.
Referenced by HandleSubmerger().
| Int_t TProof::GetActiveMergersCount | ( | ) | [private] |
Definition at line 3865 of file TProof.cxx.
References fMergers, and TMergerInfo::IsActive().
Referenced by HandleSubmerger().
| Int_t TProof::FindNextFreeMerger | ( | ) | [private] |
Definition at line 3732 of file TProof.cxx.
References TList::At(), fLastAssignedMerger, fMergers, and TCollection::GetSize().
Referenced by RedirectWorker().
| void TProof::ResetMergers | ( | ) | [inline, private] |
Definition at line 680 of file TProof.h.
References fMergersSet, and kFALSE.
Referenced by TProofServ::HandleProcess().
| void TProof::AskForOutput | ( | TSlave * | sl | ) | [private] |
Definition at line 3763 of file TProof.cxx.
References fMergePrg, TSlave::GetOrdinal(), TSlave::GetSocket(), TProofMergePrg::IncreaseNWrks(), TObject::Info(), IsLite(), kPROOF_SUBMERGER, kSendOutput, PDB, and TSocket::Send().
Referenced by HandleSubmerger(), and RedirectWorker().
| void TProof::FinalizationDone | ( | ) | [inline, private] |
Definition at line 683 of file TProof.h.
References fFinalizationRunning, and kFALSE.
Referenced by TProofPlayerRemote::Finalize().
| void TProof::ResetMergePrg | ( | ) | [private] |
Definition at line 2149 of file TProof.cxx.
References fActiveSlaves, fMergePrg, TCollection::GetSize(), and TProofMergePrg::Reset().
Referenced by TProofPlayerRemote::Process().
| void TProof::ParseConfigField | ( | const char * | config | ) | [private] |
Definition at line 937 of file TProof.cxx.
References AddEnvVar(), TString::Atoi(), TString::BeginsWith(), TString::Contains(), TString::Data(), DelEnvVar(), fgProofEnvList, TList::FindObject(), TString::Form(), gEnv, TString::Index(), TObject::Info(), TString::IsDigit(), IsLite(), kNPOS, TString::Length(), n, Printf(), TString::ReplaceAll(), TEnv::SetValue(), and TObject::Warning().
Referenced by Init().
| Bool_t TProof::Prompt | ( | const char * | p | ) | [private] |
Definition at line 6154 of file TProof.cxx.
References a, TString::Contains(), TString::Data(), Getline(), kFALSE, kTRUE, and Printf().
Referenced by ClearData().
| void TProof::InitMembers | ( | ) | [protected] |
Definition at line 472 of file TProof.cxx.
References AddEnvVar(), DelEnvVar(), env, fActiveMonitor, fActiveSlaves, fAllMonitor, fAllUniqueMonitor, fAllUniqueSlaves, fAvailablePackages, fBadSlaves, fBytesRead, fBytesReady, fChains, fCloseMutex, fCollectTimeout, fCpuTime, fCurrentMonitor, fDataReady, fDrawQueries, fDSet, fDynamicStartup, fEnabledPackages, fEnabledPackagesOnClient, fEndMaster, fFeedback, fFinalizationRunning, fGlobalPackageDirList, fInactiveSlaves, fInputData, fIntHandler, fIsWaiting, fLastAssignedMerger, fLoadedMacros, fLogFileR, fLogFileW, fLogToWindowOnly, fManager, fMasterServ, fMaxDrawQueries, fMergers, fMergersCount, fMergersSet, fNonUniqueMasters, fNotIdle, fOtherQueries, fPackageLock, fPlayer, fPrintProgress, fProgressDialog, fProgressDialogStarted, fProtocol, fQueries, fQueryMode, fRealTime, fRecvMessages, fRedirLog, fRunningDSets, fRunStatus, fSendGroupView, fSeqNum, fSessionID, fSlaveInfo, fSlaves, fSync, fTotalBytes, fUniqueMonitor, fUniqueSlaves, fValid, fWaitingSlaves, fWorkersToMerge, TSystem::Getenv(), gSystem, TObject::Info(), kFALSE, kRunning, kSync, kTRUE, kUseProgressDialog, TObject::SetBit(), and TObject::Warning().
Referenced by TProof().
| Int_t TProof::Init | ( | const char * | masterurl, | |
| const char * | conffile, | |||
| const char * | confdir, | |||
| Int_t | loglevel, | |||
| const char * | alias = 0 | |||
| ) | [protected] |
Definition at line 671 of file TProof.cxx.
References TSystem::AccessPathName(), ActivateAsyncInput(), TSeqCollection::Add(), TList::Add(), AddInput(), AssertPath(), TString::Data(), TMonitor::DeActivateAll(), TMessage::EnableSchemaEvolutionForAll(), TObject::Error(), TSystem::ExpandPathName(), fActiveMonitor, fActiveSlaves, fAllMonitor, fAllUniqueMonitor, fAllUniqueSlaves, fAvailablePackages, fBadSlaves, fBytesRead, fChains, fCollectTimeout, fConfDir, fConfFile, fCpuTime, fCurrentMonitor, fDataPoolUrl, fDrawQueries, fDynamicStartup, fEnabledPackages, fEnabledPackagesOnClient, fEndMaster, fFeedback, fGlobalPackageDirList, fGroup, fImage, fInactiveSlaves, fInputData, fIntHandler, fIsWaiting, fLoadedMacros, fLogFileName, fLogFileR, fLogFileW, fLogLevel, fLogToWindowOnly, fMaster, fMasterServ, fMaxDrawQueries, fNonUniqueMasters, fNotIdle, fopen, TString::Form(), Form(), fOtherQueries, fPackageDir, fPackageLock, fPlayer, fPrintProgress, fProgressDialog, fProgressDialogStarted, fProtocol, fQueries, fRealTime, fRecvMessages, fRedirLog, fRunningDSets, fSendGroupView, fSeqNum, fSessionID, fSlaveInfo, fSlaves, fStatus, fSync, fUniqueMonitor, fUniqueSlaves, fUrl, fValid, fWaitingSlaves, fWorkDir, gEnv, TProofServ::GetGroup(), TROOT::GetListOfSockets(), TUrl::GetOptions(), TProofServ::GetPackageDir(), TSystem::GetPid(), TCollection::GetSize(), TEnv::GetValue(), GoParallel(), gProofServ, gROOT, gROOTMutex, gSystem, TObject::Info(), TString::Insert(), IsIdle(), IsMaster(), TString::IsNull(), IsValid(), kFALSE, kIsClient, kIsMaster, kNewInputData, kPROOF_ConfDir, kPROOF_ConfFile, kPROOF_PackageLockFile, kPROOF_PackDir, kPROOF_Protocol, kPROOF_WorkDir, kReadPermission, kSortDescending, kTRUE, kUsingSessionGui, TString::Length(), MakePlayer(), opts, ParseConfigField(), R__ASSERT, R__LOCKGUARD2, TString::ReplaceAll(), TObject::ResetBit(), SafeDelete, SendInitialState(), SetActive(), SetAlias(), TObject::SetBit(), TCollection::SetName(), TUrl::SetOptions(), TCollection::SetOwner(), StartSlaves(), TSystem::TempDirectory(), TObject::TestBit(), TNamed::TNamed(), TString::Tokenize(), TObject::Warning(), and TSystem::WorkingDirectory().
Referenced by TProof().
Definition at line 1351 of file TProof.cxx.
References TMonitor::Add(), TList::Add(), AddWorkers(), TSlave::Close(), Collect(), CreateSubmaster(), emsg(), TObject::Error(), fAllMonitor, fConfFile, TPluginManager::FindHandler(), fIntHandler, fprintf(), fProgressDialog, fProtocol, fSlaves, fUrl, gDebug, TROOT::GetPluginManager(), TSlave::GetSocket(), TSlave::GetStatus(), TUrl::GetUrl(), TProofServ::GetWorkers(), gProofServ, gROOT, TObject::Info(), TROOT::IsBatch(), TSlave::IsValid(), kFALSE, kIsMaster, TSlave::kMaster, kPROOF_Protocol, TProofServ::kQueryStop, kTRUE, kUseProgressDialog, TPluginHandler::LoadPlugin(), Printf(), TList::Remove(), TMonitor::Remove(), TProofServ::SendAsynMessage(), TSlave::SetInterruptHandler(), TSlave::SetupServ(), StartupMessage(), TObject::TestBit(), and TProofInterruptHandler.
Referenced by Init(), and TProofPEAC::StartSlaves().
Definition at line 1102 of file TProof.cxx.
References TMonitor::Add(), TList::Add(), AddDynamicPath(), AddIncludePath(), CreateSlave(), TString::Data(), EnablePackage(), TObject::Error(), fAllMonitor, fBadSlaves, fDynamicStartup, fImage, fLoadedMacros, TString::Form(), TString::Format(), fSlaves, fUrl, TSystem::GetDynamicPath(), TProofServ::GetEnabledPackages(), TProofServ::GetGroup(), TProofServ::GetImage(), TProofNodeInfo::GetImage(), TSystem::GetIncludePath(), TObjString::GetName(), TProofNodeInfo::GetNodeName(), TProofNodeInfo::GetOrdinal(), TProofServ::GetOrdinal(), TProofNodeInfo::GetPerfIndex(), TUrl::GetPort(), TProofNodeInfo::GetPort(), TCollection::GetSize(), TSlave::GetSocket(), TProofServ::GetSocket(), TProofServ::GetUser(), TProofServ::GetWorkDir(), TProofNodeInfo::GetWorkDir(), gProofServ, gSystem, TSystem::HostName(), image, TObject::Info(), IsMaster(), TString::IsNull(), TSlave::IsValid(), kFALSE, kPROOF_SERVERSTARTED, TSlave::kSlave, kTRUE, TString::Length(), Load(), m, ord, PDB, Printf(), TString::ReplaceAll(), SafeDelete, TSocket::Send(), TProofServ::SendParallel(), TCollection::SetOwner(), SetParallel(), TSlave::SetupServ(), u, UploadPackage(), and workdir.
Referenced by TProofServ::HandleProcess(), TProofServ::HandleSocketInput(), and StartSlaves().
Definition at line 1286 of file TProof.cxx.
References xmlio::Class, TObject::ClassName(), TObject::Error(), fFileMap, fSlaves, gDebug, TSlave::GetName(), TProofNodeInfo::GetNodeName(), TSlave::GetOrdinal(), TCollection::GetSize(), gProofServ, TObject::Info(), TObject::InheritsFrom(), IsMaster(), TProofServ::ReleaseWorker(), TerminateWorker(), and TObject::Warning().
Referenced by TProofLite::Process(), TProofServ::ProcessNext(), and TProofLite::~TProofLite().
| void TProof::SetPlayer | ( | TVirtualProofPlayer * | player | ) | [protected] |
Definition at line 9091 of file TProof.cxx.
References fPlayer.
Referenced by TProofServ::DeletePlayer(), MakePlayer(), TProofServ::MakePlayer(), and TProofSuperMaster::MakePlayer().
| TVirtualProofPlayer* TProof::GetPlayer | ( | ) | const [inline, protected] |
Definition at line 704 of file TProof.h.
References fPlayer.
Referenced by TProofServ::HandleSocketInput(), TVirtualPacketizer::HandleTimer(), MakePlayer(), TProofSuperMaster::MakePlayer(), and TProofSuperMaster::Process().
| TVirtualProofPlayer * TProof::MakePlayer | ( | const char * | player = 0, |
|
| TSocket * | s = 0 | |||
| ) | [protected, virtual] |
Definition at line 9101 of file TProof.cxx.
References TVirtualProofPlayer::Create(), GetPlayer(), s, and SetPlayer().
Referenced by Init(), TProofLite::Init(), and TProofServ::MakePlayer().
| void TProof::UpdateDialog | ( | ) | [protected] |
Definition at line 3782 of file TProof.cxx.
References TQObject::Emit(), TQObject::EmitVA(), fPlayer, fSync, TVirtualProofPlayer::GetEventsProcessed(), TVirtualProofPlayer::GetExitStatus(), GetRemoteProtocol(), TObject::Info(), TVirtualProofPlayer::kAborted, kFALSE, TVirtualProofPlayer::kStopped, kTRUE, Long64_t, and Progress().
Referenced by HandleInputMessage(), and TProofLite::Process().
| void TProof::HandleLibIncPath | ( | const char * | what, | |
| Bool_t | add, | |||
| const char * | dirs | |||
| ) | [protected] |
Definition at line 7935 of file TProof.cxx.
References TSystem::AccessPathName(), TSystem::AddIncludePath(), TString::Data(), TObject::Error(), TSystem::ExpandPathName(), Form(), gDebug, TSystem::GetDynamicPath(), TSystem::GetIncludePath(), TObjString::GetName(), gInterpreter, gSystem, TObject::Info(), kIterBackward, kNPOS, kReadPermission, TString::Length(), TString::ReplaceAll(), TSystem::SetDynamicPath(), TSystem::SetIncludePath(), TString::Tokenize(), type, and TObject::Warning().
Referenced by AddDynamicPath(), AddIncludePath(), RemoveDynamicPath(), and RemoveIncludePath().
| TList* TProof::GetListOfActiveSlaves | ( | ) | const [inline, protected] |
Definition at line 711 of file TProof.h.
References fActiveSlaves.
Referenced by ClassImp(), GetListOfSlaveInfos(), GetParallel(), GetTreeHeader(), HandleInputMessage(), TProofServ::HandleSocketInput(), TProofServ::HandleWorkerLists(), TProofPlayerRemote::InitPacketizer(), IsDataReady(), ValidateDSet(), and TProofSuperMaster::ValidateDSet().
| TSlave * TProof::CreateSlave | ( | const char * | url, | |
| const char * | ord, | |||
| Int_t | perf, | |||
| const char * | image, | |||
| const char * | workdir | |||
| ) | [protected] |
Definition at line 1535 of file TProof.cxx.
References TSlave::Create(), TSlave::fParallel, TSlave::GetSocket(), TSlave::IsValid(), TSlave::kSlave, and TSlave::SetInputHandler().
Referenced by AddWorkers(), TProofLite::SetupWorkers(), TProofPEAC::StartSlaves(), and TProofCondor::StartSlaves().
| TSlave * TProof::CreateSubmaster | ( | const char * | url, | |
| const char * | ord, | |||
| const char * | image, | |||
| const char * | msd | |||
| ) | [protected] |
Definition at line 1557 of file TProof.cxx.
References TSlave::Create(), TSlave::GetSocket(), TSlave::IsValid(), TSlave::kMaster, and TSlave::SetInputHandler().
Referenced by TProofSuperMaster::StartSlaves(), and StartSlaves().
| void TProof::SaveWorkerInfo | ( | ) | [protected, virtual] |
Definition at line 10518 of file TProof.cxx.
References TString::Data(), TSystem::DirName(), TObject::Error(), fBadSlaves, fclose(), TList::FindObject(), fopen, Form(), fprintf(), fSlaves, gDebug, TSystem::Getenv(), TSlave::GetName(), TSlave::GetOrdinal(), TSlave::GetPort(), TProofServ::GetSessionDir(), TSlave::GetUser(), TSlave::GetWorkDir(), gProofServ, gSystem, TObject::Info(), kIsClient, TString::Length(), TObject::TestBit(), and TObject::Warning().
Referenced by TXProofServ::CreateServer(), and MarkBad().
| Int_t TProof::Collect | ( | ESlaves | list = kActive, |
|
| Long_t | timeout = -1, |
|||
| Int_t | endtype = -1, |
|||
| Bool_t | deactonfail = kFALSE | |||
| ) | [protected] |
Definition at line 2407 of file TProof.cxx.
References TMonitor::ActivateAll(), Collect(), fActiveMonitor, fAllMonitor, fAllUniqueMonitor, fCurrentMonitor, fUniqueMonitor, kActive, kAll, kAllUnique, kUnique, and ReleaseMonitor().
| Int_t TProof::Collect | ( | TList * | slaves, | |
| Long_t | timeout = -1, |
|||
| Int_t | endtype = -1, |
|||
| Bool_t | deactonfail = kFALSE | |||
| ) | [protected] |
Definition at line 2376 of file TProof.cxx.
References TMonitor::Activate(), Collect(), TMonitor::DeActivateAll(), fAllMonitor, fCurrentMonitor, TSlave::GetSocket(), TSlave::IsValid(), and ReleaseMonitor().
| void TProof::SetDSet | ( | TDSet * | dset | ) | [inline, protected] |
Definition at line 722 of file TProof.h.
References fDSet.
Referenced by ValidateDSet(), and TProofSuperMaster::ValidateDSet().
| void TProof::ValidateDSet | ( | TDSet * | dset | ) | [protected, virtual] |
Definition at line 8315 of file TProof.cxx.
References TList::Add(), TList::AddAfter(), TList::After(), TList::At(), Collect(), TDSet::ElementsValid(), TList::FindObject(), TDSet::GetDirectory(), GetListOfActiveSlaves(), TDSet::GetListOfElements(), TDSet::GetObjName(), TCollection::GetSize(), TDSet::GetType(), i, TObject::Info(), j, kFALSE, kPROOF_VALIDATE_DSET, kTRUE, local, p, p2(), p3(), PDB, TList::Remove(), SetDSet(), TCollection::SetName(), TCollection::SetOwner(), and TObject::Warning().
Referenced by ClassImp(), and TProofServ::HandleSocketInput().
| TPluginHandler* TProof::GetProgressDialog | ( | ) | const [inline, protected] |
Definition at line 725 of file TProof.h.
References fProgressDialog.
Referenced by TProofSuperMaster::Process().
Definition at line 1055 of file TProof.cxx.
References TSystem::AccessPathName(), TSystem::Chmod(), TObject::Error(), TSystem::ExpandPathName(), gSystem, kFileExists, kTRUE, kWritePermission, and TSystem::mkdir().
Referenced by TProofLite::CreateSandbox(), and Init().
| void TProof::PrepareInputDataFile | ( | TString & | dataFile | ) | [protected] |
Definition at line 8567 of file TProof.cxx.
References TSystem::AccessPathName(), TSystem::CopyFile(), TString::Data(), TObject::Error(), TObject::FindObject(), fInputData, fInputDataFile, GetInputList(), TCollection::GetSize(), gSystem, TString::IsNull(), kFALSE, kNewInputData, kPROOF_InputDataFile, kReadPermission, TObject::kSingleKey, kTRUE, o, TFile::Open(), TObject::ResetBit(), SafeDelete, TObject::TestBit(), and TSystem::Unlink().
Referenced by TProofLite::SendInputDataFile(), and SendInputDataFile().
| void TProof::SendInputDataFile | ( | ) | [protected, virtual] |
Definition at line 8541 of file TProof.cxx.
References AddInput(), TSystem::BaseName(), BroadcastFile(), TString::Data(), Form(), gSystem, TObject::Info(), kActive, kBinary, TString::Length(), PrepareInputDataFile(), and TNamed::TNamed().
Referenced by TProofPlayerRemote::Process(), and TProofPlayerLite::Process().
| Int_t TProof::SendFile | ( | const char * | file, | |
| Int_t | opt = (kBinary|kForward|kCp|kCpBin), |
|||
| const char * | rfile = 0, |
|||
| TSlave * | sl = 0 | |||
| ) | [protected] |
Definition at line 5536 of file TProof.cxx.
References TList::Add(), TSystem::BaseName(), buf, CheckFile(), close, Collect(), TString::Data(), TObject::Error(), fActiveSlaves, fCollectTimeout, flags, Form(), TSlave::fSlaveType, fUniqueSlaves, TSystem::GetErrno(), TSlave::GetName(), TSlave::GetOrdinal(), TSystem::GetPathInfo(), TCollection::GetSize(), TSlave::GetSocket(), gSystem, id, TObject::Info(), Interrupt(), TString::IsNull(), IsValid(), TSlave::IsValid(), kActive, kBinary, kCp, kCpBin, kFALSE, kForce, kForward, kMAXBUF, kPROOF_SENDFILE, TSlave::kSlave, kSoftInterrupt, kTRUE, len, Long64_t, lseek, MarkBad(), O_BINARY, open, PDB, read, TSystem::ResetErrno(), SafeDelete, SEEK_SET, TSocket::Send(), TSocket::SendRaw(), size, snprintf, and TObject::SysError().
Referenced by BroadcastFile(), Exec(), TProofServ::HandleSocketInput(), Load(), TProofPlayerRemote::SendSelector(), and UploadPackage().
| static void* TProof::SlaveStartupThread | ( | void * | arg | ) | [static, protected] |
| Int_t TProof::AssertDataSet | ( | TDSet * | dset, | |
| TList * | input, | |||
| TDataSetManager * | mgr, | |||
| TString & | emsg | |||
| ) | [static, protected] |
Definition at line 10674 of file TProof.cxx.
References TDSet::Add(), TFileCollection::Add(), TList::Add(), TString::Data(), dir(), emsg(), fc, TList::First(), TString::Form(), TString::Format(), gDebug, gEnv, TDataSetManager::GetDataSet(), TDataSetManager::GetDataSetSrvMaps(), TFileCollection::GetDefaultTreeName(), TDSet::GetDirectory(), TFileCollection::GetList(), TEntryList::GetLists(), TObjString::GetName(), TNamed::GetName(), TDSet::GetObjName(), GetParameter(), TCollection::GetSize(), TEnv::GetValue(), gProofServ, TString::Index(), TString::IsNull(), TPair::Key(), kFALSE, TDSet::kMultiDSet, kNPOS, kTRUE, TString::Length(), TDataSetManager::ParseDataSetSrvMaps(), TDataSetManager::ParseUri(), TCollection::Print(), TString::Remove(), THashList::Remove(), TIter::Reset(), SafeDelete, TProofServ::SendAsynMessage(), TObject::SetBit(), TDSet::SetDirectory(), TDSet::SetEntryList(), TCollection::SetName(), TDSet::SetObjName(), TCollection::SetOwner(), TDSet::SetSrvMaps(), TObject::TestBit(), TNamed::TNamed(), and TPair::Value().
Referenced by TProofServ::HandleProcess(), and TProofLite::Process().
| Int_t TProof::GetInputData | ( | TList * | input, | |
| const char * | cachedir, | |||
| TString & | emsg | |||
| ) | [static, protected] |
Definition at line 11026 of file TProof.cxx.
References TSystem::AccessPathName(), TString::Data(), emsg(), TString::Form(), TNamed::GetTitle(), gSystem, k, o, and TFile::Open().
Referenced by TProofServ::HandleProcess().
| Int_t TProof::SaveInputData | ( | TQueryResult * | qr, | |
| const char * | cachedir, | |||
| TString & | emsg | |||
| ) | [static, protected] |
Definition at line 10923 of file TProof.cxx.
References TSystem::AccessPathName(), TSystem::CopyFile(), data, emsg(), TQueryResult::GetInputList(), TCollection::GetSize(), gSystem, TObject::Info(), kFALSE, kPROOF_InputDataFile, kTRUE, TFile::Open(), TNamed::TNamed(), and TCollection::Write().
Referenced by TProofServ::HandleProcess().
| Int_t TProof::SendInputData | ( | TQueryResult * | qr, | |
| TProof * | p, | |||
| TString & | emsg | |||
| ) | [static, protected] |
Definition at line 10993 of file TProof.cxx.
References TSystem::AccessPathName(), emsg(), TQueryResult::GetInputList(), TNamed::GetTitle(), gSystem, kBinary, and p.
Referenced by TProofPlayerRemote::Process().
Definition at line 5309 of file TProof.cxx.
References gSystem, TString::IsNull(), TString::kBoth, kFALSE, kTRUE, s, and TSystem::SplitAclicMode().
Referenced by Exec(), and TProofServ::HandleSocketInput().
| void TProof::SystemCmd | ( | const char * | cmd, | |
| Int_t | fdout | |||
| ) | [static, protected] |
Definition at line 6241 of file TProof.cxx.
References TSystem::ClosePipe(), TSystem::Exec(), TSystem::GetErrno(), gSystem, line, TSystem::OpenPipe(), TObject::Warning(), and write.
Referenced by ShowPackages().
| void TProof::cd | ( | Int_t | id = -1 |
) |
Definition at line 9387 of file TProof.cxx.
References d, GetManager(), TProofMgr::GetProofDesc(), and gProof.
Referenced by TSessionQueryFrame::OnBtnSubmit(), and TSessionViewer::OnListTreeClicked().
| Int_t TProof::Ping | ( | ) |
| void TProof::Touch | ( | ) |
Definition at line 4187 of file TProof.cxx.
References fSlaves, TCollection::GetSize(), TSlave::IsValid(), and TSlave::Touch().
| Long64_t TProof::Process | ( | TDSet * | dset, | |
| const char * | selector, | |||
| Option_t * | option = "", |
|||
| Long64_t | nentries = -1, |
|||
| Long64_t | firstentry = 0 | |||
| ) | [virtual] |
Definition at line 4308 of file TProof.cxx.
References TSystem::AddSignalHandler(), TString::Data(), TList::Delete(), fPlayer, fRunningDSets, fSync, gApplication, GetQueryMode(), TCollection::GetSize(), gSystem, TObject::Info(), IsIdle(), IsValid(), IsWaiting(), kFALSE, kRunning, kSync, kTRUE, Long64_t, TVirtualProofPlayer::Process(), TSystem::RemoveSignalHandler(), TString::ReplaceAll(), TCollection::SetOwner(), and SetRunStatus().
Referenced by TProofLite::Process(), TProofSuperMaster::Process(), Process(), TDSet::Process(), PT_Event(), PT_H1DataSet(), PT_H1FileCollection(), PT_H1MultiDataSet(), PT_H1MultiDSetEntryList(), PT_H1SimpleAsync(), PT_InputData(), PT_PackageArguments(), and PT_Simple().
| Long64_t TProof::Process | ( | TFileCollection * | fc, | |
| const char * | selector, | |||
| Option_t * | option = "", |
|||
| Long64_t | nentries = -1, |
|||
| Long64_t | firstentry = 0 | |||
| ) | [virtual] |
Definition at line 4360 of file TProof.cxx.
References TList::Add(), TVirtualProofPlayer::AddInput(), Form(), fPlayer, fProtocol, fRunningDSets, fSync, TVirtualProofPlayer::GetInputList(), TNamed::GetName(), TObject::Info(), IsLite(), IsValid(), Long64_t, Process(), TList::Remove(), and retval.
| Long64_t TProof::Process | ( | const char * | dsetname, | |
| const char * | selector, | |||
| Option_t * | option = "", |
|||
| Long64_t | nentries = -1, |
|||
| Long64_t | firstentry = 0, |
|||
| TObject * | enl = 0 | |||
| ) | [virtual] |
Definition at line 4396 of file TProof.cxx.
References TSystem::AccessPathName(), TList::Add(), AddInput(), buf, TString::Data(), dir(), elist, TString::EndsWith(), TObject::Error(), TObject::FindObject(), TList::FindObject(), TDirectory::FindObject(), TString::Format(), fProtocol, fRunningDSets, fSync, gDebug, gDirectory, GetInputList(), TUrl::GetOptions(), TUrl::GetUrl(), gSystem, TObject::Info(), IsLite(), TString::IsNull(), k, TString::kExact, kNPOS, kReadPermission, kTRUE, len, TString::Length(), Long64_t, name, names, TFile::Open(), Process(), TString::Remove(), TString::ReplaceAll(), retval, SafeDelete, TDSet::SetEntryList(), TUrl::SetOptions(), and TObject::Warning().
| Long64_t TProof::Process | ( | const char * | selector, | |
| Long64_t | nentries, | |||
| Option_t * | option = "" | |||
| ) | [virtual] |
Definition at line 4649 of file TProof.cxx.
References TList::Add(), fProtocol, fRunningDSets, fSync, TObject::Info(), IsLite(), IsValid(), TDSet::kEmpty, Long64_t, Process(), retval, and TObject::SetBit().
| Long64_t TProof::DrawSelect | ( | TDSet * | dset, | |
| const char * | varexp, | |||
| const char * | selection = "", |
|||
| Option_t * | option = "", |
|||
| Long64_t | nentries = -1, |
|||
| Long64_t | firstentry = 0 | |||
| ) | [virtual] |
Definition at line 4967 of file TProof.cxx.
References TVirtualProofPlayer::DrawSelect(), fPlayer, TString::Index(), TObject::Info(), IsIdle(), IsValid(), TString::kIgnoreCase, kNPOS, and TString::Replace().
Referenced by TDSet::Draw(), and DrawSelect().
| Long64_t TProof::DrawSelect | ( | const char * | dsetname, | |
| const char * | varexp, | |||
| const char * | selection = "", |
|||
| Option_t * | option = "", |
|||
| Long64_t | nentries = -1, |
|||
| Long64_t | firstentry = 0, |
|||
| TObject * | enl = 0 | |||
| ) |
Definition at line 4992 of file TProof.cxx.
References dir(), DrawSelect(), TObject::Error(), fProtocol, TObject::Info(), TString::kExact, kNPOS, Long64_t, name, retval, and TDSet::SetEntryList().
| Int_t TProof::Archive | ( | const char * | queryref, | |
| const char * | url = 0 | |||
| ) |
Definition at line 4898 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, kActive, kPROOF_ARCHIVE, and m.
| Int_t TProof::CleanupSession | ( | const char * | sessiontag | ) |
Definition at line 4916 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, kActive, kPROOF_CLEANUPSESSION, and m.
Referenced by TSessionViewer::CleanupSession().
Definition at line 4703 of file TProof.cxx.
References fPlayer, GetQueryReference(), and TObject::Info().
Referenced by TProofPlayerLite::Finalize(), TProofPlayerRemote::Finalize(), finalizeProof(), and TSessionQueryFrame::OnBtnFinalize().
Definition at line 4728 of file TProof.cxx.
References TString::Data(), TVirtualProofPlayer::Finalize(), TString::Form(), fPlayer, TNamed::GetName(), TVirtualProofPlayer::GetQueryResult(), GetQueryResult(), TNamed::GetTitle(), TObject::Info(), TQueryResult::IsFinalized(), TString::IsNull(), kFALSE, kTRUE, retrieve(), and Retrieve().
Definition at line 4837 of file TProof.cxx.
References GetQueryReference(), and TObject::Info().
Referenced by TSessionViewer::DeleteQuery(), Detach(), and PT_H1SimpleAsync().
Definition at line 4854 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, fPlayer, IsLite(), kActive, kPROOF_REMOVE, and m.
Definition at line 4771 of file TProof.cxx.
References GetQueryReference(), and TObject::Info().
Referenced by Finalize(), finalizeProof(), TSessionQueryFrame::OnBtnRetrieve(), PT_H1SimpleAsync(), and ShowLog().
| Int_t TProof::Retrieve | ( | const char * | queryref, | |
| const char * | path = 0 | |||
| ) |
Definition at line 4789 of file TProof.cxx.
References Broadcast(), TDirectoryFile::cd(), TFile::Close(), Collect(), fCollectTimeout, fPlayer, TVirtualProofPlayer::GetQueryResult(), TObject::Info(), TFile::IsOpen(), kActive, kPROOF_RETRIEVE, m, TFile::Open(), SafeDelete, TQueryResult::SetArchived(), and TObject::Write().
| void TProof::DisableGoAsyn | ( | ) |
Definition at line 5083 of file TProof.cxx.
References TQObject::Emit().
Referenced by HandleInputMessage().
| void TProof::GoAsynchronous | ( | ) |
Definition at line 5091 of file TProof.cxx.
References Broadcast(), fSync, GetRemoteProtocol(), TObject::Info(), IsIdle(), IsValid(), kPROOF_GOASYNC, and m.
Referenced by TProofProgressDialog::DoAsyn().
Definition at line 5048 of file TProof.cxx.
References fPlayer, fSlaves, TCollection::GetSize(), TObject::Info(), InterruptCurrentMonitor(), IsValid(), TSlave::IsValid(), kAborted, kIsClient, kStopped, PDB, SetRunStatus(), TSlave::StopProcess(), TVirtualProofPlayer::StopProcess(), and TObject::TestBit().
Referenced by Detach(), TProofProgressDialog::DoAbort(), TProofProgressDialog::DoStop(), TXProofServ::HandleInput(), TProofServ::HandleSocketInput(), TXProofServ::HandleTermination(), TSessionQueryFrame::OnBtnAbort(), TSessionQueryFrame::OnBtnStop(), and TProofChain::Progress().
| void TProof::Browse | ( | TBrowser * | b | ) | [virtual] |
Reimplemented from TObject.
Definition at line 9071 of file TProof.cxx.
References b, fActiveSlaves, fChains, fFeedback, fMaster, fPlayer, TVirtualProofPlayer::GetInputList(), TVirtualProofPlayer::GetListOfResults(), and TVirtualProofPlayer::GetOutputList().
Referenced by TSessionViewer::MyHandleMenu().
Definition at line 5767 of file TProof.cxx.
References TString::Data(), kIsClient, n, Printf(), SetParallelSilent(), and TObject::TestBit().
Referenced by AddWorkers(), TProofServ::HandleSocketInput(), TSessionFrame::OnApplyParallel(), run_selector_tests(), and TProofLite::SetupWorkers().
Definition at line 5711 of file TProof.cxx.
References Broadcast(), fLogLevel, gProofDebugLevel, gProofDebugMask, kAll, kPROOF_LOGLEVEL, snprintf, and str.
Referenced by getProof(), TProofServ::HandleSocketInput(), TSessionFrame::OnApplyLogLevel(), TSessionServerFrame::OnBtnConnectClicked(), and SendInitialState().
| void TProof::Close | ( | Option_t * | option = "" |
) |
Definition at line 1487 of file TProof.cxx.
References TList::Clear(), TSlave::Close(), TList::Delete(), fActiveSlaves, fAllUniqueSlaves, fBadSlaves, fCloseMutex, fIntHandler, fNonUniqueMasters, fSlaves, fUniqueSlaves, fValid, TROOT::GetListOfProofs(), TROOT::GetListOfSockets(), gProof, gROOT, gROOTMutex, IsProofd(), kFALSE, kIterBackward, R__LOCKGUARD2, and TCollection::Remove().
Referenced by TProofPEAC::Close(), Detach(), TXProofServ::HandleError(), TXProofServ::HandleTermination(), stressProof(), and ~TProof().
| void TProof::Print | ( | Option_t * | option = "" |
) | const [virtual] |
Reimplemented from TNamed.
Definition at line 4208 of file TProof.cxx.
References TList::Add(), AskStatistics(), Collect(), TObject::Error(), fActiveSlaves, fCollectTimeout, TList::First(), Form(), fSlaves, TSystem::GetBuildArch(), TSystem::GetBuildCompilerVersion(), GetBytesRead(), GetClientProtocol(), GetConfDir(), GetConfFile(), GetCpuTime(), GetDataPoolUrl(), TSystem::Getenv(), TProofServ::GetGroup(), GetImage(), GetLogLevel(), GetMaster(), GetNumberOfActiveSlaves(), GetNumberOfBadSlaves(), GetNumberOfInactiveSlaves(), GetNumberOfSlaves(), GetNumberOfUniqueSlaves(), TProofServ::GetOrdinal(), GetParallel(), GetPort(), GetRealTime(), GetRemoteProtocol(), GetSessionTag(), TROOT::GetSvnRevision(), GetUser(), TROOT::GetVersion(), gProofServ, gROOT, gSystem, TSystem::HostName(), IsParallel(), IsValid(), TString::kIgnoreCase, kIsClient, TSlave::kMaster, kPROOF_PRINT, TSlave::kSlave, Printf(), R__ASSERT, SendPrint(), TObject::TestBit(), and TSystem::WorkingDirectory().
Referenced by GetStatistics(), TProofServ::Print(), and PT_Open().
Definition at line 6196 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, fNonUniqueMasters, IsValid(), kAllUnique, kPROOF_CACHE, kShowCache, kShowSubCache, and kUnique.
Referenced by TProofServ::HandleCache().
| void TProof::ClearCache | ( | const char * | file = 0 |
) | [virtual] |
Definition at line 6219 of file TProof.cxx.
References Broadcast(), Collect(), fFileMap, fNonUniqueMasters, IsValid(), kAllUnique, kClearCache, kClearSubCache, kPROOF_CACHE, and kUnique.
Referenced by TProofServ::HandleCache().
| TList * TProof::GetListOfPackages | ( | ) |
Definition at line 8045 of file TProof.cxx.
References Broadcast(), Collect(), fAvailablePackages, fCollectTimeout, IsValid(), kActive, kListPackages, and kPROOF_CACHE.
Referenced by PT_PackageArguments(), PT_Packages(), and TSessionViewer::UpdateListOfPackages().
| TList * TProof::GetListOfEnabledPackages | ( | ) |
Definition at line 8061 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, fEnabledPackages, IsValid(), kActive, kListEnabledPackages, and kPROOF_CACHE.
Referenced by PT_Packages(), and TSessionViewer::UpdateListOfPackages().
Definition at line 6273 of file TProof.cxx.
References Broadcast(), Collect(), TString::Data(), fCollectTimeout, fflush(), fGlobalPackageDirList, fLogFileW, fNonUniqueMasters, Form(), fPackageDir, fprintf(), fRedirLog, TNamed::GetName(), TCollection::GetSize(), TNamed::GetTitle(), IsLite(), IsValid(), kAllUnique, kIsClient, kLS, kPROOF_CACHE, kShowPackages, kShowSubPackages, kTRUE, kUnique, lseek, SEEK_END, SystemCmd(), TObject::TestBit(), and TObject::Warning().
Referenced by DownloadPackage(), TProofServ::HandleCache(), and TSessionViewer::ShowPackages().
Definition at line 6338 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, fEnabledPackagesOnClient, gSystem, TSystem::HostName(), IsLite(), IsValid(), kActive, kIsClient, kPROOF_CACHE, kShowEnabledPackages, str, and TObject::TestBit().
Referenced by TProofServ::HandleCache(), and TSessionViewer::ShowEnabledPackages().
| Int_t TProof::ClearPackages | ( | ) |
Definition at line 6363 of file TProof.cxx.
References DisablePackages(), fStatus, IsValid(), and UnloadPackages().
Referenced by TProofServ::HandleCache(), TSessionFrame::OnClearPackages(), and PT_Packages().
| Int_t TProof::ClearPackage | ( | const char * | package | ) |
Definition at line 6380 of file TProof.cxx.
References TSystem::BaseName(), DisablePackage(), TString::EndsWith(), TObject::Error(), fStatus, gSystem, IsValid(), TString::Length(), TString::Remove(), and UnloadPackage().
Referenced by TProofServ::HandleCache(), TSessionFrame::OnDisablePackages(), PT_PackageArguments(), and PT_Packages().
| Int_t TProof::DownloadPackage | ( | const char * | par, | |
| const char * | dstdir = 0 | |||
| ) |
Definition at line 7200 of file TProof.cxx.
References TSystem::BaseName(), TString::Data(), TObject::Error(), fLogFileName, fManager, FileStat_t::fMode, TSystem::GetErrno(), TProofMgr::GetFile(), GetLastLog(), TMacro::GetListOfLines(), TSystem::GetPathInfo(), gSystem, TObject::Info(), TProofMgr::IsValid(), kFALSE, kTRUE, TSystem::mkdir(), R_ISDIR(), R_ISLNK(), TSystem::RedirectOutput(), s, ShowPackages(), TProofMgr::Stat(), and TObject::Warning().
Referenced by BuildPackageOnClient().
Definition at line 7112 of file TProof.cxx.
Referenced by AddWorkers(), EnablePackage(), make_event_trees(), TSessionServerFrame::OnBtnConnectClicked(), TSessionFrame::OnEnablePackages(), PT_PackageArguments(), PT_Packages(), and Run_Node_Tests().
| Int_t TProof::EnablePackage | ( | const char * | package, | |
| const char * | loadopts, | |||
| Bool_t | notOnClient = kFALSE | |||
| ) |
Definition at line 7125 of file TProof.cxx.
References TList::Add(), EnablePackage(), fProtocol, kTRUE, SafeDelete, TCollection::SetOwner(), and TObject::Warning().
Definition at line 7156 of file TProof.cxx.
References TSystem::BaseName(), BuildPackage(), TString::EndsWith(), TObject::Error(), fProtocol, gSystem, IsValid(), kBuildAll, kDontBuildOnClient, TString::Length(), LoadPackage(), TString::Remove(), and TObject::Warning().
| Int_t TProof::UploadPackage | ( | const char * | par, | |
| EUploadPackageOpt | opt = kUntar | |||
| ) |
Definition at line 7294 of file TProof.cxx.
References TSystem::AccessPathName(), TSystem::BaseName(), Collect(), TString::Data(), TObject::Error(), TSystem::ExpandPathName(), fCheckFileStatus, fCollectTimeout, fGlobalPackageDirList, TMD5::FileChecksum(), fNonUniqueMasters, TString::Form(), Form(), fPackageDir, fProtocol, fUniqueSlaves, gDebug, TSlave::GetName(), TSlave::GetOrdinal(), TSlave::GetProofWorkDir(), TCollection::GetSize(), TSlave::GetSocket(), TNamed::GetTitle(), gSystem, TObject::Info(), IsLite(), IsValid(), TSlave::IsValid(), kBinary, kCpBin, kForce, kForward, kPROOF_CHECKFILE, kPROOF_PackDir, kReadPermission, TString::Length(), md5, par, TString::Replace(), TSocket::Send(), SendFile(), and UploadPackageOnClient().
Referenced by AddWorkers(), TProofServ::HandleCache(), TProofServ::HandleCheckFile(), make_event_trees(), TSessionFrame::OnEnablePackages(), TSessionFrame::OnUploadPackages(), PT_PackageArguments(), PT_Packages(), and Run_Node_Tests().
| Int_t TProof::Load | ( | const char * | macro, | |
| Bool_t | notOnClient = kFALSE, |
|||
| Bool_t | uniqueOnly = kTRUE, |
|||
| TList * | wrks = 0 | |||
| ) | [virtual] |
Definition at line 7588 of file TProof.cxx.
References TSystem::AccessPathName(), TList::Add(), TSystem::AddIncludePath(), TSystem::BaseName(), TString::BeginsWith(), Broadcast(), Collect(), TString::Contains(), TString::Data(), TSystem::DirName(), RootCsg::dot(), TObject::Error(), fActiveSlaves, TList::FindObject(), fLoadedMacros, Form(), TString::Format(), fUniqueSlaves, gDebug, TSystem::GetIncludePath(), TROOT::GetMacroPath(), TObjString::GetName(), TCollection::GetSize(), gROOT, gSystem, h, TString::Index(), TObject::Info(), TString::Insert(), TString::IsNull(), IsValid(), kActive, kAscii, kFALSE, kForward, kIsClient, kLoadMacro, kNPOS, kPROOF_CACHE, kReadPermission, kTRUE, kUnique, TString::Last(), TString::Length(), PDB, TROOT::ProcessLine(), TString::Remove(), TString::Replace(), SendFile(), TSystem::SetIncludePath(), TROOT::SetMacroPath(), TCollection::SetOwner(), TSystem::SplitAclicMode(), TObject::TestBit(), and TString::Tokenize().
Referenced by AddWorkers(), TProofServ::HandleCache(), TProofLite::Load(), make_event_trees(), and run_selector_tests().
Definition at line 7793 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, gDebug, HandleLibIncPath(), TObject::Info(), kActive, kPROOF_LIB_INC_PATH, kTRUE, and m.
Referenced by AddWorkers(), and TProofServ::HandleLibIncPath().
Definition at line 7830 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, gDebug, HandleLibIncPath(), TObject::Info(), kActive, kPROOF_LIB_INC_PATH, kTRUE, and m.
Referenced by AddWorkers(), and TProofServ::HandleLibIncPath().
Definition at line 7867 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, gDebug, HandleLibIncPath(), TObject::Info(), kActive, kFALSE, kPROOF_LIB_INC_PATH, and m.
Referenced by TProofServ::HandleLibIncPath().
Definition at line 7901 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, gDebug, HandleLibIncPath(), TObject::Info(), kActive, kFALSE, kPROOF_LIB_INC_PATH, and m.
Referenced by TProofServ::HandleLibIncPath().
| Int_t TProof::UploadDataSet | ( | const char * | dataset, | |
| TList * | files, | |||
| const char * | dest = 0, |
|||
| Int_t | opt = kAskUser, |
|||
| TList * | skippedFiles = 0 | |||
| ) |
Definition at line 9498 of file TProof.cxx.
References TSystem::AccessPathName(), TList::Add(), TSystem::BaseName(), Broadcast(), xmlio::Class, CollapseSlashesInPath(), Collect(), TFile::Cp(), TString::Data(), TObject::Error(), fCollectTimeout, Form(), fProtocol, fStatus, UserGroup_t::fUser, GetDataPoolUrl(), TUrl::GetFile(), TFileCollection::GetList(), TCollection::GetSize(), TUrl::GetUrl(), TSystem::GetUserInfo(), gSystem, TObject::Info(), IsLite(), IsValid(), kActive, kAppend, kCheckDataSetName, kDataSetExists, kError, kFALSE, kFileExists, kNoOverwriteDataSet, kOverwriteAllFiles, kOverwriteDataSet, kOverwriteNoFiles, kPROOF_DATASETS, kTRUE, o, TString::ReadToken(), and RegisterDataSet().
Referenced by UploadDataSet(), TUploadDataSetDlg::UploadDataSet(), and UploadDataSetFromFile().
| Int_t TProof::UploadDataSet | ( | const char * | dataset, | |
| const char * | files, | |||
| const char * | dest = 0, |
|||
| Int_t | opt = kAskUser, |
|||
| TList * | skippedFiles = 0 | |||
| ) |
Definition at line 9698 of file TProof.cxx.
References TSystem::AccessPathName(), TList::Add(), TSystem::BaseName(), TSystem::DirName(), Form(), fProtocol, TSystem::GetDirEntry(), TCollection::GetSize(), gSystem, TString::Index(), TObject::Info(), kFALSE, kNPOS, kReadPermission, TSystem::OpenDirectory(), Printf(), TCollection::SetOwner(), u, and UploadDataSet().
| Int_t TProof::UploadDataSetFromFile | ( | const char * | dataset, | |
| const char * | file, | |||
| const char * | dest = 0, |
|||
| Int_t | opt = kAskUser, |
|||
| TList * | skippedFiles = 0 | |||
| ) |
Definition at line 9755 of file TProof.cxx.
References TSystem::AccessPathName(), TList::Add(), TObject::Error(), TSystem::ExpandPathName(), fProtocol, TCollection::GetSize(), gSystem, TObject::Info(), kFALSE, kReadPermission, TString::kTrailing, line, out, TCollection::SetOwner(), and UploadDataSet().
| Bool_t TProof::RegisterDataSet | ( | const char * | name, | |
| TFileCollection * | dataset, | |||
| const char * | optStr = "" | |||
| ) | [virtual] |
Definition at line 9800 of file TProof.cxx.
References Broadcast(), Collect(), TObject::Error(), fProtocol, fStatus, TObject::Info(), kFALSE, kPROOF_DATASETS, kRegisterDataSet, kTRUE, result(), and TMessage::WriteObject().
Referenced by PT_DataSets(), RegisterDataSet(), and UploadDataSet().
| TMap * TProof::GetDataSets | ( | const char * | uri = "", |
|
| const char * | optStr = "" | |||
| ) | [virtual] |
Definition at line 9885 of file TProof.cxx.
References Broadcast(), xmlio::Class, Collect(), TObject::Error(), fCollectTimeout, TList::First(), fProtocol, fRecvMessages, fStatus, TObject::Info(), kActive, kGetDataSets, kMESS_OK, kPROOF_DATASETS, TBufferFile::ReadObject(), TObject::Warning(), and TMessage::What().
Referenced by ClearData(), GetDataSets(), and PT_DataSets().
| void TProof::ShowDataSets | ( | const char * | uri = "", |
|
| const char * | optStr = "" | |||
| ) | [virtual] |
Definition at line 9925 of file TProof.cxx.
References Broadcast(), Collect(), TObject::Error(), fCollectTimeout, fProtocol, fStatus, TObject::Info(), kActive, kPROOF_DATASETS, and kShowDataSets.
Referenced by PT_DataSets(), and ShowDataSets().
| TMap * TProof::GetDataSetQuota | ( | const char * | optStr = "" |
) |
Definition at line 10128 of file TProof.cxx.
References Broadcast(), xmlio::Class, Collect(), TObject::Error(), fCollectTimeout, TList::First(), fRecvMessages, fStatus, TObject::Info(), IsLite(), kActive, kGetQuota, kMESS_OK, kPROOF_DATASETS, TBufferFile::ReadObject(), and TMessage::What().
| void TProof::ShowDataSetQuota | ( | Option_t * | opt = 0 |
) |
Definition at line 10160 of file TProof.cxx.
References Broadcast(), Collect(), TObject::Error(), fProtocol, fStatus, TObject::Info(), IsLite(), kPROOF_DATASETS, and kShowQuota.
| Bool_t TProof::ExistsDataSet | ( | const char * | dataset | ) | [virtual] |
Definition at line 9948 of file TProof.cxx.
References Broadcast(), Collect(), TObject::Error(), fCollectTimeout, fProtocol, fStatus, TObject::Info(), kActive, kCheckDataSetName, kFALSE, kPROOF_DATASETS, and kTRUE.
Referenced by ClearData(), and ExistsDataSet().
| void TProof::ShowDataSet | ( | const char * | dataset = "", |
|
| const char * | opt = "M" | |||
| ) |
Definition at line 10057 of file TProof.cxx.
References GetDataSet(), TFileCollection::Print(), and TObject::Warning().
| Int_t TProof::RemoveDataSet | ( | const char * | dataset, | |
| const char * | optStr = "" | |||
| ) | [virtual] |
Definition at line 10070 of file TProof.cxx.
References Broadcast(), Collect(), TObject::Error(), fCollectTimeout, fStatus, kActive, kPROOF_DATASETS, and kRemoveDataSet.
Referenced by ClearData(), TSessionFrame::OnBtnRemoveDSet(), PT_DataSets(), and RemoveDataSet().
| Int_t TProof::VerifyDataSet | ( | const char * | dataset, | |
| const char * | optStr = "" | |||
| ) | [virtual] |
Definition at line 10099 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, fProtocol, fStatus, TObject::Info(), kActive, kError, kPROOF_DATASETS, and kVerifyDataSet.
Referenced by TSessionFrame::OnBtnVerifyDSet(), PT_DataSets(), and VerifyDataSet().
| TFileCollection * TProof::GetDataSet | ( | const char * | dataset, | |
| const char * | optStr = "" | |||
| ) | [virtual] |
Definition at line 10012 of file TProof.cxx.
References Broadcast(), xmlio::Class, Collect(), TObject::Error(), fCollectTimeout, TList::First(), fProtocol, fRecvMessages, fStatus, TObject::Info(), kActive, kGetDataSet, kMESS_OK, kPROOF_DATASETS, TBufferFile::ReadObject(), and TMessage::What().
Referenced by ClearData(), GetDataSet(), ShowDataSet(), TSessionFrame::UpdateListOfDataSets(), and VerifyDataSet().
| TList * TProof::FindDataSets | ( | const char * | searchString, | |
| const char * | optStr = "" | |||
| ) |
| Int_t TProof::SetDataSetTreeName | ( | const char * | dataset, | |
| const char * | treename | |||
| ) | [virtual] |
Definition at line 9844 of file TProof.cxx.
References TString::BeginsWith(), Broadcast(), Collect(), TObject::Error(), fProtocol, fStatus, TUri::GetUri(), TObject::Info(), TString::Insert(), kPROOF_DATASETS, kSetDefaultTreeName, and TUri::SetFragment().
| void TProof::ShowDataSetCache | ( | const char * | dataset = 0 |
) | [virtual] |
Definition at line 9994 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, fProtocol, TObject::Info(), kActive, kCache, and kPROOF_DATASETS.
Referenced by DataSetCache().
| void TProof::ClearDataSetCache | ( | const char * | dataset = 0 |
) | [virtual] |
Definition at line 9976 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, fProtocol, TObject::Info(), kActive, kCache, and kPROOF_DATASETS.
Referenced by DataSetCache().
| void TProof::ShowData | ( | ) |
Definition at line 5915 of file TProof.cxx.
References TProofMgr::Find(), fManager, and IsValid().
Referenced by ClearData().
| void TProof::ClearData | ( | UInt_t | what = kUnregistered, |
|
| const char * | dsname = 0 | |||
| ) |
Definition at line 5927 of file TProof.cxx.
References a, TMap::Add(), TString::BeginsWith(), ClearDataProgress(), TString::Data(), TObject::Error(), ExistsDataSet(), fc, fclose(), fi, TObject::FindObject(), fManager, TString::Format(), fprintf(), TFileInfo::GetCurrentUrl(), GetDataSet(), GetDataSets(), TUrl::GetFile(), GetGroup(), TUrl::GetHost(), TFileCollection::GetList(), TObjString::GetName(), TCollection::GetName(), TFileInfo::GetNUrls(), TUrl::GetOptions(), TUrl::GetProtocol(), TCollection::GetSize(), GetUser(), TMap::GetValue(), gSystem, h, TObject::Info(), TString::IsNull(), IsValid(), kDataset, kFALSE, kForceClear, kPurge, TString::kTrailing, kTRUE, kUnregistered, line, TFileInfo::NextUrl(), nfiles, PDB, TCollection::Print(), Prompt(), TSystem::RedirectOutput(), RemoveDataSet(), TString::ReplaceAll(), TFileInfo::ResetUrl(), TProofMgr::Rm(), SafeDelete, sel, TCollection::SetOwner(), ShowData(), TSystem::TempFileName(), TSystem::Unlink(), and TObject::Warning().
| const char* TProof::GetMaster | ( | ) | const [inline] |
Definition at line 865 of file TProof.h.
References fMaster.
Referenced by make_event_trees(), TSessionServerFrame::OnBtnConnectClicked(), Print(), TSessionQueryFrame::Progress(), TProofProgressDialog::Progress(), TSessionFrame::ProofInfos(), TSessionQueryFrame::ResetProgressDialog(), TProofProgressDialog::ResetProgressDialog(), TSessionLogView::SetTitle(), TSessionViewer::UpdateListOfProofs(), and TSessionViewer::UpdateListOfSessions().
| const char* TProof::GetConfDir | ( | ) | const [inline] |
Definition at line 866 of file TProof.h.
References fConfDir.
Referenced by TProofCondor::GetJobAd(), TProofPEAC::GetJobAd(), Print(), and TSessionFrame::ProofInfos().
| const char* TProof::GetConfFile | ( | ) | const [inline] |
Definition at line 867 of file TProof.h.
References fConfFile.
Referenced by TSessionServerFrame::OnBtnConnectClicked(), Print(), TSessionFrame::ProofInfos(), TSessionViewer::UpdateListOfProofs(), and TSessionViewer::UpdateListOfSessions().
| const char* TProof::GetUser | ( | ) | const [inline] |
Definition at line 868 of file TProof.h.
References fUrl, and TUrl::GetUser().
Referenced by ClearData(), TSessionServerFrame::OnBtnConnectClicked(), TProofLite::Print(), Print(), TSessionFrame::ProofInfos(), TSessionViewer::UpdateListOfProofs(), and TSessionViewer::UpdateListOfSessions().
| const char* TProof::GetGroup | ( | ) | const [inline] |
| const char* TProof::GetWorkDir | ( | ) | const [inline] |
| const char* TProof::GetSessionTag | ( | ) | const [inline] |
Definition at line 871 of file TProof.h.
References TNamed::GetName().
Referenced by TSessionQueryFrame::OnBtnSubmit(), Print(), and TSessionFrame::ProofInfos().
| const char* TProof::GetImage | ( | ) | const [inline] |
Definition at line 872 of file TProof.h.
References fImage.
Referenced by Print(), and TSessionFrame::ProofInfos().
| const char* TProof::GetUrl | ( | ) | [inline] |
| Int_t TProof::GetPort | ( | ) | const [inline] |
Definition at line 874 of file TProof.h.
References fUrl, and TUrl::GetPort().
Referenced by TSessionServerFrame::OnBtnConnectClicked(), Print(), TSessionFrame::ProofInfos(), TProof(), TSessionViewer::UpdateListOfProofs(), and TSessionViewer::UpdateListOfSessions().
| Int_t TProof::GetRemoteProtocol | ( | ) | const [inline] |
Definition at line 875 of file TProof.h.
References fProtocol.
Referenced by GoAsynchronous(), HandleInputMessage(), Print(), TSessionFrame::ProofInfos(), TProofProgressDialog::ResetProgressDialog(), and UpdateDialog().
| Int_t TProof::GetClientProtocol | ( | ) | const [inline] |
Definition at line 876 of file TProof.h.
References kPROOF_Protocol.
Referenced by TProofLite::Print(), Print(), and TSessionFrame::ProofInfos().
| Int_t TProof::GetStatus | ( | ) | const [inline] |
Definition at line 877 of file TProof.h.
References fStatus.
Referenced by TSessionViewer::ShowStatus().
| Int_t TProof::GetLogLevel | ( | ) | const [inline] |
Definition at line 878 of file TProof.h.
References fLogLevel.
Referenced by TProofCondor::GetJobAd(), TProofPEAC::GetJobAd(), TXSlave::Init(), TSessionServerFrame::OnBtnConnectClicked(), TProofLite::Print(), Print(), TSessionFrame::ProofInfos(), TSessionViewer::UpdateListOfProofs(), and TSessionViewer::UpdateListOfSessions().
| Int_t TProof::GetParallel | ( | ) | const |
Definition at line 1987 of file TProof.cxx.
References GetListOfActiveSlaves(), and IsValid().
Referenced by TProofMgrLite::CreateSession(), Exec(), GetStatistics(), GoParallel(), TProofServ::HandleSocketInput(), IsParallel(), TProofLite::Print(), Print(), TProofPlayerRemote::Process(), TSessionQueryFrame::Progress(), TProofProgressDialog::Progress(), TSessionFrame::ProofInfos(), TSessionQueryFrame::ResetProgressDialog(), TProofProgressDialog::ResetProgressDialog(), run_selector_tests(), SendCurrentState(), TProofServ::SendLogFile(), TProofServ::SendParallel(), SetParallelSilent(), TProofLite::SetQueryRunning(), and TProofServ::SetQueryRunning().
| Int_t TProof::GetSeqNum | ( | ) | const [inline] |
Definition at line 880 of file TProof.h.
References fSeqNum.
Referenced by TSessionQueryFrame::OnBtnSubmit().
| Int_t TProof::GetSessionID | ( | ) | const [inline] |
| TList * TProof::GetListOfSlaveInfos | ( | ) |
Definition at line 2005 of file TProof.cxx.
References TList::Add(), Collect(), TList::Delete(), TObject::Error(), fSlaveInfo, GetListOfActiveSlaves(), GetListOfBadSlaves(), GetListOfSlaves(), TSlave::GetName(), TSlaveInfo::GetOrdinal(), TSlave::GetOrdinal(), TSlave::GetPerfIdx(), TCollection::GetSize(), TSlave::GetSlaveType(), TSlave::GetSocket(), gSystem, TSystem::HostName(), IsLite(), IsValid(), TSlave::IsValid(), TSlaveInfo::kActive, TSlaveInfo::kBad, TSlave::kMaster, kPROOF_GETSLAVEINFO, TSlave::kSlave, kSortDescending, MarkBad(), name, R__ASSERT, TSocket::Send(), TCollection::SetOwner(), and TSlaveInfo::SetStatus().
Referenced by TProofServ::HandleSocketInput(), make_event_trees(), make_tdset(), and TPerfStats::TPerfStats().
| Bool_t TProof::UseDynamicStartup | ( | ) | const [inline] |
Definition at line 883 of file TProof.h.
References fDynamicStartup.
Referenced by TProofServ::HandleProcess(), TProofServ::HandleSocketInput(), and TProofServ::ProcessNext().
| TProof::EQueryMode TProof::GetQueryMode | ( | Option_t * | mode = 0 |
) | const |
Definition at line 4943 of file TProof.cxx.
References fQueryMode, gDebug, TObject::Info(), kAsync, kSync, and m.
Referenced by TProofLite::Process(), TProofPlayerRemote::Process(), TProofPlayerLite::Process(), and Process().
| void TProof::SetQueryMode | ( | EQueryMode | mode | ) |
Definition at line 4931 of file TProof.cxx.
References fQueryMode, gDebug, TObject::Info(), and kSync.
Referenced by TSessionServerFrame::OnBtnConnectClicked().
Definition at line 5724 of file TProof.cxx.
References Broadcast(), IsValid(), kPROOF_REALTIMELOG, and TObject::Warning().
Referenced by TProofServ::HandleSocketInput().
Definition at line 1717 of file TProof.cxx.
References AskStatistics(), fBytesRead, fCpuTime, fLogFileName, fProtocol, fRealTime, GetBytesRead(), GetCpuTime(), GetLastLog(), TMacro::GetListOfLines(), GetParallel(), GetRealTime(), gSystem, Long64_t, Print(), Printf(), TSystem::RedirectOutput(), and s.
Referenced by stressProof().
| Long64_t TProof::GetBytesRead | ( | ) | const [inline] |
Definition at line 891 of file TProof.h.
References fBytesRead.
Referenced by TQueryResultManager::FinalizeQuery(), GetStatistics(), TProofLite::Print(), Print(), TSessionFrame::ProofInfos(), TProofServ::SendStatistics(), TProofLite::SetQueryRunning(), and TProofServ::SetQueryRunning().
| Float_t TProof::GetRealTime | ( | ) | const [inline] |
Definition at line 892 of file TProof.h.
References fRealTime.
Referenced by GetStatistics(), TProofLite::Print(), Print(), TSessionFrame::ProofInfos(), and TProofServ::SendStatistics().
| Float_t TProof::GetCpuTime | ( | ) | const [inline] |
Definition at line 893 of file TProof.h.
References fCpuTime.
Referenced by TQueryResultManager::FinalizeQuery(), GetStatistics(), TProofLite::Print(), Print(), TSessionFrame::ProofInfos(), TProofServ::SendStatistics(), TProofLite::SetQueryRunning(), TProofServ::SetQueryRunning(), and stressProof().
| Bool_t TProof::IsLite | ( | ) | const [inline] |
Definition at line 895 of file TProof.h.
References fServType, and TProofMgr::kProofLite.
Referenced by TDSet::Add(), AskForOutput(), BuildPackage(), ClassImp(), TProofMgrLite::CreateSession(), DisablePackage(), DisablePackages(), Exec(), GetDataSetQuota(), GetListOfSlaveInfos(), HandleInputMessage(), HandleSubmerger(), TProofPlayerRemote::Incorporate(), make_tdset(), TProofPlayerRemote::NotifyMemory(), TSessionServerFrame::OnBtnConnectClicked(), TSessionQueryFrame::OnBtnSubmit(), ParseConfigField(), TProofPlayerRemote::Process(), Process(), PT_AdminFunc(), PT_H1SimpleAsync(), RedirectWorker(), Remove(), SendDataSetStatus(), ShowDataSetQuota(), ShowEnabledPackages(), ShowPackages(), stressProof(), TProofChain::TProofChain(), UnloadPackage(), UnloadPackages(), TSessionViewer::UpdateListOfProofs(), TSessionViewer::UpdateListOfSessions(), UploadDataSet(), and UploadPackage().
| Bool_t TProof::IsProofd | ( | ) | const [inline] |
Definition at line 896 of file TProof.h.
References fServType, and TProofMgr::kProofd.
Referenced by Close(), TSlave::Create(), SetAlias(), and TProof().
| Bool_t TProof::IsFolder | ( | ) | const [inline, virtual] |
| Bool_t TProof::IsMaster | ( | ) | const [inline] |
Definition at line 898 of file TProof.h.
References fMasterServ.
Referenced by AddWorkers(), ClassImp(), TSlave::Close(), TSlave::Create(), TProofPlayerRemote::Finalize(), TXSlave::HandleError(), TXSlave::Init(), Init(), TSlave::Init(), TSlave::Interrupt(), TProofPEAC::IsDataReady(), LoadPackage(), MarkBad(), TProofPlayerRemote::Process(), TSessionFrame::ProofInfos(), RemoveWorkers(), TProofPEAC::StartSlaves(), TerminateWorker(), and TXSlave::TXSlave().
| Bool_t TProof::IsValid | ( | ) | const [inline] |
Definition at line 899 of file TProof.h.
References fValid.
Referenced by AskParallel(), AskStatistics(), Broadcast(), BroadcastFile(), BroadcastGroupPriority(), BroadcastRaw(), TSessionQueryFrame::Build(), BuildPackage(), TSessionViewer::CleanupSession(), ClearCache(), TProofLite::ClearCache(), ClearData(), ClearPackage(), ClearPackages(), TXProofServ::CreateServer(), TProofServ::CreateServer(), TProofMgrLite::CreateSession(), TSessionViewer::DeleteQuery(), Detach(), DisablePackage(), DisablePackages(), DrawSelect(), TProofLite::DrawSelect(), EnablePackage(), Exec(), GetListOfEnabledPackages(), GetListOfPackages(), GetListOfQueries(), GetListOfSlaveInfos(), GetLog(), GetParallel(), getProof(), GoAsynchronous(), GoParallel(), TSessionQueryFrame::IndicateStop(), Init(), TProofLite::Init(), Interrupt(), IsDataReady(), Load(), TProofLite::Load(), LoadPackage(), MarkBad(), TSessionQueryFrame::Modified(), TSessionViewer::MyHandleMenu(), TSessionFrame::OnApplyLogLevel(), TSessionFrame::OnApplyParallel(), TSessionQueryFrame::OnBtnAbort(), TSessionServerFrame::OnBtnConnectClicked(), TSessionFrame::OnBtnDisconnectClicked(), TSessionQueryFrame::OnBtnFinalize(), TSessionFrame::OnBtnGetQueriesClicked(), TSessionFrame::OnBtnRemoveDSet(), TSessionQueryFrame::OnBtnRetrieve(), TEditQueryFrame::OnBtnSave(), TSessionQueryFrame::OnBtnStop(), TSessionQueryFrame::OnBtnSubmit(), TSessionFrame::OnBtnVerifyDSet(), TSessionViewer::OnCascadeMenu(), TSessionFrame::OnClearPackages(), TSessionFrame::OnCommandLine(), TSessionFrame::OnDisablePackages(), TSessionFrame::OnEnablePackages(), TSessionViewer::OnListTreeClicked(), TSessionFrame::OnUploadPackages(), Print(), TProofLite::Process(), TProofSuperMaster::Process(), Process(), TSessionFrame::ProofInfos(), TSessionQueryFrame::ResetProgressDialog(), TSessionViewer::ResetSession(), SendCommand(), SendCurrentState(), SendFile(), SendGroupView(), SendInitialState(), SendObject(), SendPrint(), SetAlias(), SetParallelSilent(), SetRealTimeLog(), TProofLite::ShowCache(), ShowCache(), ShowData(), TSessionViewer::ShowEnabledPackages(), ShowEnabledPackages(), ShowPackages(), TSessionViewer::ShowPackages(), ShowQueries(), TSessionViewer::ShowStatus(), TSessionFrame::ShutdownSession(), TPEAC::StartSession(), StopProcess(), TSessionViewer::Terminate(), TUploadDataSetDlg::TUploadDataSetDlg(), UnloadPackage(), UnloadPackages(), TSessionQueryFrame::UpdateButtons(), TSessionQueryFrame::UpdateInfos(), TSessionFrame::UpdateListOfDataSets(), TSessionViewer::UpdateListOfPackages(), TUploadDataSetDlg::UploadDataSet(), UploadDataSet(), UploadPackage(), and TProofProgressDialog::~TProofProgressDialog().
| Bool_t TProof::IsParallel | ( | ) | const [inline] |
Definition at line 900 of file TProof.h.
References GetParallel(), kFALSE, and kTRUE.
Referenced by TProofPlayerLite::Finalize(), TProofPlayerRemote::Finalize(), TProofServ::IsParallel(), TProofLite::Print(), Print(), TSessionFrame::ProofInfos(), TSessionFrame::UpdateListOfDataSets(), and TSessionViewer::UpdateListOfPackages().
| Bool_t TProof::IsIdle | ( | ) | const [inline] |
Definition at line 901 of file TProof.h.
References fNotIdle, kFALSE, and kTRUE.
Referenced by Collect(), Detach(), DrawSelect(), TProofLite::DrawSelect(), GoAsynchronous(), Init(), NotifyLogMsg(), TProofLite::Process(), Process(), PT_H1SimpleAsync(), and RecvLogFile().
| Bool_t TProof::IsWaiting | ( | ) | const [inline] |
| ERunStatus TProof::GetRunStatus | ( | ) | const [inline] |
Definition at line 904 of file TProof.h.
References fRunStatus.
Referenced by TProofPlayerRemote::InitPacketizer(), and TDSet::Lookup().
| TList* TProof::GetLoadedMacros | ( | ) | const [inline] |
| void TProof::SetParameter | ( | const char * | par, | |
| const char * | value | |||
| ) |
Definition at line 8713 of file TProof.cxx.
References TList::Add(), TList::FindObject(), fPlayer, TVirtualProofPlayer::GetInputList(), TList::Remove(), TNamed::TNamed(), and TObject::Warning().
Referenced by AssertParallelUnzip(), TProofLite::Process(), TProofPlayerRemote::Process(), TProofPlayerLite::Process(), PT_H1FileCollection(), PT_H1SimpleAsync(), PT_PackageArguments(), PT_Simple(), Run_Node_Tests(), and runProof().
| void TProof::SetParameter | ( | const char * | par, | |
| Int_t | value | |||
| ) |
Definition at line 8733 of file TProof.cxx.
References TList::Add(), TList::FindObject(), fPlayer, TVirtualProofPlayer::GetInputList(), TList::Remove(), and TObject::Warning().
| void TProof::SetParameter | ( | const char * | par, | |
| Long_t | value | |||
| ) |
Definition at line 8752 of file TProof.cxx.
References TList::Add(), TList::FindObject(), fPlayer, TVirtualProofPlayer::GetInputList(), TList::Remove(), and TObject::Warning().
| void TProof::SetParameter | ( | const char * | par, | |
| Long64_t | value | |||
| ) |
Definition at line 8771 of file TProof.cxx.
References TList::Add(), TList::FindObject(), fPlayer, TVirtualProofPlayer::GetInputList(), TList::Remove(), and TObject::Warning().
| void TProof::SetParameter | ( | const char * | par, | |
| Double_t | value | |||
| ) |
Definition at line 8790 of file TProof.cxx.
References TList::Add(), TList::FindObject(), fPlayer, TVirtualProofPlayer::GetInputList(), TList::Remove(), and TObject::Warning().
| TObject * TProof::GetParameter | ( | const char * | par | ) | const |
Definition at line 8809 of file TProof.cxx.
References TList::FindObject(), fPlayer, TVirtualProofPlayer::GetInputList(), and TObject::Warning().
Referenced by AssertDataSet(), ClassImp(), TPacketizerMulti::CreatePacketizer(), G__G__Proof_142_0_299(), G__G__Proof_142_0_300(), G__G__Proof_142_0_301(), G__G__Proof_142_0_302(), G__G__Proof_142_0_303(), G__setup_memfuncTProof(), TProofServ::HandleProcess(), HandleSubmerger(), TProofPlayerRemote::InitPacketizer(), MarkBad(), TProofPlayerRemote::Process(), TProofPlayer::Process(), TProofDraw::SetDrawAtt(), TProofPlayerSuperMaster::SetupFeedback(), TProofPlayerLite::SetupFeedback(), TProofPlayerRemote::SetupFeedback(), TPerfStats::TPerfStats(), TPacketizerFile::TSlaveStat::TSlaveStat(), and TPacketizerUnit::TSlaveStat::TSlaveStat().
| void TProof::DeleteParameters | ( | const char * | wildcard | ) |
Definition at line 8824 of file TProof.cxx.
References fPlayer, TVirtualProofPlayer::GetInputList(), kNPOS, kTRUE, p, TList::Remove(), and s.
Referenced by PT_H1FileCollection(), PT_PackageArguments(), PT_Simple(), and runProof().
| void TProof::ShowParameters | ( | const char * | wildcard = "PROOF_*" |
) | const |
Definition at line 8849 of file TProof.cxx.
References xmlio::Class, TParameter< AParamType >::Class(), fPlayer, TVirtualProofPlayer::GetInputList(), kNPOS, kTRUE, p, Printf(), and s.
| void TProof::AddInput | ( | TObject * | obj | ) |
Definition at line 8667 of file TProof.cxx.
References TVirtualProofPlayer::AddInput(), and fPlayer.
Referenced by TDSet::AddInput(), ClearInput(), Init(), TProofLite::Init(), Process(), PT_InputData(), Run_Node_Tests(), TProofLite::SendInputDataFile(), and SendInputDataFile().
| void TProof::ClearInput | ( | ) |
Definition at line 8676 of file TProof.cxx.
References AddInput(), TVirtualProofPlayer::ClearInput(), fFeedback, and fPlayer.
Referenced by TDSet::ClearInput().
| TList * TProof::GetInputList | ( | ) |
Definition at line 8687 of file TProof.cxx.
References fPlayer, and TVirtualProofPlayer::GetInputList().
Referenced by ClearInputData(), PrepareInputDataFile(), Process(), PT_H1MultiDSetEntryList(), and runProof().
| TObject * TProof::GetOutput | ( | const char * | name | ) |
Definition at line 8695 of file TProof.cxx.
References fPlayer, and TVirtualProofPlayer::GetOutput().
Referenced by TDSet::GetOutput(), HandleInputMessage(), and MarkBad().
| TList * TProof::GetOutputList | ( | ) |
Definition at line 8705 of file TProof.cxx.
References fPlayer, and TVirtualProofPlayer::GetOutputList().
Referenced by TDSet::GetOutputList(), TProofServ::HandleSocketInput(), PT_Event(), PT_InputData(), PT_PackageArguments(), and SavePerfInfo().
| void TProof::ShowMissingFiles | ( | TQueryResult * | qr = 0 |
) |
Definition at line 11120 of file TProof.cxx.
References fi, TList::FindObject(), TQueryResult::GetEntries(), TFileInfoMeta::GetEntries(), TFileInfo::GetMetaData(), TNamed::GetName(), TQueryResult::GetOutputList(), GetQueryResult(), TNamed::GetTitle(), TFileInfoMeta::GetTotBytes(), TFileInfoMeta::GetZipBytes(), TObject::Info(), Long64_t, TFileInfo::Print(), Printf(), and TObject::Warning().
| TFileCollection * TProof::GetMissingFiles | ( | TQueryResult * | qr = 0 |
) |
Definition at line 11164 of file TProof.cxx.
References TFileCollection::Add(), TNamed::Clone(), fc, fi, TList::FindObject(), TDirectory::FindObject(), TString::Form(), gDebug, gDirectory, TQueryResult::GetInputObject(), TNamed::GetName(), TDSet::GetObjName(), TQueryResult::GetOutputList(), GetQueryResult(), TNamed::GetTitle(), TObject::Info(), j, TFileCollection::SetDefaultTreeName(), TFileCollection::Update(), and TObject::Warning().
Definition at line 8453 of file TProof.cxx.
References TList::Add(), TList::FindObject(), fInputData, kNewInputData, and TObject::SetBit().
Referenced by PT_InputData().
| void TProof::SetInputDataFile | ( | const char * | datafile | ) |
Definition at line 8516 of file TProof.cxx.
References TSystem::AccessPathName(), fInputDataFile, gSystem, TString::IsNull(), kNewInputData, kPROOF_InputDataFile, kReadPermission, and TObject::SetBit().
Referenced by PT_InputData().
| void TProof::ClearInputData | ( | TObject * | obj = 0 |
) |
Definition at line 8472 of file TProof.cxx.
References TList::FindObject(), TObject::FindObject(), fInputData, fInputDataFile, GetInputList(), TCollection::GetSize(), gSystem, kNewInputData, kPROOF_InputDataFile, kTRUE, o, TList::Remove(), TObject::ResetBit(), SafeDelete, TObject::SetBit(), and TSystem::Unlink().
Referenced by ClearInputData(), PT_InputData(), and runProof().
| void TProof::ClearInputData | ( | const char * | name | ) |
Definition at line 8507 of file TProof.cxx.
References ClearInputData(), TList::FindObject(), and fInputData.
| void TProof::AddFeedback | ( | const char * | name | ) |
Definition at line 8881 of file TProof.cxx.
References TList::Add(), fFeedback, TList::FindObject(), TObject::Info(), and PDB.
Referenced by TProofPlayerRemote::DrawSelect(), TSessionServerFrame::OnBtnConnectClicked(), TSessionQueryFrame::OnBtnSubmit(), and TSessionViewer::OnCascadeMenu().
| void TProof::RemoveFeedback | ( | const char * | name | ) |
Definition at line 8892 of file TProof.cxx.
References fFeedback, TList::FindObject(), and TList::Remove().
Referenced by TProofPlayerRemote::DrawSelect().
| void TProof::ClearFeedback | ( | ) |
Definition at line 8904 of file TProof.cxx.
References TList::Delete(), and fFeedback.
Referenced by TSessionServerFrame::OnBtnConnectClicked(), TSessionQueryFrame::OnBtnSubmit(), and TSessionViewer::OnCascadeMenu().
| void TProof::ShowFeedback | ( | ) | const |
Definition at line 8912 of file TProof.cxx.
References fFeedback, TCollection::GetSize(), TObject::Info(), and TCollection::Print().
| TList * TProof::GetFeedbackList | ( | ) | const |
Definition at line 1772 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, fQueries, IsValid(), kActive, kFALSE, kIsMaster, kPROOF_QUERYLIST, kTRUE, m, and TObject::TestBit().
Referenced by finalizeProof(), GetQueryReference(), TSessionFrame::OnBtnGetQueriesClicked(), ShowLog(), and ShowQueries().
| Int_t TProof::GetNumberOfQueries | ( | ) |
Definition at line 1789 of file TProof.cxx.
References fOtherQueries, fQueries, and TCollection::GetSize().
Referenced by ShowQueries().
| Int_t TProof::GetNumberOfDrawQueries | ( | ) | [inline] |
| TList * TProof::GetQueryResults | ( | ) |
Definition at line 1823 of file TProof.cxx.
References fPlayer, and TVirtualProofPlayer::GetListOfResults().
Referenced by PT_Event(), PT_H1DataSet(), PT_H1FileCollection(), PT_H1Http(), PT_H1MultiDataSet(), PT_H1MultiDSetEntryList(), PT_H1SimpleAsync(), PT_InputData(), PT_PackageArguments(), PT_Simple(), and ShowLog().
| TQueryResult * TProof::GetQueryResult | ( | const char * | ref = 0 |
) |
Definition at line 1831 of file TProof.cxx.
References fPlayer, and TVirtualProofPlayer::GetQueryResult().
Referenced by Finalize(), GetMissingFiles(), TPerfStats::PacketEvent(), PT_Event(), PT_H1DataSet(), PT_H1FileCollection(), PT_H1Http(), PT_H1MultiDataSet(), PT_H1MultiDSetEntryList(), PT_H1SimpleAsync(), PT_InputData(), PT_PackageArguments(), PT_Simple(), TSessionViewer::QueryResultReady(), ShowMissingFiles(), and TPerfStats::WriteQueryLog().
| void TProof::GetMaxQueries | ( | ) |
Definition at line 1811 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, kActive, kFALSE, kPROOF_MAXQUERIES, and m.
| void TProof::SetMaxDrawQueries | ( | Int_t | max | ) |
Definition at line 1799 of file TProof.cxx.
References fMaxDrawQueries, fPlayer, and TVirtualProofPlayer::SetMaxDrawQueries().
| void TProof::ShowQueries | ( | Option_t * | opt = "" |
) |
Definition at line 1840 of file TProof.cxx.
References fDrawQueries, fOtherQueries, fPlayer, fQueries, GetListOfQueries(), TVirtualProofPlayer::GetListOfResults(), GetNumberOfQueries(), TCollection::GetSize(), help(), IsValid(), kFALSE, kTRUE, local, TObject::Print(), and Printf().
Definition at line 1924 of file TProof.cxx.
References TList::Add(), Broadcast(), Collect(), TQObject::EmitVA(), fBytesReady, fDataReady, fTotalBytes, GetListOfActiveSlaves(), TCollection::GetSize(), TObject::Info(), IsValid(), kFALSE, TSlave::kMaster, kPROOF_DATA_READY, and kTRUE.
Referenced by TProofServ::HandleSocketInput(), TProofPEAC::IsDataReady(), and TPEAC::StartSession().
Definition at line 948 of file TProof.h.
Referenced by TProofServ::HandleSigPipe(), TProofServ::HandleSocketInput(), TProofServ::HandleUrgentData(), TXProofServ::HandleUrgentData(), Init(), TProofLite::Init(), and TProofCondor::SetActive().
| void TProof::LogMessage | ( | const char * | msg, | |
| Bool_t | all | |||
| ) |
Definition at line 5230 of file TProof.cxx.
References buf, TQObject::EmitVA(), TObject::Error(), fLogFileR, TSystem::GetErrno(), gROOT, TObject::Info(), TROOT::IsBatch(), kFALSE, kMAXBUF, len, lseek, PDB, read, TSystem::ResetErrno(), and SEEK_SET.
Referenced by ShowLog().
Definition at line 8135 of file TProof.cxx.
References TQObject::EmitVA(), fPrintProgress, gROOT, TObject::Info(), TROOT::IsBatch(), PDB, and PrintProgress().
Referenced by TProofPlayerRemote::Progress(), and UpdateDialog().
| void TProof::Progress | ( | Long64_t | total, | |
| Long64_t | processed, | |||
| Long64_t | bytesread, | |||
| Float_t | initTime, | |||
| Float_t | procTime, | |||
| Float_t | evtrti, | |||
| Float_t | mbrti | |||
| ) |
Definition at line 8158 of file TProof.cxx.
References TQObject::EmitVA(), gROOT, TObject::Info(), TROOT::IsBatch(), PDB, and PrintProgress().
| void TProof::Progress | ( | Long64_t | total, | |
| Long64_t | processed, | |||
| Long64_t | bytesread, | |||
| Float_t | initTime, | |||
| Float_t | procTime, | |||
| Float_t | evtrti, | |||
| Float_t | mbrti, | |||
| Int_t | actw, | |||
| Int_t | tses, | |||
| Float_t | eses | |||
| ) |
Definition at line 8180 of file TProof.cxx.
References TQObject::EmitVA(), gROOT, TObject::Info(), TROOT::IsBatch(), PDB, and PrintProgress().
| void TProof::Feedback | ( | TList * | objs | ) |
Definition at line 8202 of file TProof.cxx.
References TQObject::Emit(), TCollection::GetSize(), TObject::Info(), TCollection::ls(), and PDB.
Referenced by TProofPlayerRemote::Feedback().
| void TProof::QueryResultReady | ( | const char * | ref | ) |
Definition at line 8304 of file TProof.cxx.
References TQObject::Emit(), TObject::Info(), and PDB.
Referenced by HandleInputMessage(), and TProofLite::Process().
| void TProof::CloseProgressDialog | ( | ) |
Definition at line 8218 of file TProof.cxx.
References TQObject::Emit(), fProgressDialogStarted, TObject::Info(), and PDB.
Referenced by Detach().
Definition at line 8234 of file TProof.cxx.
References TQObject::EmitVA(), TObject::Info(), and PDB.
Referenced by HandleInputMessage(), and TProofLite::Process().
Definition at line 8247 of file TProof.cxx.
References TQObject::EmitVA(), TObject::Info(), and PDB.
Referenced by HandleInputMessage(), and StartSlaves().
Definition at line 8259 of file TProof.cxx.
References TQObject::EmitVA(), TObject::Info(), and PDB.
Referenced by HandleInputMessage().
Definition at line 8271 of file TProof.cxx.
References fprintf(), fSync, TProofServ::GetSocket(), gProofServ, IsLite(), kIsMaster, kPROOF_DATASET_STATUS, NotifyLogMsg(), TSocket::Send(), snprintf, TObject::TestBit(), and type.
Referenced by TDSet::Lookup(), TPacketizer::ValidateFiles(), and TPacketizerAdaptive::ValidateFiles().
Definition at line 9131 of file TProof.cxx.
References Broadcast(), Collect(), fCollectTimeout, IsValid(), kActive, kIsMaster, kPROOF_LOGFILE, and TObject::TestBit().
| TMacro * TProof::GetLastLog | ( | ) |
Definition at line 9147 of file TProof.cxx.
References TMacro::AddLine(), fLogFileR, TSystem::GetErrno(), line, lseek, SEEK_CUR, SEEK_END, SEEK_SET, TObject::SysError(), and TObject::Warning().
Referenced by DownloadPackage(), and GetStatistics().
| void TProof::PutLog | ( | TQueryResult * | qr | ) |
Definition at line 9213 of file TProof.cxx.
References TQObject::EmitVA(), TMacro::GetListOfLines(), TQueryResult::GetLogFile(), kFALSE, and l.
Referenced by ShowLog().
| void TProof::ShowLog | ( | Int_t | qry = -1 |
) |
Definition at line 9258 of file TProof.cxx.
References fLogFileR, fQueries, gDebug, TSystem::GetErrno(), Getline(), GetListOfQueries(), GetQueryResults(), TQueryResult::GetSeqNum(), TObject::Info(), kFALSE, TList::Last(), line, LogMessage(), lseek, p, PutLog(), SEEK_CUR, SEEK_END, SEEK_SET, SendingLogToWindow(), TObject::SysError(), w, and write.
Referenced by TSessionViewer::ShowLog().
| void TProof::ShowLog | ( | const char * | queryref | ) |
Definition at line 9229 of file TProof.cxx.
References fPlayer, TVirtualProofPlayer::GetListOfResults(), TNamed::GetName(), TNamed::GetTitle(), PutLog(), and Retrieve().
| Bool_t TProof::SendingLogToWindow | ( | ) | const [inline] |
Definition at line 976 of file TProof.h.
References fLogToWindowOnly.
Referenced by TSessionViewer::ShowLog(), and ShowLog().
| void TProof::SendLogToWindow | ( | Bool_t | mode | ) | [inline] |
Definition at line 977 of file TProof.h.
References fLogToWindowOnly.
Referenced by TSessionViewer::ShowLog().
| void TProof::ResetProgressDialogStatus | ( | ) | [inline] |
Definition at line 979 of file TProof.h.
References fProgressDialogStarted, and kFALSE.
Referenced by TProofProgressDialog::~TProofProgressDialog().
Definition at line 8933 of file TProof.cxx.
References TBuffer::BufferSize(), Collect(), d, TObject::Error(), fCollectTimeout, TList::First(), fProtocol, fRecvMessages, GetListOfActiveSlaves(), TSlave::GetSocket(), TObject::Info(), int, kPROOF_GETTREEHEADER, l, PDB, TSocket::Recv(), s1, TSocket::Send(), and t.
Referenced by TDSet::GetTreeHeader(), and TProofChain::TProofChain().
| TList * TProof::GetOutputNames | ( | ) |
Definition at line 9010 of file TProof.cxx.
| void TProof::AddChain | ( | TChain * | chain | ) |
Definition at line 9115 of file TProof.cxx.
References TList::Add(), chain, and fChains.
Referenced by TProofChain::TProofChain().
| void TProof::RemoveChain | ( | TChain * | chain | ) |
Definition at line 9123 of file TProof.cxx.
References chain, fChains, and TList::Remove().
Referenced by PT_H1Http(), and ~TProof().
| TDrawFeedback * TProof::CreateDrawFeedback | ( | ) |
Definition at line 8985 of file TProof.cxx.
References TVirtualProofPlayer::CreateDrawFeedback(), and fPlayer.
Referenced by TProofChain::ConnectProof().
| void TProof::SetDrawFeedbackOption | ( | TDrawFeedback * | f, | |
| Option_t * | opt | |||
| ) |
Definition at line 8994 of file TProof.cxx.
References fPlayer, and TVirtualProofPlayer::SetDrawFeedbackOption().
Referenced by TProofChain::Draw().
| void TProof::DeleteDrawFeedback | ( | TDrawFeedback * | f | ) |
Definition at line 9002 of file TProof.cxx.
References TVirtualProofPlayer::DeleteDrawFeedback(), and fPlayer.
Referenced by TProofChain::ReleaseProof().
| void TProof::Detach | ( | Option_t * | opt = "" |
) |
Definition at line 9409 of file TProof.cxx.
References Close(), CloseProgressDialog(), Collect(), d, DeActivateAsyncInput(), TObject::Error(), fActiveSlaves, TList::First(), TSlave::FlushSocket(), fProgressDialogStarted, fValid, gEnv, GetManager(), TSlave::GetSocket(), TEnv::GetValue(), IsIdle(), IsValid(), TSlave::IsValid(), kActive, kFALSE, kTRUE, TProofMgr::QuerySessions(), TList::Remove(), Remove(), s, and StopProcess().
Referenced by TSessionFrame::OnBtnDisconnectClicked(), TSessionFrame::ShutdownSession(), and TSessionViewer::Terminate().
| void TProof::SetAlias | ( | const char * | alias = "" |
) | [virtual] |
Definition at line 9473 of file TProof.cxx.
References fActiveSlaves, TList::First(), IsProofd(), IsValid(), kIsClient, kIsMaster, TSlave::SetAlias(), TNamed::SetName(), TNamed::SetTitle(), and TObject::TestBit().
Referenced by Init(), and TSessionServerFrame::OnBtnConnectClicked().
| TProofMgr* TProof::GetManager | ( | ) | [inline] |
Definition at line 995 of file TProof.h.
References fManager.
Referenced by cd(), Detach(), TXSlave::Init(), and PT_AdminFunc().
| void TProof::SetManager | ( | TProofMgr * | mgr | ) |
Definition at line 1087 of file TProof.cxx.
References TSeqCollection::Add(), fManager, TROOT::GetListOfSockets(), gROOT, gROOTMutex, R__LOCKGUARD2, and TCollection::Remove().
| void TProof::ActivateWorker | ( | const char * | ord | ) |
Definition at line 10195 of file TProof.cxx.
References kTRUE, and ModifyWorkerLists().
Referenced by TProofServ::HandleWorkerLists().
| void TProof::DeactivateWorker | ( | const char * | ord | ) |
Definition at line 10208 of file TProof.cxx.
References kFALSE, and ModifyWorkerLists().
Referenced by HandleInputMessage(), and TProofServ::HandleWorkerLists().
| const char* TProof::GetDataPoolUrl | ( | ) | const [inline] |
Definition at line 1001 of file TProof.h.
References fDataPoolUrl.
Referenced by Print(), and UploadDataSet().
| void TProof::SetDataPoolUrl | ( | const char * | url | ) | [inline] |
| void TProof::SetPrintProgress | ( | PrintProgress_t | pp | ) | [inline] |
Definition at line 1004 of file TProof.h.
References fPrintProgress.
Referenced by PT_Event(), PT_H1DataSet(), PT_H1FileCollection(), PT_H1Http(), PT_H1MultiDataSet(), PT_H1MultiDSetEntryList(), PT_H1SimpleAsync(), PT_InputData(), PT_PackageArguments(), and PT_Simple().
Definition at line 11108 of file TProof.cxx.
References kUseProgressDialog, TObject::ResetBit(), and TObject::SetBit().
| TProof * TProof::Open | ( | const char * | url = 0, |
|
| const char * | conffile = 0, |
|||
| const char * | confdir = 0, |
|||
| Int_t | loglevel = 0 | |||
| ) | [static] |
Definition at line 10293 of file TProof.cxx.
References TString::Atoi(), TProofMgr::AttachSession(), TString::BeginsWith(), TProofMgr::Create(), TProofMgr::CreateSession(), d, TObject::Error(), TPluginHandler::ExecPlugin(), TPluginManager::FindHandler(), TList::First(), gEnv, TROOT::GetPluginManager(), TProofMgr::GetProofDesc(), gROOT, TString::Index(), TObject::Info(), TString::Insert(), TROOT::IsBatch(), TString::IsDigit(), TProofMgr::IsLite(), TProofMgr::IsProofd(), TProofMgr::IsValid(), kFALSE, TString::kIgnoreCase, kNPOS, kTRUE, TPluginHandler::LoadPlugin(), opts, XrdMonCtrCollector::port, proof, TProofMgr::QuerySessions(), TString::Remove(), SafeDelete, TEnv::SetValue(), u, and TObject::Warning().
Referenced by G__G__Proof_142_0_291(), G__setup_memfuncTProof(), getProof(), Run_Simple_Test(), and TPEAC::StartSession().
| void TProof::LogViewer | ( | const char * | url = 0, |
|
| Int_t | sessionidx = 0 | |||
| ) | [static] |
Definition at line 11070 of file TProof.cxx.
References TObject::Error(), TPluginHandler::ExecPlugin(), fgLogViewer, TPluginManager::FindHandler(), TROOT::GetPluginManager(), gROOT, TObject::Info(), TROOT::IsBatch(), TPluginHandler::LoadPlugin(), and u.
Referenced by G__G__Proof_142_0_292(), and G__setup_memfuncTProof().
| TProofMgr * TProof::Mgr | ( | const char * | url | ) | [static] |
Definition at line 10435 of file TProof.cxx.
References TProofMgr::Create().
Referenced by TProofProgressMemoryPlot::BuildLogList(), TProofProgressLog::BuildLogList(), TProofProgressLog::DoLog(), TProofProgressMemoryPlot::DoPlot(), G__G__Proof_142_0_293(), G__setup_memfuncTProof(), PT_GetLogs(), Reset(), and TSessionViewer::ResetSession().
Definition at line 10448 of file TProof.cxx.
References Error, TProofMgr::IsValid(), Mgr(), and TProofMgr::Reset().
Referenced by G__G__Proof_142_0_294(), and G__setup_memfuncTProof().
| void TProof::AddEnvVar | ( | const char * | name, | |
| const char * | value | |||
| ) | [static] |
Definition at line 10471 of file TProof.cxx.
References TList::Add(), fgProofEnvList, TList::FindObject(), gDebug, TObject::Info(), o, TList::Remove(), TCollection::SetOwner(), and TNamed::TNamed().
Referenced by G__G__Proof_142_0_295(), G__setup_memfuncTProof(), getProof(), TXSlave::Init(), InitMembers(), ParseConfigField(), runProof(), TProofServ::SetupCommon(), and VerifyDataSet().
| void TProof::DelEnvVar | ( | const char * | name | ) | [static] |
Definition at line 10493 of file TProof.cxx.
References fgProofEnvList, TList::FindObject(), o, and TList::Remove().
Referenced by G__G__Proof_142_0_296(), G__setup_memfuncTProof(), TXSlave::Init(), InitMembers(), and ParseConfigField().
| const TList * TProof::GetEnvVars | ( | ) | [static] |
Definition at line 10463 of file TProof.cxx.
References fgProofEnvList.
Referenced by G__G__Proof_142_0_297(), G__setup_memfuncTProof(), TXSlave::Init(), and TSlave::Init().
| void TProof::ResetEnvVars | ( | ) | [static] |
Definition at line 10507 of file TProof.cxx.
References fgProofEnvList, and SafeDelete.
Referenced by G__G__Proof_142_0_298(), and G__setup_memfuncTProof().
| Int_t TProof::GetParameter | ( | TCollection * | c, | |
| const char * | par, | |||
| TString & | value | |||
| ) | [static] |
| Int_t TProof::GetParameter | ( | TCollection * | c, | |
| const char * | par, | |||
| Int_t & | value | |||
| ) | [static] |
| Int_t TProof::GetParameter | ( | TCollection * | c, | |
| const char * | par, | |||
| Long_t & | value | |||
| ) | [static] |
| Int_t TProof::GetParameter | ( | TCollection * | c, | |
| const char * | par, | |||
| Long64_t & | value | |||
| ) | [static] |
| Int_t TProof::GetParameter | ( | TCollection * | c, | |
| const char * | par, | |||
| Double_t & | value | |||
| ) | [static] |
| void TProof::operator= | ( | const TProof & | ) | [private] |
| void TProof::CleanGDirectory | ( | TList * | ol | ) | [private] |
| Bool_t TProof::CheckFile | ( | const char * | file, | |
| TSlave * | sl, | |||
| Long_t | modtime, | |||
| Int_t | cpopt = (kCp|kCpBin) | |||
| ) | [private] |
| Int_t TProof::SendGroupView | ( | ) | [private] |
| Int_t TProof::SendInitialState | ( | ) | [private] |
| void TProof::AskStatistics | ( | ) | [private] |
| void TProof::AskParallel | ( | ) | [private] |
| void TProof::NotifyLogMsg | ( | const char * | msg, | |
| const char * | sfx = "\n" | |||
| ) | [private] |
| Int_t TProof::BuildPackage | ( | const char * | package, | |
| EBuildPackageOpt | opt = kBuildAll | |||
| ) | [private] |
| Int_t TProof::BuildPackageOnClient | ( | const char * | package, | |
| Int_t | opt = 0, |
|||
| TString * | path = 0 | |||
| ) | [private] |
| Int_t TProof::LoadPackage | ( | const char * | package, | |
| Bool_t | notOnClient = kFALSE, |
|||
| TList * | loadopts = 0 | |||
| ) | [private] |
| Int_t TProof::UnloadPackage | ( | const char * | package | ) | [private] |
| Int_t TProof::UnloadPackageOnClient | ( | const char * | package | ) | [private] |
| Int_t TProof::UnloadPackages | ( | ) | [private] |
| Int_t TProof::UploadPackageOnClient | ( | const char * | package, | |
| EUploadPackageOpt | opt, | |||
| TMD5 * | md5 | |||
| ) | [private] |
| Int_t TProof::DisablePackage | ( | const char * | package | ) | [private] |
| Int_t TProof::DisablePackageOnClient | ( | const char * | package | ) | [private] |
| Int_t TProof::DisablePackages | ( | ) | [private] |
| void TProof::Activate | ( | TList * | slaves = 0 |
) | [private] |
| Int_t TProof::Broadcast | ( | const char * | mess, | |
| Int_t | kind = kMESS_STRING, |
|||
| ESlaves | list = kActive | |||
| ) | [private] |
| Int_t TProof::BroadcastFile | ( | const char * | file, | |
| Int_t | opt, | |||
| const char * | rfile, | |||
| TList * | wrks | |||
| ) | [private] |
| Int_t TProof::BroadcastFile | ( | const char * | file, | |
| Int_t | opt, | |||
| const char * | rfile = 0, |
|||
| ESlaves | list = kAllUnique | |||
| ) | [private] |
| Int_t TProof::BroadcastGroupPriority | ( | const char * | grp, | |
| Int_t | priority, | |||
| ESlaves | list = kAllUnique | |||
| ) | [private] |
| Int_t TProof::BroadcastGroupPriority | ( | const char * | grp, | |
| Int_t | priority, | |||
| TList * | workers | |||
| ) | [private] |
| Int_t TProof::BroadcastObject | ( | const TObject * | obj, | |
| Int_t | kind = kMESS_OBJECT, |
|||
| ESlaves | list = kActive | |||
| ) | [private] |
| Int_t TProof::Collect | ( | const TSlave * | sl, | |
| Long_t | timeout = -1, |
|||
| Int_t | endtype = -1, |
|||
| Bool_t | deactonfail = kFALSE | |||
| ) | [private] |
| Int_t TProof::Collect | ( | TMonitor * | mon, | |
| Long_t | timeout = -1, |
|||
| Int_t | endtype = -1, |
|||
| Bool_t | deactonfail = kFALSE | |||
| ) | [private] |
| Int_t TProof::CollectInputFrom | ( | TSocket * | s, | |
| Int_t | endtype = -1, |
|||
| Bool_t | deactonfail = kFALSE | |||
| ) | [private] |
| Int_t TProof::HandleInputMessage | ( | TSlave * | wrk, | |
| TMessage * | m, | |||
| Bool_t | deactonfail = kFALSE | |||
| ) | [private] |
| void TProof::ReleaseMonitor | ( | TMonitor * | mon | ) | [private] |
| virtual void TProof::FindUniqueSlaves | ( | ) | [private, virtual] |
| TList* TProof::GetListOfSlaves | ( | ) | const [inline, private] |
| TList* TProof::GetListOfInactiveSlaves | ( | ) | const [inline, private] |
| TList* TProof::GetListOfUniqueSlaves | ( | ) | const [inline, private] |
| TList* TProof::GetListOfBadSlaves | ( | ) | const [inline, private] |
| Int_t TProof::GetNumberOfSlaves | ( | ) | const [private] |
| Int_t TProof::GetNumberOfActiveSlaves | ( | ) | const [private] |
| Int_t TProof::GetNumberOfInactiveSlaves | ( | ) | const [private] |
| Int_t TProof::GetNumberOfUniqueSlaves | ( | ) | const [private] |
| Int_t TProof::GetNumberOfBadSlaves | ( | ) | const [private] |
| Bool_t TProof::IsEndMaster | ( | ) | const [inline, private] |
| void TProof::ModifyWorkerLists | ( | const char * | ord, | |
| Bool_t | add | |||
| ) | [private] |
| Bool_t TProof::IsSync | ( | ) | const [inline, private] |
| void TProof::InterruptCurrentMonitor | ( | ) | [private] |
| void TProof::SetRunStatus | ( | ERunStatus | rst | ) | [inline, private] |
| void TProof::MarkBad | ( | TSlave * | wrk, | |
| const char * | reason = 0 | |||
| ) | [private] |
| void TProof::MarkBad | ( | TSocket * | s, | |
| const char * | reason = 0 | |||
| ) | [private] |
| void TProof::TerminateWorker | ( | TSlave * | wrk | ) | [private] |
| void TProof::TerminateWorker | ( | const char * | ord | ) | [private] |
| void TProof::ActivateAsyncInput | ( | ) | [private] |
| void TProof::DeActivateAsyncInput | ( | ) | [private] |
| void TProof::PrintProgress | ( | Long64_t | total, | |
| Long64_t | processed, | |||
| Float_t | procTime = -1., |
|||
| Long64_t | bytesread = -1 | |||
| ) | [private] |
| Int_t TProof::GetActiveMergersCount | ( | ) | [private] |
| Int_t TProof::FindNextFreeMerger | ( | ) | [private] |
| void TProof::ResetMergers | ( | ) | [inline, private] |
| void TProof::AskForOutput | ( | TSlave * | sl | ) | [private] |
| void TProof::FinalizationDone | ( | ) | [inline, private] |
| void TProof::ResetMergePrg | ( | ) | [private] |
| void TProof::ParseConfigField | ( | const char * | config | ) | [private] |
| Bool_t TProof::Prompt | ( | const char * | p | ) | [private] |
| void TProof::InitMembers | ( | ) | [protected] |
| Int_t TProof::Init | ( | const char * | masterurl, | |
| const char * | conffile, | |||
| const char * | confdir, | |||
| Int_t | loglevel, | |||
| const char * | alias = 0 | |||
| ) | [protected] |
| void TProof::SetPlayer | ( | TVirtualProofPlayer * | player | ) | [protected] |
| TVirtualProofPlayer* TProof::GetPlayer | ( | ) | const [inline, protected] |
| virtual TVirtualProofPlayer* TProof::MakePlayer | ( | const char * | player = 0, |
|
| TSocket * | s = 0 | |||
| ) | [protected, virtual] |
| void TProof::UpdateDialog | ( | ) | [protected] |
| void TProof::HandleLibIncPath | ( | const char * | what, | |
| Bool_t | add, | |||
| const char * | dirs | |||
| ) | [protected] |
| TList* TProof::GetListOfActiveSlaves | ( | ) | const [inline, protected] |
| TSlave* TProof::CreateSlave | ( | const char * | url, | |
| const char * | ord, | |||
| Int_t | perf, | |||
| const char * | image, | |||
| const char * | workdir | |||
| ) | [protected] |
| TSlave* TProof::CreateSubmaster | ( | const char * | url, | |
| const char * | ord, | |||
| const char * | image, | |||
| const char * | msd | |||
| ) | [protected] |
| virtual void TProof::SaveWorkerInfo | ( | ) | [protected, virtual] |
| Int_t TProof::Collect | ( | ESlaves | list = kActive, |
|
| Long_t | timeout = -1, |
|||
| Int_t | endtype = -1, |
|||
| Bool_t | deactonfail = kFALSE | |||
| ) | [protected] |
| Int_t TProof::Collect | ( | TList * | slaves, | |
| Long_t | timeout = -1, |
|||
| Int_t | endtype = -1, |
|||
| Bool_t | deactonfail = kFALSE | |||
| ) | [protected] |
| void TProof::SetDSet | ( | TDSet * | dset | ) | [inline, protected] |
| virtual void TProof::ValidateDSet | ( | TDSet * | dset | ) | [protected, virtual] |
| TPluginHandler* TProof::GetProgressDialog | ( | ) | const [inline, protected] |
| void TProof::PrepareInputDataFile | ( | TString & | dataFile | ) | [protected] |
| virtual void TProof::SendInputDataFile | ( | ) | [protected, virtual] |
| Int_t TProof::SendFile | ( | const char * | file, | |
| Int_t | opt = (kBinary|kForward|kCp|kCpBin), |
|||
| const char * | rfile = 0, |
|||
| TSlave * | sl = 0 | |||
| ) | [protected] |
| static void* TProof::SlaveStartupThread | ( | void * | arg | ) | [static, protected] |
| static Int_t TProof::AssertDataSet | ( | TDSet * | dset, | |
| TList * | input, | |||
| TDataSetManager * | mgr, | |||
| TString & | emsg | |||
| ) | [static, protected] |
| static Int_t TProof::GetInputData | ( | TList * | input, | |
| const char * | cachedir, | |||
| TString & | emsg | |||
| ) | [static, protected] |
| static Int_t TProof::SaveInputData | ( | TQueryResult * | qr, | |
| const char * | cachedir, | |||
| TString & | emsg | |||
| ) | [static, protected] |
| static Int_t TProof::SendInputData | ( | TQueryResult * | qr, | |
| TProof * | p, | |||
| TString & | emsg | |||
| ) | [static, protected] |
| static void TProof::SystemCmd | ( | const char * | cmd, | |
| Int_t | fdout | |||
| ) | [static, protected] |
| void TProof::cd | ( | Int_t | id = -1 |
) |
| Int_t TProof::Ping | ( | ) |
| void TProof::Touch | ( | ) |
| virtual Long64_t TProof::Process | ( | TDSet * | dset, | |
| const char * | selector, | |||
| Option_t * | option = "", |
|||
| Long64_t | nentries = -1, |
|||
| Long64_t | firstentry = 0 | |||
| ) | [virtual] |
| virtual Long64_t TProof::Process | ( | TFileCollection * | fc, | |
| const char * | selector, | |||
| Option_t * | option = "", |
|||
| Long64_t | nentries = -1, |
|||
| Long64_t | firstentry = 0 | |||
| ) | [virtual] |
| virtual Long64_t TProof::Process | ( | const char * | dsetname, | |
| const char * | selector, | |||
| Option_t * | option = "", |
|||
| Long64_t | nentries = -1, |
|||
| Long64_t | firstentry = 0, |
|||
| TObject * | enl = 0 | |||
| ) | [virtual] |
| virtual Long64_t TProof::Process | ( | const char * | selector, | |
| Long64_t | nentries, | |||
| Option_t * | option = "" | |||
| ) | [virtual] |
| virtual Long64_t TProof::DrawSelect | ( | TDSet * | dset, | |
| const char * | varexp, | |||
| const char * | selection = "", |
|||
| Option_t * | option = "", |
|||
| Long64_t | nentries = -1, |
|||
| Long64_t | firstentry = 0 | |||
| ) | [virtual] |
| Long64_t TProof::DrawSelect | ( | const char * | dsetname, | |
| const char * | varexp, | |||
| const char * | selection = "", |
|||
| Option_t * | option = "", |
|||
| Long64_t | nentries = -1, |
|||
| Long64_t | firstentry = 0, |
|||
| TObject * | enl = 0 | |||
| ) |
| Int_t TProof::Archive | ( | const char * | queryref, | |
| const char * | url = 0 | |||
| ) |
| Int_t TProof::CleanupSession | ( | const char * | sessiontag | ) |
| Int_t TProof::Retrieve | ( | const char * | queryref, | |
| const char * | path = 0 | |||
| ) |
| void TProof::DisableGoAsyn | ( | ) |
| void TProof::GoAsynchronous | ( | ) |
| void TProof::Close | ( | Option_t * | option = "" |
) |
| virtual void TProof::ClearCache | ( | const char * | file = 0 |
) | [virtual] |
| TList* TProof::GetListOfPackages | ( | ) |
| TList* TProof::GetListOfEnabledPackages | ( | ) |
| Int_t TProof::ClearPackages | ( | ) |
| Int_t TProof::ClearPackage | ( | const char * | package | ) |
| Int_t TProof::DownloadPackage | ( | const char * | par, | |
| const char * | dstdir = 0 | |||
| ) |
| Int_t TProof::EnablePackage | ( | const char * | package, | |
| const char * | loadopts, | |||
| Bool_t | notOnClient = kFALSE | |||
| ) |
| Int_t TProof::UploadPackage | ( | const char * | par, | |
| EUploadPackageOpt | opt = kUntar | |||
| ) |
| virtual Int_t TProof::Load | ( | const char * | macro, | |
| Bool_t | notOnClient = kFALSE, |
|||
| Bool_t | uniqueOnly = kTRUE, |
|||
| TList * | wrks = 0 | |||
| ) | [virtual] |
| Int_t TProof::UploadDataSet | ( | const char * | dataset, | |
| TList * | files, | |||
| const char * | dest = 0, |
|||
| Int_t | opt = kAskUser, |
|||
| TList * | skippedFiles = 0 | |||
| ) |
| Int_t TProof::UploadDataSet | ( | const char * | dataset, | |
| const char * | files, | |||
| const char * | dest = 0, |
|||
| Int_t | opt = kAskUser, |
|||
| TList * | skippedFiles = 0 | |||
| ) |
| Int_t TProof::UploadDataSetFromFile | ( | const char * | dataset, | |
| const char * | file, | |||
| const char * | dest = 0, |
|||
| Int_t | opt = kAskUser, |
|||
| TList * | skippedFiles = 0 | |||
| ) |
| virtual Bool_t TProof::RegisterDataSet | ( | const char * | name, | |
| TFileCollection * | dataset, | |||
| const char * | optStr = "" | |||
| ) | [virtual] |
| virtual TMap* TProof::GetDataSets | ( | const char * | uri = "", |
|
| const char * | optStr = "" | |||
| ) | [virtual] |
| virtual void TProof::ShowDataSets | ( | const char * | uri = "", |
|
| const char * | optStr = "" | |||
| ) | [virtual] |
| TMap* TProof::GetDataSetQuota | ( | const char * | optStr = "" |
) |
| void TProof::ShowDataSetQuota | ( | Option_t * | opt = 0 |
) |
| virtual Bool_t TProof::ExistsDataSet | ( | const char * | dataset | ) | [virtual] |
| void TProof::ShowDataSet | ( | const char * | dataset = "", |
|
| const char * | opt = "M" | |||
| ) |
| virtual Int_t TProof::RemoveDataSet | ( | const char * | dataset, | |
| const char * | optStr = "" | |||
| ) | [virtual] |
| virtual Int_t TProof::VerifyDataSet | ( | const char * | dataset, | |
| const char * | optStr = "" | |||
| ) | [virtual] |
| virtual TFileCollection* TProof::GetDataSet | ( | const char * | dataset, | |
| const char * | optStr = "" | |||
| ) | [virtual] |
| TList* TProof::FindDataSets | ( | const char * | searchString, | |
| const char * | optStr = "" | |||
| ) |
| virtual Int_t TProof::SetDataSetTreeName | ( | const char * | dataset, | |
| const char * | treename | |||
| ) | [virtual] |
| virtual void TProof::ShowDataSetCache | ( | const char * | dataset = 0 |
) | [virtual] |
| virtual void TProof::ClearDataSetCache | ( | const char * | dataset = 0 |
) | [virtual] |
| void TProof::ShowData | ( | ) |
| void TProof::ClearData | ( | UInt_t | what = kUnregistered, |
|
| const char * | dsname = 0 | |||
| ) |
| const char* TProof::GetMaster | ( | ) | const [inline] |
| const char* TProof::GetConfDir | ( | ) | const [inline] |
| const char* TProof::GetConfFile | ( | ) | const [inline] |
| const char* TProof::GetUser | ( | ) | const [inline] |
| const char* TProof::GetGroup | ( | ) | const [inline] |
| const char* TProof::GetWorkDir | ( | ) | const [inline] |
| const char* TProof::GetSessionTag | ( | ) | const [inline] |
| const char* TProof::GetImage | ( | ) | const [inline] |
| const char* TProof::GetUrl | ( | ) | [inline] |
| Int_t TProof::GetPort | ( | ) | const [inline] |
| Int_t TProof::GetRemoteProtocol | ( | ) | const [inline] |
| Int_t TProof::GetClientProtocol | ( | ) | const [inline] |
| Int_t TProof::GetStatus | ( | ) | const [inline] |
| Int_t TProof::GetLogLevel | ( | ) | const [inline] |
| Int_t TProof::GetParallel | ( | ) | const |
| Int_t TProof::GetSeqNum | ( | ) | const [inline] |
| Int_t TProof::GetSessionID | ( | ) | const [inline] |
| TList* TProof::GetListOfSlaveInfos | ( | ) |
| Bool_t TProof::UseDynamicStartup | ( | ) | const [inline] |
| EQueryMode TProof::GetQueryMode | ( | Option_t * | mode = 0 |
) | const |
| void TProof::SetQueryMode | ( | EQueryMode | mode | ) |
| Long64_t TProof::GetBytesRead | ( | ) | const [inline] |
| Float_t TProof::GetRealTime | ( | ) | const [inline] |
| Float_t TProof::GetCpuTime | ( | ) | const [inline] |
| Bool_t TProof::IsLite | ( | ) | const [inline] |
| Bool_t TProof::IsProofd | ( | ) | const [inline] |
| Bool_t TProof::IsFolder | ( | ) | const [inline, virtual] |
| Bool_t TProof::IsMaster | ( | ) | const [inline] |
| Bool_t TProof::IsValid | ( | ) | const [inline] |
| Bool_t TProof::IsParallel | ( | ) | const [inline] |
| Bool_t TProof::IsIdle | ( | ) | const [inline] |
| Bool_t TProof::IsWaiting | ( | ) | const [inline] |
| ERunStatus TProof::GetRunStatus | ( | ) | const [inline] |
| TList* TProof::GetLoadedMacros | ( | ) | const [inline] |
| void TProof::SetParameter | ( | const char * | par, | |
| const char * | value | |||
| ) |
| void TProof::SetParameter | ( | const char * | par, | |
| Int_t | value | |||
| ) |
| void TProof::SetParameter | ( | const char * | par, | |
| Long_t | value | |||
| ) |
| void TProof::SetParameter | ( | const char * | par, | |
| Long64_t | value | |||
| ) |
| void TProof::SetParameter | ( | const char * | par, | |
| Double_t | value | |||
| ) |
| TObject* TProof::GetParameter | ( | const char * | par | ) | const |
| void TProof::DeleteParameters | ( | const char * | wildcard | ) |
| void TProof::ShowParameters | ( | const char * | wildcard = "PROOF_*" |
) | const |
| void TProof::AddInput | ( | TObject * | obj | ) |
| void TProof::ClearInput | ( | ) |
| TList* TProof::GetInputList | ( | ) |
| TObject* TProof::GetOutput | ( | const char * | name | ) |
| TList* TProof::GetOutputList | ( | ) |
| void TProof::ShowMissingFiles | ( | TQueryResult * | qr = 0 |
) |
| TFileCollection* TProof::GetMissingFiles | ( | TQueryResult * | qr = 0 |
) |
| void TProof::SetInputDataFile | ( | const char * | datafile | ) |
| void TProof::ClearInputData | ( | TObject * | obj = 0 |
) |
| void TProof::ClearInputData | ( | const char * | name | ) |
| void TProof::AddFeedback | ( | const char * | name | ) |
| void TProof::RemoveFeedback | ( | const char * | name | ) |
| void TProof::ClearFeedback | ( | ) |
| void TProof::ShowFeedback | ( | ) | const |
| TList* TProof::GetFeedbackList | ( | ) | const |
| Int_t TProof::GetNumberOfQueries | ( | ) |
| Int_t TProof::GetNumberOfDrawQueries | ( | ) | [inline] |
| TList* TProof::GetQueryResults | ( | ) |
| TQueryResult* TProof::GetQueryResult | ( | const char * | ref = 0 |
) |
| void TProof::GetMaxQueries | ( | ) |
| void TProof::SetMaxDrawQueries | ( | Int_t | max | ) |
| void TProof::ShowQueries | ( | Option_t * | opt = "" |
) |
| void TProof::LogMessage | ( | const char * | msg, | |
| Bool_t | all | |||
| ) |
| void TProof::Progress | ( | Long64_t | total, | |
| Long64_t | processed, | |||
| Long64_t | bytesread, | |||
| Float_t | initTime, | |||
| Float_t | procTime, | |||
| Float_t | evtrti, | |||
| Float_t | mbrti | |||
| ) |
| void TProof::Progress | ( | Long64_t | total, | |
| Long64_t | processed, | |||
| Long64_t | bytesread, | |||
| Float_t | initTime, | |||
| Float_t | procTime, | |||
| Float_t | evtrti, | |||
| Float_t | mbrti, | |||
| Int_t | actw, | |||
| Int_t | tses, | |||
| Float_t | eses | |||
| ) |
| void TProof::Feedback | ( | TList * | objs | ) |
| void TProof::QueryResultReady | ( | const char * | ref | ) |
| void TProof::CloseProgressDialog | ( | ) |
| TMacro* TProof::GetLastLog | ( | ) |
| void TProof::PutLog | ( | TQueryResult * | qr | ) |
| void TProof::ShowLog | ( | Int_t | qry = -1 |
) |
| void TProof::ShowLog | ( | const char * | queryref | ) |
| Bool_t TProof::SendingLogToWindow | ( | ) | const [inline] |
| void TProof::SendLogToWindow | ( | Bool_t | mode | ) | [inline] |
| void TProof::ResetProgressDialogStatus | ( | ) | [inline] |
| TList* TProof::GetOutputNames | ( | ) |
| void TProof::AddChain | ( | TChain * | chain | ) |
| void TProof::RemoveChain | ( | TChain * | chain | ) |
| TDrawFeedback* TProof::CreateDrawFeedback | ( | ) |
| void TProof::SetDrawFeedbackOption | ( | TDrawFeedback * | f, | |
| Option_t * | opt | |||
| ) |
| void TProof::DeleteDrawFeedback | ( | TDrawFeedback * | f | ) |
| void TProof::Detach | ( | Option_t * | opt = "" |
) |
| virtual void TProof::SetAlias | ( | const char * | alias = "" |
) | [virtual] |
| TProofMgr* TProof::GetManager | ( | ) | [inline] |
| void TProof::SetManager | ( | TProofMgr * | mgr | ) |
| void TProof::ActivateWorker | ( | const char * | ord | ) |
| void TProof::DeactivateWorker | ( | const char * | ord | ) |
| const char* TProof::GetDataPoolUrl | ( | ) | const [inline] |
| void TProof::SetDataPoolUrl | ( | const char * | url | ) | [inline] |
| void TProof::SetPrintProgress | ( | PrintProgress_t | pp | ) | [inline] |
| static TProof* TProof::Open | ( | const char * | url = 0, |
|
| const char * | conffile = 0, |
|||
| const char * | confdir = 0, |
|||
| Int_t | loglevel = 0 | |||
| ) | [static] |
| static void TProof::LogViewer | ( | const char * | url = 0, |
|
| Int_t | sessionidx = 0 | |||
| ) | [static] |
| static TProofMgr* TProof::Mgr | ( | const char * | url | ) | [static] |
| static void TProof::AddEnvVar | ( | const char * | name, | |
| const char * | value | |||
| ) | [static] |
| static void TProof::DelEnvVar | ( | const char * | name | ) | [static] |
| static const TList* TProof::GetEnvVars | ( | ) | [static] |
| static void TProof::ResetEnvVars | ( | ) | [static] |
| static Int_t TProof::GetParameter | ( | TCollection * | c, | |
| const char * | par, | |||
| TString & | value | |||
| ) | [static] |
| static Int_t TProof::GetParameter | ( | TCollection * | c, | |
| const char * | par, | |||
| Int_t & | value | |||
| ) | [static] |
| static Int_t TProof::GetParameter | ( | TCollection * | c, | |
| const char * | par, | |||
| Long_t & | value | |||
| ) | [static] |
| static Int_t TProof::GetParameter | ( | TCollection * | c, | |
| const char * | par, | |||
| Long64_t & | value | |||
| ) | [static] |
| static Int_t TProof::GetParameter | ( | TCollection * | c, | |
| const char * | par, | |||
| Double_t & | value | |||
| ) | [static] |
TPacketizer [friend] |
TPacketizerAdaptive [friend] |
TProofLite [friend] |
TDataSetManager [friend] |
TProofServ [friend] |
TProofInputHandler [friend] |
TProofInterruptHandler [friend] |
TProofPlayer [friend] |
TProofPlayerLite [friend] |
TProofPlayerRemote [friend] |
TProofProgressDialog [friend] |
TSlaveLite [friend] |
TVirtualPacketizer [friend] |
TXSocketHandler [friend] |
TXProofMgr [friend] |
TXProofServ [friend] |
Bool_t TProof::fValid [private] |
Definition at line 470 of file TProof.h.
Referenced by Close(), Detach(), Init(), TProofLite::Init(), InitMembers(), IsValid(), and MarkBad().
TString TProof::fMaster [private] |
TString TProof::fWorkDir [private] |
Definition at line 472 of file TProof.h.
Referenced by TProofLite::CleanupSandbox(), TProofLite::CreateSandbox(), GetWorkDir(), Init(), TProofLite::Init(), TProofLite::SetProofServEnv(), and TProofLite::SetupWorkers().
TString TProof::fGroup [private] |
Definition at line 473 of file TProof.h.
Referenced by GetGroup(), HandleInputMessage(), and Init().
Int_t TProof::fLogLevel [private] |
Definition at line 474 of file TProof.h.
Referenced by GetLogLevel(), Init(), TProofLite::Init(), SendInitialState(), and SetLogLevel().
Int_t TProof::fStatus [private] |
Definition at line 475 of file TProof.h.
Referenced by BuildPackage(), ClearPackage(), ClearPackages(), Collect(), DisablePackage(), DisablePackages(), ExistsDataSet(), GetDataSet(), GetDataSetQuota(), GetDataSets(), GetStatus(), HandleInputMessage(), Init(), TProofLite::Init(), LoadPackage(), RegisterDataSet(), RemoveDataSet(), SendCommand(), SetDataSetTreeName(), ShowDataSetQuota(), ShowDataSets(), UnloadPackage(), UnloadPackages(), UploadDataSet(), and VerifyDataSet().
Int_t TProof::fCheckFileStatus [private] |
Definition at line 476 of file TProof.h.
Referenced by CheckFile(), HandleInputMessage(), and UploadPackage().
TList* TProof::fRecvMessages [private] |
Definition at line 477 of file TProof.h.
Referenced by Collect(), GetDataSet(), GetDataSetQuota(), GetDataSets(), GetTreeHeader(), HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), and ~TProof().
TList* TProof::fSlaveInfo [private] |
Definition at line 478 of file TProof.h.
Referenced by GetListOfSlaveInfos(), HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), and ~TProof().
Bool_t TProof::fSendGroupView [private] |
list returned by kPROOF_GETSLAVEINFO
Definition at line 479 of file TProof.h.
Referenced by Init(), TProofLite::Init(), InitMembers(), MarkBad(), and SendGroupView().
TList* TProof::fActiveSlaves [private] |
Definition at line 480 of file TProof.h.
Referenced by Activate(), Broadcast(), BroadcastFile(), BroadcastGroupPriority(), BroadcastRaw(), Browse(), Close(), TProofLite::CreateSymLinks(), Detach(), FindUniqueSlaves(), TProofLite::FindUniqueSlaves(), GetListOfActiveSlaves(), GetNumberOfActiveSlaves(), GoParallel(), TXProofServ::HandleUrgentData(), Init(), TProofLite::Init(), InitMembers(), Interrupt(), Load(), MarkBad(), ModifyWorkerLists(), Ping(), Print(), ResetMergePrg(), SendFile(), SendGroupView(), SetAlias(), TProofLite::SetupWorkers(), and ~TProof().
TList* TProof::fInactiveSlaves [private] |
Definition at line 481 of file TProof.h.
Referenced by GetListOfInactiveSlaves(), GetNumberOfInactiveSlaves(), GoParallel(), Init(), TProofLite::Init(), InitMembers(), MarkBad(), ModifyWorkerLists(), and ~TProof().
TList* TProof::fUniqueSlaves [private] |
Definition at line 482 of file TProof.h.
Referenced by Broadcast(), BroadcastFile(), BroadcastGroupPriority(), BroadcastRaw(), Close(), FindUniqueSlaves(), TProofLite::FindUniqueSlaves(), GetListOfUniqueSlaves(), GetNumberOfUniqueSlaves(), Init(), TProofLite::Init(), InitMembers(), Interrupt(), Load(), MarkBad(), Ping(), SendFile(), UploadPackage(), and ~TProof().
TList* TProof::fAllUniqueSlaves [private] |
Definition at line 483 of file TProof.h.
Referenced by Broadcast(), BroadcastFile(), BroadcastGroupPriority(), BroadcastRaw(), Close(), FindUniqueSlaves(), TProofLite::FindUniqueSlaves(), Init(), TProofLite::Init(), InitMembers(), Interrupt(), MarkBad(), Ping(), and ~TProof().
TList* TProof::fNonUniqueMasters [private] |
Definition at line 484 of file TProof.h.
Referenced by BuildPackage(), ClearCache(), Close(), DisablePackage(), DisablePackages(), FindUniqueSlaves(), TProofLite::FindUniqueSlaves(), Init(), TProofLite::Init(), InitMembers(), MarkBad(), ShowCache(), ShowPackages(), UploadPackage(), and ~TProof().
TMonitor* TProof::fActiveMonitor [private] |
Definition at line 485 of file TProof.h.
Referenced by Collect(), GoParallel(), Init(), TProofLite::Init(), InitMembers(), MarkBad(), ModifyWorkerLists(), ReleaseMonitor(), and ~TProof().
TMonitor* TProof::fUniqueMonitor [private] |
Definition at line 486 of file TProof.h.
Referenced by Collect(), FindUniqueSlaves(), TProofLite::FindUniqueSlaves(), Init(), TProofLite::Init(), InitMembers(), ReleaseMonitor(), and ~TProof().
TMonitor* TProof::fAllUniqueMonitor [private] |
Definition at line 487 of file TProof.h.
Referenced by Collect(), FindUniqueSlaves(), TProofLite::FindUniqueSlaves(), Init(), TProofLite::Init(), InitMembers(), ReleaseMonitor(), and ~TProof().
TMonitor* TProof::fCurrentMonitor [private] |
Definition at line 488 of file TProof.h.
Referenced by Collect(), CollectInputFrom(), TXSlave::HandleInput(), HandleSubmerger(), Init(), TProofLite::Init(), InitMembers(), InterruptCurrentMonitor(), MarkBad(), and SetMonitor().
Long64_t TProof::fBytesRead [private] |
Definition at line 489 of file TProof.h.
Referenced by Collect(), GetBytesRead(), GetStatistics(), HandleInputMessage(), Init(), and InitMembers().
Float_t TProof::fRealTime [private] |
Definition at line 490 of file TProof.h.
Referenced by Collect(), GetRealTime(), GetStatistics(), HandleInputMessage(), Init(), and InitMembers().
Float_t TProof::fCpuTime [private] |
Definition at line 491 of file TProof.h.
Referenced by Collect(), GetCpuTime(), GetStatistics(), HandleInputMessage(), Init(), and InitMembers().
TSignalHandler* TProof::fIntHandler [private] |
Definition at line 492 of file TProof.h.
Referenced by Close(), Collect(), TXSlave::HandleError(), Init(), TProofLite::Init(), InitMembers(), StartSlaves(), and ~TProof().
TPluginHandler* TProof::fProgressDialog [private] |
Definition at line 493 of file TProof.h.
Referenced by GetProgressDialog(), HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), TProofLite::Process(), TProofLite::SetupWorkers(), and StartSlaves().
Bool_t TProof::fProgressDialogStarted [private] |
Definition at line 494 of file TProof.h.
Referenced by CloseProgressDialog(), Detach(), HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), TProofLite::Process(), and ResetProgressDialogStatus().
TVirtualProofPlayer* TProof::fPlayer [private] |
Definition at line 495 of file TProof.h.
Referenced by AddInput(), Browse(), ClearInput(), Collect(), CreateDrawFeedback(), DeleteDrawFeedback(), DeleteParameters(), DrawSelect(), Finalize(), GetInputList(), GetOutput(), GetOutputList(), GetParameter(), GetPlayer(), GetQueryResult(), GetQueryResults(), HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), TProofLite::MakeQueryResult(), MarkBad(), TProofLite::Process(), Process(), TProofLite::Remove(), Remove(), Retrieve(), SetDrawFeedbackOption(), SetMaxDrawQueries(), SetParameter(), SetPlayer(), ShowLog(), ShowParameters(), ShowQueries(), StopProcess(), UpdateDialog(), and ~TProof().
TList* TProof::fFeedback [private] |
Definition at line 496 of file TProof.h.
Referenced by AddFeedback(), Browse(), ClearFeedback(), ClearInput(), GetFeedbackList(), Init(), TProofLite::Init(), InitMembers(), RemoveFeedback(), ShowFeedback(), and ~TProof().
TList* TProof::fChains [private] |
Definition at line 497 of file TProof.h.
Referenced by AddChain(), Browse(), Init(), TProofLite::Init(), InitMembers(), RemoveChain(), and ~TProof().
FileMap_t TProof::fFileMap [private] |
Definition at line 503 of file TProof.h.
Referenced by CheckFile(), ClearCache(), and RemoveWorkers().
TDSet* TProof::fDSet [private] |
Definition at line 504 of file TProof.h.
Referenced by HandleInputMessage(), InitMembers(), and SetDSet().
Int_t TProof::fNotIdle [private] |
Definition at line 506 of file TProof.h.
Referenced by HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), and IsIdle().
Bool_t TProof::fSync [private] |
Definition at line 507 of file TProof.h.
Referenced by GoAsynchronous(), HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), IsSync(), TProofLite::Process(), Process(), SendDataSetStatus(), and UpdateDialog().
ERunStatus TProof::fRunStatus [private] |
Definition at line 508 of file TProof.h.
Referenced by GetRunStatus(), InitMembers(), and SetRunStatus().
Bool_t TProof::fIsWaiting [private] |
Definition at line 509 of file TProof.h.
Referenced by HandleInputMessage(), Init(), InitMembers(), and IsWaiting().
Bool_t TProof::fRedirLog [private] |
Definition at line 511 of file TProof.h.
Referenced by Collect(), HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), NotifyLogMsg(), PrintProgress(), TProofPlayerRemote::Process(), RecvLogFile(), and ShowPackages().
TString TProof::fLogFileName [private] |
Definition at line 512 of file TProof.h.
Referenced by DownloadPackage(), TProofPlayerRemote::Finalize(), GetStatistics(), Init(), TProofLite::Init(), TProofPlayerRemote::Process(), TProofPlayerLite::Process(), and ~TProof().
FILE* TProof::fLogFileW [private] |
Definition at line 513 of file TProof.h.
Referenced by Init(), TProofLite::Init(), InitMembers(), NotifyLogMsg(), RecvLogFile(), TProofPlayerRemote::RedirectOutput(), TProofLite::SetQueryRunning(), ShowPackages(), and ~TProof().
FILE* TProof::fLogFileR [private] |
Definition at line 514 of file TProof.h.
Referenced by GetLastLog(), Init(), TProofLite::Init(), InitMembers(), LogMessage(), ShowLog(), and ~TProof().
Bool_t TProof::fLogToWindowOnly [private] |
Definition at line 515 of file TProof.h.
Referenced by Init(), TProofLite::Init(), InitMembers(), NotifyLogMsg(), RecvLogFile(), SendingLogToWindow(), and SendLogToWindow().
TProofMergePrg TProof::fMergePrg [private] |
Definition at line 517 of file TProof.h.
Referenced by AskForOutput(), HandleInputMessage(), HandleSubmerger(), and ResetMergePrg().
TList* TProof::fWaitingSlaves [private] |
Definition at line 519 of file TProof.h.
Referenced by HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), and ~TProof().
TList* TProof::fQueries [private] |
Definition at line 520 of file TProof.h.
Referenced by GetListOfQueries(), TProofLite::GetListOfQueries(), GetNumberOfQueries(), GetQueryReference(), HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), ShowLog(), and ShowQueries().
Int_t TProof::fOtherQueries [private] |
Definition at line 521 of file TProof.h.
Referenced by TProofLite::GetListOfQueries(), GetNumberOfQueries(), HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), and ShowQueries().
Int_t TProof::fDrawQueries [private] |
Definition at line 522 of file TProof.h.
Referenced by TProofLite::GetListOfQueries(), GetNumberOfDrawQueries(), HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), and ShowQueries().
Int_t TProof::fMaxDrawQueries [private] |
Definition at line 523 of file TProof.h.
Referenced by Init(), TProofLite::Init(), InitMembers(), and SetMaxDrawQueries().
Int_t TProof::fSeqNum [private] |
Definition at line 524 of file TProof.h.
Referenced by GetSeqNum(), HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), TProofLite::Process(), and TProofPlayerRemote::Process().
Int_t TProof::fSessionID [private] |
Definition at line 526 of file TProof.h.
Referenced by GetSessionID(), TXSlave::Init(), Init(), TProofLite::Init(), and InitMembers().
Bool_t TProof::fEndMaster [private] |
Definition at line 528 of file TProof.h.
Referenced by GoParallel(), Init(), TProofLite::Init(), InitMembers(), and IsEndMaster().
TString TProof::fPackageDir [private] |
Definition at line 530 of file TProof.h.
Referenced by BuildPackageOnClient(), TProofLite::CreateSandbox(), DisablePackageOnClient(), DisablePackages(), Init(), TProofLite::Init(), LoadPackageOnClient(), TProofLite::SetProofServEnv(), ShowPackages(), UploadPackage(), and UploadPackageOnClient().
THashList* TProof::fGlobalPackageDirList [private] |
Definition at line 531 of file TProof.h.
Referenced by BuildPackageOnClient(), Init(), TProofLite::Init(), InitMembers(), LoadPackageOnClient(), ShowPackages(), UploadPackage(), and ~TProof().
TProofLockPath* TProof::fPackageLock [private] |
Definition at line 532 of file TProof.h.
Referenced by BuildPackage(), DisablePackageOnClient(), DisablePackages(), Init(), TProofLite::Init(), InitMembers(), LoadPackageOnClient(), UploadPackageOnClient(), and ~TProof().
TList* TProof::fEnabledPackagesOnClient [private] |
Definition at line 533 of file TProof.h.
Referenced by Init(), TProofLite::Init(), InitMembers(), LoadPackageOnClient(), TProofLite::SetQueryRunning(), ShowEnabledPackages(), UnloadPackageOnClient(), UnloadPackages(), and ~TProof().
TList* TProof::fInputData [private] |
Definition at line 535 of file TProof.h.
Referenced by AddInputData(), ClearInputData(), Init(), TProofLite::Init(), InitMembers(), PrepareInputDataFile(), and ~TProof().
TString TProof::fInputDataFile [private] |
Definition at line 536 of file TProof.h.
Referenced by ClearInputData(), PrepareInputDataFile(), and SetInputDataFile().
PrintProgress_t TProof::fPrintProgress [private] |
Definition at line 538 of file TProof.h.
Referenced by Init(), InitMembers(), PrintProgress(), Progress(), and SetPrintProgress().
TVirtualMutex* TProof::fCloseMutex [private] |
TList* TProof::fLoadedMacros [private] |
Definition at line 542 of file TProof.h.
Referenced by AddWorkers(), GetLoadedMacros(), Init(), TProofLite::Init(), InitMembers(), Load(), and ~TProof().
TList * TProof::fgProofEnvList [static, private] |
Definition at line 543 of file TProof.h.
Referenced by AddEnvVar(), DelEnvVar(), GetEnvVars(), ParseConfigField(), ResetEnvVars(), and TProofLite::SetProofServEnv().
Bool_t TProof::fMergersSet [private] |
Definition at line 546 of file TProof.h.
Referenced by HandleInputMessage(), HandleSubmerger(), InitMembers(), MarkBad(), and ResetMergers().
Int_t TProof::fMergersCount [private] |
Definition at line 547 of file TProof.h.
Referenced by CreateMerger(), HandleSubmerger(), InitMembers(), and MarkBad().
Int_t TProof::fWorkersToMerge [private] |
Definition at line 548 of file TProof.h.
Referenced by CreateMerger(), HandleSubmerger(), and InitMembers().
Int_t TProof::fLastAssignedMerger [private] |
Definition at line 549 of file TProof.h.
Referenced by FindNextFreeMerger(), HandleSubmerger(), and InitMembers().
TList* TProof::fMergers [private] |
Definition at line 550 of file TProof.h.
Referenced by CreateMerger(), FindNextFreeMerger(), GetActiveMergersCount(), HandleSubmerger(), InitMembers(), and RedirectWorker().
Bool_t TProof::fFinalizationRunning [private] |
Definition at line 551 of file TProof.h.
Referenced by FinalizationDone(), HandleInputMessage(), HandleSubmerger(), and InitMembers().
Int_t TProof::fRedirectNext [private] |
TPluginHandler * TProof::fgLogViewer [static, private] |
Bool_t TProof::fMasterServ [protected] |
Definition at line 559 of file TProof.h.
Referenced by Init(), InitMembers(), IsMaster(), and TProof().
TUrl TProof::fUrl [protected] |
Definition at line 560 of file TProof.h.
Referenced by AddWorkers(), GetPort(), GetUrl(), GetUser(), TXSlave::Init(), Init(), TSlave::Init(), MarkBad(), TProofSuperMaster::StartSlaves(), StartSlaves(), and TProof().
TString TProof::fConfFile [protected] |
Definition at line 561 of file TProof.h.
Referenced by GetConfFile(), TXSlave::Init(), Init(), TProofLite::Init(), TProofPEAC::StartSlaves(), StartSlaves(), and TProofCondor::StartSlaves().
TString TProof::fConfDir [protected] |
Definition at line 562 of file TProof.h.
Referenced by GetConfDir(), Init(), TProofLite::Init(), and TProofCondor::StartSlaves().
TString TProof::fImage [protected] |
Definition at line 563 of file TProof.h.
Referenced by AddWorkers(), FindUniqueSlaves(), GetImage(), Init(), TProofLite::Init(), TProofLite::SetProofServEnv(), TProofLite::SetupWorkers(), TProofSuperMaster::StartSlaves(), TProofPEAC::StartSlaves(), and TProofCondor::StartSlaves().
Int_t TProof::fProtocol [protected] |
Definition at line 564 of file TProof.h.
Referenced by ClearDataSetCache(), DrawSelect(), EnablePackage(), ExistsDataSet(), TProofPlayerRemote::Finalize(), GetDataSet(), GetDataSets(), GetRemoteProtocol(), GetStatistics(), GetTreeHeader(), HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), TProofPlayerRemote::Process(), Process(), RegisterDataSet(), SetDataSetTreeName(), TXSlave::SetupServ(), TSlave::SetupServ(), ShowDataSetCache(), ShowDataSetQuota(), ShowDataSets(), TProofSuperMaster::StartSlaves(), StartSlaves(), TSlave::StopProcess(), UploadDataSet(), UploadDataSetFromFile(), UploadPackage(), and VerifyDataSet().
TList* TProof::fSlaves [protected] |
Definition at line 565 of file TProof.h.
Referenced by ActivateAsyncInput(), AddWorkers(), Broadcast(), BroadcastFile(), BroadcastGroupPriority(), BroadcastRaw(), Close(), DeActivateAsyncInput(), FindSlave(), GetListOfSlaves(), GetNumberOfSlaves(), GoParallel(), Init(), TProofLite::Init(), InitMembers(), Interrupt(), MarkBad(), Ping(), TProofLite::Print(), Print(), RemoveWorkers(), SaveWorkerInfo(), TProofLite::SetupWorkers(), TProofSuperMaster::StartSlaves(), TProofPEAC::StartSlaves(), StartSlaves(), TProofCondor::StartSlaves(), StopProcess(), TerminateWorker(), Touch(), and ~TProof().
TList* TProof::fBadSlaves [protected] |
Definition at line 566 of file TProof.h.
Referenced by AddWorkers(), Close(), GetListOfBadSlaves(), GetNumberOfBadSlaves(), GoParallel(), Init(), TProofLite::Init(), InitMembers(), MarkBad(), SaveWorkerInfo(), TProofLite::SetupWorkers(), TProofSuperMaster::StartSlaves(), TProofPEAC::StartSlaves(), TProofCondor::StartSlaves(), and ~TProof().
TMonitor* TProof::fAllMonitor [protected] |
Definition at line 567 of file TProof.h.
Referenced by Activate(), AddWorkers(), Collect(), Init(), TProofLite::Init(), InitMembers(), MarkBad(), ReleaseMonitor(), TProofLite::SetupWorkers(), TProofSuperMaster::StartSlaves(), TProofPEAC::StartSlaves(), StartSlaves(), TProofCondor::StartSlaves(), and ~TProof().
Bool_t TProof::fDataReady [protected] |
Definition at line 568 of file TProof.h.
Referenced by HandleInputMessage(), InitMembers(), and IsDataReady().
Long64_t TProof::fBytesReady [protected] |
Definition at line 569 of file TProof.h.
Referenced by HandleInputMessage(), InitMembers(), and IsDataReady().
Long64_t TProof::fTotalBytes [protected] |
Definition at line 570 of file TProof.h.
Referenced by HandleInputMessage(), InitMembers(), and IsDataReady().
TList* TProof::fAvailablePackages [protected] |
Definition at line 571 of file TProof.h.
Referenced by GetListOfPackages(), HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), and ~TProof().
TList* TProof::fEnabledPackages [protected] |
Definition at line 572 of file TProof.h.
Referenced by GetListOfEnabledPackages(), HandleInputMessage(), Init(), TProofLite::Init(), InitMembers(), and ~TProof().
TList* TProof::fRunningDSets [protected] |
Definition at line 573 of file TProof.h.
Referenced by Init(), InitMembers(), TProofLite::Process(), Process(), and ~TProof().
Int_t TProof::fCollectTimeout [protected] |
Definition at line 575 of file TProof.h.
Referenced by AddDynamicPath(), AddIncludePath(), Archive(), AskParallel(), AskStatistics(), CheckFile(), CleanupSession(), ClearDataSetCache(), ExistsDataSet(), GetDataSet(), GetDataSetQuota(), GetDataSets(), GetListOfEnabledPackages(), GetListOfPackages(), GetListOfQueries(), GetLog(), GetMaxQueries(), GetTreeHeader(), GoParallel(), Init(), TProofLite::Init(), InitMembers(), ModifyWorkerLists(), Print(), Remove(), RemoveDataSet(), RemoveDynamicPath(), RemoveIncludePath(), Retrieve(), SendFile(), SendPrint(), SetParallelSilent(), ShowCache(), ShowDataSetCache(), ShowDataSets(), ShowEnabledPackages(), ShowPackages(), UploadDataSet(), UploadPackage(), and VerifyDataSet().
TString TProof::fDataPoolUrl [protected] |
Definition at line 577 of file TProof.h.
Referenced by GetDataPoolUrl(), Init(), and SetDataPoolUrl().
TProofMgr::EServType TProof::fServType [protected] |
Definition at line 578 of file TProof.h.
Referenced by TXSlave::Init(), IsLite(), IsProofd(), and TProof().
TProofMgr* TProof::fManager [protected] |
Definition at line 579 of file TProof.h.
Referenced by ClearData(), DisablePackage(), DownloadPackage(), GetManager(), InitMembers(), MarkBad(), SetManager(), ShowData(), TProof(), and ~TProof().
EQueryMode TProof::fQueryMode [protected] |
Definition at line 580 of file TProof.h.
Referenced by GetQueryMode(), InitMembers(), SetQueryMode(), and TProof().
Bool_t TProof::fDynamicStartup [protected] |
Definition at line 581 of file TProof.h.
Referenced by AddWorkers(), Init(), InitMembers(), and UseDynamicStartup().
TSemaphore* TProof::fgSemaphore [static, protected] |
TList* TProof::fRecvMessages [private] |
TList* TProof::fSlaveInfo [private] |
TList* TProof::fActiveSlaves [private] |
TList* TProof::fInactiveSlaves [private] |
TList* TProof::fUniqueSlaves [private] |
TList* TProof::fAllUniqueSlaves [private] |
TList* TProof::fNonUniqueMasters [private] |
TMonitor* TProof::fActiveMonitor [private] |
TMonitor* TProof::fUniqueMonitor [private] |
TMonitor* TProof::fAllUniqueMonitor [private] |
TMonitor* TProof::fCurrentMonitor [private] |
TSignalHandler* TProof::fIntHandler [private] |
TPluginHandler* TProof::fProgressDialog [private] |
TVirtualProofPlayer* TProof::fPlayer [private] |
TList* TProof::fFeedback [private] |
TList* TProof::fChains [private] |
TDSet* TProof::fDSet [private] |
FILE* TProof::fLogFileW [private] |
FILE* TProof::fLogFileR [private] |
TList* TProof::fWaitingSlaves [private] |
TList* TProof::fQueries [private] |
THashList* TProof::fGlobalPackageDirList [private] |
TProofLockPath* TProof::fPackageLock [private] |
TList* TProof::fEnabledPackagesOnClient [private] |
TList* TProof::fInputData [private] |
TVirtualMutex* TProof::fCloseMutex [private] |
TList* TProof::fLoadedMacros [private] |
TList* TProof::fgProofEnvList [static, private] |
TList* TProof::fMergers [private] |
TPluginHandler* TProof::fgLogViewer [static, private] |
TList* TProof::fSlaves [protected] |
TList* TProof::fBadSlaves [protected] |
TMonitor* TProof::fAllMonitor [protected] |
TList* TProof::fAvailablePackages [protected] |
TList* TProof::fEnabledPackages [protected] |
TList* TProof::fRunningDSets [protected] |
TProofMgr* TProof::fManager [protected] |
TSemaphore* TProof::fgSemaphore [static, protected] |
1.5.1