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. |