class TMPWorker

Function Members (Methods)

public:

virtual	~TMPWorker()
static TClass*	Class()
unsigned int	GetNWorker() const
pid_t	GetPid()
TSocket*	GetSocket()
virtual void	Init(int fd, unsigned int workerN)
virtual TClass*	IsA() const
TMPWorker&	operator=(const TMPWorker&)
void	Run()
virtual void	ShowMembers(TMemberInspector& insp) const
virtual void	Streamer(TBuffer&)
void	StreamerNVirtual(TBuffer& ClassDef_StreamerNVirtual_b)
	TMPWorker()
	TMPWorker(const TMPWorker&)
	TMPWorker(TTree* tree, unsigned int nWorkers, ULong64_t maxEntries)
	TMPWorker(const vector<string>& fileNames, const string& treeName, unsigned int nWorkers, ULong64_t maxEntries)

protected:

void	CloseFile()
TFile*	OpenFile(const string& fileName)
TTree*	RetrieveTree(TFile* fp)
void	SendError(const string& errmsg, unsigned int code = MPCode::kError)
void	Setup()
void	SetupTreeCache(TTree* tree)

private:

virtual void

protected:

TFile*	fFile	last open file
vector<string>	fFileNames	the files to be processed by all workers
string	fId	identifier string in the form W<nwrk>\|P<proc id>
ULong64_t	fMaxNEntries	the maximum number of entries to be processed by this worker
unsigned int	fNWorkers	the number of workers spawned
ULong64_t	fProcessedEntries	the number of entries processed by this worker so far
TTree*	fTree	pointer to the tree to be processed. It is only used if the tree is directly passed to TProcessExecutor::Process as argument
string	fTreeName	the name of the tree to be processed

private:

Long64_t	fCacheSize	Cache size
unsigned int	fNWorker	the ordinal number of this worker (0 to nWorkers-1)
pid_t	fPid	the PID of the process in which this worker is running
unique_ptr<TSocket>	fS	This worker's socket. The unique_ptr makes sure resources are released.
TTreeCache*	fTreeCache	instance of the tree cache for the tree
Bool_t	fTreeCacheIsLearning	Whether cache is in learning phase
Bool_t	fUseTreeCache	Control usage of the tree cache

Inheritance Chart:

TMPWorker

 \endcond

TMPWorker(const vector<string>& fileNames, const string& treeName, unsigned int nWorkers, ULong64_t maxEntries)

TMPWorker(TTree* tree, unsigned int nWorkers, ULong64_t maxEntries)

virtual ~TMPWorker()

it doesn't make sense to copy a TMPWorker (each one has a uniq_ptr to its socket)

void Init(int fd, unsigned int workerN)

void Run()

{ return fS.get(); }

{ return fPid; }

unsigned GetNWorker() const

{ return fNWorker; }

TFile * OpenFile(const string& fileName)

void SendError(const string& errmsg, unsigned int code = MPCode::kError)

void Setup()