mirror of
https://github.com/privatevoid-net/nix-super.git
synced 2024-11-16 03:06:17 +02:00
bcdee80a0d
- Get a rump derivation goal: hook instance will come later, local derivation goal will come after that. - Start cleaning up the channel / waiting code with an abstraction.
83 lines
1.7 KiB
C++
83 lines
1.7 KiB
C++
#pragma once
|
|
///@file
|
|
|
|
#include <thread>
|
|
#include <future>
|
|
|
|
#include "store-api.hh"
|
|
#include "goal.hh"
|
|
#include "realisation.hh"
|
|
#include "muxable-pipe.hh"
|
|
|
|
namespace nix {
|
|
|
|
class Worker;
|
|
|
|
/**
|
|
* Substitution of a derivation output.
|
|
* This is done in three steps:
|
|
* 1. Fetch the output info from a substituter
|
|
* 2. Substitute the corresponding output path
|
|
* 3. Register the output info
|
|
*/
|
|
class DrvOutputSubstitutionGoal : public Goal {
|
|
|
|
/**
|
|
* The drv output we're trying to substitute
|
|
*/
|
|
DrvOutput id;
|
|
|
|
/**
|
|
* The realisation corresponding to the given output id.
|
|
* Will be filled once we can get it.
|
|
*/
|
|
std::shared_ptr<const Realisation> outputInfo;
|
|
|
|
/**
|
|
* The remaining substituters.
|
|
*/
|
|
std::list<ref<Store>> subs;
|
|
|
|
/**
|
|
* The current substituter.
|
|
*/
|
|
std::shared_ptr<Store> sub;
|
|
|
|
struct DownloadState
|
|
{
|
|
MuxablePipe outPipe;
|
|
std::promise<std::shared_ptr<const Realisation>> promise;
|
|
};
|
|
|
|
std::shared_ptr<DownloadState> downloadState;
|
|
|
|
/**
|
|
* Whether a substituter failed.
|
|
*/
|
|
bool substituterFailed = false;
|
|
|
|
public:
|
|
DrvOutputSubstitutionGoal(const DrvOutput& id, Worker & worker, RepairFlag repair = NoRepair, std::optional<ContentAddress> ca = std::nullopt);
|
|
|
|
typedef void (DrvOutputSubstitutionGoal::*GoalState)();
|
|
GoalState state;
|
|
|
|
void init();
|
|
void tryNext();
|
|
void realisationFetched();
|
|
void outPathValid();
|
|
void finished();
|
|
|
|
void timedOut(Error && ex) override { abort(); };
|
|
|
|
std::string key() override;
|
|
|
|
void work() override;
|
|
void handleEOF(Descriptor fd) override;
|
|
|
|
JobCategory jobCategory() const override {
|
|
return JobCategory::Substitution;
|
|
};
|
|
};
|
|
|
|
}
|