start()

void MayaFlux::Core::NetworkSubsystem::start ( )

overridevirtual

Start the subsystem's processing/event loops.

Begins active processing. After this call, the subsystem should be actively responding to callbacks and processing data according to its domain requirements.

Implements MayaFlux::Core::ISubsystem.

Definition at line 65 of file NetworkSubsystem.cpp.

{
    if (!m_ready.load()) {
        MF_ERROR(Journal::Component::Core, Journal::Context::Init,
            "Cannot start NetworkSubsystem: not initialized");
        return;
    }
 
    if (m_running.load()) {
        return;
    }
 
    {
        std::shared_lock lock(m_backends_mutex);
        for (auto& [transport, backend] : m_backends) {
            backend->start();
        }
    }
 
    m_work_guard = std::make_unique<asio::executor_work_guard<asio::io_context::executor_type>>(
        m_io_context->get_executor());
 
#if MAYAFLUX_USE_JTHREAD
    m_io_thread = std::jthread([this](const std::stop_token& token) {
        while (!token.stop_requested()) {
            try {
                m_io_context->run();
                break;
            } catch (const std::exception& e) {
                MF_ERROR(Journal::Component::Core, Journal::Context::Init,
                    "IO context exception: {}", e.what());
            }
        }
 
        MF_DEBUG(Journal::Component::Core, Journal::Context::Init,
            "Network IO thread exiting");
    });
#else
    m_io_stop_requested.store(false);
    m_io_thread = std::thread([this]() {
        while (!m_io_stop_requested.load()) {
            try {
                m_io_context->run();
                break;
            } catch (const std::exception& e) {
                MF_ERROR(Journal::Component::Core, Journal::Context::Networking,
                    "IO context exception: {}", e.what());
            }
        }
 
        MF_DEBUG(Journal::Component::Core, Journal::Context::Init,
            "Network IO thread exiting");
    });
#endif
 
    m_running.store(true);
 
    MF_INFO(Journal::Component::Core, Journal::Context::Init,
        "Network Subsystem started");
}

References MayaFlux::Journal::Core, MayaFlux::Journal::Init, m_backends, m_backends_mutex, m_io_context, m_io_thread, m_ready, m_running, m_work_guard, MF_DEBUG, and MF_ERROR.