TXProofMgr Class Reference

#include <TXProofMgr.h>

Inheritance diagram for TXProofMgr:

List of all members.


Public Member Functions
	TXProofMgr (const char url, Int_t loglevel=-1, const char alias="")
virtual	~TXProofMgr ()
Bool_t	HandleInput (const void *)
Bool_t	HandleError (const void *in=0)
Bool_t	IsValid () const
void	SetInvalid ()
TProof *	AttachSession (Int_t id, Bool_t gui=kFALSE)
TProof *	AttachSession (TProofDesc *d, Bool_t gui=kFALSE)
void	DetachSession (Int_t, Option_t *="")
void	DetachSession (TProof , Option_t ="")
TProofLog *	GetSessionLogs (Int_t ridx=0, const char stag=0, const char pattern="-v \"\| SvcMsg\"")
Bool_t	MatchUrl (const char *url)
void	ShowROOTVersions ()
TList *	QuerySessions (Option_t *opt="S")
TObjString *	ReadBuffer (const char *file, Long64_t ofs, Int_t len)
TObjString *	ReadBuffer (const char file, const char pattern)
Int_t	Reset (Bool_t hard=kFALSE, const char *usr=0)
Int_t	SendMsgToUsers (const char msg, const char usr=0)
void	SetROOTVersion (const char *tag)
void	ShowWorkers ()
Int_t	Cp (const char src, const char dst=0, const char *opts=0)
void	Find (const char what="~/", const char how="-type f", const char *where=0)
void	Grep (const char what, const char how=0, const char *where=0)
void	Ls (const char what="~/", const char how=0, const char *where=0)
void	More (const char what, const char how=0, const char *where=0)
Int_t	Rm (const char what, const char how=0, const char *where=0)
void	Tail (const char what, const char how=0, const char *where=0)
Int_t	Md5sum (const char what, TString &sum, const char where=0)
Int_t	Stat (const char what, FileStat_t &st, const char where=0)
Int_t	GetFile (const char remote, const char local, const char *opt=0)
Int_t	PutFile (const char local, const char remote, const char *opt=0)
Private Member Functions
Int_t	Init (Int_t loglevel=-1)
void	CpProgress (const char pfx, Long64_t bytes, Long64_t size, TStopwatch watch, Bool_t cr=kFALSE)
TObjString *	Exec (Int_t action, const char what, const char how, const char *where)
Private Attributes
TXSocket *	fSocket

Detailed Description

Definition at line 46 of file TXProofMgr.h.

Constructor & Destructor Documentation

TXProofMgr::TXProofMgr	(	const char *	url,
		Int_t	loglevel = `-1`,
		const char *	alias = `""`
	)

Definition at line 92 of file TXProofMgr.cxx.

References TProofMgr::fServType, fSocket, Init(), TProofMgr::kXProofd, and SafeDelete.

TXProofMgr::~TXProofMgr ( ) [virtual]

Definition at line 150 of file TXProofMgr.cxx.

References SetInvalid().

Member Function Documentation

Int_t TXProofMgr::Init ( Int_t loglevel = -1 ) [private]

Definition at line 109 of file TXProofMgr.cxx.

References TObject::Error(), TProofMgr::fIntHandler, TProofMgr::fRemoteProtocol, TProofMgr::fServType, fSocket, TProofMgr::fUrl, gDebug, TROOT::GetListOfSockets(), TXSocket::GetOpenError(), TSocket::GetRemoteProtocol(), TUrl::GetUrl(), gROOT, gROOTMutex, TXSocket::IsServProofd(), TXSocket::IsValid(), kPROOF_Protocol, TProofMgr::kProofd, kTRUE, kXPROOF_Protocol, R__LOCKGUARD2, TCollection::Remove(), and u.

Referenced by TXProofMgr().

void TXProofMgr::CpProgress	(	const char *	pfx,
		Long64_t	bytes,
		Long64_t	size,
		TStopwatch *	watch,
		Bool_t	cr = `kFALSE`
	)			`[private]`

Definition at line 1603 of file TXProofMgr.cxx.

