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()
void	TObject::AbstractMethod(const char* method) const
virtual void	TObject::AppendPad(Option_t* option = "")
virtual const char*	TApplication::ApplicationName() const
static Bool_t	TQObject::AreAllSignalsBlocked()
Bool_t	TQObject::AreSignalsBlocked() const
Int_t	TApplication::Argc() const
char**	TApplication::Argv() const
char*	TApplication::Argv(Int_t index) const
static Bool_t	TQObject::BlockAllSignals(Bool_t b)
Bool_t	TQObject::BlockSignals(Bool_t b)
virtual void	TObject::Browse(TBrowser* b)
virtual void	TQObject::ChangedBy(const char* method)SIGNAL
static TClass*	Class()
virtual const char*	TObject::ClassName() const
virtual void	TObject::Clear(Option_t* = "")
void	TApplication::ClearInputFiles()
virtual TObject*	TObject::Clone(const char* newname = "") const
void	TQObject::CollectClassSignalLists(TList& list, TClass* cls)
virtual Int_t	TObject::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	TObject::Copy(TObject& object) const
Int_t	TProofServ::CopyFromCache(const char* name, Bool_t cpbin)
Int_t	TProofServ::CopyToCache(const char* name, Int_t opt = 0)
static void	TApplication::CreateApplication()
virtual Int_t	CreateServer()
virtual void	TObject::Delete(Option_t* option = "")MENU
virtual void	TQObject::Destroyed()SIGNAL
virtual void	DisableTimeout()
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() constMENU
virtual TObject*	TObject::DrawClone(Option_t* option = "") constMENU
virtual void	TObject::Dump() constMENU
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)
virtual void	EnableTimeout()
virtual void	TObject::Error(const char* method, const char* msgfmt) const
static void	TProofServ::ErrorHandler(Int_t level, Bool_t abort, const char* location, const char* msg)
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)
static Long_t	TApplication::ExecuteFile(const char* file, Int_t* error = 0, Bool_t keep = kFALSE)
TApplication::EExitOnException	TApplication::ExitOnException(TApplication::EExitOnException opt = kExit)
virtual void	TObject::Fatal(const char* method, const char* msgfmt) const
virtual TObject*	TObject::FindObject(const char* name) const
virtual TObject*	TObject::FindObject(const TObject* obj) const
void	TProofServ::FlushLogFile()
TObject*	TProofServ::Get(const char* namecycle)
Int_t	TProofServ::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_t	TProofServ::GetCpuTime() const
const char*	TProofServ::GetDataDir() const
virtual Option_t*	TObject::GetDrawOption() const
static Long_t	TObject::GetDtorOnly()
Float_t	TProofServ::GetEffSessions() const
TList*	TProofServ::GetEnabledPackages() const
const char*	TProofServ::GetGroup() const
Int_t	TProofServ::GetGroupId() const
Int_t	TProofServ::GetGroupSize() const
virtual const char*	TObject::GetIconName() const
const char*	TApplication::GetIdleCommand() const
const char*	TProofServ::GetImage() const
Int_t	TProofServ::GetInflateFactor() const
TList*	TQObject::GetListOfClassSignals() const
TList*	TQObject::GetListOfConnections() const
TList*	TQObject::GetListOfSignals() const
Int_t	TProofServ::GetLogLevel() const
static Float_t	TProofServ::GetMemHWM()
static Float_t	TProofServ::GetMemStop()
Long64_t	TProofServ::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_t	TObject::GetObjectStat()
virtual Option_t*	TObject::GetOption() const
virtual void	TProofServ::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_t	TProofServ::GetProtocol() const
Int_t	TProofServ::GetQuerySeqNum() const
Float_t	TProofServ::GetRealTime() const
static Long_t	TProofServ::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
Int_t	TProofServ::GetTotSessions() const
virtual UInt_t	TObject::GetUniqueID() const
const char*	TProofServ::GetUser() const
static Long_t	TProofServ::GetVirtMemMax()
const char*	TProofServ::GetWorkDir() const
virtual TProofServ::EQueryAction	GetWorkers(TList* workers, Int_t& prioritychange, Bool_t resume = kFALSE)
virtual Bool_t	HandleError(const void* in = 0)
virtual void	TProofServ::HandleException(Int_t sig)
virtual void	TApplication::HandleIdleTimer()SIGNAL
virtual Bool_t	HandleInput(const void* in = 0)
virtual void	HandleSigPipe()
virtual void	TProofServ::HandleSocketInput()
virtual Int_t	TProofServ::HandleSocketInput(TMessage* mess, Bool_t all)
virtual void	HandleTermination()
virtual Bool_t	TApplication::HandleTermInput()
virtual Bool_t	TObject::HandleTimer(TTimer* timer)
virtual void	HandleUrgentData()
virtual Bool_t	TQObject::HasConnection(const char* signal_name) const
virtual ULong_t	TObject::Hash() const
virtual void	TApplication::Hide()
virtual void	TQObject::HighPriority(const char* signal_name, const char* slot_name = 0)
virtual void	TApplication::Iconify()
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	TApplication::Init()
void	TApplication::InitializeGraphics()
TObjArray*	TApplication::InputFiles() const
virtual void	TObject::Inspect() constMENU
void	TProofServ::Interrupt()
void	TObject::InvertBit(UInt_t f)
virtual TClass*	IsA() const
static Bool_t	TProofServ::IsActive()
virtual Bool_t	TApplication::IsCmdThread()
Bool_t	TProofServ::IsEndMaster() const
virtual Bool_t	TObject::IsEqual(const TObject* obj) const
virtual Bool_t	TObject::IsFolder() const
Bool_t	TProofServ::IsMaster() const
Bool_t	TObject::IsOnHeap() const
Bool_t	TProofServ::IsParallel() const
Bool_t	TApplication::IsRunning() const
virtual Bool_t	TObject::IsSortable() const
Bool_t	TProofServ::IsTopMaster() const
Bool_t	TObject::IsZombie() const
virtual void	TApplication::KeyPressed(Int_t key)SIGNAL
virtual void	TApplication::LineProcessed(const char* line)SIGNAL
static void	TQObject::LoadRQ_OBJECT()
void	TProofServ::LogToMaster(Bool_t on = kTRUE)
virtual void	TApplication::Lower()
virtual void	TQObject::LowPriority(const char* signal_name, const char* slot_name = 0)
virtual void	TApplication::ls(Option_t* option = "") const
void	TObject::MayNotUse(const char* method) const
virtual void	TQObject::Message(const char* msg)SIGNAL
static void	TApplication::NeedGraphicsLibs()
Bool_t	TApplication::NoLogoOpt() const
Bool_t	TApplication::NoLogOpt() const
virtual Bool_t	TObject::Notify()
virtual Int_t	TQObject::NumberOfConnections() const
virtual Int_t	TQObject::NumberOfSignals() const
virtual void	TApplication::Open()
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)
TObject&	TObject::operator=(const TObject& rhs)
virtual void	TObject::Paint(Option_t* option = "")
virtual void	TObject::Pop()
virtual void	TProofServ::Print(Option_t* option = "") const
virtual Long_t	TApplication::ProcessFile(const char* file, Int_t* error = 0, Bool_t keep = kFALSE)
virtual Long_t	TApplication::ProcessLine(const char* line, Bool_t sync = kFALSE, Int_t* error = 0)
Bool_t	TApplication::QuitOpt() const
virtual void	TApplication::Raise()
virtual Int_t	TObject::Read(const char* name)
Int_t	TProofServ::ReceiveFile(const char* file, Bool_t bin, Long64_t size)
virtual void	TObject::RecursiveRemove(TObject* obj)
virtual void	ReleaseWorker(const char* ord)
virtual void	TApplication::RemoveIdleTimer()
void	TProofServ::Reset(const char* dir)
void	TObject::ResetBit(UInt_t f)
static void	TProofServ::ResolveKeywords(TString& fname, const char* path = 0)
void	TProofServ::RestartComputeTime()
Bool_t	TApplication::ReturnFromRun() const
virtual void	TApplication::ReturnPressed(char* text)SIGNAL
virtual void	TProofServ::Run(Bool_t retrn = kFALSE)
virtual void	TObject::SaveAs(const char* filename = "", Option_t* option = "") constMENU
virtual void	TObject::SavePrimitive(basic_ostream<char,char_traits<char> >& out, Option_t* option = "")
virtual Int_t	TProofServ::SendAsynMessage(const char* msg, Bool_t lf = kTRUE)
virtual void	TProofServ::SendLogFile(Int_t status = 0, Int_t start = -1, Int_t end = -1)
void	TProofServ::SendParallel(Bool_t async = kFALSE)
void	TProofServ::SendStatistics()
void	TObject::SetBit(UInt_t f)
void	TObject::SetBit(UInt_t f, Bool_t set)
virtual void	TObject::SetDrawOption(Option_t* option = "")MENU
static void	TObject::SetDtorOnly(void* obj)
virtual void	TApplication::SetEchoMode(Bool_t mode)
static FILE*	TProofServ::SetErrorHandlerFile(FILE* ferr)
virtual void	TApplication::SetIdleTimer(UInt_t idleTimeInSec, const char* command)
static void	TProofServ::SetLastMsg(const char* lastmsg)
static void	TObject::SetObjectStat(Bool_t stat)
void	TApplication::SetReturnFromRun(Bool_t ret)
virtual void	TObject::SetUniqueID(UInt_t uid)
virtual void	TApplication::Show()
virtual void	ShowMembers(TMemberInspector& insp)
virtual void	TApplication::StartIdleing()
virtual void	TApplication::StopIdleing()
virtual void	Streamer(TBuffer& b)
void	StreamerNVirtual(TBuffer& b)
virtual void	TObject::SysError(const char* method, const char* msgfmt) const
virtual void	Terminate(Int_t status)
Bool_t	TObject::TestBit(UInt_t f) const
Int_t	TObject::TestBits(UInt_t f) const
static TProofServ*	TProofServ::This()
Int_t	TProofServ::UpdateSessionStatus(Int_t xst = -1)
virtual void	TObject::UseCurrentStyle()
virtual void	TObject::Warning(const char* method, const char* msgfmt) const
const char*	TApplication::WorkingDirectory() 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:

