TextureContainer.cpp

Go to the documentation of this file.

#include "TextureContainer.hpp"
 
#include "MayaFlux/Core/Backends/Graphics/Vulkan/VKImage.hpp"
#include "MayaFlux/Kakshya/DataProcessingChain.hpp"
#include "MayaFlux/Kakshya/NDData/DataAccess.hpp"
 
#include "MayaFlux/Kakshya/Utils/CoordUtils.hpp"
#include "MayaFlux/Kakshya/Utils/DataUtils.hpp"
#include "MayaFlux/Kakshya/Utils/PixelStorage.hpp"
#include "MayaFlux/Kakshya/Utils/RegionUtils.hpp"
 
#include "MayaFlux/Portal/Graphics/TextureLoom.hpp"
 
#include "MayaFlux/Journal/Archivist.hpp"
 
namespace MayaFlux::Kakshya {
 
using Portal::Graphics::ImageFormat;
using Portal::Graphics::TextureLoom;
 
//=============================================================================
// Construction
//=============================================================================
 
TextureContainer::TextureContainer(uint32_t width, uint32_t height, ImageFormat format, uint32_t layers)
    : m_width(width)
    , m_height(height)
    , m_format(format)
    , m_channels(TextureLoom::get_channel_count(format))
    , m_bpp(TextureLoom::get_bytes_per_pixel(format))
{
    m_chain = std::make_shared<DataProcessingChain>();
    const size_t element_count = static_cast<size_t>(m_width) * m_height * m_channels;
 
    for (uint32_t i = 0; i < std::max(layers, 1U); ++i) {
        m_data.emplace_back(make_empty_storage(m_format, element_count));
    }
 
    m_normalised_cache.resize(m_data.size());
 
    m_normalised_dirty = std::vector<std::atomic<bool>>(m_data.size());
    for (auto& flag : m_normalised_dirty)
        flag.store(true, std::memory_order_relaxed);
 
    m_slot_locks.resize(m_data.size());
    setup_dimensions();
 
    m_ready_for_processing.store(true);
 
    MF_INFO(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
        "TextureContainer created: {}x{} layers={} fmt={} bpp={}",
        m_width, m_height, m_data.size(), static_cast<int>(m_format), m_bpp);
}
 
TextureContainer::TextureContainer(const std::shared_ptr<Core::VKImage>& image, ImageFormat format)
    : TextureContainer(image->get_width(), image->get_height(), format)
{
    from_image(image, 0);
}
 
//=============================================================================
// Setup
//=============================================================================
 
void TextureContainer::setup_dimensions()
{
    const uint64_t h = m_height;
    const uint64_t w = m_width;
    const uint64_t c = m_channels;
    const auto n = static_cast<uint64_t>(m_data.size());
 
    m_structure = ContainerDataStructure::image_interleaved();
 
    if (n > 1) {
        m_structure.dimensions = DataDimension::create_dimensions(
            DataModality::IMAGE_COLOR_ARRAY, { n, h, w, c }, MemoryLayout::ROW_MAJOR);
    } else {
        m_structure.dimensions = DataDimension::create_dimensions(
            DataModality::IMAGE_COLOR, { h, w, c }, MemoryLayout::ROW_MAJOR);
    }
}
 
//=============================================================================
// GPU bridge
//=============================================================================
 
void TextureContainer::from_image(const std::shared_ptr<Core::VKImage>& image, uint32_t layer)
{
    if (!image || !image->is_initialized()) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::from_image called with uninitialised image");
        return;
    }
 
    if (layer >= m_data.size()) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::from_image layer {} out of range ({})", layer, m_data.size());
        return;
    }
 
    const size_t sz = byte_size();
    const size_t element_count = static_cast<size_t>(m_width) * m_height * m_channels;
 
    {
        Memory::SeqlockWriteGuard g(m_slot_locks[layer]);
        m_data[layer] = make_empty_storage(m_format, element_count);
        auto [ptr, bytes] = variant_bytes_mutable(m_data[layer]);
        if (!ptr || bytes != sz) {
            MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
                "TextureContainer::from_image variant size mismatch ({} vs {})", bytes, sz);
            return;
        }
        TextureLoom::instance().download_data(image, ptr, sz, nullptr);
    }
 
    m_normalised_dirty[layer].store(true, std::memory_order_release);
    update_processing_state(ProcessingState::READY);
}
 