References TStopwatch::Continue(), fprintf(), gSystem, l, TSystem::ProcessEvents(), TStopwatch::RealTime(), and TStopwatch::Stop().

Referenced by GetFile(), and PutFile().

TObjString * TXProofMgr::Exec	(	Int_t	action,
		const char *	what,
		const char *	how,
		const char *	where
	)			`[private]`

Definition at line 1086 of file TXProofMgr.cxx.

References TSignalHandler::Add(), TString::Data(), TObject::Error(), TProofMgr::fIntHandler, TString::Form(), fSocket, TProofMgr::fUrl, TUrl::GetHost(), TUrl::GetPort(), TXSocket::GetXrdProofdVersion(), TString::IsNull(), IsValid(), kExec, kFALSE, TString::kLeading, kTail, kTRUE, o, opts, TSignalHandler::Remove(), TXSocket::SendCoordinator(), and TObject::Warning().

Referenced by Find(), Grep(), Ls(), Md5sum(), More(), Rm(), Stat(), and Tail().

Bool_t TXProofMgr::HandleInput ( const void * ) [virtual]

Reimplemented from TXHandler.

Definition at line 432 of file TXProofMgr.cxx.

References fSocket, gDebug, TObject::Info(), TXSocket::IsValid(), kPROOF_TOUCH, kTRUE, TXSocket::Recv(), TXSocket::RemoteTouch(), TObject::Warning(), and what.

Bool_t TXProofMgr::HandleError ( const void * in = 0 ) [virtual]

Reimplemented from TXHandler.

Definition at line 460 of file TXProofMgr.cxx.

References d, XHandleErr_t::fOpt, TProofMgr::fSessions, fSocket, TProofMgr::fUrl, gDebug, TCollection::GetSize(), TUrl::GetUrl(), TXSocket::IsValid(), kFALSE, kTRUE, p, Printf(), and TXSocket::Reconnect().

Bool_t TXProofMgr::IsValid ( ) const [inline, virtual]

Reimplemented from TProofMgr.

Definition at line 66 of file TXProofMgr.h.

References fSocket.

Referenced by AttachSession(), Cp(), DetachSession(), Exec(), Find(), GetFile(), GetSessionLogs(), Grep(), Ls(), MatchUrl(), Md5sum(), More(), PutFile(), QuerySessions(), ReadBuffer(), Reset(), Rm(), SetROOTVersion(), ShowROOTVersions(), ShowWorkers(), Stat(), and Tail().

void TXProofMgr::SetInvalid ( ) [virtual]

Reimplemented from TProofMgr.

Definition at line 158 of file TXProofMgr.cxx.

References TXSocket::Close(), fSocket, TROOT::GetListOfSockets(), gROOT, gROOTMutex, R__LOCKGUARD2, TCollection::Remove(), and SafeDelete.

Referenced by ~TXProofMgr().

TProof* TXProofMgr::AttachSession	(	Int_t	id,
		Bool_t	gui = `kFALSE`
	)			`[inline, virtual]`

Reimplemented from TProofMgr.

Definition at line 69 of file TXProofMgr.h.

References TProofMgr::AttachSession().

