close_endpoint()

void MayaFlux::Core::TCPBackend::close_endpoint ( uint64_t  endpoint_id )

overridevirtual

Close an endpoint and release its resources.

Parameters

endpoint_id

Endpoint to close. No-op if already closed.

Implements MayaFlux::Core::INetworkBackend.

Definition at line 196 of file TCPBackend.cpp.

{
    {
        std::unique_lock lock(m_connections_mutex);
        auto it = m_connections.find(endpoint_id);
        if (it != m_connections.end()) {
            asio::error_code ec;
 
            if (!it->second->socket.close(ec)) {
                MF_WARN(Journal::Component::Core, Journal::Context::NetworkBackend,
                    "Error closing TCP connection {}: {}", endpoint_id, ec.message());
            }
 
            if (it->second->reconnect_timer) {
                it->second->reconnect_timer->cancel();
            }
            m_connections.erase(it);
 
            MF_DEBUG(Journal::Component::Core, Journal::Context::NetworkBackend,
                "TCP connection {} closed", endpoint_id);
            return;
        }
    }
 
    {
        std::unique_lock lock(m_listeners_mutex);
        auto it = m_listeners.find(endpoint_id);
        if (it != m_listeners.end()) {
            asio::error_code ec;
 
            if (it->second->acceptor.close(ec)) {
                MF_WARN(Journal::Component::Core, Journal::Context::NetworkBackend,
                    "Error closing TCP listener {}: {}", endpoint_id, ec.message());
            }
 
            m_listeners.erase(it);
 
            MF_DEBUG(Journal::Component::Core, Journal::Context::NetworkBackend,
                "TCP listener {} closed", endpoint_id);
        }
    }
}

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