wmva_runner.h

Go to the documentation of this file.

#ifndef WM_VA_RUNNER_H
#define WM_VA_RUNNER_H
 
#include "sync/synchronizer.h"
#include "wmhostaction.h"
 
#include <memory>
#include <vector>
#include <array>
#include <numeric>
 
namespace wxm
{
namespace variable
{
class distributed_variable_t;
}
namespace dfem
{
namespace variable_adjuster
{
class variable_adjuster_t;
}
} // namespace dfem
 
class va_runner : public WmHostAction
{
    // internal storage for patch processes to run
    std::vector<std::unique_ptr<WmHostAction>> processors_;
 
    bool add_variables(const WxCryptSet& wxc, const std::string& name);
 
    // all local patch synchronizers
    std::vector<std::unique_ptr<wxm::sync::patch_synchronizer_t>> synchronizers_;
 
public:
    // pair of variable/component
    typedef std::vector<std::pair<wxm::variable::distributed_variable_t*, size_t>>
        variables_type;
 
protected:
    // variable adjusters to be run, in sorted order
    std::vector<wxm::dfem::variable_adjuster::variable_adjuster_t*> adjusters_;
 
    // priorities of the various variable adjusters
    std::vector<int> va_priorities;
 
    int min_priority;
    // maximum number of variable adjuster priority levels
    int max_priority;
 
    // pair of distributed variable and component index
    variables_type variables_;
 
public:
    va_runner(const WmConstOpaquePtr& parent_solver) : WmHostAction(parent_solver)
    {
    }
 
    void setup(const WxCryptSet& wxc) override;
 
    bool needsDomain() const override
    {
        return false;
    }
 
    WxStepperStatus step() override;
 
    void start_sync();
 
    void finish_sync();
 
protected:
    void typeCheck() override;
};
} // namespace wxm
 
#endif