Method Shutdown

Core/KernelSML/src/sml_ConnectionManager.cpp:89–147

Close all connections

// Close all connections
void ConnectionManager::Shutdown()
{
//  sml::PrintDebug("Shutting down connection manager") ;

    // Stop the thread (and wait until it has stopped)
    if (m_ListenerThread)
    {
        m_ListenerThread->Stop(true) ;
        
        // Remove the listener
        delete m_ListenerThread ;
        m_ListenerThread = NULL ;
    }
    
//  sml::PrintDebug("Listener stopped") ;

    // Stop the receiver thread (and wait until is has stopped)
    if (m_ReceiverThread)
    {
        m_ReceiverThread->Stop(true) ;
        
        //  sml::PrintDebug("Receiver stopped") ;
        
        // Remove the thread
        delete m_ReceiverThread ;
        m_ReceiverThread = NULL ;
    }
    
    // Serialize thread access to the connections list
    soar_thread::Lock lock(&m_ConnectionsMutex) ;
    
    for (ConnectionsIter iter = m_Connections.begin() ; iter != m_Connections.end() ; iter++)
    {
        Connection* pConnection = *iter ;
        pConnection->CloseConnection() ;
        
        // Remove any events that this connection is listening to
        KernelSML* pKernelSML = static_cast<KernelSML*>(pConnection->GetUserData());
        pKernelSML->RemoveAllListeners(pConnection) ;
        
        // Not clear that we can just delete connections as we might be inside a connection callback
        // when the shutdown comes.  So for safety, move connections to a closed list instead of deleting.
        // For now this will leak the connection object.  Later if we are confident we can delete this list.
        //delete pConnection ;
        m_ClosedConnections.push_back(pConnection) ;
    }
    
    m_Connections.clear() ;
    
    // Now clean up all closed connections.
    for (ConnectionsIter iter = m_ClosedConnections.begin() ; iter != m_ClosedConnections.end() ; iter++)
    {
        Connection* pConnection = *iter ;
        delete pConnection ;
    }
    m_ClosedConnections.clear() ;
    
//  sml::PrintDebug("Completed shutdown") ;