+
class TXProofServ
-
library: libProofx
#include "TXProofServ.h"
Display options:
Show inherited
Show non-public

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
Int_tTApplication::Argc() const
char**TApplication::Argv() const
char*TApplication::Argv(Int_t index) const
virtual voidTObject::Browse(TBrowser* b)
virtual voidTQObject::ChangedBy(const char* method)
static TClass*Class()
virtual const char*TObject::ClassName() const
virtual voidTObject::Clear(Option_t* = "")
voidTApplication::ClearInputFiles()
virtual TObject*TObject::Clone(const char* newname = "") const
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)
Int_tTProofServ::CopyToCache(const char* name, Int_t opt = 0)
static voidTApplication::CreateApplication()
virtual Int_tCreateServer()
virtual voidTObject::Delete(Option_t* option = "")
virtual voidTQObject::Destroyed()
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() const
virtual TObject*TObject::DrawClone(Option_t* option = "") const
virtual voidTObject::Dump() const
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
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)
virtual voidTObject::Fatal(const char* method, const char* msgfmt) const
virtual TObject*TObject::FindObject(const char* name) const
virtual TObject*TObject::FindObject(const TObject* obj) const
voidTProofServ::FlushLogFile()
TObject*TProofServ::Get(const char* namecycle)
virtual TApplicationImp*TApplication::GetApplicationImp()
static TList*TApplication::GetApplications()
TApplication*TApplication::GetAppRemote() const
const char*TProofServ::GetConfDir() const
const char*TProofServ::GetConfFile() const
Float_tTProofServ::GetCpuTime() const
virtual Option_t*TObject::GetDrawOption() const
static Long_tTObject::GetDtorOnly()
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
Int_tTProofServ::GetLogLevel() 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::GetPrefix() const
TProof*TProofServ::GetProof() const
Int_tTProofServ::GetProtocol() const
Float_tTProofServ::GetRealTime() const
const char*TProofServ::GetService() const
const char*TProofServ::GetSessionDir() const
TSignalHandler*TApplication::GetSignalHandler() const
TSocket*TProofServ::GetSocket() const
virtual const char*TObject::GetTitle() const
virtual UInt_tTObject::GetUniqueID() const
const char*TProofServ::GetUser() const
const char*TProofServ::GetWorkDir() const
virtual TProofServ::EQueryActionGetWorkers(TList* workers, Int_t& prioritychange)
virtual Bool_tHandleError(const void* in = 0)
virtual voidTApplication::HandleIdleTimer()
virtual Bool_tHandleInput(const void* in = 0)
virtual voidHandleSigPipe()
virtual voidTProofServ::HandleSocketInput()
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() const
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)
static voidTQObject::LoadRQ_OBJECT()
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)
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
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* line, Int_t* error = 0)
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)
virtual voidTApplication::RemoveIdleTimer()
voidTProofServ::Reset(const char* dir)
voidTObject::ResetBit(UInt_t f)
Bool_tTApplication::ReturnFromRun() const
virtual voidTApplication::ReturnPressed(char* text)
virtual voidTProofServ::Run(Bool_t retrn = kFALSE)
virtual voidTObject::SaveAs(const char* filename = "", Option_t* option = "") const
virtual voidTObject::SavePrimitive(ostream& out, Option_t* option = "")
virtual Int_tTProofServ::SendAsynMessage(const char* msg, Bool_t lf = kTRUE)
voidTProofServ::SendParallel()
voidTProofServ::SendStatistics()
voidTObject::SetBit(UInt_t f)
voidTObject::SetBit(UInt_t f, Bool_t set)
virtual voidTObject::SetDrawOption(Option_t* option = "")
static voidTObject::SetDtorOnly(void* obj)
virtual voidTApplication::SetEchoMode(Bool_t mode)
virtual voidTApplication::SetIdleTimer(UInt_t idleTimeInSec, const char* command)
static voidTObject::SetObjectStat(Bool_t stat)
voidTApplication::SetReturnFromRun(Bool_t ret)
virtual voidTObject::SetUniqueID(UInt_t uid)
virtual voidTApplication::Show()
virtual voidShowMembers(TMemberInspector& insp, char* parent)
virtual voidTApplication::StartIdleing()
virtual voidTApplication::StopIdleing()
virtual voidStreamer(TBuffer& b)
voidStreamerNVirtual(TBuffer& b)
virtual voidTObject::SysError(const char* method, const char* msgfmt) const
virtual voidTerminate(Int_t status)
Bool_tTObject::TestBit(UInt_t f) const
Int_tTObject::TestBits(UInt_t f) const
static TProofServ*TProofServ::This()
virtual voidTObject::UseCurrentStyle()
virtual voidTObject::Warning(const char* method, const char* msgfmt) 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
static voidTProofServ::ErrorHandler(Int_t level, Bool_t abort, const char* location, const char* msg)
virtual void*TQObject::GetSender()
virtual const char*TQObject::GetSenderClassName() const
virtual voidTProofServ::HandleArchive(TMessage* mess)
virtual Int_tTProofServ::HandleCache(TMessage* mess)
virtual voidTProofServ::HandleCheckFile(TMessage* mess)
virtual Int_tTProofServ::HandleDataSets(TMessage* mess)
virtual voidTProofServ::HandleLibIncPath(TMessage* mess)
virtual voidTProofServ::HandleProcess(TMessage* mess)
virtual voidTProofServ::HandleQueryList(TMessage* mess)
virtual voidTProofServ::HandleRemove(TMessage* mess)
virtual voidTProofServ::HandleRetrieve(TMessage* mess)
virtual voidTProofServ::HandleSocketInputDuringProcess()
virtual voidTProofServ::HandleWorkerLists(TMessage* mess)
virtual voidTApplication::Help(const char* line)
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 Long_tTApplication::ProcessRemote(const char* line, Int_t* error = 0)
voidTApplication::SetSignalHandler(TSignalHandler* sh)
private:
Int_tLockSession(const char* sessiontag, TProofLockPath** lck)
virtual voidSendLogFile(Int_t status = 0, Int_t start = -1, Int_t end = -1)
virtual voidSetShutdownTimer(Bool_t on = kTRUE, Int_t delay = 0)
virtual Int_tSetup()

Data Members

public:
enum TProofServ::EQueryAction { kQueryOK
kQueryModify
kQueryStop
};
enum TApplication::EStatusBits { kProcessRemotely
};
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
static TList*TApplication::fgApplicationsList of available applications
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
void SendLogFile(Int_t status = 0, Int_t start = -1, Int_t end = -1)
 Send log file to master.
 If start > -1 send only bytes in the range from start to end,
 if end <= start send everything from start.
TProofServ::EQueryAction GetWorkers(TList* workers, Int_t& prioritychange)
 Get list of workers to be used from now on.
 The list must be provide 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 SetShutdownTimer(Bool_t on = kTRUE, Int_t delay = 0)
 Enable/disable the timer for delayed shutdown; the delay will be 'delay'
 seconds; depending on fShutdownWhenIdle, the countdown will start
 immediately or when the session is idle.

Author: Gerardo Ganis 12/12/2005
Last update: root/proofx:$Name: $:$Id: TXProofServ.cxx,v 1.39 2007/06/22 17:16:35 ganis Exp $
Copyright (C) 1995-2005, Rene Brun and Fons Rademakers. *
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.