ROOT logo
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:
TXProofServ(Int_t* argc, char** argv, FILE* flog = 0)
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)
voidTQObject::EmitVA(const char* signal, Int_t nargs, va_list va)
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
Int_tTProofServ::GetInflateFactor() 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
static voidTQObject::LoadRQ_OBJECT()
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()
static voidTObject::operator delete(void* ptr)
static voidTObject::operator delete(void* ptr, void* vp)
static voidTObject::operator delete[](void* ptr)
static voidTObject::operator delete[](void* ptr, void* vp)
void*TObject::operator new(size_t sz)
void*TObject::operator new(size_t sz, void* vp)
void*TObject::operator new[](size_t sz)
void*TObject::operator new[](size_t sz, void* vp)
TObject&TObject::operator=(const TObject& rhs)
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&)
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()
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 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:
enum TProofServ::EStatusBits { kHighMemory
};
enum TProofServ::EQueryAction { kQueryOK
kQueryModify
kQueryStop
kQueryEnqueued
};
enum TApplication::EStatusBits { kProcessRemotely
kDefaultApplication
};
enum TApplication::EExitOnException { kDontExit
kExit
kAbort
};
enum TObject::EStatusBits { kCanDelete
kMustCleanup
kObjInCanvas
kIsReferenced
kHasUUID
kCannotPick
kNoContextMenu
kInvalidObject
};
enum TObject::[unnamed] { kIsOnHeap
kNotDeleted
kZombie
kBitMask
kSingleKey
kOverwrite
kWriteDelete
};
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 Inherited Members Includes Libraries
Class Charts

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.