ROOT » PROOF » PROOFX » TXProofServ

class TXProofServ: public TProofServ, public TXHandler


TXProofServ

TXProofServ is the XRD version of the PROOF server. It differs from
TXProofServ only for the underlying connection technology


Function Members (Methods)

public:
virtual~TXProofServ()
voidTObject::AbstractMethod(const char* method) const
virtual voidTObject::AppendPad(Option_t* option = "")
virtual const char*TApplication::ApplicationName() const
static Bool_tTQObject::AreAllSignalsBlocked()
Bool_tTQObject::AreSignalsBlocked() const
Int_tTApplication::Argc() const
char**TApplication::Argv() const
char*TApplication::Argv(Int_t index) const
static Bool_tTQObject::BlockAllSignals(Bool_t b)
Bool_tTQObject::BlockSignals(Bool_t b)
virtual voidTObject::Browse(TBrowser* b)
virtual voidTQObject::ChangedBy(const char* method)SIGNAL
static TClass*Class()
virtual const char*TObject::ClassName() const
virtual voidTObject::Clear(Option_t* = "")
voidTApplication::ClearInputFiles()
virtual TObject*TObject::Clone(const char* newname = "") const
voidTQObject::CollectClassSignalLists(TList& list, TClass* cls)
virtual Int_tTObject::Compare(const TObject* obj) const
Bool_tTQObject::Connect(const char* signal, const char* receiver_class, void* receiver, const char* slot)
static Bool_tTQObject::Connect(TQObject* sender, const char* signal, const char* receiver_class, void* receiver, const char* slot)
static Bool_tTQObject::Connect(const char* sender_class, const char* signal, const char* receiver_class, void* receiver, const char* slot)
virtual voidTQObject::Connected(const char*)
virtual voidTObject::Copy(TObject& object) const
Int_tTProofServ::CopyFromCache(const char* name, Bool_t cpbin)
Int_tTProofServ::CopyToCache(const char* name, Int_t opt = 0)
static voidTApplication::CreateApplication()
virtual Int_tCreateServer()
virtual voidTObject::Delete(Option_t* option = "")MENU
virtual voidTQObject::Destroyed()SIGNAL
virtual voidDisableTimeout()
Bool_tTQObject::Disconnect(const char* signal = 0, void* receiver = 0, const char* slot = 0)
static Bool_tTQObject::Disconnect(TQObject* sender, const char* signal = 0, void* receiver = 0, const char* slot = 0)
static Bool_tTQObject::Disconnect(const char* class_name, const char* signal, void* receiver = 0, const char* slot = 0)
virtual voidTQObject::Disconnected(const char*)
virtual Int_tTObject::DistancetoPrimitive(Int_t px, Int_t py)
virtual voidTObject::Draw(Option_t* option = "")
virtual voidTObject::DrawClass() constMENU
virtual TObject*TObject::DrawClone(Option_t* option = "") constMENU
virtual voidTObject::Dump() constMENU
voidTQObject::Emit(const char* signal)
voidTQObject::Emit(const char* signal, Long_t* paramArr)
voidTQObject::Emit(const char* signal, const char* params)
voidTQObject::Emit(const char* signal, Double_t param)
voidTQObject::Emit(const char* signal, Long_t param)
voidTQObject::Emit(const char* signal, Long64_t param)
voidTQObject::Emit(const char* signal, Bool_t param)
voidTQObject::Emit(const char* signal, Char_t param)
voidTQObject::Emit(const char* signal, UChar_t param)
voidTQObject::Emit(const char* signal, Short_t param)
voidTQObject::Emit(const char* signal, UShort_t param)
voidTQObject::Emit(const char* signal, Int_t param)
voidTQObject::Emit(const char* signal, UInt_t param)
voidTQObject::Emit(const char* signal, ULong_t param)
voidTQObject::Emit(const char* signal, ULong64_t param)
voidTQObject::Emit(const char* signal, Float_t param)
voidTQObject::EmitVA(const char* signal, Int_t nargs, va_list va)
voidTQObject::EmitVA<>(const char* signal_name, Int_t)
virtual voidEnableTimeout()
virtual voidTObject::Error(const char* method, const char* msgfmt) const
static voidTProofServ::ErrorHandler(Int_t level, Bool_t abort, const char* location, const char* msg)
virtual voidTObject::Execute(const char* method, const char* params, Int_t* error = 0)
virtual voidTObject::Execute(TMethod* method, TObjArray* params, Int_t* error = 0)
virtual voidTObject::ExecuteEvent(Int_t event, Int_t px, Int_t py)
static Long_tTApplication::ExecuteFile(const char* file, Int_t* error = 0, Bool_t keep = kFALSE)
TApplication::EExitOnExceptionTApplication::ExitOnException(TApplication::EExitOnException opt = kExit)
virtual voidTObject::Fatal(const char* method, const char* msgfmt) const
static voidTProofServ::FilterLocalroot(TString& path, const char* url = "root://dum/")
virtual TObject*TObject::FindObject(const char* name) const
virtual TObject*TObject::FindObject(const TObject* obj) const
voidTProofServ::FlushLogFile()
TObject*TProofServ::Get(const char* namecycle)
Int_tTProofServ::GetActSessions() const
virtual TApplicationImp*TApplication::GetApplicationImp()
static TList*TApplication::GetApplications()
TApplication*TApplication::GetAppRemote() const
TProofLockPath*TProofServ::GetCacheLock()
const char*TProofServ::GetConfDir() const
const char*TProofServ::GetConfFile() const
Float_tTProofServ::GetCpuTime() const
const char*TProofServ::GetDataDir() const
const char*TProofServ::GetDataDirOpts() const
static TMap*TProofServ::GetDataSetNodeMap(TFileCollection* fc, TString& emsg)
virtual Option_t*TObject::GetDrawOption() const
static Long_tTObject::GetDtorOnly()
Float_tTProofServ::GetEffSessions() const
TList*TProofServ::GetEnabledPackages() const
const char*TProofServ::GetGroup() const
Int_tTProofServ::GetGroupId() const
Int_tTProofServ::GetGroupSize() const
virtual const char*TObject::GetIconName() const
const char*TApplication::GetIdleCommand() const
const char*TProofServ::GetImage() const
TList*TQObject::GetListOfClassSignals() const
TList*TQObject::GetListOfConnections() const
TList*TQObject::GetListOfSignals() const
static voidTProofServ::GetLocalServer(TString& dsrv)
Int_tTProofServ::GetLogLevel() const
static Float_tTProofServ::GetMemHWM()
static Float_tTProofServ::GetMemStop()
Long64_tTProofServ::GetMsgSizeHWM() const
virtual const char*TObject::GetName() const
TDSetElement*TProofServ::GetNextPacket(Long64_t totalEntries = -1)
virtual char*TObject::GetObjectInfo(Int_t px, Int_t py) const
static Bool_tTObject::GetObjectStat()
virtual Option_t*TObject::GetOption() const
virtual voidTProofServ::GetOptions(Int_t* argc, char** argv)
const char*TProofServ::GetOrdinal() const
const char*TProofServ::GetPackageDir() const
const char*TProofServ::GetPrefix() const
TProof*TProofServ::GetProof() const
Int_tTProofServ::GetProtocol() const
Int_tTProofServ::GetQuerySeqNum() const
Float_tTProofServ::GetRealTime() const
static Long_tTProofServ::GetResMemMax()
const char*TProofServ::GetService() const
const char*TProofServ::GetSessionDir() const
const char*TProofServ::GetSessionTag() const
TSignalHandler*TApplication::GetSignalHandler() const
TSocket*TProofServ::GetSocket() const
virtual const char*TObject::GetTitle() const
const char*TProofServ::GetTopSessionTag() const
Int_tTProofServ::GetTotSessions() const
virtual UInt_tTObject::GetUniqueID() const
const char*TProofServ::GetUser() const
static Long_tTProofServ::GetVirtMemMax()
const char*TProofServ::GetWorkDir() const
virtual TProofServ::EQueryActionGetWorkers(TList* workers, Int_t& prioritychange, Bool_t resume = kFALSE)
virtual Bool_tHandleError(const void* in = 0)
virtual voidTProofServ::HandleException(Int_t sig)
virtual voidTApplication::HandleIdleTimer()SIGNAL
virtual Bool_tHandleInput(const void* in = 0)
virtual voidHandleSigPipe()
virtual voidTProofServ::HandleSocketInput()
virtual Int_tTProofServ::HandleSocketInput(TMessage* mess, Bool_t all)
virtual voidHandleTermination()
virtual Bool_tTApplication::HandleTermInput()
virtual Bool_tTObject::HandleTimer(TTimer* timer)
virtual voidHandleUrgentData()
virtual Bool_tTQObject::HasConnection(const char* signal_name) const
virtual ULong_tTObject::Hash() const
virtual voidTApplication::Hide()
virtual voidTQObject::HighPriority(const char* signal_name, const char* slot_name = 0)
virtual voidTApplication::Iconify()
virtual voidTObject::Info(const char* method, const char* msgfmt) const
virtual Bool_tTObject::InheritsFrom(const char* classname) const
virtual Bool_tTObject::InheritsFrom(const TClass* cl) const
virtual voidTApplication::Init()
voidTApplication::InitializeGraphics()
TObjArray*TApplication::InputFiles() const
virtual voidTObject::Inspect() constMENU
voidTProofServ::Interrupt()
voidTObject::InvertBit(UInt_t f)
virtual TClass*IsA() const
static Bool_tTProofServ::IsActive()
virtual Bool_tTApplication::IsCmdThread()
Bool_tTProofServ::IsEndMaster() const
virtual Bool_tTObject::IsEqual(const TObject* obj) const
virtual Bool_tTObject::IsFolder() const
Bool_tTProofServ::IsMaster() const
Bool_tTObject::IsOnHeap() const
Bool_tTProofServ::IsParallel() const
Bool_tTApplication::IsRunning() const
virtual Bool_tTObject::IsSortable() const
Bool_tTProofServ::IsTopMaster() const
Bool_tTObject::IsZombie() const
virtual voidTApplication::KeyPressed(Int_t key)SIGNAL
virtual voidTApplication::LineProcessed(const char* line)SIGNAL
voidTProofServ::LogToMaster(Bool_t on = kTRUE)
virtual voidTApplication::Lower()
virtual voidTQObject::LowPriority(const char* signal_name, const char* slot_name = 0)
virtual voidTApplication::ls(Option_t* option = "") const
voidTObject::MayNotUse(const char* method) const
virtual voidTQObject::Message(const char* msg)SIGNAL
static voidTApplication::NeedGraphicsLibs()
Bool_tTApplication::NoLogoOpt() const
Bool_tTApplication::NoLogOpt() const
virtual Bool_tTObject::Notify()
virtual Int_tTQObject::NumberOfConnections() const
virtual Int_tTQObject::NumberOfSignals() const
voidTObject::Obsolete(const char* method, const char* asOfVers, const char* removedFromVers) const
virtual voidTApplication::Open()
voidTObject::operator delete(void* ptr)
voidTObject::operator delete(void* ptr, void* vp)
voidTObject::operator delete[](void* ptr)
voidTObject::operator delete[](void* ptr, void* vp)
void*TObject::operator new(size_t sz)
void*TObject::operator new(size_t sz, void* vp)
void*TObject::operator new[](size_t sz)
void*TObject::operator new[](size_t sz, void* vp)
TXProofServ&operator=(const TXProofServ&)
virtual voidTObject::Paint(Option_t* option = "")
virtual voidTObject::Pop()
virtual voidTProofServ::Print(Option_t* option = "") const
virtual Long_tTApplication::ProcessFile(const char* file, Int_t* error = 0, Bool_t keep = kFALSE)
virtual Long_tTApplication::ProcessLine(const char* line, Bool_t sync = kFALSE, Int_t* error = 0)
Bool_tTApplication::QuitOpt() const
virtual voidTApplication::Raise()
virtual Int_tTObject::Read(const char* name)
Int_tTProofServ::ReceiveFile(const char* file, Bool_t bin, Long64_t size)
virtual voidTObject::RecursiveRemove(TObject* obj)
static Int_tTProofServ::RegisterDataSets(TList* in, TList* out, TDataSetManager* dsm, TString& e)
virtual voidReleaseWorker(const char* ord)
virtual voidTApplication::RemoveIdleTimer()
voidTProofServ::Reset(const char* dir)
voidTObject::ResetBit(UInt_t f)
static voidTProofServ::ResolveKeywords(TString& fname, const char* path = 0)
voidTProofServ::RestartComputeTime()
Bool_tTApplication::ReturnFromRun() const
virtual voidTApplication::ReturnPressed(char* text)SIGNAL
virtual voidTProofServ::Run(Bool_t retrn = kFALSE)
virtual voidTObject::SaveAs(const char* filename = "", Option_t* option = "") constMENU
virtual voidTObject::SavePrimitive(ostream& out, Option_t* option = "")
virtual Int_tTProofServ::SendAsynMessage(const char* msg, Bool_t lf = kTRUE)
virtual voidTProofServ::SendLogFile(Int_t status = 0, Int_t start = -1, Int_t end = -1)
voidTProofServ::SendParallel(Bool_t async = kFALSE)
voidTProofServ::SendStatistics()
voidTObject::SetBit(UInt_t f)
voidTObject::SetBit(UInt_t f, Bool_t set)
virtual voidTObject::SetDrawOption(Option_t* option = "")MENU
static voidTObject::SetDtorOnly(void* obj)
virtual voidTApplication::SetEchoMode(Bool_t mode)
static FILE*TProofServ::SetErrorHandlerFile(FILE* ferr)
virtual voidTApplication::SetIdleTimer(UInt_t idleTimeInSec, const char* command)
static voidTProofServ::SetLastEntry(Long64_t lastentry)
static voidTProofServ::SetLastMsg(const char* lastmsg)
static voidTObject::SetObjectStat(Bool_t stat)
voidTApplication::SetReturnFromRun(Bool_t ret)
virtual voidTObject::SetUniqueID(UInt_t uid)
virtual voidTApplication::Show()
virtual voidShowMembers(TMemberInspector& insp) const
virtual voidTApplication::StartIdleing()
virtual voidTApplication::StopIdleing()
virtual voidStreamer(TBuffer&)
voidStreamerNVirtual(TBuffer& ClassDef_StreamerNVirtual_b)
virtual voidTObject::SysError(const char* method, const char* msgfmt) const
virtual Int_tTApplication::TabCompletionHook(char* buf, int* pLoc, ostream& out)
virtual voidTerminate(Int_t status)
Bool_tTObject::TestBit(UInt_t f) const
Int_tTObject::TestBits(UInt_t f) const
static TProofServ*TProofServ::This()
voidTProofServ::TruncateLogFile()
TXProofServ(const TXProofServ&)
TXProofServ(Int_t* argc, char** argv, FILE* flog = 0)
Int_tTProofServ::UpdateSessionStatus(Int_t xst = -1)
virtual voidTObject::UseCurrentStyle()
virtual voidTObject::Warning(const char* method, const char* msgfmt) const
const char*TApplication::WorkingDirectory() const
virtual Int_tTObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0)
virtual Int_tTObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0) const
protected:
static Int_tTQObject::CheckConnectArgs(TQObject* sender, TClass* sender_class, const char* signal, TClass* receiver_class, const char* slot)
static voidTApplication::Close(TApplication* app)
static TStringTQObject::CompressName(const char* method_name)
static Bool_tTQObject::ConnectToClass(TQObject* sender, const char* signal, TClass* receiver_class, void* receiver, const char* slot)
static Bool_tTQObject::ConnectToClass(const char* sender_class, const char* signal, TClass* receiver_class, void* receiver, const char* slot)
virtual voidTProofServ::DeletePlayer()
virtual voidTObject::DoError(int level, const char* location, const char* fmt, va_list va) const
virtual Int_tTProofServ::Fork()
virtual void*TQObject::GetSender()
virtual const char*TQObject::GetSenderClassName() const
Int_tTProofServ::GetSessionStatus()
virtual voidTProofServ::HandleArchive(TMessage* mess, TString* slb = 0)
virtual Int_tTProofServ::HandleCache(TMessage* mess, TString* slb = 0)
virtual voidTProofServ::HandleCheckFile(TMessage* mess, TString* slb = 0)
virtual Int_tTProofServ::HandleDataSets(TMessage* mess, TString* slb = 0)
virtual voidTProofServ::HandleFork(TMessage* mess)
virtual Int_tTProofServ::HandleLibIncPath(TMessage* mess)
virtual voidTProofServ::HandleProcess(TMessage* mess, TString* slb = 0)
virtual voidTProofServ::HandleQueryList(TMessage* mess)
virtual voidTProofServ::HandleRemove(TMessage* mess, TString* slb = 0)
virtual voidTProofServ::HandleRetrieve(TMessage* mess, TString* slb = 0)
virtual voidTProofServ::HandleSubmerger(TMessage* mess)
virtual Int_tTProofServ::HandleWorkerLists(TMessage* mess)
virtual voidTApplication::Help(const char* line)
Bool_tTProofServ::IsIdle()
virtual voidTApplication::LoadGraphicsLibs()
virtual voidTApplication::MakeBatch()
virtual voidTProofServ::MakePlayer()
voidTObject::MakeZombie()
static TApplication*TApplication::Open(const char* url, Int_t debug, const char* script)
static Int_tTApplication::ParseRemoteLine(const char* ln, TString& hostdir, TString& user, Int_t& dbg, TString& script)
virtual voidTProofServ::ProcessNext(TString* slb = 0)
virtual Long_tTApplication::ProcessRemote(const char* line, Int_t* error = 0)
voidTApplication::SetSignalHandler(TSignalHandler* sh)
Int_tTProofServ::SetupCommon()
Bool_tTProofServ::UnlinkDataDir(const char* path)
private:
Int_tLockSession(const char* sessiontag, TProofLockPath** lck)
virtual Int_tSetup()

