substitution-goal.hh

Go to the documentation of this file.

#pragma once
 
#include "lix/libstore/lock.hh"
#include "lix/libutil/notifying-counter.hh"
#include "lix/libstore/store-api.hh"
#include "lix/libstore/build/goal.hh"
 
namespace nix {
 
class Worker;
 
struct PathSubstitutionGoal : public Goal
{
    StorePath storePath;

    std::optional<StorePath> subPath;

    std::list<ref<Store>> subs;

    std::shared_ptr<Store> sub;

    bool substituterFailed = false;

    std::shared_ptr<const ValidPathInfo> info;

    kj::Own<kj::CrossThreadPromiseFulfiller<void>> outPipe;

    std::future<void> thr;

    RepairFlag repair;

    Path destPath;
 
    NotifyingCounter<uint64_t>::Bump maintainExpectedSubstitutions,
        maintainRunningSubstitutions, maintainExpectedNar, maintainExpectedDownload;

    std::optional<ContentAddress> ca;
 
    WorkResult done(
        ExitCode result,
        BuildResult::Status status,
        std::optional<std::string> errorMsg = {});
 
public:
    PathSubstitutionGoal(
        const StorePath & storePath,
        Worker & worker,
        bool isDependency,
        RepairFlag repair = NoRepair,
        std::optional<ContentAddress> ca = std::nullopt
    );
    ~PathSubstitutionGoal();
 
    kj::Promise<Result<WorkResult>> workImpl() noexcept override;

    kj::Promise<Result<WorkResult>> tryNext() noexcept;
    kj::Promise<Result<WorkResult>> referencesValid() noexcept;
    kj::Promise<Result<WorkResult>> tryToRun() noexcept;
    kj::Promise<Result<WorkResult>> finished() noexcept;
 
    /* Called by destructor, can't be overridden */
    void cleanup() override final;
 
    JobCategory jobCategory() const override {
        return JobCategory::Substitution;
    };
};
 
}