Implements the actual sampling / collecting logic for parallel MIMCMC. More...
#include <ParallelMIMCMCWorker.h>
Implements the actual sampling / collecting logic for parallel MIMCMC.
Workers will, in a loop until finalized, wait for instructions to join a set of collectors or a worker group for sampling. They then listen for commands to execute these tasks until unassigned from that task again. As a collector, workers will request MCMC samples (more specifically, samples and their coarser ancesters in analogy to the sequential MIMCMCBox) from sampling worker groups. As part of a sampling worker group, they will compute MCMC samples and provide them to other processes via the phonebook.
Definition at line 109 of file ParallelMIMCMCWorker.h.
Public Member Functions | |
WorkerServer (boost::property_tree::ptree const &pt, std::shared_ptr< parcer::Communicator > comm, std::shared_ptr< PhonebookClient > phonebookClient, int RootRank, std::shared_ptr< ParallelizableMIComponentFactory > componentFactory, std::shared_ptr< muq::Utilities::OTF2TracerBase > tracer) | |
WorkerServer::WorkerServer | ( | boost::property_tree::ptree const & | pt, |
std::shared_ptr< parcer::Communicator > | comm, | ||
std::shared_ptr< PhonebookClient > | phonebookClient, | ||
int | RootRank, | ||
std::shared_ptr< ParallelizableMIComponentFactory > | componentFactory, | ||
std::shared_ptr< muq::Utilities::OTF2TracerBase > | tracer | ||
) |
Definition at line 185 of file ParallelMIMCMCWorker.cpp.
References muq::SamplingAlgorithms::ASSIGN, muq::SamplingAlgorithms::ASSIGN_COLLECTOR, muq::Utilities::CollectorBusy, muq::SamplingAlgorithms::ControlTag, muq::SamplingAlgorithms::MEANS, muq::SamplingAlgorithms::MEANS_DONE, multiindexToConfigString(), muq::SamplingAlgorithms::QUIT, muq::SamplingAlgorithms::SAMPLE, muq::SamplingAlgorithms::SAMPLE_BOX, muq::SamplingAlgorithms::SAMPLE_BOX_DONE, muq::Utilities::Sampling, nlohmann::to_string(), muq::SamplingAlgorithms::UNASSIGN, and muq::SamplingAlgorithms::WRITE_TO_FILE.
|
private |
Definition at line 413 of file ParallelMIMCMCWorker.cpp.
Referenced by WorkerServer().