void TextureContainer::from_image(
    const std::shared_ptr<Core::VKImage>& image,
    const std::shared_ptr<Buffers::VKBuffer>& staging,
    uint32_t layer)
{
    if (!image || !image->is_initialized()) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::from_image(staging) called with uninitialised image");
        return;
    }
 
    if (layer >= m_data.size()) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::from_image(staging) layer {} out of range ({})", layer, m_data.size());
        return;
    }
 
    const size_t sz = byte_size();
    const size_t element_count = static_cast<size_t>(m_width) * m_height * m_channels;
 
    {
        Memory::SeqlockWriteGuard g(m_slot_locks[layer]);
        m_data[layer] = make_empty_storage(m_format, element_count);
        auto [ptr, bytes] = variant_bytes_mutable(m_data[layer]);
        if (!ptr || bytes != sz) {
            MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
                "TextureContainer::from_image(staging) variant size mismatch ({} vs {})", bytes, sz);
            return;
        }
        TextureLoom::instance().download_data(image, ptr, sz, staging);
    }
 
    m_normalised_dirty[layer].store(true, std::memory_order_release);
    update_processing_state(ProcessingState::READY);
}
 
void TextureContainer::from_image_array(const std::shared_ptr<Core::VKImage>& image)
{
    if (!image || !image->is_initialized()) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::from_image_array called with uninitialised image");
        return;
    }
 
    const auto n = static_cast<uint32_t>(m_data.size());
    if (image->get_array_layers() < n) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::from_image_array image has {} layers, container expects {}",
            image->get_array_layers(), n);
        return;
    }
 
    const size_t layer_bytes = byte_size();
    std::vector<uint8_t> combined(layer_bytes * n);
    TextureLoom::instance().download_data(image, combined.data(), combined.size(), nullptr);
 
    const size_t element_count = static_cast<size_t>(m_width) * m_height * m_channels;
    for (uint32_t i = 0; i < n; ++i) {
        Memory::SeqlockWriteGuard g(m_slot_locks[i]);
        m_data[i] = make_empty_storage(m_format, element_count);
        auto [ptr, bytes] = variant_bytes_mutable(m_data[i]);
        if (ptr && bytes == layer_bytes)
            std::memcpy(ptr, combined.data() + i * layer_bytes, layer_bytes);
 
        m_normalised_dirty[i].store(true, std::memory_order_release);
    }
 
    update_processing_state(ProcessingState::READY);
}
 
void TextureContainer::from_image_array(
    const std::shared_ptr<Core::VKImage>& image,
    const std::shared_ptr<Buffers::VKBuffer>& staging)
{
    if (!image || !image->is_initialized()) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::from_image_array(staging) called with uninitialised image");
        return;
    }
 
    const auto n = static_cast<uint32_t>(m_data.size());
    if (image->get_array_layers() < n) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::from_image_array(staging) image has {} layers, container expects {}",
            image->get_array_layers(), n);
        return;
    }
 
    const size_t layer_bytes = byte_size();
    std::vector<uint8_t> combined(layer_bytes * n);
    TextureLoom::instance().download_data(image, combined.data(), combined.size(), staging);
 
    const size_t element_count = static_cast<size_t>(m_width) * m_height * m_channels;
    for (uint32_t i = 0; i < n; ++i) {
        Memory::SeqlockWriteGuard g(m_slot_locks[i]);
        m_data[i] = make_empty_storage(m_format, element_count);
        auto [ptr, bytes] = variant_bytes_mutable(m_data[i]);
        if (ptr && bytes == layer_bytes)
            std::memcpy(ptr, combined.data() + i * layer_bytes, layer_bytes);
 
        m_normalised_dirty[i].store(true, std::memory_order_release);
    }
 
    update_processing_state(ProcessingState::READY);
}
 
