Function sml_ProcessMessage

Core/KernelSML/src/KernelSMLInterface.cpp:88–155

}

ElementXML_Handle sml_ProcessMessage(Connection_Receiver_Handle hReceiverConnection, ElementXML_Handle hIncomingMsg, int action)
{
    EmbeddedConnection* pConnection = GetConnectionFromHandle(hReceiverConnection) ;
    
    if (action == SML_MESSAGE_ACTION_CLOSE)
    {
        if (pConnection)
        {
            // Close our connection to the remote process
            pConnection->ClearConnectionHandle() ;
            
            // When the embedded connection disconnects we're about to exit the application
            // so shutdown any remote connections cleanly and do any other cleanup.
            KernelSML* pKernelSML = reinterpret_cast<KernelSML*>(pConnection->GetUserData());
            assert(pKernelSML);
            pKernelSML->Shutdown() ;
            
            // The shutdown call above will also delete our connection object as part of its cleanup
            // so set it to NULL here to make sure we don't try to use it again.
            pConnection = NULL ;
            
            delete pKernelSML;
        }
        
        return NULL ;
    }
    
    if (action == SML_MESSAGE_ACTION_SYNCH)
    {
        // Create an object to wrap this message.
        // When this object is deleted, it releases our reference to this handle.
        soarxml::ElementXML incomingMsg(hIncomingMsg) ;
        
        soarxml::ElementXML* pResponse = pConnection->InvokeCallbacks(&incomingMsg) ;
        
        if (!pResponse)
        {
            return NULL ;
        }
        
        ElementXML_Handle hResponse = pResponse->Detach() ;
        delete pResponse ;
        return hResponse ;
    }
    
    if (action == SML_MESSAGE_ACTION_ASYNCH)
    {
        // Store the incoming message on a queue and execute it on the receiver's thread (our thread) at a later point.
        EmbeddedConnectionAsynch* eca = static_cast<EmbeddedConnectionAsynch*>(pConnection);
        eca->AddToIncomingMessageQueue(hIncomingMsg) ;
        
        // There is no immediate response to an asynch message.
        // The response will be sent back to the caller as another asynch message later, once the command has been executed.
        return NULL ;
    }
    
    if (action == SML_MESSAGE_ACTION_TRACE_ON || action == SML_MESSAGE_ACTION_TRACE_OFF)
    {