Compare commits

..

No commits in common. "41575df141dad6ece0c39324761f77030d5cfcdd" and "68c49ebdfbc235090e44dabc45b9c78222a74b37" have entirely different histories.

14 changed files with 136 additions and 200 deletions

View file

@ -19,7 +19,7 @@ public:
template<typename Component_T> template<typename Component_T>
auto add(Component_T component) -> Component_T & auto add(Component_T component) -> Component_T &
{ {
return m_registry->add(m_identifier, component); m_registry->add(m_identifier, component);
} }
template<typename Component_T> template<typename Component_T>
@ -42,6 +42,7 @@ public:
private: private:
memory::Ref<Registry> m_registry; memory::Ref<Registry> m_registry;
EntityId m_identifier; EntityId m_identifier;
}; };

View file

@ -64,25 +64,30 @@ public:
if (input.get_action(m_quit_action_key).state == State::active) if (input.get_action(m_quit_action_key).state == State::active)
{ {
log_dbg("Quit triggered! BYE!");
should_quit = true; should_quit = true;
} }
if (input.get_action(m_debug_action_keys[0]).state == State::active) if (input.get_action(m_debug_action_keys[0]).state == State::active)
{ {
log_dbg("Deubg action 1");
surface.push_request(surface::ModifyPositionRequest({ x + 5, y + 5 })); surface.push_request(surface::ModifyPositionRequest({ x + 5, y + 5 }));
} }
if (input.get_action(m_debug_action_keys[1]).state == State::active) if (input.get_action(m_debug_action_keys[1]).state == State::active)
{ {
log_dbg("Deubg action 2");
surface.push_request(surface::ModifyPositionRequest({ x - 5, y - 5 })); surface.push_request(surface::ModifyPositionRequest({ x - 5, y - 5 }));
} }
if (input.get_action(m_debug_action_keys[2]).state == State::active) if (input.get_action(m_debug_action_keys[2]).state == State::active)
{ {
log_dbg("Deubg action 3");
surface.push_request(surface::ModifyResolutionRequest({ width + 5, height + 5 })); surface.push_request(surface::ModifyResolutionRequest({ width + 5, height + 5 }));
} }
if (input.get_action(m_debug_action_keys[3]).state == State::active) if (input.get_action(m_debug_action_keys[3]).state == State::active)
{ {
log_dbg("Deubg action 4");
surface.push_request(surface::ModifyResolutionRequest({ width - 5, height - 5 })); surface.push_request(surface::ModifyResolutionRequest({ width - 5, height - 5 }));
} }
} }
@ -149,7 +154,7 @@ public:
m_surface_system = memory::create_ref<lt::surface::System>(m_editor_registry); m_surface_system = memory::create_ref<lt::surface::System>(m_editor_registry);
m_window = m_editor_registry->create_entity(); m_window = m_editor_registry->create_entity();
m_surface_system->create_component( m_editor_registry->add<SurfaceComponent>(
m_window, m_window,
SurfaceComponent::CreateInfo { SurfaceComponent::CreateInfo {
.title = "Editor Window", .title = "Editor Window",
@ -212,15 +217,12 @@ public:
.surface_entity = entity, .surface_entity = entity,
}); });
m_renderer_system->create_messenger_component( // entity.add<renderer::MessengerComponent>({
m_window, // .severities = renderer::MessageSeverity::all,
renderer::MessengerComponent::CreateInfo { // .types = renderer::MessageType::all,
.severities = renderer::MessageSeverity::all, // .callback = &renderer_callback,
.types = renderer::MessageType::all, // .user_data = this,
.callback = &renderer_callback, // });
.user_data = this,
}
);
} }
void setup_input_system() void setup_input_system()

View file

@ -3,7 +3,6 @@
#include <ecs/entity.hpp> #include <ecs/entity.hpp>
#include <memory/pointer_types/null_on_move.hpp> #include <memory/pointer_types/null_on_move.hpp>
#include <memory/scope.hpp> #include <memory/scope.hpp>
#include <renderer/backend/vk/context/swapchain.hpp>
#include <renderer/frontend/context/context.hpp> #include <renderer/frontend/context/context.hpp>
namespace lt::renderer::vk { namespace lt::renderer::vk {
@ -44,11 +43,7 @@ public:
void recreate_swapchain() override void recreate_swapchain() override
{ {
m_swapchain.reset(); m_swapchain.reset();
m_swapchain = memory::create_scope<vk::Swapchain>( // m_swapchain = memory::create_scope<vk::Swapchain>(m_device, m_surface);
m_surface.get(),
m_gpu.get(),
m_device.get()
);
} }
private: private:

View file

@ -44,7 +44,6 @@ Swapchain::Swapchain(ISurface *surface, IGpu *gpu, IDevice *device)
.oldSwapchain = nullptr, .oldSwapchain = nullptr,
} }
); );
m_resolution = capabilities.currentExtent;
m_device->name(m_swapchain, "swapchain {}", idx++); m_device->name(m_swapchain, "swapchain {}", idx++);
m_device->wait_idle(); m_device->wait_idle();