std::shared_ptr<Core::VKImage> TextureContainer::to_image(uint32_t layer) const
{
    if (layer >= m_data.size()) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::to_image layer {} out of range ({})", layer, m_data.size());
        return nullptr;
    }
 
    std::shared_ptr<Core::VKImage> img;
    seqlock_read_void(m_slot_locks[layer], 8, [&] {
        auto [ptr, bytes] = variant_bytes(m_data[layer]);
        if (!ptr || bytes == 0)
            return;
        img = TextureLoom::instance().create_2d(m_width, m_height, m_format, ptr);
    });
 
    if (!img) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::to_image: TextureLoom failed to create VKImage");
    }
    return img;
}
 
std::shared_ptr<Core::VKImage> TextureContainer::to_image(
    uint32_t layer, const std::shared_ptr<Buffers::VKBuffer>& staging) const
{
    if (layer >= m_data.size()) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::to_image(staging) layer {} out of range ({})", layer, m_data.size());
        return nullptr;
    }
 
    std::shared_ptr<Core::VKImage> img;
    seqlock_read_void(m_slot_locks[layer], 8, [&] {
        auto [ptr, bytes] = variant_bytes(m_data[layer]);
        if (!ptr || bytes == 0) {
            MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
                "TextureContainer::to_image(staging) called on empty/invalid buffer");
            return;
        }
        auto& loom = TextureLoom::instance();
        img = loom.create_2d(m_width, m_height, m_format, nullptr);
        if (!img) {
            MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
                "TextureContainer::to_image(staging): VKImage allocation failed");
            return;
        }
        loom.upload_data(img, ptr, bytes, staging);
    });
    return img;
}
 
std::shared_ptr<Core::VKImage> TextureContainer::to_image_array() const
{
    const auto n = static_cast<uint32_t>(m_data.size());
    if (n == 0)
        return nullptr;
 
    if (n == 1) {
        std::shared_ptr<Core::VKImage> img;
        seqlock_read_void(m_slot_locks[0], 8, [&] {
            auto [ptr, bytes] = variant_bytes(m_data[0]);
            if (!ptr || bytes == 0)
                return;
            img = TextureLoom::instance().create_2d(m_width, m_height, m_format, ptr);
        });
        return img;
    }
 
    const size_t layer_bytes = byte_size();
    std::vector<uint8_t> combined(layer_bytes * n);
    for (uint32_t i = 0; i < n; ++i) {
        bool ok = seqlock_read_void(m_slot_locks[i], 8, [&] {
            auto [ptr, bytes] = variant_bytes(m_data[i]);
            if (!ptr || bytes != layer_bytes) {
                MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
                    "TextureContainer::to_image_array layer {} has unexpected byte count ({} vs {})",
                    i, bytes, layer_bytes);
                return;
            }
            std::memcpy(combined.data() + i * layer_bytes, ptr, layer_bytes);
        });
        if (!ok)
            return nullptr;
    }
 
    return TextureLoom::instance().create_2d_array(m_width, m_height, n, m_format, combined.data());
}
 
std::shared_ptr<Core::VKImage> TextureContainer::to_image_array(
    const std::shared_ptr<Buffers::VKBuffer>& staging) const
{
    const auto n = static_cast<uint32_t>(m_data.size());
    if (n == 0)
        return nullptr;
 
    if (n == 1) {
        std::shared_ptr<Core::VKImage> img;
        seqlock_read_void(m_slot_locks[0], 8, [&] {
            auto [ptr, bytes] = variant_bytes(m_data[0]);
            if (!ptr || bytes == 0)
                return;
            auto& loom = TextureLoom::instance();
            img = loom.create_2d(m_width, m_height, m_format, nullptr);
            if (img)
                loom.upload_data(img, ptr, bytes, staging);
        });
        return img;
    }
 
    const size_t layer_bytes = byte_size();
    std::vector<uint8_t> combined(layer_bytes * n);
    for (uint32_t i = 0; i < n; ++i) {
        bool ok = seqlock_read_void(m_slot_locks[i], 8, [&] {
            auto [ptr, bytes] = variant_bytes(m_data[i]);
            if (!ptr || bytes != layer_bytes) {
                MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
                    "TextureContainer::to_image_array(staging) layer {} size mismatch", i);
                return;
            }
            std::memcpy(combined.data() + i * layer_bytes, ptr, layer_bytes);
        });
 
        if (!ok)
            return nullptr;
    }
 
    auto& loom = TextureLoom::instance();
    auto img = loom.create_2d_array(m_width, m_height, n, m_format, nullptr);
    if (!img)
        return nullptr;
    loom.upload_data(img, combined.data(), combined.size(), staging);
    return img;
}
 
