VulkanQueue.h

#pragma once
 
#include "spark/render/CommandQueue.h"
#include "spark/render/Resource.h"
#include "spark/render/vk/Export.h"
#include "spark/render/vk/Helpers.h"
#include "spark/render/vk/VulkanCommandBuffer.h"
 
SPARK_FWD_DECLARE_VK_HANDLE(VkQueue)
SPARK_FWD_DECLARE_VK_HANDLE(VkCommandPool)
SPARK_FWD_DECLARE_VK_HANDLE(VkSemaphore)
using VkPipelineStageFlags = std::uint32_t;
 
namespace spark::render::vk
{
    class VulkanDevice;
    class VulkanCommandBuffer;
 
    class SPARK_RENDER_VK_EXPORT VulkanQueue final : public CommandQueue<VulkanCommandBuffer>, public Resource<VkQueue>
    {
    public:
        explicit VulkanQueue(const VulkanDevice& device, QueueType type, QueuePriority priority, unsigned family_id, unsigned queue_id);
        ~VulkanQueue() override;
 
        VulkanQueue(const VulkanQueue& other) = delete;
        VulkanQueue(VulkanQueue&& other) noexcept = delete;
        VulkanQueue& operator=(const VulkanQueue& other) = delete;
        VulkanQueue& operator=(VulkanQueue&& other) noexcept = delete;
 
        [[nodiscard]] const VulkanDevice& device() const noexcept;
 
        [[nodiscard]] const VkCommandPool& commandPool() const noexcept;
 
        [[nodiscard]] unsigned familyId() const noexcept;
 
        [[nodiscard]] unsigned queueId() const noexcept;
 
        [[nodiscard]] const VkSemaphore& timelineSemaphore() const noexcept;
 
        [[nodiscard]] bool isBound() const noexcept override;
 
        [[nodiscard]] QueuePriority priority() const noexcept override;
 
        [[nodiscard]] QueueType type() const noexcept override;
 
        void bind() const noexcept override;
 
        void release() const noexcept override;
 
        void waitFor(std::size_t fence) const noexcept override;
 
        [[nodiscard]] std::size_t currentFence() const noexcept override;
 
        [[nodiscard]] std::shared_ptr<VulkanCommandBuffer> createCommandBuffer(bool begin_recording, bool secondary) const noexcept override;
 
        [[nodiscard]] std::size_t submit(std::shared_ptr<const VulkanCommandBuffer> command_buffer,
                                         std::span<VkSemaphore> wait_for_semaphores,
                                         std::span<VkPipelineStageFlags> wait_for_stages,
                                         std::span<VkSemaphore> signal_semaphores = {}) const;
 
        [[nodiscard]] std::size_t submit(const std::vector<std::shared_ptr<const VulkanCommandBuffer>>& command_buffers,
                                         std::span<VkSemaphore> wait_for_semaphores,
                                         std::span<VkPipelineStageFlags> wait_for_stages,
                                         std::span<VkSemaphore> signal_semaphores = {}) const;
 
        [[nodiscard]] std::size_t submit(std::shared_ptr<VulkanCommandBuffer> command_buffer) const noexcept override;
 
        [[nodiscard]] std::size_t submit(std::shared_ptr<const VulkanCommandBuffer> command_buffer) const noexcept override;
 
        [[nodiscard]] std::size_t submit(const std::vector<std::shared_ptr<const VulkanCommandBuffer>>& command_buffers) const noexcept override;
 
        [[nodiscard]] std::size_t submit(const std::vector<std::shared_ptr<VulkanCommandBuffer>>& command_buffers) const noexcept override;
 
    private:
        struct Impl;
        std::unique_ptr<Impl> m_impl;
    };
}