Abstraction / Wrapper for the comms system. Used from mcmc.run() for submitting jobs and retrieves results. More...
#include <asyncdelegator.hpp>
Public Member Functions | |
GeoAsyncPolicy (stateline::comms::Delegator &delegator, const GlobalPrior &prior, const std::set< ForwardModel > &sensorsEnabled) | |
void | submit (uint id, const Eigen::VectorXd &theta) |
Submit job for a parameter set for all sensors. More... | |
std::pair< uint, double > | retrieve () |
Retrieve a job likelihood; collated over all the sensors. More... | |
Abstraction / Wrapper for the comms system. Used from mcmc.run() for submitting jobs and retrieves results.
std::pair< uint, double > obsidian::GeoAsyncPolicy::retrieve | ( | ) |
Retrieve a job likelihood; collated over all the sensors.
void obsidian::GeoAsyncPolicy::submit | ( | uint | id, |
const Eigen::VectorXd & | theta | ||
) |
Submit job for a parameter set for all sensors.
id | a job ID (0 - uint32_t::max |
theta | parameters to compute likelihood of. |