reload_swap_units.hpp

Go to the documentation of this file.

#pragma once

 
#include <pulp/format/reload/live_swap_transaction.hpp>
#include <pulp/format/reload/reload_transaction.hpp>
 
#include <string>
#include <utility>
 
namespace pulp::format::reload {

class DspReloadSwapUnit : public SwapUnit {
public:
    DspReloadSwapUnit(ReloadSession& session, std::string library_path,
                      std::string stage_name = "dsp")
        : session_(session),
          library_path_(std::move(library_path)),
          name_(std::move(stage_name)) {}
 
    std::string name() const override { return name_; }
 
    SwapStage to_stage() override {
        return SwapStage{
            name_,
            [this] {
                last_ = session_.reload(library_path_);
                return last_.ok();
            },
            // No-op: this stage is terminal in the transaction ordering (DSP last),
            // and the reload is atomic on failure, so there is nothing to undo.
            [] {}};
    }

    const ReloadOutcome& last_outcome() const { return last_; }
 
private:
    ReloadSession& session_;
    std::string library_path_;
    std::string name_;
    ReloadOutcome last_{};
};
 
}  // namespace pulp::format::reload