View file

@ -7,13 +7,13 @@ Messenger::Messenger(IInstance *instance, ecs::Entity entity)
, m_entity(std::move(entity)) , m_entity(std::move(entity))
{ {
const auto &component = m_entity.get<MessengerComponent>(); const auto &component = entity.get<MessengerComponent>();
m_debug_messenger = m_instance->create_messenger( m_debug_messenger = m_instance->create_messenger(
VkDebugUtilsMessengerCreateInfoEXT { VkDebugUtilsMessengerCreateInfoEXT {
.sType = VK_STRUCTURE_TYPE_DEBUG_UTILS_MESSENGER_CREATE_INFO_EXT, .sType = VK_STRUCTURE_TYPE_DEBUG_UTILS_MESSENGER_CREATE_INFO_EXT,
.messageSeverity = to_native_severity(component.get_severities()), .messageSeverity = to_native_severity(component.severities),
.messageType = to_native_type(component.get_types()), .messageType = to_native_type(component.types),
.pfnUserCallback = &native_callback, .pfnUserCallback = &native_callback,
.pUserData = this, .pUserData = this,
} }
@ -43,13 +43,13 @@ Messenger::~Messenger()
auto *messenger = (Messenger *)vulkan_user_data; // NOLINT auto *messenger = (Messenger *)vulkan_user_data; // NOLINT
auto &component = messenger->m_entity.get<MessengerComponent>(); auto &component = messenger->m_entity.get<MessengerComponent>();
component.get_callback()( component.callback(
from_native_severity(severity), from_native_severity(severity),
from_native_type(type), from_native_type(type),
{ {
.message = callback_data->pMessage, .message = callback_data->pMessage,
}, },
component.get_user_data() component.user_data
); );
} }
catch (const std::exception &exp) catch (const std::exception &exp)

View file

@ -136,7 +136,6 @@ void Renderer::replace_swapchain(ISwapchain *swapchain)
m_device->wait_idle(); m_device->wait_idle();
m_swapchain = static_cast<Swapchain *>(swapchain); m_swapchain = static_cast<Swapchain *>(swapchain);
m_resolution = m_swapchain->get_resolution(); m_resolution = m_swapchain->get_resolution();
m_pass->replace_swapchain(*swapchain);
} }
void Renderer::record_cmd(VkCommandBuffer cmd, uint32_t image_idx) void Renderer::record_cmd(VkCommandBuffer cmd, uint32_t image_idx)

View file

@ -13,6 +13,7 @@ namespace lt::renderer {
switch (target_api) switch (target_api)
{ {
case API::Vulkan: return memory::create_scope<vk::Messenger>(instance, std::move(entity)); case API::Vulkan: return memory::create_scope<vk::Messenger>(instance, std::move(entity));
case API::Metal: case API::Metal:
case API::DirectX: throw std::runtime_error { "Invalid API" }; case API::DirectX: throw std::runtime_error { "Invalid API" };
} }

View file

@ -19,6 +19,10 @@ System::System(CreateInfo info)
ensure(m_registry, "Failed to initialize renderer system: null registry"); ensure(m_registry, "Failed to initialize renderer system: null registry");
m_renderer = IRenderer::create(m_api, *m_context, info.config.max_frames_in_flight); m_renderer = IRenderer::create(m_api, *m_context, info.config.max_frames_in_flight);
// WIP(Light): attach debug messenger on messenger component construction
// m_registry->connect_on_construct<renderer::MessengerComponent>([](ecs::Registry &registry,
// ecs::EntityId entity) {});
} }
System::~System() System::~System()
@ -58,21 +62,4 @@ void System::tick(app::TickInfo tick)
m_frame_idx = (m_frame_idx + 1) % m_max_frames_in_flight; m_frame_idx = (m_frame_idx + 1) % m_max_frames_in_flight;
} }
void System::create_messenger_component(ecs::EntityId entity, MessengerComponent::CreateInfo info)
try
{
auto &component = m_registry->add<MessengerComponent>(entity, std::move(info));
component.m_implementation = IMessenger::create(
m_api,
m_context->instance(),
{ m_registry, entity }
);
}
catch (const std::exception &exp)
{
log_err("Failed to create renderer::MessengerComponent:");
log_err("\twhat: {}", exp.what());
}
} // namespace lt::renderer } // namespace lt::renderer

