class TProofCondor: public TProof


TProof

This class controls a Parallel ROOT Facility, PROOF, cluster.
It fires the slave servers, it keeps track of how many slaves are
running, it keeps track of the slaves running status, it broadcasts
messages to all slaves, it collects results, etc.


Function Members (Methods)

public:
TProofCondor(const char* masterurl, const char* conffile = kPROOF_ConfFile, const char* confdir = kPROOF_ConfDir, Int_t loglevel = 0)
virtual~TProofCondor()
voidTObject::AbstractMethod(const char* method) const
voidTProof::ActivateWorker(const char* ord)
voidTProof::AddChain(TChain* chain)
Int_tTProof::AddDynamicPath(const char* libpath)
static voidTProof::AddEnvVar(const char* name, const char* value)
voidTProof::AddFeedback(const char* name)
Int_tTProof::AddIncludePath(const char* incpath)
voidTProof::AddInput(TObject* obj)
virtual voidTObject::AppendPad(Option_t* option = "")
Int_tTProof::Archive(Int_t query, const char* url)
Int_tTProof::Archive(const char* queryref, const char* url = 0)
virtual voidTProof::Browse(TBrowser* b)
voidTProof::cd(Int_t id = -1)
virtual voidTQObject::ChangedBy(const char* method)
static TClass*Class()
virtual const char*TObject::ClassName() const
Int_tTProof::CleanupSession(const char* sessiontag)
virtual voidTNamed::Clear(Option_t* option = "")
voidTProof::ClearCache()
voidTProof::ClearFeedback()
voidTProof::ClearInput()
Int_tTProof::ClearPackage(const char* package)
Int_tTProof::ClearPackages()
virtual TObject*TNamed::Clone(const char* newname = "") const
voidTProof::Close(Option_t* option = "")
voidTProof::CloseProgressDialog()
virtual Int_tTNamed::Compare(const TObject* obj) const
Bool_tTQObject::Connect(const char* signal, const char* receiver_class, void* receiver, const char* slot)
static Bool_tTQObject::Connect(TQObject* sender, const char* signal, const char* receiver_class, void* receiver, const char* slot)
static Bool_tTQObject::Connect(const char* sender_class, const char* signal, const char* receiver_class, void* receiver, const char* slot)
virtual voidTQObject::Connected(const char*)
virtual voidTNamed::Copy(TObject& named) const
Int_tTProof::CreateDataSet(const char* dataset, TList* files, Int_t opt = kAskUser)
TDrawFeedback*TProof::CreateDrawFeedback()
voidTProof::DataSetStatus(const char* msg, Bool_t status, Int_t done, Int_t total)
voidTProof::DeactivateWorker(const char* ord)
static voidTProof::DelEnvVar(const char* name)
virtual voidTObject::Delete(Option_t* option = "")
voidTProof::DeleteDrawFeedback(TDrawFeedback* f)
voidTProof::DeleteParameters(const char* wildcard)
virtual voidTQObject::Destroyed()
voidTProof::Detach(Option_t* opt = "")
Bool_tTQObject::Disconnect(const char* signal = 0, void* receiver = 0, const char* slot = 0)
static Bool_tTQObject::Disconnect(TQObject* sender, const char* signal = 0, void* receiver = 0, const char* slot = 0)
static Bool_tTQObject::Disconnect(const char* class_name, const char* signal, void* receiver = 0, const char* slot = 0)
virtual voidTQObject::Disconnected(const char*)
virtual Int_tTObject::DistancetoPrimitive(Int_t px, Int_t py)
virtual voidTObject::Draw(Option_t* option = "")
virtual voidTObject::DrawClass() const
virtual TObject*TObject::DrawClone(Option_t* option = "") const
Long64_tTProof::DrawSelect(TDSet* dset, const char* varexp, const char* selection = "", Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0)
Long64_tTProof::DrawSelect(const char* dsetname, const char* varexp, const char* selection = "", Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0, TObject* enl = 0)
virtual voidTObject::Dump() const
voidTQObject::Emit(const char* signal)
voidTQObject::Emit(const char* signal, Long_t* paramArr)
voidTQObject::Emit(const char* signal, const char* params)
voidTQObject::Emit(const char* signal, Double_t param)
voidTQObject::Emit(const char* signal, Long_t param)
voidTQObject::Emit(const char* signal, Long64_t param)
voidTQObject::Emit(const char* signal, Bool_t param)
voidTQObject::Emit(const char* signal, Char_t param)
voidTQObject::Emit(const char* signal, UChar_t param)
voidTQObject::Emit(const char* signal, Short_t param)
voidTQObject::Emit(const char* signal, UShort_t param)
voidTQObject::Emit(const char* signal, Int_t param)
voidTQObject::Emit(const char* signal, UInt_t param)
voidTQObject::Emit(const char* signal, ULong_t param)
voidTQObject::Emit(const char* signal, ULong64_t param)
voidTQObject::Emit(const char* signal, Float_t param)
voidTQObject::EmitVA(const char* signal, Int_t nargs)
voidTQObject::EmitVA(const char* signal, Int_t nargs, va_list va)
Int_tTProof::EnablePackage(const char* package, Bool_t notOnClient = kFALSE)
virtual voidTObject::Error(const char* method, const char* msgfmt) const
Int_tTProof::Exec(const char* cmd, Bool_t plusMaster = kFALSE)
virtual voidTObject::Execute(const char* method, const char* params, Int_t* error = 0)
virtual voidTObject::Execute(TMethod* method, TObjArray* params, Int_t* error = 0)
virtual voidTObject::ExecuteEvent(Int_t event, Int_t px, Int_t py)
virtual voidTObject::Fatal(const char* method, const char* msgfmt) const
voidTProof::Feedback(TList* objs)
virtual voidTNamed::FillBuffer(char*& buffer)
Long64_tTProof::Finalize(Int_t query = -1, Bool_t force = kFALSE)
Long64_tTProof::Finalize(const char* queryref, Bool_t force = kFALSE)
virtual TObject*TObject::FindObject(const char* name) const
virtual TObject*TObject::FindObject(const TObject* obj) const
Long64_tTProof::GetBytesRead() const
Int_tTProof::GetClientProtocol() const
const char*TProof::GetConfDir() const
const char*TProof::GetConfFile() const
Float_tTProof::GetCpuTime() const
const char*TProof::GetDataPoolUrl() const
TList*TProof::GetDataSet(const char* dataset)
TList*TProof::GetDataSets(const char* dir = 0)
virtual Option_t*TObject::GetDrawOption() const
static Long_tTObject::GetDtorOnly()
static const TList*TProof::GetEnvVars()
TList*TProof::GetFeedbackList() const
virtual const char*TObject::GetIconName() const
const char*TProof::GetImage() const
TList*TProof::GetInputList()
TList*TQObject::GetListOfClassSignals() const
TList*TQObject::GetListOfConnections() const
TList*TProof::GetListOfEnabledPackages()
TList*TProof::GetListOfPackages()
TList*TProof::GetListOfQueries(Option_t* opt = "")
TList*TQObject::GetListOfSignals() const
TList*TProof::GetListOfSlaveInfos()
voidTProof::GetLog(Int_t start = -1, Int_t end = -1)
Int_tTProof::GetLogLevel() const
TProofMgr*TProof::GetManager()
const char*TProof::GetMaster() const
voidTProof::GetMaxQueries()
virtual const char*TNamed::GetName() const
Int_tTProof::GetNumberOfDrawQueries()
Int_tTProof::GetNumberOfQueries()
virtual char*TObject::GetObjectInfo(Int_t px, Int_t py) const
static Bool_tTObject::GetObjectStat()
virtual Option_t*TObject::GetOption() const
TObject*TProof::GetOutput(const char* name)
TList*TProof::GetOutputList()
TList*TProof::GetOutputNames()
Int_tTProof::GetParallel() const
TObject*TProof::GetParameter(const char* par) const
static Int_tTProof::GetParameter(TCollection* c, const char* par, TString& value)
static Int_tTProof::GetParameter(TCollection* c, const char* par, Int_t& value)
static Int_tTProof::GetParameter(TCollection* c, const char* par, Long_t& value)
static Int_tTProof::GetParameter(TCollection* c, const char* par, Long64_t& value)
static Int_tTProof::GetParameter(TCollection* c, const char* par, Double_t& value)
Int_tTProof::GetPort() const
TProof::EQueryModeTProof::GetQueryMode(Option_t* mode = 0) const
TQueryResult*TProof::GetQueryResult(const char* ref = 0)
TList*TProof::GetQueryResults()
Float_tTProof::GetRealTime() const
Int_tTProof::GetRemoteProtocol() const
TProof::ERunStatusTProof::GetRunStatus() const
Int_tTProof::GetSessionID() const
const char*TProof::GetSessionTag() const
Int_tTProof::GetStatus() const
virtual const char*TNamed::GetTitle() const
TTree*TProof::GetTreeHeader(TDSet* tdset)
virtual UInt_tTObject::GetUniqueID() const
const char*TProof::GetUrl()
const char*TProof::GetUser() const
const char*TProof::GetWorkDir() const
virtual Bool_tTObject::HandleTimer(TTimer* timer)
virtual Bool_tTQObject::HasConnection(const char* signal_name) const
virtual ULong_tTNamed::Hash() const
virtual voidTQObject::HighPriority(const char* signal_name, const char* slot_name = 0)
virtual voidTObject::Info(const char* method, const char* msgfmt) const
virtual Bool_tTObject::InheritsFrom(const char* classname) const
virtual Bool_tTObject::InheritsFrom(const TClass* cl) const
virtual voidTObject::Inspect() const
voidTObject::InvertBit(UInt_t f)
virtual TClass*IsA() const
Bool_tTProof::IsDataReady(Long64_t& totalbytes, Long64_t& bytesready)
virtual Bool_tTObject::IsEqual(const TObject* obj) const
virtual Bool_tTProof::IsFolder() const
Bool_tTProof::IsIdle() const
Bool_tTProof::IsMaster() const
Bool_tTObject::IsOnHeap() const
Bool_tTProof::IsParallel() const
Bool_tTProof::IsProofd() const
virtual Bool_tTNamed::IsSortable() const
Bool_tTProof::IsValid() const
Bool_tTObject::IsZombie() const
Int_tTProof::Load(const char* macro, Bool_t notOnClient = kFALSE)
static voidTQObject::LoadRQ_OBJECT()
voidTProof::LogMessage(const char* msg, Bool_t all)
virtual voidTQObject::LowPriority(const char* signal_name, const char* slot_name = 0)
virtual voidTNamed::ls(Option_t* option = "") const
voidTObject::MayNotUse(const char* method) const
virtual voidTQObject::Message(const char* msg)
static TProofMgr*TProof::Mgr(const char* url)
virtual Bool_tTObject::Notify()
virtual Int_tTQObject::NumberOfConnections() const
virtual Int_tTQObject::NumberOfSignals() const
static TProof*TProof::Open(const char* url = 0, const char* conffile = 0, const char* confdir = 0, Int_t loglevel = 0)
static voidTObject::operator delete(void* ptr)
static voidTObject::operator delete(void* ptr, void* vp)
static voidTObject::operator delete[](void* ptr)
static voidTObject::operator delete[](void* ptr, void* vp)
void*TObject::operator new(size_t sz)
void*TObject::operator new(size_t sz, void* vp)
void*TObject::operator new[](size_t sz)
void*TObject::operator new[](size_t sz, void* vp)
TNamed&TNamed::operator=(const TNamed& rhs)
virtual voidTObject::Paint(Option_t* option = "")
Int_tTProof::Ping()
virtual voidTObject::Pop()
virtual voidTProof::Print(Option_t* option = "") const
Long64_tTProof::Process(const char* selector, Long64_t nentries, Option_t* option = "")
Long64_tTProof::Process(TDSet* dset, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0)
Long64_tTProof::Process(const char* dsetname, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0, TObject* enl = 0)
voidTProof::Progress(Long64_t total, Long64_t processed)
voidTProof::Progress(Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)
voidTProof::PutLog(TQueryResult* qr)
voidTProof::QueryResultReady(const char* ref)
virtual Int_tTObject::Read(const char* name)
virtual voidTObject::RecursiveRemove(TObject* obj)
Int_tTProof::Remove(Int_t query, Bool_t all = kFALSE)
Int_tTProof::Remove(const char* queryref, Bool_t all = kFALSE)
voidTProof::RemoveChain(TChain* chain)
Int_tTProof::RemoveDataSet(const char* dateset)
Int_tTProof::RemoveDynamicPath(const char* libpath)
voidTProof::RemoveFeedback(const char* name)
Int_tTProof::RemoveIncludePath(const char* incpath)
static voidTProof::Reset(const char* url)
voidTObject::ResetBit(UInt_t f)
static voidTProof::ResetEnvVars()
voidTProof::ResetProgressDialog(const char* sel, Int_t sz, Long64_t fst, Long64_t ent)
voidTProof::ResetProgressDialogStatus()
Int_tTProof::Retrieve(Int_t query, const char* path = 0)
Int_tTProof::Retrieve(const char* queryref, const char* path = 0)
virtual voidTObject::SaveAs(const char* filename = "", Option_t* option = "") const
virtual voidTObject::SavePrimitive(basic_ostream<char,char_traits<char> >& out, Option_t* option = "")
voidTProof::SendDataSetStatus(const char* msg, UInt_t n, UInt_t tot, Bool_t st)
Bool_tTProof::SendingLogToWindow() const
voidTProof::SendLogToWindow(Bool_t mode)
virtual voidSetActive()
virtual voidSetActive(Bool_t active)
virtual voidTProof::SetAlias(const char* alias = "")
voidTObject::SetBit(UInt_t f)
voidTObject::SetBit(UInt_t f, Bool_t set)
voidTProof::SetDataPoolUrl(const char* url)
voidTProof::SetDrawFeedbackOption(TDrawFeedback* f, Option_t* opt)
virtual voidTObject::SetDrawOption(Option_t* option = "")
static voidTObject::SetDtorOnly(void* obj)
voidTProof::SetLogLevel(Int_t level, UInt_t mask = TProofDebug::kAll)
voidTProof::SetManager(TProofMgr* mgr)
voidTProof::SetMaxDrawQueries(Int_t max)
virtual voidTNamed::SetName(const char* name)
virtual voidTNamed::SetNameTitle(const char* name, const char* title)
static voidTObject::SetObjectStat(Bool_t stat)
Int_tTProof::SetParallel(Int_t nodes = 9999, Bool_t random = kFALSE)
voidTProof::SetParameter(const char* par, const char* value)
voidTProof::SetParameter(const char* par, Int_t value)
voidTProof::SetParameter(const char* par, Long_t value)
voidTProof::SetParameter(const char* par, Long64_t value)
voidTProof::SetParameter(const char* par, Double_t value)
voidTProof::SetQueryMode(TProof::EQueryMode mode)
voidTProof::SetRealTimeLog(Bool_t on = kTRUE)
virtual voidTNamed::SetTitle(const char* title = "")
virtual voidTObject::SetUniqueID(UInt_t uid)
voidTProof::ShowCache(Bool_t all = kFALSE)
voidTProof::ShowDataSet(const char* dataset)
voidTProof::ShowDataSets(const char* dir = 0)
voidTProof::ShowEnabledPackages(Bool_t all = kFALSE)
voidTProof::ShowFeedback() const
voidTProof::ShowLog(Int_t qry = -1)
voidTProof::ShowLog(const char* queryref)
virtual voidShowMembers(TMemberInspector& insp, char* parent)
voidTProof::ShowPackages(Bool_t all = kFALSE)
voidTProof::ShowParameters(const char* wildcard = "PROOF_*") const
voidTProof::ShowQueries(Option_t* opt = "")
virtual Int_tTNamed::Sizeof() const
voidTProof::StartupMessage(const char* msg, Bool_t status, Int_t done, Int_t total)
voidTProof::StopProcess(Bool_t abort, Int_t timeout = -1)
virtual voidStreamer(TBuffer& b)
voidStreamerNVirtual(TBuffer& b)
virtual voidTObject::SysError(const char* method, const char* msgfmt) const
Bool_tTObject::TestBit(UInt_t f) const
Int_tTObject::TestBits(UInt_t f) const
Int_tTProof::UploadDataSet(const char* dataset, TList* files, const char* dest = 0, Int_t opt = kAskUser, TList* skippedFiles = 0)
Int_tTProof::UploadDataSet(const char* dataset, const char* files, const char* dest = 0, Int_t opt = kAskUser, TList* skippedFiles = 0)
Int_tTProof::UploadDataSetFromFile(const char* dataset, const char* file, const char* dest = 0, Int_t opt = kAskUser)
Int_tTProof::UploadPackage(const char* par, TProof::EUploadPackageOpt opt = kUntar)
virtual voidTObject::UseCurrentStyle()
Int_tTProof::VerifyDataSet(const char* dataset)
virtual voidTObject::Warning(const char* method, const char* msgfmt) const
virtual Int_tTObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0)
virtual Int_tTObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0) const
protected:
static Int_tTQObject::CheckConnectArgs(TQObject* sender, TClass* sender_class, const char* signal, TClass* receiver_class, const char* slot)
Int_tTProof::Collect(TProof::ESlaves list = kActive, Long_t timeout = -1)
Int_tTProof::Collect(TList* slaves, Long_t timeout = -1)
static Bool_tTQObject::ConnectToClass(TQObject* sender, const char* signal, TClass* receiver_class, void* receiver, const char* slot)
static Bool_tTQObject::ConnectToClass(const char* sender_class, const char* signal, TClass* receiver_class, void* receiver, const char* slot)
TSlave*TProof::CreateSlave(const char* url, const char* ord, Int_t perf, const char* image, const char* workdir)
TSlave*TProof::CreateSubmaster(const char* url, const char* ord, const char* image, const char* msd)
virtual voidTObject::DoError(int level, const char* location, const char* fmt, va_list va) const
TStringGetJobAd()
TList*TProof::GetListOfActiveSlaves() const
TVirtualProofPlayer*TProof::GetPlayer() const
TPluginHandler*TProof::GetProgressDialog() const
virtual void*TQObject::GetSender()
virtual const char*TQObject::GetSenderClassName() const
Int_tTProof::Init(const char* masterurl, const char* conffile, const char* confdir, Int_t loglevel, const char* alias = 0)
virtual TVirtualProofPlayer*TProof::MakePlayer(const char* player = 0, TSocket* s = 0)
voidTObject::MakeZombie()
virtual voidTProof::SaveWorkerInfo()
voidTProof::SetDSet(TDSet* dset)
voidTProof::SetPlayer(TVirtualProofPlayer* player)
static void*TProof::SlaveStartupThread(void* arg)
virtual Bool_tStartSlaves(Bool_t parallel, Bool_t)
virtual voidTProof::ValidateDSet(TDSet* dset)

