Logo ROOT  
Reference Guide
 
Loading...
Searching...
No Matches
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 ()
 
TSocketGetSocket ()
 
virtual void Init (int fd, unsigned workerN)
 This method is called by children processes right after forking.
 
TMPWorkeroperator= (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 >:
[legend]

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.

  • core/multiproc/inc/TMPWorkerExecutor.h