library: libProof #include "TProof.h" |
TProof
class description - header file - source file
viewCVS header - viewCVS source
class TProof: public TNamed, public TQObject
Function Members (Methods)
Display options:
public:
| 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 |
void | ActivateWorker(const char* ord) |
void | AddChain(TChain* chain) |
Int_t | AddDynamicPath(const char* libpath) |
static void | AddEnvVar(const char* name, const char* value) |
void | AddFeedback(const char* name) |
Int_t | AddIncludePath(const char* incpath) |
void | AddInput(TObject* obj) |
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") |
virtual void | Browse(TBrowser* b) |
void | cd(Int_t id = -1) |
virtual void | TQObject::ChangedBy(const char* method) |
static TClass* | Class() |
virtual const char* | TObject::ClassName() const |
Int_t | CleanupSession(const char* sessiontag) |
virtual void | TNamed::Clear(Option_t* option = "") |
void | ClearCache() |
void | ClearFeedback() |
void | ClearInput() |
Int_t | ClearPackage(const char* package) |
Int_t | ClearPackages() |
virtual TObject* | TNamed::Clone(const char* newname = "") const |
void | Close(Option_t* option = "") |
void | CloseProgressDialog() |
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 |
Int_t | CreateDataSet(const char* dataset, TList* files, Int_t opt = kAskUser) |
TDrawFeedback* | CreateDrawFeedback() |
void | DataSetStatus(const char* msg, Bool_t status, Int_t done, Int_t total) |
void | DeactivateWorker(const char* ord) |
static void | DelEnvVar(const char* name) |
virtual void | TObject::Delete(Option_t* option = "") |
void | DeleteDrawFeedback(TDrawFeedback* f) |
void | DeleteParameters(const char* wildcard) |
virtual void | TQObject::Destroyed() |
void | Detach(Option_t* opt = "") |
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) |
virtual void | TObject::Draw(Option_t* option = "") |
virtual void | TObject::DrawClass() const |
virtual TObject* | TObject::DrawClone(Option_t* option = "") const |
Long64_t | DrawSelect(TDSet* set, const char* varexp, const char* selection = "", Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0) |
virtual void | TObject::Dump() const |
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) |
virtual void | TObject::Error(const char* method, const char* msgfmt) const |
Int_t | Exec(const char* cmd, Bool_t plusMaster = 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 void | TObject::Fatal(const char* method, const char* msgfmt) const |
void | Feedback(TList* objs) |
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) |
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 |
TList* | GetDataSet(const char* dataset) |
TList* | GetDataSets(const char* dir = "0") |
virtual Option_t* | TObject::GetDrawOption() const |
static Long_t | TObject::GetDtorOnly() |
static const TList* | GetEnvVars() |
TList* | GetFeedbackList() const |
virtual const char* | TObject::GetIconName() const |
const char* | GetImage() const |
TList* | TQObject::GetListOfClassSignals() const |
TList* | TQObject::GetListOfConnections() const |
TList* | GetListOfEnabledPackages() |
TList* | GetListOfPackages() |
TList* | GetListOfQueries(Option_t* opt = "") |
TList* | TQObject::GetListOfSignals() const |
void | GetLog(Int_t start = -1, Int_t end = -1) |
Int_t | GetLogLevel() const |
TProofMgr* | GetManager() |
const char* | GetMaster() const |
void | GetMaxQueries() |
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) |
TList* | GetOutputList() |
TList* | GetOutputNames() |
Int_t | GetParallel() const |
TObject* | GetParameter(const char* par) const |
Int_t | GetPort() const |
TProof::EQueryMode | GetQueryMode() const |
TProof::EQueryMode | GetQueryMode(Option_t* mode) const |
TQueryResult* | GetQueryResult(const char* ref = "0") |
TList* | GetQueryResults() |
Float_t | GetRealTime() const |
Int_t | GetRemoteProtocol() const |
Int_t | GetSessionID() const |
const char* | GetSessionTag() const |
TList* | GetSlaveInfo() |
Int_t | GetStatus() const |
virtual const char* | TNamed::GetTitle() const |
TTree* | GetTreeHeader(TDSet* tdset) |
virtual UInt_t | TObject::GetUniqueID() const |
const char* | GetUrl() |
const char* | GetUser() const |
const char* | GetWorkDir() const |
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() const |
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 | IsMaster() const |
Bool_t | TObject::IsOnHeap() const |
Bool_t | IsParallel() const |
Bool_t | IsProofd() const |
virtual Bool_t | TNamed::IsSortable() const |
Bool_t | IsValid() const |
Bool_t | TObject::IsZombie() const |
static void | TQObject::LoadRQ_OBJECT() |
void | LogMessage(const char* msg, Bool_t all) |
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) |
static TProofMgr* | Mgr(const char* url) |
virtual Bool_t | TObject::Notify() |
virtual Int_t | TQObject::NumberOfConnections() const |
virtual Int_t | TQObject::NumberOfSignals() 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 |
Long64_t | Process(TDSet* set, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0, TEventList* evl = 0) |
void | Progress(Long64_t total, Long64_t processed) |
void | Progress(Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti) |
void | PutLog(TQueryResult* qr) |
void | QueryResultReady(const char* ref) |
virtual Int_t | TObject::Read(const char* name) |
virtual void | TObject::RecursiveRemove(TObject* obj) |
Int_t | Remove(Int_t query, Bool_t all = kFALSE) |
Int_t | Remove(const char* queryref, Bool_t all = kFALSE) |
void | RemoveChain(TChain* chain) |
Int_t | RemoveDataSet(const char* dateset) |
Int_t | RemoveDynamicPath(const char* libpath) |
void | RemoveFeedback(const char* name) |
Int_t | RemoveIncludePath(const char* incpath) |
static void | Reset(const char* url) |
void | TObject::ResetBit(UInt_t f) |
static void | ResetEnvVars() |
void | ResetProgressDialog(const char* sel, Int_t sz, Long64_t fst, Long64_t ent) |
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 = "") const |
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) |
void | SetDrawFeedbackOption(TDrawFeedback* f, Option_t* opt) |
virtual void | TObject::SetDrawOption(Option_t* option = "") |
static void | TObject::SetDtorOnly(void* obj) |
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) |
virtual void | TNamed::SetNameTitle(const char* name, const char* title) |
static void | TObject::SetObjectStat(Bool_t stat) |
Int_t | SetParallel(Int_t nodes = 9999) |
void | SetParameter(const char* par, const char* 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 | SetQueryMode(TProof::EQueryMode mode) |
void | SetQueryType(TProof::EQueryMode mode) |
virtual void | TNamed::SetTitle(const char* title = "") |
virtual void | TObject::SetUniqueID(UInt_t uid) |
void | ShowCache(Bool_t all = kFALSE) |
void | ShowDataSet(const char* dataset) |
void | ShowDataSets(const char* dir = "0") |
void | ShowEnabledPackages(Bool_t all = kFALSE) |
void | ShowFeedback() const |
void | ShowLog(Int_t qry = -1) |
void | ShowLog(const char* queryref) |
virtual void | ShowMembers(TMemberInspector& insp, char* parent) |
void | ShowPackages(Bool_t all = kFALSE) |
void | ShowParameters(const char* wildcard = "PROOF_*") const |
void | ShowQueries(Option_t* opt = "") |
virtual Int_t | TNamed::Sizeof() const |
void | StartupMessage(const char* msg, Bool_t status, Int_t done, Int_t total) |
void | StopProcess(Bool_t abort, Int_t timeout = -1) |
virtual void | Streamer(TBuffer& b) |
void | StreamerNVirtual(TBuffer& 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 |
Int_t | UploadDataSet(const char* dataset, TList* files, const char* dest = "0", Int_t opt = kAskUser, TList* skippedFiles = 0) |
Int_t | UploadDataSet(const char* dataset, const char* files, const char* dest = "0", Int_t opt = kAskUser, TList* skippedFiles = 0) |
Int_t | UploadDataSetFromFile(const char* dataset, const char* file, const char* dest = "0", Int_t opt = kAskUser) |
Int_t | UploadPackage(const char* par, TProof::EUploadPackageOpt opt = kUntar) |
virtual void | TObject::UseCurrentStyle() |
Int_t | VerifyDataSet(const char* dataset) |
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 |
protected:
| TProof() |
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 | Collect(TList* slaves, Long_t timeout = -1) |
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* | GetListOfActiveSlaves() const |
TProofPlayer* | GetPlayer() const |
TPluginHandler* | GetProgressDialog() const |
virtual void* | TQObject::GetSender() |
virtual const char* | TQObject::GetSenderClassName() const |
Int_t | Init(const char* masterurl, const char* conffile, const char* confdir, Int_t loglevel, const char* alias = "0") |
virtual TProofPlayer* | MakePlayer() |
void | TObject::MakeZombie() |
virtual void | SaveWorkerInfo() |
void | SetDSet(TDSet* dset) |
void | SetPlayer(TProofPlayer* player) |
static void* | SlaveStartupThread(void* arg) |
virtual Bool_t | StartSlaves(Bool_t parallel, Bool_t attach = kFALSE) |
virtual void | ValidateDSet(TDSet* dset) |
private:
| TProof(const TProof&) |
void | Activate(TList* slaves = 0) |
void | ActivateAsyncInput() |
void | AskParallel() |
void | AskStatistics() |
Int_t | Broadcast(const TMessage& mess, TList* slaves) |
Int_t | Broadcast(const TMessage& mess, TProof::ESlaves list = kActive) |
Int_t | Broadcast(Int_t kind, TList* slaves) |
Int_t | Broadcast(Int_t kind, TProof::ESlaves list = kActive) |
Int_t | Broadcast(const char* mess, Int_t kind, TList* slaves) |
Int_t | Broadcast(const char* mess, Int_t kind = kMESS_STRING, TProof::ESlaves list = kActive) |
Int_t | BroadcastObject(const TObject* obj, Int_t kind, TList* slaves) |
Int_t | BroadcastObject(const TObject* obj, Int_t kind = kMESS_OBJECT, TProof::ESlaves list = kActive) |
Int_t | BroadcastRaw(const void* buffer, Int_t length, TList* slaves) |
Int_t | BroadcastRaw(const void* buffer, Int_t length, TProof::ESlaves list = kActive) |
Int_t | BuildPackage(const char* package, TProof::EBuildPackageOpt opt = kBuildAll) |
Int_t | BuildPackageOnClient(const TString& package) |
Bool_t | CheckFile(const char* file, TSlave* sl, Long_t modtime) |
void | CleanGDirectory(TList* ol) |
Int_t | Collect(const TSlave* sl, Long_t timeout = -1) |
Int_t | Collect(TMonitor* mon, Long_t timeout = -1) |
Int_t | CollectInputFrom(TSocket* s) |
void | DeActivateAsyncInput() |
Int_t | DisablePackage(const char* package) |
Int_t | DisablePackages() |
Int_t | Exec(const char* cmd, TProof::ESlaves list, Bool_t plusMaster) |
TSlave* | FindSlave(TSocket* s) const |
void | FindUniqueSlaves() |
TList* | GetListOfBadSlaves() const |
TList* | GetListOfInactiveSlaves() const |
TList* | GetListOfSlaves() const |
TList* | GetListOfUniqueSlaves() const |
Int_t | GetNumberOfActiveSlaves() const |
Int_t | GetNumberOfBadSlaves() const |
Int_t | GetNumberOfInactiveSlaves() const |
Int_t | GetNumberOfSlaves() const |
Int_t | GetNumberOfUniqueSlaves() const |
Int_t | GetQueryReference(Int_t qry, TString& ref) |
Int_t | GoParallel(Int_t nodes, Bool_t accept = kFALSE) |
void | HandleAsyncInput(TSocket* s) |
void | Interrupt(TProof::EUrgent type, TProof::ESlaves list = kActive) |
void | InterruptCurrentMonitor() |
Bool_t | IsEndMaster() const |
Bool_t | IsSync() const |
Int_t | LoadPackage(const char* package, Bool_t notOnClient = kFALSE) |
Int_t | LoadPackageOnClient(const TString& package) |
void | MarkBad(TSlave* sl) |
void | MarkBad(TSocket* s) |
void | ModifyWorkerLists(const char* ord, Bool_t add) |
void | operator=(const TProof&) |
Int_t | Ping(TProof::ESlaves list) |
void | RecvLogFile(TSocket* s, Int_t size) |
Int_t | SendCommand(const char* cmd, TProof::ESlaves list = kActive) |
Int_t | SendCurrentState(TProof::ESlaves list = kActive) |
Int_t | SendFile(const char* file, Int_t opt = (kBinary|kForward), const char* rfile = "0", TSlave* sl = 0) |
Int_t | SendGroupView() |
Int_t | SendInitialState() |
Int_t | SendObject(const TObject* obj, TProof::ESlaves list = kActive) |
Int_t | SendPrint(Option_t* option = "") |
Int_t | SetParallelSilent(Int_t nodes) |
Int_t | UnloadPackage(const char* package) |
Int_t | UnloadPackages() |
Int_t | UploadPackageOnClient(const TString& package, TProof::EUploadPackageOpt opt, TMD5* md5) |
Data Members
public:
enum EStatusBits { | kUsingSessionGui | |
}; | | |
enum EQueryMode { | kSync | |
| kAsync | |
}; | | |
enum EUploadOpt { | kAppend | |
| kOverwriteDataSet | |
| kNoOverwriteDataSet | |
| kOverwriteAllFiles | |
| kOverwriteNoFiles | |
| kAskUser | |
}; | | |
enum EUploadDataSetAnswer { | kError | |
| kDataSetExists | |
}; | | |
enum EUploadPackageOpt { | kUntar | |
| kRemoveOld | |
}; | | |
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 | |
}; | | |
enum EProofDataSetCommands { | kUploadDataSet | |
| kCheckDataSetName | |
| kGetDataSets | |
| kCreateDataSet | |
| kGetDataSet | |
| kVerifyDataSet | |
| kRemoveDataSet | |
| kAppendDataSet | |
}; | | |
enum ESendFileOpt { | kAscii | |
| kBinary | |
| kForce | |
| kForward | |
}; | | |
enum EProofWrkListAction { | kActivateWorker | |
| kDeactivateWorker | |
}; | | |
enum EBuildPackageOpt { | kDontBuildOnClient | |
| kBuildOnSlavesNoWait | |
| kBuildAll | |
| kCollectBuildResults | |
}; | | |
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 | |
}; | | |
protected:
TUrl | fUrl | Url of the master |
TString | fConfFile | file containing config information |
TString | fConfDir | directory containing cluster config information |
TString | fImage | master's image name |
Int_t | fProtocol | remote PROOF server protocol version number |
TList* | fSlaves | list of all slave servers as in config file |
TList* | fBadSlaves | dead slaves (subset of all slaves) |
TMonitor* | fAllMonitor | monitor activity on all valid slave sockets |
Bool_t | fDataReady | true if data is ready to be analyzed |
Long64_t | fBytesReady | number of bytes staged |
Long64_t | fTotalBytes | number of bytes to be analyzed |
TList* | fAvailablePackages | list of available packages |
TList* | fEnabledPackages | list of enabled packages |
TString | fDataPoolUrl | default data pool entry point URL |
TProofMgr::EServType | fServType | type of server: proofd, XrdProofd |
TProofMgr* | fManager | manager to which this session belongs (if any) |
TProof::EQueryMode | fQueryMode | default query mode |
static TSemaphore* | fgSemaphore | semaphore to control no of parallel startup threads |
TString | TNamed::fName | object identifier |
TString | TNamed::fTitle | object title |
TList* | TQObject::fListOfSignals | ! list of signals from this object |
TList* | TQObject::fListOfConnections | ! list of connections to this object |
private:
Bool_t | fValid | is this a valid proof object |
TString | fMaster | master server ("" if a master); used in the browser |
TString | fWorkDir | current work directory on remote servers |
Int_t | fLogLevel | server debug logging level |
Int_t | fStatus | remote return status (part of kPROOF_LOGDONE) |
TList* | fSlaveInfo | !list returned by kPROOF_GETSLAVEINFO |
Bool_t | fMasterServ | true if we are a master server |
Bool_t | fSendGroupView | if true send new group view |
TList* | fActiveSlaves | list of active slaves (subset of all slaves) |
TList* | fInactiveSlaves | list of inactive slaves (good but not used for processing) |
TList* | fUniqueSlaves | list of all active slaves with unique file systems |
TList* | fAllUniqueSlaves | list of all active slaves with unique file systems, including all submasters |
TList* | fNonUniqueMasters | list of all active masters with a nonunique file system |
TMonitor* | fActiveMonitor | monitor activity on all active slave sockets |
TMonitor* | fUniqueMonitor | monitor activity on all unique slave sockets |
TMonitor* | fAllUniqueMonitor | monitor activity on all unique slave sockets, including all submasters |
TMonitor* | fCurrentMonitor | currently active monitor |
Long64_t | fBytesRead | bytes read by all slaves during the session |
Float_t | fRealTime | realtime spent by all slaves during the session |
Float_t | fCpuTime | CPU time spent by all slaves during the session |
TSignalHandler* | fIntHandler | interrupt signal handler (ctrl-c) |
TPluginHandler* | fProgressDialog | progress dialog plugin |
Bool_t | fProgressDialogStarted | indicates if the progress dialog is up |
TProofPlayer* | fPlayer | current player |
TList* | fFeedback | list of names to be returned as feedback |
TList* | fChains | chains with this proof set |
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 |
TDSet* | fDSet | current TDSet being validated |
Bool_t | fIdle | on clients, true if no PROOF jobs running |
Bool_t | fSync | true if type of currently processed query is sync |
Bool_t | fRedirLog | redirect received log info |
TString | fLogFileName | name of the temp file for redirected logs |
FILE* | fLogFileW | temp file to redirect logs |
FILE* | fLogFileR | temp file to read redirected logs |
Bool_t | fLogToWindowOnly | send log to window only |
TList* | fWaitingSlaves | stores a TPair of the slaves's TSocket and TMessage |
TList* | fQueries | list of TProofQuery objects |
Int_t | fOtherQueries | number of queries in list from previous sessions |
Int_t | fDrawQueries | number of draw queries during this sessions |
Int_t | fMaxDrawQueries | max number of draw queries kept |
Int_t | fSeqNum | Remote sequential # of the last query submitted |
Int_t | fSessionID | remote ID of the session |
Bool_t | fEndMaster | true for a master in direct contact only with workers |
TString | fPackageDir | package directory (used on client) |
TProofLockPath* | fPackageLock | package lock |
TList* | fEnabledPackagesOnClient | list of packages enabled on client |
static TList* | fgProofEnvList | List of TNameds defining environment |
TProof
This class controls a Parallel ROOT Facility, PROOF, cluster.
It fires the slave servers, it keeps track of how many slaves are
running, it keeps track of the slaves running status, it broadcasts
messages to all slaves, it collects results, etc.
TProof(const char *masterurl, const char *conffile, const char *confdir, Int_t loglevel, const char *alias, TProofMgr *mgr)
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.
TProof()
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.
~TProof()
Clean up PROOF environment.
Int_t Init(const char *masterurl, const char *conffile, const char *confdir, Int_t loglevel, const char *alias)
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.
void SetManager(TProofMgr *mgr)
Set manager and schedule its destruction after this for clean
operations.
void Close(Option_t *opt)
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.
TSlave * CreateSlave(const char *url, const char *ord, Int_t perf, const char *image, const char *workdir)
Create a new TSlave of type TSlave::kSlave.
Note: creation of TSlave is private with TProof as a friend.
Derived classes must use this function to create slaves.
void FindUniqueSlaves()
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.
Int_t GetNumberOfBadSlaves()
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.
void AskParallel()
Ask the for the number of parallel slaves.
void GetMaxQueries()
Get max number of queries whose full results are kept in the
remote sandbox
void ShowQueries(Option_t *opt)
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 ""
void Interrupt(EUrgent type, ESlaves list)
Send interrupt OOB byte to master or slave servers.
Int_t GetParallel()
Returns number of slaves active in parallel mode. Returns 0 in case
there are no active slaves. Returns -1 in case of error.
TList * GetSlaveInfo()
Returns number of slaves active in parallel mode. Returns 0 in case
there are no active slaves. Returns -1 in case of error.
Int_t Broadcast(const TMessage &mess, TList *slaves)
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.
Int_t Broadcast(const TMessage &mess, ESlaves list)
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.
Int_t Broadcast(const char *str, Int_t kind, TList *slaves)
Broadcast a character string buffer 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.
Int_t Broadcast(const char *str, Int_t kind, ESlaves list)
Broadcast a character string buffer to all slaves in the specified
list (either all slaves or only the active slaves). Use kind to
set the TMessage what field. Returns the number of slaves the message
was sent to. Returns -1 in case of error.
Int_t BroadcastObject(const TObject *obj, Int_t kind, TList *slaves)
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.
Int_t BroadcastObject(const TObject *obj, Int_t kind, ESlaves list)
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.
Int_t BroadcastRaw(const void *buffer, Int_t length, TList *slaves)
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.
Int_t BroadcastRaw(const void *buffer, Int_t length, ESlaves list)
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.
Int_t Collect(const TSlave *sl, Long_t timeout)
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).
Int_t Collect(TList *slaves, Long_t timeout)
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).
Int_t Collect(ESlaves list, Long_t timeout)
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).
Int_t Collect(TMonitor *mon, Long_t timeout)
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).
void HandleAsyncInput(TSocket *sl)
Handle input coming from the master server (when this is a client)
or from a slave server (when this is a master server). This is mainly
for a-synchronous communication. Normally when PROOF issues a command
the (slave) server messages are directly handle by Collect().
void MarkBad(TSlave *sl)
Add a bad slave server to the bad slave list and remove it from
the active list and from the two monitor objects.
void MarkBad(TSocket *s)
Add slave with socket s to the bad slave list and remove if from
the active list and from the two monitor objects.
Int_t Ping(ESlaves list)
Ping PROOF slaves. Returns the number of slaves that responded.
Long64_t Finalize(Int_t qry, Bool_t force)
Finalize the qry-th query in fQueries.
If force, force retrieval if the query is found in the local list
but has already been finalized (default kFALSE).
If query < 0, finalize current query.
Return 0 on success, -1 on error
Long64_t Finalize(const char *ref, Bool_t force)
Finalize query with reference ref.
If force, force retrieval if the query is found in the local list
but has already been finalized (default kFALSE).
If ref = 0, finalize current query.
Return 0 on success, -1 on error
Int_t Retrieve(Int_t qry, const char *path)
Send retrieve request for the qry-th query in fQueries.
If path is defined save it to path.
Int_t Retrieve(const char *ref, const char *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.
Int_t Remove(const char *ref, Bool_t all)
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".
Int_t Archive(const char *ref, const char *path)
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.
Int_t CleanupSession(const char *sessiontag)
Send cleanup request for the session specified by tag.
void SetQueryMode(EQueryMode mode)
Change query running mode to the one specified by 'mode'.
void LogMessage(const char *msg, Bool_t all)
Log a message into the appropriate window by emitting a signal.
Int_t SendGroupView()
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.
Int_t Exec(const char *cmd, Bool_t plusMaster)
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.
Int_t Exec(const char *cmd, ESlaves list, Bool_t plusMaster)
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.
Int_t SendCommand(const char *cmd, ESlaves list)
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.
Int_t SendCurrentState(ESlaves list)
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.
Int_t SendInitialState()
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.
Bool_t CheckFile(const char *file, TSlave *slave, Long_t modtime)
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.
Returns kTRUE in case file needs to be send, returns kFALSE in case
file is already on remote node.
Int_t SendFile(const char *file, Int_t opt, const char *rfile, TSlave *wrk)
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.
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).
Int_t SendObject(const TObject *obj, ESlaves list)
Send object to master or slave servers. Returns number of slaves object
was sent to, -1 in case of error.
Int_t SendPrint(Option_t *option)
Send print command to master server. Returns number of slaves message
was sent to. Returns -1 in case of error.
Int_t SetParallelSilent(Int_t nodes)
Tell RPOOF how many slaves to use in parallel. Returns the number of
parallel slaves. Returns -1 in case of error.
Int_t SetParallel(Int_t nodes)
Tell RPOOF how many slaves to use in parallel. Returns the number of
parallel slaves. Returns -1 in case of error.
Int_t GoParallel(Int_t nodes, Bool_t attach)
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.
Returns -1 in case of error.
void ShowCache(Bool_t all)
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.
void ShowPackages(Bool_t all)
List contents of package directory. If all is true show all package
directries also on slaves. If everything is ok all package directories
should be the same.
void ShowEnabledPackages(Bool_t all)
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.
Int_t BuildPackage(const char *package, EBuildPackageOpt opt)
Build specified package. Executes the PROOF-INF/BUILD.sh
script if it exists on all unique nodes. If opt is -1
then submit build command to slaves, but don't wait
for results. If opt is 1 then collect result from slaves.
To be used on the master.
If opt = 0 (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.
Int_t BuildPackageOnClient(const TString &package)
Build specified package on the client. Executes the PROOF-INF/BUILD.sh
script if it exists 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::kBuildPackage
case). Keep in sync in case of changes.
Int_t LoadPackage(const char *package, Bool_t notOnClient)
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.
Returns 0 in case of success and -1 in case of error.
Int_t LoadPackageOnClient(const TString &package)
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.
Int_t UnloadPackage(const char *package)
Unload specified package.
Returns 0 in case of success and -1 in case of error.
Int_t UnloadPackages()
Unload all packages.
Returns 0 in case of success and -1 in case of error.
Int_t EnablePackage(const char *package, Bool_t notOnClient)
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.
Returns 0 in case of success and -1 in case of error.
Int_t UploadPackage(const char *tpar, EUploadPackageOpt opt)
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 .
Returns 0 in case of success and -1 in case of error.
Int_t UploadPackageOnClient(const TString &par, EUploadPackageOpt opt, TMD5 *md5)
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. The option if effective only for PROOF protocol > 8 .
Returns 0 in case of success and -1 in case of error.
Int_t AddDynamicPath(const char *libpath)
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
Int_t AddIncludePath(const char *incpath)
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
Int_t RemoveDynamicPath(const char *libpath)
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
Int_t RemoveIncludePath(const char *incpath)
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
void Feedback(TList *objs)
Get list of feedback objects. Connect a slot to this signal
to monitor the feedback object.
void AddInput(TObject *obj)
Add objects that might be needed during the processing of
the selector (see Process()).
TObject * GetOutput(const char *name)
Get specified object that has been produced during the processing
(see Process()).
void SetParameter(const char *par, const char *value)
Set input list parameter. If the parameter is already
set it will be set to the new value.
void DeleteParameters(const char *wildcard)
Delete the input list parameters specified by a wildcard (e.g. PROOF_*)
or exact name (e.g. PROOF_MaxSlavesPerNode).
void ShowParameters(const char *wildcard)
Show the input list parameters specified by the wildcard.
Default is the special PROOF control parameters (PROOF_*).
void AddFeedback(const char *name)
Add object to feedback list.
void GetLog(Int_t start, Int_t end)
Ask for remote logs in the range [start, end]. If start == -1 all the
messages not yet received are sent back.
void ShowLog(const char *queryref)
Display on screen the content of the temporary log file for query
in reference
void ShowLog(Int_t qry)
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
void cd(Int_t id)
Set session with 'id' the default one. If 'id' is not found in the list,
the current session is set as default
void Detach(Option_t *opt)
Detach this instance to its proofserv.
If opt is 'S' or 's' the remote server is shutdown
void SetAlias(const char *alias)
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
Int_t UploadDataSet(const char *dataSetName, TList *files, const char *desiredDest, Int_t opt, TList *skippedFiles)
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 CreateDataSet ------->|
(*) - optional
Int_t UploadDataSet(const char *dataSetName, const char *files, const char *desiredDest, Int_t opt, TList *skippedFiles)
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.
Int_t UploadDataSetFromFile(const char *dataset, const char *file, const char *dest, Int_t opt)
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.
Int_t CreateDataSet(const char *dataSetName, TList *files, Int_t opt)
Create a dataSet from files existing on the cluster (listed in files)
and save it as dataSetName.
No files are uploaded nor verified to exist on the cluster
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
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!
Communication Summary
Client Master
|------------>DataSetName----------->|
|<-------kMESS_OK/kMESS_NOTOK<-------| (Name OK/file exist)
(*)|------->TList of TFileInfo -------->| (dataset to save)
(*)|<-------kMESS_OK/kMESS_NOTOK<-------| (transaction complete?)
(*) - optional
TList * GetDataSets(const char *dir)
Get TList of TObjStrings with all datasets available on master:
* with dir undifined - just ls contents of ~/proof/datasets,
* with dir == "public" - ls ~/proof/datasets/public
* with dir == "~username/public" - ls ~/username/datasets/public
void ShowDataSets(const char *dir)
Show all datasets uploaded to the cluster (just ls contents of
~/proof/datasets or user/proof/datasets/public if 'dir' is defined).
* with dir undifined - just ls contents of ~/proof/datasets,
* with dir == "public" - ls ~/proof/datasets/public
* with dir == "~username/public" - ls ~/username/datasets/public
void ShowDataSet(const char *dataset)
Show content of specific dataset (cat ~/proof/datasets/dataset).
Int_t VerifyDataSet(const char *dataSet)
Verify if all files in the specified dataset are available.
Print a list and return the number of missing files.
void ActivateWorker(const char *ord)
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.
void DeactivateWorker(const char *ord)
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.
void ModifyWorkerLists(const char *ord, Bool_t add)
Modify the worker active/inactive list by making the worker identified by
the ordinal number 'ord' active (add == TRUE) or inactive (add == FALSE).
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.
TProof * Open(const char *cluster, const char *conffile, const char *confdir, Int_t loglevel)
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 "" (empty string) then we connect to a PROOF session
on the localhost ("proof://localhost"). 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.
TProofMgr * Mgr(const char *url)
Get instance of the effective manager for 'url'
Return 0 on failure.
void AddEnvVar(const char *name, const char *value)
Add an variable to the list of environment variables passed to proofserv
on the master and slaves
void DelEnvVar(const char *name)
Remove an variable from the list of environment variables passed to proofserv
on the master and slaves
void ResetEnvVars()
Clear the list of environment variables passed to proofserv
on the master and slaves
void SaveWorkerInfo()
Save informations about the worker set in the file .workers in the working
dir. Called each time there is a change in the worker setup, e.g. by
TProof::MarkBad().
Author: Fons Rademakers 13/02/97
Last update: root/proof:$Name: $:$Id: TProof.cxx,v 1.177 2006/12/14 00:03:45 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.