stage.h

Go to the documentation of this file.

 
#pragma once
 
#include "backend/types.h"
#include "fzm_format.h"
#include "stage/fusion.h"
#include <array>
#include <cstdint>
#include <stdexcept>
#include <string>
#include <unordered_map>
#include <vector>
 
namespace fz {
 
// Forward declaration — avoids requiring mempool.h in every stage header
class MemoryPool;
 
class Stage {
public:
    virtual ~Stage() = default;
 
    static constexpr bool isSupportedOnBackend() { return true; }
 
    virtual void execute(
        fz::stream_t stream,
        MemoryPool* pool,
        const std::vector<void*>& inputs,
        const std::vector<void*>& outputs,
        const std::vector<size_t>& sizes
    ) = 0;
 
    virtual std::string getName() const = 0;
 
    virtual size_t getNumInputs()  const = 0;
    virtual size_t getNumOutputs() const = 0;
 
    virtual size_t getRequiredInputAlignment() const { return 1; }
 
    virtual std::vector<std::string> getOutputNames() const {
        return {"output"};
    }
 
    int getOutputIndex(const std::string& name) const {
        auto names = getOutputNames();
        for (size_t i = 0; i < names.size(); i++) {
            if (names[i] == name) return static_cast<int>(i);
        }
        return -1;
    }
 
    virtual std::vector<size_t> estimateOutputSizes(
        const std::vector<size_t>& input_sizes
    ) const = 0;
 
    virtual std::unordered_map<std::string, size_t> getActualOutputSizesByName() const = 0;
 
    virtual size_t getActualOutputSize(int index) const {
        auto names = getOutputNames();
        if (index < 0 || index >= static_cast<int>(names.size())) return 0;
        auto m  = getActualOutputSizesByName();
        auto it = m.find(names[index]);
        return (it != m.end()) ? it->second : 0;
    }
 
    virtual void setInverse(bool inverse) { (void)inverse; }
    virtual bool isInverse() const { return false; }
 
    virtual uint16_t getStageTypeId() const = 0;
 
    virtual uint8_t getOutputDataType(size_t output_index) const = 0;
 
    virtual uint8_t getInputDataType(size_t /*input_index*/) const {
        return static_cast<uint8_t>(DataType::UNKNOWN);
    }
 
    virtual size_t serializeHeader(size_t output_index, uint8_t* header_buffer, size_t max_size) const {
        (void)output_index; (void)header_buffer; (void)max_size;
        return 0;
    }
 
    virtual void deserializeHeader(const uint8_t* header_buffer, size_t size) {
        (void)header_buffer; (void)size;
    }
 
    virtual void saveState()    {}
    virtual void restoreState() {}
 
    virtual std::vector<std::string> getRunNotes() const { return {}; }
 
    virtual void setDims(const std::array<size_t, 3>& dims) { (void)dims; }
 
    virtual void onFinalize(size_t /*estimated_inlen*/, MemoryPool* /*pool*/) {}
 
    virtual size_t estimateDeviceFootprintBytes(size_t /*inlen*/) const { return 0; }
 
    virtual size_t estimatePinnedFootprintBytes(size_t /*inlen*/) const { return 0; }
 
    virtual void postStreamSync(fz::stream_t stream) { (void)stream; }
 
    virtual size_t getMaxHeaderSize(size_t output_index) const {
        (void)output_index;
        return 0;
    }
 
    virtual bool isGraphCompatible() const { return true; }
 
    virtual void setTerminalOutput(bool terminal) { (void)terminal; }
 
    virtual size_t estimateScratchBytes(const std::vector<size_t>& input_sizes) const {
        (void)input_sizes;
        return 0;
    }
 
    virtual FusionSpec getFusionSpec() const { return {}; }
 
    virtual FusedOpDecl getFusedOp() const { return {}; }
 
    virtual EncodingOracleDecl getEncodingOracle() const { return {}; }
 
    virtual bool bindDownstreamEncodingOracle(const EncodingOracleDecl& /*decl*/) {
        return false;
    }
 
    virtual std::vector<FusedAuxOutputDecl> getFusedAuxOutputs() const { return {}; }
 
    virtual void primeFusedForwardState(const FusedPrimeContext& /*ctx*/) {}
 
    virtual void setFusedArchiveResult(size_t /*archive_bytes*/, size_t /*orig_bytes*/) {}
 
    virtual void setFusedSideOutput(int /*output_index*/, size_t /*bytes*/) {}
};
 
} // namespace fz