//=============================================================================
// Pixel access
//=============================================================================
 
std::span<const uint8_t> TextureContainer::pixel_bytes(uint32_t layer) const
{
    if (layer >= m_data.size())
        return {};
    auto [ptr, bytes] = variant_bytes(m_data[layer]);
    return ptr ? std::span<const uint8_t>(ptr, bytes) : std::span<const uint8_t> {};
}
 
std::span<uint8_t> TextureContainer::pixel_bytes(uint32_t layer)
{
    if (layer >= m_data.size())
        return {};
    auto [ptr, bytes] = variant_bytes_mutable(m_data[layer]);
    return ptr ? std::span<uint8_t>(ptr, bytes) : std::span<uint8_t> {};
}
 
std::span<const uint8_t> TextureContainer::as_uint8(uint32_t layer) const
{
    if (layer >= m_data.size())
        return {};
    const auto* v = std::get_if<std::vector<uint8_t>>(&m_data[layer]);
    return v ? std::span<const uint8_t>(v->data(), v->size()) : std::span<const uint8_t> {};
}
 
std::span<const uint16_t> TextureContainer::as_uint16(uint32_t layer) const
{
    if (layer >= m_data.size())
        return {};
    const auto* v = std::get_if<std::vector<uint16_t>>(&m_data[layer]);
    return v ? std::span<const uint16_t>(v->data(), v->size()) : std::span<const uint16_t> {};
}
 
std::span<const float> TextureContainer::as_float(uint32_t layer) const
{
    if (layer >= m_data.size())
        return {};
    const auto* v = std::get_if<std::vector<float>>(&m_data[layer]);
    return v ? std::span<const float>(v->data(), v->size()) : std::span<const float> {};
}
 
void TextureContainer::set_pixels(std::span<const uint8_t> data, uint32_t layer)
{
    if (layer >= m_data.size()) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::set_pixels(u8) layer {} out of range", layer);
        return;
    }
    auto* buf = std::get_if<std::vector<uint8_t>>(&m_data[layer]);
    if (!buf) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::set_pixels(u8) called on non-uint8 format {}",
            static_cast<int>(m_format));
        return;
    }
    if (data.size() != buf->size()) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::set_pixels(u8) size mismatch: got {} expected {}",
            data.size(), buf->size());
        return;
    }
 
    Memory::SeqlockWriteGuard g(m_slot_locks[layer]);
    std::ranges::copy(data, buf->begin());
    m_normalised_dirty[layer].store(true, std::memory_order_release);
}
 
void TextureContainer::set_pixels(std::span<const uint16_t> data, uint32_t layer)
{
    if (layer >= m_data.size()) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::set_pixels(u16) layer {} out of range", layer);
        return;
    }
    auto* buf = std::get_if<std::vector<uint16_t>>(&m_data[layer]);
    if (!buf) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::set_pixels(u16) called on non-uint16 format {}",
            static_cast<int>(m_format));
        return;
    }
    if (data.size() != buf->size()) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::set_pixels(u16) size mismatch: got {} expected {}",
            data.size(), buf->size());
        return;
    }
 
    Memory::SeqlockWriteGuard g(m_slot_locks[layer]);
    std::ranges::copy(data, buf->begin());
    m_normalised_dirty[layer].store(true, std::memory_order_release);
}
 
void TextureContainer::set_pixels(std::span<const float> data, uint32_t layer)
{
    if (layer >= m_data.size()) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::set_pixels(f32) layer {} out of range", layer);
        return;
    }
    auto* buf = std::get_if<std::vector<float>>(&m_data[layer]);
    if (!buf) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::set_pixels(f32) called on non-float format {}",
            static_cast<int>(m_format));
        return;
    }
    if (data.size() != buf->size()) {
        MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
            "TextureContainer::set_pixels(f32) size mismatch: got {} expected {}",
            data.size(), buf->size());
        return;
    }
 
    Memory::SeqlockWriteGuard g(m_slot_locks[layer]);
    std::ranges::copy(data, buf->begin());
    m_normalised_dirty[layer].store(true, std::memory_order_release);
}
 
