drv-output-substitution-goal.hh

Go to the documentation of this file.

#pragma once
 
#include "lix/libutil/notifying-counter.hh"
#include "lix/libstore/store-api.hh"
#include "lix/libstore/build/goal.hh"
#include "lix/libstore/realisation.hh"
#include <future>
 
namespace nix {
 
class Worker;

class DrvOutputSubstitutionGoal : public Goal {

    DrvOutput id;

    std::shared_ptr<const Realisation> outputInfo;

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

    std::shared_ptr<Store> sub;
 
    NotifyingCounter<uint64_t>::Bump maintainRunningSubstitutions;
 
    struct DownloadState
    {
        kj::Own<kj::CrossThreadPromiseFulfiller<void>> outPipe;
        std::future<std::shared_ptr<const Realisation>> result;
    };
 
    std::shared_ptr<DownloadState> downloadState;

    bool substituterFailed = false;
 
public:
    DrvOutputSubstitutionGoal(
        const DrvOutput & id,
        Worker & worker,
        bool isDependency,
        RepairFlag repair = NoRepair,
        std::optional<ContentAddress> ca = std::nullopt
    );
 
    kj::Promise<Result<WorkResult>> tryNext() noexcept;
    kj::Promise<Result<WorkResult>> realisationFetched() noexcept;
    kj::Promise<Result<WorkResult>> outPathValid() noexcept;
    kj::Promise<Result<WorkResult>> finished() noexcept;
 
    kj::Promise<Result<WorkResult>> workImpl() noexcept override;
 
    JobCategory jobCategory() const override {
        return JobCategory::Substitution;
    };
};
 
}