Engine.cpp

Go to the documentation of this file.

#include "Engine.hpp"
 
#include "MayaFlux/Buffers/BufferManager.hpp"
#include "MayaFlux/Core/Input/InputManager.hpp"
#include "MayaFlux/Core/Windowing/WindowManager.hpp"
#include "MayaFlux/IO/IOManager.hpp"
#include "MayaFlux/Kinesis/Stochastic/Stochastic.hpp"
#include "MayaFlux/Nodes/NodeGraphManager.hpp"
#include "MayaFlux/Vruta/EventManager.hpp"
#include "MayaFlux/Vruta/Scheduler.hpp"
 
#include "MayaFlux/Portal/Forma/Forma.hpp"
#include "MayaFlux/Portal/System/System.hpp"
 
#include "MayaFlux/Journal/Archivist.hpp"
 
#ifdef MAYAFLUX_PLATFORM_MACOS
#include <CoreFoundation/CoreFoundation.h>
#include <csignal>
#include <future>
#include <unistd.h>
#endif
 
#ifdef MAYAFLUX_PLATFORM_WINDOWS
#include "MayaFlux/Transitive/Parallel/Dispatch.hpp"
#endif
 
#ifdef MAYAFLUX_PLATFORM_LINUX
#include <csignal>
#include <pthread.h>
#endif
 