std::span<const float> TextureContainer::as_normalised_float(uint32_t layer) const
{
    if (layer >= m_data.size())
        return {};
 
    if (!m_normalised_dirty[layer].load(std::memory_order_acquire))
        return { m_normalised_cache[layer] };
 
    std::span<const float> result;
    seqlock_read_void(m_slot_locks[layer], 8, [&] {
        result = Kakshya::as_normalised_float(m_data[layer], m_normalised_cache[layer]);
    });
 
    if (!result.empty())
        m_normalised_dirty[layer].store(false, std::memory_order_release);
 
    return result;
}
 
//=============================================================================
// NDDimensionalContainer
//=============================================================================
 
std::vector<DataDimension> TextureContainer::get_dimensions() const
{
    return m_structure.dimensions;
}
 
uint64_t TextureContainer::get_total_elements() const
{
    return m_structure.get_total_elements();
}
 
MemoryLayout TextureContainer::get_memory_layout() const
{
    return m_structure.memory_layout;
}
 
void TextureContainer::set_memory_layout(MemoryLayout layout)
{
    m_structure.memory_layout = layout;
}
 
uint64_t TextureContainer::get_frame_size() const
{
    return static_cast<uint64_t>(m_width) * m_channels;
}
 
uint64_t TextureContainer::get_num_frames() const
{
    return m_height;
}
 
std::vector<DataVariant> TextureContainer::get_region_data(const Region& region) const
{
    if (m_data.empty())
        return {};
 
    const size_t layer = (m_data.size() > 1 && !region.start_coordinates.empty())
        ? static_cast<size_t>(region.start_coordinates[0])
        : 0;
 
    if (layer >= m_data.size())
        return {};
 
    std::optional<std::vector<DataVariant>> result;
    seqlock_read_void(m_slot_locks[layer], 8, [&] {
        result = std::visit(
            [&](const auto& vec) -> std::vector<DataVariant> {
                using T = typename std::decay_t<decltype(vec)>::value_type;
                if constexpr (std::is_same_v<T, uint8_t>
                    || std::is_same_v<T, uint16_t>
                    || std::is_same_v<T, float>) {
                    auto extracted = extract_region_data<T>(
                        std::span<const T>(vec.data(), vec.size()),
                        region,
                        m_structure.dimensions);
                    return { DataVariant(std::move(extracted)) };
                } else {
                    return {};
                }
            },
            m_data[layer]);
    });
    return result.value_or(std::vector<DataVariant> {});
}
 
std::vector<DataVariant> TextureContainer::get_segments_data(
    const std::vector<RegionSegment>& /*segments*/) const
{
    std::vector<DataVariant> out;
    out.reserve(m_data.size());
    for (size_t i = 0; i < m_data.size(); ++i) {
        seqlock_read_void(m_slot_locks[i], 8, [&] {
            out.push_back(m_data[i]);
        });
    }
    return out;
}
 
