muq::SamplingAlgorithms::WorkerClient Class Reference

High-level communication wrapper for controlling worker processes. More...

#include <ParallelMIMCMCWorker.h>

Detailed Description

High-level communication wrapper for controlling worker processes.

This takes care about assigning workers to a worker group for a specific model index/level, sending commands to them and finally unassigning them again.

Definition at line 80 of file ParallelMIMCMCWorker.h.

Public Member Functions
	WorkerClient (std::shared_ptr< parcer::Communicator > comm, std::shared_ptr< PhonebookClient > phonebookClient, int RootRank)
void	assignGroup (std::vector< int > subgroup, std::shared_ptr< MultiIndex > modelindex)
std::vector< int >	UnassignGroup (std::shared_ptr< MultiIndex > modelIndex, int groupRootRank)
void	UnassignAll ()
void	Finalize ()

Constructor & Destructor Documentation

WorkerClient()

WorkerClient::WorkerClient	(	std::shared_ptr< parcer::Communicator >	comm,
		std::shared_ptr< PhonebookClient >	phonebookClient,
		int	RootRank
	)

Definition at line 139 of file ParallelMIMCMCWorker.cpp.

Member Function Documentation

assignGroup()

void WorkerClient::assignGroup	(	std::vector< int >	subgroup,
		std::shared_ptr< MultiIndex >	modelindex
	)

Definition at line 146 of file ParallelMIMCMCWorker.cpp.

References muq::SamplingAlgorithms::ASSIGN, comm, muq::SamplingAlgorithms::ControlTag, and phonebookClient.

Referenced by muq::SamplingAlgorithms::StaticLoadBalancingMIMCMC::RunSamples(), and muq::SamplingAlgorithms::StaticLoadBalancingMIMCMC::StaticLoadBalancingMIMCMC().

Finalize()

void WorkerClient::Finalize

(

)

Definition at line 179 of file ParallelMIMCMCWorker.cpp.

References comm, muq::SamplingAlgorithms::ControlTag, and muq::SamplingAlgorithms::QUIT.

Referenced by muq::SamplingAlgorithms::StaticLoadBalancingMIMCMC::Finalize().

UnassignAll()

void WorkerClient::UnassignAll

(

)

Definition at line 166 of file ParallelMIMCMCWorker.cpp.

References phonebookClient, and UnassignGroup().

Referenced by muq::SamplingAlgorithms::StaticLoadBalancingMIMCMC::Finalize().

UnassignGroup()

std::vector< int > WorkerClient::UnassignGroup	(	std::shared_ptr< MultiIndex >	modelIndex,
		int	groupRootRank
	)

Definition at line 156 of file ParallelMIMCMCWorker.cpp.

References comm, muq::SamplingAlgorithms::ControlTag, phonebookClient, and muq::SamplingAlgorithms::UNASSIGN.

Referenced by muq::SamplingAlgorithms::StaticLoadBalancingMIMCMC::RunSamples(), and UnassignAll().

Member Data Documentation

comm

std::shared_ptr<parcer::Communicator> muq::SamplingAlgorithms::WorkerClient::comm

private

Definition at line 95 of file ParallelMIMCMCWorker.h.

Referenced by assignGroup(), Finalize(), and UnassignGroup().

phonebookClient

std::shared_ptr<PhonebookClient> muq::SamplingAlgorithms::WorkerClient::phonebookClient

private

Definition at line 96 of file ParallelMIMCMCWorker.h.

Referenced by assignGroup(), UnassignAll(), and UnassignGroup().

---

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

• doxygen_prep/MUQ/SamplingAlgorithms/ParallelMIMCMCWorker.h
• doxygen_prep/modules/SamplingAlgorithms/src/ParallelMIMCMCWorker.cpp