TProof * TXProofMgr::AttachSession	(	TProofDesc *	d,
		Bool_t	gui = `kFALSE`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 173 of file TXProofMgr.cxx.

References d, TObject::Error(), Form(), TProofMgr::fUrl, gDebug, TUrl::GetUrl(), IsValid(), TProofDesc::kIdle, TProofDesc::kRunning, kTRUE, p, u, and TObject::Warning().

void TXProofMgr::DetachSession	(	Int_t	,
		Option_t *	= `""`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 224 of file TXProofMgr.cxx.

References d, TXSocket::DisconnectSession(), Form(), TProofMgr::fSessions, fSocket, TProofMgr::GetProofDesc(), IsValid(), o, p, TList::Remove(), SafeDelete, and TObject::Warning().

void TXProofMgr::DetachSession	(	TProof *	,
		Option_t *	= `""`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 270 of file TXProofMgr.cxx.

References d, TProofMgr::fSessions, fSocket, TProofMgr::GetProofDesc(), IsValid(), p, TList::Remove(), and TObject::Warning().

TProofLog * TXProofMgr::GetSessionLogs	(	Int_t	ridx = `0`,
		const char *	stag = `0`,
		const char *	pattern = `"-v \"\| SvcMsg\""`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 521 of file TXProofMgr.cxx.

References TProofLog::Add(), TString::Contains(), TString::Data(), fSocket, gDebug, TObjString::GetName(), TProofMgr::GetUrl(), TString::Index(), TObject::Info(), TString::IsNull(), IsValid(), TProofLog::kGrep, TString::kLeading, kNPOS, kQueryLogPaths, ord, TString::Remove(), retrieve(), TProofLog::Retrieve(), SafeDelete, TXSocket::SendCoordinator(), and TObject::Warning().

Bool_t TXProofMgr::MatchUrl ( const char * url ) [virtual]

Reimplemented from TProofMgr.

Definition at line 296 of file TXProofMgr.cxx.

References fSocket, TProofMgr::fUrl, TUrl::GetHost(), TUrl::GetPort(), TSocket::GetPort(), TSystem::GetServiceByName(), TUrl::GetUser(), gSystem, IsValid(), kFALSE, kTRUE, XrdMonCtrCollector::port, u, and TObject::Warning().

void TXProofMgr::ShowROOTVersions ( ) [virtual]

Reimplemented from TProofMgr.

Definition at line 661 of file TXProofMgr.cxx.

References fSocket, TObjString::GetName(), IsValid(), kQueryROOTVersions, Printf(), SafeDelete, TXSocket::SendCoordinator(), and TObject::Warning().

TList * TXProofMgr::QuerySessions ( Option_t * opt = "S" ) [virtual]

Reimplemented from TProofMgr.

Definition at line 358 of file TXProofMgr.cxx.

References TList::Add(), d, TList::FindObject(), TProofMgr::fSessions, fSocket, TObjString::GetName(), TCollection::GetSize(), TProofMgr::GetUrl(), IsValid(), kQuerySessions, nc, TList::Remove(), SafeDelete, TXSocket::SendCoordinator(), TCollection::SetOwner(), Tokenize(), and TObject::Warning().

TObjString * TXProofMgr::ReadBuffer	(	const char *	file,
		Long64_t	ofs,
		Int_t	len
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 621 of file TXProofMgr.cxx.

References fSocket, IsValid(), kReadBuffer, TXSocket::SendCoordinator(), and TObject::Warning().

TObjString * TXProofMgr::ReadBuffer	(	const char *	file,
		const char *	pattern
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 637 of file TXProofMgr.cxx.

References buf, fSocket, IsValid(), kReadBuffer, TXSocket::SendCoordinator(), and TObject::Warning().

Int_t TXProofMgr::Reset	(	Bool_t	hard = `kFALSE`,
		const char *	usr = `0`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 496 of file TXProofMgr.cxx.

References fSocket, h, IsValid(), kCleanupSessions, TXSocket::SendCoordinator(), and TObject::Warning().

Int_t TXProofMgr::SendMsgToUsers	(	const char *	msg,
		const char *	usr = `0`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 705 of file TXProofMgr.cxx.

References TSystem::AccessPathName(), buf, TObject::Error(), fopen, fSocket, TSystem::GetErrno(), gSystem, kFileExists, kMAXBUF, kReadPermission, kSendMsgToUser, len, lseek, p, read, TSystem::ResetErrno(), SEEK_END, SEEK_SET, TXSocket::SendCoordinator(), sprintf(), TObject::SysError(), and TObject::Warning().

void TXProofMgr::SetROOTVersion ( const char * tag ) [virtual]

Reimplemented from TProofMgr.

Definition at line 687 of file TXProofMgr.cxx.

References fSocket, IsValid(), kROOTVersion, TXSocket::SendCoordinator(), and TObject::Warning().

void TXProofMgr::ShowWorkers ( ) [virtual]

Reimplemented from TProofMgr.

Definition at line 334 of file TXProofMgr.cxx.

References fSocket, TObjString::GetName(), IsValid(), kQueryWorkers, Printf(), TXSocket::SendCoordinator(), Tokenize(), and TObject::Warning().

Int_t TXProofMgr::Cp	(	const char *	src,
		const char *	dst = `0`,
		const char *	opts = `0`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 1635 of file TXProofMgr.cxx.

References TSignalHandler::Add(), TSystem::BaseName(), TString::Data(), TString::EndsWith(), TObject::Error(), TProofMgr::fIntHandler, TString::Form(), fSocket, gDebug, GetFile(), TUrl::GetFileAndOptions(), TObjString::GetName(), TUrl::GetProtocol(), TUrl::GetUrl(), TProofMgr::GetUrl(), TXSocket::GetXrdProofdVersion(), gSystem, TString::IsNull(), IsValid(), kCpFile, kTRUE, Printf(), TSignalHandler::Remove(), TXSocket::SendCoordinator(), and TObject::Warning().

void TXProofMgr::Find	(	const char *	what = `"~/"`,
		const char *	how = `"-type f"`,
		const char *	where = `0`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 823 of file TXProofMgr.cxx.

References Exec(), fSocket, TObjString::GetName(), TXSocket::GetXrdProofdVersion(), IsValid(), kFind, Printf(), SafeDelete, and TObject::Warning().

void TXProofMgr::Grep	(	const char *	what,
		const char *	how = `0`,
		const char *	where = `0`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 797 of file TXProofMgr.cxx.

References Exec(), fSocket, TObjString::GetName(), TXSocket::GetXrdProofdVersion(), IsValid(), kGrep, Printf(), SafeDelete, and TObject::Warning().

void TXProofMgr::Ls	(	const char *	what = `"~/"`,
		const char *	how = `0`,
		const char *	where = `0`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 850 of file TXProofMgr.cxx.

References Exec(), fSocket, TObjString::GetName(), TXSocket::GetXrdProofdVersion(), IsValid(), kLs, Printf(), SafeDelete, and TObject::Warning().

void TXProofMgr::More	(	const char *	what,
		const char *	how = `0`,
		const char *	where = `0`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 876 of file TXProofMgr.cxx.

References Exec(), fSocket, TObjString::GetName(), TXSocket::GetXrdProofdVersion(), IsValid(), kMore, Printf(), SafeDelete, and TObject::Warning().

Int_t TXProofMgr::Rm	(	const char *	what,
		const char *	how = `0`,
		const char *	where = `0`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 902 of file TXProofMgr.cxx.

References ans(), TString::Data(), Exec(), TString::Form(), fSocket, gDebug, Getline(), TObjString::GetName(), TXSocket::GetXrdProofdVersion(), TString::IsNull(), IsValid(), kFALSE, kRm, TString::kTrailing, kTRUE, Printf(), SafeDelete, t, TString::Tokenize(), and TObject::Warning().

void TXProofMgr::Tail	(	const char *	what,
		const char *	how = `0`,
		const char *	where = `0`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 966 of file TXProofMgr.cxx.

References Exec(), fSocket, TObjString::GetName(), TXSocket::GetXrdProofdVersion(), IsValid(), kTail, Printf(), SafeDelete, and TObject::Warning().

Int_t TXProofMgr::Md5sum	(	const char *	what,
		TString &	sum,
		const char *	where = `0`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 992 of file TXProofMgr.cxx.

References Exec(), fSocket, gDebug, TObjString::GetName(), TXSocket::GetXrdProofdVersion(), IsValid(), kMd5sum, Printf(), SafeDelete, and TObject::Warning().

Referenced by GetFile(), and PutFile().

Int_t TXProofMgr::Stat	(	const char *	what,
		FileStat_t &	st,
		const char *	where = `0`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 1029 of file TXProofMgr.cxx.

References Exec(), FileStat_t::fDev, FileStat_t::fGid, FileStat_t::fIno, FileStat_t::fIsLink, FileStat_t::fMode, FileStat_t::fMtime, FileStat_t::fSize, fSocket, FileStat_t::fUid, gDebug, TObjString::GetName(), TXSocket::GetXrdProofdVersion(), IsValid(), kStat, Long64_t, Printf(), SafeDelete, size, and TObject::Warning().

Referenced by PutFile().

Int_t TXProofMgr::GetFile	(	const char *	remote,
		const char *	local,
		const char *	opt = `0`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 1168 of file TXProofMgr.cxx.

References a, TSystem::AddFileHandler(), TMD5::AsString(), TSystem::BaseName(), buf, close, TString::Contains(), CpProgress(), TString::Data(), TString::EndsWith(), TObject::Error(), TSystem::ExpandPathName(), UserGroup_t::fGid, FileStat_t::fGid, TMD5::FileChecksum(), FileStat_t::fMode, fSocket, FileStat_t::fUid, UserGroup_t::fUid, TSystem::GetErrno(), Getline(), TObjString::GetName(), TSystem::GetPathInfo(), TXSocketHandler::GetSocketHandler(), TSystem::GetUid(), TSystem::GetUserInfo(), TXSocket::GetXrdProofdVersion(), gSystem, TString::IsNull(), IsValid(), kFALSE, kGetFile, kMAXBUF, kS_IWGRP, kS_IWOTH, kS_IWUSR, kTRUE, Long64_t, Md5sum(), O_BINARY, open, p, Printf(), R_ISDIR(), R_ISREG(), TXSocket::RecvRaw(), TSystem::RemoveFileHandler(), TStopwatch::Reset(), TSystem::ResetErrno(), TXSocket::SendCoordinator(), silent, size, TStopwatch::Start(), TStopwatch::Stop(), TObject::SysError(), TString::ToUpper(), w, TObject::Warning(), and write.

Referenced by Cp().

Int_t TXProofMgr::PutFile	(	const char *	local,
		const char *	remote,
		const char *	opt = `0`
	)			`[virtual]`

Reimplemented from TProofMgr.

Definition at line 1399 of file TXProofMgr.cxx.

References a, TSystem::AddFileHandler(), TMD5::AsString(), TSystem::BaseName(), buf, close, CpProgress(), TString::Data(), TString::EndsWith(), TObject::Error(), TSystem::ExpandPathName(), TXSocket::fConn, UserGroup_t::fGid, FileStat_t::fGid, TMD5::FileChecksum(), FileStat_t::fMode, TString::Form(), FileStat_t::fSize, fSocket, FileStat_t::fUid, UserGroup_t::fUid, TSystem::GetErrno(), Getline(), TSystem::GetPathInfo(), TXSocketHandler::GetSocketHandler(), TSystem::GetUid(), TSystem::GetUserInfo(), TXSocket::GetXrdProofdVersion(), gSystem, TString::IsNull(), IsValid(), kFALSE, kMAXBUF, kPutFile, kS_IRGRP, kS_IROTH, kS_IRUSR, kTRUE, Long64_t, lseek, Md5sum(), O_BINARY, open, Printf(), R_ISREG(), read, TSystem::RemoveFileHandler(), TStopwatch::Reset(), TSystem::ResetErrno(), SEEK_SET, TXSocket::SendCoordinator(), TStopwatch::Start(), Stat(), TStopwatch::Stop(), TString::ToUpper(), TObject::Warning(), and XrdProofConn::WriteRaw().

Member Data Documentation

TXSocket* TXProofMgr::fSocket [private]

Definition at line 50 of file TXProofMgr.h.

Referenced by Cp(), DetachSession(), Exec(), Find(), GetFile(), GetSessionLogs(), Grep(), HandleError(), HandleInput(), Init(), IsValid(), Ls(), MatchUrl(), Md5sum(), More(), PutFile(), QuerySessions(), ReadBuffer(), Reset(), Rm(), SendMsgToUsers(), SetInvalid(), SetROOTVersion(), ShowROOTVersions(), ShowWorkers(), Stat(), Tail(), and TXProofMgr().

The documentation for this class was generated from the following files:

proof/proofx/inc/TXProofMgr.h
proof/proofx/src/TXProofMgr.cxx

Generated on Tue Jul 5 16:49:54 2011 for ROOT_528-00b_version by

doxygen

1.5.1