void TextureContainer::set_region_data(
    const Region& region, const std::vector<DataVariant>& data)
{
    if (data.empty())
        return;
    if (region.start_coordinates.size() < 2 || region.end_coordinates.size() < 2)
        return;
 
    const size_t layer = (m_data.size() > 1 && !region.start_coordinates.empty())
        ? static_cast<size_t>(region.start_coordinates[0])
        : 0;
 
    if (layer >= m_data.size())
        return;
 
    const size_t coord_offset = (m_data.size() > 1) ? 1 : 0;
    const uint64_t y0 = region.start_coordinates[coord_offset];
    const uint64_t x0 = region.start_coordinates[coord_offset + 1];
    const uint64_t y1 = std::min(region.end_coordinates[coord_offset], static_cast<uint64_t>(m_height - 1));
    const uint64_t x1 = std::min(region.end_coordinates[coord_offset + 1], static_cast<uint64_t>(m_width - 1));
 
    Memory::SeqlockWriteGuard g(m_slot_locks[layer]);
    std::visit(
        [&](auto& dst_vec) {
            using T = typename std::decay_t<decltype(dst_vec)>::value_type;
            if constexpr (std::is_same_v<T, uint8_t>
                || std::is_same_v<T, uint16_t>
                || std::is_same_v<T, float>) {
                const auto* src = std::get_if<std::vector<T>>(&data[0]);
                if (!src || src->empty()) {
                    MF_ERROR(Journal::Component::Kakshya, Journal::Context::ContainerProcessing,
                        "TextureContainer::set_region_data source variant does not match "
                        "container element type");
                    return;
                }
                size_t src_idx = 0;
                for (uint64_t y = y0; y <= y1 && src_idx < src->size(); ++y) {
                    for (uint64_t x = x0; x <= x1 && src_idx < src->size(); ++x) {
                        const size_t dst_idx = (y * m_width + x) * m_channels;
                        for (uint32_t c = 0; c < m_channels && src_idx < src->size(); ++c, ++src_idx) {
                            if (dst_idx + c < dst_vec.size())
                                dst_vec[dst_idx + c] = (*src)[src_idx];
                        }
                    }
                }
            }
        },
        m_data[layer]);
}
 
std::type_index TextureContainer::value_element_type() const
{
    size_t element_size = storage_element_size(m_format);
    if (element_size == 1) {
        return typeid(uint8_t);
    }
    if (element_size == 2) {
        return typeid(uint16_t);
    }
    if (element_size == 4) {
        return typeid(float);
    }
 
    return typeid(uint8_t);
}
 
uint64_t TextureContainer::coordinates_to_linear_index(const std::vector<uint64_t>& coords) const
{
    return coordinates_to_linear(coords, m_structure.dimensions);
}
 
std::vector<uint64_t> TextureContainer::linear_index_to_coordinates(uint64_t index) const
{
    return linear_to_coordinates(index, m_structure.dimensions);
}
 
void TextureContainer::clear()
{
    const size_t element_count = static_cast<size_t>(m_width) * m_height * m_channels;
 
    for (size_t i = 0; i < m_data.size(); ++i) {
        Memory::SeqlockWriteGuard g(m_slot_locks[i]);
        m_data[i] = make_empty_storage(m_format, element_count);
    }
 
    update_processing_state(ProcessingState::IDLE);
}
 
//=============================================================================
// SignalSourceContainer
//=============================================================================
 
ProcessingState TextureContainer::get_processing_state() const
{
    return m_processing_state.load();
}
 
void TextureContainer::update_processing_state(ProcessingState state)
{
    ProcessingState prev = m_processing_state.exchange(state);
    if (prev == state)
        return;
 
    seqlock_read_void(m_cb_lock, 8, [&] {
        if (m_state_cb)
            m_state_cb(shared_from_this(), state);
    });
}
 
void TextureContainer::register_state_change_callback(
    std::function<void(const std::shared_ptr<SignalSourceContainer>&, ProcessingState)> cb)
{
    Memory::SeqlockWriteGuard g(m_cb_lock);
    m_state_cb = std::move(cb);
}
 
void TextureContainer::unregister_state_change_callback()
{
    Memory::SeqlockWriteGuard g(m_cb_lock);
    m_state_cb = nullptr;
}
 
bool TextureContainer::is_ready_for_processing() const
{
    return m_ready_for_processing.load(std::memory_order_acquire);
}
 
void TextureContainer::mark_ready_for_processing(bool ready)
{
    m_ready_for_processing.store(ready, std::memory_order_release);
}
 
std::vector<DataVariant>& TextureContainer::get_processed_data()
{
    return m_processed_data;
}
 
const std::vector<DataVariant>& TextureContainer::get_processed_data() const
{
    return m_processed_data;
}
 
const std::vector<DataVariant>& TextureContainer::get_data()
{
    return m_data;
}
 
