main loop and sync

Author: Green-Sky

framework/vulkan_renderer/src/mm/services/vulkan_renderer.cpp

@@ -5,6 +5,13 @@
 
 #include <vulkan/vulkan.hpp>
 
+// mf ycm, FIXME: remove before merge
+#include <vulkan/vulkan_handles.hpp>
+#include <vulkan/vulkan_core.h>
+#include <vulkan/vulkan_structs.hpp>
+#include <vulkan/vulkan_enums.hpp>
+#include <vulkan/vulkan_funcs.hpp>
+
 #include <SDL_vulkan.h>
 
 #include <mm/logger.hpp>
@@ -188,6 +195,14 @@ bool VulkanRenderer::enable(Engine& engine, std::vector<UpdateStrategies::TaskIn
 
 	_debug_messenger = instance.createDebugUtilsMessengerEXT(debug_utils_messenger_create_info);
 
+	{ // add task
+		task_array.push_back(
+			UpdateStrategies::TaskInfo{"VulkanRenderer::render"}
+			.phase(UpdateStrategies::update_phase_t::POST) // *smirk*
+			.fn([this](Engine& e){ this->render(e); })
+		);
+	}
+
 	return true;
 }
 
@@ -196,13 +211,18 @@ void VulkanRenderer::disable(Engine&) {
 	if (_device) {
 		vk::Device device{_device};
 
+		device.waitIdle();
+
 		for (const auto& fb : _swapchain_framebuffers) {
 			device.destroy(fb);
 		}
 		for (const auto& img_view : _swapchain_image_views) {
 			device.destroy(img_view);
 		}
 		device.destroy(_swapchain);
+		device.destroy(_swapchain_sem_image_available);
+		device.destroy(_swapchain_sem_render_finished);
+		device.destroy(_swapchain_fence_in_flight);
 		device.destroy();
 	}
 
@@ -212,6 +232,55 @@ void VulkanRenderer::disable(Engine&) {
 	instance.destroy();
 }
 
+void VulkanRenderer::render(Engine&) {
+	vk::Device device{_device};
+	vk::SwapchainKHR swapchain{_swapchain};
+
+	// wait for next fb/img/img_view to be free again
+	// in most cases there are 2 but might be 1 or more
+	vk::Fence in_flight{_swapchain_fence_in_flight};
+	auto wait_in_flight_res = device.waitForFences(in_flight, true, UINT64_MAX);
+	device.resetFences(in_flight);
+
+	uint32_t next_img_index = device.acquireNextImageKHR(
+		_swapchain,
+		UINT64_MAX,
+		_swapchain_sem_image_available
+	).value;
+
+	{
+		auto g_queue = vk::Queue{_graphics_queue};
+		// do the commands n stuff
+
+		// queue submit
+		vk::Semaphore tmp_sem_wait{_swapchain_sem_image_available};
+		vk::PipelineStageFlags tmp_sem_wait_stages{vk::PipelineStageFlagBits::eColorAttachmentOutput};
+		vk::Semaphore tmp_sem_sig{_swapchain_sem_render_finished};
+		g_queue.submit({vk::SubmitInfo{
+			tmp_sem_wait,
+			tmp_sem_wait_stages,
+			{},
+			tmp_sem_sig
+		}}, _swapchain_fence_in_flight);
+	}
+
+	{ // queue present
+		auto p_queue = vk::Queue{_graphics_queue}; // TODO: present queue
+
+		vk::Semaphore tmp_sem_wait{_swapchain_sem_render_finished};
+		auto present_res = p_queue.presentKHR(vk::PresentInfoKHR{
+			tmp_sem_wait,
+			swapchain,
+			// _swapchain_curr_idx
+			next_img_index
+		});
+
+		// TODO: do i need this??
+		// next image
+		_swapchain_curr_idx = (_swapchain_curr_idx + 1) % _swapchain_images.size();
+	}
+}
+
 bool VulkanRenderer::createDevice(Engine& engine) {
 	// the surface for the window (not device dependent)
 	if (SDL_Vulkan_CreateSurface(engine.getService<SDLService>().win, _instance, &_surface) != SDL_TRUE) {
@@ -304,6 +373,10 @@ bool VulkanRenderer::createDevice(Engine& engine) {
 	// we assume it also does present
 	_graphics_queue = device.getQueue(0, 0);
 
+	_swapchain_sem_image_available = device.createSemaphore(vk::SemaphoreCreateInfo{});
+	_swapchain_sem_render_finished = device.createSemaphore(vk::SemaphoreCreateInfo{});
+	_swapchain_fence_in_flight = device.createFence({vk::FenceCreateFlagBits::eSignaled});
+
 	return true;
 }
 
@@ -383,6 +456,7 @@ bool VulkanRenderer::createSwapchain(Engine& engine) {
 		}));
 	}
 
