await_shutdown()

void MayaFlux::Core::Engine::await_shutdown

(

)

Blocks until shutdown is requested (main thread event loop)

Pumps platform-specific events on the main thread and waits for shutdown. On macOS: Runs CFRunLoop to service the main dispatch queue (required for AppKit) On other platforms: Simple blocking wait for user input

Should be called on the main thread after Start().

Definition at line 204 of file Engine.cpp.

{
#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 ......");
}

References MayaFlux::Journal::Core, m_should_shutdown, MF_ERROR, MF_LOG, MayaFlux::Journal::Runtime, and type.

Referenced by MayaFlux::Await().

Here is the caller graph for this function: