// Copyright 2019 yuzu Emulator Project
// Licensed under GPLv2 or any later version
// Refer to the license.txt file included.

#pragma once

#include <memory>
#include <optional>
#include <tuple>
#include <vector>

#include "common/common_types.h"
#include "video_core/renderer_vulkan/declarations.h"
#include "video_core/renderer_vulkan/vk_memory_manager.h"

namespace Vulkan {

class VKDevice;
class VKFence;
class VKFenceWatch;
class VKResourceManager;
class VKScheduler;

class VKStreamBuffer {
public:
    explicit VKStreamBuffer(const VKDevice& device, VKMemoryManager& memory_manager,
                            VKScheduler& scheduler, u64 size, vk::BufferUsageFlags usage,
                            vk::AccessFlags access, vk::PipelineStageFlags pipeline_stage);
    ~VKStreamBuffer();

    /**
     * Reserves a region of memory from the stream buffer.
     * @param size Size to reserve.
     * @param keep_in_host Mapped buffer will be in host memory, skipping the copy to device local.
     * @returns A tuple in the following order: Raw memory pointer (with offset added), buffer
     * offset, Vulkan buffer handle, buffer has been invalited.
     */
    std::tuple<u8*, u64, vk::Buffer, bool> Reserve(u64 size, bool keep_in_host);

    /// Ensures that "size" bytes of memory are available to the GPU, potentially recording a copy.
    [[nodiscard]] VKExecutionContext Send(VKExecutionContext exctx, u64 size);

private:
    /// Creates Vulkan buffer handles committing the required the required memory.
    void CreateBuffers(VKMemoryManager& memory_manager, vk::BufferUsageFlags usage);

    /// Increases the amount of watches available.
    void ReserveWatches(std::size_t grow_size);

    const VKDevice& device;                      ///< Vulkan device manager.
    VKScheduler& scheduler;                      ///< Command scheduler.
    const u64 buffer_size;                       ///< Total size of the stream buffer.
    const bool has_device_exclusive_memory;      ///< True if the streaming buffer will use VRAM.
    const vk::AccessFlags access;                ///< Access usage of this stream buffer.
    const vk::PipelineStageFlags pipeline_stage; ///< Pipeline usage of this stream buffer.

    UniqueBuffer mappable_buffer;   ///< Mapped buffer.
    UniqueBuffer device_buffer;     ///< Buffer exclusive to the GPU.
    VKMemoryCommit mappable_commit; ///< Commit visible from the CPU.
    VKMemoryCommit device_commit;   ///< Commit stored in VRAM.
    u8* mapped_pointer{};           ///< Pointer to the host visible commit

    u64 offset{};      ///< Buffer iterator.
    u64 mapped_size{}; ///< Size reserved for the current copy.
    bool use_device{}; ///< True if the current uses VRAM.

    std::vector<std::unique_ptr<VKFenceWatch>> watches; ///< Total watches
    std::size_t used_watches{}; ///< Count of watches, reset on invalidation.
    std::optional<std::size_t>
        invalidation_mark{}; ///< Number of watches used in the current invalidation.
};

} // namespace Vulkan