TMPWorkerExecutor< F, T, void > Class Template Reference

template<class F, class T>
class TMPWorkerExecutor< F, T, void >

Definition at line 169 of file TMPWorkerExecutor.h.

Public Member Functions
	TMPWorkerExecutor (F func, const std::vector< T > &args)
	~TMPWorkerExecutor ()
void	HandleInput (MPCodeBufPair &msg) override
	< Execute instructions received from a TProcessExecutor client
Public Member Functions inherited from TMPWorker
	TMPWorker ()
	TMPWorker (const TMPWorker &)=delete
	TMPWorker (unsigned nWorkers, ULong64_t maxEntries)
virtual	~TMPWorker ()
unsigned	GetNWorker () const
pid_t	GetPid ()
TSocket *	GetSocket ()
virtual void	Init (int fd, unsigned workerN)
	This method is called by children processes right after forking.
TMPWorker &	operator= (const TMPWorker &)=delete
void	Run ()

Private Attributes
std::vector< T >	fArgs
	a vector containing the arguments that must be passed to fFunc
F	fFunc
	the function to be executed

Additional Inherited Members
Protected Member Functions inherited from TMPWorker
void	SendError (const std::string &errmsg, unsigned int code=MPCode::kError)
	Error sender.
Protected Attributes inherited from TMPWorker
std::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	fNWorkers
	the number of workers spawned
ULong64_t	fProcessedEntries
	the number of entries processed by this worker so far

#include <TMPWorkerExecutor.h>

Inheritance diagram for TMPWorkerExecutor< F, T, void >:

Constructor & Destructor Documentation

TMPWorkerExecutor()

template<class F , class T >

TMPWorkerExecutor< F, T, void >::TMPWorkerExecutor ( F func, const std::vector< T > & args )

inline

Definition at line 171 of file TMPWorkerExecutor.h.

~TMPWorkerExecutor()

template<class F , class T >

TMPWorkerExecutor< F, T, void >::~TMPWorkerExecutor ( )

inline

Definition at line 172 of file TMPWorkerExecutor.h.

Member Function Documentation

HandleInput()

template<class F , class T >

void TMPWorkerExecutor< F, T, void >::HandleInput ( MPCodeBufPair & msg )

inlineoverridevirtual

< Execute instructions received from a TProcessExecutor client

Reimplemented from TMPWorker.

Definition at line 173 of file TMPWorkerExecutor.h.

Member Data Documentation

fArgs

template<class F , class T >

std::vector<T> TMPWorkerExecutor< F, T, void >::fArgs

private

a vector containing the arguments that must be passed to fFunc

Definition at line 189 of file TMPWorkerExecutor.h.

fFunc

template<class F , class T >

F TMPWorkerExecutor< F, T, void >::fFunc

private

the function to be executed

Definition at line 188 of file TMPWorkerExecutor.h.