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() |
void | TObject::AbstractMethod(const char* method) const |
Int_t | ActivateWorker(const char* ord, Bool_t save = kTRUE) |
void | AddChain(TChain* chain) |
Int_t | AddDynamicPath(const char* libpath, Bool_t onClient = kFALSE, TList* wrks = 0, Bool_t doCollect = kTRUE) |
static void | AddEnvVar(const char* name, const char* value) |
void | AddFeedback(const char* name) |
Int_t | AddIncludePath(const char* incpath, Bool_t onClient = kFALSE, TList* wrks = 0, Bool_t doCollect = kTRUE) |
void | AddInput(TObject* obj) |
void | AddInputData(TObject* obj, Bool_t push = kFALSE) |
virtual void | TObject::AppendPad(Option_t* option = "") |
Int_t | Archive(Int_t query, const char* url) |
Int_t | Archive(const char* queryref, const char* url = 0) |
static Bool_t | TQObject::AreAllSignalsBlocked() |
Bool_t | TQObject::AreSignalsBlocked() const |
static Bool_t | TQObject::BlockAllSignals(Bool_t b) |
Bool_t | TQObject::BlockSignals(Bool_t b) |
virtual void | Browse(TBrowser* b) |
virtual Bool_t | CancelStagingDataSet(const char* dataset) |
void | cd(Int_t id = -1) |
virtual void | TQObject::ChangedBy(const char* method)SIGNAL |
static TClass* | Class() |
virtual const char* | TObject::ClassName() const |
Int_t | CleanupSession(const char* sessiontag) |
virtual void | TNamed::Clear(Option_t* option = "") |
virtual void | ClearCache(const char* file = 0) |
void | ClearData(UInt_t what = kUnregistered, const char* dsname = 0) |
virtual void | ClearDataSetCache(const char* dataset = 0) |
void | ClearFeedback() |
void | ClearInput() |
void | ClearInputData(TObject* obj = 0) |
void | ClearInputData(const char* name) |
Int_t | ClearPackage(const char* package) |
Int_t | ClearPackages() |
virtual TObject* | TNamed::Clone(const char* newname = "") const |
void | Close(Option_t* option = "") |
void | CloseProgressDialog()SIGNAL |
void | TQObject::CollectClassSignalLists(TList& list, TClass* cls) |
virtual Int_t | TNamed::Compare(const TObject* obj) const |
Bool_t | TQObject::Connect(const char* signal, const char* receiver_class, void* receiver, const char* slot) |
static Bool_t | TQObject::Connect(TQObject* sender, const char* signal, const char* receiver_class, void* receiver, const char* slot) |
static Bool_t | TQObject::Connect(const char* sender_class, const char* signal, const char* receiver_class, void* receiver, const char* slot) |
virtual void | TQObject::Connected(const char*) |
virtual void | TNamed::Copy(TObject& named) const |
TDrawFeedback* | CreateDrawFeedback() |
void | DataSetStatus(const char* msg, Bool_t status, Int_t done, Int_t total)SIGNAL |
Int_t | DeactivateWorker(const char* ord, Bool_t save = kTRUE) |
static void | DelEnvVar(const char* name) |
virtual void | TObject::Delete(Option_t* option = "")MENU |
void | DeleteDrawFeedback(TDrawFeedback* f) |
void | DeleteParameters(const char* wildcard) |
virtual void | TQObject::Destroyed()SIGNAL |
void | Detach(Option_t* opt = "") |
void | DisableGoAsyn() |
Bool_t | TQObject::Disconnect(const char* signal = 0, void* receiver = 0, const char* slot = 0) |
static Bool_t | TQObject::Disconnect(TQObject* sender, const char* signal = 0, void* receiver = 0, const char* slot = 0) |
static Bool_t | TQObject::Disconnect(const char* class_name, const char* signal, void* receiver = 0, const char* slot = 0) |
virtual void | TQObject::Disconnected(const char*) |
virtual Int_t | TObject::DistancetoPrimitive(Int_t px, Int_t py) |
Int_t | DownloadPackage(const char* par, const char* dstdir = 0) |
virtual void | TObject::Draw(Option_t* option = "") |
virtual void | TObject::DrawClass() constMENU |
virtual TObject* | TObject::DrawClone(Option_t* option = "") constMENU |
virtual Long64_t | DrawSelect(TDSet* dset, const char* varexp, const char* selection = "", Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0) |
Long64_t | 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 void | TObject::Dump() constMENU |
virtual Int_t | Echo(const TObject* obj) |
virtual Int_t | Echo(const char* str) |
void | TQObject::Emit(const char* signal) |
void | TQObject::Emit(const char* signal, Long_t* paramArr) |
void | TQObject::Emit(const char* signal, const char* params) |
void | TQObject::Emit(const char* signal, Double_t param) |
void | TQObject::Emit(const char* signal, Long_t param) |
void | TQObject::Emit(const char* signal, Long64_t param) |
void | TQObject::Emit(const char* signal, Bool_t param) |
void | TQObject::Emit(const char* signal, Char_t param) |
void | TQObject::Emit(const char* signal, UChar_t param) |
void | TQObject::Emit(const char* signal, Short_t param) |
void | TQObject::Emit(const char* signal, UShort_t param) |
void | TQObject::Emit(const char* signal, Int_t param) |
void | TQObject::Emit(const char* signal, UInt_t param) |
void | TQObject::Emit(const char* signal, ULong_t param) |
void | TQObject::Emit(const char* signal, ULong64_t param) |
void | TQObject::Emit(const char* signal, Float_t param) |
void | TQObject::EmitVA(const char* signal, Int_t nargs) |
void | TQObject::EmitVA(const char* signal, Int_t nargs, va_list va) |
Int_t | EnablePackage(const char* package, Bool_t notOnClient = kFALSE, TList* workers = 0) |
Int_t | EnablePackage(const char* package, const char* loadopts, Bool_t notOnClient = kFALSE, TList* workers = 0) |
Int_t | EnablePackage(const char* package, TList* loadopts, Bool_t notOnClient = kFALSE, TList* workers = 0) |
virtual void | TObject::Error(const char* method, const char* msgfmt) const |
Int_t | Exec(const char* cmd, Bool_t plusMaster = kFALSE) |
Int_t | Exec(const char* cmd, const char* ord, Bool_t logtomacro = kFALSE) |
virtual void | TObject::Execute(const char* method, const char* params, Int_t* error = 0) |
virtual void | TObject::Execute(TMethod* method, TObjArray* params, Int_t* error = 0) |
virtual void | TObject::ExecuteEvent(Int_t event, Int_t px, Int_t py) |
virtual Bool_t | ExistsDataSet(const char* dataset) |
virtual void | TObject::Fatal(const char* method, const char* msgfmt) const |
void | Feedback(TList* objs)SIGNAL |
virtual void | TNamed::FillBuffer(char*& buffer) |
Long64_t | Finalize(Int_t query = -1, Bool_t force = kFALSE) |
Long64_t | Finalize(const char* queryref, Bool_t force = kFALSE) |
TList* | FindDataSets(const char* searchString, const char* optStr = "") |
virtual TObject* | TObject::FindObject(const char* name) const |
virtual TObject* | TObject::FindObject(const TObject* obj) const |
Long64_t | GetBytesRead() const |
Int_t | GetClientProtocol() const |
const char* | GetConfDir() const |
const char* | GetConfFile() const |
Float_t | GetCpuTime() const |
const char* | GetDataPoolUrl() const |
virtual TFileCollection* | GetDataSet(const char* dataset, const char* optStr = "") |
TMap* | GetDataSetQuota(const char* optStr = "") |
virtual TMap* | GetDataSets(const char* uri = "", const char* optStr = "") |
virtual Option_t* | TObject::GetDrawOption() const |
static Long_t | TObject::GetDtorOnly() |
TString | Getenv(const char* env, const char* ord = "0") |
static const TList* | GetEnvVars() |
TList* | GetFeedbackList() const |
const char* | GetGroup() const |
virtual const char* | TObject::GetIconName() const |
const char* | GetImage() const |
TList* | GetInputList() |
TMacro* | GetLastLog() |
TList* | TQObject::GetListOfClassSignals() const |
TList* | TQObject::GetListOfConnections() const |
TList* | GetListOfEnabledPackages() |
TList* | GetListOfPackages() |
virtual TList* | GetListOfQueries(Option_t* opt = "") |
TList* | TQObject::GetListOfSignals() const |
TList* | GetListOfSlaveInfos() |
TList* | GetLoadedMacros() const |
void | GetLog(Int_t start = -1, Int_t end = -1) |
Int_t | GetLogLevel() const |
TMacro* | GetMacroLog() |
TProofMgr* | GetManager() |
const char* | GetMaster() const |
void | GetMaxQueries() |
TFileCollection* | GetMissingFiles(TQueryResult* qr = 0) |
virtual const char* | TNamed::GetName() const |
Int_t | GetNumberOfDrawQueries() |
Int_t | GetNumberOfQueries() |
virtual char* | TObject::GetObjectInfo(Int_t px, Int_t py) const |
static Bool_t | TObject::GetObjectStat() |
virtual Option_t* | TObject::GetOption() const |
TObject* | GetOutput(const char* name) |
static TObject* | GetOutput(const char* name, TList* out) |
TList* | GetOutputList() |
TList* | GetOutputNames() |
Int_t | GetParallel() const |
TObject* | GetParameter(const char* par) const |
static Int_t | GetParameter(TCollection* c, const char* par, TString& value) |
static Int_t | GetParameter(TCollection* c, const char* par, Int_t& value) |
static Int_t | GetParameter(TCollection* c, const char* par, Long_t& value) |
static Int_t | GetParameter(TCollection* c, const char* par, Long64_t& value) |
static Int_t | GetParameter(TCollection* c, const char* par, Double_t& value) |
Int_t | GetPort() const |
TProof::EQueryMode | GetQueryMode(Option_t* mode = 0) const |
TQueryResult* | GetQueryResult(const char* ref = 0) |
TList* | GetQueryResults() |
Int_t | GetRC(const char* RCenv, Int_t& env, const char* ord = "0") |
Int_t | GetRC(const char* RCenv, Double_t& env, const char* ord = "0") |
Int_t | GetRC(const char* RCenv, TString& env, const char* ord = "0") |
Float_t | GetRealTime() const |
Int_t | GetRemoteProtocol() const |
TProof::ERunStatus | GetRunStatus() const |
Int_t | GetSeqNum() const |
Int_t | GetSessionID() const |
const char* | GetSessionTag() const |
virtual TFileCollection* | GetStagingStatusDataSet(const char* dataset) |
void | GetStatistics(Bool_t verbose = kFALSE) |
Int_t | GetStatus() const |
virtual const char* | TNamed::GetTitle() const |
virtual TTree* | GetTreeHeader(TDSet* tdset) |
virtual UInt_t | TObject::GetUniqueID() const |
const char* | GetUrl() |
const char* | GetUser() const |
const char* | GetWorkDir() const |
void | GoAsynchronous() |
virtual Bool_t | TObject::HandleTimer(TTimer* timer) |
virtual Bool_t | TQObject::HasConnection(const char* signal_name) const |
virtual ULong_t | TNamed::Hash() const |
virtual void | TQObject::HighPriority(const char* signal_name, const char* slot_name = 0) |
virtual void | TObject::Info(const char* method, const char* msgfmt) const |
virtual Bool_t | TObject::InheritsFrom(const char* classname) const |
virtual Bool_t | TObject::InheritsFrom(const TClass* cl) const |
virtual void | TObject::Inspect() constMENU |
void | TObject::InvertBit(UInt_t f) |
virtual TClass* | IsA() const |
Bool_t | IsDataReady(Long64_t& totalbytes, Long64_t& bytesready) |
virtual Bool_t | TObject::IsEqual(const TObject* obj) const |
virtual Bool_t | IsFolder() const |
Bool_t | IsIdle() const |
Bool_t | IsLite() const |
Bool_t | IsMaster() const |
Bool_t | TObject::IsOnHeap() const |
Bool_t | IsParallel() const |
Bool_t | IsProofd() const |
virtual Bool_t | TNamed::IsSortable() const |
Bool_t | IsTty() const |
Bool_t | IsValid() const |
Bool_t | IsWaiting() const |
Bool_t | TObject::IsZombie() const |
virtual Int_t | Load(const char* macro, Bool_t notOnClient = kFALSE, Bool_t uniqueOnly = kTRUE, TList* wrks = 0) |
static void | TQObject::LoadRQ_OBJECT() |
void | LogMessage(const char* msg, Bool_t all)SIGNAL |
static void | LogViewer(const char* url = 0, Int_t sessionidx = 0) |
virtual void | TQObject::LowPriority(const char* signal_name, const char* slot_name = 0) |
virtual void | TNamed::ls(Option_t* option = "") const |
void | TObject::MayNotUse(const char* method) const |
virtual void | TQObject::Message(const char* msg)SIGNAL |
static TProofMgr* | Mgr(const char* url) |
virtual Bool_t | TObject::Notify() |
virtual Int_t | TQObject::NumberOfConnections() const |
virtual Int_t | TQObject::NumberOfSignals() const |
void | TObject::Obsolete(const char* method, const char* asOfVers, const char* removedFromVers) const |
static TProof* | Open(const char* url = 0, const char* conffile = 0, const char* confdir = 0, Int_t loglevel = 0) |
static void | TObject::operator delete(void* ptr) |
static void | TObject::operator delete(void* ptr, void* vp) |
static void | TObject::operator delete[](void* ptr) |
static void | TObject::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) |
virtual void | TObject::Paint(Option_t* option = "") |
Int_t | Ping() |
virtual void | TObject::Pop() |
virtual void | Print(Option_t* option = "") const |
virtual Long64_t | Process(const char* selector, Long64_t nentries, Option_t* option = "") |
virtual Long64_t | Process(TSelector* selector, Long64_t nentries, Option_t* option = "") |
virtual Long64_t | Process(TDSet* dset, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0) |
virtual Long64_t | Process(TFileCollection* fc, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0) |
virtual Long64_t | Process(TDSet* dset, TSelector* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0) |
virtual Long64_t | Process(TFileCollection* fc, TSelector* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0) |
virtual Long64_t | Process(const char* dsetname, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0, TObject* enl = 0) |
virtual Long64_t | Process(const char* dsetname, TSelector* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0, TObject* enl = 0) |
void | Progress(Long64_t total, Long64_t processed)SIGNAL |
void | Progress(Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)SIGNAL |
void | 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)SIGNAL |
void | PutLog(TQueryResult* qr) |
void | QueryResultReady(const char* ref)SIGNAL |
virtual Int_t | TObject::Read(const char* name) |
virtual void | TObject::RecursiveRemove(TObject* obj) |
virtual Bool_t | RegisterDataSet(const char* name, TFileCollection* dataset, const char* optStr = "") |
Int_t | Remove(Int_t query, Bool_t all = kFALSE) |
Int_t | Remove(const char* queryref, Bool_t all = kFALSE) |
void | RemoveChain(TChain* chain) |
virtual Int_t | RemoveDataSet(const char* dataset, const char* optStr = "") |
Int_t | RemoveDynamicPath(const char* libpath, Bool_t onClient = kFALSE) |
void | RemoveFeedback(const char* name) |
Int_t | RemoveIncludePath(const char* incpath, Bool_t onClient = kFALSE) |
virtual Bool_t | RequestStagingDataSet(const char* dataset) |
static void | Reset(const char* url, Bool_t hard = kFALSE) |
void | TObject::ResetBit(UInt_t f) |
static void | ResetEnvVars() |
void | ResetProgressDialog(const char* sel, Int_t sz, Long64_t fst, Long64_t ent)SIGNAL |
void | ResetProgressDialogStatus() |
Int_t | Retrieve(Int_t query, const char* path = 0) |
Int_t | Retrieve(const char* queryref, const char* path = 0) |
virtual void | TObject::SaveAs(const char* filename = "", Option_t* option = "") constMENU |
Int_t | SavePerfTree(const char* pf = 0, const char* qref = 0) |
virtual void | TObject::SavePrimitive(ostream& out, Option_t* option = "") |
void | SendDataSetStatus(const char* msg, UInt_t n, UInt_t tot, Bool_t st) |
Bool_t | SendingLogToWindow() const |
void | SendLogToWindow(Bool_t mode) |
void | SetActive(Bool_t = kTRUE) |
virtual void | SetAlias(const char* alias = "") |
void | TObject::SetBit(UInt_t f) |
void | TObject::SetBit(UInt_t f, Bool_t set) |
void | SetDataPoolUrl(const char* url) |
virtual Int_t | SetDataSetTreeName(const char* dataset, const char* treename) |
void | SetDrawFeedbackOption(TDrawFeedback* f, Option_t* opt) |
virtual void | TObject::SetDrawOption(Option_t* option = "")MENU |
static void | TObject::SetDtorOnly(void* obj) |
void | SetInputDataFile(const char* datafile) |
void | SetLogLevel(Int_t level, UInt_t mask = TProofDebug::kAll) |
void | SetManager(TProofMgr* mgr) |
void | SetMaxDrawQueries(Int_t max) |
virtual void | TNamed::SetName(const char* name)MENU |
virtual void | TNamed::SetNameTitle(const char* name, const char* title) |
static void | TObject::SetObjectStat(Bool_t stat) |
Int_t | SetParallel(Int_t nodes = -1, Bool_t random = kFALSE) |
void | SetParameter(const char* par, const char* value) |
void | SetParameter(const char* par, Int_t value) |
void | SetParameter(const char* par, Long_t value) |
void | SetParameter(const char* par, Long64_t value) |
void | SetParameter(const char* par, Double_t value) |
void | SetPerfTree(const char* pf = "perftree.root", Bool_t withWrks = kFALSE) |
void | SetPrintProgress(PrintProgress_t pp) |
void | SetProgressDialog(Bool_t on = kTRUE) |
void | SetQueryMode(TProof::EQueryMode mode) |
void | SetRealTimeLog(Bool_t on = kTRUE) |
virtual void | TNamed::SetTitle(const char* title = "")MENU |
virtual void | TObject::SetUniqueID(UInt_t uid) |
virtual void | ShowCache(Bool_t all = kFALSE) |
virtual void | ShowData() |
void | ShowDataSet(const char* dataset = "", const char* opt = "filter:SsCc") |
virtual void | ShowDataSetCache(const char* dataset = 0) |
void | ShowDataSetQuota(Option_t* opt = 0) |
virtual void | ShowDataSets(const char* uri = "", const char* optStr = "") |
void | ShowEnabledPackages(Bool_t all = kFALSE) |
void | ShowFeedback() const |
void | ShowLog(Int_t qry = -1) |
void | ShowLog(const char* queryref) |
virtual void | ShowMembers(TMemberInspector&) |
void | ShowMissingFiles(TQueryResult* qr = 0) |
void | ShowPackages(Bool_t all = kFALSE, Bool_t redirlog = kFALSE) |
void | ShowParameters(const char* wildcard = "PROOF_*") const |
void | ShowQueries(Option_t* opt = "") |
virtual void | ShowStagingStatusDataSet(const char* dataset, const char* optStr = "filter:SsCc") |
virtual Int_t | TNamed::Sizeof() const |
void | StartupMessage(const char* msg, Bool_t status, Int_t done, Int_t total)SIGNAL |
void | StopProcess(Bool_t abort, Int_t timeout = -1) |
virtual void | Streamer(TBuffer&) |
void | StreamerNVirtual(TBuffer& ClassDef_StreamerNVirtual_b) |
virtual void | TObject::SysError(const char* method, const char* msgfmt) const |
Bool_t | TObject::TestBit(UInt_t f) const |
Int_t | TObject::TestBits(UInt_t f) const |
void | Touch() |
Int_t | UploadDataSet(const char*, TList*, const char* = 0, Int_t = 0, TList* = 0) |
Int_t | UploadDataSet(const char*, const char*, const char* = 0, Int_t = 0, TList* = 0) |
Int_t | UploadDataSetFromFile(const char*, const char*, const char* = 0, Int_t = 0, TList* = 0) |
Int_t | UploadPackage(const char* par, TProof::EUploadPackageOpt opt = kUntar, TList* workers = 0) |
virtual void | TObject::UseCurrentStyle() |
Bool_t | UseDynamicStartup() const |
virtual Int_t | VerifyDataSet(const char* dataset, const char* optStr = "") |
virtual void | TObject::Warning(const char* method, const char* msgfmt) const |
virtual Int_t | TObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0) |
virtual Int_t | TObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0) const |
TProof() | |
Int_t | AddWorkers(TList* wrks) |
static Int_t | AssertDataSet(TDSet* dset, TList* input, TDataSetManager* mgr, TString& emsg) |
Int_t | AssertPath(const char* path, Bool_t writable) |
static Int_t | TQObject::CheckConnectArgs(TQObject* sender, TClass* sender_class, const char* signal, TClass* receiver_class, const char* slot) |
Int_t | Collect(TProof::ESlaves list = kActive, Long_t timeout = -1, Int_t endtype = -1, Bool_t deactonfail = kFALSE) |
Int_t | Collect(TList* slaves, Long_t timeout = -1, Int_t endtype = -1, Bool_t deactonfail = kFALSE) |
static Bool_t | TQObject::ConnectToClass(TQObject* sender, const char* signal, TClass* receiver_class, void* receiver, const char* slot) |
static Bool_t | TQObject::ConnectToClass(const char* sender_class, const char* signal, TClass* receiver_class, void* receiver, const char* slot) |
TSlave* | CreateSlave(const char* url, const char* ord, Int_t perf, const char* image, const char* workdir) |
TSlave* | CreateSubmaster(const char* url, const char* ord, const char* image, const char* msd) |
virtual void | TObject::DoError(int level, const char* location, const char* fmt, va_list va) const |
TList* | GetEnabledPackages() const |
static Bool_t | GetFileInCmd(const char* cmd, TString& fn) |
static Int_t | GetInputData(TList* input, const char* cachedir, TString& emsg) |
TList* | GetListOfActiveSlaves() const |
TVirtualProofPlayer* | GetPlayer() const |
TPluginHandler* | GetProgressDialog() const |
Int_t | GetSandbox(TString& sb, Bool_t assert = kFALSE, const char* rc = 0) |
virtual void* | TQObject::GetSender() |
virtual const char* | TQObject::GetSenderClassName() const |
void | HandleLibIncPath(const char* what, Bool_t add, const char* dirs) |
Int_t | HandleOutputOptions(TString& opt, TString& target, Int_t action) |
Int_t | Init(const char* masterurl, const char* conffile, const char* confdir, Int_t loglevel, const char* alias = 0) |
void | InitMembers() |
virtual TVirtualProofPlayer* | MakePlayer(const char* player = 0, TSocket* s = 0) |
void | TObject::MakeZombie() |
virtual Int_t | PollForNewWorkers() |
void | PrepareInputDataFile(TString& dataFile) |
Int_t | RemoveWorkers(TList* wrks) |
static Int_t | SaveInputData(TQueryResult* qr, const char* cachedir, TString& emsg) |
virtual void | SaveWorkerInfo() |
Int_t | SendFile(const char* file, Int_t opt = (kBinary|kForward|kCp|kCpBin), const char* rfile = 0, TSlave* sl = 0) |
static Int_t | SendInputData(TQueryResult* qr, TProof* p, TString& emsg) |
virtual void | SendInputDataFile() |
void | SetDSet(TDSet* dset) |
void | SetFeedback(TString& opt, TString& optfb, Int_t action) |
void | SetPlayer(TVirtualProofPlayer* player) |
void | SetupWorkersEnv(TList* wrks, Bool_t increasingpool = kFALSE) |
static void* | SlaveStartupThread(void* arg) |
virtual Bool_t | StartSlaves(Bool_t attach = kFALSE) |
static void | SystemCmd(const char* cmd, Int_t fdout) |
void | UpdateDialog() |
virtual void | ValidateDSet(TDSet* dset) |
Int_t | VerifyDataSetParallel(const char* uri, const char* optStr) |
enum EStatusBits { | kUsingSessionGui | |
kNewInputData | ||
kIsClient | ||
kIsMaster | ||
kIsTopMaster | ||
kUseProgressDialog | ||
}; | ||
enum EQueryMode { | kSync | |
kAsync | ||
}; | ||
enum EUploadOpt { | kAppend | |
kOverwriteDataSet | ||
kNoOverwriteDataSet | ||
kOverwriteAllFiles | ||
kOverwriteNoFiles | ||
kAskUser | ||
}; | ||
enum ERegisterOpt { | kFailIfExists | |
kOverwriteIfExists | ||
kMergeIfExists | ||
}; | ||
enum EUploadDataSetAnswer { | kError | |
kDataSetExists | ||
kFail | ||
}; | ||
enum EUploadPackageOpt { | kUntar | |
kRemoveOld | ||
}; | ||
enum ERunStatus { | kRunning | |
kStopped | ||
kAborted | ||
}; | ||
enum ESubMerger { | kOutputSize | |
kSendOutput | ||
kBeMerger | ||
kMergerDown | ||
kStopMerging | ||
kOutputSent | ||
}; | ||
enum EProofClearData { | kPurge | |
kUnregistered | ||
kDataset | ||
kForceClear | ||
}; | ||
enum EUrgent { | kLocalInterrupt | |
kPing | ||
kHardInterrupt | ||
kSoftInterrupt | ||
kShutdownInterrupt | ||
}; | ||
enum EProofCacheCommands { | kShowCache | |
kClearCache | ||
kShowPackages | ||
kClearPackages | ||
kClearPackage | ||
kBuildPackage | ||
kLoadPackage | ||
kShowEnabledPackages | ||
kShowSubCache | ||
kClearSubCache | ||
kShowSubPackages | ||
kDisableSubPackages | ||
kDisableSubPackage | ||
kBuildSubPackage | ||
kUnloadPackage | ||
kDisablePackage | ||
kUnloadPackages | ||
kDisablePackages | ||
kListPackages | ||
kListEnabledPackages | ||
kLoadMacro | ||
}; | ||
enum EProofDataSetCommands { | kUploadDataSet | |
kCheckDataSetName | ||
kGetDataSets | ||
kRegisterDataSet | ||
kGetDataSet | ||
kVerifyDataSet | ||
kRemoveDataSet | ||
kMergeDataSet | ||
kShowDataSets | ||
kGetQuota | ||
kShowQuota | ||
kSetDefaultTreeName | ||
kCache | ||
kRequestStaging | ||
kStagingStatus | ||
kCancelStaging | ||
}; | ||
enum ESendFileOpt { | kAscii | |
kBinary | ||
kForce | ||
kForward | ||
kCpBin | ||
kCp | ||
}; | ||
enum EProofWrkListAction { | kActivateWorker | |
kDeactivateWorker | ||
}; | ||
enum EBuildPackageOpt { | kDontBuildOnClient | |
kBuildOnSlavesNoWait | ||
kBuildAll | ||
kCollectBuildResults | ||
}; | ||
enum EParCheckVersionOpt { | kDontCheck | |
kCheckROOT | ||
kCheckSVN | ||
}; | ||
enum EProofShowQuotaOpt { | kPerGroup | |
kPerUser | ||
}; | ||
enum 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 | ||
}; |
TMonitor* | fAllMonitor | monitor activity on all valid slave sockets |
TList* | fAvailablePackages | list of available packages |
TList* | fBadSlaves | dead slaves (subset of all slaves) |
Long64_t | fBytesReady | number of bytes staged |
Int_t | fCollectTimeout | Timeout for (some) collect actions |
TString | fConfDir | directory containing cluster config information |
TString | fConfFile | file containing config information |
TString | fDataPoolUrl | default data pool entry point URL |
Bool_t | fDataReady | true if data is ready to be analyzed |
Bool_t | fDynamicStartup | are the workers started dynamically? |
TList* | fEnabledPackages | list of enabled packages |
TString | fImage | master's image name |
TList* | TQObject::fListOfConnections | ! list of connections to this object |
TList* | TQObject::fListOfSignals | ! list of signals from this object |
TProofMgr* | fManager | manager to which this session belongs (if any) |
Bool_t | fMasterServ | true if we are a master server |
TString | TNamed::fName | object identifier |
Float_t | fPrepTime | Preparation time |
Int_t | fProtocol | remote PROOF server protocol version number |
TProof::EQueryMode | fQueryMode | default query mode |
TStopwatch | fQuerySTW | Stopwatch to measure query times |
TList* | fRunningDSets | Temporary datasets used for async running |
TSelector* | fSelector | Selector to be processed, if any |
TProofMgr::EServType | fServType | type of server: proofd, XrdProofd |
Bool_t | TQObject::fSignalsBlocked | ! flag used for suppression of signals |
TList* | fSlaves | list of all slave servers as in config file |
TList* | fTerminatedSlaveInfos | list of unique infos of terminated slaves |
TString | TNamed::fTitle | object title |
Long64_t | fTotalBytes | number of bytes to be analyzed |
TUrl | fUrl | Url of the master |
static Bool_t | TQObject::fgAllSignalsBlocked | flag used for suppression of all signals |
static TSemaphore* | fgSemaphore | semaphore to control no of parallel startup threads |
TMonitor* | fActiveMonitor | monitor activity on all active slave sockets |
TList* | fActiveSlaves | list of active slaves (subset of all slaves) |
TString | fActiveSlavesSaved | comma-separated list of active slaves (before last call to |
TMonitor* | fAllUniqueMonitor | monitor activity on all unique slave sockets, including all submasters |
TList* | fAllUniqueSlaves | list of all active slaves with unique file systems, including all submasters |
Long64_t | fBytesRead | bytes read by all slaves during the session |
TList* | fChains | chains with this proof set |
Int_t | fCheckFileStatus | remote return status after kPROOF_CHECKFILE |
TVirtualMutex* | fCloseMutex | Avoid crashes in MarkBad or alike while closing |
Float_t | fCpuTime | CPU time spent by all slaves during the session |
TMonitor* | fCurrentMonitor | currently active monitor |
TDSet* | fDSet | current TDSet being validated |
Int_t | fDrawQueries | number of draw queries during this sessions |
TList* | fEnabledPackagesOnClient | list of packages enabled on client |
TList* | fEnabledPackagesOnCluster | list of enabled packages |
Bool_t | fEndMaster | true for a master in direct contact only with workers |
TList* | fFeedback | list of names to be returned as feedback |
map<TString,TProof::MD5Mod_t,less<TString>,allocator<pair<const TString,TProof::MD5Mod_t> > > | fFileMap | map keeping track of a file's md5 and mod time |
Bool_t | fFinalizationRunning | |
THashList* | fGlobalPackageDirList | list of directories containing global packages libs |
TString | fGroup | PROOF group of this user |
TList* | fInactiveSlaves | list of inactive slaves (good but not used for processing) |
TList* | fInputData | Input data objects sent over via file |
TString | fInputDataFile | File with input data objects |
TSignalHandler* | fIntHandler | interrupt signal handler (ctrl-c) |
Bool_t | fIsPollingWorkers | will be set to kFALSE to prevent recursive dyn workers check in dyn mode |
Bool_t | fIsWaiting | true if queries have been enqueued |
Int_t | fLastAssignedMerger | |
Long64_t | fLastPollWorkers_s | timestamp (in seconds) of last poll for workers, -1 if never checked |
TList* | fLoadedMacros | List of loaded macros (just file names) |
TString | fLogFileName | name of the temp file for redirected logs |
FILE* | fLogFileR | temp file to read redirected logs |
FILE* | fLogFileW | temp file to redirect logs |
Int_t | fLogLevel | server debug logging level |
Bool_t | fLogToWindowOnly | send log to window only |
TMacro | fMacroLog | Macro with the saved (last) log |
TString | fMaster | master server ("" if a master); used in the browser |
Int_t | fMaxDrawQueries | max number of draw queries kept |
TProofMergePrg | fMergePrg | Merging progress |
TList* | fMergers | |
Bool_t | fMergersByHost | Mergers assigned by host name |
Int_t | fMergersCount | |
Bool_t | fMergersSet | Indicates, if the following variables have been initialized properly |
TList* | fNonUniqueMasters | list of all active masters with a nonunique file system |
Int_t | fNotIdle | Number of non-idle sub-nodes |
Int_t | fOtherQueries | number of queries in list from previous sessions |
TProofOutputList | fOutputList | TList implementation filtering ls(...) and Print(...) |
TString | fPackageDir | package directory (used on client) |
TProofLockPath* | fPackageLock | package lock |
TString | fPerfTree | If non-null triggers saving of the performance info into fPerfTree |
TVirtualProofPlayer* | fPlayer | current player |
PrintProgress_t | fPrintProgress | Function function to display progress info in batch mode |
TPluginHandler* | fProgressDialog | progress dialog plugin |
Bool_t | fProgressDialogStarted | indicates if the progress dialog is up |
TList* | fQueries | list of TProofQuery objects |
Float_t | fRealTime | realtime spent by all slaves during the session |
TList* | fRecvMessages | Messages received during collect not yet processed |
Bool_t | fRedirLog | redirect received log info |
Int_t | fRedirectNext | |
TProof::ERunStatus | fRunStatus | run status |
Bool_t | fSaveLogToMacro | Whether to save received logs to TMacro fMacroLog (use with care) |
Bool_t | fSendGroupView | if true send new group view |
Int_t | fSeqNum | Remote sequential # of the last query submitted |
Int_t | fSessionID | remote ID of the session |
TList* | fSlaveInfo | !list returned by kPROOF_GETSLAVEINFO |
Int_t | fStatus | remote return status (part of kPROOF_LOGDONE) |
Bool_t | fSync | true if type of currently processed query is sync |
Bool_t | fTty | TRUE if connected to a terminal |
TMonitor* | fUniqueMonitor | monitor activity on all unique slave sockets |
TList* | fUniqueSlaves | list of all active slaves with unique file systems |
Bool_t | fValid | is this a valid proof object |
TList* | fWaitingSlaves | stores a TPair of the slaves's TSocket and TMessage |
TString | fWorkDir | current work directory on remote servers |
Int_t | fWorkersToMerge | Current total number of workers, which have not been yet assigned to any merger |
TList* | fWrksOutputReady | List of workers ready to send output (in control output sending mode) |
static TPluginHandler* | fgLogViewer | Log dialog box plugin |
static TList* | fgProofEnvList | List of TNameds defining environment |
Create a PROOF environment. Starting PROOF involves either connecting
to a master server, which in turn will start a set of slave servers, or
directly starting as master server (if master = ""). Masterurl is of
the form: [proof[s]://]host[:port]. Conffile is the name of the config
file describing the remote PROOF cluster (this argument alows you to
describe different cluster configurations).
The default is proof.conf. Confdir is the directory where the config
file and other PROOF related files are (like motd and noproof files).
Loglevel is the log level (default = 1). User specified custom config
files will be first looked for in $HOME/.conffile.
Protected constructor to be used by classes deriving from TProof (they have to call Init themselves and override StartSlaves appropriately). This constructor simply closes any previous gProof and sets gProof to this instance.
Start the PROOF environment. Starting PROOF involves either connecting to a master server, which in turn will start a set of slave servers, or directly starting as master server (if master = ""). For a description of the arguments see the TProof ctor. Returns the number of started master or slave servers, returns 0 in case of error, in which case fValid remains false.
Set the sandbox path from ' Proof.Sandbox' or the alternative var 'rc'. Use the existing setting or the default if nothing is found. If 'assert' is kTRUE, make also sure that the path exists. Return 0 on success, -1 on failure
The config file field may contain special instructions which need to be
parsed at the beginning, e.g. for debug runs with valgrind.
Several options can be given separated by a ','
Make sure that 'path' exists; if 'writable' is kTRUE, make also sure that the path is writable
Set manager and schedule its destruction after this for clean operations.
Works on the master node only. It starts workers on the machines in workerList and sets the paths, packages and macros as on the master. It is a subbstitute for StartSlaves(...) The code is mostly the master part of StartSlaves, with the parallel startup removed.
Set up packages, loaded macros, include and lib paths ...
Used for shuting down the workres after a query is finished. Sends each of the workers from the workerList, a kPROOF_STOP message. If the workerList == 0, shutdown all the workers.
Close all open slave servers. Client can decide to shutdown the remote session by passing option is 'S' or 's'. Default for clients is detach, if supported. Masters always shutdown the remote counterpart.
Find slave that has TSocket s. Returns 0 in case slave is not found.
Add to the fUniqueSlave list the active slaves that have a unique (user) file system image. This information is used to transfer files only once to nodes that share a file system (an image). Submasters which are not in fUniqueSlaves are put in the fNonUniqueMasters list. That list is used to trigger the transferring of files to the submaster's unique slaves without the need to transfer the file to the submaster.
Return number of active slaves, i.e. slaves that are valid and in the current computing group.
Return number of inactive slaves, i.e. slaves that are valid but not in the current computing group.
Return number of unique slaves, i.e. active slaves that have each a unique different user files system.
Return number of bad slaves. This are slaves that we in the config file, but refused to startup or that died during the PROOF session.
Get statistics about CPU time, real time and bytes read. If verbose, print the resuls (always available via GetCpuTime(), GetRealTime() and GetBytesRead()
Return pointer to the full TQueryResult instance owned by the player and referenced by 'ref'. If ref = 0 or "", return the last query result.
Ask the master for the list of queries. Options: "A" show information about all the queries known to the server, i.e. even those processed by other sessions "L" show only information about queries locally available i.e. already retrieved. If "L" is specified, "A" is ignored. "F" show all details available about queries "H" print help menu Default ""
See if the data is ready to be analyzed.
Send interrupt to master or slave servers.
Returns number of slaves active in parallel mode. Returns 0 in case there are no active slaves. Returns -1 in case of error.
Activate (on == TRUE) or deactivate (on == FALSE) all sockets monitored by 'mon'.
Broadcast the group priority to all workers in the specified list. Returns the number of workers the message was successfully sent to. Returns -1 in case of error.
Broadcast the group priority to all workers in the specified list. Returns the number of workers the message was successfully sent to. Returns -1 in case of error.
Broadcast a message to all slaves in the specified list. Returns the number of slaves the message was successfully sent to. Returns -1 in case of error.
Broadcast a message to all slaves in the specified list (either all slaves or only the active slaves). Returns the number of slaves the message was successfully sent to. Returns -1 in case of error.
Broadcast an object to all slaves in the specified list. Use kind to set the TMEssage what field. Returns the number of slaves the message was sent to. Returns -1 in case of error.
Broadcast an object to all slaves in the specified list. Use kind to set the TMEssage what field. Returns the number of slaves the message was sent to. Returns -1 in case of error.
Broadcast a raw buffer of specified length to all slaves in the specified list. Returns the number of slaves the buffer was sent to. Returns -1 in case of error.
Broadcast a raw buffer of specified length to all slaves in the specified list. Returns the number of slaves the buffer was sent to. Returns -1 in case of error.
Broadcast file to all workers in the specified list. Returns the number of workers the buffer was sent to. Returns -1 in case of error.
Broadcast file to all workers in the specified list. Returns the number of workers the buffer was sent to. Returns -1 in case of error.
Release the used monitor to be used, making sure to delete newly created monitors.
Collect responses from slave sl. Returns the number of slaves that responded (=1). If timeout >= 0, wait at most timeout seconds (timeout = -1 by default, which means wait forever). If defined (>= 0) endtype is the message that stops this collection.
Collect responses from the slave servers. Returns the number of slaves that responded. If timeout >= 0, wait at most timeout seconds (timeout = -1 by default, which means wait forever). If defined (>= 0) endtype is the message that stops this collection.
Collect responses from the slave servers. Returns the number of slaves that responded. If timeout >= 0, wait at most timeout seconds (timeout = -1 by default, which means wait forever). If defined (>= 0) endtype is the message that stops this collection.
Collect responses from the slave servers. Returns the number of messages received. Can be 0 if there are no active slaves. If timeout >= 0, wait at most timeout seconds (timeout = -1 by default, which means wait forever). If defined (>= 0) endtype is the message that stops this collection. Collect also stops its execution from time to time to check for new workers in Dynamic Startup mode.
Asks the PROOF Serv for new workers in Dynamic Startup mode and activates them. Returns the number of new workers found, or <0 on errors.
Collect and analyze available input from socket s. Returns 0 on success, -1 if any failure occurs.
Analyze the received message. Returns 0 on success (1 if this the last message from this socket), -1 if any failure occurs.
Redirect output of worker sl to some merger
Return a merger, which is both active and still accepts some workers to be assigned to it. It works on the 'round-robin' basis.
Add a bad slave server to the bad slave list and remove it from the active list and from the two monitor objects. Assume that the work done by this worker was lost and ask packerizer to reassign it.
Add slave with socket s to the bad slave list and remove if from the active list and from the two monitor objects.
Extract from opt information about output handling settings. The understood keywords are: of=<file>, outfile=<file> output file location ds=<dsname>, dataset=<dsname> dataset name ('of' and 'ds' are mutually exclusive,execution stops if both are found) sft[=<opt>], savetofile[=<opt>] control saving to file For 'mvf', the <opt> integer has the following meaning: <opt> = <how>*10 + <force> <force> = 0 save to file if memory threshold is reached (the memory threshold is set by the cluster admin); in case an output file is defined, the files are merged at the end; 1 save results to file. <how> = 0 save at the end of the query 1 save results after each packet (to reduce the loss in case of crash). Setting 'ds' automatically sets 'mvf=1'; it is still possible to set 'mvf=11' to save results after each packet. The separator from the next option is either a ' ' or a ';' All recognized settings are removed from the input string opt. If action == 0, set up the output file accordingly, if action == 1 clean related output file settings. If the final target file is local then 'target' is set to the final local path when action == 0 and used to retrieve the file with TFile::Cp when action == 1. Output file settings are in the form <previous_option>of=name <next_option> <previous_option>outfile=name,...;<next_option> The separator from the next option is either a ' ' or a ';' Called interanally by TProof::Process. Returns 0 on success, -1 on error.
Extract from opt in optfb information about wanted feedback settings. Feedback are removed from the input string opt. If action == 0, set up feedback accordingly, if action == 1 clean related feedback settings (using info in optfb, if available, or reparsing opt). Feedback requirements are in the form <previous_option>fb=name1,name2,name3,... <next_option> <previous_option>feedback=name1,name2,name3,...;<next_option> The special name 'stats' triggers feedback about events and packets. The separator from the next option is either a ' ' or a ';'. Called interanally by TProof::Process.
Process a data set (TFileCollection) using the specified selector (.C) file or TSelector object. The default tree is analyzed (i.e. the first one found). To specify another tree, the default tree can be changed using TFileCollection::SetDefaultMetaData . The return value is -1 in case of error and TSelector::GetStatus() in in case of success.
Process a dataset which is stored on the master with name 'dsetname'. The syntax for dsetname is name[#[dir/]objname], e.g. "mydset" analysis of the first tree in the top dir of the dataset named "mydset" "mydset#T" analysis tree "T" in the top dir of the dataset named "mydset" "mydset#adir/T" analysis tree "T" in the dir "adir" of the dataset named "mydset" "mydset#adir/" analysis of the first tree in the dir "adir" of the dataset named "mydset" The component 'name' in its more general form contains also the group and user name following "/<group>/<user>/<dsname>". Each of these components can contain one or more wildcards '*', in which case all the datasets matching the expression are added together as a global dataset (wildcard support has been added in version 5.27/02). The last argument 'elist' specifies an entry- or event-list to be used as event selection. It is also possible (starting w/ version 5.27/02) to run on multiple datasets at once in a more flexible way that the one provided by wildcarding. There are three possibilities: 1) specifying the dataset names separated by the OR operator '|', e.g. dsetname = "<dset1>|<dset2>|<dset3>|..." in this case the datasets are a seen as a global unique dataset 2) specifying the dataset names separated by a ',' or a ' ', e.g. dsetname = "<dset1>,<dset2> <dset3>,..." in this case the datasets are processed one after the other and the selector is notified when switching dataset via a bit in the current processed element. 3) giving the path of a textfile where the dataset names are specified on one or multiple lines; the lines found are joined as in 1), unless the filepath is followed by a ',' (i.e. p->Process("datasets.txt,",...) with the dataset names listed in 'datasets.txt') in which case they are treated as in 2); the file is open in raw mode with TFile::Open and therefore it cane be remote, e.g. on a Web server. Each <dsetj> has the format specified above for the single dataset processing, included wildcarding (the name of the tree and subdirectory must be same for all the datasets). In the case of multiple datasets, 'elist' is treated a global entry list. It is possible to specify per-dataset entry lists using the syntax "mydset[#adir/[T]]?enl=entrylist" or "mydset[#adir/[T]]<<entrylist" Here 'entrylist' is a tag identifying, in the order : i. a named entry-list in the input list or in the input data list ii. a named entry-list in memory (in gDirectory) iii. the path of a file containing the entry-list to be used In the case ii) and iii) the entry-list object(s) is(are) added to the input data list. The return value is -1 in case of error and TSelector::GetStatus() in in case of success.
Process a data set (TFileCollection) using the specified selector object The default tree is analyzed (i.e. the first one found). To specify another tree, the default tree can be changed using TFileCollection::SetDefaultMetaData . The return value is -1 in case of error and TSelector::GetStatus() in in case of success.
Get reference for the qry-th query in fQueries (as displayed by ShowQueries).
Send retrieve request for the qry-th query in fQueries. If path is defined save it to path.
Send retrieve request for the query specified by ref. If path is defined save it to path. Generic method working for all queries known by the server.
Send remove request for the qry-th query in fQueries.
Send remove request for the query specified by ref.
If all = TRUE remove also local copies of the query, if any.
Generic method working for all queries known by the server.
This method can be also used to reset the list of queries
waiting to be processed: for that purpose use ref == "cleanupqueue".
Send archive request for the query specified by ref.
Generic method working for all queries known by the server.
If ref == "Default", path is understood as a default path for
archiving.
Change query running mode to the one specified by 'mode'.
Execute the specified drawing action on a data set (TDSet). Event- or Entry-lists should be set in the data set object using TDSet::SetEntryList. Returns -1 in case of error or number of selected events otherwise.
Execute the specified drawing action on a data set which is stored on the master with name 'dsetname'. The syntax for dsetname is name[#[dir/]objname], e.g. "mydset" analysis of the first tree in the top dir of the dataset named "mydset" "mydset#T" analysis tree "T" in the top dir of the dataset named "mydset" "mydset#adir/T" analysis tree "T" in the dir "adir" of the dataset named "mydset" "mydset#adir/" analysis of the first tree in the dir "adir" of the dataset named "mydset" The last argument 'enl' specifies an entry- or event-list to be used as event selection. The return value is -1 in case of error and TSelector::GetStatus() in in case of success.
Notify locally 'msg' to the appropriate units (file, stdout, window) If defined, 'sfx' is added after 'msg' (typically a line-feed);
Log a message into the appropriate window by emitting a signal.
Send to all active slaves servers the current slave group size and their unique id. Returns number of active slaves. Returns -1 in case of error.
Send command to be executed on the PROOF master and/or slaves. If plusMaster is kTRUE then exeucte on slaves and master too. Command can be any legal command line command. Commands like ".x file.C" or ".L file.C" will cause the file file.C to be send to the PROOF cluster. Returns -1 in case of error, >=0 in case of succes.
Send command to be executed on the PROOF master and/or slaves. Command can be any legal command line command. Commands like ".x file.C" or ".L file.C" will cause the file file.C to be send to the PROOF cluster. Returns -1 in case of error, >=0 in case of succes.
Send command to be executed on node of ordinal 'ord' (use "0" for master). Command can be any legal command line command. Commands like ".x file.C" or ".L file.C" will cause the file file.C to be send to the PROOF cluster. If logtomacro is TRUE the text result of the action is saved in the fMacroLog TMacro, accessible via TMacro::GetMacroLog(); Returns -1 in case of error, >=0 in case of succes.
Send command to be executed on the PROOF master and/or slaves. Command can be any legal command line command, however commands like ".x file.C" or ".L file.C" will not cause the file.C to be transfered to the PROOF cluster. In that case use TProof::Exec(). Returns the status send by the remote server as part of the kPROOF_LOGDONE message. Typically this is the return code of the command on the remote side. Returns -1 in case of error.
Get value of environment variable 'env' on node 'ord'
Get into 'env' the value of integer RC env variable 'rcenv' on node 'ord'
Get into 'env' the value of double RC env variable 'rcenv' on node 'ord'
Get into 'env' the value of string RC env variable 'rcenv' on node 'ord'
Transfer the current state of the master to the active slave servers. The current state includes: the current working directory, etc. Returns the number of active slaves. Returns -1 in case of error.
Transfer the current state of the master to the active slave servers. The current state includes: the current working directory, etc. Returns the number of active slaves. Returns -1 in case of error.
Transfer the initial (i.e. current) state of the master to all slave servers. Currently the initial state includes: log level. Returns the number of active slaves. Returns -1 in case of error.
Check if a file needs to be send to the slave. Use the following algorithm: - check if file appears in file map - if yes, get file's modtime and check against time in map, if modtime not same get md5 and compare against md5 in map, if not same return kTRUE. - if no, get file's md5 and modtime and store in file map, ask slave if file exists with specific md5, if yes return kFALSE, if no return kTRUE. The options 'cpopt' define if to copy things from cache to sandbox and what. To retrieve from the cache the binaries associated with the file TProof::kCpBin must be set in cpopt; the default is copy everything. Returns kTRUE in case file needs to be send, returns kFALSE in case file is already on remote node.
Send a file to master or slave servers. Returns number of slaves the file was sent to, maybe 0 in case master and slaves have the same file system image, -1 in case of error. If defined, send to worker 'wrk' only. If defined, the full path of the remote path will be rfile. If rfile = "cache" the file is copied to the remote cache instead of the sandbox (to copy to the cache on a different name use rfile = "cache:newname"). The mask 'opt' is an or of ESendFileOpt: kAscii (0x0) if set true ascii file transfer is used kBinary (0x1) if set true binary file transfer is used kForce (0x2) if not set an attempt is done to find out whether the file really needs to be downloaded (a valid copy may already exist in the cache from a previous run); the bit is set by UploadPackage, since the check is done elsewhere. kForward (0x4) if set, ask server to forward the file to slave or submaster (meaningless for slave servers). kCpBin (0x8) Retrieve from the cache the binaries associated with the file kCp (0x10) Retrieve the files from the cache
Sends a string to master and workers and expect them to echo it back to the client via a message. It is a special case of the generic Echo() that works with TObjects. Returns -1 on error, the number of workers that received the message on success.
Send object to master or slave servers. Returns number of slaves object was sent to, -1 in case of error.
Send print command to master server. Returns number of slaves message was sent to. Returns -1 in case of error.
Switch ON/OFF the real-time logging facility. When this option is ON, log messages from processing are sent back as they come, instead of being sent back at the end in one go. This may help debugging or monitoring in some cases, but, depending on the amount of log, it may have significant consequencies on the load over the network, so it must be used with care.
Tell PROOF how many slaves to use in parallel. If random is TRUE a random selection is done (if nodes is less than the available nodes). Returns the number of parallel slaves. Returns -1 in case of error.
Tell PROOF how many slaves to use in parallel. Returns the number of parallel slaves. Returns -1 in case of error.
Add nWorkersToAdd workers to current list of workers. This function is
works on the master only, and only when an analysis is ongoing. A message
is sent back to the client when we go "more" parallel.
Returns -1 on error, number of total (not added!) workers on success.
Go in parallel mode with at most "nodes" slaves. Since the fSlaves list is sorted by slave performace the active list will contain first the most performant nodes. Returns the number of active slaves. If random is TRUE, and nodes is less than the number of available workers, a random selection is done. Returns -1 in case of error.
List contents of the data directory in the sandbox. This is the place where files produced by the client queries are kept
Remove files for the data directory. The option 'what' can take the values: kPurge remove all files and directories under '~/data' kUnregistered remove only files not in registered datasets (default) kDataset remove files belonging to dataset 'dsname' User is prompt for confirmation, unless kForceClear is ORed with the option
List contents of file cache. If all is true show all caches also on slaves. If everything is ok all caches are to be the same.
Remove file from all file caches. If file is 0 or "" or "*", remove all the files
Exec system command 'cmd'. If fdout > -1, append the output to fdout.
List which packages are enabled. If all is true show enabled packages for all active slaves. If everything is ok all active slaves should have the same packages enabled.
Remove a specific package. Returns 0 in case of success and -1 in case of error.
Remove a specific package. Returns 0 in case of success and -1 in case of error.
Remove a specific package 'pack' from the client. Returns 0 in case of success and -1 in case of error.
Build specified package. Executes the PROOF-INF/BUILD.sh script if it exists on all unique nodes. If opt is kBuildOnSlavesNoWait then submit build command to slaves, but don't wait for results. If opt is kCollectBuildResults then collect result from slaves. To be used on the master. If opt = kBuildAll (default) then submit and wait for results (to be used on the client). Returns 0 in case of success and -1 in case of error.
Build specified package on the client. Executes the PROOF-INF/BUILD.sh script if it exists on the client. If opt == 0, both the preparation and building phases are run. If opt == 1, only the preparation phase (asserting and, eventually, downloading of the package) is done; '*path' contains the full path to the package to be passed in the next call If opt == 2, only the building phase is run using *path . Returns 0 in case of success and -1 in case of error. The code is equivalent to the one in TProofServ.cxx (TProof::kBuildPackage case). Keep in sync in case of changes.
Load specified package. Executes the PROOF-INF/SETUP.C script on all active nodes. If notOnClient = true, don't load package on the client. The default is to load the package also on the client. The argument 'loadopts' specify a list of objects to be passed to the SETUP. The objects in the list must be streamable; the SETUP macro will be executed like this: SETUP.C(loadopts). Returns 0 in case of success and -1 in case of error.
Load specified package in the client. Executes the PROOF-INF/SETUP.C script on the client. Returns 0 in case of success and -1 in case of error. The code is equivalent to the one in TProofServ.cxx (TProof::kLoadPackage case). Keep in sync in case of changes. The argument 'loadopts' specify a list of objects to be passed to the SETUP. The objects in the list must be streamable; the SETUP macro will be executed like this: SETUP.C(loadopts). Returns 0 in case of success and -1 in case of error.
Unload specified package. Returns 0 in case of success and -1 in case of error.
Unload a specific package on the client. Returns 0 in case of success and -1 in case of error. The code is equivalent to the one in TProofServ.cxx (TProof::UnloadPackage case). Keep in sync in case of changes.
Enable specified package. Executes the PROOF-INF/BUILD.sh script if it exists followed by the PROOF-INF/SETUP.C script. In case notOnClient = true, don't enable the package on the client. The default is to enable packages also on the client. If specified, enables packages only on the specified workers. Returns 0 in case of success and -1 in case of error. Provided for backward compatibility.
Enable specified package. Executes the PROOF-INF/BUILD.sh script if it exists followed by the PROOF-INF/SETUP.C script. In case notOnClient = true, don't enable the package on the client. The default is to enable packages also on the client. It is is possible to specify options for the loading step via 'loadopts'; the string will be passed passed as argument to SETUP. Special option 'chkv=<o>' (or 'checkversion=<o>') can be used to control plugin version checking during building: possible choices are: off no check; failure may occur at loading on check ROOT version [default] svn check ROOT version and SVN revision number. (Use ';', ' ' or '|' to separate 'chkv=<o>' from the rest.) If specified, enables packages only on the specified workers. Returns 0 in case of success and -1 in case of error.
Enable specified package. Executes the PROOF-INF/BUILD.sh script if it exists followed by the PROOF-INF/SETUP.C script. In case notOnClient = true, don't enable the package on the client. The default is to enable packages also on the client. It is is possible to specify a list of objects to be passed to the SETUP functions via 'loadopts'; the objects must be streamable. Returns 0 in case of success and -1 in case of error.
Download a PROOF archive (PAR file) from the master package repository. The PAR file is downloaded in the current directory or in the directory specified by 'dstdir'. If a package with the same name already exists at destination, a check on the MD5 sum is done and the user warned or prompted for action, depending is the file is equal or different. Returns 0 in case of success and -1 in case of error.
Upload a PROOF archive (PAR file). A PAR file is a compressed tar file with one special additional directory, PROOF-INF (blatantly copied from Java's jar format). It must have the extension .par. A PAR file can be directly a binary or a source with a build procedure. In the PROOF-INF directory there can be a build script: BUILD.sh to be called to build the package, in case of a binary PAR file don't specify a build script or make it a no-op. Then there is SETUP.C which sets the right environment variables to use the package, like LD_LIBRARY_PATH, etc. The 'opt' allows to specify whether the .PAR should be just unpacked in the existing dir (opt = kUntar, default) or a remove of the existing directory should be executed (opt = kRemoveOld), so triggering a full re-build. The option if effective only for PROOF protocol > 8 . The lab 'dirlab' (e.g. 'G0') indicates that the package is to uploaded to an alternative global directory for global usage. This may require special privileges. If download is kTRUE and the package is not found locally, then it is downloaded from the master repository. Returns 0 in case of success and -1 in case of error.
Upload a package on the client in ~/.proof/packages. The 'opt' allows to specify whether the .PAR should be just unpacked in the existing dir (opt = kUntar, default) or a remove of the existing directory should be executed (opt = kRemoveOld), thereby triggering a full re-build. This option if effective only for PROOF protocol > 8. Returns 0 in case of success and -1 in case of error.
Load the specified macro on master, workers and, if notOnClient is kFALSE, on the client. The macro file is uploaded if new or updated. Additional files to be uploaded (or updated, if needed) can be specified after a comma, e.g. "mymacro.C+,thisheader.h,thatheader.h". If existing in the same directory, a header basename(macro).h or .hh, is also uploaded. The default is to load the macro also on the client; notOnClient can be used to avoid loading on the client. On masters, if uniqueWorkers is kTRUE, the macro is loaded on unique workers only, and collection is not done; if uniqueWorkers is kFALSE, collection from the previous request is done, and broadcasting + collection from the other workers is done. The wrks arg can be used on the master to limit the set of workers. Returns 0 in case of success and -1 in case of error.
Add 'libpath' to the lib path search. Multiple paths can be specified at once separating them with a comma or a blank. Return 0 on success, -1 otherwise
Add 'incpath' to the inc path search. Multiple paths can be specified at once separating them with a comma or a blank. Return 0 on success, -1 otherwise
Remove 'libpath' from the lib path search. Multiple paths can be specified at once separating them with a comma or a blank. Return 0 on success, -1 otherwise
Remove 'incpath' from the inc path search. Multiple paths can be specified at once separating them with a comma or a blank. Return 0 on success, -1 otherwise
Handle lib, inc search paths modification request
Print a progress bar on stderr. Used in batch mode.
Get query progress information. Connect a slot to this signal to track progress.
Get query progress information. Connect a slot to this signal to track progress.
Get query progress information. Connect a slot to this signal to track progress.
Get list of feedback objects. Connect a slot to this signal to monitor the feedback object.
Reset progress dialog.
Send dataset preparation status.
Send or notify data set status
Add data objects that might be needed during the processing of the selector (see Process()). This object can be very large, so they are distributed in an optimized way using a dedicated file. If push is TRUE the input data are sent over even if no apparent change occured to the list.
Remove obj form the input data list; if obj is null (default), clear the input data info.
Set the file to be used to optimally distribute the input data objects. If the file exists the object in the file are added to those in the fInputData list. If the file path is null, a default file will be created at the moment of sending the processing request with the content of the fInputData list. See also SendInputDataFile.
Send the input data objects to the master; the objects are taken from the dedicated list and / or the specified file. If the fInputData is empty the specified file is sent over. If there is no specified file, a file named "inputdata.root" is created locally with the content of fInputData and sent over to the master. If both fInputData and the specified file are not empty, a copy of the file is made locally and augmented with the content of fInputData.
Prepare the file with the input data objects to be sent the master; the objects are taken from the dedicated list and / or the specified file. If the fInputData is empty the specified file is sent over. If there is no specified file, a file named "inputdata.root" is created locally with the content of fInputData and sent over to the master. If both fInputData and the specified file are not empty, a copy of the file is made locally and augmented with the content of fInputData.
Add objects that might be needed during the processing of the selector (see Process()).
Get specified object that has been produced during the processing (see Process()).
Find object 'name' in list 'out' or in the files specified in there
Set input list parameter. If the parameter is already set it will be set to the new value.
Get specified parameter. A parameter set via SetParameter() is either a TParameter or a TNamed or 0 in case par is not defined.
Delete the input list parameters specified by a wildcard (e.g. PROOF_*) or exact name (e.g. PROOF_MaxSlavesPerNode).
Show the input list parameters specified by the wildcard. Default is the special PROOF control parameters (PROOF_*).
Creates a tree header (a tree with nonexisting files) object for the DataSet.
Construct a TProofPlayer object. The player string specifies which player should be created: remote, slave, sm (supermaster) or base. Default is remote. Socket is needed in case a slave player is created.
Ask for remote logs in the range [start, end]. If start == -1 all the messages not yet received are sent back.
Display on screen the content of the temporary log file for query in reference
Display on screen the content of the temporary log file. If qry == -2 show messages from the last (current) query. If qry == -1 all the messages not yet displayed are shown (default). If qry == 0, all the messages in the file are shown. If qry > 0, only the messages related to query 'qry' are shown. For qry != -1 the original file offset is restored at the end
Set session with 'id' the default one. If 'id' is not found in the list, the current session is set as default
Detach this instance to its proofserv. If opt is 'S' or 's' the remote server is shutdown
Set an alias for this session. If reconnection is supported, the alias will be communicated to the remote coordinator so that it can be recovered when reconnecting
*** This function is deprecated and will disappear in future versions *** *** It is just a wrapper around TFile::Cp. *** Please use TProofMgr::UploadFiles. Upload a set of files and save the list of files by name dataSetName. The 'files' argument is a list of TFileInfo objects describing the files as first url. The mask 'opt' is a combination of EUploadOpt: kAppend (0x1) if set true files will be appended to the dataset existing by given name kOverwriteDataSet (0x2) if dataset with given name exited it would be overwritten kNoOverwriteDataSet (0x4) do not overwirte if the dataset exists kOverwriteAllFiles (0x8) overwrite all files that may exist kOverwriteNoFiles (0x10) overwrite none kAskUser (0x0) ask user before overwriteng dataset/files The default value is kAskUser. The user will be asked to confirm overwriting dataset or files unless specified opt provides the answer! If kOverwriteNoFiles is set, then a pointer to TList must be passed as skippedFiles argument. The function will add to this list TFileInfo objects describing all files that existed on the cluster and were not uploaded. Communication Summary Client Master |------------>DataSetName----------->| |<-------kMESS_OK/kMESS_NOTOK<-------| (Name OK/file exist) (*)|-------> call RegisterDataSet ------->| (*) - optional
*** This function is deprecated and will disappear in future versions *** *** It is just a wrapper around TFile::Cp. *** Please use TProofMgr::UploadFiles. Upload a set of files and save the list of files by name dataSetName. The mask 'opt' is a combination of EUploadOpt: kAppend (0x1) if set true files will be appended to the dataset existing by given name kOverwriteDataSet (0x2) if dataset with given name exited it would be overwritten kNoOverwriteDataSet (0x4) do not overwirte if the dataset exists kOverwriteAllFiles (0x8) overwrite all files that may exist kOverwriteNoFiles (0x10) overwrite none kAskUser (0x0) ask user before overwriteng dataset/files The default value is kAskUser. The user will be asked to confirm overwriting dataset or files unless specified opt provides the answer! If kOverwriteNoFiles is set, then a pointer to TList must be passed as skippedFiles argument. The function will add to this list TFileInfo objects describing all files that existed on the cluster and were not uploaded.
*** This function is deprecated and will disappear in future versions *** *** It is just a wrapper around TFile::Cp. *** Please use TProofMgr::UploadFiles. Upload files listed in "file" to PROOF cluster. Where file = name of file containing list of files and dataset = dataset name and opt is a combination of EUploadOpt bits. Each file description (line) can include wildcards. Check TFileInfo compatibility
Register the 'dataSet' on the cluster under the current user, group and the given 'dataSetName'. If a dataset with the same name already exists the action fails unless 'opts' contains 'O', in which case the old dataset is overwritten, or contains 'U', in which case 'newDataSet' is added to the existing dataset (duplications are ignored, if any). If 'opts' contains 'V' the dataset files are also verified (if the dataset manager is configured to allow so). By default the dataset is not verified. If 'opts' contains 'T' the in the dataset object (status bits, meta,...) is trusted, i.e. not reset (if the dataset manager is configured to allow so). If 'opts' contains 'S' validation would be run serially (meaningful only if validation is required). Returns kTRUE on success.
Set/Change the name of the default tree. The tree name may contain
subdir specification in the form "subdir/name".
Returns 0 on success, -1 otherwise.
Lists all datasets that match given uri. The 'optStr' can contain a comma-separated list of servers for which the information is wanted. If ':lite:' (case insensitive) is specified in 'optStr' only the global information in the TFileCollection is retrieved; useful to only get the list of available datasets.
Shows datasets in locations that match the uri. By default shows the user's datasets and global ones
Clear the content of the dataset cache, if any (matching 'dataset', if defined).
Display the content of the dataset cache, if any (matching 'dataset', if defined).
Get a list of TFileInfo objects describing the files of the specified dataset. To get the short version (containing only the global meta information) specify optStr = "S:" or optStr = "short:". To get the sub-dataset of files located on a given server(s) specify the list of servers (comma-separated) in the 'optStr' field.
display meta-info for given dataset usi
Remove the specified dataset from the PROOF cluster. Files are not deleted.
Find datasets, returns in a TList all found datasets.
Allows users to request staging of a particular dataset. Requests are saved in a special dataset repository and must be honored by the endpoint.
Obtains a TFileCollection showing the staging status of the specified dataset. A valid dataset manager and dataset staging requests repository must be present on the endpoint.
Like GetStagingStatusDataSet, but displays results immediately.
Verify if all files in the specified dataset are available. Print a list and return the number of missing files. Returns -1 in case of error.
Internal function for parallel dataset verification used TProof::VerifyDataSet and TProofLite::VerifyDataSet
shows the quota and usage of all groups
if opt contains "U" shows also distribution of usage on user-level
Make sure that the worker identified by the ordinal number 'ord' is
in the active list. The request will be forwarded to the master
in direct contact with the worker. If needed, this master will move
the worker from the inactive to the active list and rebuild the list
of unique workers.
Use ord = "*" to activate all inactive workers.
The string 'ord' can also be a comma-separated list of ordinal numbers the
status of which will be modified at once.
Return <0 if something went wrong (-2 if at least one worker was not found)
or the number of workers with status change (on master; 0 on client).
Remove the worker identified by the ordinal number 'ord' from the the active list. The request will be forwarded to the master in direct contact with the worker. If needed, this master will move the worker from the active to the inactive list and rebuild the list of unique workers. Use ord = "*" to deactivate all active workers. The string 'ord' can also be a comma-separated list of ordinal numbers the status of which will be modified at once. Return <0 if something went wrong (-2 if at least one worker was not found) or the number of workers with status change (on master; 0 on client).
Modify the worker active/inactive list by making the worker identified by the ordinal number 'ord' active (add == TRUE) or inactive (add == FALSE). The string 'ord' can also be a comma-separated list of ordinal numbers the status of which will be modified at once. If needed, the request will be forwarded to the master in direct contact with the worker. The end-master will move the worker from one list to the other active and rebuild the list of unique active workers. Use ord = "*" to deactivate all active workers. If save is TRUE the current active list is saved before any modification is done; re-running with ord = "restore" restores the saved list Return <0 if something went wrong (-2 if at least one worker was not found) or the number of workers with status change (on master; 0 on client).
Start a PROOF session on a specific cluster. If cluster is 0 (the default) then the PROOF Session Viewer GUI pops up and 0 is returned. If cluster is "lite://" we start a PROOF-lite session. If cluster is "" (empty string) then we connect to the cluster specified by 'Proof.LocalDefault', defaulting to "lite://". If cluster is "pod://" (case insensitive), then we connect to a PROOF cluster managed by PROOF on Demand (PoD, http://pod.gsi.de ). Via conffile a specific PROOF config file in the confir directory can be specified. Use loglevel to set the default loging level for debugging. The appropriate instance of TProofMgr is created, if not yet existing. The instantiated TProof object is returned. Use TProof::cd() to switch between PROOF sessions. For more info on PROOF see the TProof ctor.
Get instance of the effective manager for 'url' Return 0 on failure.
Add an variable to the list of environment variables passed to proofserv on the master and slaves
Remove an variable from the list of environment variables passed to proofserv on the master and slaves
Clear the list of environment variables passed to proofserv on the master and slaves
Get the value from the specified parameter from the specified collection. Returns -1 in case of error (i.e. list is 0, parameter does not exist or value type does not match), 0 otherwise.
Get the value from the specified parameter from the specified collection. Returns -1 in case of error (i.e. list is 0, parameter does not exist or value type does not match), 0 otherwise.
Get the value from the specified parameter from the specified collection. Returns -1 in case of error (i.e. list is 0, parameter does not exist or value type does not match), 0 otherwise.
Get the value from the specified parameter from the specified collection. Returns -1 in case of error (i.e. list is 0, parameter does not exist or value type does not match), 0 otherwise.
Get the value from the specified parameter from the specified collection. Returns -1 in case of error (i.e. list is 0, parameter does not exist or value type does not match), 0 otherwise.
Make sure that dataset is in the form to be processed. This may mean retrieving the relevant info from the dataset manager or from the attached input list. Returns 0 on success, -1 on error
Save input data file from 'cachedir' into the sandbox or create a the file with input data objects
Send the input data file to the workers
Get the input data from the file defined in the input list
Start the log viewer window usign the plugin manager
Enable/Disable the graphic progress dialog. By default the dialog is enabled
Show information about missing files during query described by 'qr' or the last query if qr is null (default). A short summary is printed in the end.
Get a TFileCollection with the files missing in the query described by 'qr' or the last query if qr is null (default). Return a null pointer if none were found, for whatever reason. The caller is responsible for the returned object.
Enable/Disable saving of the performance tree
Save performance information from TPerfStats to file 'pf'. If 'ref' is defined, do it for query 'ref'. Return 0 on sucecss, -1 in case of any error