stop()

void MayaFlux::Core::TCPBackend::stop ( )

overridevirtual

Stop receive threads without releasing resources.

Endpoints remain valid. Pending sends complete. Receive callbacks cease until start() is called again.

Implements MayaFlux::Core::INetworkBackend.

Definition at line 55 of file TCPBackend.cpp.

{
    if (!m_running.load()) {
        return;
    }
 
    m_running.store(false);
 
    {
        std::shared_lock lock(m_connections_mutex);
        for (auto& [id, conn] : m_connections) {
            asio::error_code ec;
 
            if (conn->socket.close(ec)) {
                MF_WARN(Journal::Component::Core, Journal::Context::NetworkBackend,
                    "Error closing TCP connection {}: {}", id, ec.message());
            }
 
            if (conn->reconnect_timer) {
                conn->reconnect_timer->cancel();
            }
        }
    }
 
    {
        std::shared_lock lock(m_listeners_mutex);
        for (auto& [id, listener] : m_listeners) {
            asio::error_code ec;
            if (!listener->acceptor.close(ec)) {
                MF_WARN(Journal::Component::Core, Journal::Context::NetworkBackend,
                    "Error closing TCP listener {}: {}", id, ec.message());
            }
        }
    }
 
    MF_DEBUG(Journal::Component::Core, Journal::Context::Shutdown,
        "TCP backend stopped");
}

References MayaFlux::Journal::Core, m_connections, m_connections_mutex, m_listeners, m_listeners_mutex, m_running, MF_DEBUG, MF_WARN, MayaFlux::Journal::NetworkBackend, and MayaFlux::Journal::Shutdown.

Referenced by shutdown().

Here is the caller graph for this function: