await_shutdown()

void Lila::Lila::await_shutdown

(

const std::atomic< bool > *

external_flag

)

Blocks until server shutdown (main thread event loop)

Parameters

external_flag

std::atomic<bool> Whether to force shutdown externally

On macOS: Runs CFRunLoop to process main queue (required for JIT GLFW) On other platforms: Simple blocking wait

Should be called on main thread after initialize() in Server mode. Returns when stop_server() is called or server fails.

Definition at line 221 of file Lila.cpp.

{
    LILA_INFO(Emitter::SYSTEM, "Entering main event loop");
 
#ifdef MAYAFLUX_PLATFORM_MACOS
    while (!m_shutdown_requested.load(std::memory_order_acquire) && (!external_flag || external_flag->load(std::memory_order_acquire))) {
        if (!is_server_running()) {
            LILA_ERROR(Emitter::SYSTEM, "Server stopped unexpectedly");
            break;
        }
        CFRunLoopRunInMode(kCFRunLoopDefaultMode, server_loop_rate, false);
    }
 
#elif defined(MAYAFLUX_PLATFORM_WINDOWS)
    if (MayaFlux::Parallel::g_MainThreadId == 0) {
        MayaFlux::Parallel::g_MainThreadId = GetCurrentThreadId();
    }
 
    MSG msg;
    PeekMessage(&msg, NULL, WM_USER, WM_USER, PM_NOREMOVE);
 
    while (!m_shutdown_requested.load(std::memory_order_acquire)
        && (!external_flag || external_flag->load(std::memory_order_acquire))) {
        if (!is_server_running()) {
            LILA_ERROR(Emitter::SYSTEM, "Server stopped unexpectedly");
            break;
        }
 
        while (PeekMessage(&msg, NULL, 0, 0, PM_REMOVE)) {
            if (msg.message == WM_QUIT) {
                m_shutdown_requested.store(true, std::memory_order_release);
                break;
            }
 
            if (msg.message == MAYAFLUX_WM_DISPATCH) {
                auto* task = reinterpret_cast<std::function<void()>*>(msg.lParam);
                if (task) {
                    (*task)();
                    delete task;
                }
            } else {
                TranslateMessage(&msg);
                DispatchMessage(&msg);
            }
        }
 
        std::this_thread::sleep_for(
            std::chrono::milliseconds(static_cast<int>(server_loop_rate * 1000.0F)));
    }
 
#else
    while (!m_shutdown_requested.load(std::memory_order_acquire) && (!external_flag || external_flag->load(std::memory_order_acquire))) {
        if (!is_server_running()) {
            LILA_ERROR(Emitter::SYSTEM, "Server stopped unexpectedly");
            break;
        }
        std::this_thread::sleep_for(std::chrono::milliseconds(static_cast<int>(server_loop_rate * 1000)));
    }
#endif
 
    LILA_INFO(Emitter::SYSTEM, "Exiting main event loop");
}

References LILA_ERROR, and LILA_INFO.

Referenced by main().

Here is the caller graph for this function: