Logo ROOT  
Reference Guide
TMPWorkerExecutor< F, void, R > Class Template Reference

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

Definition at line 127 of file TMPWorkerExecutor.h.

Public Member Functions

 TMPWorkerExecutor (F func, R redfunc)
 
 ~TMPWorkerExecutor ()
 
void HandleInput (MPCodeBufPair &msg)
 Handle a message with an EMPCode. More...
 
- 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. More...
 
TMPWorkeroperator= (const TMPWorker &)=delete
 
void Run ()
 

Private Attributes

bool fCanReduce
 true if fReducedResult can be reduced with a new result, false until we have produced one result More...
 
F fFunc
 the function to be executed More...
 
R fRedFunc
 the reduce function More...
 
decltype(fFunc()) fReducedResult
 the result of the execution More...
 

Additional Inherited Members

- Protected Member Functions inherited from TMPWorker
void SendError (const std::string &errmsg, unsigned int code=MPCode::kError)
 Error sender. More...
 
- Protected Attributes inherited from TMPWorker
std::string fId
 identifier string in the form W<nwrk>|P<proc id> More...
 
ULong64_t fMaxNEntries
 the maximum number of entries to be processed by this worker More...
 
unsigned fNWorkers
 the number of workers spawned More...
 
ULong64_t fProcessedEntries
 the number of entries processed by this worker so far More...
 

#include <TMPWorkerExecutor.h>

Inheritance diagram for TMPWorkerExecutor< F, void, R >:
[legend]

Constructor & Destructor Documentation

◆ TMPWorkerExecutor()

template<class F , class R >
TMPWorkerExecutor< F, void, R >::TMPWorkerExecutor ( F  func,
R  redfunc 
)
inline

Definition at line 129 of file TMPWorkerExecutor.h.

◆ ~TMPWorkerExecutor()

template<class F , class R >
TMPWorkerExecutor< F, void, R >::~TMPWorkerExecutor ( )
inline

Definition at line 133 of file TMPWorkerExecutor.h.

Member Function Documentation

◆ HandleInput()

template<class F , class R >
void TMPWorkerExecutor< F, void, R >::HandleInput ( MPCodeBufPair msg)
inlinevirtual

Handle a message with an EMPCode.

This method is called upon receiving a message with a code >= 1000 (i.e. EMPCode). It handles the most generic types of messages.
Classes inheriting from TMPWorker should implement their own HandleInput function, that should be able to handle codes specific to that application.
The appropriate version of the HandleInput method (TMPWorker's or the overriding version) is automatically called depending on the message code.

Reimplemented from TMPWorker.

Definition at line 135 of file TMPWorkerExecutor.h.

Member Data Documentation

◆ fCanReduce

template<class F , class R >
bool TMPWorkerExecutor< F, void, R >::fCanReduce
private

true if fReducedResult can be reduced with a new result, false until we have produced one result

Definition at line 164 of file TMPWorkerExecutor.h.

◆ fFunc

template<class F , class R >
F TMPWorkerExecutor< F, void, R >::fFunc
private

the function to be executed

Definition at line 161 of file TMPWorkerExecutor.h.

◆ fRedFunc

template<class F , class R >
R TMPWorkerExecutor< F, void, R >::fRedFunc
private

the reduce function

Definition at line 162 of file TMPWorkerExecutor.h.

◆ fReducedResult

template<class F , class R >
decltype(fFunc()) TMPWorkerExecutor< F, void, R >::fReducedResult
private

the result of the execution

Definition at line 163 of file TMPWorkerExecutor.h.


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