View file

@ -1,9 +1,7 @@
#pragma once #pragma once
#include <any>
#include <bitwise/operations.hpp> #include <bitwise/operations.hpp>
#include <memory/scope.hpp> #include <any>
#include <renderer/frontend/messenger.hpp>
namespace lt::renderer { namespace lt::renderer {
@ -38,16 +36,11 @@ using Callback_T = std::function<void(
MessageSeverity message_severity, MessageSeverity message_severity,
MessageType message_type, MessageType message_type,
MessengerCallbackData data, MessengerCallbackData data,
std::any &user_data std::any user_data
)>; )>;
class MessengerComponent struct MessengerComponent
{ {
public:
friend class System;
struct CreateInfo
{
MessageSeverity severities; MessageSeverity severities;
MessageType types; MessageType types;
@ -55,46 +48,6 @@ public:
Callback_T callback; Callback_T callback;
std::any user_data; std::any user_data;
};
[[nodiscard]] auto get_severities() const -> MessageSeverity
{
return m_severities;
}
[[nodiscard]] auto get_types() const -> MessageType
{
return m_types;
}
[[nodiscard]] auto get_callback() const -> const Callback_T &
{
return m_callback;
}
[[nodiscard]] auto get_user_data() -> std::any &
{
return m_user_data;
}
private:
MessengerComponent(CreateInfo info)
: m_severities(info.severities)
, m_types(info.types)
, m_callback(std::move(info.callback))
, m_user_data(std::move(info.user_data))
{
}
MessageSeverity m_severities;
MessageType m_types;
Callback_T m_callback;
std::any m_user_data;
memory::Scope<IMessenger> m_implementation;
}; };
} // namespace lt::renderer } // namespace lt::renderer

View file