DataAccess TextureContainer::channel_data(size_t channel_index)
{
    (void)channel_index;
 
    if (m_data.empty()) {
        static DataVariant empty = std::vector<uint8_t> {};
        static std::vector<DataDimension> empty_dims;
        return { empty, empty_dims, DataModality::IMAGE_COLOR };
    }
 
    return { m_data[0], m_structure.dimensions, DataModality::IMAGE_COLOR };
}
 
std::vector<DataAccess> TextureContainer::all_channel_data()
{
    std::vector<DataAccess> result;
    result.reserve(m_channels);
    for (size_t c = 0; c < m_channels; ++c)
        result.push_back(channel_data(c));
    return result;
}
 
void TextureContainer::add_region_group(const RegionGroup& group)
{
    Memory::SeqlockWriteGuard g(m_region_lock);
    m_region_groups[group.name] = group;
}
 
RegionGroup TextureContainer::get_region_group(const std::string& name) const
{
    static const RegionGroup empty;
    std::optional<RegionGroup> result;
    seqlock_read_void(m_region_lock, 8, [&] {
        auto it = m_region_groups.find(name);
        result = (it != m_region_groups.end()) ? it->second : empty;
    });
    return result.value_or(empty);
}
 
std::unordered_map<std::string, RegionGroup> TextureContainer::get_all_region_groups() const
{
    std::optional<std::unordered_map<std::string, RegionGroup>> result;
    seqlock_read_void(m_region_lock, 8, [&] {
        result = m_region_groups;
    });
    return result.value_or(std::unordered_map<std::string, RegionGroup> {});
}
 
void TextureContainer::remove_region_group(const std::string& name)
{
    Memory::SeqlockWriteGuard g(m_region_lock);
    m_region_groups.erase(name);
}
 
const void* TextureContainer::get_raw_data() const
{
    if (m_data.empty()) {
        return nullptr;
    }
 
    auto [ptr, bytes] = variant_bytes(m_data[0]);
    return (ptr && bytes > 0) ? static_cast<const void*>(ptr) : nullptr;
}
 
bool TextureContainer::has_data() const
{
    if (m_data.empty()) {
        return false;
    }
 
    auto [ptr, bytes] = variant_bytes(m_data[0]);
    return ptr && bytes > 0;
}
 
std::shared_ptr<DataProcessingChain> TextureContainer::get_processing_chain()
{
    if (!m_chain) {
        m_chain = std::make_shared<DataProcessingChain>();
    }
    return m_chain;
}
 
void TextureContainer::get_frames_impl(
    void* output,
    size_t count,
    uint64_t start_frame,
    uint64_t num_frames,
    const std::type_info& type) const
{
    get_frames_typed(output, count, start_frame, num_frames, type);
}
 
auto TextureContainer::get_frame_typed(uint64_t frame_index) const -> DataSpanVariant
{
    if (frame_index >= m_data.size()) {
        return { std::span<const uint8_t> {} };
    }
 
    const size_t layer_elems = static_cast<size_t>(m_width) * m_height * m_channels;
    DataSpanVariant out { std::span<const uint8_t> {} };
    seqlock_read_void(m_slot_locks[frame_index], 8, [&] {
        out = std::visit(
            [&](const auto& vec) -> DataSpanVariant {
                using T = typename std::decay_t<decltype(vec)>::value_type;
                if constexpr (std::is_same_v<T, uint8_t> || std::is_same_v<T, uint16_t> || std::is_same_v<T, float>) {
                    const size_t nn = std::min(layer_elems, vec.size());
                    return DataSpanVariant(std::span<const T>(vec.data(), nn));
                } else {
                    return { std::span<const uint8_t> {} };
                }
            },
            m_data[frame_index]);
    });
    return out;
}
 
void TextureContainer::get_frames_typed(
    void* output,
    size_t count,
    uint64_t start_frame,
    uint64_t num_frames,
    const std::type_info& type) const
{
    if (type == typeid(uint8_t)) {
        get_frames_typed_as<uint8_t>(std::span<uint8_t>(static_cast<uint8_t*>(output), count), start_frame, num_frames);
        return;
    }
    if (type == typeid(uint16_t)) {
        get_frames_typed_as<uint16_t>(std::span<uint16_t>(static_cast<uint16_t*>(output), count), start_frame, num_frames);
        return;
    }
    if (type == typeid(float)) {
        get_frames_typed_as<float>(std::span<float>(static_cast<float*>(output), count), start_frame, num_frames);
        return;
    }
 
    error<std::runtime_error>(
        Journal::Component::Kakshya,
        Journal::Context::Runtime,
        std::source_location::current(),
        "TextureContainer supports only uint8_t, uint16_t, and float for typed frame extraction");
}
 