Data Members

public:
static TApplication::EExitOnExceptionTApplication::kAbort
static TObject::(anonymous)TObject::kBitMask
static TObject::EStatusBitsTObject::kCanDelete
static TObject::EStatusBitsTObject::kCannotPick
static TApplication::EStatusBitsTApplication::kDefaultApplication
static TApplication::EExitOnExceptionTApplication::kDontExit
static TApplication::EExitOnExceptionTApplication::kExit
static TApplication::EFileBitsTApplication::kExpression
static TObject::EStatusBitsTObject::kHasUUID
static TProofServ::EStatusBitsTProofServ::kHighMemory
static TObject::EStatusBitsTObject::kInvalidObject
static TObject::(anonymous)TObject::kIsOnHeap
static TObject::EStatusBitsTObject::kIsReferenced
static TObject::EStatusBitsTObject::kMustCleanup
static TObject::EStatusBitsTObject::kNoContextMenu
static TObject::(anonymous)TObject::kNotDeleted
static TObject::EStatusBitsTObject::kObjInCanvas
static TObject::(anonymous)TObject::kOverwrite
static TApplication::EStatusBitsTApplication::kProcessRemotely
static TProofServ::EQueryActionTProofServ::kQueryEnqueued
static TProofServ::EQueryActionTProofServ::kQueryModify
static TProofServ::EQueryActionTProofServ::kQueryOK
static TProofServ::EQueryActionTProofServ::kQueryStop
static TObject::(anonymous)TObject::kSingleKey
static TObject::(anonymous)TObject::kWriteDelete
static TObject::(anonymous)TObject::kZombie
protected:
TApplication*TApplication::fAppRemoteCurrent remote application, if defined
TList*TQObject::fListOfConnections! list of connections to this object
TList*TQObject::fListOfSignals! list of signals from this object
Bool_tTQObject::fSignalsBlocked! flag used for suppression of signals
static Bool_tTQObject::fgAllSignalsBlockedflag used for suppression of all signals
static TList*TApplication::fgApplicationsList of available applications
static Long64_tTProofServ::fgLastEntryLast entry before exception
static TStringTProofServ::fgLastMsgMessage about status before exception
private:
TXSocketHandler*fInputHandler
TXProofServInterruptHandler*fInterruptHandler
TStringfSockPath
Bool_tfTerminatedtrue if Terminate() has been already called