namespace MayaFlux::Core {
 
//-------------------------------------------------------------------------
// Initialization and Lifecycle
//-------------------------------------------------------------------------
 
Engine::Engine()
    : m_stochastic_engine(new Kinesis::Stochastic::Stochastic(Kinesis::Stochastic::Algorithm::UNIFORM))
{
}
 
Engine::~Engine()
{
    End();
}
 
Engine::Engine(Engine&& other) noexcept
    : m_stream_info(other.m_stream_info)
    , m_graphics_config(other.m_graphics_config)
    , m_is_paused(other.m_is_paused)
    , m_is_initialized(other.m_is_initialized)
    , m_should_shutdown(other.m_should_shutdown.load())
    , m_scheduler(std::move(other.m_scheduler))
    , m_node_graph_manager(std::move(other.m_node_graph_manager))
    , m_buffer_manager(std::move(other.m_buffer_manager))
    , m_subsystem_manager(std::move(other.m_subsystem_manager))
    , m_window_manager(std::move(other.m_window_manager))
    , m_event_manager(std::move(other.m_event_manager))
    , m_input_manager(std::move(other.m_input_manager))
    , m_io_manager(std::move(other.m_io_manager))
    , m_stochastic_engine(std::move(other.m_stochastic_engine))
{
    other.m_is_initialized = false;
    other.m_is_paused = false;
}
 
Engine& Engine::operator=(Engine&& other) noexcept
{
    if (this != &other) {
        End();
 
        m_stream_info = other.m_stream_info;
        m_graphics_config = other.m_graphics_config;
 
        m_subsystem_manager = std::move(other.m_subsystem_manager);
        m_node_graph_manager = std::move(other.m_node_graph_manager);
        m_buffer_manager = std::move(other.m_buffer_manager);
        m_scheduler = std::move(other.m_scheduler);
        m_window_manager = std::move(other.m_window_manager);
        m_event_manager = std::move(other.m_event_manager);
        m_input_manager = std::move(other.m_input_manager);
        m_io_manager = std::move(other.m_io_manager);
        m_stochastic_engine = std::move(other.m_stochastic_engine);
 
        m_is_initialized = other.m_is_initialized;
        m_is_paused = other.m_is_paused;
        m_should_shutdown = other.m_should_shutdown.load();
 
        other.m_is_initialized = false;
        other.m_is_paused = false;
    }
    return *this;
}
 
void Engine::Init()
{
    Init(m_stream_info, m_graphics_config, m_input_config, m_network_config);
}
 
void Engine::Init(const GlobalStreamInfo& streamInfo)
{
    Init(streamInfo, m_graphics_config, m_input_config, m_network_config);
}
 
void Engine::Init(const GlobalStreamInfo& streamInfo, const GlobalGraphicsConfig& graphics_config, const GlobalInputConfig& input_config, const GlobalNetworkConfig& network_config)
{
    MF_LOG(Journal::Component::Core, Journal::Context::Init, "Engine initializing");
    m_stream_info = streamInfo;
    m_graphics_config = graphics_config;
    m_input_config = input_config;
    m_network_config = network_config;
 
    m_scheduler = std::make_shared<Vruta::TaskScheduler>(m_stream_info.sample_rate);
    m_event_manager = std::make_shared<Vruta::EventManager>();
    m_input_manager = std::make_shared<InputManager>();
 
    m_buffer_manager = std::make_shared<Buffers::BufferManager>(
        m_stream_info.output.channels,
        m_stream_info.input.enabled ? m_stream_info.input.channels : 0,
        m_stream_info.sample_rate, m_stream_info.buffer_size, m_graphics_config.target_frame_rate);
 
    m_node_graph_manager = std::make_shared<Nodes::NodeGraphManager>(
        m_stream_info.sample_rate, m_stream_info.buffer_size, m_graphics_config.target_frame_rate);
 
    m_node_graph_manager->set_node_config(m_node_config);
 
    m_io_manager = std::make_shared<IO::IOManager>(
        m_stream_info, m_graphics_config.target_frame_rate, m_buffer_manager, m_scheduler);
 
    if (m_graphics_config.windowing_backend != GlobalGraphicsConfig::WindowingBackend::NONE) {
        m_window_manager = std::make_shared<WindowManager>(m_graphics_config);
    } else {
        MF_WARN(Journal::Component::Core, Journal::Context::Init, "No windowing backend selected - running in audio-only mode");
    }
 
    m_subsystem_manager = std::make_shared<SubsystemManager>(
        m_node_graph_manager, m_buffer_manager, m_scheduler, m_window_manager, m_input_manager);
 
    m_subsystem_manager->create_audio_subsystem(m_stream_info);
 
    m_subsystem_manager->create_graphics_subsystem(m_graphics_config);
 
    m_subsystem_manager->create_network_subsystem(m_network_config);
 
    m_subsystem_manager->create_input_subsystem(m_input_config);
 
    m_buffer_manager->initialize_buffer_service();
 
    m_is_initialized = true;
 
    MF_LOG(Journal::Component::Core, Journal::Context::Init, "Audio backend: {}, Sample rate: {}", Reflect::enum_to_string(m_stream_info.backend), m_stream_info.sample_rate);
}
 
void Engine::Start()
{
    if (!m_is_initialized) {
        Init();
    }
    m_subsystem_manager->start_all_subsystems();
    Portal::Forma::initialize(m_node_graph_manager, m_buffer_manager, m_scheduler, m_event_manager, m_window_manager);
    Portal::System::initialize();
}
 
void Engine::Pause()
{
    if (m_is_paused || !m_is_initialized) {
        return;
    }
 
    m_subsystem_manager->pause_all_subsystems();
    m_is_paused = true;
}
 
void Engine::Resume()
{
    if (!m_is_paused || !m_is_initialized) {
        return;
    }
 
    m_subsystem_manager->resume_all_subsystems();
    m_is_paused = false;
}
 
bool Engine::is_running() const
{
    if (!m_is_initialized || m_is_paused) {
        return false;
    }
 
    if (m_is_initialized) {
        auto status = m_subsystem_manager->query_subsystem_status();
        for (const auto& [type, readiness] : status) {
            const auto& [is_ready, is_running] = readiness;
            if (is_ready && is_running) {
                return true;
            }
        }
    }
    return false;
}
 
void Engine::await_shutdown()
{
#ifdef MAYAFLUX_PLATFORM_MACOS
    run_macos_event_loop();
#elif defined(MAYAFLUX_PLATFORM_WINDOWS)
    static HANDLE s_shutdown_event = CreateEventW(nullptr, TRUE, FALSE, nullptr);
    if (!s_shutdown_event) {
        MF_ERROR(Journal::Component::Core, Journal::Context::Runtime,
            "Failed to create shutdown event (GetLastError={}), cannot await Ctrl-C", GetLastError());
        return;
    }
    ResetEvent(s_shutdown_event);
 
    SetConsoleCtrlHandler([](DWORD type) -> BOOL {
        if (type == CTRL_C_EVENT || type == CTRL_BREAK_EVENT || type == CTRL_CLOSE_EVENT) {
            SetEvent(s_shutdown_event);
            return TRUE;
        }
        return FALSE;
    },
        TRUE);
 
    WaitForSingleObject(s_shutdown_event, INFINITE);
#else
    static std::atomic<bool> s_signal_received { false };
    s_signal_received.store(false, std::memory_order_relaxed);
 
    sigset_t block_mask, orig_mask;
    sigemptyset(&block_mask);
    sigaddset(&block_mask, SIGINT);
    sigaddset(&block_mask, SIGTERM);
    pthread_sigmask(SIG_BLOCK, &block_mask, &orig_mask);
 
    struct sigaction sa {};
    sigemptyset(&sa.sa_mask);
    sa.sa_handler = [](int) { s_signal_received.store(true, std::memory_order_release); };
    sigaction(SIGINT, &sa, nullptr);
    sigaction(SIGTERM, &sa, nullptr);
 
    while (!s_signal_received.load(std::memory_order_acquire)) {
        sigsuspend(&orig_mask);
    }
 
    pthread_sigmask(SIG_SETMASK, &orig_mask, nullptr);
#endif
 
    m_should_shutdown.store(true, std::memory_order_release);
 
    MF_LOG(Journal::Component::Core, Journal::Context::Runtime,
        "Shutdown requested, awaiting all subsystem termination ......");
}
 
void Engine::request_shutdown()
{
    m_should_shutdown.store(true, std::memory_order_release);
 
#ifdef MAYAFLUX_PLATFORM_MACOS
    CFRunLoopStop(CFRunLoopGetMain());
#endif
}
 
bool Engine::is_shutdown_requested() const
{
    return m_should_shutdown.load(std::memory_order_acquire);
}
 
#ifdef MAYAFLUX_PLATFORM_MACOS
void Engine::run_macos_event_loop()
{
    CFRunLoopRef runLoop = CFRunLoopGetMain();
 
    signal(SIGINT, SIG_IGN);
    signal(SIGTERM, SIG_IGN);
 
    dispatch_source_t sigintSource = dispatch_source_create(
        DISPATCH_SOURCE_TYPE_SIGNAL,
        SIGINT,
        0,
        dispatch_get_main_queue());
 
    dispatch_source_t sigtermSource = dispatch_source_create(
        DISPATCH_SOURCE_TYPE_SIGNAL,
        SIGTERM,
        0,
        dispatch_get_main_queue());
 
    dispatch_source_set_event_handler(sigintSource, ^{
        request_shutdown();
    });
 
    dispatch_source_set_event_handler(sigtermSource, ^{
        request_shutdown();
    });
 
    dispatch_resume(sigintSource);
    dispatch_resume(sigtermSource);
 
    double timeout_seconds = 1.0 / static_cast<double>(m_graphics_config.target_frame_rate);
 
    MF_INFO(Journal::Component::Core, Journal::Context::Runtime,
        "Main thread event loop running (polling at {}fps)",
        m_graphics_config.target_frame_rate);
 
    while (!is_shutdown_requested()) {
        CFRunLoopRunInMode(kCFRunLoopDefaultMode, timeout_seconds, false);
    }
 
    dispatch_source_cancel(sigintSource);
    dispatch_release(sigintSource);
    dispatch_source_cancel(sigtermSource);
    dispatch_release(sigtermSource);
 
    MF_INFO(Journal::Component::Core, Journal::Context::Runtime,
        "Main thread event loop exiting");
}
#endif
 
void Engine::stop_subsystems()
{
    if (!m_subsystem_manager) {
        return;
    }
 
#ifdef MAYAFLUX_PLATFORM_MACOS
    if (CFRunLoopGetCurrent() == CFRunLoopGetMain()) {
        auto stopped = std::async(std::launch::async, [this]() {
            m_subsystem_manager->stop();
        });
        while (stopped.wait_for(std::chrono::milliseconds(0)) != std::future_status::ready) {
            CFRunLoopRunInMode(kCFRunLoopDefaultMode, 0.01, false);
        }
        stopped.get();
        return;
    }
#endif
 
    m_subsystem_manager->stop();
}
 
void Engine::End()
{
    if (!m_is_initialized)
        return;
 
    Portal::Forma::shutdown();
 
    Portal::System::shutdown();
 
    if (m_event_manager) {
        m_event_manager->terminate_all_events();
    }
 
    if (m_node_graph_manager) {
        m_node_graph_manager->terminate_active_processing();
    }
 
    if (m_io_manager) {
        m_io_manager->stop();
    }
 
    stop_subsystems();
 
    if (m_io_manager) {
        m_io_manager->shutdown();
    }
 
    if (m_scheduler) {
        m_scheduler->terminate_all_tasks();
    }
 
    if (m_buffer_manager) {
        m_buffer_manager->terminate_active_buffers();
        m_buffer_manager.reset();
    }
 
    if (m_window_manager) {
        m_window_manager->set_terminate();
        auto windows = m_window_manager->get_windows();
        for (auto& window : windows) {
            m_window_manager->destroy_window(window, true);
        }
        m_window_manager.reset();
    }
 
    if (m_node_graph_manager) {
        m_node_graph_manager.reset();
    }
 
    if (m_subsystem_manager) {
        m_subsystem_manager->shutdown();
    }
 
    m_is_initialized = false;
    m_is_paused = false;
}
 
Nodes::NodeConfig& Engine::get_node_config()
{
    if (m_node_graph_manager) {
        return m_node_graph_manager->get_node_config();
    }
 
    return m_node_config;
}
 
void Engine::set_node_config(const Nodes::NodeConfig& config)
{
    m_node_config = config;
    if (m_node_graph_manager) {
        m_node_graph_manager->set_node_config(config);
    }
}
 
} // namespace MayaFlux::Core