Poller Class Reference

An interface implementing the basics of a poll loop, posting an MPI_Irecv and waiting for new requests on a specific communicator. More...

#include <Poller.h>

Inheritance diagram for Poller:

Public Member Functions
	Poller (MPI_Comm comm, double delay=0.1)
virtual	~Poller ()

Protected Member Functions
virtual bool	onMessage (MPI_Status status, size_t recv_value)=0
virtual void	onStop ()=0
	enable implementation to react to STOP tag More...
virtual void	setupPoll ()=0
	executed before starting polling loop More...
virtual void	prePoll ()=0
	executed before checking for new request More...
virtual void	postPoll ()=0
	executed after handling (if any) new request More...
virtual void	run ()

Protected Attributes
MPI_Comm	comm_m
	communicator the poller listens to requests More...
bool	is_running_
double	last_polled_
	time of last MPI_Test More...
double	poll_delay_
	delay in seconds between polls More...

Detailed Description

An interface implementing the basics of a poll loop, posting an MPI_Irecv and waiting for new requests on a specific communicator.

See Also

Pilot

Worker

Optimizer

MPIHelper.h

Definition at line 18 of file Poller.h.

Constructor & Destructor Documentation

Poller::Poller ( MPI_Comm  comm, double  delay = 0.1  )

inline

Definition at line 22 of file Poller.h.

References last_polled_.

virtual Poller::~Poller ( )

inlinevirtual

Definition at line 30 of file Poller.h.

Member Function Documentation

virtual bool Poller::onMessage ( MPI_Status  status, size_t  recv_value  )

protectedpure virtual

User specific behavior on receiving a message.

Returns

boolean indicating if Irecv has to be re-posted

Implemented in Pilot< Opt_t, Sim_t, SolPropagationGraph_t, Comm_t >, SamplePilot< Opt_t, Sim_t, SolPropagationGraph_t, Comm_t >, Worker< Sim_t >, SampleWorker< Sim_t >, FixedPisaNsga2< CrossoverOperator, MutationOperator >, Sampler, and Optimizer.

Referenced by run().

virtual void Poller::onStop ( )

protectedpure virtual

enable implementation to react to STOP tag

Implemented in Pilot< Opt_t, Sim_t, SolPropagationGraph_t, Comm_t >, Worker< Sim_t >, FixedPisaNsga2< CrossoverOperator, MutationOperator >, Sampler, and Optimizer.

Referenced by run().

virtual void Poller::postPoll ( )

protectedpure virtual

executed after handling (if any) new request

Implemented in Pilot< Opt_t, Sim_t, SolPropagationGraph_t, Comm_t >, Worker< Sim_t >, SamplePilot< Opt_t, Sim_t, SolPropagationGraph_t, Comm_t >, FixedPisaNsga2< CrossoverOperator, MutationOperator >, Sampler, and Optimizer.

Referenced by run().

virtual void Poller::prePoll ( )

protectedpure virtual

executed before checking for new request

Implemented in Pilot< Opt_t, Sim_t, SolPropagationGraph_t, Comm_t >, Worker< Sim_t >, FixedPisaNsga2< CrossoverOperator, MutationOperator >, Sampler, and Optimizer.

Referenced by run().

virtual void Poller::run ( )

inlineprotectedvirtual

The poll loop stops when receiving a 'MPI_STOP_TAG' otherwise passes message to user.

Reimplemented in Pilot< Opt_t, Sim_t, SolPropagationGraph_t, Comm_t >.

Definition at line 62 of file Poller.h.

References comm_m, is_running_, last_polled_, MPI_STOP_TAG, onMessage(), onStop(), poll_delay_, postPoll(), prePoll(), and setupPoll().

Referenced by Sampler::initialize(), SampleWorker< Sim_t >::onMessage(), SampleWorker< Sim_t >::runSlave(), SampleWorker< Sim_t >::SampleWorker(), and Worker< Sim_t >::Worker().

Here is the call graph for this function:

virtual void Poller::setupPoll ( )

protectedpure virtual

executed before starting polling loop

Implemented in Pilot< Opt_t, Sim_t, SolPropagationGraph_t, Comm_t >, Worker< Sim_t >, FixedPisaNsga2< CrossoverOperator, MutationOperator >, Sampler, and Optimizer.

Referenced by run().

Member Data Documentation

MPI_Comm Poller::comm_m

protected

communicator the poller listens to requests

Definition at line 35 of file Poller.h.

Referenced by SampleWorker< Sim_t >::onMessage(), Worker< Sim_t >::onMessage(), Pilot< Opt_t, Sim_t, SolPropagationGraph_t, Comm_t >::parseInputFile(), run(), and Worker< Sim_t >::setupPoll().

bool Poller::is_running_

protected

Definition at line 37 of file Poller.h.

Referenced by run(), Worker< Sim_t >::runCoWorker(), and SampleWorker< Sim_t >::runSlave().

double Poller::last_polled_

protected

time of last MPI_Test

Definition at line 40 of file Poller.h.

Referenced by Poller(), and run().

double Poller::poll_delay_

protected

delay in seconds between polls

Definition at line 42 of file Poller.h.

Referenced by run().

---

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

• optimizer/Pilot/Poller.h