Class Charts

Inheritance Chart:
TObject
TQObject
TApplication
TProofServ
TXHandler
TXProofServ

Function documentation

TXProofServ(Int_t* argc, char** argv, FILE* flog = 0)
 Main constructor
Int_t CreateServer()
 Finalize the server setup. If master, create the TProof instance to talk
 the worker or submaster nodes.
 Return 0 on success, -1 on error
~TXProofServ()
 Cleanup. Not really necessary since after this dtor there is no
 live anyway.
void HandleUrgentData()
 Handle high priority data sent by the master or client.
void HandleSigPipe()
 Called when the client is not alive anymore; terminate the session.
void HandleTermination()
 Called when the client is not alive anymore; terminate the session.
Int_t Setup()
 Print the ProofServ logo on standard output.
 Return 0 on success, -1 on error
TProofServ::EQueryAction GetWorkers(TList* workers, Int_t& prioritychange, Bool_t resume = kFALSE)
 Get list of workers to be used from now on.
 The list must be provided by the caller.
Bool_t HandleError(const void* in = 0)
 Handle error on the input socket
Bool_t HandleInput(const void* in = 0)
 Handle asynchronous input on the input socket
void DisableTimeout()
 Disable read timeout on the underlying socket
void EnableTimeout()
 Enable read timeout on the underlying socket
void Terminate(Int_t status)
 Terminate the proof server.
Int_t LockSession(const char* sessiontag, TProofLockPath** lck)
 Try locking query area of session tagged sessiontag.
 The id of the locking file is returned in fid and must be
 unlocked via UnlockQueryFile(fid).
void ReleaseWorker(const char* ord)
 Send message to intermediate coordinator to release worker of last ordinal
 ord.
TXProofServ(Int_t* argc, char** argv, FILE* flog = 0)