library: libProof
#include "TProofSuperMaster.h"

TProofSuperMaster

class description - header file - source file
viewCVS header - viewCVS source

class TProofSuperMaster: public TProof

Inheritance Inherited Members Includes Libraries
Class Charts

Function Members (Methods)

Display options:
Show inherited
Show non-public
public:
TProofSuperMaster(const char* masterurl, const char* conffile = "kPROOF_ConfFile", const char* confdir = "kPROOF_ConfDir", Int_t loglevel = 0)
virtual~TProofSuperMaster()
voidTObject::AbstractMethod(const char* method) const
virtual voidTProof::ActivateWorker(const char* ord)
virtual voidTProof::AddChain(TChain* chain)
virtual Int_tTProof::AddDynamicPath(const char* libpath)
static voidTVirtualProof::AddEnvVar(const char* name, const char* value)
virtual voidTProof::AddFeedback(const char* name)
virtual Int_tTProof::AddIncludePath(const char* incpath)
virtual voidTProof::AddInput(TObject* obj)
virtual voidTObject::AppendPad(Option_t* option = "")
virtual Int_tTProof::Archive(Int_t query, const char* url)
virtual Int_tTProof::Archive(const char* queryref, const char* url = "0")
virtual voidTProof::Browse(TBrowser* b)
virtual voidTProof::cd(Int_t id = -1)
virtual voidTQObject::ChangedBy(const char* method)
static TClass*Class()
virtual const char*TObject::ClassName() const
virtual Int_tTProof::CleanupSession(const char* sessiontag)
virtual voidTNamed::Clear(Option_t* option = "")
virtual voidTProof::ClearCache()
virtual voidTProof::ClearFeedback()
virtual voidTProof::ClearInput()
virtual Int_tTProof::ClearPackage(const char* package)
virtual Int_tTProof::ClearPackages()
virtual TObject*TNamed::Clone(const char* newname = "") const
virtual voidTProof::Close(Option_t* option = "")
virtual 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
virtual Int_tTProof::CreateDataSet(const char* dataset, TList* files, Int_t opt = kAskUser)
virtual TDrawFeedback*TProof::CreateDrawFeedback()
virtual voidTProof::DataSetStatus(const char* msg, Bool_t status, Int_t done, Int_t total)
virtual voidTProof::DeactivateWorker(const char* ord)
static voidTVirtualProof::DelEnvVar(const char* name)
virtual voidTObject::Delete(Option_t* option = "")
virtual voidTProof::DeleteDrawFeedback(TDrawFeedback* f)
virtual voidTQObject::Destroyed()
virtual 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
virtual Long64_tTProof::DrawSelect(TDSet* set, const char* varexp, const char* selection = "", Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 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)
virtual Int_tTProof::EnablePackage(const char* package)
virtual voidTObject::Error(const char* method, const char* msgfmt) const
virtual 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
virtual voidTProof::Feedback(TList* objs)
virtual voidTNamed::FillBuffer(char*& buffer)
virtual Int_tTProof::Finalize(Int_t query = -1, Bool_t force = kFALSE)
virtual Int_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
virtual Long64_tTProof::GetBytesRead() const
virtual Int_tTProof::GetClientProtocol() const
virtual const char*TProof::GetConfDir() const
virtual const char*TProof::GetConfFile() const
virtual Float_tTProof::GetCpuTime() const
virtual const char*TVirtualProof::GetDataPoolUrl() const
virtual TList*TProof::GetDataSet(const char* dataset)
virtual TList*TProof::GetDataSets(const char* dir = "0")
virtual Option_t*TObject::GetDrawOption() const
static Long_tTObject::GetDtorOnly()
static const TList*TVirtualProof::GetEnvVars()
virtual TList*TProof::GetFeedbackList() const
virtual const char*TObject::GetIconName() const
virtual const char*TProof::GetImage() const
TList*TQObject::GetListOfClassSignals() const
TList*TQObject::GetListOfConnections() const
virtual TList*TProof::GetListOfEnabledPackages()
virtual TList*TProof::GetListOfPackages()
virtual TList*TProof::GetListOfQueries(Option_t* opt = "")
TList*TQObject::GetListOfSignals() const
virtual voidTProof::GetLog(Int_t start = -1, Int_t end = -1)
virtual Int_tTProof::GetLogLevel() const
virtual TVirtualProofMgr*TVirtualProof::GetManager()
virtual const char*TProof::GetMaster() const
virtual voidTProof::GetMaxQueries()
virtual const char*TNamed::GetName() const
virtual Int_tTProof::GetNumberOfDrawQueries()
virtual Int_tTProof::GetNumberOfQueries()
virtual char*TObject::GetObjectInfo(Int_t px, Int_t py) const
static Bool_tTObject::GetObjectStat()
virtual Option_t*TObject::GetOption() const
virtual TObject*TProof::GetOutput(const char* name)
virtual TList*TProof::GetOutputList()
virtual TList*TProof::GetOutputNames()
virtual Int_tTProof::GetParallel() const
virtual Int_tTProof::GetPort() const
virtual TVirtualProof::EQueryModeTProof::GetQueryMode() const
TVirtualProof::EQueryModeTProof::GetQueryMode(Option_t* mode) const
virtual TQueryResult*TProof::GetQueryResult(const char* ref = "0")
virtual TList*TProof::GetQueryResults()
virtual Float_tTProof::GetRealTime() const
virtual Int_tTProof::GetRemoteProtocol() const
virtual TVirtualProofMgr::EServTypeTVirtualProof::GetServType() const
virtual Int_tTProof::GetSessionID() const
virtual const char*TVirtualProof::GetSessionTag() const
virtual TList*TProof::GetSlaveInfo()
virtual Int_tTProof::GetStatus() const
virtual const char*TNamed::GetTitle() const
static TProof_tTVirtualProof::GetTProofHook()
virtual TTree*TProof::GetTreeHeader(TDSet* tdset)
virtual UInt_tTObject::GetUniqueID() const
virtual const char*TProof::GetUrl()
virtual const char*TProof::GetUser() const
virtual 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
virtual Bool_tTProof::IsDataReady(Long64_t& totalbytes, Long64_t& bytesready)
virtual Bool_tTObject::IsEqual(const TObject* obj) const
virtual Bool_tTProof::IsFolder() const
virtual Bool_tTProof::IsIdle() const
virtual Bool_tTProof::IsMaster() const
Bool_tTObject::IsOnHeap() const
virtual Bool_tTProof::IsParallel() const
virtual Bool_tTVirtualProof::IsProofd() const
virtual Bool_tTNamed::IsSortable() const
virtual Bool_tTProof::IsValid() const
Bool_tTObject::IsZombie() const
static voidTQObject::LoadRQ_OBJECT()
virtual 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)
virtual Bool_tTObject::Notify()
virtual Int_tTQObject::NumberOfConnections() const
virtual Int_tTQObject::NumberOfSignals() const
static TVirtualProof*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 = "")
virtual Int_tTProof::Ping()
virtual voidTObject::Pop()
virtual voidTProof::Print(Option_t* option = "") const
virtual voidTProof::Progress(Long64_t total, Long64_t processed)
virtual voidTProof::Progress(Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)
virtual voidTProof::PutLog(TQueryResult* qr)
virtual voidTProof::QueryResultReady(const char* ref)
virtual Int_tTObject::Read(const char* name)
virtual voidTObject::RecursiveRemove(TObject* obj)
virtual Int_tTProof::Remove(Int_t query, Bool_t all = kFALSE)
virtual Int_tTProof::Remove(const char* queryref, Bool_t all = kFALSE)
virtual voidTProof::RemoveChain(TChain* chain)
virtual Int_tTProof::RemoveDataSet(const char* dateset)
virtual Int_tTProof::RemoveDynamicPath(const char* libpath)
virtual voidTProof::RemoveFeedback(const char* name)
virtual Int_tTProof::RemoveIncludePath(const char* incpath)
static Int_tTProof::Reset(const char* url, const char* usr = "0")
voidTObject::ResetBit(UInt_t f)
static voidTVirtualProof::ResetEnvVars()
virtual voidTProof::ResetProgressDialog(const char* sel, Int_t sz, Long64_t fst, Long64_t ent)
virtual voidTProof::ResetProgressDialogStatus()
virtual Int_tTProof::Retrieve(Int_t query, const char* path = "0")
virtual Int_tTProof::Retrieve(const char* queryref, const char* path = "0")
virtual voidTObject::SaveAs(const char* filename = "", Option_t* option = "") const
virtual voidTObject::SavePrimitive(ostream& out, Option_t* option = "")
virtual voidTProof::SendDataSetStatus(const char* msg, UInt_t n, UInt_t tot, Bool_t st)
virtual Bool_tTProof::SendingLogToWindow() const
virtual voidTProof::SendLogToWindow(Bool_t mode)
virtual voidTProof::SetActive(Bool_t = kTRUE)
virtual voidTProof::SetAlias(const char* alias = "")
voidTObject::SetBit(UInt_t f)
voidTObject::SetBit(UInt_t f, Bool_t set)
virtual voidTVirtualProof::SetDataPoolUrl(const char* url)
virtual voidTProof::SetDrawFeedbackOption(TDrawFeedback* f, Option_t* opt)
virtual voidTObject::SetDrawOption(Option_t* option = "")
static voidTObject::SetDtorOnly(void* obj)
virtual voidTProof::SetLogLevel(Int_t level, UInt_t mask = TProofDebug::kAll)
virtual voidTProof::SetManager(TVirtualProofMgr* mgr)
virtual 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)
virtual Int_tTProof::SetParallel(Int_t nodes = 9999)
voidTProof::SetQueryMode(TVirtualProof::EQueryMode mode)
virtual voidTVirtualProof::SetQueryType(TVirtualProof::EQueryMode mode)
virtual voidTNamed::SetTitle(const char* title = "")
static voidTVirtualProof::SetTProofHook(TProof_t proofhook)
virtual voidTObject::SetUniqueID(UInt_t uid)
virtual voidTProof::ShowCache(Bool_t all = kFALSE)
virtual voidTProof::ShowDataSet(const char* dataset)
virtual voidTProof::ShowDataSets(const char* dir = "0")
virtual voidTProof::ShowEnabledPackages(Bool_t all = kFALSE)
virtual voidTProof::ShowFeedback() const
virtual voidTProof::ShowLog(Int_t qry = -1)
virtual voidTProof::ShowLog(const char* queryref)
virtual voidShowMembers(TMemberInspector& insp, char* parent)
virtual voidTProof::ShowPackages(Bool_t all = kFALSE)
virtual voidTProof::ShowQueries(Option_t* opt = "")
virtual Int_tTNamed::Sizeof() const
virtual voidTProof::StartupMessage(const char* msg, Bool_t status, Int_t done, Int_t total)
virtual 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
virtual Int_tTProof::UploadDataSet(const char* dataset, TList* files, const char* dest = "0", Int_t opt = kAskUser, TList* skippedFiles = 0)
virtual Int_tTProof::UploadDataSet(const char* dataset, const char* files, const char* dest = "0", Int_t opt = kAskUser, TList* skippedFiles = 0)
virtual Int_tTProof::UploadDataSetFromFile(const char* dataset, const char* file, const char* dest = "0", Int_t opt = kAskUser)
virtual Int_tTProof::UploadPackage(const char* par, TVirtualProof::EUploadPackageOpt opt = kUntar)
virtual voidTObject::UseCurrentStyle()
virtual 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
TList*TProof::GetListOfActiveSlaves() const
TProofPlayer*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 TProofPlayer*MakePlayer()
voidTObject::MakeZombie()
virtual Long64_tProcess(TDSet* set, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0, TEventList* evl = 0)
voidTProof::SetDSet(TDSet* dset)
voidTProof::SetPlayer(TProofPlayer* player)
static void*TProof::SlaveStartupThread(void* arg)
virtual Bool_tStartSlaves(Bool_t, Bool_t)
virtual voidValidateDSet(TDSet* dset)

