class TProofServLite: public TProofServ


TProofServLite

TProofServLite is the version of the PROOF worker server for local
running. The client starts directly the desired number of these
 workers; the master and daemons are eliminated, optimizing the number
of messages exchanged and created / destroyed.

Function Members (Methods)

public:

	TProofServLite(Int_t* argc, char** argv, FILE* flog = 0)
virtual	~TProofServLite()
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	TProofServ::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	TProofServ::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	TProofServ::GetWorkers(TList* workers, Int_t& prioritychange, Bool_t resume = kFALSE)
virtual void	TProofServ::HandleException(Int_t sig)
virtual void	HandleFork(TMessage* mess)
virtual void	TApplication::HandleIdleTimer()SIGNAL
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	TProofServ::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
void	TObject::Obsolete(const char* method, const char* asOfVers, const char* removedFromVers) 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	TProofServ::ReleaseWorker(const char*)
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(ostream& 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 Int_t	TApplication::TabCompletionHook(char* buf, int* pLoc, ostream& out)
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()
void	TProofServ::TruncateLogFile()
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::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 Int_t	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:

virtual Int_t	Setup()
Int_t	SetupOnFork(const char* ord)

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:

TProofServLiteInterruptHandler*	fInterruptHandler
TString	fSockPath	unix socket path
Bool_t	fTerminated	true if Terminate() has been already called

Class Charts

Inheritance Inherited Members Includes Libraries

Function documentation

TProofServLite(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

~TProofServLite()

 Cleanup. Not really necessary since after this dtor there is no
 live anyway.

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 Terminate(Int_t status)

 Terminate the proof server.

void HandleFork(TMessage* mess)

 Cloning itself via fork.

Int_t SetupOnFork(const char* ord)

 Finalize the server setup afetr forking.
 Return 0 on success, -1 on error