+
 	// TODO: move
 
 	_swapchain_framebuffers.clear();

framework/vulkan_renderer/src/mm/services/vulkan_renderer.hpp

@@ -8,11 +8,11 @@
 #define MM_VK_DEFINE_HANDLE(object) typedef struct object##_T* object;
 // TODO: determain what we use
 //#ifndef VK_DEFINE_NON_DISPATCHABLE_HANDLE
-    //#if (VK_USE_64_BIT_PTR_DEFINES==1)
-        #define MM_VK_DEFINE_NON_DISPATCHABLE_HANDLE(object) typedef struct object##_T *object;
-    //#else
-        //#define VK_DEFINE_NON_DISPATCHABLE_HANDLE(object) typedef uint64_t object;
-    //#endif
+	//#if (VK_USE_64_BIT_PTR_DEFINES==1)
+		#define MM_VK_DEFINE_NON_DISPATCHABLE_HANDLE(object) typedef struct object##_T *object;
+	//#else
+		//#define VK_DEFINE_NON_DISPATCHABLE_HANDLE(object) typedef uint64_t object;
+	//#endif
 //#endif
 
 MM_VK_DEFINE_NON_DISPATCHABLE_HANDLE(VkBuffer)
@@ -21,6 +21,8 @@ MM_VK_DEFINE_HANDLE(VkInstance)
 MM_VK_DEFINE_HANDLE(VkPhysicalDevice)
 MM_VK_DEFINE_HANDLE(VkDevice)
 MM_VK_DEFINE_HANDLE(VkQueue)
+MM_VK_DEFINE_NON_DISPATCHABLE_HANDLE(VkSemaphore)
+MM_VK_DEFINE_NON_DISPATCHABLE_HANDLE(VkFence)
 MM_VK_DEFINE_NON_DISPATCHABLE_HANDLE(VkImageView)
 MM_VK_DEFINE_NON_DISPATCHABLE_HANDLE(VkFramebuffer)
 
@@ -46,19 +48,27 @@ class VulkanRenderer : public Service {
 		//VkQueue _present_queue{};
 
 		VkSwapchainKHR _swapchain{};
+		uint32_t _swapchain_curr_idx{};
 		std::vector<VkImage> _swapchain_images{};
 		std::vector<VkImageView> _swapchain_image_views{};
 		std::vector<VkFramebuffer> _swapchain_framebuffers{};
 
+		VkSemaphore _swapchain_sem_image_available{};
+		VkSemaphore _swapchain_sem_render_finished{};
+		VkFence _swapchain_fence_in_flight{};
+
 	public:
 		VulkanRenderer(void);
 		~VulkanRenderer(void);
 
+	private: // Service interface
 		bool enable(Engine& engine, std::vector<UpdateStrategies::TaskInfo>& task_array) override;
-		void disable(Engine&) override;
+		void disable(Engine& engine) override;
 
 		const char* name(void) override { return "VulkanRenderer"; }
 
+		void render(Engine& engine);
+
 	public:
 		bool createDevice(Engine& engine);