static Int_t	TQObject::CheckConnectArgs(TQObject* sender, TClass* sender_class, const char* signal, TClass* receiver_class, const char* slot)
static void	TApplication::Close(TApplication* app)
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)
virtual void	TProofServ::DeletePlayer()
virtual void	TObject::DoError(int level, const char* location, const char* fmt, va_list va) const
virtual Int_t	TProofServ::Fork()
virtual void*	TQObject::GetSender()
virtual const char*	TQObject::GetSenderClassName() const
Int_t	TProofServ::GetSessionStatus()
virtual void	TProofServ::HandleArchive(TMessage* mess, TString* slb = 0)
virtual Int_t	TProofServ::HandleCache(TMessage* mess, TString* slb = 0)
virtual void	TProofServ::HandleCheckFile(TMessage* mess, TString* slb = 0)
virtual Int_t	TProofServ::HandleDataSets(TMessage* mess, TString* slb = 0)
virtual void	TProofServ::HandleFork(TMessage* mess)
virtual void	TProofServ::HandleLibIncPath(TMessage* mess)
virtual void	TProofServ::HandleProcess(TMessage* mess, TString* slb = 0)
virtual void	TProofServ::HandleQueryList(TMessage* mess)
virtual void	TProofServ::HandleRemove(TMessage* mess, TString* slb = 0)
virtual void	TProofServ::HandleRetrieve(TMessage* mess, TString* slb = 0)
virtual void	TProofServ::HandleSubmerger(TMessage* mess)
virtual void	TProofServ::HandleWorkerLists(TMessage* mess)
virtual void	TApplication::Help(const char* line)
Bool_t	TProofServ::IsIdle()
virtual void	TApplication::LoadGraphicsLibs()
virtual void	TApplication::MakeBatch()
virtual void	TProofServ::MakePlayer()
void	TObject::MakeZombie()
static TApplication*	TApplication::Open(const char* url, Int_t debug, const char* script)
static Int_t	TApplication::ParseRemoteLine(const char* ln, TString& hostdir, TString& user, Int_t& dbg, TString& script)
virtual void	TProofServ::ProcessNext(TString* slb = 0)
virtual Long_t	TApplication::ProcessRemote(const char* line, Int_t* error = 0)
void	TApplication::SetSignalHandler(TSignalHandler* sh)
Int_t	TProofServ::SetupCommon()
Bool_t	TProofServ::UnlinkDataDir(const char* path)

private:

Int_t	LockSession(const char* sessiontag, TProofLockPath** lck)
virtual Int_t	Setup()

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::fAppRemote	Current remote application, if defined
TList*	TQObject::fListOfConnections	! list of connections to this object
TList*	TQObject::fListOfSignals	! list of signals from this object
Bool_t	TQObject::fSignalsBlocked	! flag used for suppression of signals
static Bool_t	TQObject::fgAllSignalsBlocked	flag used for suppression of all signals
static TList*	TApplication::fgApplications	List of available applications
static TString	TProofServ::fgLastMsg	Message about status before exception

private:

TXSocketHandler*	fInputHandler
TXProofServInterruptHandler*	fInterruptHandler
TString	fSockPath
Bool_t	fTerminated	true if Terminate() has been already called

Class Charts

Inheritance Inherited Members Includes Libraries

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.