@ -6,7 +6,6 @@
#include <memory/reference.hpp> #include <memory/reference.hpp>
#include <memory/scope.hpp> #include <memory/scope.hpp>
#include <renderer/api.hpp> #include <renderer/api.hpp>
#include <renderer/components/messenger.hpp>
namespace lt::renderer { namespace lt::renderer {
@ -47,8 +46,6 @@ public:
void tick(app::TickInfo tick) override; void tick(app::TickInfo tick) override;
void create_messenger_component(ecs::EntityId entity, MessengerComponent::CreateInfo info);
[[nodiscard]] auto get_last_tick_result() const -> const app::TickResult & override [[nodiscard]] auto get_last_tick_result() const -> const app::TickResult & override
{ {
return m_last_tick_result; return m_last_tick_result;
@ -65,6 +62,8 @@ private:
memory::Scope<class IRenderer> m_renderer; memory::Scope<class IRenderer> m_renderer;
std::vector<memory::Scope<class IMessenger>> m_messengers;
app::TickResult m_last_tick_result {}; app::TickResult m_last_tick_result {};
uint32_t m_frame_idx {}; uint32_t m_frame_idx {};

View file

@ -54,6 +54,12 @@ System::System(memory::Ref<ecs::Registry> registry): m_registry(std::move(regist
"Failed to initialize surface system: registry has surface component(s)" "Failed to initialize surface system: registry has surface component(s)"
); );
m_registry->connect_on_construct<SurfaceComponent>(
[this](ecs::Registry &registry, ecs::EntityId entity) {
on_surface_construct(registry, entity);
}
);
m_registry->connect_on_destruct<SurfaceComponent>( m_registry->connect_on_destruct<SurfaceComponent>(
[this](ecs::Registry &registry, ecs::EntityId entity) { [this](ecs::Registry &registry, ecs::EntityId entity) {
on_surface_destruct(registry, entity); on_surface_destruct(registry, entity);
@ -100,12 +106,11 @@ void System::on_unregister()
{ {
} }
auto System::create_component(ecs::EntityId entity, SurfaceComponent::CreateInfo info) void System::on_surface_construct(ecs::Registry &registry, ecs::EntityId entity)
-> std::optional<SurfaceComponent *>
try
{ {
auto &component = m_registry->add<SurfaceComponent>(entity, info); try
auto &surface = m_registry->get<SurfaceComponent>(entity); {
auto &surface = registry.get<SurfaceComponent>(entity);
const auto &resolution = surface.get_resolution(); const auto &resolution = surface.get_resolution();
const auto &position = surface.get_position(); const auto &position = surface.get_position();
ensure_component_sanity(surface); ensure_component_sanity(surface);
@ -183,16 +188,15 @@ try
{ {
XUnmapWindow(display, main_window); XUnmapWindow(display, main_window);
} }
}
return &component; catch (const std::exception &exp)
} {
catch (const std::exception &exp)
{
log_err("Exception thrown when on_constructing surface component"); log_err("Exception thrown when on_constructing surface component");
log_err("\tentity: {}", entity); log_err("\tentity: {}", entity);
log_err("\twhat: {}", exp.what()); log_err("\twhat: {}", exp.what());
m_registry->remove<SurfaceComponent>(entity); registry.remove<SurfaceComponent>(entity);
return {}; throw;
}
} }
void System::on_surface_destruct(ecs::Registry &registry, ecs::EntityId entity) void System::on_surface_destruct(ecs::Registry &registry, ecs::EntityId entity)
@ -281,6 +285,7 @@ void System::handle_events(SurfaceComponent &surface)
const auto new_height = event.xconfigure.height; const auto new_height = event.xconfigure.height;
if (prev_width != new_width || prev_height != new_height) if (prev_width != new_width || prev_height != new_height)
{ {
log_dbg("resized: {} - {}", new_width, new_height);
surface.m_resolution.x = new_width; surface.m_resolution.x = new_width;
surface.m_resolution.y = new_height; surface.m_resolution.y = new_height;
queue.emplace_back<ResizedEvent>(ResizedEvent { queue.emplace_back<ResizedEvent>(ResizedEvent {
@ -337,7 +342,7 @@ void System::modify_title(SurfaceComponent &surface, const ModifyTitleRequest &r
void System::modify_resolution(SurfaceComponent &surface, const ModifyResolutionRequest &request) void System::modify_resolution(SurfaceComponent &surface, const ModifyResolutionRequest &request)
{ {
// surface.m_resolution = request.resolution; surface.m_resolution = request.resolution;
auto &[display, window, _] = surface.m_native_data; auto &[display, window, _] = surface.m_native_data;
const auto &[width, height] = request.resolution; const auto &[width, height] = request.resolution;

View file

@ -13,10 +13,7 @@ typedef struct _XDisplay Display;
namespace lt::surface { namespace lt::surface {
/** Represents a platform's surface (eg. a Window). /** Represents a platform's surface (eg. a Window). */
*
* @note This is a "system component"
*/
class SurfaceComponent class SurfaceComponent
{ {
public: public:
@ -69,6 +66,15 @@ public:
bool visible; bool visible;
}; };
SurfaceComponent(const CreateInfo &info)
: m_title(info.title)
, m_resolution(info.resolution)
, m_vsync(info.vsync)
, m_visible(info.visible)
, m_native_data({})
{
}
[[nodiscard]] auto get_title() const -> std::string_view [[nodiscard]] auto get_title() const -> std::string_view
{ {
return m_title; return m_title;
@ -121,15 +127,6 @@ public:
} }
private: private:
SurfaceComponent(const CreateInfo &info)
: m_title(info.title)
, m_resolution(info.resolution)
, m_vsync(info.vsync)
, m_visible(info.visible)
, m_native_data({})
{
}
std::string m_title; std::string m_title;
math::uvec2 m_resolution; math::uvec2 m_resolution;

View file

@ -4,7 +4,6 @@
#include <ecs/registry.hpp> #include <ecs/registry.hpp>
#include <math/vec2.hpp> #include <math/vec2.hpp>
#include <memory/reference.hpp> #include <memory/reference.hpp>
#include <surface/components.hpp>
namespace lt::surface { namespace lt::surface {
@ -27,9 +26,6 @@ public:
void on_unregister() override; void on_unregister() override;
auto create_component(ecs::EntityId entity, SurfaceComponent::CreateInfo info)
-> std::optional<SurfaceComponent *>;
void tick(app::TickInfo tick) override; void tick(app::TickInfo tick) override;
[[nodiscard]] auto get_last_tick_result() const -> const app::TickResult & override [[nodiscard]] auto get_last_tick_result() const -> const app::TickResult & override
@ -38,6 +34,8 @@ public:
} }
private: private:
void on_surface_construct(ecs::Registry &registry, ecs::EntityId entity);
void on_surface_destruct(ecs::Registry &registry, ecs::EntityId entity); void on_surface_destruct(ecs::Registry &registry, ecs::EntityId entity);
void handle_requests(struct SurfaceComponent &surface); void handle_requests(struct SurfaceComponent &surface);