template <typename T>
auto TextureContainer::get_frame_typed_as(uint64_t frame_index) const -> std::span<const T>
{
    if (frame_index >= m_data.size())
        return {};
 
    std::span<const T> result;
    seqlock_read_void(m_slot_locks[frame_index], 8, [&] {
        const auto* vec = std::get_if<std::vector<T>>(&m_data[frame_index]);
        if (!vec || vec->empty())
            return;
        const size_t layer_elems = static_cast<size_t>(m_width) * m_height * m_channels;
        const size_t n = std::min(layer_elems, vec->size());
        result = std::span<const T>(vec->data(), n);
    });
 
    return result;
}
 
template <typename T>
void TextureContainer::get_frames_typed_as(std::span<T> output, uint64_t start_frame, uint64_t num_frames) const
{
    const size_t layer_elems = static_cast<size_t>(m_width) * m_height * m_channels;
    size_t out_idx = 0;
 
    for (uint64_t layer = start_frame;
        layer < start_frame + num_frames && layer < m_data.size() && out_idx < output.size();
        ++layer) {
        seqlock_read_void(m_slot_locks[layer], 8, [&] {
            const auto* vec = std::get_if<std::vector<T>>(&m_data[layer]);
            if (!vec || vec->empty())
                return;
            const size_t copy_n = std::min(layer_elems, std::min(vec->size(), output.size() - out_idx));
            std::copy_n(vec->begin(), static_cast<std::ptrdiff_t>(copy_n), output.begin() + static_cast<std::ptrdiff_t>(out_idx));
            out_idx += copy_n;
        });
    }
 
    if (out_idx < output.size()) {
        std::fill(output.begin() + static_cast<std::ptrdiff_t>(out_idx), output.end(), T {});
    }
}
 
void TextureContainer::get_value_impl(
    const std::vector<uint64_t>& coords,
    void* out,
    const std::type_info& type) const
{
    if (coords.empty() || m_data.empty())
        return;
 
    const size_t layer = (m_data.size() > 1) ? static_cast<size_t>(coords[0]) : 0;
    if (layer >= m_data.size() || coords.size() < (m_data.size() > 1 ? 4U : 3U))
        return;
 
    const size_t co = (m_data.size() > 1) ? 1 : 0;
    const size_t idx = (coords[co] * m_width + coords[co + 1]) * m_channels + coords[co + 2];
 
    seqlock_read_void(m_slot_locks[layer], 8, [&] {
        std::visit([&](const auto& vec) {
            using T = typename std::decay_t<decltype(vec)>::value_type;
            if (type != typeid(T) || idx >= vec.size())
                return;
            *static_cast<T*>(out) = vec[idx];
        },
            m_data[layer]);
    });
}
 
void TextureContainer::set_value_impl(
    const std::vector<uint64_t>& coords,
    const void* in,
    const std::type_info& type)
{
    if (coords.empty() || m_data.empty())
        return;
 
    const size_t layer = (m_data.size() > 1) ? static_cast<size_t>(coords[0]) : 0;
    if (layer >= m_data.size() || coords.size() < (m_data.size() > 1 ? 4U : 3U))
        return;
 
    const size_t co = (m_data.size() > 1) ? 1 : 0;
    const size_t idx = (coords[co] * m_width + coords[co + 1]) * m_channels + coords[co + 2];
 
    Memory::SeqlockWriteGuard g(m_slot_locks[layer]);
    std::visit([&](auto& vec) {
        using T = typename std::decay_t<decltype(vec)>::value_type;
        if (type != typeid(T) || idx >= vec.size())
            return;
        vec[idx] = *static_cast<const T*>(in);
    },
        m_data[layer]);
}
 
} // namespace MayaFlux::Kakshya