Data Members

public:
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
};
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::ESlaves { kAll
kActive
kUnique
kAllUnique
};
enum TVirtualProof::EStatusBits { kUsingSessionGui
};
enum TVirtualProof::EQueryMode { kSync
kAsync
};
enum TVirtualProof::EUploadOpt { kAppend
kOverwriteDataSet
kNoOverwriteDataSet
kOverwriteAllFiles
kOverwriteNoFiles
kAskUser
};
enum TVirtualProof::EUploadDataSetAnswer { kError
kDataSetExists
};
enum TVirtualProof::EUploadPackageOpt { kUntar
kRemoveOld
};
enum TObject::EStatusBits { kCanDelete
kMustCleanup
kObjInCanvas
kIsReferenced
kHasUUID
kCannotPick
kNoContextMenu
kInvalidObject
};
enum TObject::[unnamed] { kIsOnHeap
kNotDeleted
kZombie
kBitMask
kSingleKey
kOverwrite
kWriteDelete
};
protected:
TUrlTProof::fUrlUrl of the master
TStringTProof::fConfFilefile containing config information
TStringTProof::fConfDirdirectory containing cluster config information
TStringTProof::fImagemaster's image name
Int_tTProof::fProtocolremote PROOF server protocol version number
TList*TProof::fSlaveslist of all slave servers as in config file
TList*TProof::fBadSlavesdead slaves (subset of all slaves)
TMonitor*TProof::fAllMonitormonitor activity on all valid slave sockets
Bool_tTProof::fDataReadytrue if data is ready to be analyzed
Long64_tTProof::fBytesReadynumber of bytes staged
Long64_tTProof::fTotalBytesnumber of bytes to be analyzed
TList*TProof::fAvailablePackageslist of available packages
TList*TProof::fEnabledPackageslist of enabled packages
static TSemaphore*TProof::fgSemaphoresemaphore to control no of parallel startup threads
TStringTVirtualProof::fDataPoolUrlDefault data pool entry point URL
TVirtualProofMgr::EServTypeTVirtualProof::fServTypeType of server: proofd, XrdProofd
TVirtualProofMgr*TVirtualProof::fManagerManager to which this session belongs (if any)
TVirtualProof::EQueryModeTVirtualProof::fQueryModedefault query mode
TStringTNamed::fNameobject identifier
TStringTNamed::fTitleobject title
TList*TQObject::fListOfSignals! list of signals from this object
TList*TQObject::fListOfConnections! list of connections to this object

Class Description

                                                                      
 TProofSuperMaster                                                    
                                                                      
 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.
TProofSuperMaster(const char *masterurl, const char *conffile, const char *confdir, Int_t loglevel)
 Start super master PROOF session.
Bool_t StartSlaves(Bool_t parallel, Bool_t)
 Start up PROOF submasters.
Long64_t Process(TDSet *set, const char *selector, Option_t *option, Long64_t nentries, Long64_t first, TEventList *evl)
 Process a data set (TDSet) using the specified selector (.C) file.
 The return value is -1 in case of error and TSelector::GetStatus() in
 in case of success.
void ValidateDSet(TDSet *dset)
 Validate a TDSet.
TProofPlayer * MakePlayer()
 Construct a TProofPlayer object.
virtual ~TProofSuperMaster()
{ }

Author: Fons Rademakers 13/02/97
Last update: root/proof:$Name: $:$Id: TProofSuperMaster.cxx,v 1.15 2006/08/06 07:15:00 rdm Exp $
Copyright (C) 1995-2000, Rene Brun and Fons Rademakers. *

ROOT page - Class index - Class Hierarchy - Top of the page
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.