Data Members

public:
enum TProof::EStatusBits { kUsingSessionGui
};
enum TProof::EQueryMode { kSync
kAsync
};
enum TProof::EUploadOpt { kAppend
kOverwriteDataSet
kNoOverwriteDataSet
kOverwriteAllFiles
kOverwriteNoFiles
kAskUser
};
enum TProof::EUploadDataSetAnswer { kError
kDataSetExists
};
enum TProof::EUploadPackageOpt { kUntar
kRemoveOld
};
enum TProof::ERunStatus { kRunning
kStopped
kAborted
};
enum TProof::EUrgent { kLocalInterrupt
kPing
kHardInterrupt
kSoftInterrupt
kShutdownInterrupt
};
enum TProof::EProofCacheCommands { kShowCache
kClearCache
kShowPackages
kClearPackages
kClearPackage
kBuildPackage
kLoadPackage
kShowEnabledPackages
kShowSubCache
kClearSubCache
kShowSubPackages
kDisableSubPackages
kDisableSubPackage
kBuildSubPackage
kUnloadPackage
kDisablePackage
kUnloadPackages
kDisablePackages
kListPackages
kListEnabledPackages
kLoadMacro
};
enum TProof::EProofDataSetCommands { kUploadDataSet
kCheckDataSetName
kGetDataSets
kCreateDataSet
kGetDataSet
kVerifyDataSet
kRemoveDataSet
kAppendDataSet
};
enum TProof::ESendFileOpt { kAscii
kBinary
kForce
kForward
};
enum TProof::EProofWrkListAction { kActivateWorker
kDeactivateWorker
};
enum TProof::EBuildPackageOpt { kDontBuildOnClient
kBuildOnSlavesNoWait
kBuildAll
kCollectBuildResults
};
enum TProof::ESlaves { kAll
kActive
kUnique
kAllUnique
};
enum TObject::EStatusBits { kCanDelete
kMustCleanup
kObjInCanvas
kIsReferenced
kHasUUID
kCannotPick
kNoContextMenu
kInvalidObject
};
enum TObject::[unnamed] { kIsOnHeap
kNotDeleted
kZombie
kBitMask
kSingleKey
kOverwrite
kWriteDelete
};
protected:
TMonitor*TProof::fAllMonitormonitor activity on all valid slave sockets
TList*TProof::fAvailablePackageslist of available packages
TList*TProof::fBadSlavesdead slaves (subset of all slaves)
Long64_tTProof::fBytesReadynumber of bytes staged
Int_tTProof::fCollectTimeoutTimeout for (some) collect actions
TStringTProof::fConfDirdirectory containing cluster config information
TStringTProof::fConfFilefile containing config information
TStringTProof::fDataPoolUrldefault data pool entry point URL
Bool_tTProof::fDataReadytrue if data is ready to be analyzed
TList*TProof::fEnabledPackageslist of enabled packages
TStringTProof::fImagemaster's image name
TList*TQObject::fListOfConnections! list of connections to this object
TList*TQObject::fListOfSignals! list of signals from this object
TProofMgr*TProof::fManagermanager to which this session belongs (if any)
TStringTNamed::fNameobject identifier
Int_tTProof::fProtocolremote PROOF server protocol version number
TProof::EQueryModeTProof::fQueryModedefault query mode
TProofMgr::EServTypeTProof::fServTypetype of server: proofd, XrdProofd
TList*TProof::fSlaveslist of all slave servers as in config file
TStringTNamed::fTitleobject title
Long64_tTProof::fTotalBytesnumber of bytes to be analyzed
TUrlTProof::fUrlUrl of the master
static TSemaphore*TProof::fgSemaphoresemaphore to control no of parallel startup threads
private:
TCondor*fCondorproxy for our Condor pool
TTimer*fTimertimer for delayed Condor COD suspend

Class Charts

Inheritance Inherited Members Includes Libraries
Class Charts

Function documentation

TProofCondor(const char* masterurl, const char* conffile = kPROOF_ConfFile, const char* confdir = kPROOF_ConfDir, Int_t loglevel = 0)
 Start proof using condor
~TProofCondor()
 Clean up Condor PROOF environment.
Bool_t StartSlaves(Bool_t parallel, Bool_t )
 non static config
void SetActive(Bool_t active)
 Suspend or resume PROOF via Condor.
TString GetJobAd()
 Get job Ad
void SetActive(Bool_t active)
{ TProof::SetActive(); }

Author: Fons Rademakers 13/02/97
Last update: root/proof:$Id: TProofCondor.h 20882 2007-11-19 11:31:26Z rdm $
Copyright (C) 1995-2000, Rene Brun and Fons Rademakers. *

This page has been automatically generated. If you have any comments or suggestions about the page layout send a mail to ROOT support, or contact the developers with any questions or problems regarding ROOT.